chore: 🎨 working

This commit is contained in:
Leifer Mendez
2023-01-06 14:31:04 +01:00
parent 3a74927b9d
commit a6c10fe414

View File

@@ -18,6 +18,7 @@ class CoreClass {
flowClass flowClass
databaseClass databaseClass
providerClass providerClass
listCallbacks = []
constructor(_flow, _database, _provider) { constructor(_flow, _database, _provider) {
this.flowClass = _flow this.flowClass = _flow
this.databaseClass = _database this.databaseClass = _database
@@ -114,18 +115,24 @@ class CoreClass {
} }
// 📄 Se encarga de revisar si el contexto del mensaje tiene callback y ejecutarlo // 📄 Se encarga de revisar si el contexto del mensaje tiene callback y ejecutarlo
const cbEveryCtx = (inRef) => { const cbEveryCtx =
this.flowClass.allCallbacks[inRef](messageCtxInComming, { (inRef, _injectMessageCtx, _injectfallBack, _injectflowDynamic) =>
fallBack, () => {
flowDynamic, this.flowClass.allCallbacks[inRef](_injectMessageCtx, {
}) fallBack: _injectfallBack,
} flowDynamic: _injectflowDynamic,
})
}
// 📄 [options: callback]: Si se tiene un callback se ejecuta // 📄 [options: callback]: Si se tiene un callback se ejecuta
if (!fallBackFlag) { const callAllCb = (_msgToList = []) => {
if (refToContinue?.options?.capture) cbEveryCtx(refToContinue?.ref) for (const ite of _msgToList) {
for (const ite of this.flowClass.find(body)) { this.listCallbacks[ite?.ref] = cbEveryCtx(
if (!ite?.options?.capture) cbEveryCtx(ite?.ref) ite?.ref,
messageCtxInComming,
fallBack,
flowDynamic
)
} }
} }
@@ -138,10 +145,7 @@ class CoreClass {
msgToSend = this.flowClass.find(body, false, flowStandalone) || [] msgToSend = this.flowClass.find(body, false, flowStandalone) || []
for (const ite of msgToSend) { callAllCb(msgToSend)
cbEveryCtx(ite?.ref)
}
this.sendFlow(msgToSend, from) this.sendFlow(msgToSend, from)
return return
} }
@@ -153,12 +157,14 @@ class CoreClass {
if (['string', 'boolean'].includes(typeCapture) && valueCapture) { if (['string', 'boolean'].includes(typeCapture) && valueCapture) {
msgToSend = this.flowClass.find(refToContinue?.ref, true) || [] msgToSend = this.flowClass.find(refToContinue?.ref, true) || []
callAllCb(msgToSend)
this.sendFlow(msgToSend, from) this.sendFlow(msgToSend, from)
return return
} }
} }
msgToSend = this.flowClass.find(body) || [] msgToSend = this.flowClass.find(body) || []
callAllCb(msgToSend)
this.sendFlow(msgToSend, from) this.sendFlow(msgToSend, from)
} }
@@ -169,10 +175,19 @@ class CoreClass {
* @returns * @returns
*/ */
sendProviderAndSave = (numberOrId, ctxMessage) => { sendProviderAndSave = (numberOrId, ctxMessage) => {
const executeCb = (ref) => {
try {
return this.listCallbacks[ref]()
} catch (e) {
return Promise.resolve()
}
}
const { answer } = ctxMessage const { answer } = ctxMessage
return Promise.all([ return Promise.all([
this.providerClass.sendMessage(numberOrId, answer, ctxMessage), this.providerClass.sendMessage(numberOrId, answer, ctxMessage),
this.databaseClass.save({ ...ctxMessage, from: numberOrId }), this.databaseClass.save({ ...ctxMessage, from: numberOrId }),
executeCb(ctxMessage?.ref),
]) ])
} }