github/directus
1
0
Fork 0
mirror of https://github.com/directus/directus.git synced 2026-01-24 08:58:11 -05:00
Code Issues Packages Projects Releases Wiki Activity

Fix Emit Events for item CRUD operations in Flows (#14741)

Browse Source
This commit is contained in:
Azri Kahar
2022-07-29 22:52:28 +08:00
committed by GitHub
parent a11b14b3de
commit ab045cffce
4 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
api/src/operations/item-create/index.ts
View File

@@ -42,7 +42,7 @@ export default defineOperationApi<Options>({
if (!payloadObject) {
result = null;
} else {
result = await itemsService.createMany(toArray(payloadObject), { emitEvents });
result = await itemsService.createMany(toArray(payloadObject), { emitEvents: !!emitEvents });
}
return result;

4
api/src/operations/item-delete/index.ts
View File

@@ -47,9 +47,9 @@ export default defineOperationApi<Options>({
const keys = toArray(key);
if (keys.length === 1) {
result = await itemsService.deleteOne(keys[0], { emitEvents });
result = await itemsService.deleteOne(keys[0], { emitEvents: !!emitEvents });
} else {
result = await itemsService.deleteMany(keys, { emitEvents });
result = await itemsService.deleteMany(keys, { emitEvents: !!emitEvents });
}
}

4
api/src/operations/item-read/index.ts
View File

@@ -48,9 +48,9 @@ export default defineOperationApi<Options>({
const keys = toArray(key);
if (keys.length === 1) {
result = await itemsService.readOne(keys[0], sanitizedQueryObject, { emitEvents });
result = await itemsService.readOne(keys[0], sanitizedQueryObject, { emitEvents: !!emitEvents });
} else {
result = await itemsService.readMany(keys, sanitizedQueryObject, { emitEvents });
result = await itemsService.readMany(keys, sanitizedQueryObject, { emitEvents: !!emitEvents });
}
}

6
api/src/operations/item-update/index.ts
View File

@@ -53,14 +53,14 @@ export default defineOperationApi<Options>({
let result: PrimaryKey | PrimaryKey[] | null;
if (!key || (Array.isArray(key) && key.length === 0)) {
result = await itemsService.updateByQuery(sanitizedQueryObject, payloadObject, { emitEvents });
result = await itemsService.updateByQuery(sanitizedQueryObject, payloadObject, { emitEvents: !!emitEvents });
} else {
const keys = toArray(key);
if (keys.length === 1) {
result = await itemsService.updateOne(keys[0], payloadObject, { emitEvents });
result = await itemsService.updateOne(keys[0], payloadObject, { emitEvents: !!emitEvents });
} else {
result = await itemsService.updateMany(keys, payloadObject, { emitEvents });
result = await itemsService.updateMany(keys, payloadObject, { emitEvents: !!emitEvents });
}
}