[⚡] Api para envio de mensajes

[eduardolat]

Antes que nada, muchas gracias por el buen trabajo al hacer esta biblioteca 🫶

Describe tu problema

Sería muy bueno que la función createBot retornara un objeto con funciones para poder aprovechar la abstracción de envío de mensajes y poder reutilizar las implementaciones con los distintos proveedores que la biblioteca ya de por sí ofrece.

Esto nos permitiría extender la funcionalidad de la biblioteca haciendo nuestras propias funciones sin necesidad de crear nuestras propias abstracciones sobre los proveedores, por ejemplo, podríamos tener un chatbot y un api de WhatsApp en el mismo proyecto, podríamos configurar webhooks, enviar a clientes notificaciones de su cuenta, pedidos, etc.

Es genial como bot-whatsapp puede intercambiar entre proveedores, sería genial poder combinar esa función con la propuesta

Información Adicional

Adjunto imagen con un ejemplo de como puede ser útil. No propongo agregar endpoints (¿o si?), solamente tener las funciones para poder hacerlo por cuenta propia.

[leifermendez]

@eduardolat Buenas interesante tu enfoque afortunadamente ya puedes aprovechar esas funcionalidades te dejo un ejemplo

const express = require('express')
const { createBot, createProvider, createFlow, addKeyword } = require('@bot-whatsapp/bot')

const BaileysProvider = require('@bot-whatsapp/provider/baileys')
const MockAdapter = require('@bot-whatsapp/database/mock')

const app = express()
const main = async () => {
    const adapterDB = new MockAdapter()
    const adapterFlow = createFlow([flowPrincipal])
    const adapterProvider = createProvider(BaileysProvider)

    createBot({
        flow: adapterFlow,
        provider: adapterProvider,
        database: adapterDB,
    })

    /**
     * Enviar mensaje con metodos propios del provider del bot
     */
    app.post('/send-message-bot', async (req, res) => {
        await adapterProvider.sendText('52XXXXXXXXX@c.us', 'Mensaje desde API')
        res.send({ data: 'enviado!' })
    })
    /**
     * Enviar mensajes con metodos nativos del provider
     */
    app.post('/send-message-provider', async (req, res) => {
        const id = '52XXXXXXXXX@c.us'
        const templateButtons = [
            {
                index: 1,
                urlButton: {
                    displayText: ':star: Star Baileys on GitHub!',
                    url: 'https://github.com/adiwajshing/Baileys',
                },
            },
            { index: 2, callButton: { displayText: 'Call me!', phoneNumber: '+1 (234) 5678-901' } },
            {
                index: 3,
                quickReplyButton: {
                    displayText: 'This is a reply, just like normal buttons!',
                    id: 'id-like-buttons-message',
                },
            },
        ]

        const templateMessage = {
            text: "Hi it's a template message",
            footer: 'Hello World',
            templateButtons: templateButtons,
        }

        const abc = await adapterProvider.getInstance()
        await abc.sendMessage(id, templateMessage)

        res.send({ data: 'enviado!' })
    })
    const PORT = 4000
    app.listen(PORT, () => console.log(`http://localhost:${PORT}`))
}

main()

[ramonbello]

Hola, @leifermendez como puedo validar que exista una session activa antes de enviar el mensaje, intente enviar el mensaje sin ninguna session y me sale este error

[ramonbello]

Lo solucione de esta forma:

Cree esta validación para verificar si la sesión estaba creada

async function sesionCreada() {
    try {
        const files = await readdirAsync('bot_sessions');
        return files.length !== 0;
    } catch (err) {
        console.error(err);
        return false;
    }
}

Luego la utilizo antes de llamar a la función del envió del mensaje:

app.post('/enviar-mensaje', async (req, res) => {
        const numero = req.body.numero;
        const media = req.body.url_media;
        const mensaje = req.body.mensaje;

        if (!validarCelular(numero)) {
            return res.send({
                transaccion: false,
                mensaje: 'Número de celular no válido'
            });
        }

        const existeSesion = await sesionCreada();
        if (!existeSesion) {
            return res.send({
                transaccion: false,
                mensaje: 'Sesion no creada, por favor escane el codigo qr'
            });
        }
        
        try {
            if (req.body?.hasOwnProperty('url_media')) {
                await adapterProvider.sendMedia(numero, media, mensaje);
            } else {
                await adapterProvider.sendText(numero, mensaje);
            }
            return res.send({
                transaccion: true,
                mensaje: 'enviado!'
            });

        } catch (error) {
            return res.send({
                transaccion: false,
                mensaje: 'error!'
            });
        }
    });

