[core] Bump to 2024.3.2

[core] Use ubuntu in NOWEB
[core] No more MOBILE engine
2024-03-07 19:28:12 +07:00 · 2024-03-07 19:27:45 +07:00 · 2024-03-04 23:14:28 +07:00 · 2024-03-02 18:08:52 +07:00 · 2024-03-02 18:08:31 +07:00 · 2024-03-02 18:02:30 +07:00
61 changed files with 2555 additions and 1496 deletions
@@ -0,0 +1,15 @@
+ignore:
+  teams:
+    - no-labels
+  users:
+    - allburov
+teamLabels:
+  - team: waha-patrons-pro
+    label: patron:PRO
+    comment: '[![patron:PRO](https://img.shields.io/badge/patron-PRO-188a42)](https://waha.devlike.pro/docs/how-to/plus-version/#tiers)'
+  - team: waha-patrons-advanced
+    label: patron:ADVANCED
+    comment: '[![patron:ADVANCED](https://img.shields.io/badge/patron-ADVANCED-4cd07d)](https://waha.devlike.pro/docs/how-to/plus-version/#tiers)'
+  - team: waha-patrons-plus
+    label: patron:PLUS
+    comment: '[![patron:PLUS](https://img.shields.io/badge/patron-PLUS-a0e6ba)](https://waha.devlike.pro/docs/how-to/plus-version/#tiers)'
@@ -5,16 +5,21 @@ FROM node:20-bullseye as build
 ENV PUPPETEER_SKIP_DOWNLOAD=True

 # npm packages
+RUN apt-get update \
+    && apt-get install -y openssh-client
+RUN apt install openssh-client
+RUN mkdir -p -m 0700 ~/.ssh && ssh-keyscan github.com >> ~/.ssh/known_hosts
+
 WORKDIR /src
 COPY package.json .
 COPY yarn.lock .
 RUN yarn set version 3.6.3
-RUN yarn install
+RUN --mount=type=ssh yarn install

 # App
 WORKDIR /src
 ADD . /src
-RUN yarn install
+RUN --mount=type=ssh yarn install
 RUN yarn build && find ./dist -name "*.d.ts" -delete

 #
@@ -12,6 +12,13 @@ build-all: build build-chrome build-noweb
 build-plus:
 	docker build . -t devlikeapro/whatsapp-http-api-plus

+build-ssh:
+	# check IMAGE provided
+	@[ "${IMAGE}" ]  || ( echo "Add APP: make build-ssh image=devlikeapro/whatsapp-http-api"; exit 1 );
+	eval $(ssh-agent) && \
+	ssh-add ~/.ssh/id_rsa && \
+	docker buildx build --ssh default=${SSH_AUTH_SOCK} . -t ${IMAGE} --build-arg USE_BROWSER=none
+
 stop:
 	docker stop whatsapp-http-api

@@ -28,7 +35,7 @@ update-swagger:
 	wget http://localhost:3000/-json -O ./docs/site/static/swagger/openapi.json

 update-dependencies:
-	. ${NVM_DIR}/nvm.sh && nvm exec yarn up whatsapp-web.js@https://github.com/pedroslopez/whatsapp-web.js
+	. ${NVM_DIR}/nvm.sh && nvm exec yarn up whatsapp-web.js@https://github.com/devlikeapro/whatsapp-web.js#main-fork
 	. ${NVM_DIR}/nvm.sh && nvm exec yarn up @adiwajshing/baileys@github:WhiskeySockets/Baileys
 	. ${NVM_DIR}/nvm.sh && nvm exec yarn up venom-bot

@@ -30,3 +30,15 @@ services:
      - WHATSAPP_SWAGGER_PASSWORD=123
      - WHATSAPP_API_HOSTNAME=localhost
    restart: always
+
+  mongodb:
+    image: mongo
+    container_name: mongodb
+    ports:
+      - '27017:27017/tcp'
+    volumes:
+      - mongodb_data:/data/db
+    restart: always
+
+volumes:
+  mongodb_data: {}
@@ -77,6 +77,12 @@
  url = "/docs/how-to/plus-version"
  parent = "waha-plus"

+[[main]]
+  name = "Patron Portal ->"
+  weight = 20
+  url = "https://portal.devlike.pro/"
+  parent = "waha-plus"
+
 [[main]]
  name = "Get on Patreon ->"
  weight = 50
@@ -1,7 +1,7 @@
 ---
 title : "WAHA"
 description: "WAHA - WhatsApp HTTP API that you can run in a click!"
-lead: "WAHA - WhatsApp HTTP API that you can run in a click!"
+lead: "WAHA - <b>WhatsApp HTTP API</b> that you can run in a click!"
 date: 2020-10-06T08:47:36+00:00
 lastmod: 2020-10-06T08:47:36+00:00
 draft: false
@@ -38,6 +38,8 @@ The following environment variables can be used to configure the WAHA.
    response.
 - `WHATSAPP_START_SESSION=session1,session2`: This variable can be used to start sessions with the specified names right
  after launching the API. Separate session names with a comma.
+- Also read more about [Sessions ->]({{< relref "/docs/how-to/sessions" >}})
+- Also read more about [Session Storages on the dedicated page ->]({{< relref "/docs/how-to/storages#sessions" >}})

 ### Swagger
 - `WHATSAPP_SWAGGER_CONFIG_ADVANCED=true` - enables advanced configuration options for Swagger documentation - you can customize host, port and base URL for the requests.
