zapishis-client/packages/graphql/api/orders.ts

import { getClientWithToken } from '../apollo/client';
import * as GQL from '../types';
import { BaseService } from './base';
import { CustomersService } from './customers';
import { ServicesService } from './services';
import { type VariablesOf } from '@graphql-typed-document-node/core';
import { isCustomerMaster } from '@repo/utils/customer';
import { getMinutes } from '@repo/utils/datetime-format';
import dayjs from 'dayjs';

const ERRORS = {
  INVALID_SERVICE_DURATION: 'Invalid service duration',
  MISSING_CLIENT: 'Missing client',
  MISSING_ORDER: 'Order not found',
  MISSING_SERVICE_ID: 'Missing service id',
  MISSING_SERVICES: 'Missing services',
  MISSING_SLOT: 'Missing slot id',
  MISSING_START_TIME: 'Missing time start',
  MISSING_USER: 'User not found',
  NO_PERMISSION: 'No permission',
};

export class OrdersService extends BaseService {
  async createOrder(variables: VariablesOf<typeof GQL.CreateOrderDocument>) {
    // Проверки на существование обязательных полей для предотвращения ошибок типов
    if (!variables.input.slot) throw new Error(ERRORS.MISSING_SLOT);
    if (!variables.input.services?.length) throw new Error(ERRORS.MISSING_SERVICES);
    if (!variables.input.services[0]) throw new Error(ERRORS.MISSING_SERVICE_ID);
    if (!variables.input.datetime_start) throw new Error(ERRORS.MISSING_START_TIME);
    if (!variables.input.client) throw new Error(ERRORS.MISSING_CLIENT);

    const customersService = new CustomersService(this.customer);
    const servicesService = new ServicesService(this.customer);

    const { customer } = await customersService.getCustomer(this.customer);
    if (!customer) throw new Error(ERRORS.MISSING_USER);

    const { service } = await servicesService.getService({
      documentId: variables.input.services[0],
    });
    if (!service?.duration) throw new Error(ERRORS.INVALID_SERVICE_DURATION);

    const datetimeEnd = dayjs(variables.input.datetime_start)
      .add(getMinutes(service.duration), 'minute')
      .toISOString();

    const { mutate } = await getClientWithToken();

    const mutationResult = await mutate({
      mutation: GQL.CreateOrderDocument,
      variables: {
        ...variables,
        input: {
          ...variables.input,
          datetime_end: datetimeEnd,
          state: isCustomerMaster(customer)
            ? GQL.Enum_Order_State.Approved
            : GQL.Enum_Order_State.Created,
        },
      },
    });

    const error = mutationResult.errors?.at(0);
    if (error) throw new Error(error.message);

    return mutationResult.data;
  }

  async getOrder(variables: VariablesOf<typeof GQL.GetOrderDocument>) {
    const { query } = await getClientWithToken();

    const result = await query({
      query: GQL.GetOrderDocument,
      variables,
    });

    return result.data;
  }

  async getOrders(variables: VariablesOf<typeof GQL.GetOrdersDocument>) {
    const { query } = await getClientWithToken();

    const result = await query({
      query: GQL.GetOrdersDocument,
      variables,
    });

    return result.data;
  }

  async updateOrder(variables: VariablesOf<typeof GQL.UpdateOrderDocument>) {
    const customersService = new CustomersService(this.customer);
    const { customer } = await customersService.getCustomer(this.customer);

    if (!customer) throw new Error(ERRORS.MISSING_USER);

    const { query } = await getClientWithToken();

    const {
      data: { order },
    } = await query({
      query: GQL.GetOrderDocument,
      variables: { documentId: variables.documentId },
    });

    if (!order) throw new Error(ERRORS.MISSING_ORDER);

    const isOrderClient = order.client?.documentId === customer.documentId;
    const isOrderMaster = order.slot?.master?.documentId === customer.documentId;

    if (!isOrderClient && !isOrderMaster) throw new Error(ERRORS.NO_PERMISSION);

    if (isOrderClient && Object.keys(variables.data).length > 1)
      throw new Error(ERRORS.NO_PERMISSION);

    if (
      isOrderClient &&
      variables.data.state &&
      variables.data.state !== GQL.Enum_Order_State.Cancelling
    ) {
      throw new Error(ERRORS.NO_PERMISSION);
    }

    const { mutate } = await getClientWithToken();

    const mutationResult = await mutate({
      mutation: GQL.UpdateOrderDocument,
      variables,
    });

    const error = mutationResult.errors?.at(0);
    if (error) throw new Error(error.message);

    return mutationResult.data;
  }
}