Merge branch 'leifermendez:dev' into dev

.gitignore

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

.vscode/settings.json

@@ -6,6 +6,7 @@
         "bot",
         "provider",
         "adapter",
-        "ci"
+        "ci",
+        "starters"
     ]
 }

core.class.log

@@ -1,3 +0,0 @@
-[handleMsg]:  { from: 'XXXXXX', body: 'hola', hasMedia: false }
-[handleMsg]:  { from: 'XXXXXX', body: 'hola', hasMedia: false }
-[handleMsg]:  { from: 'XXXXXX', body: 'hola', hasMedia: false }

packages/bot/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@bot-whatsapp/bot",
-    "version": "0.0.21-alpha.0",
+    "version": "0.0.22-alpha.0",
     "description": "",
     "main": "./lib/bundle.bot.cjs",
     "scripts": {

packages/cli/interactive/index.js

@@ -34,7 +34,8 @@ const startInteractive = async () => {
             choices: [
                 { title: 'whatsapp-web.js (gratis)', value: 'wweb' },
                 { title: 'Twilio', value: 'twilio' },
-                { title: 'Baileys (gratis)', value: 'bailey', disabled: true },
+                { title: 'Venom (gratis)', value: 'venom' },
+                { title: 'Baileys (gratis)', value: 'bailey' },
                 { title: 'API Oficial (Meta)', value: 'meta', disabled: true },
             ],
             max: 1,

packages/cli/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@bot-whatsapp/cli",
-    "version": "0.0.28-alpha.0",
+    "version": "0.0.29-alpha.0",
     "description": "",
     "main": "index.js",
     "devDependencies": {

packages/create-bot-whatsapp/package.json

@@ -1,6 +1,6 @@
 {
     "name": "create-bot-whatsapp",
-    "version": "0.0.39-alpha.0",
+    "version": "0.0.40-alpha.0",
     "description": "",
     "main": "./lib/bundle.create-bot-whatsapp.cjs",
     "files": [

packages/database/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@bot-whatsapp/database",
-    "version": "0.0.20-alpha.0",
+    "version": "0.0.21-alpha.0",
     "description": "Esto es el conector a  mysql, pg, mongo",
     "main": "./lib/mock/index.cjs",
     "keywords": [],

packages/provider/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@bot-whatsapp/provider",
-    "version": "0.0.26-alpha.0",
+    "version": "0.0.27-alpha.0",
     "description": "Esto es el conector a Twilio, Meta, etc...",
     "main": "./lib/mock/index.cjs",
     "keywords": [],
@@ -16,6 +16,8 @@
     "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",
+        "./baileys": "./lib/baileys/index.cjs"
     }
 }

packages/provider/rollup-provider.config.js

@@ -30,4 +30,22 @@ 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()],
+    },
+    {
+        input: join(__dirname, 'src', 'baileys', 'index.js'),
+        output: {
+            banner: banner['banner.output'].join(''),
+            file: join(__dirname, 'lib', 'baileys', 'index.cjs'),
+            format: 'cjs',
+        },
+        plugins: [commonjs()],
+    },
 ]

packages/provider/src/baileys/index.js

