32 lines
835 B
TypeScript
32 lines
835 B
TypeScript
import { WebhookSubscription } from "@server/models";
|
|
import { Event } from "@server/types";
|
|
import DeliverWebhookTask from "../tasks/DeliverWebhookTask";
|
|
import BaseProcessor from "./BaseProcessor";
|
|
|
|
export default class WebhookProcessor extends BaseProcessor {
|
|
static applicableEvents: ["*"] = ["*"];
|
|
|
|
async perform(event: Event) {
|
|
if (!event.teamId) {
|
|
return;
|
|
}
|
|
|
|
const webhookSubscriptions = await WebhookSubscription.findAll({
|
|
where: {
|
|
enabled: true,
|
|
teamId: event.teamId,
|
|
},
|
|
});
|
|
|
|
const applicableSubscriptions = webhookSubscriptions.filter((webhook) =>
|
|
webhook.validForEvent(event)
|
|
);
|
|
|
|
await Promise.all(
|
|
applicableSubscriptions.map((subscription) =>
|
|
DeliverWebhookTask.schedule({ event, subscriptionId: subscription.id })
|
|
)
|
|
);
|
|
}
|
|
}
|