feat(provider): new provider - venon:zap: configuracion inicial provi…

feat(provider): new provider - venon:zap: configuracion inicial provi…

.gitignore

@@ -3,6 +3,7 @@
 /packages/*/node_modules
 /packages/*/dist
 /packages/*/docs/dist
+/packages/provider/src/venom/tokens
 session.json
 chats/*
 !chats/.gitkeep

packages/provider/package.json

@@ -16,6 +16,7 @@
     "exports": {
         "./mock": "./lib/mock/index.cjs",
         "./twilio": "./lib/twilio/index.cjs",
-        "./web-whatsapp": "./lib/web-whatsapp/index.cjs"
+        "./web-whatsapp": "./lib/web-whatsapp/index.cjs",
+        "./venom": "./lib/venom/index.cjs"
     }
 }

packages/provider/rollup-provider.config.js

@@ -30,4 +30,13 @@ module.exports = [
         },
         plugins: [commonjs()],
     },
+    {
+        input: join(__dirname, 'src', 'venom', 'index.js'),
+        output: {
+            banner: banner['banner.output'].join(''),
+            file: join(__dirname, 'lib', 'venom', 'index.cjs'),
+            format: 'cjs',
+        },
+        plugins: [commonjs()],
+    },
 ]

packages/provider/src/venom/index.js

@@ -0,0 +1,54 @@
+const { ProviderClass } = require('@bot-whatsapp/bot')
+const venom = require('venom-bot')
+const { cleanNumber } = require('./utils/utils')
+
+class VenomProvider extends ProviderClass {
+    constructor() {
+        super()
+        this.vendor
+        venom
+            .create(
+                {
+                    session: 'session-1', //nombre de la sesion o id
+                    multidevice: true,
+                },
+                (base64Qrimg) => this.generateQr(base64Qrimg)
+            )
+            .then((client) => {
+                this.vendor = client
+                this.start()
+            })
+            .catch((erro) => {
+                console.log(erro)
+            })
+    }
+
+    generateQr = () => {
+        this.emit('require_action', {
+            instructions: [
+                `Debes escanear el QR Code para iniciar session reivsa qr.svg`,
+                `Recuerda que el QR se actualiza cada minuto `,
+                `Necesitas ayuda: https://link.codigoencasa.com/DISCORD`,
+            ],
+        })
+        //generateImage(qr)
+    }
+
+    start = () => {
+        this.vendor.onMessage((payload) => {
+            payload.from = cleanNumber(payload.from, true)
+            this.emit('message', payload)
+        })
+    }
+
+    sendMessage = async (userId, message, { options }) => {
+        console.log('entramos')
+        const number = cleanNumber(userId)
+        if (options?.buttons?.length)
+            return this.sendButtons(number, message, options.buttons)
+        if (options?.media) return this.sendMedia(number, options.media)
+        return this.vendor.sendText(number, message)
+    }
+}
+
+module.exports = VenomProvider

packages/provider/src/venom/utils/utils.js

@@ -0,0 +1,15 @@
+const qr = require('qr-image')
+const { createWriteStream } = require('fs')
+
+const cleanNumber = (number, full = false) => {
+    number = number.replace('@c.us', '')
+    number = !full ? `${number}@c.us` : `${number}`
+    return number
+}
+
+const generateImage = (base64) => {
+    let qr_svg = qr.image(base64, { type: 'svg', margin: 4 })
+    qr_svg.pipe(createWriteStream(`${process.cwd()}/qr.svg`))
+}
+
+module.exports = { cleanNumber, generateImage }

packages/provider/src/web-whatsapp/index.js

@@ -31,6 +31,7 @@ class WebWhatsappProvider extends ProviderClass {
         for (const { event, func } of listEvents) {
             this.vendor.on(event, func)
         }
+
         this.vendor.emit('preinit')
         this.vendor.initialize().catch((e) => {
             logger.log(e)

starters/apps/base-venom-memory/README.md

@@ -0,0 +1,12 @@
+### BASE APP
+
+Este bot contiene un flujo basico en el cual una persona (cliente) escribe **"hola"** y el bot responde.
+- Bienvenido a mi tienda
+- Como puedo ayudarte?
+- Tengo: Zapatos Bolsos etc..
+
+------
+-   [Discord](https://link.codigoencasa.com/DISCORD)
+-   [Twitter](https://twitter.com/leifermendez)
+-   [Youtube](https://www.youtube.com/watch?v=5lEMCeWEJ8o&list=PL_WGMLcL4jzWPhdhcUyhbFU6bC0oJd2BR)
+-   [Telegram](https://t.me/leifermendez)

starters/apps/base-venom-memory/app.js

@@ -0,0 +1,28 @@
+const {
+    createBot,
+    createProvider,
+    createFlow,
+    addKeyword,
+} = require('@bot-whatsapp/bot')
+
+const WebWhatsappProvider = require('@bot-whatsapp/provider/venom')
+const MockAdapter = require('@bot-whatsapp/database/mock')
+
+const flowPrincipal = addKeyword(['hola', 'ole', 'HOLA'])
+    .addAnswer('Bienvenido a mi tienda')
+    .addAnswer('Como puedo ayudarte?')
+    .addAnswer(['Tengo:', 'Zapatos', 'Bolsos', 'etc..'])
+
+const main = async () => {
+    const adapterDB = new MockAdapter()
+    const adapterFlow = createFlow([flowPrincipal])
+    const adapterProvider = createProvider(WebWhatsappProvider)
+
+    createBot({
+        flow: adapterFlow,
+        provider: adapterProvider,
+        database: adapterDB,
+    })
+}
+
+main()

starters/apps/base-venom-memory/package.json

@@ -0,0 +1,20 @@
+{
+    "name": "bot-whatsapp-base",
+    "version": "1.0.0",
+    "description": "",
+    "main": "app.js",
+    "scripts": {
+        "pre-copy": "cd .. && yarn run copy.lib base-venom-mysql",
+        "start": "node app.js"
+    },
+    "keywords": [],
+    "dependencies": {
+        "venom-bot": "^4.3.7",
+        "@bot-whatsapp/bot": "latest",
+        "@bot-whatsapp/cli": "latest",
+        "@bot-whatsapp/database": "latest",
+        "@bot-whatsapp/provider": "latest"
+    },
+    "author": "",
+    "license": "ISC"
+}

starters/apps/base-venom-mongo/README.md

@@ -0,0 +1,12 @@
+### BASE APP
+
+Este bot contiene un flujo basico en el cual una persona (cliente) escribe **"hola"** y el bot responde.
+- Bienvenido a mi tienda
+- Como puedo ayudarte?
+- Tengo: Zapatos Bolsos etc..
+
+------
+-   [Discord](https://link.codigoencasa.com/DISCORD)
+-   [Twitter](https://twitter.com/leifermendez)
+-   [Youtube](https://www.youtube.com/watch?v=5lEMCeWEJ8o&list=PL_WGMLcL4jzWPhdhcUyhbFU6bC0oJd2BR)
+-   [Telegram](https://t.me/leifermendez)

starters/apps/base-venom-mongo/app.js

@@ -0,0 +1,28 @@
+const {
+    createBot,
+    createProvider,
+    createFlow,
+    addKeyword,
+} = require('@bot-whatsapp/bot')
+
+const WebWhatsappProvider = require('@bot-whatsapp/provider/venom')
+const MockAdapter = require('@bot-whatsapp/database/mock')
+
+const flowPrincipal = addKeyword(['hola', 'ole', 'HOLA'])
+    .addAnswer('Bienvenido a mi tienda')
+    .addAnswer('Como puedo ayudarte?')
+    .addAnswer(['Tengo:', 'Zapatos', 'Bolsos', 'etc..'])
+
+const main = async () => {
+    const adapterDB = new MockAdapter()
+    const adapterFlow = createFlow([flowPrincipal])
+    const adapterProvider = createProvider(WebWhatsappProvider)
+
+    createBot({
+        flow: adapterFlow,
+        provider: adapterProvider,
+        database: adapterDB,
+    })
+}
+
+main()

starters/apps/base-venom-mongo/package.json

@@ -0,0 +1,20 @@
+{
+    "name": "bot-whatsapp-base",
+    "version": "1.0.0",
+    "description": "",
+    "main": "app.js",
+    "scripts": {
+        "pre-copy": "cd .. && yarn run copy.lib base-venom-mysql",
+        "start": "node app.js"
+    },
+    "keywords": [],
+    "dependencies": {
+        "venom-bot": "^4.3.7",
+        "@bot-whatsapp/bot": "latest",
+        "@bot-whatsapp/cli": "latest",
+        "@bot-whatsapp/database": "latest",
+        "@bot-whatsapp/provider": "latest"
+    },
+    "author": "",
+    "license": "ISC"
+}

starters/apps/base-venom-mysql/README.md

@@ -0,0 +1,12 @@
+### BASE APP
+
+Este bot contiene un flujo basico en el cual una persona (cliente) escribe **"hola"** y el bot responde.
+- Bienvenido a mi tienda
+- Como puedo ayudarte?
+- Tengo: Zapatos Bolsos etc..
+
+------
+-   [Discord](https://link.codigoencasa.com/DISCORD)
+-   [Twitter](https://twitter.com/leifermendez)
+-   [Youtube](https://www.youtube.com/watch?v=5lEMCeWEJ8o&list=PL_WGMLcL4jzWPhdhcUyhbFU6bC0oJd2BR)
+-   [Telegram](https://t.me/leifermendez)

starters/apps/base-venom-mysql/app.js

@@ -0,0 +1,28 @@
+const {
+    createBot,
+    createProvider,
+    createFlow,
+    addKeyword,
+} = require('@bot-whatsapp/bot')
+
+const WebWhatsappProvider = require('@bot-whatsapp/provider/venom')
+const MockAdapter = require('@bot-whatsapp/database/mock')
+
+const flowPrincipal = addKeyword(['hola', 'ole', 'HOLA'])
+    .addAnswer('Bienvenido a mi tienda')
+    .addAnswer('Como puedo ayudarte?')
+    .addAnswer(['Tengo:', 'Zapatos', 'Bolsos', 'etc..'])
+
+const main = async () => {
+    const adapterDB = new MockAdapter()
+    const adapterFlow = createFlow([flowPrincipal])
+    const adapterProvider = createProvider(WebWhatsappProvider)
+
+    createBot({
+        flow: adapterFlow,
+        provider: adapterProvider,
+        database: adapterDB,
+    })
+}
+
+main()

starters/apps/base-venom-mysql/package.json

@@ -0,0 +1,20 @@
+{
+    "name": "bot-whatsapp-base",
+    "version": "1.0.0",
+    "description": "",
+    "main": "app.js",
+    "scripts": {
+        "pre-copy": "cd .. && yarn run copy.lib base-venom-mysql",
+        "start": "node app.js"
+    },
+    "keywords": [],
+    "dependencies": {
+        "venom-bot": "^4.3.7",
+        "@bot-whatsapp/bot": "latest",
+        "@bot-whatsapp/cli": "latest",
+        "@bot-whatsapp/database": "latest",
+        "@bot-whatsapp/provider": "latest"
+    },
+    "author": "",
+    "license": "ISC"
+}