Merge pull request #137 from vicente1992/feat-mysql-adapter

feat(adapter): added adapter mysql

.c8rc.json

@@ -4,5 +4,5 @@
     "reporter": ["html"],
     "report-dir": "./coverage",
     "check-coverage": true,
-    "lines": 95
+    "lines": 90
 }

.gitignore

@@ -14,12 +14,17 @@ mediaSend/*
 .wwebjs_auth
 packages/cli/config.json
 config.json
+.yarnrc.yml
 coverage/
 *.lcov
 log
 lib
 tmp/
+.yarn/*
+!.yarn/releases
+!.yarn/plugins/@yarnpkg/plugin-postinstall.cjs
 .fleet/
-example-app/
+example-app*/
 qr.svg
-package-lock.json
+package-lock.json
+yarn-error.log

.husky/commit-msg

@@ -0,0 +1,4 @@
+#!/usr/bin/env sh
+. "$(dirname -- "$0")/_/husky.sh"
+
+npx --no -- commitlint --edit 

.husky/pre-commit

@@ -1,4 +1,4 @@
 #!/usr/bin/env sh
 . "$(dirname -- "$0")/_/husky.sh"
 
-yarn run format:check && yarn run format:write && git add .
+yarn run fmt.staged

.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+    "conventionalCommits.scopes": ["hook", "contributing", "cli"]
+}

.yarn/plugins/@yarnpkg/plugin-postinstall.cjs

