diff --git a/apps/webapp/app/services/events/deliverEvent.server.ts b/apps/webapp/app/services/events/deliverEvent.server.ts index f3745a49b..04df77fe5 100644 --- a/apps/webapp/app/services/events/deliverEvent.server.ts +++ b/apps/webapp/app/services/events/deliverEvent.server.ts @@ -33,7 +33,9 @@ export class DeliverEventService { const possibleEventDispatchers = await tx.eventDispatcher.findMany({ where: { environmentId: eventRecord.environmentId, - event: eventRecord.name, + event: { + has: eventRecord.name, + }, source: eventRecord.source, enabled: true, manual: false, diff --git a/packages/database/prisma/migrations/20230724074140_changed/migration.sql b/packages/database/prisma/migrations/20230724074140_changed/migration.sql new file mode 100644 index 000000000..6fce4a15f --- /dev/null +++ b/packages/database/prisma/migrations/20230724074140_changed/migration.sql @@ -0,0 +1,9 @@ +/* + Warnings: + + - The `event` column on the `EventDispatcher` table would be dropped and recreated. This will lead to data loss if there is data in the column. + +*/ +-- AlterTable +ALTER TABLE "EventDispatcher" DROP COLUMN "event", +ADD COLUMN "event" TEXT[]; diff --git a/packages/database/prisma/schema.prisma b/packages/database/prisma/schema.prisma index 5d62807e3..d586ee429 100644 --- a/packages/database/prisma/schema.prisma +++ b/packages/database/prisma/schema.prisma @@ -582,12 +582,12 @@ enum DynamicTriggerType { } model EventDispatcher { - id String @id @default(cuid()) - event String + id String @id @default(cuid()) + event String[] source String payloadFilter Json? contextFilter Json? - manual Boolean @default(false) + manual Boolean @default(false) dispatchableId String dispatchable Json