WhatsApp Chatbot Integration

// Example in Meta's webhook format (not a NotifyTech AI endpoint)
const express = require('express');
const app = express();
app.use(express.json());

const seen = new Set(); // use a database in production

// Meta verifies your URL once with a GET
app.get('/webhook', (req, res) => {
  const mode = req.query['hub.mode'];
  const token = req.query['hub.verify_token'];
  if (mode === 'subscribe' && token === process.env.VERIFY_TOKEN) {
    return res.status(200).send(req.query['hub.challenge']);
  }
  res.sendStatus(403);
});

// Every event arrives as a POST
app.post('/webhook', (req, res) => {
  res.sendStatus(200); // acknowledge first, work after
  for (const entry of req.body.entry ?? []) {
    for (const change of entry.changes ?? []) {
      for (const msg of change.value.messages ?? []) {
        if (seen.has(msg.id)) continue; // retries can repeat a message
        seen.add(msg.id);
        if (msg.type === 'text') decide(msg.from, msg.text.body);
      }
    }
  }
});

// Example: one decision per message
const ANSWERS = {
  hours: 'We reply Mon–Sat, 9–7 IST.',
  // add the questions your customers really ask
};

function decide(from, text) {
  const q = text.trim().toLowerCase();

  if (q.includes('agent') || q.includes('person')) {
    return handOff(from); // move the chat to your team inbox
  }

  const key = Object.keys(ANSWERS).find(k => q.includes(k));
  if (key) return reply(from, ANSWERS[key]);

  return reply(from, 'I did not catch that. Ask again, or type "agent".');
}

// reply() calls the send API shown in the next tab.

const axios = require('axios');

const sendMessage = async () => {
  try {
    const response = await axios.post(
      'https://api.notifytechai.com/v1/whatsapp/send',
      {
        to: '+919876543210',
        type: 'template',
        template: {
          name: 'welcome_message',
          language: 'en',
          components: [{
            type: 'body',
            parameters: [
              { type: 'text', text: 'John' }
            ]
          }]
        }
      },
      {
        headers: {
          'Authorization': 'Bearer YOUR_API_KEY',
          'Content-Type': 'application/json'
        }
      }
    );
    console.log('Message sent:', response.data);
  } catch (error) {
    console.error('Error:', error.response?.data ?? error.message);
  }
};

<?php
// webhook.php - Handle delivery reports

$payload = file_get_contents('php://input');
$data = json_decode($payload, true);

$signature =
  $_SERVER['HTTP_X_NOTIFYTECH_SIGNATURE'];
$secret = 'your_webhook_secret';

if (!verifySignature($payload, $signature, $secret)) {
    http_response_code(401);
    exit('Invalid signature');
}

switch ($data['event']) {
    case 'message.delivered':
        updateMessageStatus(
          $data['message_id'], 'delivered'
        );
        break;
    case 'message.failed':
        updateMessageStatus(
          $data['message_id'], 'failed'
        );
        logError($data['error']);
        break;
}

http_response_code(200);
echo json_encode(['status' => 'processed']);