[refactor] UserWebhookの配信処理をService化

[samunohito]

Summary

UserWebhookを送出用のキューに積む処理が随所でむき出しになっているので、これをUserWebhookServiceにまとめたいです。
↓こんなの

misskey/packages/backend/src/core/NoteCreateService.ts

Lines 658 to 663 in ff47fef

	const webhooks = (await this.webhookService.getActiveWebhooks()).filter(x => x.userId === data.renote!.userId && x.on.includes('renote'));
	for (const webhook of webhooks) {
	this.queueService.userWebhookDeliver(webhook, 'renote', {
	note: noteObj,
	});
	}

具体的なイメージとしては、SystemWebhookServiceの下記処理と同等の構造にします。に近い形となります。

misskey/packages/backend/src/core/SystemWebhookService.ts

Lines 168 to 187 in 5229f5d

	public async enqueueSystemWebhook<T extends SystemWebhookEventType>(
	webhook: MiSystemWebhook | MiSystemWebhook['id'],
	type: T,
	content: unknown,
	) {
	const webhookEntity = typeof webhook === 'string'
	? (await this.fetchActiveSystemWebhooks()).find(a => a.id === webhook)
	: webhook;
	if (!webhookEntity || !webhookEntity.isActive) {
	this.logger.info(`SystemWebhook is not active or not found : ${webhook}`);
	return;
	}
	if (!webhookEntity.on.includes(type)) {
	this.logger.info(`SystemWebhook ${webhookEntity.id} is not listening to ${type}`);
	return;
	}
	return this.queueService.systemWebhookDeliver(webhookEntity, type, content);
	}

アクティブなWebhookを取得し、それら全件に向かって発信するのはどこも同じなので、以下のように出来ると良いと思っています

	public async enqueueUserWebhook<T extends WebhookEventTypes>(
		type: T,
		content: UserWebhookPayload<T>,
	) {
		const webhooks = await this.getActiveWebhooks()
			.then(webhooks => webhooks.filter(webhook => webhook.on.includes(type)));
		return Promise.all(
			webhooks.map(webhook => {
				return this.queueService.userWebhookDeliver(webhook, type, content);
			}),
		);
	}

Purpose

• 積む処理周辺の見通しがよくなる（特にNoteCreateService）
• UserWebhook絡みの影響範囲調査をするときに影響範囲調査が楽になる（UserWebhookServiceにまとまるので）

Do you want to implement this feature yourself?

• Yes, I will implement this by myself and send a pull request

[samunohito]

（SystemWebhookServiceも改良の余地あるのでそっちもやろうと思います）