import express from 'express';
const app = express();

app.post('/webhooks/podium', express.json(), async (req, res) => {
  const event = req.body;
  if (event.type === 'message.received') {
    const msg = event.data;
    console.log(`From: ${msg.attributes['contact-phone']}`);
    console.log(`Body: ${msg.attributes.body}`);
    // Auto-reply or route to agent
    await sendReply(msg.attributes['location-uid'], msg.attributes['contact-phone'], 'Thanks for reaching out!');
  }
  res.status(200).json({ received: true });
});

const { data } = await podium.post('/webhooks', {
  data: {
    attributes: {
      url: 'https://your-app.com/webhooks/podium',
      events: ['message.received', 'message.sent', 'message.failed'],
    },
  },
});
console.log(`Webhook registered: ${data.data.id}`);

async function sendReply(locationId: string, phone: string, body: string) {
  const { data } = await podium.post(`/locations/${locationId}/messages`, {
    data: { attributes: { body, 'contact-phone': phone } },
  });
  return data.data.id;
}