This commit is contained in:
parent
7eb2e8f218
commit
48bfba71de
|
@ -30,8 +30,7 @@ module.exports = Self => {
|
||||||
return Object.keys(criteria).every(key => criteria[key] === paramsObj?.[key]);
|
return Object.keys(criteria).every(key => criteria[key] === paramsObj?.[key]);
|
||||||
});
|
});
|
||||||
|
|
||||||
if (filteredNotifications.length >= 1)
|
if (filteredNotifications.length >= 1) return;
|
||||||
throw new Error('Previous notification sended with the same parameters');
|
|
||||||
}
|
}
|
||||||
|
|
||||||
await models.NotificationQueue.create({
|
await models.NotificationQueue.create({
|
||||||
|
|
Loading…
Reference in New Issue