import { nanoid } from '@documenso/lib/universal/id';
import { prisma } from '@documenso/prisma';
import type { Field } from '@documenso/prisma/client';
import { type Recipient, WebhookTriggerEvents } from '@documenso/prisma/client';

import { DOCUMENT_AUDIT_LOG_TYPE } from '../../types/document-audit-logs';
import type { RequestMetadata } from '../../universal/extract-request-metadata';
import { createDocumentAuditLogData } from '../../utils/document-audit-logs';
import { triggerWebhook } from '../webhooks/trigger/trigger-webhook';

type RecipientWithId = {
  id: number;
  name?: string;
  email: string;
};

type FinalRecipient = Pick<Recipient, 'name' | 'email' | 'role'> & {
  templateRecipientId: number;
  fields: Field[];
};

export type CreateDocumentFromTemplateOptions = {
  templateId: number;
  userId: number;
  teamId?: number;
  recipients:
    | RecipientWithId[]
    | {
        name?: string;
        email: string;
      }[];
  requestMetadata?: RequestMetadata;
};

export const createDocumentFromTemplate = async ({
  templateId,
  userId,
  teamId,
  recipients,
  requestMetadata,
}: CreateDocumentFromTemplateOptions) => {
  const user = await prisma.user.findFirstOrThrow({
    where: {
      id: userId,
    },
  });

  const template = await prisma.template.findUnique({
    where: {
      id: templateId,
      ...(teamId
        ? {
            team: {
              id: teamId,
              members: {
                some: {
                  userId,
                },
              },
            },
          }
        : {
            userId,
            teamId: null,
          }),
    },
    include: {
      Recipient: {
        include: {
          Field: true,
        },
      },
      templateDocumentData: true,
    },
  });

  if (!template) {
    throw new Error('Template not found.');
  }

  if (recipients.length !== template.Recipient.length) {
    throw new Error('Invalid number of recipients.');
  }

  let finalRecipients: FinalRecipient[] = [];

  if (recipients.length > 0 && Object.prototype.hasOwnProperty.call(recipients[0], 'id')) {
    finalRecipients = template.Recipient.map((templateRecipient) => {
      // eslint-disable-next-line @typescript-eslint/consistent-type-assertions
      const foundRecipient = (recipients as RecipientWithId[]).find(
        (recipient) => recipient.id === templateRecipient.id,
      );

      if (!foundRecipient) {
        throw new Error('Recipient not found.');
      }

      return {
        templateRecipientId: templateRecipient.id,
        fields: templateRecipient.Field,
        name: foundRecipient.name ?? '',
        email: foundRecipient.email,
        role: templateRecipient.role,
      };
    });
  } else {
    // Backwards compatible logic for /v1/ API where we use the index to associate
    // the provided recipient with the template recipient.
    finalRecipients = recipients.map((recipient, index) => ({
      templateRecipientId: template.Recipient[index].id,
      fields: template.Recipient[index].Field,
      name: recipient.name ?? '',
      email: recipient.email,
      role: template.Recipient[index].role,
    }));
  }

  const documentData = await prisma.documentData.create({
    data: {
      type: template.templateDocumentData.type,
      data: template.templateDocumentData.data,
      initialData: template.templateDocumentData.initialData,
    },
  });

  return await prisma.$transaction(async (tx) => {
    const document = await tx.document.create({
      data: {
        userId,
        teamId: template.teamId,
        title: template.title,
        documentDataId: documentData.id,
        Recipient: {
          createMany: {
            data: finalRecipients.map((recipient) => ({
              email: recipient.email,
              name: recipient.name,
              role: recipient.role,
              token: nanoid(),
            })),
          },
        },
      },
      include: {
        Recipient: {
          orderBy: {
            id: 'asc',
          },
        },
        documentData: true,
      },
    });

    let fieldsToCreate: Omit<Field, 'id' | 'secondaryId' | 'templateId'>[] = [];

    Object.values(finalRecipients).forEach(({ email, fields }) => {
      const recipient = document.Recipient.find((recipient) => recipient.email === email);

      if (!recipient) {
        throw new Error('Recipient not found.');
      }

      fieldsToCreate = fieldsToCreate.concat(
        fields.map((field) => ({
          documentId: document.id,
          recipientId: recipient.id,
          type: field.type,
          page: field.page,
          positionX: field.positionX,
          positionY: field.positionY,
          width: field.width,
          height: field.height,
          customText: '',
          inserted: false,
        })),
      );
    });

    await tx.field.createMany({
      data: fieldsToCreate,
    });

    await tx.documentAuditLog.create({
      data: createDocumentAuditLogData({
        type: DOCUMENT_AUDIT_LOG_TYPE.DOCUMENT_CREATED,
        documentId: document.id,
        user,
        requestMetadata,
        data: {
          title: document.title,
        },
      }),
    });

    await triggerWebhook({
      event: WebhookTriggerEvents.DOCUMENT_CREATED,
      data: document,
      userId,
      teamId,
    });

    return document;
  });
};