@@ -66,14 +68,18 @@ Read more about it on [**Session page** ->]({{< relref "/docs/how-to/sessions#co
 Keep in mind that session's proxy configuration takes precedence over proxy configuration set by environment variables!


-### Security ![](/images/versions/plus.png)
+### Security
+<b>Security is available in [WAHA Plus ![](/images/versions/plus.png)]({{< relref "/docs/how-to/plus-version" >}}) only.</b>
+
 - `WHATSAPP_API_KEY=mysecret`: If you set this variable, you must include the `X-Api-Key: mysecret` header in all
  requests to the API. This will protect the API with a secret code.
 - `WHATSAPP_SWAGGER_USERNAME=admin` and `WHATSAPP_SWAGGER_PASSWORD=admin`: These variables can be used to protect the
  Swagger panel with `admin / admin` credentials. This does not affect API access.

+Read more about security settings for Swagger and API on [**Security page** ->]({{< relref "/docs/how-to/security" >}}).

-### Files ![](/images/versions/plus.png)
+### Files
+<b>Files configuration is available in [WAHA Plus ![](/images/versions/plus.png)]({{< relref "/docs/how-to/plus-version" >}}) only.</b>

 The following environment variables can be used to configure the file storage options for the WAHA:

@@ -85,8 +91,11 @@ The following environment variables can be used to configure the file storage op
  - Under the hood, it sets `WHATSAPP_FILES_MIMETYPES=mimetype/ignore-all-media` to ignore all media files.
 - `WHATSAPP_FILES_LIFETIME`: This variable can be used to set the time (in seconds) after which files will be removed to
  free up space. The default value is `180`.
+  - Set this variable to `0` to disable the file lifetime.
 - `WHATSAPP_FILES_FOLDER`: This variable can be used to set the folder where files from chats (images, voice messages)
  will be stored. The default value is `/tmp/whatsapp-files`.
+  - The folder must be mounted to the host machine to keep the files between container restarts. [ Read more about how to persist files ->]({{< relref "/docs/how-to/storages#media" >}})
+- Also read more about [Media Storages on the dedicated page ->]({{< relref "/docs/how-to/storages#media" >}})

 💡 Even if WAHA doesn't process the message media because of `WHATSAPP_FILES_MIMETYPES` or `WHATSAPP_DOWNLOAD_MEDIA`
 you'll get a webhook event with `hasMedia: True` field, but with no `media.url`.
@@ -105,6 +114,14 @@ you'll get a webhook event with `hasMedia: True` field, but with no `media.url`.
 }
 ```

+### Health Check
+<b>Health check is available in [WAHA Plus ![](/images/versions/plus.png)]({{< relref "/docs/how-to/plus-version" >}}) only.</b>
+
+The following environment variables can be used to configure the [Health Check ->]({{< relref "/docs/how-to/other" >}}):
+- `WHATSAPP_HEALTH_MEDIA_FILES_THRESHOLD_MB` - the threshold in MB for the media files storage. The default value is `100`.
+- `WHATSAPP_HEALTH_SESSIONS_FILES_THRESHOLD_MB` - the threshold in MB for the sessions files storage. The default value is `100`.
+- `WHATSAPP_HEALTH_MONGODB_TIMEOUT` - the timeout in milliseconds for the MongoDB health check. The default value is `5000`.
+
 ## Examples

 #### Debug Mode
@@ -63,13 +63,26 @@ Get contact

 If you want to check if phone number is registered in WhatsApp (even if the number is not in your contact list) - use
 this endpoint for that.
- `GET /api/contacts/check-exists?phone=11231231231&session=default`
+```bash
+GET /api/contacts/check-exists?phone=11231231231&session=default
+```
+It returns `numberExists` field with `true` or `false` value and `chatId` field with chat ID of the number (if exists).

 ```json
 {
-  "numberExists": true
+  "numberExists": true,
+  "chatId": "123123123@c.us"
 }
 ```
+**Note for Brazilian Phone Numbers**
+
+You should use the `GET /api/contacts/check-exists` endpoint **before sending a message to a new phone number**
+to get the correct chatId because of the additional 9-digit number added after 2012.
+
+Read more about
+[error sending text to half of Brazilian numbers (every number registered before 2012) ->](https://github.com/devlikeapro/whatsapp-http-api/issues/238)
+
+It's fine to send the response to `chatId` for incoming messages, though - the payload already has the correct `chatId`.

 ### Get "about" contact

@@ -68,7 +68,7 @@ For **x86** processors use following images:

 For **ARM** processors use following images:
 - `devlikeapro/whatsapp-http-api:arm` - **Chromium**
- `devlikeapro/whatsapp-http-api:arm-noweb`- **no browser installed**
+- `devlikeapro/whatsapp-http-api:noweb-arm`- **no browser installed**

 {{< alert icon="💡" text="Chrome version is not available in ARM" />}}

@@ -98,20 +98,22 @@ it's the engine WAHA runs by default.
 If you find any inconsistency with actual endpoints -
 please [create an issue](https://github.com/devlikeapro/whatsapp-http-api/issues/new?title=Error+in+engine+features )

-|                                           | WEBJS | NOWEB | VENOM |
-|-------------------------------------------|:-----:|:-----:|:-----:|
-| **Session**                               |       |       |       |
-| `POST /api/sessions/start`                |  ✔️   |  ✔️   |  ✔️   |
-| `POST /api/sessions/stop`                 |  ✔️   |  ✔️   |  ✔️   |
-| `POST /api/sessions/logout`               |  ✔️   |  ✔️   |  ✔️   |
-| `GET /api/sessions/`                      |  ✔️   |  ✔️   |  ✔️   |
-| `GET /api/sessions/{session}/me`          |  ✔️   |  ✔️   |   ➖   |
-| **Authentication**                        |       |       |       |
-| `POST /api/{session}/auth/qr`             |  ✔️   |  ✔️   |  ✔️   |
-| `POST /api/{session}/auth/request-code`   |   ➖   |  ✔️   |   ➖   |
-| `POST /api/{session}/auth/authorize-code` |   ➖   |  ✔️   |   ➖   |
-| **Screenshot**                            |       |       |       |
-| `POST /api/screenshot`                    |  ✔️   |   ➖   |  ✔️   |
+|                                                                   | WEBJS |                                   NOWEB                                   | VENOM |
+|-------------------------------------------------------------------|:-----:|:-------------------------------------------------------------------------:|:-----:|
+| **Session**                                                       |       |                                                                           |       |
+| `POST /api/sessions/start`                                        |  ✔️   |                                    ✔️                                     |  ✔️   |
+| `POST /api/sessions/stop`                                         |  ✔️   |                                    ✔️                                     |  ✔️   |
+| `POST /api/sessions/logout`                                       |  ✔️   |                                    ✔️                                     |  ✔️   |
+| `GET /api/sessions/`                                              |  ✔️   |                                    ✔️                                     |  ✔️   |
+| `GET /api/sessions/{session}/me`                                  |  ✔️   |                                    ✔️                                     |   ➖   |
+| **Authentication**                                                |       |                                                                           |       |
+| `POST /api/{session}/auth/qr`                                     |  ✔️   |                                    ✔️                                     |  ✔️   |
+| `POST /api/{session}/auth/request-code`                           |   ➖   |                                    ✔️                                     |   ➖   |
+| `POST /api/{session}/auth/authorize-code`                         |   ➖   | ➖️<br>[#113](https://github.com/devlikeapro/whatsapp-http-api/issues/113) |   ➖   |
+| `GET /api/{session}/auth/captcha`   <br>Only in **MOBILE** engine |   ➖   |                                     ➖                                     |   ➖   |
+| `POST /api/{session}/auth/captcha` <br>Only in **MOBILE** engine  |   ➖   |                                     ➖                                     |   ➖   |
+| **Screenshot**                                                    |       |                                                                           |       |
+| `POST /api/screenshot`                                            |  ✔️   |                                     ➖                                     |  ✔️   |

 | **Chatting**                                         | WEBJS | NOWEB | VENOM |
 |------------------------------------------------------|:-----:|:-----:|:-----:|
@@ -176,12 +178,13 @@ please [create an issue](https://github.com/devlikeapro/whatsapp-http-api/issues
 |                                                   | WEBJS | NOWEB | VENOM |
 |---------------------------------------------------|:-----:|:-----:|:-----:|
 | **Presence**                                      |       |       |       |
-| `POST /api/{session}/presence`                    |   ➖   |  ✔️   |   ➖   |
+| `POST /api/{session}/presence`                    |  ✔️   |  ✔️   |   ➖   |
 | `GET /api/{session}/presence`                     |   ➖   |  ✔️   |   ➖   |
 | `GET /api/{session}/presence/{chatId}`            |   ➖   |  ✔️   |   ➖   |
 | `POST /api/{session}/presence/{chatId}/subscribe` |   ➖   |  ✔️   |   ➖   |
 | **Other**                                         |       |       |       |
-| `POST /api/version`                               |   ➖   |  ✔️   |   ➖   |
+| `GET /api/version`                                |   ➖   |  ✔️   |   ➖   |
+| `GET /health` ![](/images/versions/plus.png)      |  ✔️   |  ✔️   |  ✔️   |

 | **Webhooks**                                        | WEBJS | NOWEB | VENOM |
 |-----------------------------------------------------|:-----:|:-----:|:-----:|
@@ -0,0 +1,192 @@
+---
+title: "Other"
+description: "Other features and API"
+lead: ""
+date: 2020-10-06T08:48:45+00:00
+lastmod: 2020-10-06T08:48:45+00:00
+draft: false
+images: [ ]
+weight: 802
+---
+
+This page provides useful information about other features and API that are not covered in the other sections.
+
+## Health Check
+<b>Health check is available in [WAHA Plus ![](/images/versions/plus.png)]({{< relref "/docs/how-to/plus-version" >}}) only.</b>
+
+The health check endpoint is used to determine the health of the service.
+
+```
+GET /health
+```
+
+It returns a **200 OK** status code if the service is healthy.
+
+The response format:
+```json
+{
+  "status": "ok",
+  "info": {
+    "metric1": {
+      "field": "value"
+    },
+    "metric2": {
+      "field": "value"
+    }
+  },
+  "error": {},
+  "details": {}
+}
+```
+
+Where:
+- `status`: `'error' | 'ok' | 'shutting_down'` - If any health indicator failed the status will be `'error'`. If the app is shutting down but still accepting HTTP requests, the health check will have the `'shutting_down'` status.
+- `info`: Object containing information of each health indicator which is of status `'up'`, or in other words "healthy".
+- `error`: Object containing information of each health indicator which is of status `'down'`, or in other words "unhealthy".
+- `details`: Object containing detailed information of each health indicator.
+
+### Health Check Indicators
+Few things we check in the health check:
+- Media files storage space - `mediaFiles.space`
+- Sessions files storage space - `sessionsFiles.space`
+- MongoDB connection - `mongodb`
+
+### Configuration
+The following environment variables can be used to configure the health check:
+- `WHATSAPP_HEALTH_MEDIA_FILES_THRESHOLD_MB` - the threshold in MB for the media files storage. The default value is `100`.
+- `WHATSAPP_HEALTH_SESSIONS_FILES_THRESHOLD_MB` - the threshold in MB for the sessions files storage. The default value is `100`.
+- `WHATSAPP_HEALTH_MONGODB_TIMEOUT` - the timeout in milliseconds for the MongoDB health check. The default value is `5000`.
+
+### Examples
+**Healthy response** when you use [Local Storage]({{< relref "/docs/how-to/storages#sessions" >}}) for session authentication:
+
+**200 OK**
+```json
+{
+  "status": "ok",
+  "info": {
+    "mediaFiles.space": {
+      "status": "up",
+      "path": "/tmp/whatsapp-files",
+      "diskPath": "/",
+      "free": 132979355648,
+      "threshold": 104857600
+    },
+    "sessionsFiles.space": {
+      "status": "up",
+      "path": "/app/.sessions",
+      "diskPath": "/",
+      "free": 132979355648,
+      "threshold": 104857600
+    }
+  },
+  "error": {},
+  "details": {
+    "mediaFiles.space": {
+      "status": "up",
+      "path": "/tmp/whatsapp-files",
+      "diskPath": "/",
+      "free": 132979355648,
+      "threshold": 104857600
+    },
+    "sessionsFiles.space": {
+      "status": "up",
+      "path": "/app/.sessions",
+      "diskPath": "/",
+      "free": 132979355648,
+      "threshold": 104857600
+    }
+  }
+}
+```
+
+**Healthy response** when you use [MongoDB Storage]({{< relref "/docs/how-to/storages#sessions" >}}) for session authentication:
+
+**200 OK**
+```json
+{
+  "status": "ok",
+  "info": {
+    "mediaFiles.space": {
+      "status": "up",
+      "path": "/tmp/whatsapp-files",
+      "diskPath": "/",
+      "free": 132977496064,
+      "threshold": 104857600
+    },
+    "mongodb": {
+      "status": "up",
+      "message": "Up and running"
+    }
+  },
+  "error": {},
+  "details": {
+    "mediaFiles.space": {
+      "status": "up",
+      "path": "/tmp/whatsapp-files",
+      "diskPath": "/",
+      "free": 132977496064,
+      "threshold": 104857600
+    },
+    "mongodb": {
+      "status": "up",
+      "message": "Up and running"
+    }
+  }
+}
+```
+
+**Unhealthy response example**
+
+**503 Service Unavailable**
+```json
+{
+  "status": "error",
+  "info": {
+    "mediaFiles.space": {
+      "status": "up",
+      "path": "/tmp/whatsapp-files",
+      "diskPath": "/",
+      "free": 132976623616,
+      "threshold": 104857600
+    }
+  },
+  "error": {
+    "mongodb": {
+      "status": "down",
+      "error": "Timeout"
+    }
+  },
+  "details": {
+    "mediaFiles.space": {
+      "status": "up",
+      "path": "/tmp/whatsapp-files",
+      "diskPath": "/",
+      "free": 132976623616,
+      "threshold": 104857600
+    },
+    "mongodb": {
+      "status": "down",
+      "error": "Timeout"
+    }
+  }
+}
+```
+
+
+
+## Get version
+Returns the version of the installed docker image.
+```
+GET /api/version
+```
+
+```json
+{
+  "version": "2024.2.3",
+  "engine": "NOWEB",
+  "tier": "PLUS",
+  "browser": "/usr/bin/google-chrome-stable"
+}
+```
+
@@ -49,17 +49,35 @@ Treat **WAHA Plus** it as an additional episode, behind-the-scenes videos, our n
 We donate most of the donations down to the stream to the underlying libraries and tools - JS-community, Node, other libraries authors, personal contributors.
 By donating to the **WAHA** you donate to the Open Source world!

-### Features
+### Tiers

-The Plus additional features are:
+The more you support the project - the more you get!
+
+|                                                                                                                                                                                                                                                                                                              | Core     | Plus    | Advanced |   Pro   |
+|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|:---------|---------|:--------:|:-------:|
+| Messages limit                                                                                                                                                                                                                                                                                               | **∞**    | **∞**   |  **∞**   |  **∞**  |
+| [Send and receive text messages ->]({{< relref "/docs/how-to/send-messages" >}})                                                                                                                                                                                                                             | ✔️       | ✔️      |    ✔️    |   ✔️    |
+| No license checks on installed instances                                                                                                                                                                                                                                                                     | ✔️       | ✔️      |    ✔️    |   ✔️    |
+| [Sessions limit ->]({{< relref "/docs/how-to/sessions" >}})                                                                                                                                                                                                                                                  | **1**    | **∞**   |  **∞**   |  **∞**  |
+| [Send and receive files ->]({{< relref "/docs/how-to/send-messages" >}})                                                                                                                                                                                                                                     | ➖️       | ✔️      |    ✔️    |   ✔️    |
+| [Built-in Security ->]({{< relref "/docs/how-to/security" >}})                                                                                                                                                                                                                                               | ➖️       | ✔️      |    ✔️    |   ✔️    |
+| [**Webhook retries** →]({{< relref "/docs/how-to/receive-messages#retries" >}})                                                                                                                                                                                                                              | ➖️       | ✔️      |    ✔️    |   ✔️    |
+| [MongoDB support ->]({{< relref "/docs/how-to/storages" >}})                                                                                                                                                                                                                                                 | ➖️       | ✔️      |    ✔️    |   ✔️    |
+| Access to **WAHA Plus** ![](/images/versions/plus.png) docker image with a personal key.                                                                                                                                                                                                                     | ➖️       | ✔️      |    ✔️    |   ✔️    |
+| Special badge ([![patron:TIER](https://img.shields.io/badge/patron-TIER-188a42)](https://waha.devlike.pro/docs/how-to/plus-version/#tiers)) and labels (`patron:TIER`) on [project's issues, PRs and Discussion](https://github.com/devlikeapro/whatsapp-http-api) to highlight your support to the project! |          | ✔️      |    ✔️    |   ✔️    |
+| 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.                                                                                                                                                                                                                                          | ➖️       | ➖️      |    ➖     |   ✔️    |
+| Access to an [experimental MOBILE engine]({{< relref "/docs/how-to/plus-version#tiers" >}})!.                                                                                                                                                                                                                | ➖️       | ➖️      |    ➖     |   ✔️    |
+| **Donation**                                                                                                                                                                                                                                                                                                 | **FREE** | **$19** | **$39**  | **$99** |
+
+For **$19** donation you get:
+1. **Secret password** for Docker Hub to download Plus image: `devlikeapro/whatsapp-http-api-plus`.
+2. **All updates for one month** for the Plus image.
+3. **NO LICENSE CHECKS** on installed instances!
+4. **NO LICENSE EXPIRATION** on installed instances! We repeated it twice to make sure that you've got it 😊
+
+{{< alert icon="💡" text="If you stay subscribed - the donation amount will never change for you and always be $19 to get monthly updates!" />}}

-1. [**Send images\files\voices** →]({{< relref "/docs/how-to/send-messages" >}})
-2. [**Receive images\files\voices** →]({{< relref "/docs/how-to/receive-messages" >}})
-3. [**Webhook retries** →]({{< relref "/docs/how-to/receive-messages#retries" >}})
-4. [**Security** →]({{< relref "/docs/how-to/security" >}})
-5. [**Saving sessions** →]({{< relref "/docs/how-to/sessions" >}})
-6. [**Support multiple sessions** →]({{< relref "/docs/how-to/sessions" >}})
-7. **Priority in support** - on both bugs and features

 ### Why WAHA?

@@ -77,25 +95,6 @@ What is the difference between **WAHA Plus** and **other SaaS solutions** for Wh

 ## Get Plus ![](/images/versions/plus.png)

-The more you support the project - the more you get!
-
-Here's available tiers for our supporters:
-
-|                                                                                     |  Plus   | Advanced |   Pro   |
-|-------------------------------------------------------------------------------------|---------|:--------:|:-------:|
-| 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:
-1. **Secret password** for Docker Hub to download Plus image: `devlikeapro/whatsapp-http-api-plus`.
-2. **All updates for one month** for the Plus image.
-3. **NO LICENSE CHECKS** on installed instances!
-4. **NO LICENSE EXPIRATION** on installed instances! We repeated it twice to make sure that you've got it 😊
-
-{{< alert icon="💡" text="If you stay subscribed - the donation amount will never change for you and always be $19 to get monthly updates!" />}}

 ### Patreon
 <p align="center">
@@ -127,8 +126,9 @@ Boosty ->

 Go ahead and get your own WhatsApp HTTP API!

-### Install Plus
-After you get the password, use it to login and download docker image:
+## Install Plus
+After you get the password, get your login to Docker Hub in [Patron Portal ->](https://portal.devlike.pro/)
+and run the commands:
 ```bash
 docker login -u devlikeapro -p {KEY}
 docker pull devlikeapro/whatsapp-http-api-plus
@@ -27,7 +27,8 @@ See the list of engines [**that support the feature ->**]({{< relref "/docs/how-
 You can set your global or chat-related presence with `POST /api/{session}/presence` endpoint

 Start typing to a chat (you can use `POST /startTyping` instead)
-```json
+```
+POST /api/{session}/presence
 {
  "chatId": "111111111@c.us",
  "presence": "typing"
@@ -35,7 +36,8 @@ Start typing to a chat (you can use `POST /startTyping` instead)
 ```

 Clear "typing" state (you can use `POST /stopTyping` instead)
-```json
+```
+POST /api/{session}/presence
 {
  "chatId": "111111111@c.us",
  "presence": "paused"
@@ -43,7 +45,8 @@ Clear "typing" state (you can use `POST /stopTyping` instead)
 ```

 Set global "online", all contacts will see it
-```json
+```
+POST /api/{session}/presence
 {
  "presence": "online"
 }
@@ -53,7 +56,8 @@ Set global "online", all contacts will see it
 to the device.
 If you would like to receive said notifications - you need to mark a session's presence as `offline`.

-```json
+```
+POST /api/{session}/presence
 {
  "presence": "offline"
 }
@@ -15,18 +15,34 @@ If you haven't yet - please follow the steps from [**Quick Start →**]({{< relr

 ## Fields
 There are common fields that you can find in almost all requests:
- `session` - a session name from which account you're sending the message. We use `default` in the examples.
-  - Core ![](/images/versions/core.png) version supports only `default` session.
-  - Plus ![](/images/versions/plus.png) allows you to run multiple sessions inside one container to save your memory and CPU resources!
+```json
+{
+  "session": "default",
+  "chatId": "12132132130@c.us",
+  "file": "..."
+}
+```
+
+### session
+`session` - a session name from which account you're sending the message. We use `default` in the examples.
+- Core ![](/images/versions/core.png) version supports only `default` session.
+- Plus ![](/images/versions/plus.png) allows you to run multiple sessions inside one container to save your memory and CPU resources!
+
 Read more about [multiple sessions →]({{< relref "/docs/how-to/sessions" >}})

- `chatId` - it's a phone number or Group identifier where you're sending the message.
-  - **Phone numbers** accounts use international phone number without + at the start and add `@c.us` at the end.
-    For phone number `12132132131` the `chatId` is  `12132132131@c.us`.
-  - **Groups** use random number with `@g.us` at the end.
+### chatId
+`chatId` - it's a phone number or Group identifier where you're sending the message.
+- **Phone numbers** accounts use international phone number without + at the start and add `@c.us` at the end.
+  For phone number `12132132131` the `chatId` is  `12132132131@c.us`.
+- **Groups** use random number with `@g.us` at the end.

+> To get the actual `chatId` for **Brazilian phone number** - use `chatId` field from
+> [Check phone number exists ->]({{< relref "/docs/how-to/contacts#check-phone-number-exists" >}})
+> response.
+
+### file
 When sending media (images, voice, files) you can either use:
- `file.data` field with base64 encoded file (https://base64.guru/converter/encode/file)
+- `file.data` field [with base64 encoded file](https://base64.guru/converter/encode/file)
 - `file.url` field with public available URL for that file

 ## Endpoints
@@ -298,28 +298,8 @@ configure autostart options so when the docker container restarts - it restores

 ### Session persistent

-#### File storage
-If you want to save your session and do not scan QR code everytime when you launch WAHA - connect a local file storage
-to the container. WAHA stores authentication information in the directory and reuses it after restart.
-
-[Attach volume](https://docs.docker.com/storage/volumes/) part to the command:
-
-```bash
-v `pwd`/.sessions:/app/.sessions
-```
-
-The full command would be:
-
-```bash
-docker run --rm -d -v `pwd`/.sessions:/app/.sessions -p 3000:3000/tcp --name whatsapp-http-api devlikeapro/whatsapp-http-api-plus
-```
-
-#### Remote storage ![](/images/versions/soon.png)
-
-If you're interested in using some "remote" storage (like Redis or other Databases) to save sessions - please create an
-issue on GitHub.
-
-For instances, it may be useful if you run WAHA in a cluster of servers and do not have shared file storage
+If you want to save your session and do not scan QR code everytime when you launch WAHA -
+[connect the session storage to the container ->]({{< relref "/docs/how-to/storages#sessions" >}})

 ### Autostart
 If you don't want to call `POST /api/sessions/start` for every session each time when the container restart -
@@ -0,0 +1,149 @@
+---
+title: "Storages"
+description: "Storages"
+lead: ""
+date: 2020-10-06T08:48:45+00:00
+lastmod: 2020-10-06T08:48:45+00:00
+draft: false
+images: [ ]
+weight: 700
+---
+There are several storages that are used by the WAHA, below you can find the list of them and the way to configure them.
+1. [Sessions](#sessions) - used to store the session data, such as authentication information, configuration, and other data that is required to keep the session alive and connected to WhatsApp.
+2. [Media](#media) - used to store the media files, such as images, videos, and other files that are received from the WhatsApp instance.
+
+<b>Storages are available in [WAHA Plus ![](/images/versions/plus.png)]({{< relref "/docs/how-to/plus-version" >}}) only.</b>
+
+## Sessions
+The "Sessions" storage is used to store the session data, such as authentication information, configuration,
+and other data that is required to keep the session alive and connected to WhatsApp.
+
+If you want to save your session and do not scan QR code everytime when you launch WAHA -
+connect the session storage to the container.
+
+For the session storage, you can use the following options:
+1. [Local (files)](#local-files) - the default option, stores the session data in the local storage using files.
+2. [MongoDB](#mongodb) - stores the session data in the MongoDB database.
+
+The following table shows the compatibility of the session storage with the engines:
+
+|               | WEBJS | NOWEB | VENOM |
+|---------------|:-----:|:-----:|:-----:|
+| Local (files) |  ✔️   |  ✔️   |  ✔️   |
+| MongoDB       |  ✔️   |  ✔️   |   ➖   |
+
+## Sessions - Local (files)
+By default, the WAHA uses the **local storage (files)** to store the session data.
+
+{{< alert icon="💡" text="It's <b>well tested solution</b> even for production" />}}
+
+In order to use the local storage and save the session data between the container restarts,
+you need to mount the volume to the `/app/.sessions` directory using the `-v` option in `docker run` command:
+
+```bash
+-v /path/to/on/host/.sessions:/app/.sessions
+```
+
+The full command to run the WAHA with the local storage and save the session data
+in the current directory and `.sessions` directory:
+```bash
+docker run -v `pwd`/.sessions:/app/.sessions -p 3000:3000/tcp devlikeapro/whatsapp-http-api-plus
+```
+This is the only action you need to do to use the local storage - all session data will be available between the container restarts.
+
+### How it works
+In the host machine, the session data will be stored in the current directory in the `.sessions` directory.
+
+Under the hood, the WAHA stores the session data in the following directory structure:
+```
+.sessions/{engine}/{sessionName}/...
+```
+when you "logout" the session using [POST /api/sessions/logout]({{< relref "/docs/how-to/sessions#logout">}}) or providing `logout: True` in [POST /api/sessions/stop]({{< relref "/docs/how-to/sessions#stop">}})
+it removes the directory with the session data.
+
+### Health Check
+The [WAHA Plus ![](/images/versions/plus.png)]({{< relref "/docs/how-to/plus-version" >}}) provides [the health check endpoint]({{< relref "/docs/how-to/other" >}}) that checks the local storage.
+
+## Sessions - MongoDB
+If you want to use the MongoDB to store the session data, you need to:
+1. Start the MongoDB server (using docker or any other way). You can either start your own MongoDB server or use the one of cloud providers, like [MongoDB Atlas](https://www.mongodb.com/atlas/database).
+2. Set `WHATSAPP_SESSIONS_MONGO_URL=mongodb://user:password@host:port/` environment variable to connect to the MongoDB server.
+
+
+**We recommend using your own MongoDB server as close as possible to WAHA server** for the best performance and security reasons.
+
+{{< alert icon="💡" text="For <b>WEBJS</b> engine it can take up to 1 minute to save credentials in Mongo Database" />}}
+
+### Example
+First, you need to start MongoDB server:
+```bash
+docker run -d -p 27017:27017 --name mongodb mongo
+```
+
+Then, you need to run the WAHA with the `WHATSAPP_SESSIONS_MONGO_URL` environment variable (please note using `--network host` option as well)
+```bash
+docker run -e WHATSAPP_SESSIONS_MONGO_URL=mongodb://localhost:27017/ --network host devlikeapro/whatsapp-http-api-plus
+```
+
+This is the only action you need to do to use the MongoDB storage -
+all session authentication data will be stored in the MongoDB database.
+
+### How it works
+When you start a session, it stores the session data in the MongoDB database in two databases:
+1. `waha_{engine}` - it saves the session configuration in `sessions` collection with `name: {sessionName}` field.
+2. `waha_{engine}_{sessionName}` - it saves the WhatsApp authentication data and other session data. Each engine saves different data in this database.
+
+When you "logout" the session using [POST /api/sessions/logout]({{< relref "/docs/how-to/sessions#logout">}}) or providing `logout: True` in [POST /api/sessions/stop]({{< relref "/docs/how-to/sessions#stop">}}) it removes those databases or elements from them.
+
+For dealing and troubleshooting with the MongoDB, we recommend using [MongoDB Compass](https://www.mongodb.com/products/tools/compass).
+
+![](waha-mongodb.png)
+
+### MongoDB Atlas
+If you use the [MongoDB Atlas](https://www.mongodb.com/atlas/database) you must grant
+`Atlas Admin` role in **Security => Database Access** before you connect to the database.
+
+For production please consider running the MongoDB server close to the WAHA server for the best performance and security reasons.
+
+### Health Check
+The [WAHA Plus ![](/images/versions/plus.png)]({{< relref "/docs/how-to/plus-version" >}}) provides [the health check endpoint]({{< relref "/docs/how-to/other" >}}) that checks the MongoDB connection.
+
+## Media
+When your WhatsApp instance receives media files, it stores them in the media storage.
+
+You can use the following options to store the media files:
+1. [Local](#local) - the default option, stores the media files in the local storage using files.
+2. [S3](#s3) - stores the media files in the S3 storage.
+
+Read more about [available configuration options ->]({{<relref "/docs/how-to/config#files">}}).
+
+The following table shows the compatibility of the storage with the engines:
+
+|       | WEBJS | NOWEB | VENOM |
+|-------|:-----:|:-----:|:-----:|
+| Local |  ✔️   |  ✔️   |  ✔️   |
+| S3    |  🕒   |  🕒   |   ➖   |
+
+## Media - Local
+By default, the WAHA uses the **local file storage** to store the media files and those files has a short lifetime (180 seconds).
+So it's your app responsibility to download and store them in a safe persistent place during this time.
+
+### Save media files between the container restarts
+If you want to use the local storage and **save the media files between the container restarts for a long time** - you need to:
+1. Specify a dedicated folder to store the media files using `WHATSAPP_FILES_FOLDER=/app/.media` environment variable
+2. Disable automatic media files cleanup using `WHATSAPP_FILES_LIFETIME=0` environment variable
+3. Connect the volume to the specified folder using the `-v /path/to/files/on/host:/app/.media` option in `docker run` command to the folder specified in `WHATSAPP_FILES_FOLDER` environment variable.
+
+Read more about [available configuration options ->]({{<relref "/docs/how-to/config#files">}}).
+
+Here's all the steps in one command:
+```bash
+docker run -v /path/to/on/host/.media:/app/.media -e WHATSAPP_FILES_FOLDER=/app/.media -e WHATSAPP_FILES_LIFETIME=0 -p 3000:3000/tcp devlikeapro/whatsapp-http-api-plus
+```
+
+### Health Check
+The [WAHA Plus ![](/images/versions/plus.png)]({{< relref "/docs/how-to/plus-version" >}}) provides [the health check endpoint]({{< relref "/docs/how-to/other" >}}) that checks the local storage.
+
+## Media - S3
+If you're interested in using the S3 storage or any other cloud storage (like [self-hosted S3 - Minio](https://min.io/)),
+please create an issue or vote for the S3 issue in [the GitHub repository](https://github.com/devlikeapro/whatsapp-http-api/issues?q=is%3Aissue+is%3Aopen+S3).
@@ -263,7 +263,7 @@ revokes a previously sent message.

 ```json
 {
-  "event": "message.ack",
+  "event": "message.revoked",
  "session": "default",
  "payload": {
    "before": {
@@ -19,6 +19,26 @@ If you wish to get and read Release Notes - read them on one of our platforms, *

 You even can **subscribe to get new updates** there!

+## 2024.2
+- Add support for [MongoDB as storage for Session data]({{< relref "/docs/how-to/storages" >}})
+- Support persistent file storage for media files - [now you can save media files between container restarts]({{< relref "/docs/how-to/storages#media" >}})
+- If you set `WHATSAPP_FILES_LIFETIME=0` environment variable - media files will be never deleted.
+- Add `GET /api/health` endpoint to [check the health of the service](https://waha.devlike.pro/docs/how-to/other/)
+
+## 2024.1
+- Implement [Patron Portal](https://portal.devlike.pro/) where you can get your personal API key and manage your perks.
+  - Read more on [Patreon ->](https://www.patreon.com/posts/waha-patron-97637416)
+  - Read more on [Boosty ->](https://boosty.to/wa-http-api/posts/8319079f-dac1-4179-b954-fcc559097c76)
+
+## 2024.2
+- Listen for browser disconnected and page close events in **WEBJS** engine [#262](https://github.com/devlikeapro/whatsapp-http-api/issues/262)
+
+## 2023.12
+December 2023
+- Add `chatId` field to `GET /api/contacts/check-exists` to help get the right `chatId` for Brazilian numbers.
+Read more about
+  [error sending text to half of Brazilian numbers (every number registered before 2012) ->](https://github.com/devlikeapro/whatsapp-http-api/issues/238)
+
 ## 2023.11
 November 2023
 - Add different formats for QR code:
@@ -14,6 +14,7 @@ toc: true
 ---

 ## How much CPU and Memory does WhatsApp HTTP API consume?
+### WEBJS

 The benchmark has been made on **Intel(R) Core(TM) i7-10510U CPU @ 1.80GHz**.
 It may differ from case to case, it depends on usage pattern - how many messages you get, how many send, etc.
@@ -26,4 +27,10 @@ It may differ from case to case, it depends on usage pattern - how many messages
 The nature of WhatsApp HTTP API and its underlying engines - is to run **real** WhatsApp Web version in Chrome and
 communicate with it to prevent blocking from WhatsApp. It's the reason why it's so demanding on resources.

+### NOWEB
 If you're looking for less resource demanded engine - [have a look at **NOWEB** engine ->]({{< relref "/docs/how-to/engines" >}})
+
+The quote from the user:
+> The server has 2 CPU and 8GB of memory.
+> Today we have 85 session in this instance.
+
@@ -27,6 +27,9 @@ When developing a bot for WhatsApp, you **should never initiate a conversation**
 Instead, your bot **should only reply** to messages that it receives.
 This will prevent your bot from being flagged as spam by WhatsApp's users and algorithms.

+> You can use a short link http://wa.me/7911111111?text=Hi
+> so a user can click on it and start the dialog with the bot first
+
 ### 2. Avoid Spamming and Sending Unnecessary Content

 Sending too many messages or sending content that the user did not request can also lead to your bot being blocked. Make
@@ -56,3 +59,34 @@ Here's a recommended process to follow:

 By following these steps, you can ensure that your bot processes messages in a way that's compliant with WhatsApp's
 guidelines and reduces the risk of being blocked.
+
+## How to not get Banned?
+
+WhatsApp knows that it's uncommon for someone to send so many messages or bulk messages to people they've never talked to each other before so it is considered spam/marketing junk pretty fast. There are some tips before sending a message to WhatsApp
+
+**Dos and Don'ts:**
+
+1. Important: Do NOT send messages which get you a report. As long as you don't get reports from users who you sent a message, your account will be mostly fine.
+2. Having real content, a survey that the person agreed with is different from a marketing message on a Saturday night.
+3. Send messages written in different ways, you could make a script that places spacebars randomly on your string AND includes the person's (first) name
+4. Never use fixed times, always go for sending the first message, wait a random time between 30 ~ and 60 seconds and then send the second message
+5. Always try to group contacts by their area code, WhatsApp expects a regular person to talk mostly with contacts that are within the same area of your phone number.
+6. Have a profile picture, this is not related to WhatsApp Bots Catcher® but sending a new message for someone not having a picture/name/status will elevate your chances of being manually tagged as spam.
+7. Send "seen" confirmation to messages or disable it on WhatsApp
+8. Avoid sending links that were previously marked as spam on WhatsApp or non-HTTPS. A URL shortener is a good idea
+9. IMPORTANT: It's terrible if you send messages 24/7 without giving it some time to wait. Random delays between messages are not enough, send a reasonable amount of messages keeping in mind your conversion rate, For example: for one hour send a maximum of 4 messages per contact that have replied to your message, and stop sending messages for one hour, then start again. Again, don't send messages without stopping for a while between every "package"
+10. Send only one short message when starting a conversation, one should not send long texts or multiple messages without the user consenting
+
+**Have in mind:**
+
+1. For every one you send a message that doesn't have your number on their contact list asked if it's spam, being tagged as spam a few times (5 - 10) will get you banned
+2. WhatsApp records every movement you do, you can even check the logs when sending simple support email, it contains all kinds of information, this said: act as human as possible
+3. Try to engage in conversations, as long as you send a message and the person doesn't automatically block you it'll be quite okay. People constantly talking to you and adding you to their contact list will make your number stronger against a ban
+4. Think about that like a points system, you start with zero points (negative if your device was previously blacklisted), if you reach below zero you are out, if you engage in conversations you get a point, if you are tagged as spam you lose some points, if you are blocked you may lose more points
+5. Finally, If your content is spam, it doesn't matter if you are using a broadcast list, group, or direct contact, you will still be banned
+
+As API, we say all that's left to do right now is to agree with WhatsApp's policy, not send spam messages, and always wait for the other person to contact you first.
+
+You could make it by sending an SMS to the person with a link to start a chat on WhatsApp with you by link [https://wa.me/12132132131?text=Hi](https://wa.me/12132132131?text=Hi).
+
+
@@ -1,79 +1,104 @@
 {{ define "main" }}
-<section class="section container-fluid mt-n3 pb-3">
-  <div class="row justify-content-center">
-    <div class="col-lg-12 text-center">
-      <h1 class="mt-0">{{ .Title }}</h1>
+<section class='section container-fluid mt-n3 pb-3'>
+  <div class='row justify-content-center'>
+    <div class='col-lg-12 text-center'>
+      <h1 class='mt-0'>{{ .Title }}</h1>
    </div>
-    <div class="col-lg-9 col-xl-9 text-center">
-      <div class="mb-4">
-        <img src="/images/logo.png" title="WhatsApp HTTP API" alt="logo" width="100"/>
+    <div class='col-lg-9 col-xl-9 text-center'>
+      <div class='mb-4'>
+        <img src='/images/logo.png' title='WhatsApp HTTP API' alt='logo' width='100' />
      </div>
-      <p class="lead">{{ .Params.lead | safeHTML }}</p>
+      <p class='lead'>{{ .Params.lead | safeHTML }}</p>
      <code>
        docker run -it -p 3000:3000/tcp devlikeapro/whatsapp-http-api
      </code>
-      <br/>
-      <br/>
-      <a class="btn btn-primary btn-lg px-4 mb-2"
-         href="/docs/{{ if .Site.Params.options.docsVersioning }}{{ .Site.Params.docsVersion }}/{{ end }}overview/introduction/"
-         role="button">Get Started</a>
-      <p class="meta"><a href="https://github.com/devlikeapro/whatsapp-http-api">Source code in GitHub.</a></p>
+      <br />
+      <br />
+      <a class='btn btn-primary btn-lg px-4 mb-2'
+         href='/docs/{{ if .Site.Params.options.docsVersioning }}{{ .Site.Params.docsVersion }}/{{ end }}overview/introduction/'
+         role='button'>Get Started</a>
+      <p class='meta'><a href='https://github.com/devlikeapro/whatsapp-http-api'>Source code in GitHub.</a></p>
    </div>
  </div>
 </section>
 {{ end }}

 {{ define "sidebar-prefooter" }}
-<section class="section section-sm">
-  <div class="container">
-    <div class="row justify-content-center text-center">
-      <div class="col-lg-5">
-        <h2 class="h4">It's free!</h2>
+<section class='section section-sm'>
+  <div class='container'>
+    <div class='row justify-content-center text-center'>
+      <div class='col-lg-5'>
+        <img src='/images/icons/free.png' alt='Free' style='width: 5rem'>
+        <h2 class='h4'>It's free!</h2>
        <p>
-          <b>WAHA Core</b> version is always free!
+          <a href='https://waha.devlike.pro/docs/how-to/plus-version/#tiers' target='_blank'>
+            <b>WAHA Core</b>
+          </a>
+          version is always free!
          <br>
-          Even <b>WAHA Plus</b> version have no licence expiration!
+          Even
+          <a href='https://waha.devlike.pro/docs/how-to/plus-version/#tiers' target='_blank'>
+            <b>WAHA Plus</b>
+          </a>
+          version have no licence expiration!
        </p>
      </div>
-      <div class="col-lg-5">
-        <h2 class="h4">Language agnostic</h2>
+      <div class='col-lg-5'>
+        <img src='/images/icons/api.png' alt='API' style='width: 5rem'>
+        <h2 class='h4'>Language agnostic</h2>
        <p>
          Use your own favorite language - Python, JavaScript, PHP, C#, Clojure, or PowerShell.
-          <br/>
-          <small class="text-muted">
+          <br />
+          <small class='text-muted'>
            PowerShell, really? Are you insane?! Choose another language, dude.
          </small>
        </p>
      </div>
-      <div class="col-lg-5">
-        <h2 class="h4">Well documented</h2>
-        <p>Documentation has a lof examples and how-to guides.</p>
+      <div class='col-lg-5'>
+        <img src='/images/icons/document.png' alt='Document' style='width: 5rem'>
+        <h2 class='h4'>Well documented</h2>
+        <p>
+          <a href='https://waha.devlike.pro/docs/overview/introduction/' target='_blank'>
+            Documentation
+          </a>
+          has a lof examples and how-to guides.</p>
      </div>
    </div>
-    <div class="row justify-content-center text-center">
-      <div class="col-lg-5">
-        <h2 class="h4">Self hosted</h2>
+    <div class='row justify-content-center text-center'>
+      <div class='col-lg-5'>
+        <img src='/images/icons/servers.png' alt='Servers' style='width: 5rem'>
+        <h2 class='h4'>Self-hosted solution</h2>
        <p>
-          No strings to suspicious SaaS WhatsApp HTTP API solutions. Install it on your own server!
+          <a href='https://waha.devlike.pro/docs/how-to/plus-version/#why-waha' target='_blank'>
+            No strings to suspicious SaaS WhatsApp HTTP API solutions.
+          </a>
+          Install it on your own server!
        </p>
      </div>
-      <div class="col-lg-5">
-        <h2 class="h4">Easy installation</h2>
+      <div class='col-lg-5'>
+        <img src='/images/icons/easy.png' alt='Easy' style='width: 5rem'>
+        <h2 class='h4'>Quick installation</h2>
        <p>
-          You need to install <a href="https://docs.docker.com/engine/install/">Docker</a> and can run the API in a
-          click!
-          <br/>
-          <small class="text-muted">
+          You need to install Docker and
+          <a href='https://waha.devlike.pro/docs/how-to/install/' target='_blank'>
+            run the API in a click!
+          </a>
+          <br />
+          <small class='text-muted'>
            It's actually "a command", not a click.
          </small>
        </p>
      </div>
-      <div class="col-lg-5">
-        <h2 class="h4">No blocking</h2>
+      <div class='col-lg-5'>
+        <img src='/images/icons/checked.png' alt='Checked' style='width: 5rem'>
+        <h2 class='h4'>No blocking</h2>
        <p>
-          Under the hood it runs a real instance of Whatsapp Web to avoid getting blocked.
-          <br/>
-          <small class="text-muted">
+          <a href='https://waha.devlike.pro/docs/how-to/engines/' target='_blank'>
+            Under the hood
+          </a>
+          it runs a real instance of Whatsapp Web to avoid getting blocked.
+          <br />
+          <small class='text-muted'>
            WhatsApp does not allow bots or unofficial clients on their platform, so this shouldn't be considered
            totally safe.
          </small>
@@ -85,9 +110,9 @@
 {{ end }}

 {{ define "sidebar-footer" }}
-<section class="section section-sm container-fluid">
-  <div class="row justify-content-center text-center">
-    <div class="col-lg-9">
+<section class='section section-sm container-fluid'>
+  <div class='row justify-content-center text-center'>
+    <div class='col-lg-9'>
      {{- .Content -}}
    </div>
  </div>
@@ -1 +1 @@
-{"openapi":"3.1.0","paths":{"/api/{session}/auth/qr":{"get":{"operationId":"AuthController_getQR","summary":"Get QR code for pairing WhatsApp Web.","parameters":[{"name":"session","required":true,"in":"path","schema":{"default":"default"},"description":"WhatsApp session name"},{"name":"format","required":true,"in":"query","schema":{"default":"image","enum":["image","raw"],"type":"string"}}],"responses":{"200":{"content":{"image/png":{"schema":{"type":"string","format":"binary"}},"application/json":{"schema":{"oneOf":[{"$ref":"#/components/schemas/Base64File"},{"$ref":"#/components/schemas/QRCodeValue"}]}}},"description":""}},"tags":["auth"],"security":[{"api_key":[]}]}},"/api/{session}/auth/request-code":{"post":{"operationId":"AuthController_requestCode","summary":"Request authentication code.","parameters":[{"name":"session","required":true,"in":"path","schema":{"default":"default"},"description":"WhatsApp session name"}],"requestBody":{"required":true,"content":{"application/json":{"schema":{"$ref":"#/components/schemas/RequestCodeRequest"}}}},"responses":{"201":{"description":""}},"tags":["auth"],"security":[{"api_key":[]}]}},"/api/{session}/auth/authorize-code":{"post":{"operationId":"AuthController_authorizeCode","summary":"Send OTP authentication code.","parameters":[{"name":"session","required":true,"in":"path","schema":{"default":"default"},"description":"WhatsApp session name"}],"requestBody":{"required":true,"content":{"application/json":{"schema":{"$ref":"#/components/schemas/OTPRequest"}}}},"responses":{"201":{"description":""}},"tags":["auth"],"security":[{"api_key":[]}]}},"/api/sessions/start":{"post":{"operationId":"SessionsController_start","parameters":[],"requestBody":{"required":true,"content":{"application/json":{"schema":{"$ref":"#/components/schemas/SessionStartRequest"}}}},"responses":{"201":{"description":"","content":{"application/json":{"schema":{"$ref":"#/components/schemas/SessionDTO"}}}}},"tags":["sessions"],"security":[{"api_key":[]}]}},"/api/sessions/stop":{"post":{"operationId":"SessionsController_stop","summary":"Stop session","parameters":[],"requestBody":{"required":true,"content":{"application/json":{"schema":{"$ref":"#/components/schemas/SessionStopRequest"}}}},"responses":{"201":{"description":""}},"tags":["sessions"],"security":[{"api_key":[]}]}},"/api/sessions/logout":{"post":{"operationId":"SessionsController_clean","summary":"Logout from session.","parameters":[],"requestBody":{"required":true,"content":{"application/json":{"schema":{"$ref":"#/components/schemas/SessionLogoutRequest"}}}},"responses":{"201":{"description":""}},"tags":["sessions"],"security":[{"api_key":[]}]}},"/api/sessions":{"get":{"operationId":"SessionsController_list","parameters":[{"name":"all","required":false,"in":"query","example":false,"description":"Return all sessions, including those that are in the STOPPED state.","schema":{"type":"boolean"}}],"responses":{"200":{"description":"","content":{"application/json":{"schema":{"type":"array","items":{"$ref":"#/components/schemas/SessionInfo"}}}}}},"tags":["sessions"],"security":[{"api_key":[]}]}},"/api/sessions/{session}/me":{"get":{"operationId":"SessionController_getMe","summary":"Get information about the authenticated account","parameters":[{"name":"session","required":true,"in":"path","schema":{"default":"default"},"description":"WhatsApp session name"}],"responses":{"200":{"description":"","content":{"application/json":{"schema":{"$ref":"#/components/schemas/MeInfo"}}}}},"tags":["sessions"],"security":[{"api_key":[]}]}},"/api/checkNumberStatus":{"get":{"operationId":"ChattingController_checkNumberStatus","summary":"Check number status","parameters":[{"name":"phone","required":true,"in":"query","schema":{"type":"string"}},{"name":"session","required":true,"in":"query","schema":{"default":"default","type":"string"}}],"responses":{"200":{"description":"","content":{"application/json":{"schema":{"$ref":"#/components/schemas/WANumberExistResult"}}}}},"tags":["chatting"],"security":[{"api_key":[]}]}},"/api/sendContactVcard":{"post":{"operationId":"ChattingController_sendContactVcard","parameters":[],"requestBody":{"required":true,"content":{"application/json":{"schema":{"$ref":"#/components/schemas/MessageContactVcardRequest"}}}},"responses":{"201":{"description":""}},"tags":["chatting"],"security":[{"api_key":[]}]}},"/api/sendText":{"get":{"operationId":"ChattingController_sendTextGet","summary":"Send a text message","parameters":[{"name":"phone","required":true,"in":"query","schema":{"type":"string"}},{"name":"text","required":true,"in":"query","schema":{"type":"string"}},{"name":"session","required":true,"in":"query","schema":{"default":"default","type":"string"}}],"responses":{"200":{"description":"","content":{"application/json":{"schema":{"type":"object"}}}}},"tags":["chatting"],"security":[{"api_key":[]}]},"post":{"operationId":"ChattingController_sendText","summary":"Send a text message","parameters":[],"requestBody":{"required":true,Line truncated
+{"openapi":"3.1.0","paths":{"/api/{session}/auth/qr":{"get":{"operationId":"AuthController_getQR","summary":"Get QR code for pairing WhatsApp Web.","parameters":[{"name":"session","required":true,"in":"path","schema":{"default":"default"},"description":"WhatsApp session name"},{"name":"format","required":true,"in":"query","schema":{"default":"image","enum":["image","raw"],"type":"string"}}],"responses":{"200":{"content":{"image/png":{"schema":{"type":"string","format":"binary"}},"application/json":{"schema":{"oneOf":[{"$ref":"#/components/schemas/Base64File"},{"$ref":"#/components/schemas/QRCodeValue"}]}}},"description":""}},"tags":["auth"],"security":[{"api_key":[]}]}},"/api/{session}/auth/request-code":{"post":{"operationId":"AuthController_requestCode","summary":"Request authentication code.","parameters":[{"name":"session","required":true,"in":"path","schema":{"default":"default"},"description":"WhatsApp session name"}],"requestBody":{"required":true,"content":{"application/json":{"schema":{"$ref":"#/components/schemas/RequestCodeRequest"}}}},"responses":{"201":{"description":""}},"tags":["auth"],"security":[{"api_key":[]}]}},"/api/{session}/auth/authorize-code":{"post":{"operationId":"AuthController_authorizeCode","summary":"Send OTP authentication code.","parameters":[{"name":"session","required":true,"in":"path","schema":{"default":"default"},"description":"WhatsApp session name"}],"requestBody":{"required":true,"content":{"application/json":{"schema":{"$ref":"#/components/schemas/OTPRequest"}}}},"responses":{"201":{"description":""}},"tags":["auth"],"security":[{"api_key":[]}]}},"/api/sessions/start":{"post":{"operationId":"SessionsController_start","parameters":[],"requestBody":{"required":true,"content":{"application/json":{"schema":{"$ref":"#/components/schemas/SessionStartRequest"}}}},"responses":{"201":{"description":"","content":{"application/json":{"schema":{"$ref":"#/components/schemas/SessionDTO"}}}}},"tags":["sessions"],"security":[{"api_key":[]}]}},"/api/sessions/stop":{"post":{"operationId":"SessionsController_stop","summary":"Stop session","parameters":[],"requestBody":{"required":true,"content":{"application/json":{"schema":{"$ref":"#/components/schemas/SessionStopRequest"}}}},"responses":{"201":{"description":""}},"tags":["sessions"],"security":[{"api_key":[]}]}},"/api/sessions/logout":{"post":{"operationId":"SessionsController_clean","summary":"Logout from session.","parameters":[],"requestBody":{"required":true,"content":{"application/json":{"schema":{"$ref":"#/components/schemas/SessionLogoutRequest"}}}},"responses":{"201":{"description":""}},"tags":["sessions"],"security":[{"api_key":[]}]}},"/api/sessions":{"get":{"operationId":"SessionsController_list","parameters":[{"name":"all","required":false,"in":"query","example":false,"description":"Return all sessions, including those that are in the STOPPED state.","schema":{"type":"boolean"}}],"responses":{"200":{"description":"","content":{"application/json":{"schema":{"type":"array","items":{"$ref":"#/components/schemas/SessionInfo"}}}}}},"tags":["sessions"],"security":[{"api_key":[]}]}},"/api/sessions/{session}/me":{"get":{"operationId":"SessionController_getMe","summary":"Get information about the authenticated account","parameters":[{"name":"session","required":true,"in":"path","schema":{"default":"default"},"description":"WhatsApp session name"}],"responses":{"200":{"description":"","content":{"application/json":{"schema":{"$ref":"#/components/schemas/MeInfo"}}}}},"tags":["sessions"],"security":[{"api_key":[]}]}},"/api/checkNumberStatus":{"get":{"operationId":"ChattingController_checkNumberStatus","summary":"Check number status","parameters":[{"name":"phone","required":true,"in":"query","schema":{"type":"string"}},{"name":"session","required":true,"in":"query","schema":{"default":"default","type":"string"}}],"responses":{"200":{"description":"","content":{"application/json":{"schema":{"$ref":"#/components/schemas/WANumberExistResult"}}}}},"tags":["chatting"],"security":[{"api_key":[]}]}},"/api/sendContactVcard":{"post":{"operationId":"ChattingController_sendContactVcard","parameters":[],"requestBody":{"required":true,"content":{"application/json":{"schema":{"$ref":"#/components/schemas/MessageContactVcardRequest"}}}},"responses":{"201":{"description":""}},"tags":["chatting"],"security":[{"api_key":[]}]}},"/api/sendText":{"get":{"operationId":"ChattingController_sendTextGet","summary":"Send a text message","parameters":[{"name":"phone","required":true,"in":"query","schema":{"type":"string"}},{"name":"text","required":true,"in":"query","schema":{"type":"string"}},{"name":"session","required":true,"in":"query","schema":{"default":"default","type":"string"}}],"responses":{"200":{"description":"","content":{"application/json":{"schema":{"type":"object"}}}}},"tags":["chatting"],"security":[{"api_key":[]}]},"post":{"operationId":"ChattingController_sendText","summary":"Send a text message","parameters":[],"requestBody":{"required":true,Line truncated
@@ -1,4 +1,6 @@
+import random
 from pprint import pprint
+from time import sleep

 import requests
 from flask import Flask
@@ -49,6 +51,30 @@ def send_seen(chat_id, message_id, participant):
    )
    response.raise_for_status()

+def start_typing(chat_id):
+    response = requests.post(
+        "http://localhost:3000/api/startTyping",
+        json={
+            "session": "default",
+            "chatId": chat_id,
+        },
+    )
+    response.raise_for_status()
+
+def stop_typing(chat_id):
+    response = requests.post(
+        "http://localhost:3000/api/stopTyping",
+        json={
+            "session": "default",
+            "chatId": chat_id,
+        },
+    )
+    response.raise_for_status()
+
+def typing(chat_id, seconds):
+    start_typing(chat_id=chat_id)
+    sleep(seconds)
+    stop_typing(chat_id=chat_id)

@app.route("/")
 def whatsapp_echo():
@@ -69,7 +95,12 @@ def whatsapp_webhook():
    # Payload that we've got
    payload = data["payload"]
    # The text
-    text = payload["body"]
+    text = payload.get("body")
+    if not text:
+        # We can't process non-text messages yet
+        print("No text in message")
+        print(payload)
+        return "OK"
    # Number in format 1231231231@c.us or @g.us for group
    chat_id = payload["from"]
    # Message ID - false_11111111111@c.us_AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA
@@ -79,9 +110,13 @@ def whatsapp_webhook():
    # IMPORTANT - Always send seen before sending new message
    send_seen(chat_id=chat_id, message_id=message_id, participant=participant)

+
    # Send a text back via WhatsApp HTTP API
+    typing(chat_id=chat_id, seconds=random.random() * 3)
    send_message(chat_id=chat_id, text=text)
+
    # OR reply on the message
+    typing(chat_id=chat_id, seconds=random.random() * 3)
    reply(chat_id=chat_id, message_id=message_id, text=text)

    # Send OK back
@@ -24,6 +24,7 @@
  "dependencies": {
    "@adiwajshing/baileys": "github:WhiskeySockets/Baileys",
    "@adiwajshing/keyed-db": "^0.2.4",
+    "@nestjs/axios": "^3.0.2",
    "@nestjs/common": "^9.0.9",
    "@nestjs/config": "^0.5.0",
    "@nestjs/core": "^9.0.9",
@@ -31,8 +32,10 @@
    "@nestjs/platform-express": "^9.0.9",
    "@nestjs/serve-static": "^2.1.3",
    "@nestjs/swagger": "^7.1.11",
+    "@nestjs/terminus": "^10.2.3",
    "@types/lodash": "^4.14.194",
    "@types/ws": "^8.5.4",
+    "check-disk-space": "^3.4.0",
    "class-validator": "^0.12.2",
    "del": "^6.0.0",
    "express-basic-auth": "^1.2.1",
@@ -42,6 +45,7 @@
    "link-preview-js": "^3.0.4",
    "lodash": "^4.17.21",
    "mime-types": "^2.1.27",
+    "mongodb": "^6.3.0",
    "passport": "^0.6.0",
    "passport-headerapikey": "^1.2.2",
    "qrcode": "^1.5.1",
@@ -53,7 +57,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/devlikeapro/whatsapp-web.js#main-fork"
  },
  "devDependencies": {
    "@nestjs/cli": "^9.0.0",
@@ -12,6 +12,7 @@ import { ApiOperation, ApiSecurity, ApiTags } from '@nestjs/swagger';
 import { SessionManager } from '../core/abc/manager.abc';
 import { WhatsappSession } from '../core/abc/session.abc';
 import {
+  CaptchaBody,
  OTPRequest,
  QRCodeFormat,
  QRCodeQuery,
@@ -60,7 +61,7 @@ class AuthController {
    @SessionParam session: WhatsappSession,
    @Body() request: RequestCodeRequest,
  ) {
-    return session.requestCode(request.phoneNumber, request.method);
+    return session.requestCode(request.phoneNumber, request.method, request);
  }

  @Post('authorize-code')
@@ -74,6 +75,30 @@ class AuthController {
  ) {
    return session.authorizeCode(request.code);
  }
+
+  @Get('captcha')
+  @SessionApiParam
+  @ApiFileAcceptHeader()
+  @UseInterceptors(new BufferResponseInterceptor())
+  @ApiOperation({
+    summary: 'Get captcha image.',
+  })
+  async getCaptcha(@SessionParam session: WhatsappSession): Promise<Buffer> {
+    const image = await session.getCaptcha();
+    return image.get();
+  }
+
+  @Post('captcha')
+  @SessionApiParam
+  @ApiOperation({
+    summary: 'Enter captcha code.',
+  })
+  saveCaptcha(
+    @SessionParam session: WhatsappSession,
+    @Body() body: CaptchaBody,
+  ) {
+    return session.saveCaptcha(body.code);
+  }
 }

 export { AuthController };
@@ -0,0 +1,17 @@
+import { Controller, Get } from '@nestjs/common';
+import { ApiTags } from '@nestjs/swagger';
+import { HealthCheck } from '@nestjs/terminus';
+
+import { WAHAHealthCheckService } from '../core/abc/WAHAHealthCheckService';
+
+@Controller('health')
+@ApiTags('other')
+export class HealthController {
+  constructor(private wahaHealth: WAHAHealthCheckService) {}
+
+  @Get()
+  @HealthCheck()
+  async check() {
+    return this.wahaHealth.check();
+  }
+}
@@ -29,7 +29,7 @@ class SessionsController {
  @Post('/start/')
  async start(@Body() request: SessionStartRequest): Promise<SessionDTO> {
    const result = await this.manager.start(request);
-    await this.manager.sessionStorage.configRepository.save(
+    await this.manager.sessionConfigRepository.save(
      request.name,
      request.config || null,
    );
@@ -108,6 +108,10 @@ export class WhatsappConfigService {
    return value ? value.split(',') : [];
  }

+  getSessionMongoUrl(): string | undefined {
+    return this.configService.get('WHATSAPP_SESSIONS_MONGO_URL', undefined);
+  }
+
  getDefaultEngineName(): WAHAEngine {
    const value = getEngineName();
    if (value in WAHAEngine) {
@@ -151,4 +155,25 @@ export class WhatsappConfigService {
  getSwaggerAdvancedConfigEnabled(): boolean {
    return this.configService.get('WHATSAPP_SWAGGER_CONFIG_ADVANCED', false);
  }
+
+  getHealthMediaFilesThreshold(): number {
+    return this.configService.get<number>(
+      'WHATSAPP_HEALTH_MEDIA_FILES_THRESHOLD_MB',
+      100,
+    );
+  }
+
+  getHealthSessionFilesThreshold(): number {
+    return this.configService.get<number>(
+      'WHATSAPP_HEALTH_SESSION_FILES_THRESHOLD_MB',
+      100,
+    );
+  }
+
+  getHealthMongoTimeout(): number {
+    return this.configService.get<number>(
+      'WHATSAPP_HEALTH_MONGO_TIMEOUT_MS',
+      3000,
+    );
+  }
 }
@@ -0,0 +1 @@
+export abstract class DataStore {}
@@ -0,0 +1,18 @@
+import { ConsoleLogger, Injectable } from '@nestjs/common';
+import { DiskHealthIndicator, HealthCheckService } from '@nestjs/terminus';
+import type { HealthCheckResult } from '@nestjs/terminus/dist/health-check/health-check-result.interface';
+
+import { WhatsappConfigService } from '../../config.service';
+import { SessionManager } from './manager.abc';
+
+@Injectable()
+export abstract class WAHAHealthCheckService {
+  constructor(
+    protected sessionManager: SessionManager,
+    protected health: HealthCheckService,
+    protected log: ConsoleLogger,
+    protected config: WhatsappConfigService,
+  ) {}
+
+  abstract check(): Promise<HealthCheckResult>;
+}
@@ -8,12 +8,15 @@ import {
  SessionStartRequest,
  SessionStopRequest,
 } from '../../structures/sessions.dto';
+import { ISessionAuthRepository } from '../storage/ISessionAuthRepository';
+import { ISessionConfigRepository } from '../storage/ISessionConfigRepository';
 import { WhatsappSession } from './session.abc';
-import { LocalSessionStorage } from './storage.abc';
 import { WebhookConductor } from './webhooks.abc';

 export abstract class SessionManager implements OnApplicationShutdown {
-  public sessionStorage: LocalSessionStorage;
+  public store: any;
+  public sessionAuthRepository: ISessionAuthRepository;
+  public sessionConfigRepository: ISessionConfigRepository;

  protected abstract getEngine(engine: WAHAEngine): typeof WhatsappSession;

@@ -3,7 +3,6 @@ import { EventEmitter } from 'events';
 import * as fs from 'fs';
 import { MessageId } from 'whatsapp-web.js';

-import { OTPRequest, RequestCodeRequest } from '../../structures/auth.dto';
 import {
  ChatRequest,
  CheckNumberStatusQuery,
@@ -47,8 +46,8 @@ import {
 import { WASessionStatusBody } from '../../structures/webhooks.dto';
 import { NotImplementedByEngineError } from '../exceptions';
 import { QR } from '../QR';
+import { DataStore } from './DataStore';
 import { MediaManager } from './media.abc';
-import { LocalSessionStorage } from './storage.abc';

 const CHROME_PATH = '/usr/bin/google-chrome-stable';
 const CHROMIUM_PATH = '/usr/bin/chromium';
@@ -77,7 +76,7 @@ export interface SessionParams {
  name: string;
  mediaManager: MediaManager;
  log: ConsoleLogger;
-  sessionStorage: LocalSessionStorage;
+  sessionStore: DataStore;
  proxyConfig?: ProxyConfig;
  sessionConfig?: SessionConfig;
 }
@@ -89,7 +88,7 @@ export abstract class WhatsappSession {
  public name: string;
  protected mediaManager: MediaManager;
  protected log: ConsoleLogger;
-  protected sessionStorage: LocalSessionStorage;
+  protected sessionStore: DataStore;
  protected proxyConfig?: ProxyConfig;
  public sessionConfig?: SessionConfig;

@@ -98,7 +97,7 @@ export abstract class WhatsappSession {
  public constructor({
    name,
    log,
-    sessionStorage,
+    sessionStore,
    proxyConfig,
    mediaManager,
    sessionConfig,
@@ -107,7 +106,7 @@ export abstract class WhatsappSession {
    this.name = name;
    this.proxyConfig = proxyConfig;
    this.log = log;
-    this.sessionStorage = sessionStorage;
+    this.sessionStore = sessionStore;
    this.mediaManager = mediaManager;
    this.sessionConfig = sessionConfig;
  }
@@ -199,7 +198,7 @@ export abstract class WhatsappSession {
    throw new NotImplementedByEngineError();
  }

-  public requestCode(phoneNumber: string, method: string) {
+  public requestCode(phoneNumber: string, method: string, params?: any) {
    throw new NotImplementedByEngineError();
  }

@@ -213,6 +212,14 @@ export abstract class WhatsappSession {
    throw new NotImplementedByEngineError();
  }

+  public getCaptcha(): Promise<QR> {
+    throw new NotImplementedByEngineError();
+  }
+
+  public saveCaptcha(code: string) {
+    throw new NotImplementedByEngineError();
+  }
+
  /**
   * Other methods
   */
@@ -1,35 +0,0 @@
-import { SessionConfig } from '../../structures/sessions.dto';
-
-abstract class SessionConfigRepository {
-  abstract save(
-    sessionName: string,
-    config: SessionConfig | null,
-  ): Promise<void>;
-
-  abstract get(sessionName: string): Promise<SessionConfig | null>;
-}
-
-abstract class SessionStorage {
-  protected constructor(public engine: string) {
-    this.engine = engine;
-  }
-
-  abstract init(sessionName?: string): Promise<void>;
-
-  abstract clean(sessionName: string): Promise<void>;
-
-  abstract getAll(): Promise<string[]>;
-
-  //
-  // Repositories
-  //
-  abstract get configRepository(): SessionConfigRepository;
-}
-
-abstract class LocalSessionStorage extends SessionStorage {
-  public sessionsFolder: string;
-
-  abstract getFolderPath(sessionName: string): string;
-}
-
-export { LocalSessionStorage, SessionConfigRepository };
@@ -2,12 +2,14 @@ import { ConsoleLogger, Module } from '@nestjs/common';
 import { ConfigModule } from '@nestjs/config';
 import { PassportModule } from '@nestjs/passport';
 import { ServeStaticModule } from '@nestjs/serve-static';
+import { TerminusModule } from '@nestjs/terminus';

 import { AuthController } from '../api/auth.controller';
 import { ChatsController } from '../api/chats.controller';
 import { ChattingController } from '../api/chatting.controller';
 import { ContactsController } from '../api/contacts.controller';
 import { GroupsController } from '../api/groups.controller';
+import { HealthController } from '../api/health.controller';
 import { PresenceController } from '../api/presence.controller';
 import { ScreenshotController } from '../api/screenshot.controller';
 import {
@@ -18,6 +20,8 @@ import { StatusController } from '../api/status.controller';
 import { VersionController } from '../api/version.controller';
 import { WhatsappConfigService } from '../config.service';
 import { SessionManager } from './abc/manager.abc';
+import { WAHAHealthCheckService } from './abc/WAHAHealthCheckService';
+import { WAHAHealthCheckServiceCore } from './health/WAHAHealthCheckServiceCore';
 import { SessionManagerCore } from './manager.core';

 export const IMPORTS = [
@@ -38,6 +42,7 @@ export const IMPORTS = [
    },
  }),
  PassportModule,
+  TerminusModule,
 ];
 export const CONTROLLERS = [
  AuthController,
@@ -51,12 +56,17 @@ export const CONTROLLERS = [
  PresenceController,
  ScreenshotController,
  VersionController,
+  HealthController,
 ];
 const PROVIDERS = [
  {
    provide: SessionManager,
    useClass: SessionManagerCore,
  },
+  {
+    provide: WAHAHealthCheckService,
+    useClass: WAHAHealthCheckServiceCore,
+  },
  WhatsappConfigService,
  ConsoleLogger,
 ];
@@ -0,0 +1,19 @@
+import { useMultiFileAuthState } from '@adiwajshing/baileys';
+import { Store } from 'whatsapp-web.js';
+
+import { DataStore } from '../../abc/DataStore';
+import { LocalStore } from '../../storage/LocalStore';
+
+export class NowebAuthFactoryCore {
+  buildAuth(store: DataStore, name: string) {
+    if (store instanceof LocalStore) return this.buildLocalAuth(store, name);
+    throw new Error(`Unsupported store type '${store.constructor.name}'`);
+  }
+
+  protected async buildLocalAuth(store: LocalStore, name: string) {
+    await store.init(name);
+    const authFolder = store.getSessionDirectory(name);
+    const { state, saveCreds } = await useMultiFileAuthState(authFolder);
+    return { state, saveCreds };
+  }
+}
@@ -5,6 +5,7 @@ import makeWASocket, {
  getKeyAuthor,
  isJidGroup,
  jidNormalizedUser,
+  makeCacheableSignalKeyStore,
  makeInMemoryStore,
  PresenceData,
  proto,
@@ -19,7 +20,7 @@ import { Agent } from 'https';
 import * as lodash from 'lodash';
 import { PairingCodeResponse } from 'src/structures/auth.dto';

-import { flipObject, splitAt } from '../helpers';
+import { flipObject, splitAt } from '../../../helpers';
 import {
  ChatRequest,
  CheckNumberStatusQuery,
@@ -35,8 +36,8 @@ import {
  MessageVoiceRequest,
  SendSeenRequest,
  WANumberExistResult,
-} from '../structures/chatting.dto';
-import { ContactQuery, ContactRequest } from '../structures/contacts.dto';
+} from '../../../structures/chatting.dto';
+import { ContactQuery, ContactRequest } from '../../../structures/contacts.dto';
 import {
  ACK_UNKNOWN,
  SECOND,
@@ -45,35 +46,36 @@ import {
  WAHAPresenceStatus,
  WAHASessionStatus,
  WAMessageAck,
-} from '../structures/enums.dto';
+} from '../../../structures/enums.dto';
 import {
  CreateGroupRequest,
  ParticipantsRequest,
-} from '../structures/groups.dto';
+} from '../../../structures/groups.dto';
 import {
  WAHAChatPresences,
  WAHAPresenceData,
-} from '../structures/presence.dto';
-import { WAMessage } from '../structures/responses.dto';
-import { MeInfo } from '../structures/sessions.dto';
-import { BROADCAST_ID, TextStatus } from '../structures/status.dto';
+} from '../../../structures/presence.dto';
+import { WAMessage } from '../../../structures/responses.dto';
+import { MeInfo } from '../../../structures/sessions.dto';
+import { BROADCAST_ID, TextStatus } from '../../../structures/status.dto';
 import {
  PollVote,
  PollVotePayload,
  WAMessageAckBody,
-} from '../structures/webhooks.dto';
-import { IEngineMediaProcessor } from './abc/media.abc';
+} from '../../../structures/webhooks.dto';
+import { IEngineMediaProcessor } from '../../abc/media.abc';
 import {
  ensureSuffix,
  WAHAInternalEvent,
  WhatsappSession,
-} from './abc/session.abc';
+} from '../../abc/session.abc';
 import {
  AvailableInPlusVersion,
  NotImplementedByEngineError,
-} from './exceptions';
-import { createAgentProxy } from './helpers.proxy';
-import { QR } from './QR';
+} from '../../exceptions';
+import { createAgentProxy } from '../../helpers.proxy';
+import { QR } from '../../QR';
+import { NowebAuthFactoryCore } from './NowebAuthFactoryCore';

 // eslint-disable-next-line @typescript-eslint/no-var-requires
 const QRCode = require('qrcode');
@@ -101,6 +103,11 @@ const ToEnginePresenceStatus = flipObject(PresenceStatuses);

 export class WhatsappSessionNoWebCore extends WhatsappSession {
  engine = WAHAEngine.NOWEB;
+  authFactory = new NowebAuthFactoryCore();
+
+  get listenConnectionEventsFromTheStart() {
+    return true;
+  }

  sock: any;
  store: any;
@@ -120,9 +127,13 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
    return {
      agent: agent,
      fetchAgent: agent,
-      auth: state,
+      auth: {
+        creds: state.creds,
+        /** caching makes the store faster to send/recv messages */
+        keys: makeCacheableSignalKeyStore(state.keys, logger),
+      },
      printQRInTerminal: true,
-      browser: Browsers.macOS('Chrome'),
+      browser: Browsers.ubuntu('Chrome'),
      logger: logger,
      mobile: false,
      defaultQueryTimeoutMs: undefined,
@@ -131,9 +142,10 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
  }

  async makeSocket() {
-    const authFolder = this.sessionStorage.getFolderPath(this.name);
-    await fs.mkdir(authFolder, { recursive: true });
-    const { state, saveCreds } = await useMultiFileAuthState(authFolder);
+    const { state, saveCreds } = await this.authFactory.buildAuth(
+      this.sessionStore,
+      this.name,
+    );
    const agent = this.makeAgent();
    const socketConfig = this.getSocketConfig(agent, state);
    const sock: any = makeWASocket(socketConfig);
@@ -170,8 +182,10 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
    if (this.isDebugEnabled()) {
      this.listenEngineEventsInDebugMode();
    }
-    this.listenConnectionEvents();
-    this.events.emit(WAHAInternalEvent.ENGINE_START);
+    if (this.listenConnectionEventsFromTheStart) {
+      this.listenConnectionEvents();
+      this.events.emit(WAHAInternalEvent.ENGINE_START);
+    }
  }

  protected async getMessage(
@@ -229,9 +243,9 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
  }

  async stop() {
-    this.sock.ev.removeAllListeners();
-    this.sock.ws.removeAllListeners();
-    this.sock.ws.close();
+    this.sock?.ev?.removeAllListeners();
+    this.sock?.ws?.removeAllListeners();
+    this.sock?.ws?.close();
    this.status = WAHASessionStatus.STOPPED;
    return;
  }
@@ -263,6 +277,7 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
  public async requestCode(
    phoneNumber: string,
    method: string,
+    params?: any,
  ): Promise<PairingCodeResponse> {
    if (method) {
      const err = `NOWEB engine doesn't support any 'method', remove it and try again`;
@@ -279,7 +294,7 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
      throw new UnprocessableEntityException(err);
    }

-    this.log.log('Requesting pairing code...');
+    this.log.log(`Requesting pairing code for '${phoneNumber}'...`);
    const code: string = await this.sock.requestPairingCode(phoneNumber);
    // show it as ABCD-ABCD
    const parts = splitAt(code, 4);
@@ -312,10 +327,13 @@ export class WhatsappSessionNoWebCore extends WhatsappSession {
  ): Promise<WANumberExistResult> {
    const phone = request.phone.split('@')[0];
    const [result] = await this.sock.onWhatsApp(phone);
-    if (!result) {
+    if (!result || !result.exists) {
      return { numberExists: false };
    }
-    return { numberExists: result.exists };
+    return {
+      numberExists: true,
+      chatId: toCusFormat(result.jid),
+    };
  }

  sendText(request: MessageTextRequest) {
@@ -15,17 +15,17 @@ import {
  MessageReplyRequest,
  MessageTextRequest,
  WANumberExistResult,
-} from '../structures/chatting.dto';
+} from '../../../structures/chatting.dto';
 import {
  WAHAEngine,
  WAHAEvents,
  WAHASessionStatus,
-} from '../structures/enums.dto';
-import { WAMessage } from '../structures/responses.dto';
-import { IEngineMediaProcessor } from './abc/media.abc';
-import { WAHAInternalEvent, WhatsappSession } from './abc/session.abc';
-import { NotImplementedByEngineError } from './exceptions';
-import { QR } from './QR';
+} from '../../../structures/enums.dto';
+import { WAMessage } from '../../../structures/responses.dto';
+import { IEngineMediaProcessor } from '../../abc/media.abc';
+import { WAHAInternalEvent, WhatsappSession } from '../../abc/session.abc';
+import { NotImplementedByEngineError } from '../../exceptions';
+import { QR } from '../../QR';

 export class WhatsappSessionVenomCore extends WhatsappSession {
  engine = WAHAEngine.VENOM;
@@ -24,8 +24,8 @@ import {
  MessageVoiceRequest,
  SendSeenRequest,
  WANumberExistResult,
-} from '../structures/chatting.dto';
-import { ContactQuery, ContactRequest } from '../structures/contacts.dto';
+} from '../../../structures/chatting.dto';
+import { ContactQuery, ContactRequest } from '../../../structures/contacts.dto';
 import {
  ACK_UNKNOWN,
  WAHAEngine,
@@ -33,22 +33,22 @@ import {
  WAHAPresenceStatus,
  WAHASessionStatus,
  WAMessageAck,
-} from '../structures/enums.dto';
+} from '../../../structures/enums.dto';
 import {
  CreateGroupRequest,
  ParticipantsRequest,
  SettingsSecurityChangeInfo,
-} from '../structures/groups.dto';
-import { WAMessage } from '../structures/responses.dto';
-import { MeInfo } from '../structures/sessions.dto';
-import { WAMessageRevokedBody } from '../structures/webhooks.dto';
-import { IEngineMediaProcessor } from './abc/media.abc';
-import { WAHAInternalEvent, WhatsappSession } from './abc/session.abc';
+} from '../../../structures/groups.dto';
+import { WAMessage } from '../../../structures/responses.dto';
+import { MeInfo } from '../../../structures/sessions.dto';
+import { WAMessageRevokedBody } from '../../../structures/webhooks.dto';
+import { IEngineMediaProcessor } from '../../abc/media.abc';
+import { WAHAInternalEvent, WhatsappSession } from '../../abc/session.abc';
 import {
  AvailableInPlusVersion,
  NotImplementedByEngineError,
-} from './exceptions';
-import { QR } from './QR';
+} from '../../exceptions';
+import { QR } from '../../QR';

 // eslint-disable-next-line @typescript-eslint/no-var-requires
 const QRCode = require('qrcode');
@@ -67,7 +67,7 @@ export class WhatsappSessionWebJSCore extends WhatsappSession {
    this.qr = new QR();
  }

-  protected buildClient() {
+  protected async buildClient() {
    const clientOptions: ClientOptions = {
      puppeteer: {
        headless: true,
@@ -98,12 +98,26 @@ export class WhatsappSessionWebJSCore extends WhatsappSession {

  async start() {
    this.status = WAHASessionStatus.STARTING;
-    this.whatsapp = this.buildClient();
-    this.whatsapp.initialize().catch((error) => {
-      this.status = WAHASessionStatus.FAILED;
-      this.log.error(error);
-      return;
-    });
+    this.whatsapp = await this.buildClient();
+    this.whatsapp
+      .initialize()
+      .then(() => {
+        // Listen for browser disconnected event
+        this.whatsapp.pupBrowser.on('disconnected', () => {
+          this.status = WAHASessionStatus.FAILED;
+          this.log.error('The browser has been disconnected');
+        });
+        // Listen for page close event
+        this.whatsapp.pupPage.on('close', () => {
+          this.status = WAHASessionStatus.FAILED;
+          this.log.error('The WhatsApp Web page has been closed');
+        });
+      })
+      .catch((error) => {
+        this.status = WAHASessionStatus.FAILED;
+        this.log.error(error);
+        return;
+      });
    if (this.isDebugEnabled()) {
      this.listenEngineEventsInDebugMode();
    }
@@ -192,16 +206,23 @@ export class WhatsappSessionWebJSCore extends WhatsappSession {
  async checkNumberStatus(
    request: CheckNumberStatusQuery,
  ): Promise<WANumberExistResult> {
-    const exist = await this.whatsapp.isRegisteredUser(
-      this.ensureSuffix(request.phone),
-    );
-    return { numberExists: exist };
+    const phone = request.phone.split('@')[0];
+    const result = await this.whatsapp.getNumberId(phone);
+    if (!result) {
+      return {
+        numberExists: false,
+      };
+    }
+    return {
+      numberExists: true,
+      chatId: result._serialized,
+    };
  }

  sendText(request: MessageTextRequest) {
    const options = {
      // It's fine to sent just ids instead of Contact object
-      mentions: request.mentions as unknown as Contact[],
+      mentions: request.mentions as unknown as string[],
    };
    return this.whatsapp.sendMessage(
      this.ensureSuffix(request.chatId),
@@ -214,7 +235,7 @@ export class WhatsappSessionWebJSCore extends WhatsappSession {
    const options = {
      quotedMessageId: request.reply_to,
      // It's fine to sent just ids instead of Contact object
-      mentions: request.mentions as unknown as Contact[],
+      mentions: request.mentions as unknown as string[],
    };
    return this.whatsapp.sendMessage(request.chatId, request.text, options);
  }
@@ -0,0 +1,12 @@
+import { Injectable } from '@nestjs/common';
+import { HealthCheckResult } from '@nestjs/terminus';
+
+import { WAHAHealthCheckService } from '../abc/WAHAHealthCheckService';
+import { AvailableInPlusVersion } from '../exceptions';
+
+@Injectable()
+export class WAHAHealthCheckServiceCore extends WAHAHealthCheckService {
+  check(): Promise<HealthCheckResult> {
+    throw new AvailableInPlusVersion();
+  }
+}
@@ -19,13 +19,15 @@ import {
 import { WebhookConfig } from '../structures/webhooks.config.dto';
 import { SessionManager } from './abc/manager.abc';
 import { SessionParams, WhatsappSession } from './abc/session.abc';
+import { WhatsappSessionNoWebCore } from './engines/noweb/session.noweb.core';
+import { WhatsappSessionVenomCore } from './engines/venom/session.venom.core';
+import { WhatsappSessionWebJSCore } from './engines/webjs/session.webjs.core';
 import { DOCS_URL } from './exceptions';
 import { getProxyConfig } from './helpers.proxy';
 import { CoreMediaManager, MediaStorageCore } from './media.core';
-import { WhatsappSessionNoWebCore } from './session.noweb.core';
-import { WhatsappSessionVenomCore } from './session.venom.core';
-import { WhatsappSessionWebJSCore } from './session.webjs.core';
-import { SessionStorageCore } from './storage.core';
+import { LocalSessionAuthRepository } from './storage/LocalSessionAuthRepository';
+import { LocalSessionConfigRepository } from './storage/LocalSessionConfigRepository';
+import { LocalStoreCore } from './storage/LocalStoreCore';
 import { WebhookConductorCore } from './webhooks.core';

 export class OnlyDefaultSessionIsAllowed extends UnprocessableEntityException {
@@ -59,8 +61,9 @@ export class SessionManagerCore extends SessionManager {
    this.session = undefined;
    const engineName = this.config.getDefaultEngineName();
    this.EngineClass = this.getEngine(engineName);
-    this.sessionStorage = new SessionStorageCore(engineName.toLowerCase());
-
+    this.store = new LocalStoreCore(engineName.toLowerCase());
+    this.sessionAuthRepository = new LocalSessionAuthRepository(this.store);
+    this.sessionConfigRepository = new LocalSessionConfigRepository(this.store);
    this.startPredefinedSessions();
  }

@@ -116,11 +119,11 @@ export class SessionManagerCore extends SessionManager {
      name,
      mediaManager,
      log,
-      sessionStorage: this.sessionStorage,
+      sessionStore: this.store,
      proxyConfig: proxyConfig,
      sessionConfig: request.config,
    };
-    await this.sessionStorage.init(name);
+    await this.sessionAuthRepository.init(name);
    // @ts-ignore
    const session = new this.EngineClass(sessionConfig);
    this.session = session;
@@ -181,7 +184,7 @@ export class SessionManagerCore extends SessionManager {
  }

  async logout(request: SessionLogoutRequest) {
-    await this.sessionStorage.clean(request.name);
+    await this.sessionAuthRepository.clean(request.name);
  }

  getSession(name: string): WhatsappSession {
@@ -1,97 +0,0 @@
-import * as crypto from 'crypto';
-import * as fs from 'fs/promises';
-import * as os from 'os';
-import * as path from 'path';
-
-import { SessionConfig } from '../structures/sessions.dto';
-import {
-  LocalSessionStorage,
-  SessionConfigRepository,
-} from './abc/storage.abc';
-
-class LocalSessionConfigRepository extends SessionConfigRepository {
-  FILENAME = '.waha.session.config.json';
-
-  constructor(private storage: LocalSessionStorage) {
-    super();
-  }
-
-  async get(sessionName: string): Promise<SessionConfig | null> {
-    const filepath = this.getFilePath(sessionName);
-    // Check file exists
-    try {
-      await fs.access(filepath, fs.constants.F_OK);
-    } catch (error) {
-      return null;
-    }
-
-    // Try to load config
-    let content;
-    try {
-      content = await fs.readFile(filepath, 'utf-8');
-    } catch (error) {
-      return null;
-    }
-
-    return JSON.parse(content);
-  }
-
-  async save(sessionName: string, config: SessionConfig | null) {
-    // Create folder if not exist
-    const folder = this.storage.getFolderPath(sessionName);
-    await fs.mkdir(folder, { recursive: true });
-    // Save config
-    const filepath = this.getFilePath(sessionName);
-    const content = JSON.stringify(config || null);
-    await fs.writeFile(filepath, content);
-  }
-
-  private getFilePath(sessionName): string {
-    const folder = this.storage.getFolderPath(sessionName);
-    return path.join(folder, this.FILENAME);
-  }
-}
-
-export class SessionStorageCore extends LocalSessionStorage {
-  public sessionsFolder: string;
-
-  constructor(engine: string) {
-    super(engine);
-    this.sessionsFolder = path.join(os.tmpdir(), 'waha-sessions');
-  }
-
-  get engineFolder() {
-    return path.join(this.sessionsFolder, this.engine);
-  }
-
-  async init(sessionName?: string) {
-    const folder = sessionName
-      ? this.getFolderPath(sessionName)
-      : this.engineFolder;
-    await fs.mkdir(folder, { recursive: true });
-  }
-
-  getFolderPath(name: string): string {
-    const suffix = crypto.createHash('md5').update(name).digest('hex');
-    return path.join(this.engineFolder, `${name}-${suffix}`);
-  }
-
-  async clean(sessionName: string) {
-    const folder = this.getFolderPath(sessionName);
-    await fs.rm(folder, { recursive: true });
-  }
-
-  async getAll(): Promise<string[]> {
-    await this.init();
-    const content = await fs.readdir(this.engineFolder, {
-      withFileTypes: true,
-    });
-    return content
-      .filter((dirent) => dirent.isDirectory())
-      .map((dirent) => dirent.name);
-  }
-
-  get configRepository(): LocalSessionConfigRepository {
-    return new LocalSessionConfigRepository(this);
-  }
-}
@@ -0,0 +1,7 @@
+export abstract class ISessionAuthRepository {
+  abstract init(sessionName?: string): Promise<void>;
+
+  abstract clean(sessionName: string): Promise<void>;
+
+  abstract getAll(): Promise<string[]>;
+}
@@ -0,0 +1,12 @@
+import { SessionConfig } from '../../structures/sessions.dto';
+
+export abstract class ISessionConfigRepository {
+  abstract save(
+    sessionName: string,
+    config: SessionConfig | null,
+  ): Promise<void>;
+
+  abstract get(sessionName: string): Promise<SessionConfig | null>;
+
+  abstract delete(sessionName: string): Promise<void>;
+}
@@ -0,0 +1,32 @@
+import * as fs from 'fs/promises';
+
+import { ISessionAuthRepository } from './ISessionAuthRepository';
+import { LocalStore } from './LocalStore';
+
+export class LocalSessionAuthRepository extends ISessionAuthRepository {
+  private store: LocalStore;
+
+  constructor(store: LocalStore) {
+    super();
+    this.store = store;
+  }
+
+  async init(sessionName?: string) {
+    await this.store.init(sessionName);
+  }
+
+  async clean(sessionName: string) {
+    const folder = this.store.getSessionDirectory(sessionName);
+    await fs.rm(folder, { recursive: true });
+  }
+
+  async getAll(): Promise<string[]> {
+    await this.init();
+    const content = await fs.readdir(this.store.getEngineDirectory(), {
+      withFileTypes: true,
+    });
+    return content
+      .filter((dirent) => dirent.isDirectory())
+      .map((dirent) => dirent.name);
+  }
+}
@@ -0,0 +1,66 @@
+import * as fs from 'fs/promises';
+import * as path from 'path';
+
+import { SessionConfig } from '../../structures/sessions.dto';
+import { ISessionConfigRepository } from './ISessionConfigRepository';
+import { LocalStore } from './LocalStore';
+
+export class LocalSessionConfigRepository extends ISessionConfigRepository {
+  FILENAME = '.waha.session.config.json';
+  private store: LocalStore;
+
+  constructor(store: LocalStore) {
+    super();
+    this.store = store;
+  }
+
+  private async fileExists(filepath: string) {
+    try {
+      await fs.access(filepath, fs.constants.F_OK);
+    } catch (error) {
+      return false;
+    }
+    return true;
+  }
+
+  async get(sessionName: string): Promise<SessionConfig | null> {
+    const filepath = this.getFilePath(sessionName);
+    // Check file exists
+    if (!(await this.fileExists(filepath))) {
+      return null;
+    }
+
+    // Try to load config
+    let content;
+    try {
+      content = await fs.readFile(filepath, 'utf-8');
+    } catch (error) {
+      return null;
+    }
+
+    return JSON.parse(content);
+  }
+
+  async save(sessionName: string, config: SessionConfig | null) {
+    // Create folder if not exist
+    const folder = this.store.getSessionDirectory(sessionName);
+    await fs.mkdir(folder, { recursive: true });
+    // Save config
+    const filepath = this.getFilePath(sessionName);
+    const content = JSON.stringify(config || null);
+    await fs.writeFile(filepath, content);
+  }
+
+  private getFilePath(sessionName): string {
+    const folder = this.store.getSessionDirectory(sessionName);
+    return path.join(folder, this.FILENAME);
+  }
+
+  async delete(sessionName: string): Promise<void> {
+    const filepath = this.getFilePath(sessionName);
+    if (!(await this.fileExists(filepath))) {
+      return;
+    }
+    await fs.unlink(filepath);
+  }
+}
@@ -0,0 +1,20 @@
+import { DataStore } from '../abc/DataStore';
+
+export abstract class LocalStore extends DataStore {
+  abstract init(sessionName?: string): Promise<void>;
+
+  /**
+   * Get the directory where all the engines and sessions are stored
+   */
+  abstract getBaseDirectory(): string;
+
+  /**
+   * Get the directory where the engine sessions are stored
+   */
+  abstract getEngineDirectory(): string;
+
+  /**
+   * Get the directory where the session data is stored
+   */
+  abstract getSessionDirectory(name: string): string;
+}
@@ -0,0 +1,52 @@
+import * as crypto from 'crypto';
+import * as fs from 'fs/promises';
+import * as os from 'os';
+import * as path from 'path';
+
+import { LocalStore } from './LocalStore';
+
+export class LocalStoreCore extends LocalStore {
+  protected readonly baseDirectory: string = path.join(
+    os.tmpdir(),
+    'waha-sessions',
+  );
+
+  private readonly engine: string;
+
+  constructor(engine: string) {
+    super();
+    this.engine = engine;
+  }
+
+  async init(sessionName?: string) {
+    await fs.mkdir(this.getEngineDirectory(), { recursive: true });
+    if (sessionName) {
+      await fs.mkdir(this.getSessionDirectory(sessionName), {
+        recursive: true,
+      });
+    }
+  }
+
+  /**
+   * Get the directory where all the engines and sessions are stored
+   */
+  getBaseDirectory() {
+    return path.join(this.baseDirectory);
+  }
+
+  /**
+   * Get the directory where the engine sessions are stored
+   */
+  getEngineDirectory() {
+    return path.join(this.baseDirectory, this.engine);
+  }
+
+  getSessionDirectory(name: string): string {
+    return this.getDirectoryPath(name);
+  }
+
+  protected getDirectoryPath(name: string): string {
+    const suffix = crypto.createHash('md5').update(name).digest('hex');
+    return path.join(this.getEngineDirectory(), `${name}-${suffix}`);
+  }
+}
@@ -1,4 +1,4 @@
-import { ApiProperty } from '@nestjs/swagger';
+import { ApiHideProperty, ApiProperty } from '@nestjs/swagger';

 export enum QRCodeFormat {
  IMAGE = 'image',
@@ -26,12 +26,22 @@ export class RequestCodeRequest {
    required: false,
  })
  method: string;
+
+  @ApiHideProperty()
+  localeLanguage: string;
+
+  @ApiHideProperty()
+  localeCountry: string;
 }

 export class OTPRequest {
  code: string;
 }

+export class CaptchaBody {
+  code: string;
+}
+
 export class PairingCodeResponse {
  code: string;
 }
@@ -169,6 +169,11 @@ export class MessageReactionRequest extends MessageRequest {

 export class WANumberExistResult {
  numberExists: boolean;
+  @ApiProperty({
+    example:
+      'Chat id for the phone number. Undefined if the number does not exist',
+  })
+  chatId?: string;
 }

 export class MessagePoll {
@@ -26,7 +26,7 @@ export enum WAHAEngine {
  VENOM = 'VENOM',
  WEBJS = 'WEBJS',
  NOWEB = 'NOWEB',
-  NOWEB_MOBILE = 'NOWEB_MOBILE',
+  MOBILE = 'MOBILE',
 }

 export enum WAHAPresenceStatus {
@@ -21,13 +21,13 @@ export class WAMedia {
    description: 'mimetype for the media in the message if any',
    example: 'audio/jpeg',
  })
-  mimetype: string | null;
+  mimetype?: string;

  @ApiProperty({
    description: 'The original filename in mediaUrl in the message if any',
    example: 'example.pdf',
  })
-  filename: string | null;
+  filename?: string;
 }

 export class WAMessage {
@@ -76,7 +76,7 @@ export class WAMessage {
  })
  hasMedia: boolean;

-  media: WAMedia | null = null;
+  media?: WAMedia = null;

  @ApiProperty({
    description:
@@ -84,8 +84,8 @@ export class PollVotePayload {
 }

 export class WAMessageRevokedBody {
-  after: WAMessage | null;
-  before: WAMessage | null;
+  after?: WAMessage;
+  before?: WAMessage;
 }
 export class WASessionStatusBody {
  @ApiProperty({
@@ -107,7 +107,7 @@ export class WAHAWebhook {
  })
  engine: WAHAEngine;

-  me: MeInfo | null;
+  me?: MeInfo;

  environment: WAHAEnvironment;

@@ -0,0 +1,34 @@
+/**
+ * An errors which gets raised when the timeout
+ * exceeded
+ *
+ * @internal
+ */
+export class TimeoutError extends Error {}
+
+/**
+ * Executes a promise in the given timeout. If the promise
+ * does not finish in the given timeout, it will
+ * raise a TimeoutError
+ *
+ * @param {number} ms The timeout in milliseconds
+ * @param {Promise<any>} promise The promise which should get executed
+ *
+ * @internal
+ */
+export const promiseTimeout = function (
+  ms: number,
+  promise: Promise<any>,
+): Promise<any> {
+  let timer: NodeJS.Timeout;
+  return Promise.race([
+    promise,
+    new Promise(
+      (_, reject) =>
+        (timer = setTimeout(
+          () => reject(new TimeoutError(`Timed out in ${ms}ms.`)),
+          ms,
+        )),
+    ),
+  ]).finally(() => clearTimeout(timer));
+};
@@ -33,7 +33,7 @@ export function getEngineName(): string {
 }

 export const VERSION: WAHAEnvironment = {
-  version: '2023.12.1',
+  version: '2024.3.2',
  engine: getEngineName(),
  tier: getWAHAVersion(),
  browser: getBrowserExecutablePath(),
Author	SHA1	Message	Date
allburov	cae955c483	[core] Bump to 2024.3.2 Release / amd64 - chrome - chrome (push) Waiting to run Details Release / amd64 - chromium - latest (push) Waiting to run Details Release / linux/arm64 - chromium - arm (push) Waiting to run Details Release / amd64 - none - noweb (push) Waiting to run Details Release / linux/arm64 - none - noweb-arm (push) Waiting to run Details	2024-03-07 19:28:12 +07:00
allburov	0bfff5259e	[core] Use ubuntu in NOWEB	2024-03-07 19:27:45 +07:00
allburov	0fa83e603b	[core] No more MOBILE engine	2024-03-04 23:14:28 +07:00
allburov	906b03804f	[core] Update WEBJS Release / amd64 - chrome - chrome (push) Waiting to run Details Release / amd64 - chromium - latest (push) Waiting to run Details Release / linux/arm64 - chromium - arm (push) Waiting to run Details Release / amd64 - none - noweb (push) Waiting to run Details Release / linux/arm64 - none - noweb-arm (push) Waiting to run Details	2024-03-02 18:08:52 +07:00
allburov	1ed7a61bea	[core] Use fork for WEBJS in Makefile	2024-03-02 18:08:31 +07:00
allburov	ad6ae7ab05	[core] Bump version to 2024.3.1	2024-03-02 18:02:30 +07:00
allburov	5e2de1d47d	[core] Bump to 2024.2.4 Release / amd64 - chrome - chrome (push) Waiting to run Details Release / amd64 - chromium - latest (push) Waiting to run Details Release / linux/arm64 - chromium - arm (push) Waiting to run Details Release / amd64 - none - noweb (push) Waiting to run Details Release / linux/arm64 - none - noweb-arm (push) Waiting to run Details	2024-02-25 17:57:29 +07:00
allburov	591ca51104	[core] add GET /health	2024-02-25 17:56:58 +07:00
allburov	b210841158	[core] Fix documentation for message.revoked	2024-02-21 10:31:54 +07:00
allburov	a223a3985b	[core] Self-hosted solution	2024-02-19 14:52:23 +07:00
allburov	8baa6a73cd	[core] Self-hosted	2024-02-19 14:52:07 +07:00
allburov	508efac2ea	[core] Add links on index	2024-02-19 14:51:59 +07:00
allburov	b6eed9e228	[core] Rewrite tiers	2024-02-19 14:46:17 +07:00
allburov	b62cad07f0	[core] Icons on main page	2024-02-19 14:28:18 +07:00
allburov	6d552d27ac	[core] Bold	2024-02-19 14:11:24 +07:00
allburov	39d0f2a060	[core] Fix doc about WEBJS Release / linux/arm64 - chromium - arm (push) Waiting to run Details Release / amd64 - none - noweb (push) Waiting to run Details Release / linux/arm64 - none - noweb-arm (push) Waiting to run Details Release / amd64 - chrome - chrome (push) Waiting to run Details Release / amd64 - chromium - latest (push) Waiting to run Details	2024-02-18 20:22:45 +07:00
allburov	0b03abee91	[core] Fix delete file when it doesn't exist anymore	2024-02-18 20:22:41 +07:00
allburov	b4fb69d0ee	[core] Use extends instead of implements for LocalStoreCore.ts	2024-02-18 19:55:54 +07:00
allburov	5b9ed029b3	[core] NOWEB - fix stop session	2024-02-18 19:42:32 +07:00
allburov	c29397371b	[core] Use network host in mongo example	2024-02-18 19:37:45 +07:00
allburov	fe47e27788	[core] Fix yarn file	2024-02-18 19:37:33 +07:00
allburov	a14c702c79	[core] Bump to 2024.2.3	2024-02-18 19:25:12 +07:00
allburov	fe4246036d	[core] Support MongoDB	2024-02-18 19:21:19 +07:00
allburov	074063b814	[core] Fix set presence documentation	2024-02-12 11:34:15 +07:00
allburov	0271a8b721	[core] Fix changelog version Release / amd64 - chrome - chrome (push) Waiting to run Details Release / amd64 - chromium - latest (push) Waiting to run Details Release / linux/arm64 - chromium - arm (push) Waiting to run Details Release / amd64 - none - noweb (push) Waiting to run Details Release / linux/arm64 - none - noweb-arm (push) Waiting to run Details	2024-02-10 15:09:16 +07:00
allburov	08617383be	[core] Listen for page close event fix #262	2024-02-10 15:08:03 +07:00
allburov	3840459b0a	[core] add noweb engine performance	2024-02-09 15:11:36 +07:00
Sunil Sankar	aee7ac28bc	[core] Fix the image name (#260 ) The image name is wrongly mentioned	2024-02-05 14:02:21 +07:00
allburov	9e6cd39b2d	[core] fix types Release / amd64 - none - noweb (push) Waiting to run Details Release / linux/arm64 - none - noweb-arm (push) Waiting to run Details Release / amd64 - chrome - chrome (push) Waiting to run Details Release / amd64 - chromium - latest (push) Waiting to run Details Release / linux/arm64 - chromium - arm (push) Waiting to run Details	2024-02-01 16:23:42 +03:00
allburov	8898429046	[core] Update engines	2024-02-01 16:23:36 +03:00
allburov	a74def6dbd	[core] Add Patron Portal link	2024-02-01 16:15:42 +03:00
allburov	9f783cd35e	[core] Add Patron Portal link	2024-02-01 16:14:04 +03:00
allburov	9d2f061d81	[core] Pass other parameters to requestCode, like locale	2024-01-27 15:11:16 +07:00
allburov	a6045b2d54	[core] Add badge example	2024-01-27 13:58:50 +07:00
allburov	6142b2b564	[core] Link fixes	2024-01-27 13:56:30 +07:00
allburov	ed53ccb919	[core] One more PRO tier perk	2024-01-27 13:54:38 +07:00
allburov	1ab45c6cfd	[core] Add MOBILE engine note	2024-01-27 13:40:10 +07:00
allburov	c2fdb090e1	[core] build via ssh	2024-01-27 13:40:10 +07:00
allburov	a10b47eb7e	[core] Dockerfile - mount ssh in case of private repositories	2024-01-27 13:40:10 +07:00
allburov	7b234e2e37	[core] make build-ssh	2024-01-27 13:40:10 +07:00
allburov	90d45a4698	[core] Add captcha API endpoints	2024-01-27 13:40:10 +07:00
allburov	5e40b70e19	[core] NOWEB - Listen connection events from the start	2024-01-27 13:40:10 +07:00
allburov	a27d0c3efb	[core] Add MOBILE engine	2024-01-27 13:40:10 +07:00
allburov	46ed506b35	[core] start stop typing in the example	2024-01-27 13:01:52 +07:00
allburov	0ad813a1fe	[core] Add links	2024-01-08 18:58:44 +07:00
allburov	e57e42f47a	[core] Add tiers	2024-01-08 18:53:31 +07:00
Alex	cc58157d37	[core] Add badges for patreons	2024-01-08 11:55:34 +07:00
Alex	9b5bb0a339	[core] Create gh-team-labels.yml	2024-01-07 16:34:03 +07:00
Alex	84ebbea287	Delete .github/.github/gh-team-labels.yml	2024-01-07 16:33:44 +07:00
Alex	1c2021f54b	Update gh-team-labels.yml	2024-01-07 16:33:09 +07:00
Alex	98a7f00d7d	[core] Update gh-team-labels.yml	2024-01-07 16:29:14 +07:00
Alex	60d97d0e67	[core] Create gh-team-labels.yml	2024-01-07 16:28:17 +07:00
allburov	03f4a07cbe	[core] Update NOWEB	2023-12-26 18:33:53 +07:00
allburov	3fbe526793	[core] log phone	2023-12-26 17:54:34 +07:00
allburov	a892f03382	[core] Bump version to 2023.12.3	2023-12-26 17:20:12 +07:00
allburov	8db69f6e69	[core] Update WEBJS	2023-12-26 17:20:00 +07:00
allburov	f9037ff9fc	[core] Add github link to authroize-code	2023-12-26 17:10:37 +07:00
allburov	366ddffa2b	[core] Add more about How to not get Banned	2023-12-22 16:05:25 +07:00
allburov	b8468588de	[core] Add note about wa.me link	2023-12-18 21:12:43 +07:00
allburov	62dd6f7f4a	[core] No --rm	2023-12-11 13:26:33 +07:00
allburov	858202f1bb	[core] Add chatId to changelog	2023-12-02 16:36:20 +07:00
allburov	db7900dc26	[core] Bump version to 2023.12.2	2023-12-02 16:34:20 +07:00
allburov	aa87e437dc	[core] Add note for Brazilian phone number	2023-12-02 16:33:50 +07:00
allburov	741e5e86f8	[core] Reformat send messages documentation	2023-12-02 16:28:44 +07:00
allburov	390a171891	[core] Document check exists changes	2023-12-02 16:23:00 +07:00
allburov	1fc5e2b47c	[core] Add chatId to check exists result	2023-12-02 16:13:23 +07:00
allburov	8926dc7cc6	[core] update swagger	2023-12-01 09:38:52 +07:00
allburov	5c3d3c0d70	[core] No null in swagger	2023-12-01 09:38:52 +07:00