import { GraphQLError } from 'graphql';
import { Injector } from 'graphql-modules';
import { ChargeTagsProvider } from '../../tags/providers/charge-tags.provider.js';
import { TagsProvider } from '../../tags/providers/tags.provider.js';
import { ChargesProvider } from '../providers/charges.provider.js';
import { IGetChargesByIdsResult } from '../types.js';

const FINANCIAL_TAG_NAME = 'financial';

export async function generateAndTagCharge(
  injector: Injector,
  ownerId: string,
  taxCategoryId: string,
  description: string,
): Promise<IGetChargesByIdsResult> {
  const charge = await injector.get(ChargesProvider).generateCharge({
    ownerId,
    userDescription: description,
    type: 'FINANCIAL',
    taxCategoryId,
  });

  if (!charge) {
    throw new Error('Error creating new charge');
  }

  const extendedChargePromise = injector.get(ChargesProvider).getChargeByIdLoader.load(charge.id);

  const tagPromise = (async () => {
    const tag = await injector
      .get(TagsProvider)
      .getTagByNameLoader.load(FINANCIAL_TAG_NAME)
      .catch(() => {
        throw new GraphQLError(`Error finding "${FINANCIAL_TAG_NAME}" tag`);
      });

    if (!tag) {
      throw new GraphQLError(`"${FINANCIAL_TAG_NAME}" tag not found`);
    }

    await injector
      .get(ChargeTagsProvider)
      .insertChargeTag({ chargeId: charge.id, tagId: tag.id })
      .catch(() => {
        throw new GraphQLError(
          `Error adding "${FINANCIAL_TAG_NAME}" tag to charge ID="${charge.id}"`,
        );
      });
  })();

  const [extendedCharge] = await Promise.all([extendedChargePromise, tagPromise]);

  if (!extendedCharge) {
    throw new Error('Error creating new charge');
  }

  return extendedCharge;
}