@@ -0,0 +1,171 @@
+const { ProviderClass } = require('@bot-whatsapp/bot')
+const pino = require('pino')
+const {
+    default: makeWASocket,
+    useMultiFileAuthState,
+} = require('@adiwajshing/baileys')
+const {
+    baileyGenerateImage,
+    baileyCleanNumber,
+    baileyIsValidNumber,
+} = require('./utils')
+
+/**
+ * ⚙️ BaileysProvider: Es una clase tipo adaptor
+ * que extiende clases de ProviderClass (la cual es como interfaz para sber que funciones rqueridas)
+ * https://github.com/adiwajshing/Baileys
+ */
+class BaileysProvider extends ProviderClass {
+    vendor
+    constructor() {
+        super()
+        this.initBailey().then(() => this.initBusEvents())
+    }
+
+    /**
+     * Iniciar todo Bailey
+     */
+    async initBailey() {
+        const { state, saveCreds } = await useMultiFileAuthState('sessions')
+
+        try {
+            this.vendor = makeWASocket({
+                printQRInTerminal: false,
+                auth: state,
+                logger: pino({ level: 'error' }),
+            })
+
+            this.vendor.ev.on(
+                'connection.update',
+                async ({ qr, connection, lastDisconnect }) => {
+                    if (qr) baileyGenerateImage(qr)
+                    if (connection === 'open') this.emit('ready', true)
+                    if (lastDisconnect?.error) {
+                        saveCreds()
+                        this.initBailey()
+                    }
+                }
+            )
+        } catch (e) {
+            this.emit('error', e)
+        }
+    }
+
+    /**
+     * Mapeamos los eventos nativos a los que la clase Provider espera
+     * para tener un standar de eventos
+     * @returns
+     */
+    busEvents = () => [
+        {
+            event: 'connection.update',
+            func: async ({ qr, connection, lastDisconnect }) => {
+                if (qr) {
+                    this.emit('require_action', {
+                        instructions: [
+                            `Debes escanear el QR Code para iniciar session reivsa qr.png`,
+                            `Recuerda que el QR se actualiza cada minuto `,
+                            `Necesitas ayuda: https://link.codigoencasa.com/DISCORD`,
+                        ],
+                    })
+                    baileyGenerateImage(qr)
+                }
+
+                if (lastDisconnect?.error) {
+                    this.emit('require_action', {
+                        instructions: [
+                            `Algo sucedio reinicia el bot o revisa tu whatsapp`,
+                            `Necesitas ayuda: https://link.codigoencasa.com/DISCORD`,
+                        ],
+                    })
+                }
+
+                if (connection === 'open') this.emit('ready', true)
+            },
+        },
+        {
+            event: 'messages.upsert',
+            func: ({ messages }) => {
+                const [messageCtx] = messages
+                let payload = {
+                    ...messageCtx,
+                    body: messageCtx?.message?.conversation,
+                    from: messageCtx?.key?.remoteJid,
+                }
+                if (payload.from === 'status@broadcast') {
+                    return
+                }
+
+                if (!baileyIsValidNumber(payload.from)) {
+                    return
+                }
+                payload.from = baileyCleanNumber(payload.from, true)
+                this.emit('message', payload)
+            },
+        },
+    ]
+
+    initBusEvents = () => {
+        const listEvents = this.busEvents()
+
+        for (const { event, func } of listEvents) {
+            this.vendor.ev.on(event, func)
+        }
+    }
+
+    /**
+     * @alpha
+     * @param {string} number
+     * @param {string} message
+     * @example await sendMessage('+XXXXXXXXXXX', 'https://dominio.com/imagen.jpg' | 'img/imagen.jpg')
+     */
+
+    sendMedia = async (number, imageUrl) => {
+        await this.vendor.sendMessage(number, {
+            image: { url: imageUrl },
+        })
+    }
+
+    /**
+     * @alpha
+     * @param {string} number
+     * @param {string} message
+     * @param {boolean} voiceNote optional
+     * @example await sendMessage('+XXXXXXXXXXX', 'audio.mp3')
+     */
+
+    sendAudio = async (number, audioUrl, voiceNote = false) => {
+        const numberClean = number.replace('+', '')
+        await this.vendor.sendMessage(`${numberClean}@c.us`, {
+            audio: { url: audioUrl },
+            ptt: voiceNote,
+        })
+    }
+
+    /**
+     *
+     * @param {string} number
+     * @param {string} message
+     * @returns
+     */
+    sendText = async (number, message) => {
+        return this.vendor.sendMessage(number, { text: message })
+    }
+    /**
+     * TODO: Necesita terminar de implementar el sendMedia y sendButton guiarse:
+     * https://github.com/leifermendez/bot-whatsapp/blob/4e0fcbd8347f8a430adb43351b5415098a5d10df/packages/provider/src/web-whatsapp/index.js#L165
+     * @param {string} number
+     * @param {string} message
+     * @example await sendMessage('+XXXXXXXXXXX', 'Hello World')
+     */
+    sendMessage = async (numberIn, message, { options }) => {
+        const number = baileyCleanNumber(numberIn)
+
+        // if (options?.buttons?.length)
+        //     return this.sendButtons(number, message, options.buttons)
+        if (options?.media) return this.sendMedia(number, options.media)
+        return this.sendText(number, message)
+    }
+}
+
+module.exports = BaileysProvider

packages/provider/src/baileys/utils.js

