[core] Update yarn, engines

Fix #191

.github/workflows/build.yaml

@@ -6,18 +6,12 @@ on:
       - "*"
 
 jobs:
-  deploy-docker:
-    runs-on: ubuntu-latest
+  docker-amd64:
+    runs-on: buildjet-4vcpu-ubuntu-2204
 
     steps:
       - name: Checkout
         uses: actions/checkout@v3
-
-      - name: Set up QEMU
-        uses: docker/setup-qemu-action@v2
-        with:
-          platforms: 'amd64'
-
       - name: Set up Docker Buildx
         uses: docker/setup-buildx-action@v2
 
@@ -26,9 +20,9 @@ jobs:
         uses: docker/metadata-action@v4
         with:
           images: ${{ secrets.DOCKER_IMAGE }}
-          flavor: latest=true
+          flavor: latest=false
           tags: |
-            type=semver,pattern={{version}}
+            type=raw,value=latest
 
       - name: Login to image repository
         if: github.ref_type == 'tag'
@@ -46,3 +40,38 @@ jobs:
           push: ${{ github.ref_type == 'tag' }}
           tags: ${{ steps.meta.outputs.tags }}
           labels: ${{ steps.meta.outputs.labels }}
+
+  docker-arm:
+    runs-on: buildjet-4vcpu-ubuntu-2204-arm
+
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v3
+      - name: Set up Docker Buildx
+        uses: docker/setup-buildx-action@v2
+
+      - name: Docker meta
+        id: meta
+        uses: docker/metadata-action@v4
+        with:
+          images: ${{ secrets.DOCKER_IMAGE }}
+          flavor: latest=false
+          tags: |
+            type=raw,value=arm
+
+      - name: Login to image repository
+        if: github.ref_type == 'tag'
+        uses: docker/login-action@v2
+        with:
+          username: ${{ secrets.DOCKER_USER }}
+          password: ${{ secrets.DOCKER_TOKEN }}
+
+      - name: Build and push
+        uses: docker/build-push-action@v4
+        with:
+          context: .
+          file: Dockerfile
+          platforms: 'linux/arm64'
+          push: ${{ github.ref_type == 'tag' }}
+          tags: ${{ steps.meta.outputs.tags }}
+          labels: ${{ steps.meta.outputs.labels }}

.yarnrc.yml

@@ -1,3 +1,3 @@
 nodeLinker: node-modules
 
-yarnPath: .yarn/releases/yarn-3.6.1.cjs
+yarnPath: .yarn/releases/yarn-3.6.3.cjs

Dockerfile

@@ -8,7 +8,7 @@ ENV PUPPETEER_SKIP_DOWNLOAD=True
 WORKDIR /src
 COPY package.json .
 COPY yarn.lock .
-RUN yarn set version 3.6.1
+RUN yarn set version 3.6.3
 RUN yarn install
 
 # App

README.md

@@ -40,7 +40,6 @@
 - Receive messages  
 - Message replies  
 - Send location  
-- Send buttons  
 - Receive location  
 - React to messages  
 - Send media (images/documents/files) 
