mirror of
https://github.com/directus/directus.git
synced 2026-04-25 03:00:53 -04:00
@@ -7,16 +7,21 @@ import { WebhooksService } from './services';
|
||||
import { getSchema } from './utils/get-schema';
|
||||
import { ActionHandler } from '@directus/shared/types';
|
||||
import { getMessenger } from './messenger';
|
||||
import { JobQueue } from './utils/job-queue';
|
||||
|
||||
let registered: { event: string; handler: ActionHandler }[] = [];
|
||||
|
||||
const reloadQueue = new JobQueue();
|
||||
|
||||
export async function init(): Promise<void> {
|
||||
await register();
|
||||
const messenger = getMessenger();
|
||||
|
||||
messenger.subscribe('webhooks', (event) => {
|
||||
if (event.type === 'reload') {
|
||||
reload();
|
||||
reloadQueue.enqueue(async () => {
|
||||
await reload();
|
||||
});
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user