import { eventResponsetypes, UserCredentials } from '../types';
import { url } from '../utils/Utils';
export function triggerStatusUpdateAPI(
name: string,
userCredentials: UserCredentials,
datahandler: (i: eventResponsetypes) => void
) {
const params = new URLSearchParams();
if (userCredentials.uri) {
params.append('uri', userCredentials.uri);
}
if (userCredentials.database) {
params.append('database', userCredentials.database);
}
if (userCredentials.userName) {
params.append('userName', userCredentials.userName);
}
if (userCredentials.password) {
params.append('password', btoa(userCredentials.password));
}
const queryString = params.toString();
const requestUrl = queryString
? `${url()}/update_extract_status/${name}?${queryString}`
: `${url()}/update_extract_status/${name}`;
const eventSource = new EventSource(requestUrl);
eventSource.onmessage = (event) => {
const eventResponse = JSON.parse(event.data);
if (
eventResponse.status === 'Completed' ||
eventResponse.status === 'Failed' ||
eventResponse.status === 'Cancelled'
) {
datahandler(eventResponse);
eventSource.close();
} else {
datahandler(eventResponse);
}
};
}
