HR integration

• ACCESS_TOKEN: It is the token that identifies the 4hse user who will perform the operation, an admin of the project.
• PROJECT_ID: It is the ID of the project we have just created.
• PRIMARY_KEY: It is the column in the CSV that uniquely identifies an employee. We have chosen “tax_code.”
• EMULATION: It allows us to execute the request in emulation mode. This means we can perform the sync and obtain the results without actually making the changes. This allows us to test the outcome of the operation before applying it. We will initially set this value to TRUE.
• MAX_CHANGES: It is a security parameter that controls the maximum number of changes applicable in the request. If the total number of changes made exceeds this value, we will be alerted, and the request will be rejected. We initially set it to 150.

Now let’s define the createTask method, which will be used to create the synchronization task at the people-sync service of 4hse. The creation of the task is a simple HTTP POST request to the server, which responds with a task_id. The task ID is an identifier for the task that allows us to query the server to know its progress (queued, executed, etc.).

The method only requires the input of the file name to synchronize and provides the output of the created task ID.

private static String createTask(String filePath) throws IOException {
 ...
}

The first thing to do is to instantiate an HTTP client for sending the request.

private static String createTask(String filePath) throws IOException {
 HttpClient httpClient = HttpClients.createDefault();
 HttpPost httpPost = new HttpPost("http://localhost:8081/people-sync/create");
}

Since we need to send a file, the data must be transmitted in multipart format. Let’s populate the body of the multipart request by providing the file and the remaining input parameters:

private static String createTask(String filePath) throws IOException {
 HttpClient httpClient = HttpClients.createDefault();
 HttpPost httpPost = new HttpPost("http://localhost:8081/people-sync/create");

 MultipartEntityBuilder builder = MultipartEntityBuilder.create();

 // Add file parameter
 builder.addBinaryBody("file", new File(filePath), 
ContentType.APPLICATION_OCTET_STREAM, "file.csv");

 // Add other parameters
 builder.addTextBody("access-token", ACCESS_TOKEN);
 builder.addTextBody("project_id", PROJECT_ID);
 builder.addTextBody("pk", PRIMARY_KEY);
 builder.addTextBody("emulation", String.valueOf(EMULATION));
 builder.addTextBody("max_changes", String.valueOf(MAX_CHANGES));

 HttpEntity multipart = builder.build();
 httpPost.setEntity(multipart);
}

Finally, we execute the request. In case of success, the server will respond with a JSON that needs to be parsed to obtain the task_id, which we will return as output. In case of failure, we print the error on the screen.