feat(release): release v1.2.0 version

Author: DutaKey

.github/workflows/release.yml

@@ -1,38 +1,38 @@
 name: Release
 
 on:
-  push:
-     branches:
-      - main
+    push:
+        branches:
+            - main
 
 permissions:
-  contents: write
-  issues: write
-  pull-requests: write
+    contents: write
+    issues: write
+    pull-requests: write
 
 jobs:
-  release:
-    runs-on: ubuntu-latest
-    steps:
-      - name: Checkout code
-        uses: actions/checkout@v2
-
-      - name: Set up Node.js
-        uses: actions/setup-node@v4
-        with:
-          node-version: 'lts/*'
-
-      - name: Install dependencies
-        run: npm install
-
-      - name: Build package
-        run: npm run build
-
-      - name: Run audit
-        run: npm audit signatures
-
-      - name: Release
-        env:
-          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
-          NPM_TOKEN: ${{ secrets.NPM_TOKEN }}
-        run: npx semantic-release
+    release:
+        runs-on: ubuntu-latest
+        steps:
+            - name: Checkout code
+              uses: actions/checkout@v2
+
+            - name: Set up Node.js
+              uses: actions/setup-node@v4
+              with:
+                  node-version: 'lts/*'
+
+            - name: Install dependencies
+              run: npm install
+
+            - name: Build package
+              run: npm run build
+
+            - name: Run audit
+              run: npm audit signatures
+
+            - name: Release
+              env:
+                  GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+                  NPM_TOKEN: ${{ secrets.NPM_TOKEN }}
+              run: npx semantic-release

.prettierrc

@@ -0,0 +1,7 @@
+{
+    "semi": true,
+    "singleQuote": true,
+    "tabWidth": 4,
+    "trailingComma": "es5",
+    "printWidth": 120
+}

Example/example.ts

@@ -0,0 +1,96 @@
+import WhatsMulti from '../src';
+
+// Start the WhatsMulti example
+const start = async () => {
+    const client = new WhatsMulti({
+        mongoUri: 'mongodb://localhost:27017/whatsmulti',
+    });
+
+    // Create the first session with local storage
+    await client.createSession('session-1', 'mongodb');
+
+    // Event listeners for session status changes
+    client.on('disconnected', (_, sessionId) => console.log(sessionId, 'is Disconnected.'));
+    client.on('connecting', (_, sessionId) => console.log(sessionId, 'is Connecting...'));
+    client.on('connected', (_, sessionId) => console.log(sessionId, 'is Connected.'));
+
+    // Listen for QR Code event and log it
+    client.on('qr', (data) => console.log(data));
+
+    // Listen for incoming messages
+    client.on('messages.upsert', (data, sessionId) => {
+        const msg = data.messages[0];
+        if (msg.key.fromMe) return; // Ignore messages sent by the bot
+
+        const text = msg.message?.conversation || '';
+        const command = text.split(' ')[0]; // Extract command from message
+
+        switch (command) {
+            case 'status':
+                // Get and send the session status
+                const status = client.getSessionStatus(sessionId);
+                client.sendMessage(sessionId, msg, {
+                    text: `Status: ${sessionId} is ${status}`,
+                });
+                break;
+
+            case 'allsessions':
+                // List all active sessions
+                const sessions = client.getSessions();
+                client.sendMessage(sessionId, msg, {
+                    text: `Total Sessions: ${sessions.length}\n${sessions.join('\n')}`,
+                });
+                break;
+
+            case 'create':
+                // Create a new session dynamically
+                let newSessionIdVar = text.split(' ')[1] || 'session-2';
+                client.createSession(newSessionIdVar, 'local', {
+                    printQRInTerminal: false,
+                });
+
+                // Send QR code when it's generated
+                client.on('qr', (data, newSessionId) => {
+                    if (newSessionId === newSessionIdVar) {
+                        const base64Data = data.image.replace(/^data:image\/png;base64,/, '');
+                        const buffer = Buffer.from(base64Data, 'base64');
+                        client.sendMessage(sessionId, msg, {
+                            image: buffer,
+                            caption: 'Scan QR Code.',
+                        });
+                    }
+                });
+
+                // Notify when the session is connected
+                client.on('connected', (_, newSessionId) => {
+                    if (newSessionId === newSessionIdVar) {
+                        client.sendMessage(sessionId, msg, {
+                            text: `Session ${newSessionIdVar} is Connected.`,
+                        });
+                    }
+                });
+                break;
+
+            case 'delete':
+                // Delete an existing session
+                sessionId = text.split(' ')[1] || 'session-1';
+                client.deleteSession(sessionId);
+                client.sendMessage(sessionId, msg, {
+                    text: `Session ${sessionId} has been deleted.`,
+                });
+                break;
+
+            case 'send':
+                // Send a message to a specific session
+                sessionId = text.split(' ')[1] || 'session-1';
+                const message = text.split(' ').slice(2).join(' ');
+                client.sendMessage(sessionId, msg, {
+                    text: message,
+                });
+                break;
+        }
+    });
+};
+
+// Start the example
+start();

