Notes

import axios from 'axios';
import { handleApiResponse, axiosInstance } from 'utils/networkUtils';
import { CATALOGUE_SERVICE } from './constants';

const INGESTION_JOB_BASE_URL = `${CATALOGUE_SERVICE}/ingestionJob`;
const PICKLIST_SERVICE = `${CATALOGUE_SERVICE}/picklist`;

const getIngestionJobs = (params: {
connectionName: String;
page: number;
limit: number;
}) =>
axiosInstance
.get(`${INGESTION_JOB_BASE_URL}`, { params })
.then((res) => handleApiResponse(res))
.catch((err) => handleApiResponse(err));

const getAllIngestionJobs = (params: { page: number; limit: number }) =>
axiosInstance
.get(`${INGESTION_JOB_BASE_URL}/all`, { params })
.then((res) => handleApiResponse(res))
.catch((err) => handleApiResponse(err));

const getIngestionJobById = (ingestionJobId: String, connectionName: String) =>
axiosInstance
.get(`${INGESTION_JOB_BASE_URL}/${ingestionJobId}`, {
params: { connectionName },
})
.then((res) => handleApiResponse(res))
.catch((err) => handleApiResponse(err));

const searchIngestionJobs = (
connectionName: String,
ingestionJobName: String,
) =>
axiosInstance
.get(`${INGESTION_JOB_BASE_URL}/_search`, {
params: { query: ingestionJobName, connectionName },
})
.then((res) => handleApiResponse(res))
.catch((err) => handleApiResponse(err));

const mapUserToIngestionJob = (params: any) =>
axiosInstance
.post(`${INGESTION_JOB_BASE_URL}/map_user`, { subDataset: params })
.then((res) => handleApiResponse(res))
.catch((err) => handleApiResponse(err));

const unmapUserToIngestionJob = (params: any) =>
axiosInstance
.delete(`${INGESTION_JOB_BASE_URL}/delete_mapping`, {
data: { mapUserdata: params },
})
.then((res) => handleApiResponse(res))
.catch((err) => handleApiResponse(err));

const checkMilestones = (
dataSourceId: string | number,
objectId: string | number,
flowType: String,
) =>
axiosInstance
.get(
`${INGESTION_JOB_BASE_URL}/get_milestones/${flowType}/${dataSourceId}/${objectId}`,
)
.then((res) => handleApiResponse(res))
.catch((err) => handleApiResponse(err));

const deleteIngestionJob = (connectionId: String, ingestionJobId: String) =>
axiosInstance
.delete(`${INGESTION_JOB_BASE_URL}/${connectionId}/${ingestionJobId}`)
.then((res) => handleApiResponse(res))
.catch((err) => handleApiResponse(err));

const getPreviewData = (params: { ingestionJobId: Number }) =>
axiosInstance
.get(`${INGESTION_JOB_BASE_URL}/preview_data`, {
params,
})
.then((res) => handleApiResponse(res))
.catch((err) => handleApiResponse(err));

const getObjectField = (params: { ingestionJobId: Number }) =>
axiosInstance
.get(`${INGESTION_JOB_BASE_URL}/object_fields`, {
params,
})
.then((res) => handleApiResponse(res))
.catch((err) => handleApiResponse(err));

const deletePreviewCoulmns = (params: any) =>
axiosInstance
.delete(`${INGESTION_JOB_BASE_URL}/preview_columns/`, { data: params })
.then((res) => handleApiResponse(res))
.catch((err) => handleApiResponse(err));

const saveIngestionJob = (payload: any) =>
axiosInstance
.post(`${INGESTION_JOB_BASE_URL}/save`, { ingestionJob: payload })
.then((response) => handleApiResponse(response))
.catch((error) => handleApiResponse(error));

const downloadSampleTemplate = (objectId: any) =>
axios
.get(`${INGESTION_JOB_BASE_URL}/${objectId}/sampleTemplate.csv`, {
headers: {
'Content-Type': 'application/csv',
},
})
.then((response) => handleApiResponse(response))
.then((blob) => {
const url = window.URL.createObjectURL(new Blob([blob]));
const link = document.createElement('a');
link.href = url;
link.setAttribute('download', `sampleTemplate.csv`);
document.body.appendChild(link);
link.click();
link?.parentNode?.removeChild(link);
})
.catch((error) => {
if (axios.isCancel(error)) {
return 'canceled';
}
return handleApiResponse(error);
});

const uploadHeaderFile = (formData: any) =>
axios
.post(`${INGESTION_JOB_BASE_URL}/upload`, formData, {
headers: { 'Content-Type': 'multipart/form-data' },
})
.then((response) => handleApiResponse(response))
.catch((error) => handleApiResponse(error));

const getHrcSoColumn = (objectId: any) =>
axios
.get(`${INGESTION_JOB_BASE_URL}/${objectId}/object_columns`)
.then((response) => handleApiResponse(response))
.catch((error) => handleApiResponse(error));

const getPicklistValues = () =>
axios
.get(`${PICKLIST_SERVICE}/input_date_format`)
.then((response) => handleApiResponse(response))
.catch((error) => handleApiResponse(error));

const editUserNotification = (ingestionJobId, userIds) =>
axios
.put(`${INGESTION_JOB_BASE_URL}/edit_user_notification`, {
ingestionJobUserNotification: { ingestionJobId, userIds },
})
.then((response) => handleApiResponse(response))
.catch((error) => handleApiResponse(error));

const editIngestionJobDescription = (ingestionJobId, description) =>
axios
.put(`${INGESTION_JOB_BASE_URL}/update_description`, null, {
params: { ingestionJobId, description },
})
.then((response) => handleApiResponse(response))
.catch((error) => handleApiResponse(error));
const checkDuplicateIngestionJob = (payload: any) =>
axiosInstance
.post(`${INGESTION_JOB_BASE_URL}/check_duplicate`, {
ingestionJob: payload,
})
.then((response) => handleApiResponse(response))
.catch((error) => handleApiResponse(error));

export default {
getIngestionJobs,
getAllIngestionJobs,
getIngestionJobById,
searchIngestionJobs,
mapUserToIngestionJob,
unmapUserToIngestionJob,
checkMilestones,
deleteIngestionJob,
getPreviewData,
getObjectField,
deletePreviewCoulmns,
saveIngestionJob,
downloadSampleTemplate,
uploadHeaderFile,
getHrcSoColumn,
getPicklistValues,
editUserNotification,
editIngestionJobDescription,
checkDuplicateIngestionJob,
};