mongo adapter:next step, continue conversation from db

docker-compose.yml

@@ -0,0 +1,25 @@
+version: '3.3'
+
+services:
+  mongo:
+    image: mongo
+    container_name: app_enviroment
+    restart: always
+    ports:
+      - "27019:27017"
+    environment:
+      MONGO_INITDB_DATABASE: bot
+    expose:
+      - 27019
+  mysql:
+    image: mysql
+    command: --default-authentication-plugin=mysql_native_password
+    restart: always
+    environment:
+      MYSQL_ROOT_PASSWORD: example
+      MYSQL_DATABASE: bot
+    container_name: app_mysql
+    ports:
+      - "3306:3306"
+    expose:
+      - 3306

package.json

@@ -8,7 +8,7 @@
         "cli:rollup": "rollup --config ./packages/cli/rollup-cli.config.js ",
         "bot:rollup": "rollup --config ./packages/bot/rollup-bot.config.js",
         "provider:rollup": "rollup --config ./packages/provider/rollup-provider.config.js ",
-        "database:rollup": "rollup ./packages/database/index.js --config ./packages/database/rollup-cli.config.js",
+        "database:rollup": "rollup --config ./packages/database/rollup-database.config.js",
         "format:check": "prettier --check ./packages",
         "format:write": "prettier --write ./packages",
         "lint:check": "eslint ./packages",

packages/bot/package.json

@@ -23,7 +23,11 @@
     "license": "ISC",
     "devDependencies": {
         "@bot-whatsapp/cli": "*",
+        "@bot-whatsapp/database": "*",
         "@bot-whatsapp/provider": "*",
         "kleur": "^4.1.5"
+    },
+    "dependencies": {
+        "dotenv": "^16.0.3"
     }
 }

packages/database/mongo/index.js

@@ -0,0 +1,37 @@
+require('dotenv').config()
+const { MongoClient } = require('mongodb')
+
+const DB_URI = process.env.DB_URI || 'mongodb://0.0.0.0:27017'
+const DB_NAME = process.env.DB_NAME || 'db_bot'
+
+class MongoAdapter {
+    db
+    listHistory = []
+
+    constructor() {
+        console.log({ DB_URI })
+        this.init().then()
+    }
+
+    init = async () => {
+        try {
+            const client = new MongoClient(DB_URI, {})
+            await client.connect()
+            console.log('Connected successfully to server')
+            const db = client.db(DB_NAME)
+            this.db = db
+            return true
+        } catch (e) {
+            console.log('Error', e)
+            return
+        }
+    }
+
+    save = async (ctx) => {
+        await this.db.collection('history').insert(ctx)
+        console.log('Guardando DB...', ctx)
+        this.listHistory.push(ctx)
+    }
+}
+
+module.exports = MongoAdapter

packages/database/package.json

@@ -2,10 +2,17 @@
     "name": "@bot-whatsapp/database",
     "version": "0.0.1",
     "description": "Esto es el conector a  mysql, pg, mongo",
-    "main": "./lib/bundle.database.cjs",
+    "main": "./lib/mock/index.cjs",
     "private": true,
     "keywords": [],
     "author": "",
     "license": "ISC",
-    "devDependencies": {}
+    "devDependencies": {},
+    "dependencies": {
+        "dotenv": "^16.0.3",
+        "mongodb": "^4.11.0"
+    },
+    "files": [
+        "./lib/*"
+    ]
 }

packages/database/rollup-cli.config.js

@@ -1,14 +0,0 @@
-const commonjs = require('@rollup/plugin-commonjs')
-const { nodeResolve } = require('@rollup/plugin-node-resolve')
-const { join } = require('path')
-
-const PATH = join(__dirname, 'lib', 'bundle.database.cjs')
-
-module.exports = {
-    input: join(__dirname, 'index.js'),
-    output: {
-        file: PATH,
-        format: 'cjs',
-    },
-    plugins: [commonjs(), nodeResolve()],
-}

packages/database/rollup-database.config.js

@@ -0,0 +1,21 @@
+const commonjs = require('@rollup/plugin-commonjs')
+const { join } = require('path')
+
+module.exports = [
+    {
+        input: join(__dirname, 'mock', 'index.js'),
+        output: {
+            file: join(__dirname, 'lib', 'mock', 'index.cjs'),
+            format: 'cjs',
+        },
+        plugins: [commonjs()],
+    },
+    {
+        input: join(__dirname, 'mongo', 'index.js'),
+        output: {
+            file: join(__dirname, 'lib', 'mongo', 'index.cjs'),
+            format: 'cjs',
+        },
+        plugins: [commonjs()],
+    },
+]