Mensajes y media

await ctx.reply('👋 ¡Hola!')
await ctx.quote('respondiendo a tu mensaje')     // cita el mensaje entrante
await ctx.reply('escribiendo esto...', { typing: true }) // muestra "escribiendo…" antes de enviar

const sent = await ctx.reply(respuestaLarga) // 9000 caracteres en Telegram → 3 mensajes
sent.id        // la última parte
sent.parts     // el ref de cada parte, en orden (solo si el texto se dividió)

await ctx.photo('https://picsum.photos/400/300', '📸 pie de foto')
await ctx.photo('./foto.jpg', 'pie de foto')  // archivo local
await ctx.photo(buffer, 'pie de foto')        // Buffer

await ctx.video(url, 'pie de video')
await ctx.video(url, 'pie de video', { gifPlayback: true })  // GIF
await ctx.video(url, 'pie de video', { ptv: true })           // video circular

await ctx.audio(url)   // audio
await ctx.voice(url)   // nota de voz (PTT)

await ctx.file(url, 'documento.pdf', 'Tu documento')

await ctx.sticker(url, { pack: 'Mi pack', author: 'yo' })

await ctx.location(4.7110, -74.0721, 'Bogotá, Colombia 🇨🇴')

await ctx.contact('573001234567', 'Bot de soporte')

await ctx.buttons('Elige una', [
  { id: 'a', title: 'Opción A' },
  { id: 'b', title: 'Opción B' },
])

// Las encuestas son nativas en Baileys y Telegram. La Cloud API no tiene
// encuestas: ahí ctx.poll() rechaza con UnsupportedContentError — usa botones.
await ctx.poll('¿Qué prefieres?', ['Opción A', 'Opción B'])

// Selección múltiple
await ctx.poll('¿Qué te gusta?', ['🍕 Pizza', '🍔 Hamburguesa'], true)

const bot = new Bot({ provider, lang: 'es', typing: true }) // por defecto: { minMs: 800, maxMs: 3000, charsPerSecond: 20 }
const ajustado = new Bot({ provider, lang: 'es', typing: { enabled: true, minMs: 500, maxMs: 2000 } })

// Por respuesta: cambia el indicador y/o espera antes
await ctx.reply('Un momento…', { typing: false })
await ctx.reply('Aquí está', { delay: '1.5s', typing: { maxMs: 1000 } })

const msg = await ctx.reply('Procesando…')
await ctx.edit('Listo ✅')                       // edita la última respuesta de este mismo contexto
await ctx.edit(msg.ref, 'Listo ✅')              // edita un mensaje concreto
await ctx.edit('Listo ✅', { fallback: 'skip' }) // nunca envía un mensaje nuevo

await ctx.react('👍')
await ctx.react('❤️')
await ctx.react('🔥', msg.ref) // reacciona a otro mensaje
await ctx.react('')            // quita la reacción, donde el transporte lo permite

await ctx.markRead()   // marca el mensaje entrante como leído
await ctx.typing()     // muestra "escribiendo…"
await ctx.recording()  // muestra "grabando audio…"
await ctx.delete()     // elimina el mensaje entrante (si está permitido)

bot.onType('image', async (ctx) => { await ctx.reply('📸 ¡Recibí tu imagen!') })
bot.onType('audio', async (ctx) => { await ctx.reply('🎵 Recibí tu audio') })
bot.onType('video', async (ctx) => { await ctx.reply('🎬 Recibí tu video') })
bot.onType('sticker', async (ctx) => { await ctx.reply('🎨 ¡Recibí tu sticker!') })
bot.onType('document', async (ctx) => { await ctx.reply('📄 Recibí tu archivo') })
bot.onType('location', async (ctx) => { await ctx.reply('📍 Recibí tu ubicación') })
bot.onType('contact', async (ctx) => { await ctx.reply('👤 Recibí tu contacto') })
bot.onType('poll', async (ctx) => { await ctx.reply('📊 Recibí tu encuesta') })

bot.onType('location', async (ctx) => {
  const loc = ctx.sharedLocation
  if (!loc) return ctx.reply('No pude leer esa ubicación')
  await ctx.reply(`📍 ${loc.latitude}, ${loc.longitude}${loc.name ? ` (${loc.name})` : ''}`)
})

bot.conversation('envio', async (c) => {
  await c.say('Comparte la ubicación de entrega 📍')
  const loc = await c.waitLocation({ timeout: '5m' })
  await c.say(`Entregamos en ${loc.latitude}, ${loc.longitude}`)
})

await ctx.poll('¿Pizza o sushi?', ['Pizza', 'Sushi'])

bot.on('poll', (vote) => {
  // vote.ref.id      → id del mensaje de la encuesta
  // vote.ref.chatId  → chat donde se votó (el mismo chatId que usan sus mensajes)
  // vote.senderId    → quien acaba de votar, con el id canónico de sus mensajes
  // vote.options     → recuento actual: [{ name, votes, voters }]
  const elegidas = vote.options.filter((o) => o.voters?.includes(vote.senderId)).map((o) => o.name)
  console.log(elegidas.length ? `Eligió: ${elegidas.join(', ')}` : 'Retiró su voto')
})

import { loadMediaOf, MediaTooLargeError } from '@botmesh/core'

bot.onType('image', async (ctx) => {
  try {
    const media = await loadMediaOf(ctx, { maxBytes: 5 * 1024 * 1024 })
    if (!media) return                 // sin media, o la descarga falló
    console.log(media.mimetype)        // 'image/jpeg'
    console.log(media.buffer)          // Buffer
    console.log(media.size)            // bytes, si el provider los declaró
    // ctx.media ya es el mismo payload
  } catch (err) {
    if (err instanceof MediaTooLargeError) await ctx.reply('Ese archivo es demasiado grande')
    else throw err
  }
})

await bot.send('573001234567@s.whatsapp.net', '🌅 ¡Buenos días!')
await bot.send('573001234567@s.whatsapp.net', {
  kind: 'image',
  media: { url },
  caption: 'hola',
})
await bot.send(chatId, 'Hola, soy Ana de soporte')  // mismo camino; un string se envía como texto

const ac = new AbortController()
const res = await bot.broadcast(chatIds, '🎉 ¡Nueva promo!', {
  batchSize: 10,          // chats por lote (default 10)
  delayBetween: '2s',     // pausa entre lotes (ms o '2s', '1m'; default 0)
  concurrency: 1,         // envíos en paralelo por lote (default 1)
  retries: 3,             // reintentos por chat tras un RateLimitedError (default 3)
  onProgress: (done, total) => bot.logger.info(`${done}/${total}`),
  onFail: (chatId, error) => bot.logger.warn({ chatId, err: error }, 'broadcast falló'),
  signal: ac.signal,      // aborta para parar antes
})
// → { total, sent, failed, skipped, errors: [{ chatId, error }], messages, cancelled, pending }

bot.schedule('0 9 * * *', async () => {
  for (const cita of await db.citasDeHoy()) {
    await bot.trigger('recordatorio', { chatId: cita.chatId, data: { hora: cita.hora } })
  }
})