@bot-whatsapp/bot - npm Package Compare versions

Comparing version 0.0.217-alpha.0 to 0.0.218-alpha.0

core/core.class.js

@@ -177,34 +177,34 @@ const { EventEmitter } = require('node:events')
             (flag) =>
-            async (messages = null, options = { fromGotoFlow: false, end: false }) => {
-                flag.endFlow = true
-                endFlowFlag = true
+                async (messages = null, options = { fromGotoFlow: false, end: false }) => {
+                    flag.endFlow = true
+                    endFlowFlag = true
 
-                if (typeof messages === 'string' || messages === null) {
-                    await this.sendProviderAndSave(from, createCtxMessage(messages))
-                    clearQueue()
-                    return
-                }
+                    if (typeof messages === 'string' || messages === null) {
+                        await this.sendProviderAndSave(from, createCtxMessage(messages))
+                        clearQueue()
+                        return
+                    }
 
-                // Procesos de callback que se deben execute como exepciones
-                if (Array.isArray(messages)) {
-                    // console.log('options.fromGotoFlow', messages)
+                    // Procesos de callback que se deben execute como exepciones
+                    if (Array.isArray(messages)) {
+                        // console.log('options.fromGotoFlow', messages)
 
-                    // const indexLimit = messages.findIndex((m) => m.ref === inRef)
-                    for (const iteratorCtxMessage of messages) {
-                        // console.log(`Counter ${indexLimit}`)
-                        // if(indexLimit !== -1 && counterFor === indexLimit) break
-                        const scopeCtx = await resolveCbEveryCtx(iteratorCtxMessage, {
-                            omitEndFlow: options.fromGotoFlow,
-                            idleCtx: !!iteratorCtxMessage?.options?.idle,
-                            triggerKey: iteratorCtxMessage.keyword.startsWith('key_'),
-                        })
+                        // const indexLimit = messages.findIndex((m) => m.ref === inRef)
+                        for (const iteratorCtxMessage of messages) {
+                            // console.log(`Counter ${indexLimit}`)
+                            // if(indexLimit !== -1 && counterFor === indexLimit) break
+                            const scopeCtx = await resolveCbEveryCtx(iteratorCtxMessage, {
+                                omitEndFlow: options.fromGotoFlow,
+                                idleCtx: !!iteratorCtxMessage?.options?.idle,
+                                triggerKey: iteratorCtxMessage.keyword.startsWith('key_'),
+                            })
 
-                        if (scopeCtx?.endFlow) break
+                            if (scopeCtx?.endFlow) break
 
-                        // options.fromGotoFlow = false
+                            // options.fromGotoFlow = false
+                        }
                     }
+                    clearQueue()
+                    return
                 }
-                clearQueue()
-                return
-            }
 
@@ -215,3 +215,3 @@ // 📄 Esta funcion se encarga de enviar un array de mensajes dentro de este ctx
 
-            if (options.prev?.options?.capture) {
+            if (options.prev?.options?.capture && !options?.omitEndFlow) {
                 await cbEveryCtx(options.prev?.ref)
@@ -267,3 +267,3 @@ }
 
-        const continueFlow = async (initRef = undefined) => {
+        const continueFlow = async (initRef = undefined, options = {}) => {
             const currentPrev = await this.databaseClass.getPrevByNumber(from)
@@ -283,5 +283,5 @@ let nextFlow = (await this.flowClass.find(refToContinue?.ref, true)) ?? []
                 if (nextChildMessages?.length)
-                    return exportFunctionsSend(() => sendFlow(nextChildMessages, from, { prev: undefined }))
+                    return exportFunctionsSend(() => sendFlow(nextChildMessages, from, { ...options, ...{ prev: undefined } }))
 
-                return exportFunctionsSend(() => sendFlow(filterNextFlow, from, { prev: undefined }))
+                return exportFunctionsSend(() => sendFlow(filterNextFlow, from, { ...options, ...{ prev: undefined } }))
             }
@@ -292,51 +292,51 @@ }
             (flag) =>
-            async (message = null) => {
-                this.queuePrincipal.clearQueue(from)
-                flag.fallBack = true
-                await this.sendProviderAndSave(from, {
-                    ...prevMsg,
-                    answer: typeof message === 'string' ? message : message?.body ?? prevMsg.answer,
-                    options: {
-                        ...prevMsg.options,
-                        buttons: prevMsg.options?.buttons,
-                    },
-                })
-                return
-            }
+                async (message = null) => {
+                    this.queuePrincipal.clearQueue(from)
+                    flag.fallBack = true
+                    await this.sendProviderAndSave(from, {
+                        ...prevMsg,
+                        answer: typeof message === 'string' ? message : message?.body ?? prevMsg.answer,
+                        options: {
+                            ...prevMsg.options,
+                            buttons: prevMsg.options?.buttons,
+                        },
+                    })
+                    return
+                }
 
         const gotoFlow =
             (flag) =>
-            async (flowInstance, step = 0) => {
-                const promises = []
-                flag.gotoFlow = true
+                async (flowInstance, step = 0) => {
+                    const promises = []
+                    flag.gotoFlow = true
 
-                if (!flowInstance?.toJson) {
-                    printer([
-                        `[POSSIBLE_CIRCULAR_DEPENDENCY]: Se ha detectado una dependencia circular.`,
-                        `Para evitar problemas, te recomendamos utilizar 'require'('./ruta_del_flow')`,
-                        `Ejemplo:  gotoFlow(helloFlow) -->  gotoFlow(require('./flows/helloFlow.js'))`,
-                        `[INFO]: https://bot-whatsapp.netlify.app/docs/goto-flow/`,
-                    ])
-                    return
-                }
+                    if (!flowInstance?.toJson) {
+                        printer([
+                            `[POSSIBLE_CIRCULAR_DEPENDENCY]: Se ha detectado una dependencia circular.`,
+                            `Para evitar problemas, te recomendamos utilizar 'require'('./ruta_del_flow')`,
+                            `Ejemplo:  gotoFlow(helloFlow) -->  gotoFlow(require('./flows/helloFlow.js'))`,
+                            `[INFO]: https://bot-whatsapp.netlify.app/docs/goto-flow/`,
+                        ])
+                        return
+                    }
 
-                await delay(flowInstance?.ctx?.options?.delay ?? 0)
+                    await delay(flowInstance?.ctx?.options?.delay ?? 0)
 
-                const flowTree = flowInstance.toJson()
+                    const flowTree = flowInstance.toJson()
 
-                const flowParentId = flowTree[step]
+                    const flowParentId = flowTree[step]
 
-                const parseListMsg = await this.flowClass.find(flowParentId?.ref, true, flowTree)
+                    const parseListMsg = await this.flowClass.find(flowParentId?.ref, true, flowTree)
 
-                for (const msg of parseListMsg) {
-                    const msgParse = this.flowClass.findSerializeByRef(msg?.ref)
+                    for (const msg of parseListMsg) {
+                        const msgParse = this.flowClass.findSerializeByRef(msg?.ref)
 
-                    const ctxMessage = { ...msgParse, ...msg }
-                    await this.sendProviderAndSave(from, ctxMessage).then(() => promises.push(ctxMessage))
+                        const ctxMessage = { ...msgParse, ...msg }
+                        await this.sendProviderAndSave(from, ctxMessage).then(() => promises.push(ctxMessage))
+                    }
+
+                    await endFlow(flag)(promises, { fromGotoFlow: true, ...{ end: endFlowFlag } })
+                    return
                 }
 
-                await endFlow(flag)(promises, { fromGotoFlow: true, ...{ end: endFlowFlag } })
-                return
-            }
-
         // 📄 [options: flowDynamic]: esta funcion se encarga de responder un array de respuesta esta limitado a 5 mensajes
@@ -347,38 +347,38 @@ // para evitar bloque de whatsapp
             (flag, inRef, privateOptions) =>
-            async (listMsg = [], options = { continue: true }) => {
-                if (!options.hasOwnProperty('continue')) {
-                    options = { ...options, continue: true }
-                }
+                async (listMsg = [], options = { continue: true }) => {
+                    if (!options.hasOwnProperty('continue')) {
+                        options = { ...options, continue: true }
+                    }
 
-                flag.flowDynamic = true
+                    flag.flowDynamic = true
 
-                if (!Array.isArray(listMsg)) {
-                    listMsg = [{ body: listMsg, ...options }]
-                }
+                    if (!Array.isArray(listMsg)) {
+                        listMsg = [{ body: listMsg, ...options }]
+                    }
 
-                const parseListMsg = listMsg.map((opt, index) => createCtxMessage(opt, index))
+                    const parseListMsg = listMsg.map((opt, index) => createCtxMessage(opt, index))
 
-                // Si endFlowFlag existe y no se omite la finalización del flujo, no hacer nada.
-                if (endFlowFlag && !privateOptions?.omitEndFlow) {
-                    return
-                }
+                    // Si endFlowFlag existe y no se omite la finalización del flujo, no hacer nada.
+                    if (endFlowFlag && !privateOptions?.omitEndFlow) {
+                        return
+                    }
 
-                this.queuePrincipal.setFingerTime(from, inRef) // Debe decirle al sistema que finalizó el flujo aquí.
+                    this.queuePrincipal.setFingerTime(from, inRef) // Debe decirle al sistema que finalizó el flujo aquí.
 
-                for (const msg of parseListMsg) {
-                    if (privateOptions?.idleCtx) {
-                        continue // Saltar al siguiente mensaje si se está en modo idleCtx.
+                    for (const msg of parseListMsg) {
+                        if (privateOptions?.idleCtx) {
+                            continue // Saltar al siguiente mensaje si se está en modo idleCtx.
+                        }
+
+                        const delayMs = msg?.options?.delay ?? this.generalArgs.delay ?? 0
+                        await delay(delayMs)
+                        await this.sendProviderAndSave(from, msg)
                     }
 
-                    const delayMs = msg?.options?.delay ?? this.generalArgs.delay ?? 0
-                    await delay(delayMs)
-                    await this.sendProviderAndSave(from, msg)
-                }
-
-                if (options?.continue) {
-                    await continueFlow()
+                    if (options?.continue) {
+                        await continueFlow()
+                        return
+                    }
                     return
                 }
-                return
-            }
 
@@ -449,3 +449,3 @@ // 📄 Se encarga de revisar si el contexto del mensaje tiene callback o idle
                 if (continueAfterIdle) {
-                    await continueFlow(overCtx)
+                    await continueFlow(overCtx, options)
                     return
@@ -455,3 +455,3 @@ }
                 if (ifContinue) {
-                    await continueFlow()
+                    await continueFlow(undefined, options)
                     return
@@ -458,0 +458,0 @@ }

io/events/eventAction.js

@@ -0,0 +0,0 @@ const { generateRef } = require('../../utils/hash')

io/events/eventDocument.js

@@ -0,0 +0,0 @@ const { generateRef } = require('../../utils/hash')

io/events/eventLocation.js

@@ -0,0 +0,0 @@ const { generateRef } = require('../../utils/hash')

io/events/eventMedia.js

@@ -0,0 +0,0 @@ const { generateRef } = require('../../utils/hash')

io/events/eventOrder.js

@@ -0,0 +0,0 @@ const { generateRef } = require('../../utils/hash')

io/events/eventTemplate.js

@@ -0,0 +0,0 @@ const { generateRef } = require('../../utils/hash')

io/events/eventVoiceNote.js

@@ -0,0 +0,0 @@ const { generateRef } = require('../../utils/hash')

io/events/eventWelcome.js

@@ -0,0 +0,0 @@ const { generateRef } = require('../../utils/hash')

io/events/index.js

@@ -0,0 +0,0 @@ const { eventDocument, REGEX_EVENT_DOCUMENT } = require('./eventDocument')

io/methods/addAction.js

 const addAction = () => async () => {}
 
 module.exports = { addAction }

LICENSE.md

@@ -0,0 +0,0 @@ MIT License

package.json

 {
   "name": "@bot-whatsapp/bot",
-  "version": "0.0.217-alpha.0",
+  "version": "0.0.218-alpha.0",
   "description": "",
@@ -5,0 +5,0 @@ "main": "./lib/bundle.bot.cjs",

provider/provider.class.js

@@ -0,0 +0,0 @@ const { EventEmitter } = require('node:events')

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Number of low supply chain risk alerts

6

decreased by-40%

Number of medium supply chain risk alerts

2

decreased by-33.33%

Worsened metrics

Total package byte prevSize

100206

decreased by-35.15%

Number of package files

24

decreased by-4%

Lines of code

2463

decreased by-37.98%

No dependency changes