Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 | 1x 1x 1x 1x 1x 1x 3x 3x 3x 3x 1x 2x 6x 6x 6x 6x 6x 5x 5x 4x 3x 3x 3x 3x 3x 3x 3x 3x 3x 3x 1x 1x 3x 5x 5x 5x 1x 1x 4x 4x 3x 4x 3x 1x 1x 3x 3x 3x 1x 1x 2x 2x 2x 2x 1x 1x 1x 4x 4x 4x 1x 1x 3x 3x 3x 3x 2x 1x 1x | import { Request, Response } from "express";
import axios from "axios";
import pdfParse from 'pdf-parse';
import dotenv from "dotenv";
import FormData from 'form-data';
import { v4 as uuidv4 } from "uuid";
import { addItem, getItem, updateItem, queryByPrefix } from "@deliverables.org/database";
import { processContract, ContractData } from "./contractController";
import { sendWhatsAppMessage, getMediaUrl, downloadMedia, createNotificationTemplate, createSignupTemplate } from "@deliverables.org/helpers";
dotenv.config();
interface UserData {
packages: {};
id: string;
name: string;
address: string;
complexId: string;
email: string;
phone: string;
}
interface LlmResponse {
choices: {
message: {
content: string;
};
}[];
}
const OPENROUTER_API_KEY = process.env.OPENROUTER_API_KEY;
const BACKEND_URL = process.env.BACKEND_URL;
const META_VERIFY_TOKEN = process.env.META_VERIFY_TOKEN;
const TABLE_NAME = "Deliverables";
export const whatsappController = {
// Verify Webhook
verifyWebhook: (req: Request, res: Response) => {
const mode = req.query["hub.mode"];
const token = req.query["hub.verify_token"];
const challenge = req.query["hub.challenge"];
if (mode === "subscribe" && token === META_VERIFY_TOKEN) {
res.status(200).send(challenge);
} else {
res.sendStatus(403);
}
},
// Receive Message Webhook
//TODO: CHECK IF USER IS NOT PENDING, AFTER USER IS NOT PENDING THEN USE LLM
receiveMessage: async (req: Request, res: Response) => {
const body = req.body;
Eif (body) {
const text = body.Body;
const from = body.From;
if (text.trim().toLowerCase() === "yes") {
try {
// Find ALL lookups for this phone number
const userLookups = await queryByPrefix({
TableName: TABLE_NAME,
PK: `PHONE#${from}`,
SKPrefix: `USER_LOOKUP`
});
if (userLookups.Items && userLookups.Items.length > 0) {
let updatedAny = false;
for (const lookup of userLookups.Items) {
const userResult = await getItem({
TableName: TABLE_NAME,
Key: { PK: `COMPLEX#${lookup.complexId}`, SK: `USER#${lookup.userId}` }
});
// Update if pending OR if we just want to ensure consistency (idempotent)
Eif (userResult.Item) {
await updateItem({
TableName: TABLE_NAME,
Key: { PK: `COMPLEX#${lookup.complexId}`, SK: `USER#${lookup.userId}` },
UpdateExpression: "SET #s = :active, #t = :true",
ExpressionAttributeValues: {
":active": "active",
":true": true
},
ExpressionAttributeNames: {
"#s": "status",
"#t": "tncAccepted"
}
});
updatedAny = true;
}
}
Eif (updatedAny) {
await sendWhatsAppMessage(from, "Thank you! You have successfully agreed to the terms. You are now fully registered.");
res.sendStatus(200);
return;
}
}
} catch (e) {
console.error("Error handling YES confirmation:", e);
res.sendStatus(400);
}
}
}
res.sendStatus(200);
},
// Send Message (API Endpoint)
sendMessage: async (req: Request, res: Response) => {
try {
const { name, telephone, message } = req.body;
if (!telephone) {
res.status(400).json({ message: "Missing telephone" });
return;
}
var phone = telephone;
if (!telephone.startsWith("whatsapp:")) {
phone = "whatsapp:" + telephone;
}
await sendWhatsAppMessage(phone, message);
res.status(200).json({ success: true });
} catch (error) {
console.error("Error sending WhatsApp message:", error);
res.status(500).json({ message: "Failed to send WhatsApp message" });
}
},
//Send Package Notification
sendNotification: async (req: Request, res: Response) => {
try {
const { name, telephone } = req.body;
if (!telephone) {
res.status(400).json({ message: "Missing telephone" });
return;
}
var phone = telephone;
Eif (!telephone.startsWith("whatsapp:")) {
phone = "whatsapp:" + telephone;
}
await sendWhatsAppMessage(phone, "", createNotificationTemplate(name));
res.status(200).json({ success: true });
} catch (error) {
console.error("Error sending notification:", error);
res.status(500).json({ message: "Failed to send notification" });
}
},
//Send Signup Notification
sendSignup: async (req: Request, res: Response) => {
try {
const { name, telephone } = req.body;
if (!telephone) {
res.status(400).json({ message: "Missing telephone" });
return;
}
var phone = telephone;
Eif (!telephone.startsWith("whatsapp:")) {
phone = "whatsapp:" + telephone;
}
await sendWhatsAppMessage(phone, "", createSignupTemplate(name));
res.status(200).json({ success: true });
} catch (error) {
console.error("Error sending signup message:", error);
res.status(500).json({ message: "Failed to send signup message" });
}
}
};
export default whatsappController; |