2024-08-01 13:13:33 +03:00

40 lines
1.5 KiB
TypeScript

import { protectedProcedure } from '../../procedure';
import { router } from '../../trpc';
import { EltInputSchema, EltOutputSchema } from './types';
import { getEltKasko } from '@/api/elt/query';
import initializeApollo from '@/apollo/client';
import { makeEltKaskoRequest } from '@/Components/Calculation/Form/ELT/lib/make-request';
import { convertEltKaskoResponse } from '@/Components/Calculation/Form/ELT/lib/process-response';
import eltHelper from '@/process/elt/lib/helper';
import RootStore from '@/stores/root';
import { createTRPCError } from '@/utils/trpc';
export const eltKaskoRouter = router({
eltKasko: protectedProcedure
.input(EltInputSchema)
.output(EltOutputSchema)
.mutation(async ({ input }) => {
try {
const apolloClient = initializeApollo();
const store = new RootStore();
store.$calculation.$values.hydrate(input.calculation.values);
const { init: initElt } = await eltHelper({ apolloClient, store });
const { kasko: initRows } = await initElt();
const requests = initRows.map(async (row) => {
const eltRequest = await makeEltKaskoRequest({ apolloClient, store }, row);
const eltResponse = await getEltKasko(eltRequest);
return convertEltKaskoResponse(eltResponse, row, input.calculation.values);
});
return {
rows: await Promise.all(requests),
};
} catch (error) {
throw createTRPCError(error);
}
}),
});