@@ -110,7 +109,7 @@ docker pull devlikeapro/whatsapp-http-api
 ![](./docs/site/content/en/docs/overview/quick-start//images/versions/plus.png) For Plus version, we use login to get the image before:
 
 ```bash
-docker login -u devlikeapro -p {PASSWORD}
+docker login -u devlikeapro -p {KEY}
 docker pull devlikeapro/whatsapp-http-api-plus
 docker logout
 ```

docs/site/content/en/docs/how-to/chats/index.md

@@ -6,7 +6,7 @@ date: 2020-10-06T08:48:45+00:00
 lastmod: 2020-10-06T08:48:45+00:00
 draft: false
 images: []
-weight: 126
+weight: 127
 ---
 
 Chats methods.

docs/site/content/en/docs/how-to/install/index.md

@@ -0,0 +1,115 @@
+---
+title : "Install"
+description: "How to install and update WAHA"
+lead: ""
+date: 2020-10-06T08:48:45+00:00
+lastmod: 2020-10-06T08:48:45+00:00
+draft: false
+images: []
+weight: 109
+---
+
+On the page you'll find answers on how to install WAHA.
+
+If you wish to read a quick start guide which show you how to send you first message via HTTP API
+please go to [**Quick Start ->**]({{< relref "/docs/overview/quick-start" >}}).
+
+WAHA is distributed in two versions, that have a similar installation instructions.
+- WAHA Core ![](/images/versions/core.png) - the basic version that meet almost 80% people's needs. 100% free and [open source ->](https://github.com/devlikeapro/whatsapp-http-api).
+- WAHA Plus ![](/images/versions/plus.png) - the version with advanced messages, security, and reliability features. Donations, no license expiration, quick updates, read more about [Plus Version →]({{< relref "plus-version" >}})
+
+## Requirements
+
+Only thing that you must have - installed docker. Please follow the original
+instruction <a href="https://docs.docker.com/get-docker/" target="_blank" rel="noopener">how to install docker -></a>.
+
+{{< details "Why Docker?" >}}
+Docker makes it easy to ship all-in-one solution with the runtime and dependencies. You don't have to worry about
+language-specific libraries or chrome installation.
+
+Also, Docker makes installation and update processes so simple, just one command!
+{{< /details >}}
+
+## WAHA Core
+Download the image:
+```bash
+docker pull devlikeapro/whatsapp-http-api
+```
+
+Run the container:
+```bash
+docker run -it -p 3000:3000/tcp devlikeapro/whatsapp-http-api
+```
+
+Open API documentation [http://localhost:3000](http://localhost:3000).
+
+## WAHA Plus
+Before installing WAHA Plus version you need to get a key, `{KEY}` in below commands, in format `dckr_pat_1111`
+
+We distribute the key via two platforms (Boosty and Patreon) and you'll find the active key **in the latest post**.
+Keep in mind that we publish new key every month, so you must get the latest active key in order to download
+the latest image.
+
+Read more about [**Plus Version →**]({{< relref "plus-version" >}})
+
+{{< alert icon="👉" text="Subscribe as **PRO** level and get your personal key which won't expire every month while you're supporting the project" />}}
+
+Download the image:
+```bash
+docker login -u devlikeapro -p {KEY}
+docker pull devlikeapro/whatsapp-http-api-plus
+docker logout
+```
+
+Run the container:
+```bash
+docker run -it -p 3000:3000/tcp devlikeapro/whatsapp-http-api-plus
+```
+
+Open API documentation [http://localhost:3000](http://localhost:3000).
+
+## ARM
+If you’re using **ARM** processor (like Apple Silicon, Apple M1, etc.) - add `:arm` tag at the end of the image name in the above commands.
+- **WAHA Core** - `devlikeapro/whatsapp-http-api:arm`
+- **WAHA Plus** - `devlikeapro/whatsapp-http-api-plus:arm`
+
+You can also rename the image after you downloaded it with `docker tag` command,
+so you can use the same image names in commands:
+```bash
+# Rename WAHA Core ARM
+docker tag devlikeapro/whatsapp-http-api:arm devlikeapro/whatsapp-http-api
+
+# Rename WAHA Plus ARM
+docker tag devlikeapro/whatsapp-http-api-plus:arm devlikeapro/whatsapp-http-api-plus
+```
+
+
+## Update WAHA
+{{< alert icon="💡" text="Please test all new versions in the development environment before updating production!" />}}
+
+The commands are the same as for downloading, expected you need to restart **all working containers** after you download new image.
+
+**WAHA Core** - download new image
+```bash
+# Download the image
+docker pull devlikeapro/whatsapp-http-api
+
+# Restart all containers
+docker stop whatsapp-http-api
+docker rm whatsapp-http-api
+docker run -it --rm -p 3000:3000/tcp --name whatsapp-http-api devlikeapro/whatsapp-http-api
+```
+
+**WAHA Plus** - download new image (please use **the latest key** from Boosty or Patreon)
+```bash
+# Download the image
+docker login -u devlikeapro -p {KEY}
+docker pull devlikeapro/whatsapp-http-api-plus
+docker logout
+docker stop whatsapp-http-api
+
+# Restart all containers
+docker stop whatsapp-http-api
+docker rm whatsapp-http-api
+docker run -it --rm -p 3000:3000/tcp --name whatsapp-http-api devlikeapro/whatsapp-http-api
+```

docs/site/content/en/docs/how-to/plus-version/index.md

@@ -86,6 +86,7 @@ Here's available tiers for our supporters:
 | Access to WAHA Plus  ![](/images/versions/plus.png) docker image.                   |   ✔️    |    ✔️    |   ✔️    |
 | An invitation to a private Github repository so you have the WAHA Plus source code. |   ➖️    |    ✔️    |   ✔️️   |
 | Access to a Telegram group where we provide support and assistance.                 |   ➖️    |    ➖     |   ✔️    |
+| Personal key to Docker Hub.                                                         |   ➖️    |    ➖     |   ✔️    |
 | **Donation**                                                                        | **$19** | **$39**  | **$99** |
 
 For **$19** donation you get:
@@ -131,7 +132,7 @@ Go ahead and get your own WhatsApp HTTP API!
 ### Install Plus
 After you get the password, use it to login and download docker image:
 ```bash
-docker login -u devlikeapro -p {PASSWORD}
+docker login -u devlikeapro -p {KEY}
 docker pull devlikeapro/whatsapp-http-api-plus
 docker logout
 ```

docs/site/content/en/docs/how-to/polls/index.md

@@ -0,0 +1,219 @@
+---
+title: "Polls"
+description: "How to send polls and receive votes"
+lead: ""
+date: 2020-10-06T08:48:45+00:00
+lastmod: 2020-10-06T08:48:45+00:00
+draft: false
+images: [ ]
+weight: 126
+---
+
+**Available on NOWEB engine only**.
+
+Waiting for WEBJS engine to support it, and we'll add it ASAP!
+
+![poll-example.jpg](poll-example.jpg)
+
+## Endpoints
+
+### Send poll
+
+Use the endpoint to send a poll!
+
+```bash
+POST /api/sendPoll
+```
+
+The request body is pretty simple:
+```json
+{
+  "session": "default",
+  "chatId": "123123123@c.us",
+  "poll": {
+    "name": "How are you?",
+    "options": [
+      "Awesome!",
+      "Good!",
+      "Not bad!"
+    ],
+    "multipleAnswers": false
+  }
+}
+```
+
+The response you get back:
+
+```json
+{
+  "id": "true_321321321@c.us_83ACBAAAAAAAAAAAAAAAAAAAA",
+  "other-fields-here": "value"
+}
+```
+
+You must save the `id` field from the response in your database so that you can identify the poll for which you receive
+a vote (see webhook events below).
+
+## Events
+
+### poll.vote
+
+With this event, you receive new votes for the poll sent.
+
+#### Vote from a user in direct messages.
+
+```json
+{
+  "event": "poll.vote",
+  "session": "default",
+  "payload": {
+    "vote": {
+      "id": "false_1111111111@c.us_83ACBE602A05C79B234B54415E95EE8A",
+      "to": "me",
+      "from": "1111111@c.us",
+      "fromMe": false,
+      "selectedOptions": [
+        "Awesome!"
+      ],
+      "timestamp": 1692861427
+    },
+    "poll": {
+      "id": "true_1111111111@c.us_BAE5F2EF5C69001E",
+      "to": "1111111111@c.us",
+      "from": "me",
+      "fromMe": true
+    }
+  },
+  "engine": "NOWEB"
+}
+```
+
+#### Do I receive votes only for my polls?
+
+No, you receive all votes. Keep in mind that you'll get all votes with this event, even from other polls. To identify
+that it's your poll, look at the `poll.fromMe` field.
+
+#### How to handle multiple-answer votes
+
+For `multipleAnswers: true`, you receive the `selectedOptions` with all the selected values at a certain moment. So if a
+user has chosen 3 options from the poll, you will receive **3** `poll.vote` events:
+
+1. `selectedOptions: ["First"]`
+2. `selectedOptions: ["First", "Second"]`
+3. `selectedOptions: ["First", "Second", "Third"]`
+
+#### Timestamp
+
+If a user clicks on the poll multiple times, you will receive multiple `poll.vote` events. This is true for
+both `multipleAnswers: false` (when a user changes their mind about answers) and `multipleAnswers: true` (when a user
+selects two or more options) events.
+
+There is a little chance that you may receive votes in the wrong order (due to the nature of HTTP and Webhooks),
+like `1-3-2` instead of `1-2-3`. To determine the right order, look at the `timestamp` field. The event with a
+higher `timestamp` value is more recent.
+
+👉 It's important to save the `timestamp` for each vote in your database and compare them as numbers, without converting to
+internal datetime. Right now, the `timestamp` shows the timestamp in seconds, but it may be changed to milliseconds in
+the future.
+
+#### Vote from a user in a group
+
+```json
+{
+  "event": "poll.vote",
+  "session": "default",
+  "payload": {
+    "vote": {
+      "id": "false_3333333333333@g.us_1C18A7EAADD2A8D0324755D241C4238A",
+      "to": "3333333333333@g.us",
+      "from": "1111111111@c.us",
+      "fromMe": false,
+      "selectedOptions": [
+        "Awesome!"
+      ],
+      "timestamp": 1692861427
+    },
+    "poll": {
+      "id": "true_3333333333333@g.us_BAE5304BA1ECF704",
+      "to": "33333333333333@g.us",
+      "from": "222222222@c.us",
+      "fromMe": true
+    }
+  },
+  "engine": "NOWEB"
+}
+```
+
+### poll.vote.failed
+
+There may be cases when WAHA fails to decrypt a vote from the user. In such cases, you will receive
+a `poll.vote.failed` event on your webhook.
+
+The payload for `poll.vote.failed` is the same as for `poll.vote`, but with an empty list in `selectedOptions`.
+
+```json
+{
+  "event": "poll.vote.failed",
+  "session": "default",
+  "payload": {
+    "vote": {
+      "id": "false_11111111111@c.us_2E8C4CDA89EDE3BC0BC7F605364B8451",
+      "to": "me",
+      "from": "111111111@c.us",
+      "fromMe": false,
+      "selectedOptions": [],
+      "timestamp": 1692956972
+    },
+    "poll": {
+      "id": "true_1111111111@c.us_BAE595F4E0A2042C",
+      "to": "111111111@c.us",
+      "from": "me",
+      "fromMe": true
+    }
+  },
+  "engine": "NOWEB"
+}
+```
+
+#### How should I handle poll.vote.failed events?
+
+When you send a poll, save the poll configuration (question and options) in your database with the `id` field from the
+response you received from `POST /api/sendPoll`.
+
+Later, when you receive a `poll.vote.failed` event, find the `id` for the poll in the database and repeat the same
+question to the user, apologizing for the inconvenience.
+For example, you can say:
+
+> Sorry, we don't understand your choice 😞
+>
+> Please click one more time on the message below 👇
+
+After the user clicks on the poll again, you will receive a `poll.vote` event with their choice.
+
+![handle-poll-vote-failed.jpg](handle-poll-vote-failed.jpg)
+
+#### How to test poll.vote.failed events?
+
+To receive `poll.vote.failed` events, follow these steps:
+
+1. Start a session and authorize it with a QR code.
+2. Send a poll to a chat.
+3. Stop the session (logout is not required).
+4. Start the session again.
+5. Vote on the poll.
+6. You will receive a `poll.vote.failed` event.
+
+#### Why does the poll.vote.failed event occur and when will it be fixed?
+
+The issue occurs because WAHA does not have a proper storage system, but polls require proper storage in order to
+decrypt votes later.
+
+There will be two fixes for this:
+
+1. In the short term, a [local file storage](https://github.com/devlikeapro/whatsapp-http-api/issues/188) will be used
+   to save poll keys.
+2. In the long term, work is being done
+   on [remote storages](https://github.com/devlikeapro/whatsapp-http-api/issues/41).
+
+Even after these fixes are implemented, it's better to handle `poll.vote.failed` events anyway, so your application is
+prepared for such cases!

docs/site/content/en/docs/how-to/presence/index.md

@@ -129,7 +129,8 @@ You can subscribe to presence information by calling `POST /api/{session}/presen
 You can get later presence information for the chat with above `GET` endpoints or by listening to `presence.update`
 webhook.
 
-## Webhook
+## Events
+### presence.update
 
 You can subscribe to `presence.update` webhook event to get the most recent presence information.
 

docs/site/content/en/docs/how-to/send-messages/index.md

@@ -31,7 +31,7 @@ When sending media (images, voice, files) you can either use:
 
 ## Endpoints
 
-### Send text ![](/images/versions/core.png)
+### Send text
 To send text message - use `POST /api/sendText` with example payload.
 ```json
 {
@@ -58,7 +58,12 @@ also mention it in `mentions` in format `2132132130@c.us`
 }
 ```
 
-### Reply on message ![](/images/versions/core.png)
+### Send poll
+We have a dedicated page [how to send polls and receive votes]({{< relref "/docs/how-to/polls" >}})!
+
+![](poll-example.jpg)
+
+### Reply on message
 To reply on a message - use `POST /api/reply` with example payload.
 ```json
 {
@@ -70,9 +75,9 @@ To reply on a message - use `POST /api/reply` with example payload.
 ```
 
 #### Reply files ![](/images/versions/plus-soon.png)
-WAHA does not support reply with files (images, voice, etc). If you're interested in it - please create an issue in GitHub.
+WAHA does not support reply with files (images, voice, etc.). If you're interested in it - please create an issue in GitHub.
 
-### Add a reaction ![](/images/versions/core.png)
+### Add a reaction
 Use `PUT /api/reaction` method to set reaction to a message.
 
 {{< alert icon="👉" text="Reaction API uses PUT, not POST request! Please make sure you send right request." />}}

docs/site/content/en/docs/how-to/sessions/index.md

@@ -128,6 +128,28 @@ In order to log out the session - call `POST /api/sessions/logout`
 }
 ```
 
+### Get me
+
+Get information about the associated account for that session (if any).
+```bash
+GET /api/sessions/{session}/me
+```
+
+**Authenticated and working** session's response:
+```json
+{
+  "id": "11111111111@c.us",
+  "pushName": "string"
+}
+```
+
+**Stopped** or **not authenticated** session returns null:
+```json
+null
+```
+
+
+
 
 ## Authentication
 ### Get QR

docs/site/content/en/docs/how-to/webhooks/index.md

@@ -284,6 +284,60 @@ It's an internal engine's state, not **session** `status`.
 }
 ```
 
+### poll.vote
+We have a dedicated page [how to send polls and receive votes]({{< relref "/docs/how-to/polls" >}})!
+
+```json
+{
+  "event": "poll.vote",
+  "session": "default",
+  "payload": {
+    "vote": {
+      "id": "false_1111111111@c.us_83ACBE602A05C79B234B54415E95EE8A",
+      "to": "me",
+      "from": "1111111@c.us",
+      "fromMe": false,
+      "selectedOptions": ["Awesome!"],
+      "timestamp": 1692861427
+    },
+    "poll": {
+      "id": "true_1111111111@c.us_BAE5F2EF5C69001E",
+      "to": "1111111111@c.us",
+      "from": "me",
+      "fromMe": true
+    }
+  },
+  "engine": "NOWEB"
+}
+```
+
+### poll.vote.failed
+We have a dedicated page [how to send polls and receive votes]({{< relref "/docs/how-to/polls" >}})!
+
+```json
+{
+  "event": "poll.vote.failed",
+  "session": "default",
+  "payload": {
+    "vote": {
+      "id": "false_11111111111@c.us_2E8C4CDA89EDE3BC0BC7F605364B8451",
+      "to": "me",
+      "from": "111111111@c.us",
+      "fromMe": false,
+      "selectedOptions": [],
+      "timestamp": 1692956972
+    },
+    "poll": {
+      "id": "true_1111111111@c.us_BAE595F4E0A2042C",
+      "to": "111111111@c.us",
+      "from": "me",
+      "fromMe": true
+    }
+  },
+  "engine": "NOWEB"
+}
+```
+
 ## Webhooks Advanced ![](/images/versions/plus.png)
 ### HMAC authentication
 

docs/site/content/en/docs/overview/changelog.md

@@ -1,7 +1,7 @@
 ---
 title: "Changelog"
 description: "WAHA's changelog"
-lead: "Changelog"
+lead: "You can find here the list of changes made to WAHA."
 date: 2020-10-06T08:49:31+00:00
 lastmod: 2020-10-06T08:49:31+00:00
 draft: false
@@ -12,8 +12,17 @@ menu:
 weight: 199
 toc: true
 ---
+
+If you wish to get and read Release Notes - read them on one of our platforms, **these posts are FREE**.
+- [**Boosty ->**](https://boosty.to/wa-http-api)
+- [**Patreon ->**](patreon.com/wa_http_api)
+
+You even can **subscribe to get new updates** there!
+
 ## 2023.9
 September 2023
+- Add `GET /api/sessions/{session/me` endpoint so you [can get the phone number associated with the session](https://waha.devlike.pro/docs/how-to/sessions/#get-me)
+- Add [polls support in NOWEB engine](https://waha.devlike.pro/docs/how-to/polls)
 - Add dedicated [Get QR](https://waha.devlike.pro/docs/how-to/sessions/#get-qr) endpoint!
 - Support [pairing method (NOWEB)](https://waha.devlike.pro/docs/how-to/sessions/#get-pairing-code) - you can connect with a code instead of QR.
 - Add string field `ackName: DEVICE|READ|...` in [message.ack payload](https://waha.devlike.pro/docs/how-to/webhooks/#messageack)

docs/site/content/en/docs/overview/faq.md

@@ -13,26 +13,6 @@ weight: 130
 toc: true
 ---
 
-## How to update?
-
-{{< alert icon="💡" text="Please test all new versions in the development environment before updating production!" />}}
-
-![](/images/versions/core.png) For **Core** version the command is
-
-```bash
-docker pull devlikeapro/whatsapp-http-api
-```
-
-![](/images/versions/plus.png) For **Plus** version, we use login to get the image before:
-
-```bash
-docker login -u devlikeapro -p {PASSWORD}
-docker pull devlikeapro/whatsapp-http-api-plus
-docker logout
-```
-
-Read more about how to get `PASSWORD` for [Plus Version →]({{< relref "plus-version" >}})
-
 ## How much CPU and Memory does WhatsApp HTTP API consume?
 
 The benchmark has been made on **Intel(R) Core(TM) i7-10510U CPU @ 1.80GHz**.

docs/site/content/en/docs/overview/introduction.md

@@ -37,7 +37,6 @@ Here's the available features:
 - Receive messages
 - Message replies
 - Send location
-- Send buttons
 - Receive location
 - React to messages
 - Send media (images/documents/files) ![](/images/versions/plus.png)

docs/site/content/en/docs/overview/quick-start/index.md

@@ -29,7 +29,7 @@ When you are ready - come back and follows the below steps to send the first tex
 Docker makes it easy to ship all-in-one solution with the runtime and dependencies. You don't have to worry about
 language-specific libraries or chrome installation.
 
-Also Docker makes installation and update processes so simple, just one command!
+Also, Docker makes installation and update processes so simple, just one command!
 {{< /details >}}
 
 ## Send your first message
@@ -63,7 +63,7 @@ docker pull devlikeapro/whatsapp-http-api
 ![](/images/versions/plus.png) For Plus version, we use login to get the image before:
 
 ```bash
-docker login -u devlikeapro -p {PASSWORD}
+docker login -u devlikeapro -p {KEY}
 docker pull devlikeapro/whatsapp-http-api-plus
 docker logout
 ```
@@ -72,7 +72,7 @@ Read more about how to get `PASSWORD` for [Plus Version →]({{< relref "plus-ve
 
 #### 1.1 Download image on ARM
 
-If you're using ARM (like Apple Silicon, Apple M1, etc) - use following commands to download the image
+If you're using ARM (like Apple Silicon, Apple M1, etc.) - use following commands to download the image
 
 ![](/images/versions/core.png) For Core version the command is
 ```bash
@@ -84,12 +84,12 @@ docker tag devlikeapro/whatsapp-http-api:arm devlikeapro/whatsapp-http-api
 
 ![](/images/versions/plus.png) For Plus version the command is:
 ```bash
-docker login -u devlikeapro -p {PASSWORD}
+docker login -u devlikeapro -p {KEY}
 docker pull devlikeapro/whatsapp-http-api-plus:arm
 docker logout
 
 # Rename it, so you can use devlikeapro/whatsapp-http-api image in other place
-docker tag devlikeapro/whatsapp-http-api-plus:arm devlikeapro/whatsapp-http-api
+docker tag devlikeapro/whatsapp-http-api-plus:arm devlikeapro/whatsapp-http-api-plus
 ```
 
 ### 2. Run WhatsApp HTTP API

examples/python/README.md

@@ -28,7 +28,7 @@ docker run -it --rm --network=host -e WHATSAPP_HOOK_URL=http://localhost:5000/bo
 
 #### Download image - ARM
 
-If you're using ARM (like Apple Silicon, Apple M1, etc) - use following commands to download the image
+If you're using ARM (like Apple Silicon, Apple M1, etc.) - use following commands to download the image
 
 ![](/images/versions/core.png) For Core version the command is
 ```bash

package.json

@@ -53,7 +53,7 @@
     "rxjs": "^7.1.0",
     "swagger-ui-express": "^4.1.4",
     "venom-bot": "5.0.1",
-    "whatsapp-web.js": "https://github.com/pedroslopez/whatsapp-web.js"
+    "whatsapp-web.js": "https://github.com/elhumbertoz/whatsapp-web.js#patch-2"
   },
   "devDependencies": {
     "@nestjs/cli": "^9.0.0",
@@ -92,5 +92,5 @@
     "coverageDirectory": "../coverage",
     "testEnvironment": "node"
   },
-  "packageManager": "yarn@3.6.0"
+  "packageManager": "yarn@3.6.3"
 }

src/api/chatting.controller.ts

@@ -11,9 +11,9 @@ import {
   MessageImageRequest,
   MessageLinkPreviewRequest,
   MessageLocationRequest,
+  MessagePollRequest,
   MessageReactionRequest,
   MessageReplyRequest,
-  MessageTextButtonsRequest,
   MessageTextQuery,
   MessageTextRequest,
   MessageVoiceRequest,
@@ -60,11 +60,13 @@ export class ChattingController {
     return whatsapp.sendText(request);
   }
 
-  @Post('/sendTextButtons')
-  @ApiOperation({ summary: 'Send a text message with buttons' })
-  sendTextButtons(@Body() request: MessageTextButtonsRequest) {
+  @Post('/sendPoll')
+  @ApiOperation({
+    summary: 'Send a poll with options. You can use it as buttons replace',
+  })
+  sendPoll(@Body() request: MessagePollRequest) {
     const whatsapp = this.manager.getSession(request.session);
-    return whatsapp.sendTextButtons(request);
+    return whatsapp.sendPoll(request);
   }
 
   @Post('/sendLocation')

src/api/groups.controller.ts

@@ -51,8 +51,14 @@ export class GroupsController {
 
   @Put(':id/settings/security/info-admin-only')
   @SessionApiParam
-  @ApiOperation({ summary: 'Updates the group settings to only allow admins to edit group info (title, description, photo).' })
-  setGroupAdminOnly(@SessionParam session: WhatsappSession, @Param('id') id: string) {
+  @ApiOperation({
+    summary:
+      'Updates the group settings to only allow admins to edit group info (title, description, photo).',
+  })
+  setGroupAdminOnly(
+    @SessionParam session: WhatsappSession,
+    @Param('id') id: string,
+  ) {
     return session.setInfoAdminsOnly(id, true);
   }
 

src/api/sessions.controller.ts

@@ -6,16 +6,21 @@ import { SessionManager } from '../core/abc/manager.abc';
 import { parseBool } from '../helpers';
 import {
   ListSessionsQuery,
+  MeInfo,
   SessionDTO,
+  SessionInfo,
   SessionLogoutRequest,
   SessionStartRequest,
   SessionStopRequest,
 } from '../structures/sessions.dto';
+import { SessionApiParam, SessionParam } from './helpers';
+import { WhatsappSession } from '../core/abc/session.abc';
+import { WAHAChatPresences } from '../structures/presence.dto';
 
 @ApiSecurity('api_key')
 @Controller('api/sessions')
 @ApiTags('sessions')
-export class SessionsController {
+class SessionsController {
   constructor(private manager: SessionManager) {}
 
   @Post('/start/')
@@ -45,8 +50,24 @@ export class SessionsController {
   }
 
   @Get('/')
-  async list(@Query() query: ListSessionsQuery): Promise<SessionDTO[]> {
+  async list(@Query() query: ListSessionsQuery): Promise<SessionInfo[]> {
     const all = parseBool(query.all);
     return this.manager.getSessions(all);
   }
 }
+
+@ApiSecurity('api_key')
+@Controller('api/sessions/:session')
+@ApiTags('sessions')
+class SessionController {
+  constructor(private manager: SessionManager) {}
+
+  @Get('me')
+  @SessionApiParam
+  @ApiOperation({ summary: 'Get information about the authenticated account' })
+  getMe(@SessionParam session: WhatsappSession): Promise<MeInfo> {
+    return session.getSessionMeInfo();
+  }
+}
+
+export { SessionController, SessionsController };

src/core/abc/manager.abc.ts

@@ -3,6 +3,7 @@ import { OnApplicationShutdown } from '@nestjs/common';
 import { WAHAEngine } from '../../structures/enums.dto';
 import {
   SessionDTO,
+  SessionInfo,
   SessionLogoutRequest,
   SessionStartRequest,
   SessionStopRequest,
@@ -35,5 +36,5 @@ export abstract class SessionManager implements OnApplicationShutdown {
 
   abstract getSession(name: string, error?: boolean): WhatsappSession;
 
-  abstract getSessions(all: boolean): Promise<SessionDTO[]>;
+  abstract getSessions(all: boolean): Promise<SessionInfo[]>;
 }

src/core/abc/session.abc.ts

@@ -12,9 +12,9 @@ import {
   MessageImageRequest,
   MessageLinkPreviewRequest,
   MessageLocationRequest,
+  MessagePollRequest,
   MessageReactionRequest,
   MessageReplyRequest,
-  MessageTextButtonsRequest,
   MessageTextRequest,
   MessageVoiceRequest,
 } from '../../structures/chatting.dto';
@@ -30,7 +30,11 @@ import {
   ParticipantsRequest,
 } from '../../structures/groups.dto';
 import { WAHAChatPresences } from '../../structures/presence.dto';
-import { ProxyConfig, SessionConfig } from '../../structures/sessions.dto';
+import {
+  MeInfo,
+  ProxyConfig,
+  SessionConfig,
+} from '../../structures/sessions.dto';
 import { NotImplementedByEngineError } from '../exceptions';
 import { LocalSessionStorage, MediaStorage } from './storage.abc';
 import { OTPRequest, RequestCodeRequest } from '../../structures/auth.dto';
@@ -167,6 +171,10 @@ export abstract class WhatsappSession {
 
   abstract getScreenshot(): Promise<Buffer | string>;
 
+  public getSessionMeInfo(): Promise<MeInfo | null> {
+    throw new NotImplementedByEngineError();
+  }
+
   /**
    * Other methods
    */
@@ -176,7 +184,9 @@ export abstract class WhatsappSession {
 
   abstract sendContactVCard(request: MessageContactVcardRequest);
 
-  abstract sendTextButtons(request: MessageTextButtonsRequest);
+  sendPoll(request: MessagePollRequest) {
+    throw new NotImplementedByEngineError();
+  }
 
   abstract sendLocation(request: MessageLocationRequest);
 

src/core/app.module.core.ts

@@ -8,7 +8,10 @@ import { ContactsController } from '../api/contacts.controller';
 import { GroupsController } from '../api/groups.controller';
 import { PresenceController } from '../api/presence.controller';
 import { ScreenshotController } from '../api/screenshot.controller';
-import { SessionsController } from '../api/sessions.controller';
+import {
+  SessionController,
+  SessionsController,
+} from '../api/sessions.controller';
 import { VersionController } from '../api/version.controller';
 import { WhatsappConfigService } from '../config.service';
 import { SessionManager } from './abc/manager.abc';
@@ -39,6 +42,7 @@ export const IMPORTS = [
 export const CONTROLLERS = [
   AuthController,
   SessionsController,
+  SessionController,
   ChattingController,
   ChatsController,
   StatusController,

src/core/manager.core.ts

@@ -10,6 +10,7 @@ import { WAHAEngine, WAHASessionStatus } from '../structures/enums.dto';
 import {
   ProxyConfig,
   SessionDTO,
+  SessionInfo,
   SessionLogoutRequest,
   SessionStartRequest,
   SessionStopRequest,
@@ -191,7 +192,7 @@ export class SessionManagerCore extends SessionManager {
     return session;
   }
 
-  async getSessions(all: boolean): Promise<SessionDTO[]> {
+  async getSessions(all: boolean): Promise<SessionInfo[]> {
     if (!this.session) {
       if (!all) {
         return [];
@@ -201,14 +202,17 @@ export class SessionManagerCore extends SessionManager {
           name: this.DEFAULT,
           status: WAHASessionStatus.STOPPED,
           config: undefined,
+          me: null,
         },
       ];
     }
+    const me = await this.session.getSessionMeInfo().catch((err) => null);
     return [
       {
         name: this.session.name,
         status: this.session.status,
         config: this.session.sessionConfig,
+        me: me,
       },
     ];
   }

src/core/session.noweb.core.ts

@@ -1,31 +1,39 @@
 import makeWASocket, {
   Browsers,
   DisconnectReason,
+  getAggregateVotesInPollMessage,
+  getKeyAuthor,
   isJidGroup,
+  jidNormalizedUser,
   makeInMemoryStore,
   PresenceData,
+  proto,
   useMultiFileAuthState,
+  WAMessageContent,
+  WAMessageKey,
 } from '@adiwajshing/baileys';
 import { UnprocessableEntityException } from '@nestjs/common';
+import { request } from 'express';
 import * as fs from 'fs/promises';
 import { Agent } from 'https';
 import * as lodash from 'lodash';
+import { update } from 'lodash';
 import { PairingCodeResponse } from 'src/structures/auth.dto';
 import { Message } from 'whatsapp-web.js';
 
 import { flipObject, splitAt } from '../helpers';
 import {
-  Button,
   ChatRequest,
   CheckNumberStatusQuery,
   MessageContactVcardRequest,
+  MessageDestination,
   MessageFileRequest,
   MessageImageRequest,
   MessageLinkPreviewRequest,
   MessageLocationRequest,
+  MessagePollRequest,
   MessageReactionRequest,
   MessageReplyRequest,
-  MessageTextButtonsRequest,
   MessageTextRequest,
   MessageVoiceRequest,
   SendSeenRequest,
@@ -51,6 +59,11 @@ import {
 } from '../structures/presence.dto';
 import { WAMessage } from '../structures/responses.dto';
 import { BROADCAST_ID, TextStatus } from '../structures/status.dto';
+import {
+  PollVote,
+  PollVotePayload,
+  WAMessageAckBody,
+} from '../structures/webhooks.dto';
 import {
   ensureSuffix,
   WAHAInternalEvent,
@@ -62,8 +75,7 @@ import {
 } from './exceptions';
 import { createAgentProxy } from './helpers.proxy';
 import { QR } from './QR';
-import { WAMessageAckBody } from '../structures/webhooks.dto';
-import { update } from 'lodash';
+import { MeInfo } from '../structures/sessions.dto';
 
 // eslint-disable-next-line @typescript-eslint/no-var-requires
 const QRCode = require('qrcode');
@@ -115,6 +127,7 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
       logger: logger,
       mobile: false,
       defaultQueryTimeoutMs: undefined,
+      getMessage: (key) => this.getMessage(key),
     };
   }
 
@@ -126,6 +139,7 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
     const socketConfig = this.getSocketConfig(agent, state);
     const sock: any = makeWASocket(socketConfig);
     sock.ev.on(BaileysEvents.CREDS_UPDATE, saveCreds);
+    this.debugLogEnginesEvents(sock);
     return sock;
   }
 
@@ -159,6 +173,16 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
     this.events.emit(WAHAInternalEvent.engine_start);
   }
 
+  protected async getMessage(
+    key: WAMessageKey,
+  ): Promise<WAMessageContent | undefined> {
+    if (!this.store) {
+      return proto.Message.fromObject({});
+    }
+    const msg = await this.store.loadMessage(key.remoteJid!, key.id!);
+    return msg?.message || undefined;
+  }
+
   protected listenConnectionEvents() {
     this.log.debug(`Start listening ${BaileysEvents.CONNECTION_UPDATE}...`);
     this.sock.ev.on(BaileysEvents.CONNECTION_UPDATE, async (update) => {
@@ -196,6 +220,19 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
     });
   }
 
+  protected debugLogEnginesEvents(sock) {
+    if (!process.env.DEBUG) {
+      return;
+    }
+
+    sock.ev.process((events) => {
+      this.log.debug('Engine events');
+      this.log.debug('=============');
+      console.log(JSON.stringify(events));
+      this.log.debug('=============');
+    });
+  }
+
   stop() {
     this.sock.ev.removeAllListeners();
     this.sock.ws.removeAllListeners();
@@ -203,6 +240,19 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
     return;
   }
 
+  async getSessionMeInfo(): Promise<MeInfo | null> {
+    const me = this.sock.authState?.creds?.me;
+    if (!me) {
+      return null;
+    }
+    const meId = jidNormalizedUser(me.id);
+    const meInfo: MeInfo = {
+      id: toCusFormat(meId),
+      pushName: me.name,
+    };
+    return meInfo;
+  }
+
   /**
    * START - Methods for API
    */
@@ -281,22 +331,19 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
     return this.sock.sendMessage(chatId, message);
   }
 
-  sendTextButtons(request: MessageTextButtonsRequest) {
-    const buttons = request.buttons.map((button: Button) => {
-      return {
-        buttonId: button.id,
-        buttonText: { displayText: button.text },
-        type: 1,
-      };
-    });
-
-    const buttonMessage = {
-      text: request.title,
-      buttons: buttons,
-      headerType: 1,
+  async sendPoll(request: MessagePollRequest) {
+    const requestPoll = request.poll;
+    const poll = {
+      name: requestPoll.name,
+      values: requestPoll.options,
+      selectableCount: requestPoll.multipleAnswers
+        ? requestPoll.options.length
+        : 1,
     };
-
-    return this.sock.sendMessage(request.chatId, buttonMessage);
+    const message = { poll: poll };
+    const remoteJid = toJID(request.chatId);
+    const result = await this.sock.sendMessage(remoteJid, message);
+    return this.toWAMessage(result);
   }
 
   sendContactVCard(request: MessageContactVcardRequest) {
@@ -523,9 +570,9 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
 
   subscribe(event, handler) {
     if (event === WAHAEvents.MESSAGE) {
-      this.sock.ev.on(BaileysEvents.MESSAGES_UPSERT, ({ messages }) =>
-        this.handleIncomingMessages(messages, handler, false),
-      );
+      this.sock.ev.on(BaileysEvents.MESSAGES_UPSERT, ({ messages }) => {
+        this.handleIncomingMessages(messages, handler, false);
+      });
     } else if (event === WAHAEvents.MESSAGE_ANY) {
       this.sock.ev.on(BaileysEvents.MESSAGES_UPSERT, ({ messages }) =>
         this.handleIncomingMessages(messages, handler, true),
@@ -535,6 +582,7 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
       this.sock.ev.on(BaileysEvents.MESSAGES_UPDATE, (events) => {
         events
           .filter(isMine)
+          .filter(isAckUpdateMessageEvent)
           .map(this.convertMessageUpdateToMessageAck)
           .forEach(handler);
       });
@@ -553,6 +601,18 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
       this.sock.ev.on(BaileysEvents.PRESENCE_UPDATE, (data) =>
         handler(this.toWahaPresences(data.id, data.presences)),
       );
+    } else if (event === WAHAEvents.POLL_VOTE) {
+      this.sock.ev.on(BaileysEvents.MESSAGES_UPDATE, (events) => {
+        events.forEach((event) =>
+          this.handleMessagesUpdatePollVote(event, handler),
+        );
+      });
+    } else if (event === WAHAEvents.POLL_VOTE_FAILED) {
+      this.sock.ev.on(BaileysEvents.MESSAGES_UPSERT, ({ messages }) => {
+        messages.forEach((message) =>
+          this.handleMessageUpsertPollVoteFailed(message, handler),
+        );
+      });
     } else {
       throw new NotImplementedByEngineError(
         `Engine does not support webhook event: ${event}`,
@@ -565,6 +625,8 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
       // if there is no text or media message
       if (!message) return;
       if (!message.message) return;
+      // Ignore poll votes, we have dedicated handler for that
+      if (message.message.pollUpdateMessage) return;
       // Do not include my messages
       if (!includeFromMe && message.key.fromMe) {
         continue;
@@ -584,7 +646,7 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
   }
 
   protected toWAMessage(message): Promise<WAMessage> {
-    const destination = getDestination(message);
+    const fromToParticipant = getFromToParticipant(message);
     const id = buildMessageId(message.key);
     let body = message.message.conversation;
     if (!body) {
@@ -595,11 +657,11 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
     return Promise.resolve({
       id: id,
       timestamp: message.messageTimestamp,
-      from: toCusFormat(destination.from),
+      from: toCusFormat(fromToParticipant.from),
       fromMe: message.key.fromMe,
       body: body,
-      to: toCusFormat(destination.to),
-      participant: toCusFormat(destination.participant),
+      to: toCusFormat(fromToParticipant.to),
+      participant: toCusFormat(fromToParticipant.participant),
       // @ts-ignore
       hasMedia: Boolean(message.mediaUrl),
       // @ts-ignore
@@ -613,24 +675,26 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
       _data: message,
     });
   }
+
   protected convertMessageUpdateToMessageAck(event): WAMessageAckBody {
     const message = event;
-    const destination = getDestination(message);
+    const fromToParticipant = getFromToParticipant(message);
     const id = buildMessageId(message.key);
     const ack = message.update.status - 1;
     const body: WAMessageAckBody = {
       id: id,
-      from: toCusFormat(destination.from),
-      to: toCusFormat(destination.to),
-      participant: toCusFormat(destination.participant),
+      from: toCusFormat(fromToParticipant.from),
+      to: toCusFormat(fromToParticipant.to),
+      participant: toCusFormat(fromToParticipant.participant),
       fromMe: message.key.fromMe,
       ack: ack,
       ackName: WAMessageAck[ack] || ACK_UNKNOWN,
     };
     return body;
   }
+
   protected convertMessageReceiptUpdateToMessageAck(event): WAMessageAckBody {
-    const destination = getDestination(event);
+    const fromToParticipant = getFromToParticipant(event);
     const id = buildMessageId(event.key);
 
     const receipt = event.receipt;
@@ -644,9 +708,9 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
     }
     const body: WAMessageAckBody = {
       id: id,
-      from: toCusFormat(destination.from),
-      to: toCusFormat(destination.to),
-      participant: toCusFormat(destination.participant),
+      from: toCusFormat(fromToParticipant.from),
+      to: toCusFormat(fromToParticipant.to),
+      participant: toCusFormat(fromToParticipant.participant),
       fromMe: event.key.fromMe,
       ack: ack,
       ackName: WAMessageAck[ack] || ACK_UNKNOWN,
@@ -654,6 +718,77 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
     return body;
   }
 
+  protected async handleMessagesUpdatePollVote(event, handler) {
+    const { key, update } = event;
+    const pollUpdates = update?.pollUpdates;
+    if (!pollUpdates) {
+      return;
+    }
+
+    const pollCreationMessageKey = key;
+    const pollCreationMessage = await this.getMessage(key);
+    // Handle updates one by one, so we can get Vote Message for the specific vote
+    for (const pollUpdate of pollUpdates) {
+      const votes = getAggregateVotesInPollMessage({
+        message: pollCreationMessage,
+        pollUpdates: [pollUpdate],
+      });
+
+      // Get selected options for the author
+      const selectedOptions = [];
+      for (const voteAggregation of votes) {
+        for (const voter of voteAggregation.voters) {
+          if (voter === getKeyAuthor(pollUpdate.pollUpdateMessageKey)) {
+            selectedOptions.push(voteAggregation.name);
+          }
+        }
+      }
+
+      // Build payload and call the handler
+      const voteDestination = getDestination(pollUpdate.pollUpdateMessageKey);
+      const pollVote: PollVote = {
+        ...voteDestination,
+        selectedOptions: selectedOptions,
+        timestamp: pollUpdate.senderTimestampMs,
+      };
+      const payload: PollVotePayload = {
+        vote: pollVote,
+        poll: getDestination(pollCreationMessageKey),
+      };
+      handler(payload);
+    }
+  }
+  protected async handleMessageUpsertPollVoteFailed(message, handler) {
+    const pollUpdateMessage = message.message?.pollUpdateMessage;
+    if (!pollUpdateMessage) {
+      return;
+    }
+    const pollCreationMessageKey = pollUpdateMessage.pollCreationMessageKey;
+    const pollCreationMessage = await this.getMessage(pollCreationMessageKey);
+    if (pollCreationMessage) {
+      // We found message, so later the engine will issue a message.update message
+      return;
+    }
+
+    // We didn't find the creation message, so send failed one
+    const pollUpdateMessageKey = message.key;
+    const voteDestination = getDestination(pollUpdateMessageKey);
+    const pollVote: PollVote = {
+      ...voteDestination,
+      selectedOptions: [],
+      // change to below line when the PR merged, so we have the same timestamps
+      // https://github.com/WhiskeySockets/Baileys/pull/348
+      // Or without toNumber() - it depends on the PR above
+      // timestamp: pollUpdateMessage.senderTimestampMs.toNumber()
+      timestamp: message.messageTimestamp,
+    };
+    const payload: PollVotePayload = {
+      vote: pollVote,
+      poll: getDestination(pollCreationMessageKey),
+    };
+    handler(payload);
+  }
+
   private toWahaPresences(
     remoteJid,
     storedPresences: PresenceData[],
@@ -699,6 +834,9 @@ function toCusFormat(remoteJid) {
   if (!remoteJid) {
     return;
   }
+  if (remoteJid == 'me') {
+    return remoteJid;
+  }
   const number = remoteJid.split('@')[0];
   return ensureSuffix(number);
 }
@@ -752,7 +890,15 @@ function isMine(message) {
   return message?.key?.fromMe;
 }
 
-function getDestination(message) {
+function isNotMine(message) {
+  return !message?.key?.fromMe;
+}
+
+function isAckUpdateMessageEvent(event) {
+  return event?.update.status != null;
+}
+
+function getFromToParticipant(message) {
   const isGroupMessage = Boolean(message.key.participant);
   let participant: string;
   let to: string;
@@ -767,3 +913,36 @@ function getDestination(message) {
     participant: participant,
   };
 }
+
+function getTo(key, meId = undefined) {
+  // For group - always to group JID
+  const isGroupMessage = Boolean(key.participant);
+  if (isGroupMessage) {
+    return key.remoteJid;
+  }
+  if (key.fromMe) {
+    return key.remoteJid;
+  }
+  return meId || 'me';
+}
+
+function getFrom(key, meId) {
+  // For group - always from participant
+  const isGroupMessage = Boolean(key.participant);
+  if (isGroupMessage) {
+    return key.participant;
+  }
+  if (key.fromMe) {
+    return meId || 'me';
+  }
+  return key.remoteJid;
+}
+
+function getDestination(key, meId = undefined): MessageDestination {
+  return {
+    id: buildMessageId(key),
+    to: toCusFormat(getTo(key, meId)),
+    from: toCusFormat(getFrom(key, meId)),
+    fromMe: key.fromMe,
+  };
+}

src/core/session.venom.core.ts

@@ -2,7 +2,6 @@ import { UnprocessableEntityException } from '@nestjs/common/exceptions/unproces
 import { create, CreateConfig, Message, Whatsapp } from 'venom-bot';
 
 import {
-  Button,
   ChatRequest,
   CheckNumberStatusQuery,
   GetMessageQuery,
@@ -13,7 +12,6 @@ import {
   MessageLocationRequest,
   MessageReactionRequest,
   MessageReplyRequest,
-  MessageTextButtonsRequest,
   MessageTextRequest,
   WANumberExistResult,
 } from '../structures/chatting.dto';
@@ -202,23 +200,6 @@ export class WhatsappSessionVenomCore extends WhatsappSession {
     return this.whatsapp.markMarkSeenMessage(chat.chatId);
   }
 
-  sendTextButtons(request: MessageTextButtonsRequest) {
-    const buttons = request.buttons.map((button: Button) => {
-      return {
-        buttonId: button.id,
-        buttonText: {
-          displayText: button.text,
-        },
-      };
-    });
-    return this.whatsapp.sendButtons(
-      this.ensureSuffix(request.chatId),
-      request.title,
-      request.footer,
-      buttons,
-    );
-  }
-
   startTyping(chat: ChatRequest) {
     return this.whatsapp.startTyping(chat.chatId, false);
   }

src/core/session.webjs.core.ts

@@ -1,6 +1,5 @@
 import { UnprocessableEntityException } from '@nestjs/common/exceptions/unprocessable-entity.exception';
 import {
-  Buttons,
   Chat,
   Client,
   ClientOptions,
@@ -13,7 +12,6 @@ import {
 import { Message as MessageInstance } from 'whatsapp-web.js/src/structures';
 
 import {
-  Button,
   ChatRequest,
   CheckNumberStatusQuery,
   GetMessageQuery,
@@ -24,7 +22,6 @@ import {
   MessageLocationRequest,
   MessageReactionRequest,
   MessageReplyRequest,
-  MessageTextButtonsRequest,
   MessageTextRequest,
   MessageVoiceRequest,
   SendSeenRequest,
@@ -50,6 +47,8 @@ import {
   NotImplementedByEngineError,
 } from './exceptions';
 import { QR } from './QR';
+import { MeInfo } from '../structures/sessions.dto';
+import { jidNormalizedUser } from '@adiwajshing/baileys';
 
 // eslint-disable-next-line @typescript-eslint/no-var-requires
 const QRCode = require('qrcode');
@@ -113,6 +112,19 @@ export class WhatsappSessionWebJSCore extends WhatsappSession {
     return this.whatsapp.destroy();
   }
 
+  async getSessionMeInfo(): Promise<MeInfo | null> {
+    const clientInfo = this.whatsapp?.info;
+    if (!clientInfo) {
+      return null;
+    }
+    const wid = clientInfo.wid;
+    const meInfo: MeInfo = {
+      id: wid._serialized,
+      pushName: clientInfo.pushname,
+    };
+    return meInfo;
+  }
+
   protected listenConnectionEvents() {
     this.whatsapp.on(Events.QR_RECEIVED, (qr) => {
       this.log.debug('QR received');
@@ -173,20 +185,6 @@ export class WhatsappSessionWebJSCore extends WhatsappSession {
     );
   }
 
-  sendTextButtons(request: MessageTextButtonsRequest) {
-    const buttons = request.buttons.map((button: Button) => {
-      return {
-        id: button.id,
-        body: button.text,
-      };
-    });
-    const message = new Buttons('', buttons, request.title, request.footer);
-    return this.whatsapp.sendMessage(
-      this.ensureSuffix(request.chatId),
-      message,
-    );
-  }
-
   sendContactVCard(request: MessageContactVcardRequest) {
     throw new NotImplementedByEngineError();
   }

src/structures/chatting.dto.ts

@@ -8,6 +8,7 @@ import {
   VoiceBinaryFile,
   VoiceRemoteFile,
 } from './files.dto';
+import { ChatIdProperty } from './properties.dto';
 
 /**
  * Queries
@@ -25,9 +26,7 @@ export class MessageTextQuery extends SessionQuery {
 }
 
 export class ChatQuery extends SessionQuery {
-  @ApiProperty({
-    example: '11111111111@c.us',
-  })
+  @ChatIdProperty()
   chatId: string;
 }
 
@@ -48,9 +47,7 @@ export class GetPresenceQuery extends ChatQuery {}
  * Requests
  */
 export class ChatRequest extends SessionBaseRequest {
-  @ApiProperty({
-    example: '11111111111@c.us',
-  })
+  @ChatIdProperty()
   chatId: string;
 }
 
@@ -95,17 +92,6 @@ export class MessageTextRequest extends ChatRequest {
   mentions?: string[];
 }
 
-export class Button {
-  id: string;
-  text: string;
-}
-
-export class MessageTextButtonsRequest extends ChatRequest {
-  title: string;
-  footer?: string;
-  buttons?: Array<Button>;
-}
-
 export class MessageReplyRequest extends MessageTextRequest {
   text = 'Reply text';
   @ApiProperty({
@@ -167,3 +153,32 @@ export class MessageReactionRequest extends MessageRequest {
 export class WANumberExistResult {
   numberExists: boolean;
 }
+
+export class MessagePoll {
+  @ApiProperty({
+    example: 'How are you?',
+  })
+  name: string;
+
+  @ApiProperty({
+    example: ['Awesome!', 'Good!', 'Not bad!'],
+  })
+  options: string[];
+
+  multipleAnswers = false;
+}
+
+export class MessagePollRequest extends ChatRequest {
+  poll: MessagePoll;
+}
+
+export class MessageDestination {
+  @ApiProperty({
+    description: 'Message ID',
+    example: 'false_11111111111@c.us_AAAAAAAAAAAAAAAAAAAA',
+  })
+  id: string;
+  to: string;
+  from: string;
+  fromMe: boolean;
+}

src/structures/enums.dto.ts

@@ -8,6 +8,8 @@ export enum WAHAEvents {
   GROUP_JOIN = 'group.join',
   GROUP_LEAVE = 'group.leave',
   PRESENCE_UPDATE = 'presence.update',
+  POLL_VOTE = 'poll.vote',
+  POLL_VOTE_FAILED = 'poll.vote.failed',
 }
 
 export enum WAHASessionStatus {

src/structures/properties.dto.ts

@@ -0,0 +1,18 @@
+import { ApiProperty } from '@nestjs/swagger';
+
+function ChatIdProperty(options = undefined) {
+  options = options || {};
+  if (!options.example) {
+    options.example = '11111111111@c.us';
+  }
+  return ApiProperty(options);
+}
+
+function MessageIdProperty() {
+  return ApiProperty({
+    description: 'Message ID',
+    example: 'false_11111111111@c.us_AAAAAAAAAAAAAAAAAAAA',
+  });
+}
+
+export { ChatIdProperty, MessageIdProperty };

src/structures/responses.dto.ts

@@ -1,6 +1,7 @@
 import { ApiProperty } from '@nestjs/swagger';
 
 import { WAMessageAck } from './enums.dto';
+import { ChatIdProperty, MessageIdProperty } from './properties.dto';
 
 export class WALocation {
   description?: string | null;
@@ -9,10 +10,7 @@ export class WALocation {
 }
 
 export class WAMessage {
-  @ApiProperty({
-    description: 'Message ID',
-    example: 'false_11111111111@c.us_AAAAAAAAAAAAAAAAAAAA',
-  })
+  @MessageIdProperty()
   id: string;
 
   /**  */
@@ -22,7 +20,7 @@ export class WAMessage {
   })
   timestamp: number;
 
-  @ApiProperty({
+  @ChatIdProperty({
     description:
       'ID for the Chat that this message was sent to, except if the message was sent by the current user ',
   })
@@ -33,7 +31,7 @@ export class WAMessage {
   })
   fromMe: boolean;
 
-  @ApiProperty({
+  @ChatIdProperty({
     description: `
 * ID for who this message is for.
 * If the message is sent by the current user, it will be the Chat to which the message is being sent.

src/structures/sessions.dto.ts

@@ -2,6 +2,7 @@ import { ApiProperty } from '@nestjs/swagger';
 
 import { WAHASessionStatus } from './enums.dto';
 import { WebhookConfig } from './webhooks.config.dto';
+import { ChatIdProperty } from './properties.dto';
 
 /**
  * Queries
@@ -66,3 +67,13 @@ export class SessionDTO {
   status: WAHASessionStatus;
   config: SessionConfig;
 }
+
+export class MeInfo {
+  @ChatIdProperty()
+  id: string;
+  pushName: string;
+}
+
+export class SessionInfo extends SessionDTO {
+  me: MeInfo | null;
+}

src/structures/webhooks.dto.ts

@@ -2,16 +2,22 @@ import { ApiProperty } from '@nestjs/swagger';
 
 import { WAHAEngine, WAHAEvents, WAMessageAck } from './enums.dto';
 import { WAMessage } from './responses.dto';
+import { MessageDestination } from './chatting.dto';
+import { ChatIdProperty, MessageIdProperty } from './properties.dto';
 
 export class WAMessageAckBody {
-  @ApiProperty({
-    description: 'Message ID',
-    example: 'false_11111111111@c.us_AAAAAAAAAAAAAAAAAAAA',
-  })
+  @MessageIdProperty()
   id: string;
+
+  @ChatIdProperty()
   from: string;
+
+  @ChatIdProperty()
   to: string;
+
+  @ChatIdProperty()
   participant: string;
+
   fromMe: boolean;
   ack: WAMessageAck;
   ackName: string;
@@ -28,7 +34,7 @@ export class WAGroupPayload {
   })
   timestamp: number;
 
-  @ApiProperty({
+  @ChatIdProperty({
     description: 'ID for the Chat that this groupNotification was sent for',
   })
   chatId: string;
@@ -50,10 +56,34 @@ export class WAGroupPayload {
   recipientIds: string[];
 }
 
+export class PollVote extends MessageDestination {
+  @ApiProperty({
+    description: 'Option that user has selected',
+    example: ['Awesome!'],
+  })
+  selectedOptions: string[];
+
+  @ApiProperty({
+    description: 'Timestamp, ms',
+    example: 1692861369,
+  })
+  timestamp: number;
+}
+
+export class PollVotePayload {
+  vote: PollVote;
+  poll: MessageDestination;
+}
+
 export class WAWebhook {
   event: WAHAEvents;
   session: string;
   engine: WAHAEngine;
-  // eslint-disable-next-line @typescript-eslint/ban-types
-  payload: WAMessage | WAGroupPayload | WAMessageAckBody | object;
+  payload:
+    | WAMessage
+    | WAGroupPayload
+    | WAMessageAckBody
+    | PollVotePayload
+    // eslint-disable-next-line @typescript-eslint/ban-types
+    | object;
 }

src/version.ts

@@ -26,7 +26,7 @@ export function getWAHAVersion(): WAHAVersion {
 }
 
 export const VERSION = {
-  version: '2023.8.23',
+  version: '2023.9.7',
   tier: getWAHAVersion(),
   browser: getBrowserExecutablePath(),
 };