documenso/packages/lib/server-only/webhooks/zapier/list-documents.ts

import type { NextApiRequest, NextApiResponse } from 'next';

import { findDocuments } from '@documenso/lib/server-only/document/find-documents';
import { getRecipientsForDocument } from '@documenso/lib/server-only/recipient/get-recipients-for-document';
import type { Webhook } from '@documenso/prisma/client';

import { getWebhooksByTeamId } from '../get-webhooks-by-team-id';
import { getWebhooksByUserId } from '../get-webhooks-by-user-id';
import { validateApiToken } from './validateApiToken';

export const listDocumentsHandler = async (req: NextApiRequest, res: NextApiResponse) => {
  try {
    const { authorization } = req.headers;
    const { user, userId, teamId } = await validateApiToken({ authorization });

    let allWebhooks: Webhook[] = [];

    const documents = await findDocuments({
      userId: userId ?? user.id,
      teamId: teamId ?? undefined,
      perPage: 1,
    });

    if (!documents || !documents.data || documents.data.length === 0) {
      const dummyWebhook = {
        event: 'DOCUMENT_SIGNED',
        createdAt: new Date(),
        webhookEndpoint: 'https://example.com/webhook',
        payload: {
          id: 1,
          userId: 2,
          title: 'Example Document',
          status: 'COMPLETED',
          documentDataId: 3,
          createdAt: new Date(),
          updatedAt: new Date(),
          completedAt: new Date(),
          deletedAt: null,
          teamId: 4,
          Recipient: [
            {
              id: 1,
              documentId: 123,
              templateId: null,
              token: 'example-token',
              email: 'recipient@example.com',
              name: 'Example Recipient',
              role: 'SIGNER',
              status: 'SIGNED',
              signedAt: new Date(),
              completedAt: new Date(),
              expired: false,
              readStatus: 'OPENED',
              signingStatus: 'SIGNED',
              sendStatus: 'SENT',
            },
          ],
        },
      };

      return res.status(200).json([dummyWebhook]);
    }

    const recipients = await getRecipientsForDocument({
      documentId: documents.data[0].id,
      userId: userId ?? user.id,
      teamId: teamId ?? undefined,
    });

    if (userId) {
      allWebhooks = await getWebhooksByUserId(userId);
    }

    if (teamId) {
      allWebhooks = await getWebhooksByTeamId(teamId, user.id);
    }

    if (documents && documents.data.length > 0 && allWebhooks.length > 0 && recipients.length > 0) {
      const testWebhook = {
        event: allWebhooks[0].eventTriggers.toString(),
        createdAt: allWebhooks[0].createdAt,
        webhookEndpoint: allWebhooks[0].webhookUrl,
        payload: {
          id: documents.data[0].id,
          userId: documents.data[0].userId,
          title: documents.data[0].title,
          status: documents.data[0].status,
          documentDataId: documents.data[0].documentDataId,
          createdAt: documents.data[0].createdAt,
          updatedAt: documents.data[0].updatedAt,
          completedAt: documents.data[0].completedAt,
          deletedAt: documents.data[0].deletedAt,
          teamId: documents.data[0].teamId,
          Recipient: recipients,
        },
      };

      return res.status(200).json([testWebhook]);
    }

    return res.status(200).json([]);
  } catch (err) {
    return res.status(500).json({
      message: 'Internal Server Error',
    });
  }
};