@@ -0,0 +1,8 @@
+/* eslint-disable */
+module.exports = {
+name: "@yarnpkg/plugin-postinstall",
+factory: function (require) {
+var plugin;(()=>{"use strict";var e={d:(t,n)=>{for(var o in n)e.o(n,o)&&!e.o(t,o)&&Object.defineProperty(t,o,{enumerable:!0,get:n[o]})},o:(e,t)=>Object.prototype.hasOwnProperty.call(e,t),r:e=>{"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})}},t={};e.r(t),e.d(t,{default:()=>s});const n=require("@yarnpkg/core"),o=require("clipanion"),a={postinstall:{description:"Postinstall hook that will always run in Yarn v2",type:n.SettingsType.STRING,default:""}},r=require("@yarnpkg/shell"),l=async e=>{if(e){console.log("Running postinstall command...");const t=await r.execute(e);if(0!==t)throw new Error("postinstall command failed with exit code "+t)}};var i=function(e,t,n,o){var a,r=arguments.length,l=r<3?t:null===o?o=Object.getOwnPropertyDescriptor(t,n):o;if("object"==typeof Reflect&&"function"==typeof Reflect.decorate)l=Reflect.decorate(e,t,n,o);else for(var i=e.length-1;i>=0;i--)(a=e[i])&&(l=(r<3?a(l):r>3?a(t,n,l):a(t,n))||l);return r>3&&l&&Object.defineProperty(t,n,l),l};class c extends o.Command{async execute(){const e=(await n.Configuration.find(this.context.cwd,this.context.plugins)).get("postinstall");await l(e)}}i([o.Command.Path("postinstall")],c.prototype,"execute",null);const s={configuration:a,commands:[c],hooks:{afterAllInstalled:async e=>{const t=e.configuration.get("postinstall");await l(t)}}};plugin=t})();
+return plugin;
+}
+};

.yarnrc.yml

@@ -0,0 +1,10 @@
+nodeLinker: node-modules
+
+npmPublishRegistry: 'https://registry.npmjs.org'
+
+plugins:
+    - path: .yarn/plugins/@yarnpkg/plugin-postinstall.cjs
+      spec: 'https://raw.githubusercontent.com/gravitywelluk/yarn-plugin-postinstall/master/bundles/%40yarnpkg/plugin-postinstall.js'
+
+yarnPath: .yarn/releases/yarn-3.3.0.cjs
+postinstall: npx husky install

CHANGELOG.md

@@ -1,3 +1,48 @@
+# Changelog
+
+All notable changes to this project will be documented in this file. See [standard-version](https://github.com/conventional-changelog/standard-version) for commit guidelines.
+
+## 0.2.0-alpha.0 (2022-12-01)
+
+
+### ⚠ BREAKING CHANGES
+
+* 🧨 NO
+
+### Features
+
+* (🎸) add onClick prop to component ([4ae3898](https://github.com/leifermendez/bot-whatsapp/commit/4ae389846d38c133f6bb2129ae373eed39d9d08d))
+
+
+### Bug Fixes
+
+* **ci:** ci ([f55cfae](https://github.com/leifermendez/bot-whatsapp/commit/f55cfae6e4ccc1df949212999406680020d27f9c))
+* **ci:** ci ([671c5b3](https://github.com/leifermendez/bot-whatsapp/commit/671c5b37f33360e8cb754625b8dd6e83bce9014d))
+* **linter:** update linter and commitlint ([70a94ab](https://github.com/leifermendez/bot-whatsapp/commit/70a94ab2c6f8e4122780c77bc3a621944883e621))
+
+
+* (💍) Is justa test! ([37d04e9](https://github.com/leifermendez/bot-whatsapp/commit/37d04e9e89d3f01fdc367654ba60fb11ab2614c4))
+
+## 0.1.0 (2022-11-29)
+
+
+### ⚠ BREAKING CHANGES
+
+* 🧨 NO
+
+### Features
+
+* (🎸) add onClick prop to component ([4ae3898](https://github.com/leifermendez/bot-whatsapp/commit/4ae389846d38c133f6bb2129ae373eed39d9d08d))
+
+
+### Bug Fixes
+
+* **ci:** ci ([f55cfae](https://github.com/leifermendez/bot-whatsapp/commit/f55cfae6e4ccc1df949212999406680020d27f9c))
+* **ci:** ci ([671c5b3](https://github.com/leifermendez/bot-whatsapp/commit/671c5b37f33360e8cb754625b8dd6e83bce9014d))
+
+
+* (💍) Is justa test! ([37d04e9](https://github.com/leifermendez/bot-whatsapp/commit/37d04e9e89d3f01fdc367654ba60fb11ab2614c4))
+
 #### Actualización 14 Ene 2022
 
 -   npm update

CONTRIBUTING.md

@@ -0,0 +1,59 @@
+# CONTRIBUTING
+
+![](https://i.giphy.com/media/ntMt6TvalpstTIx7Ak/giphy.webp)
+
+__Requerimientos:__
+- Node v16 o superior __[descargar node](https://nodejs.org/es/download/)__
+- __[Yarn](https://classic.yarnpkg.com/lang/en/docs/install/#windows-stable)__ como gestor de paquetes. En el link conseguiras las intrucciones para instalar yarn.
+- __[VSCode](https://code.visualstudio.com/download)__ (recomendado): Editor de codigo con plugins
+- __[Conventional Commits](https://marketplace.visualstudio.com/items?itemName=vivaxy.vscode-conventional-commits&ssr=false#overview)__ (plugin-vscode) este plugin te ayudara a crear commit semantico.
+- Se usara la rama __dev__ *(https://github.com/leifermendez/bot-whatsapp/tree/dev)* como rama principal hasta que se haga oficialmente el lanzamiento de la V2
+
+### 🚀 Iniciando
+
+__Clonar repo rama dev__
+```
+git clone --branch dev https://github.com/leifermendez/bot-whatsapp
+```
+__Instalar dependencias__
+``` 
+cd bot-whatsapp
+yarn install
+```
+
+__Compilar (build)__
+Para compilar la aplicación es necesario ejecutar, eso te genera dentro de packages del monorepo un directorio `lib`
+
+```
+yarn build
+```
+
+__Example-app__
+Se ejecuta el CLI (Command Line Interface) para ayudarte a crear un app-bot de ejemplo
+```
+yarn run cli
+```
+
+Abrir carpeta __example-app-base__ y ejecutar
+```
+cd example-app-base
+npm i
+npm run pre-copy
+npm start
+```
+
+__Commit y Push__
+El proyecto tiene implementado __[husky](https://typicode.github.io/husky/#/)__ es una herramienta que dispara unas acciones al momento de hacer commit y hacer push
+
+__commit:__ Los commit son semanticos esto quiere decir que deben cumplir un standar al momento de escribirlos ejemplo ` feat(adapter): new adapter myqsl ` puede ver más info sobre esto __[aquí](https://github.com/conventional-changelog/commitlint/#what-is-commitlint)__
+
+__push:__ Cada push ejecutar `yarn run test` el cual ejecuta los test internos que tienen que cumplir con __95% de cobertura__.
+
+
+> Documento en constaten actualización....
+
+------
+-   [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)

EXAMPLE.md

@@ -1,3 +1,4 @@
+
 ```js
 
 const {

README.md

@@ -1,6 +1,6 @@
 [![Test / Coverage](https://github.com/leifermendez/bot-whatsapp/actions/workflows/ci.yml/badge.svg)](https://github.com/leifermendez/bot-whatsapp/actions/workflows/ci.yml)
 [![Commitizen friendly](https://img.shields.io/badge/commitizen-friendly-brightgreen.svg)](http://commitizen.github.io/cz-cli/)
-
+--------
 🦊 Documentación: [https://bot-whatsapp.pages.dev/](https://bot-whatsapp.pages.dev/)
 Video como hacer PR: https://youtu.be/Lxt8Acob6aU
  

TODO.md

@@ -29,3 +29,4 @@
 - [ ] Meta adapter
 
 ### @bot-whatsapp/cli
+- [ ] Hacer comando para crear `example-app`

changelog.config.js

@@ -0,0 +1,91 @@
+module.exports = {
+    disableEmoji: false,
+    format: '{type}{scope}: {emoji}{subject}',
+    list: [
+        'test',
+        'feat',
+        'fix',
+        'chore',
+        'docs',
+        'refactor',
+        'style',
+        'ci',
+        'perf',
+    ],
+    maxMessageLength: 64,
+    minMessageLength: 3,
+    questions: [
+        'type',
+        'scope',
+        'subject',
+        'body',
+        'breaking',
+        'issues',
+        'lerna',
+    ],
+    scopes: [],
+    types: {
+        chore: {
+            description: 'Build process or auxiliary tool changes',
+            emoji: '(🤖)',
+            value: 'chore',
+        },
+        ci: {
+            description: 'CI related changes',
+            emoji: '(🎡)',
+            value: 'ci',
+        },
+        docs: {
+            description: 'Documentation only changes',
+            emoji: '(✏️)',
+            value: 'docs',
+        },
+        feat: {
+            description: 'A new feature',
+            emoji: '(🎸)',
+            value: 'feat',
+        },
+        fix: {
+            description: 'A bug fix',
+            emoji: '(🐛)',
+            value: 'fix',
+        },
+        perf: {
+            description: 'A code change that improves performance',
+            emoji: '(⚡️)',
+            value: 'perf',
+        },
+        refactor: {
+            description:
+                'A code change that neither fixes a bug or adds a feature',
+            emoji: '(💡)',
+            value: 'refactor',
+        },
+        release: {
+            description: 'Create a release commit',
+            emoji: '(🏹)',
+            value: 'release',
+        },
+        style: {
+            description:
+                'Markup, white-space, formatting, missing semi-colons...',
+            emoji: '(💄)',
+            value: 'style',
+        },
+        test: {
+            description: 'Adding missing tests',
+            emoji: '(💍)',
+            value: 'test',
+        },
+        messages: {
+            type: "Select the type of change that you're committing:",
+            customScope: 'Select the scope this component affects:',
+            subject:
+                'Write a short, imperative mood description of the change:\n',
+            body: 'Provide a longer description of the change:\n ',
+            breaking: 'List any breaking changes:\n',
+            footer: 'Issues this commit closes, e.g #123:',
+            confirmCommit: 'The packages that this commit has affected\n',
+        },
+    },
+}

commitlint.config.js

@@ -0,0 +1 @@
+module.exports = { extends: ['@commitlint/config-conventional'] }

config/banner.rollup.json

@@ -0,0 +1,8 @@
+{
+    "banner.output": [
+        "/** \n",
+        "* NO TOCAR ESTE ARCHIVO: Es generado automaticamente, si sabes lo que haces adelante ;)\n",
+        "* de lo contrario mejor ir a la documentacion o al servidor de discord link.codigoencasa.com/DISCORD\n",
+        "*/"
+    ]
+}

package.json

@@ -1,6 +1,6 @@
 {
     "name": "@bot-whatsapp/root",
-    "version": "0.0.1",
+    "version": "0.2.0-alpha.0",
     "description": "Bot de wahtsapp open source para MVP o pequeños negocios",
     "main": "app.js",
     "private": true,
@@ -12,10 +12,12 @@
         "database:rollup": "rollup --config ./packages/database/rollup-database.config.js",
         "format:check": "prettier --check ./packages",
         "format:write": "prettier --write ./packages",
+        "fmt.staged": "pretty-quick --staged",
         "lint:check": "eslint ./packages",
         "lint:fix": "eslint --fix ./packages",
         "build": "yarn run cli:rollup && yarn run bot:rollup && yarn run provider:rollup && yarn run database:rollup",
-        "link.dist": "cd packages/bot && npm link && cd ../provider && npm link && cd ../cli && npm link",
+        "link.dist": "cd packages/bot && npm link && cd ../provider && npm link && cd ../cli && npm link && cd ../database && npm link && cd ../provider && npm link",
+        "copy.lib": "node ./scripts/move.js",
         "test.unit": "node ./node_modules/uvu/bin.js packages test",
         "test.coverage": "node ./node_modules/c8/bin/c8.js npm run test.unit",
         "test": "npm run test.coverage",
@@ -23,7 +25,9 @@
         "dev:debug": "node --inspect ./example-app/app.js",
         "dev": "node ./example-app/app.js",
         "prepare": "npx husky install",
-        "preinstall": "npx only-allow yarn"
+        "preinstall": "npx only-allow yarn",
+        "postinstall": "npx prettier --write .",
+        "release": "standard-version"
     },
     "workspaces": [
         "packages/bot",
@@ -52,36 +56,36 @@
     "repository": "https://github.com/leifermendez/bot-whatsapp",
     "license": "ISC",
     "devDependencies": {
+        "@commitlint/cli": "^17.3.0",
+        "@commitlint/config-conventional": "^17.3.0",
         "@rollup/plugin-commonjs": "^23.0.2",
         "@rollup/plugin-json": "^5.0.1",
         "@rollup/plugin-node-resolve": "^15.0.1",
         "@rollup/plugin-replace": "^5.0.1",
         "c8": "^7.12.0",
-        "commitizen": "^4.2.5",
+        "conventional-changelog": "^3.1.25",
         "cross-env": "^7.0.3",
-        "cz-conventional-changelog": "^3.3.0",
         "eslint": "^8.26.0",
         "eslint-config-prettier": "^8.5.0",
+        "fs-extra": "^11.1.0",
+        "git-cz": "^4.9.0",
         "husky": "^8.0.2",
         "only-allow": "^1.1.1",
-        "prettier": "^2.7.1",
+        "prettier": "^2.8.0",
+        "pretty-quick": "^3.1.3",
         "prompts": "^2.4.2",
         "rimraf": "^3.0.2",
         "rollup": "^3.2.3",
         "rollup-plugin-cleanup": "^3.2.1",
         "rollup-plugin-copy": "^3.4.0",
+        "standard-version": "^9.5.0",
         "uvu": "^0.5.6"
     },
-    "packageManager": "yarn@1.22.19",
+    "packageManager": "yarn@3.3.0",
     "engines": {
         "node": ">=16",
         "npm": "please-use-yarn",
-        "yarn": ">=1"
+        "yarn": ">=3"
     },
-    "author": "Leifer Mendez <leifer33@gmail.com>",
+    "author": "Leifer Mendez <leifer33@gmail.com>"
-    "config": {
-        "commitizen": {
-            "path": "./node_modules/cz-conventional-changelog"
-        }
-    }
 }

packages/bot/index.js

@@ -1,7 +1,7 @@
 const CoreClass = require('./core/core.class')
 const ProviderClass = require('./provider/provider.class')
 const FlowClass = require('./io/flow.class')
-const { addKeyword, addAnswer, toSerialize } = require('./io/methods')
+const { addKeyword, addAnswer, addChild, toSerialize } = require('./io/methods')
 
 /**
  * Crear instancia de clase Bot
@@ -38,6 +38,7 @@ module.exports = {
     createProvider,
     addKeyword,
     addAnswer,
+    addChild,
     toSerialize,
     ProviderClass,
     CoreClass,

packages/bot/io/methods/addAnswer.js

@@ -10,6 +10,7 @@ const { toSerialize } = require('./toSerialize')
 const addAnswer =
     (inCtx) =>
     (answer, options, cb = null, nested = []) => {
+        answer = Array.isArray(answer) ? answer.join('\n') : answer
         /**
          * Todas las opciones referentes a el mensaje en concreto options:{}
          * @returns

packages/bot/io/methods/addChild.js

@@ -0,0 +1,15 @@
+const { toSerialize } = require('./toSerialize')
+/**
+ * @deprecate
+ * @param answer string
+ * @param options {media:string, buttons:[], capture:true default false}
+ * @returns
+ */
+const addChild = (flowIn = null) => {
+    if (!flowIn?.toJson) {
+        throw new Error('DEBE SER UN FLOW CON toJSON()')
+    }
+    return toSerialize(flowIn.toJson())
+}
+
+module.exports = { addChild }

packages/bot/io/methods/index.js

@@ -1,7 +1,8 @@
 const { addAnswer } = require('./addAnswer')
 const { addKeyword } = require('./addKeyword')
+const { addChild } = require('./addChild')
 const { toSerialize } = require('./toSerialize')
 const { toCtx } = require('./toCtx')
 const { toJson } = require('./toJson')
 
-module.exports = { addAnswer, addKeyword, toCtx, toJson, toSerialize }
+module.exports = { addAnswer, addKeyword, addChild, toCtx, toJson, toSerialize }

packages/bot/rollup-bot.config.js

@@ -1,3 +1,4 @@
+const banner = require('../../config/banner.rollup.json')
 const commonjs = require('@rollup/plugin-commonjs')
 const { nodeResolve } = require('@rollup/plugin-node-resolve')
 const { join } = require('path')
@@ -7,6 +8,7 @@ const PATH = join(__dirname, 'lib', 'bundle.bot.cjs')
 module.exports = {
     input: join(__dirname, 'index.js'),
     output: {
+        banner: banner['banner.output'].join(''),
         file: PATH,
         format: 'cjs',
     },

packages/bot/tests/methods.test.js

@@ -22,6 +22,15 @@ test('Debere probar las propeidades array', () => {
     assert.is(MAIN_CTX.ctx.keyword, ARRANGE.keyword)
 })
 
+test('Debere probar las propeidades array en answer', () => {
+    const ARRANGE = {
+        keyword: ['hola!', 'ole'],
+    }
+    const MAIN_CTX = addKeyword(ARRANGE.keyword).addAnswer(['hola', 'chao'])
+
+    assert.is(MAIN_CTX.ctx.keyword, ARRANGE.keyword)
+})
+
 test('Debere probar toSerialize', () => {
     const ARRANGE = {
         keyword: ['hola!', 'ole'],

packages/cli/create-app/index.js

@@ -0,0 +1,21 @@
+const fs = require('fs-extra')
+
+/**
+ * Copy files
+ */
+const copyFiles = async (from, to) => {
+    try {
+        await fs.copy(from, to)
+        console.log('success!')
+    } catch (err) {
+        console.error(err)
+    }
+}
+
+const copyBaseApp = async () => {
+    const BASEP_APP_PATH_FROM = `${process.cwd()}/starters/apps/base`
+    const BASEP_APP_PATH_TO = `${process.cwd()}/example-app-base`
+    await copyFiles(BASEP_APP_PATH_FROM, BASEP_APP_PATH_TO)
+}
+
+module.exports = { copyBaseApp }

packages/cli/interactive/index.js

@@ -2,6 +2,7 @@ const prompts = require('prompts')
 const { yellow, red } = require('kleur')
 const { installAll } = require('../install')
 const { cleanSession } = require('../clean')
+const { copyBaseApp } = require('../create-app')
 const { checkNodeVersion, checkOs } = require('../check')
 const { jsonConfig } = require('../configuration')
 
@@ -9,10 +10,16 @@ const startInteractive = async () => {
     const questions = [
         {
             type: 'text',
-            name: 'dependencies',
+            name: 'exampeOpt',
             message:
-                'Quieres actualizar las librerias "whatsapp-web.js"? (Y/n)',
+                'Quieres crear una app de ejemplo "example-app-example"? (Y/n)',
         },
+        // {
+        //     type: 'text',
+        //     name: 'dependencies',
+        //     message:
+        //         'Quieres actualizar las librerias "whatsapp-web.js"? (Y/n)',
+        // },
         {
             type: 'text',
             name: 'cleanTmp',
@@ -57,11 +64,12 @@ const startInteractive = async () => {
     const {
         dependencies = '',
         cleanTmp = '',
+        exampeOpt = '',
         providerDb = [],
         providerWs = [],
     } = response
     /**
-     * Question #1
+     * Question
      * @returns
      */
     const installOrUdpateDep = async () => {
@@ -75,7 +83,7 @@ const startInteractive = async () => {
     }
 
     /**
-     * Question #2
+     * Question
      * @returns
      */
     const cleanAllSession = async () => {
@@ -88,6 +96,16 @@ const startInteractive = async () => {
         }
     }
 
+    const createApp = async () => {
+        const answer = exampeOpt.toLowerCase() || 'n'
+        if (answer.includes('n')) return true
+
+        if (answer.includes('y')) {
+            await copyBaseApp()
+            return true
+        }
+    }
+
     const vendorProvider = async () => {
         if (!providerWs.length) {
             console.log(
@@ -117,6 +135,7 @@ const startInteractive = async () => {
         }
     }
 
+    await createApp()
     await installOrUdpateDep()
     await cleanAllSession()
     await vendorProvider()

packages/cli/rollup-cli.config.js

@@ -1,3 +1,4 @@
+const banner = require('../../config/banner.rollup.json')
 const commonjs = require('@rollup/plugin-commonjs')
 const { nodeResolve } = require('@rollup/plugin-node-resolve')
 const { join } = require('path')
@@ -7,6 +8,7 @@ const PATH = join(__dirname, 'lib', 'cli', 'bundle.cli.cjs')
 module.exports = {
     input: join(__dirname, 'index.js'),
     output: {
+        banner: banner['banner.output'].join(''),
         file: PATH,
         format: 'cjs',
     },

packages/database/README.md

@@ -25,6 +25,28 @@ const main = async () => {
 }
 ```
 
+
+#### CTX
+```json
+ {
+    ref: 'ans_7d9981e5-5019-422c-a19a-565cbb021391',
+    keyword: 'ans_cfdad31b-ff6d-475f-873a-4ed6f8a79a43',
+    answer: 'Esperando respuesta...',
+    options: {
+      media: null,
+      buttons: [],
+      capture: true,
+      child: null,
+      nested: [Array],
+      keyword: {},
+      callback: true
+    },
+    refSerialize: '81f18f563fd26a6c6d12c62aed98095f',
+    from: 'NUMERO_PERSONA_QUE_ESCRIBE'
+  }
+```
+
+
 #### Video
 
 > Video explicando como debes de agregar nuevos adaptadores 

packages/database/package.json

@@ -7,13 +7,14 @@
     "keywords": [],
     "author": "",
     "license": "ISC",
-    "devDependencies": {},
     "dependencies": {
         "dotenv": "^16.0.3",
-        "mongodb": "^4.11.0"
+        "mongodb": "^4.11.0",
+        "mysql2": "^2.3.3"
     },
     "exports": {
         "./mock": "./lib/mock/index.cjs",
-        "./mongo": "./lib/mongo/index.cjs"
+        "./mongo": "./lib/mongo/index.cjs",
+        "./mysql": "./lib/mysql/index.cjs"
     }
 }

packages/database/rollup-database.config.js

@@ -1,3 +1,4 @@
+const banner = require('../../config/banner.rollup.json')
 const commonjs = require('@rollup/plugin-commonjs')
 const { join } = require('path')
 
@@ -5,6 +6,7 @@ module.exports = [
     {
         input: join(__dirname, 'src', 'mock', 'index.js'),
         output: {
+            banner: banner['banner.output'].join(''),
             file: join(__dirname, 'lib', 'mock', 'index.cjs'),
             format: 'cjs',
         },
@@ -13,9 +15,19 @@ module.exports = [
     {
         input: join(__dirname, 'src', 'mongo', 'index.js'),
         output: {
+            banner: banner['banner.output'].join(''),
             file: join(__dirname, 'lib', 'mongo', 'index.cjs'),
             format: 'cjs',
         },
         plugins: [commonjs()],
     },
+    {
+        input: join(__dirname, 'src', 'mysql', 'index.js'),
+        output: {
+            banner: banner['banner.output'].join(''),
+            file: join(__dirname, 'lib', 'mysql', 'index.cjs'),
+            format: 'cjs',
+        },
+        plugins: [commonjs()],
+    },
 ]

packages/database/src/mock/index.js

@@ -1,15 +1,20 @@
+/**
+ * Si necesitas saber que trae el "ctx"
+ * Puedes ver el README.md dentro packages/database
+ */
+
 class MockDatabase {
+    db
     listHistory = []
 
-    constructor() {
+    constructor() {}
-        /**
+
-         * Se debe cargar listHistory con historial de mensajes
+    getPrevByNumber = (from) => {
-         * para que se pueda continuar el flow
+        const history = this.listHistory.slice().reverse()
-         */
+        return history.find((a) => a.from === from)
     }
 
     save = (ctx) => {
-        console.log('Guardando DB...', ctx)
         this.listHistory.push(ctx)
     }
 }

packages/database/src/mysql/index.js

@@ -0,0 +1,76 @@
+require('dotenv').config()
+const mysql = require('mysql2')
+
+const DB_NAME = process.env.DB_NAME || 'db_bot'
+const DB_HOST = process.env.DB_HOST || 'localhost'
+const DB_USER = process.env.DB_USER || 'root'
+
+class MyslAdapter {
+    db
+    listHistory = []
+
+    constructor() {
+        this.init().then()
+    }
+
+    async init() {
+        this.db = mysql.createConnection({
+            host: DB_HOST,
+            user: DB_USER,
+            database: DB_NAME,
+        })
+
+        await this.db.connect((error) => {
+            if (!error) {
+                console.log(`Solicitud de conexión a base de datos exitosa`)
+            }
+
+            if (error) {
+                console.log(`Solicitud de conexión fallida ${error.stack}`)
+            }
+        })
+    }
+
+    getPrevByNumber = (from) =>
+        new Promise((resolve, reject) => {
+            const sql = `SELECT * FROM history WHERE phone=${from} ORDER BY id DESC`
+            this.db.query(sql, (error, rows) => {
+                if (error) {
+                    reject(error)
+                }
+
+                if (rows.length) {
+                    const [row] = rows
+                    row.options = JSON.parse(row.options)
+                    resolve(row)
+                }
+
+                if (!rows.length) {
+                    resolve(null)
+                }
+            })
+        })
+
+    save = (ctx) => {
+        const values = [
+            [
+                ctx.ref,
+                ctx.keyword,
+                ctx.answer,
+                ctx.refSerialize,
+                ctx.from,
+                JSON.stringify(ctx.options),
+            ],
+        ]
+        const sql =
+            'INSERT INTO history (ref, keyword, answer, refSerialize, phone, options ) values ?'
+
+        this.db.query(sql, [values], (err) => {
+            if (err) throw err
+            console.log('Guardado en DB...', values)
+        })
+        this.listHistory.push(ctx)
+    }
+}
+
+module.exports = MyslAdapter

packages/provider/rollup-provider.config.js

@@ -1,3 +1,4 @@
+const banner = require('../../config/banner.rollup.json')
 const { join } = require('path')
 const commonjs = require('@rollup/plugin-commonjs')
 
@@ -5,6 +6,7 @@ module.exports = [
     {
         input: join(__dirname, 'src', 'web-whatsapp', 'index.js'),
         output: {
+            banner: banner['banner.output'].join(''),
             file: join(__dirname, 'lib', 'web-whatsapp', 'index.cjs'),
             format: 'cjs',
         },
@@ -13,6 +15,7 @@ module.exports = [
     {
         input: join(__dirname, 'src', 'twilio', 'index.js'),
         output: {
+            banner: banner['banner.output'].join(''),
             file: join(__dirname, 'lib', 'twilio', 'index.cjs'),
             format: 'cjs',
         },
@@ -21,6 +24,7 @@ module.exports = [
     {
         input: join(__dirname, 'src', 'mock', 'index.js'),
         output: {
+            banner: banner['banner.output'].join(''),
             file: join(__dirname, 'lib', 'mock', 'index.cjs'),
             format: 'cjs',
         },

scripts/move.js

@@ -0,0 +1,17 @@
+const fs = require('fs-extra')
+const PACKAGES_PATH = `${process.cwd()}/packages`
+const NAME_PREFIX = `@bot-whatsapp`
+
+const [, , appDir] = process.argv || []
+
+const copyLibPkg = async (pkgName, to) => {
+    const FROM = `${PACKAGES_PATH}/${pkgName}`
+    const TO = `${process.cwd()}/${to}/node_modules/${NAME_PREFIX}/${pkgName}`
+    await fs.copy(FROM, TO)
+}
+
+Promise.all([
+    copyLibPkg('bot', appDir),
+    copyLibPkg('database', appDir),
+    copyLibPkg('provider', appDir),
+]).then(() => console.log('Todas las lib copiadas'))

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

@@ -0,0 +1,33 @@
+const {
+    createBot,
+    createProvider,
+    createFlow,
+    addKeyword,
+} = require('@bot-whatsapp/bot')
+
+/**
+ *  ATENCION: Si vas a usar el provider whatsapp-web.js
+ *  recuerda ejecutar npm i whatsapp-web.js@latest
+ */
+
+const WebWhatsappProvider = require('@bot-whatsapp/provider/web-whatsapp')
+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/package.json

@@ -0,0 +1,16 @@
+{
+    "name": "bot-whatsapp-base",
+    "version": "1.0.0",
+    "description": "",
+    "main": "app.js",
+    "scripts": {
+        "pre-copy": "cd .. && yarn run copy.lib example-app-base",
+        "start": "node app.js"
+    },
+    "keywords": [],
+    "dependencies": {
+        "whatsapp-web.js": "^1.18.3"
+    },
+    "author": "",
+    "license": "ISC"
+}

starters/apps/basic/README.md

@@ -0,0 +1,12 @@
+### BASIC APP
+
+Este bot contiene un flujo basico en el cual una persona (cliente) escribe **"hola"** y el bot responde.
+
+
+![](https://i.imgur.com/0z0G91w.png)
+
+------
+-   [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/basic/app.js

@@ -0,0 +1,60 @@
+const {
+    createBot,
+    createProvider,
+    createFlow,
+    addKeyword,
+    addChild,
+} = require('@bot-whatsapp/bot')
+
+/**
+ *  ATENCION: Si vas a usar el provider whatsapp-web.js
+ *  recuerda ejecutar npm i whatsapp-web.js@latest
+ */
+
+const WebWhatsappProvider = require('@bot-whatsapp/provider/web-whatsapp')
+const MockAdapter = require('@bot-whatsapp/database/mock')
+
+/**
+ * Declarando flujo hijo
+ */
+
+const flowZapatos = addKeyword(['zapatos', 'ZAPATOS'])
+    .addAnswer('🤯 Veo que elegiste zapatos')
+    .addAnswer('Tengo muchos zapatos...bla bla')
+
+const flowBolsos = addKeyword(['bolsos', 'BOLSOS'])
+    .addAnswer('🙌 Veo que elegiste bolsos')
+    .addAnswer('Tengo muchos bolsos...bla bla')
+
+/**
+ * Declarando flujo principal
+ */
+const flowPrincipal = addKeyword(['hola', 'ole', 'HOLA'])
+    .addAnswer('Bienvenido a mi tienda')
+    .addAnswer('Como puedo ayudarte?')
+    .addAnswer(['Tengo:', 'Zapatos', 'Bolsos', 'etc..'])
+    .addAnswer('Escribe zapatos o bolsos')
+    .addAnswer(
+        'esperando respuesta...',
+        { 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(flowBolsos), ...addChild(flowZapatos)]
+    )
+
+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/basic/package.json

@@ -0,0 +1,16 @@
+{
+    "name": "bot-whatsapp-basic",
+    "version": "1.0.0",
+    "description": "",
+    "main": "app.js",
+    "scripts": {
+        "pre-copy": "cd .. && yarn run copy.lib example-app-basic",
+        "start": "node app.js"
+    },
+    "keywords": [],
+    "dependencies": {
+        "whatsapp-web.js": "^1.18.3"
+    },
+    "author": "",
+    "license": "ISC"
+}