* experiment: cold start perf * fix: update failing test * chore: add database indexes * chore: use json protocol and add query batching back * Update [status].tsx * Update [trpc].ts * Delete getSlimSession.ts * Update createContext.ts * remove trpc caller * correctly import Prisma * lazy ethRouter * replace crypto with md5 * import fixes * public event endpoint refactor * Update yarn.lock * Update yarn.lock * Using yarn.lock from main --------- Co-authored-by: Omar López <zomars@me.com> Co-authored-by: Peer Richelsen <peeroke@gmail.com> Co-authored-by: Efraín Rochín <roae.85@gmail.com> Co-authored-by: Keith Williams <keithwillcode@gmail.com>
32 lines
802 B
TypeScript
32 lines
802 B
TypeScript
import type { Prisma } from "@prisma/client";
|
|
|
|
import { prisma } from "@calcom/prisma";
|
|
import type { TrpcSessionUser } from "@calcom/trpc/server/trpc";
|
|
|
|
import type { TListInputSchema } from "./list.schema";
|
|
|
|
type ListOptions = {
|
|
ctx: {
|
|
user: NonNullable<TrpcSessionUser>;
|
|
};
|
|
input: TListInputSchema;
|
|
};
|
|
|
|
export const listHandler = async ({ ctx, input }: ListOptions) => {
|
|
const where: Prisma.WebhookWhereInput = {
|
|
/* Don't mixup zapier webhooks with normal ones */
|
|
AND: [{ appId: !input?.appId ? null : input.appId }],
|
|
};
|
|
if (Array.isArray(where.AND)) {
|
|
if (input?.eventTypeId) {
|
|
where.AND?.push({ eventTypeId: input.eventTypeId });
|
|
} else {
|
|
where.AND?.push({ userId: ctx.user.id });
|
|
}
|
|
}
|
|
|
|
return await prisma.webhook.findMany({
|
|
where,
|
|
});
|
|
};
|