summaryrefslogtreecommitdiff
path: root/src/server/api/endpoints/messaging/messages/delete.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/server/api/endpoints/messaging/messages/delete.ts')
-rw-r--r--src/server/api/endpoints/messaging/messages/delete.ts17
1 files changed, 13 insertions, 4 deletions
diff --git a/src/server/api/endpoints/messaging/messages/delete.ts b/src/server/api/endpoints/messaging/messages/delete.ts
index 4f3fabb4ce..5bc492c19d 100644
--- a/src/server/api/endpoints/messaging/messages/delete.ts
+++ b/src/server/api/endpoints/messaging/messages/delete.ts
@@ -4,6 +4,7 @@ import Message from '../../../../../models/messaging-message';
import define from '../../../define';
import { publishMessagingStream } from '../../../../../services/stream';
import * as ms from 'ms';
+import { ApiError } from '../../../error';
export const meta = {
stability: 'stable',
@@ -32,17 +33,25 @@ export const meta = {
'en-US': 'Target message ID.'
}
}
+ },
+
+ errors: {
+ noSuchMessage: {
+ message: 'No such message.',
+ code: 'NO_SUCH_MESSAGE',
+ id: '54b5b326-7925-42cf-8019-130fda8b56af'
+ },
}
};
-export default define(meta, (ps, user) => new Promise(async (res, rej) => {
+export default define(meta, async (ps, user) => {
const message = await Message.findOne({
_id: ps.messageId,
userId: user._id
});
if (message === null) {
- return rej('message not found');
+ throw new ApiError(meta.errors.noSuchMessage);
}
await Message.remove({ _id: message._id });
@@ -50,5 +59,5 @@ export default define(meta, (ps, user) => new Promise(async (res, rej) => {
publishMessagingStream(message.userId, message.recipientId, 'deleted', message._id);
publishMessagingStream(message.recipientId, message.userId, 'deleted', message._id);
- res();
-}));
+ return;
+});