import { bool } from "aws-sdk/clients/signer"; import { Column, Table, BelongsTo, ForeignKey, NotEmpty, DataType, IsUrl, BeforeCreate, DefaultScope, } from "sequelize-typescript"; import { SaveOptions } from "sequelize/types"; import { WebhookSubscriptionValidation } from "@shared/validations"; import { ValidationError } from "@server/errors"; import { Event } from "@server/types"; import Team from "./Team"; import User from "./User"; import ParanoidModel from "./base/ParanoidModel"; import Fix from "./decorators/Fix"; import Length from "./validators/Length"; @DefaultScope(() => ({ include: [ { association: "team", required: true, }, ], })) @Table({ tableName: "webhook_subscriptions", modelName: "webhook_subscription", }) @Fix class WebhookSubscription extends ParanoidModel { @NotEmpty @Length({ max: 255, msg: "Webhook name be less than 255 characters" }) @Column name: string; @IsUrl @NotEmpty @Length({ max: 255, msg: "Webhook url be less than 255 characters" }) @Column url: string; @Column enabled: boolean; @Column(DataType.ARRAY(DataType.STRING)) events: string[]; // associations @BelongsTo(() => User, "createdById") createdBy: User; @ForeignKey(() => User) @Column createdById: string; @BelongsTo(() => Team, "teamId") team: Team; @ForeignKey(() => Team) @Column teamId: string; // hooks @BeforeCreate static async checkLimit(model: WebhookSubscription) { const count = await this.count({ where: { teamId: model.teamId }, }); if (count >= WebhookSubscriptionValidation.maxSubscriptions) { throw ValidationError( `You have reached the limit of ${WebhookSubscriptionValidation.maxSubscriptions} webhooks` ); } } // methods /** * Disables the webhook subscription * * @param options Save options * @returns Promise */ public async disable(options?: SaveOptions) { return this.update({ enabled: false }, options); } public validForEvent = (event: Event): bool => { if (this.events.length === 1 && this.events[0] === "*") { return true; } for (const e of this.events) { if (e === event.name || event.name.startsWith(e + ".")) { return true; } } return false; }; } export default WebhookSubscription;