Handling Media Files

import { join } from 'path'
import { addKeyword } from '@builderbot/bot'

const imageFlow = addKeyword('photo')
    .addAnswer('Here is your image:', {
        media: join(process.cwd(), 'assets', 'sample.png')
    })

const imageFlow = addKeyword('logo')
    .addAnswer('Our company logo:', {
        media: 'https://example.com/images/logo.png'
    })

const productFlow = addKeyword('product')
    .addAnswer('Which product? (1-5)', { capture: true })
    .addAction(async (ctx, { flowDynamic }) => {
        const productId = ctx.body
        const imageUrl = `https://api.example.com/products/${productId}/image.jpg`
        
        await flowDynamic([
            { body: `Product #${productId}`, media: imageUrl }
        ])
    })

const videoFlow = addKeyword('video')
    .addAnswer('Check out this video:', {
        media: 'https://media.giphy.com/media/v1.Y2lkPTc5MGI3NjExYTJ0ZGdjd2syeXAwMjQ4aWdkcW04OWlqcXI3Ynh1ODkwZ25zZWZ1dCZlcD12MV9pbnRlcm5hbF9naWZfYnlfaWQmY3Q9Zw/LCohAb657pSdHv0Q5h/giphy.mp4'
    })

import { join } from 'path'

const tutorialFlow = addKeyword('tutorial')
    .addAnswer('Tutorial video:', {
        media: join(process.cwd(), 'videos', 'tutorial.mp4')
    })

const audioFlow = addKeyword('audio')
    .addAnswer('Listen to this:', {
        media: 'https://cdn.freesound.org/previews/728/728142_11861866-lq.mp3'
    })

const voiceFlow = addKeyword('voice')
    .addAnswer('Voice message:', {
        media: join(process.cwd(), 'audio', 'greeting.mp3')
    })

const pdfFlow = addKeyword('invoice')
    .addAnswer('Your invoice:', {
        media: 'https://www.w3.org/WAI/ER/tests/xhtml/testfiles/resources/pdf/dummy.pdf'
    })

const documentFlow = addKeyword('report')
    .addAction(async (ctx, { flowDynamic }) => {
        const reportPath = join(process.cwd(), 'reports', 'monthly-report.xlsx')
        
        await flowDynamic([
            { body: 'Monthly Report', media: reportPath }
        ])
    })

import { addKeyword, utils } from '@builderbot/bot'

const mediaFlow = addKeyword(utils.setEvent('MEDIA'))
    .addAnswer('Thanks for the image! Processing...', null, async (ctx, { flowDynamic }) => {
        // ctx contains the media information
        console.log('Media URL:', ctx.url)
        console.log('Media type:', ctx.type)
        
        // Download and process the media
        await processMedia(ctx.url)
        
        await flowDynamic('Image processed successfully!')
    })

adapterProvider.server.post(
    '/v1/messages',
    handleCtx(async (bot, req, res) => {
        const { number, message, urlMedia } = req.body
        
        await bot.sendMessage(number, message, { 
            media: urlMedia ?? null 
        })
        
        return res.end('sent')
    })
)

curl -X POST http://localhost:3008/v1/messages \
  -H "Content-Type: application/json" \
  -d '{
    "number": "1234567890",
    "message": "Check this out!",
    "urlMedia": "https://example.com/image.jpg"
  }'

const catalogFlow = addKeyword('catalog')
    .addAction(async (ctx, { flowDynamic }) => {
        const products = await getProducts() // Your function
        
        for (const product of products) {
            await flowDynamic([
                {
                    body: `${product.name} - $${product.price}`,
                    media: product.imageUrl
                }
            ])
        }
    })

const productFlow = addKeyword('featured')
    .addAnswer('Our featured products:', { delay: 500 })
    .addAnswer('Product 1: Premium Widget', {
        media: 'https://example.com/product1.jpg',
        delay: 1000
    })
    .addAnswer('Product 2: Deluxe Gadget', {
        media: 'https://example.com/product2.jpg',
        delay: 1000
    })

import { join } from 'path'
import { createBot, createProvider, createFlow, addKeyword, utils } from '@builderbot/bot'
import { MemoryDB } from '@builderbot/bot'
import { BaileysProvider } from '@builderbot/provider-baileys'

const PORT = process.env.PORT ?? 3008

// Media samples flow
const fullSamplesFlow = addKeyword(['samples', utils.setEvent('SAMPLES')])
    .addAnswer('💪 Sending you various files...')
    .addAnswer('Image from local:', {
        media: join(process.cwd(), 'assets', 'sample.png')
    })
    .addAnswer('Video from URL:', {
        media: 'https://media.giphy.com/media/LCohAb657pSdHv0Q5h/giphy.mp4'
    })
    .addAnswer('Audio file:', {
        media: 'https://cdn.freesound.org/previews/728/728142_11861866-lq.mp3'
    })
    .addAnswer('PDF document:', {
        media: 'https://www.w3.org/WAI/ER/tests/xhtml/testfiles/resources/pdf/dummy.pdf'
    })

// Handle received media
const mediaReceivedFlow = addKeyword(utils.setEvent('MEDIA'))
    .addAnswer('Thanks for the image!', null, async (ctx, { flowDynamic }) => {
        console.log('Received media:', ctx.url)
        await flowDynamic('I received your image successfully!')
    })

const main = async () => {
    const adapterFlow = createFlow([fullSamplesFlow, mediaReceivedFlow])
    const adapterProvider = createProvider(BaileysProvider)
    const adapterDB = new MemoryDB()

    const { handleCtx, httpServer } = await createBot({
        flow: adapterFlow,
        provider: adapterProvider,
        database: adapterDB,
    })

    // HTTP endpoint to send media
    adapterProvider.server.post(
        '/v1/media',
        handleCtx(async (bot, req, res) => {
            const { number, message, urlMedia } = req.body
            await bot.sendMessage(number, message, { media: urlMedia })
            return res.end('media sent')
        })
    )

    httpServer(+PORT)
}

main()