@@ -0,0 +1,21 @@
+const { createWriteStream } = require('fs')
+const qr = require('qr-image')
+
+const baileyCleanNumber = (number, full = false) => {
+    number = number.replace('@s.whatsapp.net', '')
+    number = !full ? `${number}@s.whatsapp.net` : `${number}`
+    return number
+}
+
+const baileyGenerateImage = (base64) => {
+    let qr_svg = qr.image(base64, { type: 'png', margin: 4 })
+    qr_svg.pipe(createWriteStream(`${process.cwd()}/qr.png`))
+}
+
+const baileyIsValidNumber = (rawNumber) => {
+    const regexGroup = /\@g.us\b/gm
+    const exist = rawNumber.match(regexGroup)
+    return !exist
+}
+
+module.exports = { baileyCleanNumber, baileyGenerateImage, baileyIsValidNumber }

packages/provider/src/venom/index.js

@@ -0,0 +1,116 @@
+const { ProviderClass } = require('@bot-whatsapp/bot')
+const venom = require('venom-bot')
+const {
+    venomCleanNumber,
+    venomGenerateImage,
+    venomisValidNumber,
+} = require('./utils')
+
+/**
+ * ⚙️ VenomProvider: Es una clase tipo adaptor
+ * que extiende clases de ProviderClass (la cual es como interfaz para sber que funciones rqueridas)
+ * https://github.com/orkestral/venom
+ */
+class VenomProvider extends ProviderClass {
+    vendor
+    constructor() {
+        super()
+        this.init().then(() => this.initBusEvents())
+    }
+
+    /**
+     * Iniciamos el Proveedor Venom
+     */
+    init = async () => {
+        try {
+            const client = await venom.create(
+                {
+                    session: 'session-base',
+                    multidevice: true,
+                },
+                (base) => this.generateQr(base),
+                undefined,
+                { logQR: false }
+            )
+            this.vendor = client
+        } catch (e) {
+            this.emit('auth_failure', {
+                instructions: [
+                    `Ocurrio un error con la inicializacion de venom`,
+                    `Necesitas ayuda: https://link.codigoencasa.com/DISCORD`,
+                    `(Puedes abrir un ISSUE) https://github.com/leifermendez/bot-whatsapp/issues/new/choose`,
+                    ``,
+                    `${e?.message}`,
+                ],
+            })
+        }
+    }
+
+    /**
+     * Generamos QR Code pra escanear con el Whatsapp
+     */
+    generateQr = (qr) => {
+        console.clear()
+        this.emit('require_action', {
+            instructions: [
+                `Debes escanear el QR Code para iniciar session reivsa qr.png`,
+                `Recuerda que el QR se actualiza cada minuto `,
+                `Necesitas ayuda: https://link.codigoencasa.com/DISCORD`,
+            ],
+        })
+        venomGenerateImage(qr)
+    }
+
+    /**
+     * Mapeamos los eventos nativos de  https://docs.orkestral.io/venom/#/?id=events
+     * para tener un standar de eventos
+     * @returns
+     */
+    busEvents = () => [
+        {
+            event: 'onMessage',
+            func: (payload) => {
+                if (payload.from === 'status@broadcast') {
+                    return
+                }
+
+                if (!venomisValidNumber(payload.from)) {
+                    return
+                }
+                payload.from = venomCleanNumber(payload.from, true)
+                this.emit('message', payload)
+            },
+        },
+    ]
+
+    /**
+     * Iniciamos y mapeamos el BusEvent
+     * Ejemplo:
+     * this.vendor.onMessage() 👉 this.vendor["onMessage"]()
+     */
+    initBusEvents = () => {
+        const listEvents = this.busEvents()
+
+        for (const { event, func } of listEvents) {
+            if (this.vendor[event])
+                this.vendor[event]((payload) => func(payload))
+        }
+    }
+
+    /**
+     * Enviar mensaje al usuario
+     * @param {*} userId
+     * @param {*} message
+     * @param {*} param2
+     * @returns
+     */
+    sendMessage = async (userId, message, { options }) => {
+        const number = venomCleanNumber(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.js

@@ -0,0 +1,36 @@
+const { writeFile } = require('fs')
+
+const venomCleanNumber = (number, full = false) => {
+    number = number.replace('@c.us', '')
+    number = !full ? `${number}@c.us` : `${number}`
+    return number
+}
+
+const venomGenerateImage = (base) => {
+    const matches = base.match(/^data:([A-Za-z-+\/]+);base64,(.+)$/)
+    if (matches.length !== 3) {
+        return new Error('Invalid input string')
+    }
+
+    let response = {}
+    response.type = matches[1]
+    response.data = new Buffer.from(matches[2], 'base64')
+
+    var imageBuffer = response
+    writeFile(
+        `${process.cwd()}/qr.png`,
+        imageBuffer['data'],
+        'binary',
+        (err) => {
+            if (err != null) throw new Error('ERROR_QR_GENERATE')
+            return
+        }
+    )
+}
+
+const venomisValidNumber = (rawNumber) => {
+    const regexGroup = /\@g.us\b/gm
+    const exist = rawNumber.match(regexGroup)
+    return !exist
+}
+module.exports = { venomCleanNumber, venomGenerateImage, venomisValidNumber }

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

@@ -3,10 +3,10 @@ const { ProviderClass } = require('@bot-whatsapp/bot')
 const { Console } = require('console')
 const { createWriteStream } = require('fs')
 const {
-    cleanNumber,
-    generateImage,
-    isValidNumber,
-    downloadMedia,
+    wwebCleanNumber,
+    wwebDownloadMedia,
+    wwebGenerateImage,
+    wwebIsValidNumber,
 } = require('./utils')
 
 const logger = new Console({
@@ -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)
@@ -59,12 +60,12 @@ class WebWhatsappProvider extends ProviderClass {
             func: (qr) => {
                 this.emit('require_action', {
                     instructions: [
-                        `Debes escanear el QR Code para iniciar session reivsa qr.svg`,
+                        `Debes escanear el QR Code para iniciar session reivsa qr.png`,
                         `Recuerda que el QR se actualiza cada minuto `,
                         `Necesitas ayuda: https://link.codigoencasa.com/DISCORD`,
                     ],
                 })
-                generateImage(qr)
+                wwebGenerateImage(qr)
             },
         },
         {
@@ -78,10 +79,10 @@ class WebWhatsappProvider extends ProviderClass {
                     return
                 }
 
-                if (!isValidNumber(payload.from)) {
+                if (!wwebIsValidNumber(payload.from)) {
                     return
                 }
-                payload.from = cleanNumber(payload.from, true)
+                payload.from = wwebCleanNumber(payload.from, true)
                 this.emit('message', payload)
             },
         },
@@ -97,7 +98,7 @@ class WebWhatsappProvider extends ProviderClass {
      */
     sendMedia = async (number, mediaInput = null) => {
         if (!mediaInput) throw new Error(`NO_SE_ENCONTRO: ${mediaInput}`)
-        const fileDownloaded = await downloadMedia(mediaInput)
+        const fileDownloaded = await wwebDownloadMedia(mediaInput)
         const media = MessageMedia.fromFilePath(fileDownloaded)
         return this.vendor.sendMessage(number, media, {
             sendAudioAsVoice: true,
@@ -162,7 +163,7 @@ class WebWhatsappProvider extends ProviderClass {
      * @returns
      */
     sendMessage = async (userId, message, { options }) => {
-        const number = cleanNumber(userId)
+        const number = wwebCleanNumber(userId)
         if (options?.buttons?.length)
             return this.sendButtons(number, message, options.buttons)
         if (options?.media) return this.sendMedia(number, options.media)

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

@@ -4,18 +4,18 @@ const { tmpdir } = require('os')
 const http = require('http')
 const https = require('https')
 
-const cleanNumber = (number, full = false) => {
+const wwebCleanNumber = (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`))
+const wwebGenerateImage = (base64) => {
+    let qr_svg = qr.image(base64, { type: 'png', margin: 4 })
+    qr_svg.pipe(createWriteStream(`${process.cwd()}/qr.png`))
 }
 
-const isValidNumber = (rawNumber) => {
+const wwebIsValidNumber = (rawNumber) => {
     const regexGroup = /\@g.us\b/gm
     const exist = rawNumber.match(regexGroup)
     return !exist
@@ -27,7 +27,7 @@ const isValidNumber = (rawNumber) => {
  * @param {*} url
  * @returns
  */
-const downloadMedia = (url) => {
+const wwebDownloadMedia = (url) => {
     return new Promise((resolve, reject) => {
         const ext = url.split('.').pop()
         const checkProtocol = url.includes('https:')
@@ -50,4 +50,9 @@ const downloadMedia = (url) => {
     })
 }
 
-module.exports = { cleanNumber, generateImage, isValidNumber, downloadMedia }
+module.exports = {
+    wwebCleanNumber,
+    wwebGenerateImage,
+    wwebIsValidNumber,
+    wwebDownloadMedia,
+}

starters/apps/base-bailey-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-bailey-memory/app.js

@@ -0,0 +1,82 @@
+const {
+    createBot,
+    createProvider,
+    createFlow,
+    addKeyword,
+    addChild,
+} = require('@bot-whatsapp/bot')
+
+const BaileysProvider = require('@bot-whatsapp/provider/baileys')
+const MockAdapter = require('@bot-whatsapp/database/mock')
+
+/**
+ * Declarando flujo hijo
+ */
+
+const flowBolsos2 = addKeyword(['bolsos2', '2'])
+    .addAnswer('🤯 *MUCHOS* bolsos ...')
+    .addAnswer('y mas bolsos... bla bla')
+
+const flowZapatos2 = addKeyword(['zapatos2', '2'])
+    .addAnswer('🤯 repito que tengo *MUCHOS* zapatos.')
+    .addAnswer('y algunas otras cosas.')
+
+const flowZapatos = addKeyword(['zapatos', 'ZAPATOS'])
+    .addAnswer('🤯 Veo que elegiste zapatos')
+    .addAnswer('Tengo muchos zapatos...bla bla')
+    .addAnswer(
+        ['Manda:', '*2*', 'o', '*zapatos2*', 'para mas información'],
+        { capture: true },
+        (ctx) => {
+            console.log('Aqui puedes ver más info del usuario...')
+            console.log('Puedes enviar un mail, hook, etc..')
+            console.log(ctx)
+        },
+        [...addChild(flowZapatos2)]
+    )
+
+const flowBolsos = addKeyword(['bolsos', 'BOLSOS'])
+    .addAnswer('🙌 Veo que elegiste bolsos')
+    .addAnswer('Tengo muchos bolsos...bla bla')
+    .addAnswer(
+        ['Manda:', '*2*', 'o', '*bolsos2*', 'para mas información.'],
+        { capture: true },
+        (ctx) => {
+            console.log('Aqui puedes ver más info del usuario...')
+            console.log('Puedes enviar un mail, hook, etc..')
+            console.log(ctx)
+        },
+        [...addChild(flowBolsos2)]
+    )
+
+/**
+ * Declarando flujo principal
+ */
+const flowPrincipal = addKeyword(['hola', 'ole', 'alo'])
+    .addAnswer('Hola, bienvenido a mi tienda')
+    .addAnswer('Como puedo ayudarte?')
+    .addAnswer(['Tengo:', 'Zapatos', 'Bolsos', 'etc..'])
+    .addAnswer(
+        ['Para continuar escribe:', '*Zapatos*', 'o', '*Bolsos*'],
+        { capture: true },
+        (ctx) => {
+            console.log('Aqui puedes ver más info del usuario...')
+            console.log('Puedes enviar un mail, hook, etc..')
+            console.log(ctx)
+            console.log(ctx['_data']['notifyName'])
+        },
+        [...addChild(flowBolsos), ...addChild(flowZapatos)]
+    )
+
+const main = async () => {
+    const adapterDB = new MockAdapter()
+    const adapterFlow = createFlow([flowPrincipal])
+    const adapterProvider = createProvider(BaileysProvider)
+    createBot({
+        flow: adapterFlow,
+        provider: adapterProvider,
+        database: adapterDB,
+    })
+}
+
+main()

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

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

starters/apps/base-bailey-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-bailey-mongo/app.js

@@ -0,0 +1,82 @@
+const {
+    createBot,
+    createProvider,
+    createFlow,
+    addKeyword,
+    addChild,
+} = require('@bot-whatsapp/bot')
+
+const BaileysProvider = require('@bot-whatsapp/provider/baileys')
+const MockAdapter = require('@bot-whatsapp/database/mock')
+
+/**
+ * Declarando flujo hijo
+ */
+
+const flowBolsos2 = addKeyword(['bolsos2', '2'])
+    .addAnswer('🤯 *MUCHOS* bolsos ...')
+    .addAnswer('y mas bolsos... bla bla')
+
+const flowZapatos2 = addKeyword(['zapatos2', '2'])
+    .addAnswer('🤯 repito que tengo *MUCHOS* zapatos.')
+    .addAnswer('y algunas otras cosas.')
+
+const flowZapatos = addKeyword(['zapatos', 'ZAPATOS'])
+    .addAnswer('🤯 Veo que elegiste zapatos')
+    .addAnswer('Tengo muchos zapatos...bla bla')
+    .addAnswer(
+        ['Manda:', '*2*', 'o', '*zapatos2*', 'para mas información'],
+        { capture: true },
+        (ctx) => {
+            console.log('Aqui puedes ver más info del usuario...')
+            console.log('Puedes enviar un mail, hook, etc..')
+            console.log(ctx)
+        },
+        [...addChild(flowZapatos2)]
+    )
+
+const flowBolsos = addKeyword(['bolsos', 'BOLSOS'])
+    .addAnswer('🙌 Veo que elegiste bolsos')
+    .addAnswer('Tengo muchos bolsos...bla bla')
+    .addAnswer(
+        ['Manda:', '*2*', 'o', '*bolsos2*', 'para mas información.'],
+        { capture: true },
+        (ctx) => {
+            console.log('Aqui puedes ver más info del usuario...')
+            console.log('Puedes enviar un mail, hook, etc..')
+            console.log(ctx)
+        },
+        [...addChild(flowBolsos2)]
+    )
+
+/**
+ * Declarando flujo principal
+ */
+const flowPrincipal = addKeyword(['hola', 'ole', 'alo'])
+    .addAnswer('Hola, bienvenido a mi tienda')
+    .addAnswer('Como puedo ayudarte?')
+    .addAnswer(['Tengo:', 'Zapatos', 'Bolsos', 'etc..'])
+    .addAnswer(
+        ['Para continuar escribe:', '*Zapatos*', 'o', '*Bolsos*'],
+        { capture: true },
+        (ctx) => {
+            console.log('Aqui puedes ver más info del usuario...')
+            console.log('Puedes enviar un mail, hook, etc..')
+            console.log(ctx)
+            console.log(ctx['_data']['notifyName'])
+        },
+        [...addChild(flowBolsos), ...addChild(flowZapatos)]
+    )
+
+const main = async () => {
+    const adapterDB = new MockAdapter()
+    const adapterFlow = createFlow([flowPrincipal])
+    const adapterProvider = createProvider(BaileysProvider)
+    createBot({
+        flow: adapterFlow,
+        provider: adapterProvider,
+        database: adapterDB,
+    })
+}
+
+main()

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

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

starters/apps/base-bailey-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-bailey-mysql/app.js

@@ -0,0 +1,82 @@
+const {
+    createBot,
+    createProvider,
+    createFlow,
+    addKeyword,
+    addChild,
+} = require('@bot-whatsapp/bot')
+
+const BaileysProvider = require('@bot-whatsapp/provider/baileys')
+const MockAdapter = require('@bot-whatsapp/database/mock')
+
+/**
+ * Declarando flujo hijo
+ */
+
+const flowBolsos2 = addKeyword(['bolsos2', '2'])
+    .addAnswer('🤯 *MUCHOS* bolsos ...')
+    .addAnswer('y mas bolsos... bla bla')
+
+const flowZapatos2 = addKeyword(['zapatos2', '2'])
+    .addAnswer('🤯 repito que tengo *MUCHOS* zapatos.')
+    .addAnswer('y algunas otras cosas.')
+
+const flowZapatos = addKeyword(['zapatos', 'ZAPATOS'])
+    .addAnswer('🤯 Veo que elegiste zapatos')
+    .addAnswer('Tengo muchos zapatos...bla bla')
+    .addAnswer(
+        ['Manda:', '*2*', 'o', '*zapatos2*', 'para mas información'],
+        { capture: true },
+        (ctx) => {
+            console.log('Aqui puedes ver más info del usuario...')
+            console.log('Puedes enviar un mail, hook, etc..')
+            console.log(ctx)
+        },
+        [...addChild(flowZapatos2)]
+    )
+
+const flowBolsos = addKeyword(['bolsos', 'BOLSOS'])
+    .addAnswer('🙌 Veo que elegiste bolsos')
+    .addAnswer('Tengo muchos bolsos...bla bla')
+    .addAnswer(
+        ['Manda:', '*2*', 'o', '*bolsos2*', 'para mas información.'],
+        { capture: true },
+        (ctx) => {
+            console.log('Aqui puedes ver más info del usuario...')
+            console.log('Puedes enviar un mail, hook, etc..')
+            console.log(ctx)
+        },
+        [...addChild(flowBolsos2)]
+    )
+
+/**
+ * Declarando flujo principal
+ */
+const flowPrincipal = addKeyword(['hola', 'ole', 'alo'])
+    .addAnswer('Hola, bienvenido a mi tienda')
+    .addAnswer('Como puedo ayudarte?')
+    .addAnswer(['Tengo:', 'Zapatos', 'Bolsos', 'etc..'])
+    .addAnswer(
+        ['Para continuar escribe:', '*Zapatos*', 'o', '*Bolsos*'],
+        { capture: true },
+        (ctx) => {
+            console.log('Aqui puedes ver más info del usuario...')
+            console.log('Puedes enviar un mail, hook, etc..')
+            console.log(ctx)
+            console.log(ctx['_data']['notifyName'])
+        },
+        [...addChild(flowBolsos), ...addChild(flowZapatos)]
+    )
+
+const main = async () => {
+    const adapterDB = new MockAdapter()
+    const adapterFlow = createFlow([flowPrincipal])
+    const adapterProvider = createProvider(BaileysProvider)
+    createBot({
+        flow: adapterFlow,
+        provider: adapterProvider,
+        database: adapterDB,
+    })
+}
+
+main()

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

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

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

@@ -6,7 +6,7 @@ const {
     addChild,
 } = require('@bot-whatsapp/bot')
 
-const WebWhatsappProvider = require('@bot-whatsapp/provider/web-whatsapp')
+const TwilioProvider = require('@bot-whatsapp/provider/twilio')
 const MockAdapter = require('@bot-whatsapp/database/mock')
 
 /**
@@ -71,7 +71,13 @@ const flowPrincipal = addKeyword(['hola', 'ole', 'alo'])
 const main = async () => {
     const adapterDB = new MockAdapter()
     const adapterFlow = createFlow([flowPrincipal])
-    const adapterProvider = createProvider(WebWhatsappProvider)
+
+    const adapterProvider = createProvider(TwilioProvider, {
+        accountSid: 'YOUR_ACCOUNT_SID',
+        authToken: 'YOUR_ACCOUNT_TOKEN',
+        vendorNumber: '+14155238886',
+    })
+
     createBot({
         flow: adapterFlow,
         provider: adapterProvider,

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

@@ -1,5 +1,5 @@
 {
-    "name": "bot-whatsapp-base",
+    "name": "bot-whatsapp-base-twilio-memory",
     "version": "1.0.0",
     "description": "",
     "main": "app.js",
@@ -9,7 +9,9 @@
     },
     "keywords": [],
     "dependencies": {
-        "whatsapp-web.js": "^1.18.3",
+        "body-parser": "^1.20.1",
+        "polka": "^0.5.2",
+        "twilio": "^3.83.4",
         "@bot-whatsapp/bot": "latest",
         "@bot-whatsapp/cli": "latest",
         "@bot-whatsapp/database": "latest",

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

@@ -6,7 +6,7 @@ const {
     addChild,
 } = require('@bot-whatsapp/bot')
 
-const WebWhatsappProvider = require('@bot-whatsapp/provider/web-whatsapp')
+const TwilioProvider = require('@bot-whatsapp/provider/twilio')
 const MockAdapter = require('@bot-whatsapp/database/mock')
 
 /**
@@ -71,7 +71,12 @@ const flowPrincipal = addKeyword(['hola', 'ole', 'alo'])
 const main = async () => {
     const adapterDB = new MockAdapter()
     const adapterFlow = createFlow([flowPrincipal])
-    const adapterProvider = createProvider(WebWhatsappProvider)
+    const adapterProvider = createProvider(TwilioProvider, {
+        accountSid: 'YOUR_ACCOUNT_SID',
+        authToken: 'YOUR_ACCOUNT_TOKEN',
+        vendorNumber: '+14155238886',
+    })
+
     createBot({
         flow: adapterFlow,
         provider: adapterProvider,

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

@@ -1,5 +1,5 @@
 {
-    "name": "bot-whatsapp-base",
+    "name": "bot-whatsapp-base-twilio-mongo",
     "version": "1.0.0",
     "description": "",
     "main": "app.js",
@@ -9,7 +9,9 @@
     },
     "keywords": [],
     "dependencies": {
-        "whatsapp-web.js": "^1.18.3",
+        "body-parser": "^1.20.1",
+        "polka": "^0.5.2",
+        "twilio": "^3.83.4",
         "@bot-whatsapp/bot": "latest",
         "@bot-whatsapp/cli": "latest",
         "@bot-whatsapp/database": "latest",

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

@@ -6,7 +6,7 @@ const {
     addChild,
 } = require('@bot-whatsapp/bot')
 
-const WebWhatsappProvider = require('@bot-whatsapp/provider/web-whatsapp')
+const TwilioProvider = require('@bot-whatsapp/provider/twilio')
 const MockAdapter = require('@bot-whatsapp/database/mock')
 
 /**
@@ -71,7 +71,11 @@ const flowPrincipal = addKeyword(['hola', 'ole', 'alo'])
 const main = async () => {
     const adapterDB = new MockAdapter()
     const adapterFlow = createFlow([flowPrincipal])
-    const adapterProvider = createProvider(WebWhatsappProvider)
+    const adapterProvider = createProvider(TwilioProvider, {
+        accountSid: 'YOUR_ACCOUNT_SID',
+        authToken: 'YOUR_ACCOUNT_TOKEN',
+        vendorNumber: '+14155238886',
+    })
     createBot({
         flow: adapterFlow,
         provider: adapterProvider,

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

@@ -1,5 +1,5 @@
 {
-    "name": "bot-whatsapp-base",
+    "name": "bot-whatsapp-base-twilio-mysql",
     "version": "1.0.0",
     "description": "",
     "main": "app.js",
@@ -9,7 +9,9 @@
     },
     "keywords": [],
     "dependencies": {
-        "whatsapp-web.js": "^1.18.3",
+        "body-parser": "^1.20.1",
+        "polka": "^0.5.2",
+        "twilio": "^3.83.4",
         "@bot-whatsapp/bot": "latest",
         "@bot-whatsapp/cli": "latest",
         "@bot-whatsapp/database": "latest",

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 VenomProvider = 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(VenomProvider)
+
+    createBot({
+        flow: adapterFlow,
+        provider: adapterProvider,
+        database: adapterDB,
+    })
+}
+
+main()

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

@@ -0,0 +1,20 @@
+{
+    "name": "bot-whatsapp-base-venom-memory",
+    "version": "1.0.0",
+    "description": "",
+    "main": "app.js",
+    "scripts": {
+        "pre-copy": "cd .. && yarn run copy.lib base-venom-memory",
+        "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 VenomProvider = 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(VenomProvider)
+
+    createBot({
+        flow: adapterFlow,
+        provider: adapterProvider,
+        database: adapterDB,
+    })
+}
+
+main()

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

@@ -0,0 +1,20 @@
+{
+    "name": "bot-whatsapp-base-venom-mongo",
+    "version": "1.0.0",
+    "description": "",
+    "main": "app.js",
+    "scripts": {
+        "pre-copy": "cd .. && yarn run copy.lib base-venom-mongo",
+        "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 VenomProvider = 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(VenomProvider)
+
+    createBot({
+        flow: adapterFlow,
+        provider: adapterProvider,
+        database: adapterDB,
+    })
+}
+
+main()

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

@@ -0,0 +1,20 @@
+{
+    "name": "bot-whatsapp-base-venom-mysql",
+    "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-wweb-memory/package.json

@@ -1,5 +1,5 @@
 {
-    "name": "bot-whatsapp-base",
+    "name": "bot-whatsapp-base-wweb-memory",
     "version": "1.0.0",
     "description": "",
     "main": "app.js",

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

@@ -1,5 +1,5 @@
 {
-    "name": "bot-whatsapp-base",
+    "name": "bot-whatsapp-base-wweb-mongo",
     "version": "1.0.0",
     "description": "",
     "main": "app.js",

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

@@ -1,5 +1,5 @@
 {
-    "name": "bot-whatsapp-base",
+    "name": "bot-whatsapp-base-wweb-mysql",
     "version": "1.0.0",
     "description": "",
     "main": "app.js",