Class WebhookController

src/api/WebhookController.ts:45–542

}

export class WebhookController extends BaseController {
	private webhooks: Map<string, WebhookConfig> = new Map();
	private webhookDeliveryQueue: WebhookDelivery[] = [];

	constructor(private plugin: TaskNotesPlugin) {
		super();
		this.loadWebhooks();
	}

	@Post("/api/webhooks")
	async registerWebhook(req: HTTPRequestLike, res: HTTPResponseLike): Promise<void> {
		try {
			const body = await this.parseRequestBody(req);
			const requestBody = isRecord(body) ? body : {};

			if (typeof requestBody.url !== "string") {
				this.sendResponse(
					res,
					400,
					this.errorResponse("URL is required and must be a string")
				);
				return;
			}

			if (
				!Array.isArray(requestBody.events) ||
				requestBody.events.length === 0 ||
				!requestBody.events.every(isWebhookEvent)
			) {
				this.sendResponse(
					res,
					400,
					this.errorResponse(
						"Events array is required and must contain valid webhook events"
					)
				);
				return;
			}

			// Generate webhook ID and secret if not provided
			const id = optionalString(requestBody.id) ?? this.generateWebhookId();
			const secret = optionalString(requestBody.secret) ?? this.generateWebhookSecret();

			const webhook: WebhookConfig = {
				id,
				url: requestBody.url,
				events: requestBody.events,
				secret,
				active: requestBody.active !== false,
				createdAt: new Date().toISOString(),
				failureCount: 0,
				successCount: 0,
				transformFile: optionalString(requestBody.transformFile),
				corsHeaders: requestBody.corsHeaders !== false, // Default to true unless explicitly set to false
			};

			this.webhooks.set(id, webhook);
			await this.saveWebhooks();