import { GraphQLError } from 'graphql';
import { Injector } from 'graphql-modules';
import { BusinessTripEmployeePaymentsProvider } from '../../business-trips/providers/business-trips-employee-payments.provider.js';
import { DocumentsProvider } from '../../documents/providers/documents.provider.js';
import { LedgerProvider } from '../../ledger/providers/ledger.provider.js';
import { MiscExpensesProvider } from '../../misc-expenses/providers/misc-expenses.provider.js';
import { TransactionsProvider } from '../../transactions/providers/transactions.provider.js';
import { deleteCharges } from './delete-charges.helper.js';

export const mergeChargesExecutor = async (
  chargeIdsToMerge: readonly string[],
  baseChargeID: string,
  injector: Injector,
) => {
  try {
    const chargeCleaner = chargeIdsToMerge.map(id => {
      // update linked documents
      const replaceDocumentsChargeIdPromise = injector
        .get(DocumentsProvider)
        .replaceDocumentsChargeId({
          replaceChargeID: id,
          assertChargeID: baseChargeID,
        });

      // update linked transactions
      const replaceTransactionsChargeIdPromise = injector
        .get(TransactionsProvider)
        .replaceTransactionsChargeId({
          replaceChargeID: id,
          assertChargeID: baseChargeID,
        });

      // update linked ledger records
      const replaceLedgerRecordsChargeIdPromise = injector
        .get(LedgerProvider)
        .replaceLedgerRecordsChargeId({
          replaceChargeID: id,
          assertChargeID: baseChargeID,
        });

      // update linked misc expenses
      const replaceMiscExpensesChargeIdPromise = injector
        .get(MiscExpensesProvider)
        .replaceMiscExpensesChargeId({
          replaceChargeID: id,
          assertChargeID: baseChargeID,
        });

      // update linked business trips employee payments
      const replaceBusinessTripsEmployeePaymentsChargeIdPromise = injector
        .get(BusinessTripEmployeePaymentsProvider)
        .replaceBusinessTripsEmployeePaymentsChargeId({
          replaceChargeID: id,
          assertChargeID: baseChargeID,
        });

      return Promise.all([
        replaceDocumentsChargeIdPromise,
        replaceTransactionsChargeIdPromise,
        replaceLedgerRecordsChargeIdPromise,
        replaceMiscExpensesChargeIdPromise,
        replaceBusinessTripsEmployeePaymentsChargeIdPromise,
      ]);
    });

    await Promise.all(chargeCleaner);

    // delete charge
    await deleteCharges([...chargeIdsToMerge], injector);
  } catch (e) {
    if (e instanceof GraphQLError) {
      throw e;
    }
    throw new GraphQLError(`Failed to merge charges: ${e}`);
  }
};