Flujos conversacionales

import { flow } from '@botmesh/core'

const saludo = flow('hola')
  .ask('👋 ¡Hola! ¿Cómo te llamas?', 'name')
  .say((_ctx, c) => `¡Mucho gusto, ${c.state.name}!`)

bot.use(saludo)

flow('x').say('texto')                               // texto fijo
flow('x').say((_ctx, c) => `Hola ${c.state.name}`)    // dinámico, lee c.state
flow('x').say('Pensando…').say('¡Listo!', { delay: '2s' }) // pausa 2 s antes de enviar

flow('x').ask('¿Cómo te llamas?', 'name')  // guarda la respuesta en c.state.name

flow('x').ask('¿Email?', 'email', {
  validate: (body) =>
    /^[^\s@]+@[^\s@]+\.[^\s@]+$/.test(body) ? true : '❌ Email no válido, inténtalo de nuevo',
  maxAttempts: 3,
  timeout: '2m',
})

import { z } from 'zod'

flow('registro')
  .ask('¿Cuántos años tienes?', 'edad', { schema: z.coerce.number().min(18, 'Debes ser mayor de edad') })
  .say((_ctx, c) => `El año que viene tendrás ${c.state.edad + 1}`)   // c.state.edad: number

flow('x').do((ctx, c) => {
  c.state.registeredAt = Date.now()
})

flow('x')
  .media('image', 'https://picsum.photos/400/300', 'Nuestro menú')
  .media('document', './factura.pdf', 'Tu factura', { filename: 'factura.pdf' })
  .media('voice', './saludo.ogg')
  .media('location', { lat: 4.71, lng: -74.07 }, 'Bogotá')

flow('confirmar')
  .choose('¿Confirmas tu pedido?', { si: 'Sí', no: 'No' })
  .say((_ctx, c) => c.state.choice === 'si' ? '✅ Confirmado' : '❌ Cancelado')

flow('menu')
  .choose('¿Qué te interesa?', {
    ofertas: { label: 'Ofertas 🏷️', then: (_ctx, c) => { c.state.interes = 'ofertas' } },
    soporte: { label: 'Soporte 🛠️', then: (_ctx, c) => { c.state.interes = 'soporte' } },
  })
  .say((_ctx, c) => `Entendido: ${c.state.interes}`)

const menu = flow('menu').choose('Menú principal', { pedidos: 'Pedidos', ayuda: 'Ayuda' })

flow('ayuda').choose('Temas de ayuda', {
  envios: { label: 'Envíos', then: flow('envios').say('Enviamos en 48 h') },
  volver: { label: '⬅️ Volver', goto: menu },
})

flow('soporte')
  .timeout('60s')
  .ask('Describe tu problema', 'problema')

const bot = new Bot({
  provider: new BaileysProvider({ session: 'mi-bot' }),
  lang: 'es',
  conversation: { timeoutMessage: '⏰ La sesión expiró por inactividad.' },
})

flow('a').say('Te redirijo...').goto('b')

const direccion = flow('direccion').ask('¿Calle?', 'calle').ask('¿Ciudad?', 'ciudad')

flow('pedido')
  .say('Datos de envío')
  .use(direccion)
  .say((_ctx, c) => `Envío a ${c.state.calle}, ${c.state.ciudad}`)

flow('admin')
  .guard((ctx) => admins.includes(ctx.sender), '⛔ Este menú es solo para admins')
  .guard(() => esHorarioLaboral(), { redirect: 'fuera-de-horario' })
  .say('Menú de admin')

flow('registrar').persistent().ask('¿Nombre?', 'name').say('Listo')

const bot = new Bot({
  provider: new BaileysProvider({ session: 'mi-bot' }),
  lang: 'es',
  store: new MemoryStore({ file: './store.json' }), // o un store real — ver la guía de Store
})

flow('soporte').scope('dm').ask('Describe tu problema', 'problema')

flow('x')
  .ask('¿Nombre?', 'name')
  .do((_ctx, c) => { c.state.name = c.state.name.trim() })
  .say((_ctx, c) => `Hola ${c.state.name}`)

const f = flow<{ plan: 'free' | 'pro' }>('alta')
  .ask('¿Edad?', 'edad', { schema: z.coerce.number() })
  .choose('¿Cómo pagas?', { tarjeta: 'Tarjeta', efectivo: 'Efectivo' }, 'pago')
  .do((_ctx, c) => {
    c.state.edad   // number
    c.state.pago   // 'tarjeta' | 'efectivo'
    c.state.plan   // 'free' | 'pro'
  })

const registro = flow('registrar')
  .say('📝 *Vamos a registrarte*')
  .ask('¿Nombre?', 'name')
  .ask('¿Email?', 'email', {
    validate: (body) => /^[^\s@]+@[^\s@]+\.[^\s@]+$/.test(body) ? true : '❌ Email no válido',
  })
  .say((_ctx, c) => `✅ ${c.state.name} <${c.state.email}>`)

bot.use(registro)

bot.conversation('quiz', async (c, ctx) => {
  let aciertos = 0
  for (const [pregunta, respuesta] of [['¿2 + 2?', '4'], ['¿Capital de Francia?', 'paris']]) {
    const r = await c.ask(pregunta, { timeout: '1m' })
    if (r.trim().toLowerCase() === respuesta) aciertos++
  }
  await ctx.reply(`Puntuación: ${aciertos}/2`)
}, { trigger: 'quiz' })

bot.conversation('foto', async (c, ctx) => {
  const img = await c.waitMedia(['image'], { timeout: '2m' })
  await ctx.react('📸')
  await ctx.reply(`Recibida (${img.type})`)
})

bot.conversation('ahorcado', async (c, ctx) => {
  let letra = await c.ask('Escribe una letra')
  while (letra.length !== 1) letra = await c.retry('❌ Solo una letra')
  await ctx.reply(`✅ ${letra}`)
})

flow('juego')
  .ask('Escribe una letra', 'letra')
  .do((_ctx, c) => {
    if (String(c.state.letra).length !== 1) c.retry('❌ Solo una letra')
  })
  .say((_ctx, c) => `✅ ${c.state.letra}`)

bot.conversation('juego', async (c, ctx) => {
  c.idle('2m', async () => {
    await ctx.reply('⏰ Te desconecté por inactividad')
    c.end('👋 ¡Hasta luego!')          // termina la conversación (envía la despedida)
  })
  await ctx.reply('Escribe una letra')
  const letra = await c.waitText({ timeout: '10m' })
  c.idleClear()                         // lo desarma cuando respondió
})

bot.onIdle('10m', async (ctx, { chatId, idleMs, lastActivityAt }) => {
  await ctx.reply('¿Sigues ahí? 👀')       // ctx = el último mensaje procesado de ese chat
})
const off = bot.onIdle('1h', (ctx) => bot.send(ctx.from, 'Cerramos tu sesión por inactividad'))
off()                                       // deja de vigilar y cancela sus temporizadores
bot.clearIdle(chatId)                       // cancela los temporizadores de un chat (de todos sin argumento)