FactuGES_ERP/modules/customers/src/web/shared/hooks/use-customer-create-mutation.ts

import { useDataSource } from "@erp/core/hooks";
import { UniqueID, ValidationErrorCollection } from "@repo/rdx-ddd";
import { type DefaultError, useMutation, useQueryClient } from "@tanstack/react-query";

import { CreateCustomerRequestSchema } from "../../../common";
import { GetCustomerByIdAdapter } from "../adapters";
import { type CreateCustomerParams, type CreateCustomerResult, createCustomer } from "../api";
import type { Customer } from "../entities";

import {
  invalidateCustomerListQueries,
  syncCreatedCustomerCaches,
} from "./customer-cache-strategy";
import { CUSTOMER_CREATE_KEY } from "./keys";
import { toValidationErrors } from "./to-validation-errors";

type CreateCustomerContext = {};

export const useCustomerCreateMutation = () => {
  const queryClient = useQueryClient();
  const dataSource = useDataSource();
  const schema = CreateCustomerRequestSchema;

  return useMutation<Customer, DefaultError, CreateCustomerParams, CreateCustomerContext>({
    mutationKey: CUSTOMER_CREATE_KEY,

    mutationFn: async (payload) => {
      const id = UniqueID.generateNewID().toString();
      const payloadWithId: CreateCustomerParams = { ...payload, id };

      const result = schema.safeParse(payloadWithId);
      if (!result.success) {
        throw new ValidationErrorCollection("Validation failed", toValidationErrors(result.error));
      }

      const dto: CreateCustomerResult = await createCustomer(dataSource, payloadWithId);
      return GetCustomerByIdAdapter.fromDTO(dto);
    },

    onSuccess: (createdCustomer) => {
      syncCreatedCustomerCaches(queryClient, createdCustomer);
    },
    onSettled: async () => {
      await invalidateCustomerListQueries(queryClient);
    },
  });
};