Create webhook.js

webhook.js

@@ -0,0 +1,386 @@
+// restaurantBot.js
+
+const express = require("express");
+const axios = require("axios");
+const { Configuration, OpenAIApi } = require("openai");
+require("dotenv").config();
+
+const router = express.Router();
+
+// Environment Variables
+const {
+  META_ACCESS_TOKEN,
+  META_PHONE_NUMBER_ID,
+  META_VERIFY_TOKEN,
+  DEEPSEEK_API_KEY,
+  PYTHON_API_BASE_URL, // e.g. http://localhost:8000
+  NVIDIA_API_KEY,      // Your NVIDIA secret key for LLM fallback
+} = process.env;
+
+// Validate Environment Variables
+if (
+  !META_ACCESS_TOKEN ||
+  !META_PHONE_NUMBER_ID ||
+  !META_VERIFY_TOKEN ||
+  !DEEPSEEK_API_KEY ||
+  !PYTHON_API_BASE_URL ||
+  !NVIDIA_API_KEY
+) {
+  console.error("Missing environment variables. Please check your .env file.");
+  process.exit(1);
+}
+
+// -----------------------------------------------------------------------------
+// Set up the OpenAI client for NVIDIA LLM fallback (if needed)
+// -----------------------------------------------------------------------------
+const llmConfig = new Configuration({
+  apiKey: NVIDIA_API_KEY,
+  // Use NVIDIA's integration endpoint:
+  basePath: "https://integrate.api.nvidia.com/v1",
+});
+const llmOpenai = new OpenAIApi(llmConfig);
+
+/**
+ * Call the LLM fallback directly using the OpenAI API configured for NVIDIA.
+ * This function returns a Promise that resolves to the complete streamed response.
+ */
+async function callLLMFallback(message) {
+  return new Promise(async (resolve, reject) => {
+    try {
+      const response = await llmOpenai.createChatCompletion(
+        {
+          model: "meta/llama-3.1-405b-instruct",
+          messages: [{ role: "user", content: message }],
+          temperature: 0.2,
+          top_p: 0.7,
+          max_tokens: 1024,
+          stream: true,
+        },
+        { responseType: "stream" }
+      );
+
+      let fullText = "";
+      response.data.on("data", (chunk) => {
+        fullText += chunk.toString();
+      });
+      response.data.on("end", () => {
+        resolve(fullText);
+      });
+      response.data.on("error", (err) => {
+        console.error("Error in LLM fallback stream:", err);
+        reject(err);
+      });
+    } catch (error) {
+      console.error("Error calling LLM fallback:", error);
+      reject(error);
+    }
+  });
+}
+
+// -----------------------------------------------------------------------------
+// Helper Functions for calling Python API endpoints
+// -----------------------------------------------------------------------------
+
+// Forward a generic chat request to the Python chatbot endpoint and format response.
+async function getPythonChatResponse(userId, message) {
+  try {
+    console.log("Forwarding chat request to Python API...");
+    const response = await axios.post(`${PYTHON_API_BASE_URL}/chatbot`, {
+      user_id: userId,
+      message: message,
+    });
+
+    // If the response data is an object, format it into a friendly string.
+    if (typeof response.data === "object" && response.data !== null) {
+      let result = response.data.response || "";
+
+      // If there's a menu array, format it nicely.
+      if (Array.isArray(response.data.menu)) {
+        result += "\n\n*Menu:*\n";
+        response.data.menu.forEach((item) => {
+          result += `• *${item.name}* - ${item.description} - ₦${item.price}\n`;
+        });
+      }
+
+      // Append any follow-up text.
+      if (response.data.follow_up) {
+        result += "\n" + response.data.follow_up;
+      }
+      return result;
+    }
+    return response.data.response || "I'm sorry, I didn't get a response.";
+  } catch (error) {
+    console.error("Error from Python API (chatbot):", error.message);
+    return "I'm experiencing technical difficulties. Please try again later.";
+  }
+}
+
+// Retrieve the chat history for the given user from the Python API.
+async function getPythonChatHistory(userId) {
+  try {
+    console.log("Requesting chat history from Python API...");
+    const response = await axios.get(`${PYTHON_API_BASE_URL}/chat_history/${userId}`);
+    return response.data;
+  } catch (error) {
+    console.error("Error from Python API (chat_history):", error.message);
+    return null;
+  }
+}
+
+// Retrieve order details from the Python API.
+async function getPythonOrderDetails(orderId) {
+  try {
+    console.log("Requesting order details from Python API...");
+    const response = await axios.get(`${PYTHON_API_BASE_URL}/order/${orderId}`);
+    return response.data;
+  } catch (error) {
+    console.error("Error from Python API (order details):", error.message);
+    return null;
+  }
+}
+
+// Retrieve user profile from the Python API.
+async function getPythonUserProfile(userId) {
+  try {
+    console.log("Requesting user profile from Python API...");
+    const response = await axios.get(`${PYTHON_API_BASE_URL}/user_profile/${userId}`);
+    return response.data;
+  } catch (error) {
+    console.error("Error from Python API (user profile):", error.message);
+    return null;
+  }
+}
+
+// Retrieve analytics from the Python API.
+async function getPythonAnalytics() {
+  try {
+    console.log("Requesting analytics from Python API...");
+    const response = await axios.get(`${PYTHON_API_BASE_URL}/analytics`);
+    return response.data;
+  } catch (error) {
+    console.error("Error from Python API (analytics):", error.message);
+    return null;
+  }
+}
+
+// -----------------------------------------------------------------------------
+// Utility: Log chat history locally (for debugging purposes)
+// -----------------------------------------------------------------------------
+const chatHistories = {}; // For debugging: { userId: [ {timestamp, direction, message}, ... ] }
+function logChat(userId, direction, message) {
+  if (!chatHistories[userId]) {
+    chatHistories[userId] = [];
+  }
+  chatHistories[userId].push({
+    timestamp: new Date().toISOString(),
+    direction,
+    message,
+  });
+}
+
+// -----------------------------------------------------------------------------
+// Webhook Verification (GET)
+// -----------------------------------------------------------------------------
+router.get("/", (req, res) => {
+  const {
+    "hub.mode": mode,
+    "hub.verify_token": token,
+    "hub.challenge": challenge,
+  } = req.query;
+  if (mode === "subscribe" && token === META_VERIFY_TOKEN) {
+    console.log("Webhook verified successfully.");
+    return res.status(200).send(challenge);
+  }
+  console.error("Webhook verification failed.");
+  res.sendStatus(403);
+});
+
+// -----------------------------------------------------------------------------
+// WhatsApp Webhook Handler (POST)
+// -----------------------------------------------------------------------------
+router.post("/", async (req, res) => {
+  try {
+    const body = req.body;
+    console.log("Webhook received:", JSON.stringify(body, null, 2));
+
+    if (body.object === "whatsapp_business_account") {
+      const changes = body.entry[0]?.changes[0]?.value;
+
+      // Handle incoming messages
+      if (changes?.messages) {
+        const messageObj = changes.messages[0];
+        const { from, text } = messageObj;
+        const userMessage = text?.body;
+        console.log(`Message from ${from}: ${userMessage}`);
+
+        // Log the incoming message locally for debugging
+        logChat(from, "inbound", userMessage);
+
+        // Generate a response based on the user's message
+        const botResponse = await generateResponse(userMessage, from);
+        console.log("Bot response:", botResponse);
+        logChat(from, "outbound", botResponse);
+
+        // Send the response back to the user via WhatsApp API.
+        await sendMessage(from, botResponse);
+        return res.status(200).send("EVENT_RECEIVED");
+      }
+
+      // Handle status updates (e.g., delivery receipts)
+      if (changes?.statuses) {
+        console.log("Status update received:", JSON.stringify(changes.statuses, null, 2));
+        return res.status(200).send("EVENT_RECEIVED");
+      }
+    }
+
+    console.log("No valid content found in webhook.");
+    res.sendStatus(404);
+  } catch (error) {
+    console.error("Error handling webhook:", error.message);
+    res.sendStatus(500);
+  }
+});
+
+// -----------------------------------------------------------------------------
+// Enhanced Response Generator
+// -----------------------------------------------------------------------------
+async function generateResponse(message, from) {
+  const lowerMessage = message.toLowerCase();
+
+  // 1. Welcome and Main Menu
+  if (lowerMessage === "hi" || lowerMessage === "hello" || lowerMessage.includes("welcome")) {
+    return `👋 Hi there! Welcome to *Angelo Foods*! 🍔🍕\nPlease choose an option:\n1️⃣ *View Menu*\n2️⃣ *Place an Order*\n3️⃣ *Payment Status*\n4️⃣ *My Profile*\n5️⃣ *Chat History*\n6️⃣ *Help & Support*\nSimply type the number or the option name.`;
+  }
+
+  // 2. Menu Display
+  if (lowerMessage === "1" || (lowerMessage.includes("menu") && !lowerMessage.includes("order"))) {
+    // Display the menu (with images and details)
+    const menuResponse = await getPythonChatResponse(from, "menu");
+    return menuResponse;
+  }
+
+  // 3. Order Flow – Triggered by multiple keywords
+  if (
+    lowerMessage === "2" ||
+    lowerMessage.includes("order") ||
+    lowerMessage.includes("buy") ||
+    lowerMessage.includes("food")
+  ) {
+    // Check if the message exactly matches one of the dish names from the menu.
+    let selectedDish = null;
+    for (let item of menu_items) {
+      if (lowerMessage.includes(item.name.toLowerCase())) {
+        selectedDish = item.name;
+        break;
+      }
+    }
+    // If a dish is selected, pass it along as part of the order command.
+    if (selectedDish) {
+      return await getPythonChatResponse(from, `order: ${selectedDish}`);
+    }
+    // Otherwise, if user simply says "order", "buy", or "food", delegate to the order flow in Python API.
+    return await getPythonChatResponse(from, "order");
+  }
+
+  // 4. Payment Status
+  if (lowerMessage === "3" || lowerMessage.includes("payment")) {
+    return await getPythonChatResponse(from, "payment");
+  }
+
+  // 5. User Profile
+  if (lowerMessage === "4" || lowerMessage.includes("profile")) {
+    const profile = await getPythonUserProfile(from);
+    if (profile) {
+      return `👤 *Your Profile*\nName: ${profile.name}\nPhone: ${profile.phone_number}\nEmail: ${profile.email}\nPreferences: ${profile.preferences}\nLast Interaction: ${profile.last_interaction}`;
+    } else {
+      return "No profile information found.";
+    }
+  }
+
+  // 6. Chat History
+  if (lowerMessage === "5" || lowerMessage.includes("chat history")) {
+    const history = await getPythonChatHistory(from);
+    if (history && history.length > 0) {
+      let formattedHistory = "*Your Chat History:*\n";
+      history.forEach((entry) => {
+        formattedHistory += `[${entry.timestamp}] ${entry.direction}: ${entry.message}\n`;
+      });
+      return formattedHistory;
+    } else {
+      return "No chat history found for your account.";
+    }
+  }
+
+  // 7. Help & Support
+  if (lowerMessage === "6" || lowerMessage.includes("help") || lowerMessage.includes("support")) {
+    return `❓ *How can I help you?*\nType one of the following:\n- *Order Status* (e.g., "order tracking ORD-123456789")\n- *Contact Support*\n- *Main Menu* to see all options again.`;
+  }
+
+  // 8. Recommendations (Advanced Feature)
+  if (lowerMessage.includes("recommendations")) {
+    return await getPythonChatResponse(from, "recommendations");
+  }
+
+  // 9. Analytics (for admin use)
+  if (lowerMessage.includes("analytics")) {
+    const analytics = await getPythonAnalytics();
+    if (analytics) {
+      return `📊 *Analytics*\nTotal Messages: ${analytics.total_messages}\nTotal Orders: ${analytics.total_orders}\nAverage Sentiment: ${analytics.average_sentiment}`;
+    } else {
+      return "Analytics data is not available.";
+    }
+  }
+
+  // 10. Fallback: Use NVIDIA LLM fallback
+  try {
+    const llmResponse = await callLLMFallback(message);
+    return llmResponse;
+  } catch (error) {
+    console.error("LLM fallback error:", error);
+    return "I'm sorry, I didn't get a response.";
+  }
+}
+
+// -----------------------------------------------------------------------------
+// Send Message to User via WhatsApp API
+// -----------------------------------------------------------------------------
+async function sendMessage(to, message) {
+  try {
+    const url = `https://graph.facebook.com/v16.0/${META_PHONE_NUMBER_ID}/messages`;
+    const response = await axios.post(
+      url,
+      {
+        messaging_product: "whatsapp",
+        to,
+        text: { body: message },
+      },
+      {
+        headers: { Authorization: `Bearer ${META_ACCESS_TOKEN}` },
+      }
+    );
+    console.log("Message sent successfully:", response.data);
+  } catch (error) {
+    if (error.response) {
+      const { status } = error.response;
+      console.error(`Error sending message: Status ${status}`);
+      if (status === 401 || status === 403) {
+        console.error(
+          "[Token Issue Detected] The META_ACCESS_TOKEN may have expired or is invalid. Please refresh the token."
+        );
+      }
+    } else {
+      console.error("Error sending message:", error.message);
+    }
+  }
+}
+
+// -----------------------------------------------------------------------------
+// Proactive Engagement: Send a greeting to inactive users
+// -----------------------------------------------------------------------------
+async function sendProactiveGreeting(userId) {
+  const greeting = "👋 Hi again! We miss you. 😊\nWould you like to see our new menu items or get personalized recommendations? Type *'Menu'* or *'Recommendations'*.";
+  await sendMessage(userId, greeting);
+  return greeting;
+}
+
+module.exports = router;