Create app.js

app.js

@@ -0,0 +1,151 @@
+import express from "express";
+import bodyParser from "body-parser";
+import crypto from "crypto";
+
+const app = express();
+app.use(bodyParser.json());
+
+/* ===== ENV (dari HF Spaces) ===== */
+const PROJECT = process.env.PAKASIR_PROJECT;
+const API_KEY = process.env.PAKASIR_API_KEY;
+const WEBHOOK_SECRET = process.env.WEBHOOK_SECRET || "pakasir";
+
+/* ===== In-memory storage (cukup untuk HF Space) ===== */
+const transactions = new Map(); // order_id => data
+const clients = new Map();      // order_id => [res,res]
+
+/* ===== Helper ===== */
+function sendEvent(order_id, payload) {
+  const arr = clients.get(order_id) || [];
+  for (const res of arr) {
+    res.write(`data: ${JSON.stringify(payload)}\n\n`);
+  }
+}
+
+/* ===== CREATE TRANSACTION ===== */
+app.post("/create", async (req, res) => {
+  try {
+    const { amount } = req.body;
+    if (!amount || amount < 1000) {
+      return res.status(400).json({ error: "amount invalid" });
+    }
+
+    const order_id = `INV-${Date.now()}`;
+
+    const r = await fetch("https://app.pakasir.com/api/transactioncreate/qris", {
+      method: "POST",
+      headers: { "Content-Type": "application/json" },
+      body: JSON.stringify({
+        project: PROJECT,
+        api_key: API_KEY,
+        order_id,
+        amount
+      })
+    });
+
+    const j = await r.json();
+    const payment = j.payment || j;
+
+    const code = j.code || payment.code || "";
+    const qris_string = payment.payment_number || j.qris_string || "";
+
+    const qr_url = code
+      ? `https://app.pakasir.com/qris/${code}.png`
+      : `https://quickchart.io/qr?text=${encodeURIComponent(qris_string)}&size=500`;
+
+    transactions.set(order_id, {
+      order_id,
+      amount,
+      status: "PENDING"
+    });
+
+    res.json({
+      success: true,
+      order_id,
+      qr_url,
+      raw: j
+    });
+  } catch (e) {
+    console.error(e);
+    res.status(500).json({ error: "failed create transaction" });
+  }
+});
+
+/* ===== SSE REALTIME ===== */
+app.get("/events/:order_id", (req, res) => {
+  const { order_id } = req.params;
+
+  res.writeHead(200, {
+    "Content-Type": "text/event-stream",
+    "Cache-Control": "no-cache",
+    Connection: "keep-alive"
+  });
+  res.write("\n");
+
+  const arr = clients.get(order_id) || [];
+  arr.push(res);
+  clients.set(order_id, arr);
+
+  req.on("close", () => {
+    const updated = (clients.get(order_id) || []).filter(r => r !== res);
+    if (updated.length === 0) clients.delete(order_id);
+    else clients.set(order_id, updated);
+  });
+});
+
+/* ===== WEBHOOK PAKASIR ===== */
+app.post("/webhook", async (req, res) => {
+  try {
+    const body = req.body;
+    const order_id = body.payment?.order_id || body.order_id;
+    const status = (body.payment?.status || body.status || "").toUpperCase();
+
+    if (!order_id) return res.status(400).send("no order_id");
+
+    if (transactions.has(order_id)) {
+      const tx = transactions.get(order_id);
+      tx.status = status;
+      transactions.set(order_id, tx);
+    }
+
+    sendEvent(order_id, { order_id, status });
+    res.json({ ok: true });
+  } catch (e) {
+    console.error(e);
+    res.status(500).send("webhook error");
+  }
+});
+
+/* ===== POLLING FALLBACK ===== */
+app.get("/status/:order_id", async (req, res) => {
+  try {
+    const { order_id } = req.params;
+
+    const url = `https://app.pakasir.com/api/transactiondetail?project=${PROJECT}&order_id=${order_id}&api_key=${API_KEY}`;
+    const r = await fetch(url);
+    const j = await r.json();
+
+    const tx = j.transaction || j;
+    const status = (tx.status || "UNKNOWN").toUpperCase();
+
+    if (transactions.has(order_id)) {
+      transactions.get(order_id).status = status;
+    }
+
+    res.json({ order_id, status, raw: j });
+  } catch (e) {
+    console.error(e);
+    res.status(500).json({ error: "status error" });
+  }
+});
+
+/* ===== HEALTH ===== */
+app.get("/", (req, res) => {
+  res.json({
+    name: "Pakasir Real-Time API",
+    status: "running"
+  });
+});
+
+const PORT = process.env.PORT || 7860;
+app.listen(PORT, () => console.log("RUNNING ON", PORT));