Method syncWebhook

api/src/services/deployment.ts:240–306

* Sync webhook registration with current tracked projects.

(provider: ProviderType)

	 * Sync webhook registration with current tracked projects.
	 */
	async syncWebhook(provider: ProviderType): Promise<void> {
		const logger = useLogger();

		logger.debug(`[webhook:${provider}] Starting webhook sync`);

		const config = await this.readConfig(provider);

		const projectsService = new ItemsService<DeploymentProject>('directus_deployment_projects', {
			knex: this.knex,
			schema: this.schema,
			accountability: null,
		});

		const projects = await projectsService.readByQuery({
			filter: { deployment: { _eq: config.id } },
			limit: -1,
		});

		const projectExternalIds = projects.map((p) => p.external_id);
		const driver = await this.getDriver(provider);

		// No projects → unregister webhooks if any exist
		if (projectExternalIds.length === 0) {
			if (config.webhook_ids && config.webhook_ids.length > 0) {
				logger.debug(`[webhook:${provider}] No projects, unregistering ${config.webhook_ids.length} webhook(s)`);

				try {
					await driver.unregisterWebhook(config.webhook_ids);
				} catch (err) {
					logger.warn(`[webhook:${provider}] Failed to unregister: ${err}`);
				}

				await super.updateOne(config.id, { webhook_ids: null, webhook_secret: null } as Partial<DeploymentConfig>);
			}

			return;
		}

		// Unregister existing webhooks before re-registering
		if (config.webhook_ids && config.webhook_ids.length > 0) {
			logger.debug(`[webhook:${provider}] Unregistering ${config.webhook_ids.length} existing webhook(s)`);

			try {
				await driver.unregisterWebhook(config.webhook_ids);
			} catch (err) {
				logger.warn(`[webhook:${provider}] Failed to unregister: ${err}`);
			}
		}

		const publicUrl = env['PUBLIC_URL'] as string;
		const webhookUrl = `${publicUrl}/deployments/webhooks/${provider}`;

		logger.debug(
			`[webhook:${provider}] Registering webhook → ${webhookUrl} for ${projectExternalIds.length} project(s)`,
		);

		const result = await driver.registerWebhook(webhookUrl, projectExternalIds);