add event watchdog

Author: oohwooh

prisma/migrations/20230202015742_add_contentful_event_restrictions/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE "Event" ADD COLUMN     "contentfulEventRestrictions" TEXT[];

prisma/migrations/20231018204933_add_watchdog_webhook/migration.sql

@@ -0,0 +1,2 @@
+-- AlterEnum
+ALTER TYPE "WebhookType" ADD VALUE 'WATCHDOG';

prisma/schema.prisma

@@ -7,7 +7,7 @@ datasource db {
 }
 
 generator client {
-  provider = "prisma-client-js"
+  provider        = "prisma-client-js"
   previewFeatures = ["filterJson"]
 }
 
@@ -57,39 +57,39 @@ model Event {
   metadata  Json?
 
   // Data
-  name               String
-  startDate          DateTime
-  endDate            DateTime
-  ticketPrice        Float
-  earlyBirdPrice     Float
-  earlyBirdCutoff    DateTime
-  groupPrice         Float?
-  registrationCutoff DateTime
-  managers           String[] // codeday account usernames
-  registrationsOpen  Boolean             @default(false)
-  contentfulWebname  String?
-  showcaseId         String?
-  minorWaiverId      String?
-  adultWaiverId      String?
-  eventRestrictions  EventRestriction[]
+  name                        String
+  startDate                   DateTime
+  endDate                     DateTime
+  ticketPrice                 Float
+  earlyBirdPrice              Float
+  earlyBirdCutoff             DateTime
+  groupPrice                  Float?
+  registrationCutoff          DateTime
+  managers                    String[] // codeday account usernames
+  registrationsOpen           Boolean             @default(false)
+  contentfulWebname           String?
+  showcaseId                  String?
+  minorWaiverId               String?
+  adultWaiverId               String?
+  eventRestrictions           EventRestriction[]
   contentfulEventRestrictions String[]
-  timezone           String?
-  majorityAge        Int                 @default(18)
-  overnightMinAge    Int?
-  minAge             Int?
-  maxAge             Int?
-  requiresPromoCode  Boolean             @default(false)
+  timezone                    String?
+  majorityAge                 Int                 @default(18)
+  overnightMinAge             Int?
+  minAge                      Int?
+  maxAge                      Int?
+  requiresPromoCode           Boolean             @default(false)
   // Relations
-  eventGroup         EventGroup          @relation(fields: [eventGroupId], references: [id])
-  eventGroupId       String
-  venue              Venue?              @relation(fields: [venueId], references: [id])
-  venueId            String?
-  sponsors           Sponsor[]
-  tickets            Ticket[]
-  schedule           ScheduleItem[]
-  promoCodes         PromoCode[]
-  interestedEmails   MailingListMember[]
-  webhooks           Webhook[]
+  eventGroup                  EventGroup          @relation(fields: [eventGroupId], references: [id])
+  eventGroupId                String
+  venue                       Venue?              @relation(fields: [venueId], references: [id])
+  venueId                     String?
+  sponsors                    Sponsor[]
+  tickets                     Ticket[]
+  schedule                    ScheduleItem[]
+  promoCodes                  PromoCode[]
+  interestedEmails            MailingListMember[]
+  webhooks                    Webhook[]
 }
 
 enum WebhookService {
@@ -100,6 +100,7 @@ enum WebhookService {
 enum WebhookType {
   ALL
   DIGEST
+  WATCHDOG
 }
 
 model Webhook {
@@ -190,7 +191,7 @@ model Person {
   age       Int?
   username  String?
   pronouns  String?
-  locale    String @default("en-US")
+  locale    String  @default("en-US")
 
   Ticket Ticket[]
 }
@@ -206,21 +207,21 @@ enum TicketType {
 
 model Ticket {
   // Metadata
-  id        String   @id @default(cuid())
-  createdAt DateTime @default(now())
-  updatedAt DateTime @updatedAt
+  id         String   @id @default(cuid())
+  createdAt  DateTime @default(now())
+  updatedAt  DateTime @updatedAt
   /// @TypeGraphQL.omit(input: ["update", "where", "orderBy"])
-  metadata  Json?
+  metadata   Json?
   // Data
-  privateKey       String? @default(uuid())
-  firstName String
-  lastName  String
-  email     String?
-  phone     String?
-  whatsApp  String?
-  username  String?
-  locale    String @default("en-US")
-  age       Int?
+  privateKey String?  @default(uuid())
+  firstName  String
+  lastName   String
+  email      String?
+  phone      String?
+  whatsApp   String?
+  username   String?
+  locale     String   @default("en-US")
+  age        Int?
 
   waiverTrackingId String?
   waiverUrl        String?
@@ -230,7 +231,7 @@ model Ticket {
   checkedIn        DateTime?
   checkedOut       DateTime?
 
-  surveyResponses  Json?
+  surveyResponses Json?
 
   couponCode String?
   type       TicketType @default(STUDENT)
@@ -386,4 +387,4 @@ model EventRestriction {
   title   String
   details String?
   Events  Event[]
-}
+}

src/webhooks/eventConfigWatchdog.ts

@@ -0,0 +1,22 @@
+import { DateTime } from 'luxon';
+import { prisma } from '../services';
+import { sendWebhook } from './sendWebhook';
+
+
+export async function eventConfigWatchdog(): Promise<void> {
+  const has_venue_closed_regs = await prisma.event.findMany({ where: { venueId: { not: null }, registrationsOpen: false, startDate: { gt: DateTime.now().toJSDate() } }});
+  const has_regs_no_venue = await prisma.event.findMany({ where: { venueId: null, registrationsOpen: true, startDate: { gt: DateTime.now().toJSDate() } } });
+  const watchdog_hooks = await prisma.webhook.findMany({ where: { type: 'WATCHDOG' } });
+
+  watchdog_hooks.forEach(async (h) => {
+    if(has_venue_closed_regs.length > 0) {
+      await sendWebhook(h, { title: 'WARNING: Events with venue and closed registrations', message: has_venue_closed_regs.map((e) => `${e.name}: https://clear.codeday.org/events/${e.id}`).join('\n') })
+    }
+  })
+
+  watchdog_hooks.forEach(async (h) => {
+    if(has_regs_no_venue.length > 0) {
+      await sendWebhook(h, { title: 'URGENT: Events with open registrations and no venue', message: has_regs_no_venue.map((e) => `${e.name}: https://clear.codeday.org/events/${e.id}`).join('\n') })
+    }
+  })
+}

src/webhooks/index.ts

@@ -4,6 +4,7 @@ import { prisma } from "../services";
 import { sendEventDigests } from "./sendEventDigests";
 import { sendEventGroupDigests } from "./sendEventGroupDigests";
 import { sendWebhook } from "./sendWebhook";
+import { eventConfigWatchdog } from "./eventConfigWatchdog";
 
 export async function automaticDigests(): Promise<void> {
     const rule = new schedule.RecurrenceRule();
@@ -14,6 +15,7 @@ export async function automaticDigests(): Promise<void> {
     schedule.scheduleJob(rule, () => {
       sendEventDigests();
       sendEventGroupDigests();
+      eventConfigWatchdog();
     });
 }