import { CreateSourceBody, getSources, ListSourcesQueryParams, UpdateSourceBody, } from '@webitel/api-services/gen'; import { getShallowFieldsToSendFromZodSchema } from '@webitel/api-services/gen/utils'; import { getDefaultGetListResponse, getDefaultGetParams } from '../../defaults'; import { applyTransform, camelToSnake, merge, notify, sanitize, snakeToCamel, } from '../../transformers'; const getSourcesList = async (params) => { const fieldsToSend = getShallowFieldsToSendFromZodSchema( ListSourcesQueryParams, ); const { page, size, fields, sort, id, q, type } = applyTransform(params, [ merge(getDefaultGetParams()), sanitize(fieldsToSend), camelToSnake(), ]); try { const response = await getSources().listSources({ page, size, fields, sort, id, q: q || params.search, type, }); const { items, next } = applyTransform(response.data, [ merge(getDefaultGetListResponse()), ]); return { items: applyTransform(items, []), next, }; } catch (err) { throw applyTransform(err, [ notify, ]); } }; const getSource = async ({ itemId: id }) => { const itemResponseHandler = (item) => item.source; // TODO wtf?? try { const response = await getSources().locateSource(id); return applyTransform(response.data, [ snakeToCamel(), itemResponseHandler, ]); } catch (err) { throw applyTransform(err, [ notify, ]); } }; const addSource = async ({ itemInstance }) => { const item = applyTransform(itemInstance, [ sanitize(getShallowFieldsToSendFromZodSchema(CreateSourceBody)), camelToSnake(), ]); try { const response = await getSources().createSource(item); return applyTransform(response.data, [ snakeToCamel(), ]); } catch (err) { throw applyTransform(err, [ notify, ]); } }; const updateSource = async ({ itemInstance, itemId: id }) => { const item = applyTransform(itemInstance, [ sanitize(getShallowFieldsToSendFromZodSchema(UpdateSourceBody)), camelToSnake(), ]); try { const response = await getSources().updateSource(id, item); return applyTransform(response.data, [ snakeToCamel(), ]); } catch (err) { throw applyTransform(err, [ notify, ]); } }; const deleteSource = async ({ id }) => { try { const response = await getSources().deleteSource(id); return applyTransform(response.data, []); } catch (err) { throw applyTransform(err, [ notify, ]); } }; const getLookup = (params) => getSourcesList({ ...params, fields: params.fields || [ 'id', 'name', 'type', ], }); export const CaseSourcesAPI = { getList: getSourcesList, get: getSource, add: addSource, update: updateSource, delete: deleteSource, getLookup, };