Allow change visibility of messages

magic8bot · Dec 25, 2020 · 47f9268 · 47f9268
1 parent aff719b
commit 47f9268
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@magic8bot/smq",
-  "version": "2.0.1",
+  "version": "2.1.0",
   "description": "Cryptocurrency trading bot",
   "bugs": "https://github.com/magic8bot/smq/issues",
   "license": "MIT",

diff --git a/src/smq.ts b/src/smq.ts
@@ -27,10 +27,14 @@ export class Smq {
     return rsmq.sendMessageAsync({ qname, message: JSON.stringify(message) })
   }
 
-  async receiveMessage<T>(qname: Channel): Promise<T | false> {
-    const { message } = (await rsmq.receiveMessageAsync({ qname })) as RedisSMQ.QueueMessage
+  async receiveMessage<T>(qname: Channel): Promise<{ id: string; message: T | false }> {
+    const { id, message } = (await rsmq.receiveMessageAsync({ qname })) as RedisSMQ.QueueMessage
 
-    return this.decode(message)
+    return { id, message: this.decode(message) }
+  }
+
+  changeMessageVisibility(qname: string, id: string, vt: number) {
+    return rsmq.changeMessageVisibilityAsync({ qname, id, vt })
   }
 
   deleteMessage(qname: Channel, id: string) {