version 1.26.2

Author: clairton

README.md

@@ -113,6 +113,20 @@ http://localhost:9876/v15.0/5549988290955/messages \
 }'
 ```
 
+To mark message as read
+
+```sh
+curl -i -X POST \
+http://localhost:9876/v15.0/5549988290955/messages \
+-H 'Content-Type: application/json' \
+-H 'Authorization: 1' \
+-d '{
+  "messaging_product": "whatsapp",
+  "status": "read",
+  "message_id": "MESSAGE_ID"
+}'
+```
+
 ## Media
 
 To test media

package.json

@@ -1,6 +1,6 @@
 {
   "name": "unoapi-cloud",
-  "version": "1.26.1",
+  "version": "1.26.2",
   "description": "Unoapi Cloud",
   "exports": "./dist/index.js",
   "types": "./dist/index.d.ts",

src/services/listener_amqp.ts

@@ -2,27 +2,27 @@ import { eventType, Listener } from './listener'
 import { EnqueueOption, amqpEnqueue } from '../amqp'
 import { UNOAPI_JOB_LISTENER } from '../defaults'
 
+const priorities = {
+  'qrcode': 5,
+  'status': 3,
+  'history': 0,
+  'append': 5,
+  'notify': 5,
+  'message': 5,
+  'update': 3,
+  'delete': 3,
+}
+
 export class ListenerAmqp implements Listener {
   private queueListener: string
 
-  private static priorities = {
-    qrcode: 5,
-    status: 3,
-    history: 0,
-    append: 5,
-    notify: 5,
-    message: 5,
-    update: 3,
-    delete: 3,
-  }
-
   constructor(queueListener = UNOAPI_JOB_LISTENER) {
     this.queueListener = queueListener
   }
 
   public async process(phone: string, messages: object[], type: eventType) {
     const options: Partial<EnqueueOption> = {}
-    options.priority = ListenerAmqp.priorities[type] || 5
+    options.priority = priorities[type] || 5
     await amqpEnqueue(this.queueListener, phone, { messages, type }, options)
   }
 }