UniqAI/hexabot
1
0
Fork 0
mirror of https://github.com/hexastack/hexabot synced 2025-02-24 21:34:31 +00:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

fix: throw when no updates has been provided

Browse Source
This commit is contained in:
abdou6666 2024-12-20 08:42:02 +01:00
parent fa282fb77b
commit 4972011dfd
1 changed files with 16 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
api/src/utils/generics/base-repository.ts
View File

@ -177,28 +177,30 @@ export abstract class BaseRepository<
const query = this as Query<D, D, unknown, T, 'findOneAndUpdate'>; const query = this as Query<D, D, unknown, T, 'findOneAndUpdate'>;
const criteria = query.getFilter(); const criteria = query.getFilter();
const updates = query.getUpdate(); const updates = query.getUpdate();
if (updates) { if (!updates) {
await repository.preUpdate(query, criteria, updates); throw new Error('Unable to run findOneAndUpdate pre hook');
repository.emitter.emit(
repository.getEventName(EHook.preUpdate),
criteria,
updates?.['$set'],
);
} }
await repository.preUpdate(query, criteria, updates);
repository.emitter.emit(
repository.getEventName(EHook.preUpdate),
criteria,
updates?.['$set'],
);
}); });
hooks.updateMany.pre.execute(async function () { hooks.updateMany.pre.execute(async function () {
const query = this as Query<D, D, unknown, T, 'updateMany'>; const query = this as Query<D, D, unknown, T, 'updateMany'>;
const criteria = query.getFilter(); const criteria = query.getFilter();
const updates = query.getUpdate(); const updates = query.getUpdate();
if (updates) { if (!updates) {
await repository.preUpdateMany(query, criteria, updates); throw new Error('Unable to run run updateMany pre hook');
repository.emitter.emit(
repository.getEventName(EHook.preUpdateMany),
criteria,
updates?.['$set'],
);
} }
await repository.preUpdateMany(query, criteria, updates);
repository.emitter.emit(
repository.getEventName(EHook.preUpdateMany),
criteria,
updates?.['$set'],
);
}); });
hooks.updateMany.post.execute(async function (updated: any) { hooks.updateMany.post.execute(async function (updated: any) {