Ejemplos

import { defineTool } from 'plz/workers'

export default defineTool({
  name: 'consultar-inventario',
  reference: 'Busca productos disponibles en stock por nombre o SKU',
  agents: ['id_agent_1'],
  parameters: [
    { name: 'query', type: 'string', description: 'Nombre o SKU del producto', example: 'Que producto estas buscando?' }
  ],

  async run(payload, plz) {
    const apiUrl = plz.env.INVENTORY_API_URL
    const apiKey = plz.env.INVENTORY_API_KEY

    const res = await fetch(`${apiUrl}/products/search?q=${payload.query}`, {
      headers: { 'Authorization': `Bearer ${apiKey}` }
    })

    const products = await res.json()

    return products.map(p => ({
      nombre: p.name,
      precio: `$${p.price}`,
      stock: p.stock > 0 ? `${p.stock} disponibles` : 'Agotado',
      sku: p.sku
    }))
  }
})

import { defineWorker } from 'plz/workers'

export default defineWorker({
  name: 'notificar-slack',
  reference: 'Notifica a Slack cuando un contacto solicita atencion humana',

  async run(payload, plz) {
    const { contactId, contact } = payload

    plz.log.info('Worker iniciado', { contactId })

    // Validar configuracion
    const webhookUrl = plz.env.SLACK_WEBHOOK_URL
    if (!webhookUrl) {
      plz.log.error('SLACK_WEBHOOK_URL no configurado en secrets')
      return { success: false, error: 'Webhook no configurado' }
    }

    // Obtener datos del contacto si no vienen en el payload
    let contactName = contact?.name || 'Sin nombre'
    let contactPhone = contact?.phoneNumber || ''

    if (!contact && contactId) {
      plz.log.info('Consultando datos del contacto...')
      const contactData = await plz.contacts.get(contactId)
      contactName = contactData.name || 'Sin nombre'
      contactPhone = contactData.phoneNumber || ''
    }

    plz.log.info('Contacto identificado', { contactName, contactPhone })

    // Enviar notificacion a Slack
    const message = `*Nuevo lead solicita atencion humana*\n- Nombre: ${contactName}\n- Telefono: ${contactPhone}\n- Ultimo mensaje: ${contact?.lastMessage || 'N/A'}`

    const response = await fetch(webhookUrl, {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify({ text: message })
    })

    if (!response.ok) {
      plz.log.error('Error enviando a Slack', await response.text())
      return { success: false }
    }

    plz.log.info('Notificacion enviada a Slack exitosamente')

    return { success: true, contactName }
  }
})

import { defineWebhook } from 'plz/workers'

export default defineWebhook({
  name: 'webhook-stripe-payments',
  reference: 'Recibe eventos de pago de Stripe y actualiza contactos',
  method: 'POST',

  async run(payload, plz) {
    const event = payload

    if (event.type !== 'checkout.session.completed') {
      return { ignored: true, reason: `Evento ${event.type} ignorado` }
    }

    const session = event.data.object
    const email = session.customer_details.email

    // Buscar contacto por email y actualizar
    const matches = await plz.contacts.search({ email })

    if (matches.length > 0) {
      const contactId = matches[0].id

      // Actualizar variables custom del contacto
      await plz.contacts.setVariable(contactId, 'ctc_ultimo_pago', `$${session.amount_total / 100}`)
      await plz.contacts.setVariable(contactId, 'ctc_fecha_pago', new Date().toISOString())
      await plz.contacts.setVariable(contactId, 'ctc_stripe_customer', session.customer)

      // Agregar tag
      await plz.contacts.addTag(contactId, 'cliente-pagado')
    }

    return {
      success: true,
      email,
      amount: session.amount_total / 100,
      currency: session.currency
    }
  }
})

import { defineSchedule } from 'plz/workers'

export default defineSchedule({
  name: 'reporte-nocturno',
  reference: 'Envia resumen diario de chats pendientes por Slack',
  cron: '0 22 * * 1-5',
  timezone: 'America/Mexico_City',

  async run(plz) {
    // Obtener contactos y filtrar los no resueltos
    const allContacts = await plz.contacts.list({ limit: 200 })
    const pendingChats = allContacts.filter(c => !c.isSolved)

    const summary = {
      total: pendingChats.length,
      byAgent: {}
    }

    for (const chat of pendingChats) {
      const agent = chat.assignedAgentName || 'Sin asignar'
      summary.byAgent[agent] = (summary.byAgent[agent] || 0) + 1
    }

    const agentLines = Object.entries(summary.byAgent)
      .map(([agent, count]) => `  - ${agent}: ${count} chats`)
      .join('\n')

    await fetch(plz.env.SLACK_WEBHOOK, {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify({
        text: `*Reporte nocturno*\n\nChats pendientes: *${summary.total}*\n\nPor agente:\n${agentLines}`
      })
    })

    return { sent: true, pending: summary.total }
  }
})