[eduardolat]

@leifermendez Muchas gracias por tu respuesta, tiene mucho sentido, ¿Crees que sería bueno documentarlo?, yo me puedo encargar de eso, tal vez en la sección, Avanzado > Providers API
Si me das el ok lo escribo y pongo un par de ejemplos

[asenawritescode]

@leifermendez
On deployment their is an outlying issue around port allocation for the express app.

This works on local machine but fails on deployment

[mastercodelatam]

y para el archivo principal
const main = async () => {
//const adapterDB = new MockAdapter()
const adapterFlow = DepenBot.createFlow([flowPrincipal]);
const adapterProvider = DepenBot.createProvider(BaileysProvider);

const bot = await DepenBot.createBot({
    flow: adapterFlow,
    provider: adapterProvider,
    database: adapterDB,
})
 //await bot.providerClass.sendText('593983612878@c.us', 'hola este es un mensaje automatico');
     //await bot.providerClass.sendMedia('593983612878@c.us', 'https://Electronicos/2/6436c570e9646dd4ac88e4fc');

lo he resulto de esta manera para el archivo Bundle.bot.cjs
```
// 📄 Esta funcion se encarga de enviar un array de mensajes dentro de este ctx
const sendFlow = async (messageToSend, numberOrId, options = { prev: prevMsg }) => {
if (options.prev?.options?.capture) await cbEveryCtx(options.prev?.ref);
const queue = [];
for (const ctxMessage of messageToSend) {
if (endFlowFlag) return
const delayMs = ctxMessage?.options?.delay ?? this.generalArgs.delay ?? 0;
if (delayMs) await delay(delayMs);
await QueuePrincipal.enqueue(() =>
this.sendProviderAndSave(numberOrId, ctxMessage).then(() => resolveCbEveryCtx(ctxMessage)).catch((e)=>{
console.log('Ocurrio un error al obtener el cxt')
})
);
}
return Promise.all(queue)

[mastercodelatam]

y para escuchar si el cliente esta listo utilice este

bot.providerClass.on('ready', () => {
        console.log('Bot de WhatsApp conectado y listo');
});

[colcodec]

hola
estoy tratando de responder por medio de el
flowDynamic({ body: mensaje, from: usuario2 })
pero solo me funciona para el primer mensaje q respondi, hay alguna forma de hacer uso de el sin necesidad q intervenga en un flujo, utilizarlo fuera del flujo

[colcodec]

quisiera enviar, a cualquier numero, sin imporetar si la seccion esta activa

[sotile]

me parece super interesante esto, pero si bien tengo algunos conocimientos de javascript y php no estoy familiarizado con express y node.js, de que manera podria agregar la funcionalidad de enviar mensajes con el bot a clientes que no iniciaron una conversacion? hay algun ejemplo funcional que sepueda probar con postman? gracias desde ya.

[mdestafadilah]

hola estoy tratando de responder por medio de el flowDynamic({ body: mensaje, from: usuario2 }) pero solo me funciona para el primer mensaje q respondi, hay alguna forma de hacer uso de el sin necesidad q intervenga en un flujo, utilizarlo fuera del flujo

maybe you can save the messsage to database, tthen catch by the number sender to reply again.

[mdestafadilah]

@leifermendez Muchas gracias por tu respuesta, tiene mucho sentido, ¿Crees que sería bueno documentarlo?, yo me puedo encargar de eso, tal vez en la sección, Avanzado > Providers API Si me das el ok lo escribo y pongo un par de ejemplos

any update then?

[colcodec]

hola estoy tratando de responder por medio de el flowDynamic({ body: mensaje, from: usuario2 }) pero solo me funciona para el primer mensaje q respondi, hay alguna forma de hacer uso de el sin necesidad q intervenga en un flujo, utilizarlo fuera del flujo

maybe you can save the messsage to database, tthen catch by the number sender to reply again.

I am doing the same thing, I capture it, but it does not send me to the established number