Delete transaction token if transaction is cancelled

ebs/src/modules/transactions.ts

@@ -4,7 +4,7 @@ import { app } from "../index";
 import { parseJWT, verifyJWT } from "../util/jwt";
 import { BitsTransactionPayload } from "../types";
 import { getConfig } from "./config";
-import { getPrepurchase, isReceiptUsed, isUserBanned, registerPrepurchase } from "../util/db";
+import { getPrepurchase, isReceiptUsed, isUserBanned, registerPrepurchase, deletePrepurchase } from "../util/db";
 import { logToDiscord } from "../util/logger";
 import { connection } from "./game";
 
@@ -203,3 +203,16 @@ app.post("/public/transaction", async (req, res) => {
 
     res.sendStatus(200);
 });
+
+app.post("/public/transaction/cancel", async (req, res) => {
+    const token = req.body as string;
+
+    // remove transaction from db
+    try {
+        await deletePrepurchase(token);
+
+        res.sendStatus(200);
+    } catch (error) {
+        res.sendStatus(404);
+    }
+});

ebs/src/util/db.ts

@@ -96,6 +96,16 @@ export async function getPrepurchase(token: string): Promise<IdentifiableCart |
     }
 }
 
+export async function deletePrepurchase(token: string) {
+    try {
+        await db.query("DELETE FROM prepurchases WHERE token = ?", [token]);
+    } catch (e: any) {
+        console.error("Database query failed (deletePrepurchase)");
+        console.error(e);
+        throw new Error("Database query failed");
+    }
+}
+
 export async function isUserBanned(userId: string): Promise<boolean> {
     try {
         const [rows] = (await db.query("SELECT COUNT(*) FROM bans WHERE userId = ?", [userId])) as [RowDataPacket[], any];

frontend/www/src/modules/auth.ts

@@ -97,6 +97,13 @@ Twitch.ext.bits.onTransactionCancelled(async () => {
             ],
         }).then();
     }
+    await ebsFetch("/public/transaction/cancel", {
+        method: "POST",
+        headers: {
+            "Content-Type": "application/json",
+        },
+        body: transactionToken,
+    });
     hideProcessingModal();
     showErrorModal("Transaction cancelled.", `Transaction ID: ${transactionToken}`);
 });