README.md

@@ -0,0 +1,37 @@
+# @Dutakey/WhatsMulti
+
+## 📌 Overview
+
+@Dutakey/WhatsMulti is a wrapper for [@whiskeysockets/baileys](https://github.com/WhiskeySockets/Baileys), designed to efficiently manage multiple WhatsApp Web sessions. It offers advanced session handling, flexible event listeners, and various storage options, making it ideal for developers integrating WhatsApp into their applications.
+
+## 🚀 Installation
+
+Install via npm:
+
+```sh
+npm install @dutakey/whatsmulti
+```
+
+Or using yarn:
+
+```sh
+yarn add @dutakey/whatsmulti
+```
+
+## ✨ Key Features
+
+- **Seamless Multi-Session Management**: Effortlessly create, manage, and maintain multiple WhatsApp sessions.
+- **Flexible Storage Options**: Store sessions locally or integrate with databases like MongoDB and Supabase.
+- **Robust Event Handling**: Easily handle events across multiple sessions for real-time monitoring.
+
+## 📂 Examples
+
+Check the [`example`](./Example/example.ts) folder for usage examples.
+
+## 🎯 Contributing
+
+Contributions are welcome! If you find a bug, have feature suggestions, or want to improve the project, feel free to open an issue or submit a pull request.
+
+## 📄 License
+
+This project is licensed under **MIT**, allowing free use, modification, and distribution.

package.json

@@ -6,36 +6,38 @@
     "main": "lib/index.js",
     "types": "lib/index.d.ts",
     "files": [
-      "lib/*",
-      "README.md"
+        "lib/*",
+        "README.md"
     ],
     "publishConfig": {
-      "access": "public"
+        "access": "public"
     },
     "dependencies": {
-      "@whiskeysockets/baileys": "^6.7.9",
-      "pino": "^7.0.0",
-      "pino-pretty": "^13.0.0",
-      "qrcode-terminal": "^0.12.0"
+        "@whiskeysockets/baileys": "^6.7.16",
+        "mongoose": "^8.13.2",
+        "pino": "^7.11.0",
+        "pino-pretty": "^13.0.0",
+        "qrcode": "^1.5.4",
+        "qrcode-terminal": "^0.12.0"
     },
     "devDependencies": {
-      "semantic-release": "^24.2.1",
-      "typescript": "^5.7.2"
+        "semantic-release": "^24.2.3",
+        "typescript": "^5.8.3"
     },
     "scripts": {
-      "build": "tsc",
-      "semantic-release": "semantic-release"
+        "build": "tsc",
+        "semantic-release": "semantic-release"
     },
     "repository": {
-      "type": "git",
-      "url": "git+https://github.com/DutaKey/WhatsMulti.git"
+        "type": "git",
+        "url": "git+https://github.com/DutaKey/WhatsMulti.git"
     },
     "keywords": [
-      "whatsapp"
+        "whatsapp"
     ],
     "license": "MIT",
     "bugs": {
-      "url": "https://github.com/DutaKey/WhatsMulti/issues"
+        "url": "https://github.com/DutaKey/WhatsMulti/issues"
     },
     "homepage": "https://github.com/DutaKey/WhatsMulti#readme"
-  }
+}

release.config.cjs

@@ -1,3 +1,3 @@
 module.exports = {
-    branches: ["main"],
-}
+    branches: ['main'],
+};

src/Defaults/index.ts

@@ -1,3 +1,3 @@
-export const LOCAL_CONNECTION_PATH = "whatsmulti_session";
+export const LOCAL_CONNECTION_PATH = 'whatsmulti_session';
 
