From a6c10fe414b8502c0ddfefa63c4e75d264d95346 Mon Sep 17 00:00:00 2001
From: Leifer Mendez <leifer33@gmail.com>
Date: Fri, 6 Jan 2023 14:31:04 +0100
Subject: [PATCH] chore: :art: working

---
 packages/bot/core/core.class.js | 43 ++++++++++++++++++++++-----------
 1 file changed, 29 insertions(+), 14 deletions(-)

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