mirror of
https://github.com/cheveguerra/bot-whatsapp.git
synced 2026-04-17 19:26:23 +00:00
adapter provider
This commit is contained in:
@@ -35,11 +35,22 @@ test(`[BotClass]: recibe los mensajes entrantes del provider`, () => {
|
||||
provider: adapterProvider,
|
||||
})
|
||||
|
||||
bot.on('message', (ctx) => messages.push(ctx.body))
|
||||
bot.emit('message', { body: 'hola' })
|
||||
bot.emit('message', { body: 'otro' })
|
||||
bot.on('message', (ctx) => messages.push(ctx))
|
||||
bot.emit('message', 'hola')
|
||||
bot.emit('message', 'otro')
|
||||
|
||||
assert.is(messages.join(','), ['hola', 'otro'].join(','))
|
||||
const getHistoryFromDB = adapterDB.engineDB.listHistory
|
||||
|
||||
assert.is(messages.join(), ['hola', 'otro'].join())
|
||||
assert.is(
|
||||
getHistoryFromDB.join(),
|
||||
[
|
||||
'hola',
|
||||
'Bienvenido a tu tienda 🥲',
|
||||
'escribe *catalogo* o *ofertas*',
|
||||
'otro',
|
||||
].join()
|
||||
)
|
||||
})
|
||||
|
||||
test.run()
|
||||
|
||||
@@ -17,13 +17,14 @@ class BotClass {
|
||||
|
||||
handleOnMessage = (ctxMessage) => {
|
||||
this.databaseClass.saveLog(ctxMessage)
|
||||
this.continue(ctxMessage.body)
|
||||
this.continue(ctxMessage)
|
||||
}
|
||||
|
||||
continue = (message, ref = false) => {
|
||||
const responde = this.flowClass.find(message, ref)
|
||||
if (responde) {
|
||||
this.providerClass.sendMessage(responde.answer)
|
||||
this.databaseClass.saveLog(responde.answer)
|
||||
this.continue(null, responde.ref)
|
||||
}
|
||||
}
|
||||
|
||||
11
packages/database/adapters/mock.js
Normal file
11
packages/database/adapters/mock.js
Normal file
@@ -0,0 +1,11 @@
|
||||
class MockDatabase {
|
||||
listHistory = []
|
||||
|
||||
constructor() {}
|
||||
|
||||
save = (ctx) => {
|
||||
this.listHistory.push(ctx)
|
||||
}
|
||||
}
|
||||
|
||||
module.exports = MockDatabase
|
||||
@@ -1,7 +1,11 @@
|
||||
class DatabaseClass {
|
||||
constructor() {}
|
||||
engineDB
|
||||
constructor(_engineDB) {
|
||||
this.engineDB = _engineDB
|
||||
}
|
||||
|
||||
saveLog = (ctx) => {
|
||||
this.engineDB.save(ctx)
|
||||
return ctx
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,4 +1,12 @@
|
||||
const DatabaseClass = require('./classes/database.class')
|
||||
const MockDatabase = require('./adapters/mock')
|
||||
|
||||
const prepareEngine = ({ engine, credentials }) => {
|
||||
// if (engine === 'mysql') return new TwilioProvider(credentials)
|
||||
// if (engine === 'meta') return new TwilioProvider(credentials)
|
||||
// if (engine === 'wev') return new TwilioProvider(credentials)
|
||||
return new MockDatabase()
|
||||
}
|
||||
|
||||
/**
|
||||
* Crear instancia de clase
|
||||
@@ -6,7 +14,8 @@ const DatabaseClass = require('./classes/database.class')
|
||||
* @returns
|
||||
*/
|
||||
const create = (args) => {
|
||||
return new DatabaseClass(args)
|
||||
const engine = prepareEngine(args)
|
||||
return new DatabaseClass(engine)
|
||||
}
|
||||
|
||||
module.exports = { create }
|
||||
|
||||
Reference in New Issue
Block a user