-export const DEFAULT_CONNECTION_TYPE = "local";
+export const DEFAULT_CONNECTION_TYPE = 'local';

src/Handlers/index.ts

@@ -2,9 +2,12 @@ import { WASocket } from '@whiskeysockets/baileys';
 import { events } from '../Stores';
 import { EventMap, EventMapKey } from '../Types/Event';
 
-export const on = <K extends EventMapKey>(eventKey: K, e: (data: EventMap[K], sessionId: string, sock: WASocket) => any) => {
+export const on = <K extends EventMapKey>(
+    eventKey: K,
+    e: (data: EventMap[K], sessionId: string, sock: WASocket) => any
+) => {
     events.set(eventKey, e);
-}
+};
 
 // export const process = (
 //     e: (data: EventMap[EventMapKey], sessionId: string, sock: WASocket) => any

src/Handlers/socket.ts

@@ -1,56 +1,57 @@
-import { DisconnectReason } from "@whiskeysockets/baileys";
+import QRCode from 'qrcode';
+import { DisconnectReason } from '@whiskeysockets/baileys';
 import { Boom } from '@hapi/boom';
-import { EventHandlerType, EventMapKey } from "../Types/Event";
-import { events, sessions } from "../Stores";
-import { createSession, deleteSession } from "../Services";
-import { SessionStatusType } from "../Types/Session";
+import { EventHandlerType, EventMapKey } from '../Types/Event';
+import { events, sessions } from '../Stores';
+import { createSession, deleteSession } from '../Services/sessions';
+import { SessionStatusType } from '../Types/Session';
 
 export const handleSocketEvents = ({ sessionId, eventMap, sock, saveCreds }: EventHandlerType) => {
-    Object.entries(eventMap).forEach(([key, value]) => {
-        events.get(key as EventMapKey)?.(value, sessionId, sock);
-        eventHandlers[key]?.({ eventValue: value, sessionId, sock, saveCreds });
+    Object.entries(eventMap).forEach(([key, data]) => {
+        events.get(key as EventMapKey)?.(data, sessionId, sock);
+        eventHandlers[key]?.({ eventValue: data, sessionId, sock, saveCreds });
     });
 };
 
-
 const handleConnectionUpdate = ({ eventValue, sessionId }): void => {
     const { connection, lastDisconnect, qr } = eventValue;
-    const sessionData = sessions.get(sessionId);
+    const session = sessions.get(sessionId);
 
     if (qr) {
-        events.get("qr")?.(qr, sessionId);
-    } else if(connection) {
+        QRCode.toDataURL(qr).then((qrUrl: String) => {
+            events.get('qr')?.({ image: qrUrl, qr }, sessionId);
+        });
+    } else if (connection) {
         updateSessionStatus(sessionId, connection as SessionStatusType);
+
+        const isLoggedOut = (lastDisconnect?.error as Boom)?.output?.statusCode === DisconnectReason.loggedOut;
         if (connection === 'close') {
-            const shouldReconnect = (lastDisconnect?.error as Boom)?.output?.statusCode !== DisconnectReason.loggedOut;
-            if (shouldReconnect && sessionData) {
-                const args = { sessionId, connectionType: sessionData.connectionType, options: sessionData.options }
-                createSession(args)
+            if (!isLoggedOut && session) {
+                createSession(sessionId, session.connectionType, session.meta.socketConfig, session.meta.options);
             } else {
                 deleteSession(sessionId);
                 events.get('disconnected')?.({}, sessionId);
             }
-        } else if(connection === 'connecting') {
+        } else if (connection === 'connecting') {
             events.get('connecting')?.({}, sessionId);
-        }
-         else if (connection === 'open') {
+        } else if (connection === 'open') {
             events.get('connected')?.({}, sessionId);
         }
     }
-}
+};
 
 const handleCredsUpdate = ({ saveCreds }) => {
     saveCreds();
-}
+};
 
 const eventHandlers: { [key: string]: Function } = {
-    "creds.update": handleCredsUpdate,
-    "connection.update": handleConnectionUpdate,
+    'creds.update': handleCredsUpdate,
+    'connection.update': handleConnectionUpdate,
 };
 
 const updateSessionStatus = (sessionId: string, status: SessionStatusType): void => {
     const session = sessions.get(sessionId);
     if (session) {
         session.status = status;
     }
-}
+};