implement manually retrying failed messages

This commit is contained in:
liamcottle
2025-02-13 17:05:03 +13:00
parent 17beabf419
commit 9d6eab3a8a
3 changed files with 30 additions and 9 deletions

View File

@@ -114,14 +114,19 @@ class Message {
$eq: id,
},
},
sort: [
{
timestamp: "desc",
},
],
}).exec();
}
static async deleteMessageById(id) {
return await database.messages.findOne({
selector: {
id: {
$eq: id,
},
},
}).incrementalRemove();
}
// mark a message as delivered by its ack code
static async setMessageDeliveredByAckCode(ackCode) {