Build EHSAN Closed Donation Loop POC — full bilingual Arabic/English app
- Backend (api-server): Complete in-memory mock DB with 11 seed cases, 5 eligible beneficiaries, 3 donors, and WhatsApp log. All 14 API routes implemented across requests, donors, stats, and whatsapp-log. OpenClaw integration with OPENCLAW_SIMULATE toggle. UUID-based IDs. Full status machine (new → closed, 10 steps). - Frontend (ehsan-poc): 8 pages fully implemented using all generated API hooks: Home (stats counters, 10-step workflow diagram), Request (form with eligibility result), Opportunities (card grid with progress bars), Donate (case summary + donor form), Admin (full data table with contextual action buttons), Track (10-step visual timeline in green), ThankYou (message form), WhatsApp Log (WhatsApp bubble preview + OpenClaw send button). - Bilingual LanguageContext (AR/EN) with RTL/LTR toggle, localStorage persistence. EHSAN green palette (HSL 143), Tajawal font, fully responsive. TypeScript clean — zero errors.
This commit is contained in:
Replit Agent
@@ -0,0 +1,359 @@
|
||||
import { Router } from "express";
|
||||
import {
|
||||
requests,
|
||||
donors,
|
||||
whatsappLog,
|
||||
checkEligibility,
|
||||
STATUS_STEP,
|
||||
DonationRequest,
|
||||
WhatsappLogEntry,
|
||||
} from "../lib/mockDb.js";
|
||||
import { v4 as uuidv4 } from "uuid";
|
||||
|
||||
const router = Router();
|
||||
|
||||
// ─── GET /requests ───────────────────────────────────────────────────────────
|
||||
router.get("/requests", (req, res) => {
|
||||
let result = [...requests];
|
||||
const { status, needType } = req.query;
|
||||
if (status) result = result.filter((r) => r.status === status);
|
||||
if (needType) result = result.filter((r) => r.needType === needType);
|
||||
res.json(result);
|
||||
});
|
||||
|
||||
// ─── GET /requests/new ──────────────────────────────────────────────────────
|
||||
router.get("/requests/new", (_req, res) => {
|
||||
res.json(requests.filter((r) => r.status === "new"));
|
||||
});
|
||||
|
||||
// ─── GET /requests/published ────────────────────────────────────────────────
|
||||
router.get("/requests/published", (_req, res) => {
|
||||
res.json(requests.filter((r) => r.status === "published"));
|
||||
});
|
||||
|
||||
// ─── POST /requests ──────────────────────────────────────────────────────────
|
||||
router.post("/requests", (req, res) => {
|
||||
const {
|
||||
beneficiaryName,
|
||||
nationalId,
|
||||
phone,
|
||||
source,
|
||||
sourceName,
|
||||
needType,
|
||||
requestedAmount,
|
||||
description,
|
||||
} = req.body;
|
||||
|
||||
if (
|
||||
!beneficiaryName ||
|
||||
!nationalId ||
|
||||
!phone ||
|
||||
!source ||
|
||||
!sourceName ||
|
||||
!needType ||
|
||||
!requestedAmount ||
|
||||
!description
|
||||
) {
|
||||
return res.status(400).json({ error: "Missing required fields" });
|
||||
}
|
||||
|
||||
const { eligible } = checkEligibility(nationalId);
|
||||
|
||||
let status: DonationRequest["status"];
|
||||
if (eligible === true) {
|
||||
status = "verified";
|
||||
} else if (eligible === false) {
|
||||
status = "rejected";
|
||||
} else {
|
||||
status = "pending_review";
|
||||
}
|
||||
|
||||
const now = new Date().toISOString();
|
||||
const caseNum = String(requests.length + 1).padStart(3, "0");
|
||||
const newReq: DonationRequest = {
|
||||
id: uuidv4(),
|
||||
caseId: `CASE-${caseNum}`,
|
||||
beneficiaryName,
|
||||
nationalId,
|
||||
phone,
|
||||
source,
|
||||
sourceName,
|
||||
needType,
|
||||
requestedAmount: Number(requestedAmount),
|
||||
collectedAmount: 0,
|
||||
description,
|
||||
status,
|
||||
currentStep: STATUS_STEP[status],
|
||||
donorId: null,
|
||||
donorName: null,
|
||||
thankYouMessage: null,
|
||||
whatsappStatus: null,
|
||||
whatsappSentAt: null,
|
||||
rejectionReason:
|
||||
status === "rejected"
|
||||
? "المستفيد غير مؤهل وفق قاعدة بيانات الاستحقاق"
|
||||
: null,
|
||||
createdAt: now,
|
||||
updatedAt: now,
|
||||
};
|
||||
|
||||
requests.push(newReq);
|
||||
return res.status(201).json(newReq);
|
||||
});
|
||||
|
||||
// ─── GET /requests/:id ───────────────────────────────────────────────────────
|
||||
router.get("/requests/:id", (req, res) => {
|
||||
const item = requests.find((r) => r.id === req.params.id || r.caseId === req.params.id);
|
||||
if (!item) return res.status(404).json({ error: "Not found" });
|
||||
res.json(item);
|
||||
});
|
||||
|
||||
// ─── Helper: find & update ───────────────────────────────────────────────────
|
||||
function findAndUpdate(
|
||||
id: string,
|
||||
updater: (r: DonationRequest) => void,
|
||||
res: any
|
||||
) {
|
||||
const item = requests.find((r) => r.id === id || r.caseId === id);
|
||||
if (!item) return res.status(404).json({ error: "Not found" });
|
||||
updater(item);
|
||||
item.updatedAt = new Date().toISOString();
|
||||
res.json(item);
|
||||
}
|
||||
|
||||
// ─── POST /requests/:id/verify ───────────────────────────────────────────────
|
||||
router.post("/requests/:id/verify", (req, res) => {
|
||||
findAndUpdate(
|
||||
req.params.id,
|
||||
(r) => {
|
||||
r.status = "verified";
|
||||
r.currentStep = STATUS_STEP["verified"];
|
||||
},
|
||||
res
|
||||
);
|
||||
});
|
||||
|
||||
// ─── POST /requests/:id/publish ──────────────────────────────────────────────
|
||||
router.post("/requests/:id/publish", (req, res) => {
|
||||
findAndUpdate(
|
||||
req.params.id,
|
||||
(r) => {
|
||||
r.status = "published";
|
||||
r.currentStep = STATUS_STEP["published"];
|
||||
},
|
||||
res
|
||||
);
|
||||
});
|
||||
|
||||
// ─── POST /requests/:id/donate ───────────────────────────────────────────────
|
||||
router.post("/requests/:id/donate", (req, res) => {
|
||||
const item = requests.find(
|
||||
(r) => r.id === req.params.id || r.caseId === req.params.id
|
||||
);
|
||||
if (!item) return res.status(404).json({ error: "Not found" });
|
||||
|
||||
const { donorName, donorPhone, donorEmail, amount } = req.body;
|
||||
if (!donorName || !donorPhone || !amount) {
|
||||
return res.status(400).json({ error: "Missing donor details" });
|
||||
}
|
||||
|
||||
const donorId = uuidv4();
|
||||
// add/update donor record
|
||||
const existingDonor = donors.find((d) => d.phone === donorPhone);
|
||||
if (existingDonor) {
|
||||
existingDonor.totalDonated += Number(amount);
|
||||
existingDonor.donationCount += 1;
|
||||
item.donorId = existingDonor.id;
|
||||
} else {
|
||||
const newDonor = {
|
||||
id: donorId,
|
||||
name: donorName,
|
||||
phone: donorPhone,
|
||||
email: donorEmail || null,
|
||||
totalDonated: Number(amount),
|
||||
donationCount: 1,
|
||||
};
|
||||
donors.push(newDonor);
|
||||
item.donorId = donorId;
|
||||
}
|
||||
|
||||
item.donorName = donorName;
|
||||
item.collectedAmount = Number(amount);
|
||||
item.status = "donated";
|
||||
item.currentStep = STATUS_STEP["donated"];
|
||||
item.updatedAt = new Date().toISOString();
|
||||
res.json(item);
|
||||
});
|
||||
|
||||
// ─── POST /requests/:id/deliver ──────────────────────────────────────────────
|
||||
router.post("/requests/:id/deliver", (req, res) => {
|
||||
findAndUpdate(
|
||||
req.params.id,
|
||||
(r) => {
|
||||
r.status = "delivered";
|
||||
r.currentStep = STATUS_STEP["delivered"];
|
||||
},
|
||||
res
|
||||
);
|
||||
});
|
||||
|
||||
// ─── POST /requests/:id/confirm-receipt ──────────────────────────────────────
|
||||
router.post("/requests/:id/confirm-receipt", (req, res) => {
|
||||
findAndUpdate(
|
||||
req.params.id,
|
||||
(r) => {
|
||||
r.status = "receipt_confirmed";
|
||||
r.currentStep = STATUS_STEP["receipt_confirmed"];
|
||||
},
|
||||
res
|
||||
);
|
||||
});
|
||||
|
||||
// ─── POST /requests/:id/thank-you ────────────────────────────────────────────
|
||||
router.post("/requests/:id/thank-you", (req, res) => {
|
||||
const item = requests.find(
|
||||
(r) => r.id === req.params.id || r.caseId === req.params.id
|
||||
);
|
||||
if (!item) return res.status(404).json({ error: "Not found" });
|
||||
|
||||
const { message } = req.body;
|
||||
if (!message) return res.status(400).json({ error: "Message is required" });
|
||||
|
||||
item.thankYouMessage = message;
|
||||
item.status = "thank_you_submitted";
|
||||
item.currentStep = STATUS_STEP["thank_you_submitted"];
|
||||
item.whatsappStatus = "pending";
|
||||
item.updatedAt = new Date().toISOString();
|
||||
|
||||
// Create whatsapp log entry
|
||||
const logEntry: WhatsappLogEntry = {
|
||||
id: uuidv4(),
|
||||
caseId: item.caseId,
|
||||
donorName: item.donorName || "متبرع",
|
||||
donorPhone: donors.find((d) => d.id === item.donorId)?.phone || "",
|
||||
beneficiaryMessage: message,
|
||||
whatsappMessage: `السلام عليكم، نشكركم على تبرعكم عبر منصة إحسان.\nتم إيصال الدعم للمستفيد، وهذه رسالة الشكر من المستفيد:\n"${message}"\nرقم الحالة: ${item.caseId}`,
|
||||
status: "pending",
|
||||
sentAt: null,
|
||||
createdAt: new Date().toISOString(),
|
||||
};
|
||||
whatsappLog.push(logEntry);
|
||||
|
||||
res.json(item);
|
||||
});
|
||||
|
||||
// ─── POST /requests/:id/send-whatsapp ────────────────────────────────────────
|
||||
router.post("/requests/:id/send-whatsapp", async (req, res) => {
|
||||
const item = requests.find(
|
||||
(r) => r.id === req.params.id || r.caseId === req.params.id
|
||||
);
|
||||
if (!item) return res.status(404).json({ error: "Not found" });
|
||||
|
||||
const simulate = process.env.OPENCLAW_SIMULATE !== "false";
|
||||
const openclawUrl =
|
||||
process.env.OPENCLAW_BASE_URL || "http://localhost:3100";
|
||||
|
||||
const logEntry = whatsappLog.find((w) => w.caseId === item.caseId);
|
||||
const now = new Date().toISOString();
|
||||
|
||||
if (simulate) {
|
||||
// Simulate mode — mark as sent without calling OpenClaw
|
||||
item.whatsappStatus = "sent";
|
||||
item.whatsappSentAt = now;
|
||||
item.status = "whatsapp_sent";
|
||||
item.currentStep = STATUS_STEP["whatsapp_sent"];
|
||||
item.updatedAt = now;
|
||||
|
||||
if (logEntry) {
|
||||
logEntry.status = "sent";
|
||||
logEntry.sentAt = now;
|
||||
}
|
||||
|
||||
return res.json({
|
||||
success: true,
|
||||
message: "WhatsApp sent (simulated)",
|
||||
simulated: true,
|
||||
sentAt: now,
|
||||
});
|
||||
}
|
||||
|
||||
// Live mode — call OpenClaw
|
||||
try {
|
||||
const donor = donors.find((d) => d.id === item.donorId);
|
||||
const payload = {
|
||||
to: donor?.phone || "",
|
||||
message: logEntry?.whatsappMessage || "",
|
||||
caseId: item.caseId,
|
||||
};
|
||||
|
||||
const response = await fetch(`${openclawUrl}/api/whatsapp/send`, {
|
||||
method: "POST",
|
||||
headers: { "Content-Type": "application/json" },
|
||||
body: JSON.stringify(payload),
|
||||
});
|
||||
|
||||
if (!response.ok) {
|
||||
throw new Error(`OpenClaw returned ${response.status}`);
|
||||
}
|
||||
|
||||
item.whatsappStatus = "sent";
|
||||
item.whatsappSentAt = now;
|
||||
item.status = "whatsapp_sent";
|
||||
item.currentStep = STATUS_STEP["whatsapp_sent"];
|
||||
item.updatedAt = now;
|
||||
|
||||
if (logEntry) {
|
||||
logEntry.status = "sent";
|
||||
logEntry.sentAt = now;
|
||||
}
|
||||
|
||||
return res.json({
|
||||
success: true,
|
||||
message: "WhatsApp sent via OpenClaw",
|
||||
simulated: false,
|
||||
sentAt: now,
|
||||
});
|
||||
} catch (err: any) {
|
||||
item.whatsappStatus = "failed";
|
||||
item.updatedAt = now;
|
||||
|
||||
if (logEntry) {
|
||||
logEntry.status = "failed";
|
||||
}
|
||||
|
||||
return res.json({
|
||||
success: false,
|
||||
message: `Failed to send via OpenClaw: ${err.message}`,
|
||||
simulated: false,
|
||||
sentAt: null,
|
||||
});
|
||||
}
|
||||
});
|
||||
|
||||
// ─── POST /requests/:id/close ────────────────────────────────────────────────
|
||||
router.post("/requests/:id/close", (req, res) => {
|
||||
findAndUpdate(
|
||||
req.params.id,
|
||||
(r) => {
|
||||
r.status = "closed";
|
||||
r.currentStep = STATUS_STEP["closed"];
|
||||
},
|
||||
res
|
||||
);
|
||||
});
|
||||
|
||||
// ─── POST /requests/:id/reject ───────────────────────────────────────────────
|
||||
router.post("/requests/:id/reject", (req, res) => {
|
||||
const item = requests.find(
|
||||
(r) => r.id === req.params.id || r.caseId === req.params.id
|
||||
);
|
||||
if (!item) return res.status(404).json({ error: "Not found" });
|
||||
|
||||
item.status = "rejected";
|
||||
item.currentStep = STATUS_STEP["rejected"];
|
||||
item.rejectionReason = req.body?.reason || "تم الرفض من قبل المشرف";
|
||||
item.updatedAt = new Date().toISOString();
|
||||
res.json(item);
|
||||
});
|
||||
|
||||
export default router;
|
||||
Reference in New Issue
Block a user