Webhooks

const express = require('express');
const app = express();
app.use(express.json());
 
// GET — called once by Bahasha when you register the webhook
app.get('/webhook', (req, res) => {
  const mode      = req.query['hub.mode'];
  const token     = req.query['hub.verify_token'];
  const challenge = req.query['hub.challenge'];
 
  if (mode === 'subscribe' && token === process.env.WEBHOOK_VERIFICATION_TOKEN) {
    // Echo back the challenge — this proves you own the URL
    return res.status(200).send(challenge);
  }
  res.sendStatus(403);
});
 
// POST — receives delivery reports and customer replies
app.post('/webhook', (req, res) => {
  // Acknowledge immediately — process asynchronously if needed
  res.sendStatus(200);
 
  const { entry } = req.body;
  for (const e of entry ?? []) {
    for (const change of e.changes ?? []) {
      if (change.field !== 'messages') continue;
      const { messages = [], statuses = [] } = change.value;
 
      // Delivery status updates (sent, delivered, read, failed)
      for (const s of statuses) {
        console.log(`[${s.status.toUpperCase()}] message ${s.id}`);
        if (s.status === 'failed') {
          console.error('Delivery error:', s.errors?.[0]?.title);
        }
      }
 
      // Incoming customer replies
      for (const m of messages) {
        console.log(`Incoming ${m.type} from ${m.from}`);
        if (m.type === 'text')        console.log('Body:', m.text.body);
        if (m.type === 'interactive') console.log('Reply:', m.interactive.button_reply ?? m.interactive.list_reply);
        if (m.type === 'button')      console.log('Button:', m.button.text);
      }
    }
  }
});
 
app.listen(3000, () => console.log('Webhook receiver running on port 3000'));

from flask import Flask, request, abort
import os
 
app = Flask(__name__)
 
# GET — called once by Bahasha when you register the webhook
@app.get('/webhook')
def verify():
    mode      = request.args.get('hub.mode')
    token     = request.args.get('hub.verify_token')
    challenge = request.args.get('hub.challenge')
 
    if mode == 'subscribe' and token == os.environ['WEBHOOK_VERIFICATION_TOKEN']:
        # Echo back the challenge — this proves you own the URL
        return challenge, 200
    abort(403)
 
# POST — receives delivery reports and customer replies
@app.post('/webhook')
def receive():
    body = request.get_json()
 
    for entry in body.get('entry', []):
        for change in entry.get('changes', []):
            if change.get('field') != 'messages':
                continue
            value    = change.get('value', {})
            statuses = value.get('statuses', [])
            messages = value.get('messages', [])
 
            # Delivery status updates (sent, delivered, read, failed)
            for s in statuses:
                print(f"[{s['status'].upper()}] message {s['id']}")
                if s['status'] == 'failed':
                    print('Delivery error:', s.get('errors', [{}])[0].get('title'))
 
            # Incoming customer replies
            for m in messages:
                print(f"Incoming {m['type']} from {m['from']}")
                if m['type'] == 'text':
                    print('Body:', m['text']['body'])
                elif m['type'] == 'interactive':
                    print('Reply:', m['interactive'].get('button_reply') or m['interactive'].get('list_reply'))
                elif m['type'] == 'button':
                    print('Button:', m['button']['text'])
 
    # Always return 200 — Bahasha will retry if it doesn't receive a prompt acknowledgement
    return 'OK', 200
 
if __name__ == '__main__':
    app.run(port=3000)