feat: support team webhooks

packages/lib/server-only/webhooks/create-webhook.ts

@@ -7,6 +7,7 @@ export interface CreateWebhookOptions {
   secret: string | null;
   enabled: boolean;
   userId: number;
+  teamId?: number;
 }
 
 export const createWebhook = async ({
@@ -15,7 +16,21 @@ export const createWebhook = async ({
   secret,
   enabled,
   userId,
+  teamId,
 }: CreateWebhookOptions) => {
+  if (teamId) {
+    await prisma.team.findFirstOrThrow({
+      where: {
+        id: teamId,
+        members: {
+          some: {
+            userId,
+          },
+        },
+      },
+    });
+  }
+
   return await prisma.webhook.create({
     data: {
       webhookUrl,
@@ -23,6 +38,7 @@ export const createWebhook = async ({
       secret,
       enabled,
       userId,
+      teamId,
     },
   });
 };

packages/lib/server-only/webhooks/delete-webhook-by-id.ts

@@ -3,13 +3,28 @@ import { prisma } from '@documenso/prisma';
 export type DeleteWebhookByIdOptions = {
   id: string;
   userId: number;
+  teamId?: number;
 };
 
-export const deleteWebhookById = async ({ id, userId }: DeleteWebhookByIdOptions) => {
+export const deleteWebhookById = async ({ id, userId, teamId }: DeleteWebhookByIdOptions) => {
   return await prisma.webhook.delete({
     where: {
       id,
-      userId,
+      ...(teamId
+        ? {
+            team: {
+              id: teamId,
+              members: {
+                some: {
+                  userId,
+                },
+              },
+            },
+          }
+        : {
+            userId,
+            teamId: null,
+          }),
     },
   });
 };

packages/lib/server-only/webhooks/edit-webhook.ts

@@ -4,15 +4,30 @@ import { prisma } from '@documenso/prisma';
 
 export type EditWebhookOptions = {
   id: string;
-  data: Prisma.WebhookUpdateInput;
+  data: Omit<Prisma.WebhookUpdateInput, 'id' | 'userId' | 'teamId'>;
   userId: number;
+  teamId?: number;
 };
 
-export const editWebhook = async ({ id, data, userId }: EditWebhookOptions) => {
+export const editWebhook = async ({ id, data, userId, teamId }: EditWebhookOptions) => {
   return await prisma.webhook.update({
     where: {
       id,
-      userId,
+      ...(teamId
+        ? {
+            team: {
+              id: teamId,
+              members: {
+                some: {
+                  userId,
+                },
+              },
+            },
+          }
+        : {
+            userId,
+            teamId: null,
+          }),
     },
     data: {
       ...data,

packages/lib/server-only/webhooks/get-all-webhooks-by-event-trigger.ts

@@ -14,6 +14,10 @@ export const getAllWebhooksByEventTrigger = async ({
 }: GetAllWebhooksByEventTriggerOptions) => {
   return prisma.webhook.findMany({
     where: {
+      enabled: true,
+      eventTriggers: {
+        has: event,
+      },
       ...(teamId
         ? {
             team: {
@@ -29,10 +33,6 @@ export const getAllWebhooksByEventTrigger = async ({
             userId,
             teamId: null,
           }),
-      eventTriggers: {
-        has: event,
-      },
-      enabled: true,
     },
   });
 };

packages/lib/server-only/webhooks/get-webhook-by-id.ts

@@ -3,13 +3,28 @@ import { prisma } from '@documenso/prisma';
 export type GetWebhookByIdOptions = {
   id: string;
   userId: number;
+  teamId?: number;
 };
 
-export const getWebhookById = async ({ id, userId }: GetWebhookByIdOptions) => {
+export const getWebhookById = async ({ id, userId, teamId }: GetWebhookByIdOptions) => {
   return await prisma.webhook.findFirstOrThrow({
     where: {
       id,
-      userId,
+      ...(teamId
+        ? {
+            team: {
+              id: teamId,
+              members: {
+                some: {
+                  userId,
+                },
+              },
+            },
+          }
+        : {
+            userId,
+            teamId: null,
+          }),
     },
   });
 };

packages/lib/server-only/webhooks/get-webhooks-by-team-id.ts

@@ -0,0 +1,19 @@
+import { prisma } from '@documenso/prisma';
+
+export const getWebhooksByTeamId = async (teamId: number, userId: number) => {
+  return await prisma.webhook.findMany({
+    where: {
+      team: {
+        id: teamId,
+        members: {
+          some: {
+            userId,
+          },
+        },
+      },
+    },
+    orderBy: {
+      createdAt: 'desc',
+    },
+  });
+};

packages/trpc/server/webhook-router/router.ts

@@ -4,13 +4,15 @@ import { createWebhook } from '@documenso/lib/server-only/webhooks/create-webhoo
 import { deleteWebhookById } from '@documenso/lib/server-only/webhooks/delete-webhook-by-id';
 import { editWebhook } from '@documenso/lib/server-only/webhooks/edit-webhook';
 import { getWebhookById } from '@documenso/lib/server-only/webhooks/get-webhook-by-id';
+import { getWebhooksByTeamId } from '@documenso/lib/server-only/webhooks/get-webhooks-by-team-id';
 import { getWebhooksByUserId } from '@documenso/lib/server-only/webhooks/get-webhooks-by-user-id';
 
 import { authenticatedProcedure, router } from '../trpc';
 import {
-  ZCreateWebhookFormSchema,
+  ZCreateWebhookMutationSchema,
   ZDeleteWebhookMutationSchema,
   ZEditWebhookMutationSchema,
+  ZGetTeamWebhooksQuerySchema,
   ZGetWebhookByIdQuerySchema,
 } from './schema';
 
@@ -25,15 +27,32 @@ export const webhookRouter = router({
       });
     }
   }),
+
+  getTeamWebhooks: authenticatedProcedure
+    .input(ZGetTeamWebhooksQuerySchema)
+    .query(async ({ ctx, input }) => {
+      const { teamId } = input;
+
+      try {
+        return await getWebhooksByTeamId(teamId, ctx.user.id);
+      } catch (err) {
+        throw new TRPCError({
+          code: 'BAD_REQUEST',
+          message: 'We were unable to fetch your webhooks. Please try again later.',
+        });
+      }
+    }),
+
   getWebhookById: authenticatedProcedure
     .input(ZGetWebhookByIdQuerySchema)
     .query(async ({ input, ctx }) => {
       try {
-        const { id } = input;
+        const { id, teamId } = input;
 
         return await getWebhookById({
           id,
           userId: ctx.user.id,
+          teamId,
         });
       } catch (err) {
         throw new TRPCError({
@@ -44,11 +63,17 @@ export const webhookRouter = router({
     }),
 
   createWebhook: authenticatedProcedure
-    .input(ZCreateWebhookFormSchema)
+    .input(ZCreateWebhookMutationSchema)
     .mutation(async ({ input, ctx }) => {
+      const { enabled, eventTriggers, secret, webhookUrl, teamId } = input;
+
       try {
         return await createWebhook({
-          ...input,
+          enabled,
+          secret,
+          webhookUrl,
+          eventTriggers,
+          teamId,
           userId: ctx.user.id,
         });
       } catch (err) {
@@ -58,14 +83,16 @@ export const webhookRouter = router({
         });
       }
     }),
+
   deleteWebhook: authenticatedProcedure
     .input(ZDeleteWebhookMutationSchema)
     .mutation(async ({ input, ctx }) => {
       try {
-        const { id } = input;
+        const { id, teamId } = input;
 
         return await deleteWebhookById({
           id,
+          teamId,
           userId: ctx.user.id,
         });
       } catch (err) {
@@ -75,16 +102,18 @@ export const webhookRouter = router({
         });
       }
     }),
+
   editWebhook: authenticatedProcedure
     .input(ZEditWebhookMutationSchema)
     .mutation(async ({ input, ctx }) => {
       try {
-        const { id } = input;
+        const { id, teamId, ...data } = input;
 
         return await editWebhook({
           id,
-          data: input,
+          data,
           userId: ctx.user.id,
+          teamId,
         });
       } catch (err) {
         throw new TRPCError({

packages/trpc/server/webhook-router/schema.ts

@@ -2,24 +2,32 @@ import { z } from 'zod';
 
 import { WebhookTriggerEvents } from '@documenso/prisma/client';
 
-export const ZCreateWebhookFormSchema = z.object({
+export const ZGetTeamWebhooksQuerySchema = z.object({
+  teamId: z.number(),
+});
+
+export type TGetTeamWebhooksQuerySchema = z.infer<typeof ZGetTeamWebhooksQuerySchema>;
+
+export const ZCreateWebhookMutationSchema = z.object({
   webhookUrl: z.string().url(),
   eventTriggers: z
     .array(z.nativeEnum(WebhookTriggerEvents))
     .min(1, { message: 'At least one event trigger is required' }),
   secret: z.string().nullable(),
   enabled: z.boolean(),
+  teamId: z.number().optional(),
 });
 
-export type TCreateWebhookFormSchema = z.infer<typeof ZCreateWebhookFormSchema>;
+export type TCreateWebhookFormSchema = z.infer<typeof ZCreateWebhookMutationSchema>;
 
 export const ZGetWebhookByIdQuerySchema = z.object({
   id: z.string(),
+  teamId: z.number().optional(),
 });
 
 export type TGetWebhookByIdQuerySchema = z.infer<typeof ZGetWebhookByIdQuerySchema>;
 
-export const ZEditWebhookMutationSchema = ZCreateWebhookFormSchema.extend({
+export const ZEditWebhookMutationSchema = ZCreateWebhookMutationSchema.extend({
   id: z.string(),
 });
 
@@ -27,6 +35,7 @@ export type TEditWebhookMutationSchema = z.infer<typeof ZEditWebhookMutationSche
 
 export const ZDeleteWebhookMutationSchema = z.object({
   id: z.string(),
+  teamId: z.number().optional(),
 });
 
 export type TDeleteWebhookMutationSchema = z.infer<typeof ZDeleteWebhookMutationSchema>;