github/directus
1
1
Fork 0
mirror of https://github.com/directus/directus.git synced 2026-04-25 03:00:53 -04:00
Code Issues Packages Projects Releases Wiki Activity

Application initialization events (#3680)

Browse Source 
* Adds `not_found` hook

* Separate hooks and endpoints initialization process

* Adds additional application events

* Remove unused import

* Change the event order to accound for notFound and errorHandler

* Change emitAsync.catch to use the emitAsyncSafe function

* Updated docs, reordered table by lifecycle and usage
This commit is contained in:
WoLfulus
2021-02-08 14:30:09 -03:00
committed by GitHub
parent 42f0f01b13
commit b8e7c80b72
8 changed files with 141 additions and 81 deletions
Download Patch File Download Diff File Expand all files Collapse all files

63
api/src/services/items.ts
View File

@@ -14,8 +14,7 @@ import {
} from '../types';
import Knex from 'knex';
import cache from '../cache';
import emitter from '../emitter';
import logger from '../logger';
import emitter, { emitAsyncSafe } from '../emitter';
import { toArray } from '../utils/to-array';
import env from '../env';
@@ -164,17 +163,15 @@ export class ItemsService<Item extends AnyItem = AnyItem> implements AbstractSer
return primaryKeys;
});
emitter
.emitAsync(`${this.eventScope}.create`, {
event: `${this.eventScope}.create`,
accountability: this.accountability,
collection: this.collection,
item: savedPrimaryKeys,
action: 'create',
payload: payloads,
schema: this.schema,
})
.catch((err) => logger.warn(err));
emitAsyncSafe(`${this.eventScope}.create`, {
event: `${this.eventScope}.create`,
accountability: this.accountability,
collection: this.collection,
item: savedPrimaryKeys,
action: 'create',
payload: payloads,
schema: this.schema,
});
return Array.isArray(data) ? savedPrimaryKeys : savedPrimaryKeys[0];
}
@@ -362,17 +359,15 @@ export class ItemsService<Item extends AnyItem = AnyItem> implements AbstractSer
await cache.clear();
}
emitter
.emitAsync(`${this.eventScope}.update`, {
event: `${this.eventScope}.update`,
accountability: this.accountability,
collection: this.collection,
item: key,
action: 'update',
payload,
schema: this.schema,
})
.catch((err) => logger.warn(err));
emitAsyncSafe(`${this.eventScope}.update`, {
event: `${this.eventScope}.update`,
accountability: this.accountability,
collection: this.collection,
item: key,
action: 'update',
payload,
schema: this.schema,
});
return key;
}
@@ -499,17 +494,15 @@ export class ItemsService<Item extends AnyItem = AnyItem> implements AbstractSer
await cache.clear();
}
emitter
.emitAsync(`${this.eventScope}.delete`, {
event: `${this.eventScope}.delete`,
accountability: this.accountability,
collection: this.collection,
item: keys,
action: 'delete',
payload: null,
schema: this.schema,
})
.catch((err) => logger.warn(err));
emitAsyncSafe(`${this.eventScope}.delete`, {
event: `${this.eventScope}.delete`,
accountability: this.accountability,
collection: this.collection,
item: keys,
action: 'delete',
payload: null,
schema: this.schema,
});
return key;
}