Support real-time point updates

regalijan · Nov 18, 2024 · d112796 · d112796
1 parent 5f3ffc0
commit d112796
Show file tree

Hide file tree

Showing 3 changed files with 86 additions and 15 deletions.
diff --git a/functions/api/events-team/events/[id]/certify.ts b/functions/api/events-team/events/[id]/certify.ts
@@ -4,11 +4,35 @@ export async function onRequestPost(context: RequestContext) {
   if (context.data.event.reached_minimum_player_count)
     return jsonError("This event is already certified", 400);
 
-  await context.env.D1.prepare(
-    "UPDATE events SET reached_minimum_player_count = 1 WHERE id = ?;",
-  )
-    .bind(context.data.event.id)
-    .run();
+  const { D1 } = context.env;
+
+  await D1.exec("BEGIN TRANSACTION;");
+
+  try {
+    const row = await D1.prepare(
+      "UPDATE events SET reached_minimum_player_count = 1 WHERE id = ? RETURNING created_by;",
+    )
+      .bind(context.data.event.id)
+      .first();
+
+    if (!row) {
+      await D1.exec("ROLLBACK;");
+      return jsonError("Event does not exist", 404);
+    }
+
+    await D1.prepare("UPDATE et_members SET points = points + 10 WHERE id = ?;")
+      .bind(row.created_by)
+      .run();
+    await D1.exec("COMMIT;");
+  } catch (e) {
+    console.log(e);
+    await D1.exec("ROLLBACK;");
+
+    return jsonError(
+      "Failed to certify event because the event or points could not be updated",
+      500,
+    );
+  }
 
   return new Response(null, {
     status: 204,

diff --git a/functions/api/events-team/events/[id]/complete.ts b/functions/api/events-team/events/[id]/complete.ts
@@ -1,11 +1,34 @@
+import { jsonError } from "../../../../common.js";
+
 export async function onRequestPost(context: RequestContext) {
   const id = context.params.id as string;
+  const { D1 } = context.env;
+
+  await D1.exec("BEGIN TRANSACTION;");
+
+  try {
+    const row = await D1.prepare(
+      "UPDATE events SET performed_at = ? WHERE id = ? RETURNING created_by;",
+    )
+      .bind(Date.now(), id)
+      .first();
+
+    if (!row) {
+      await D1.exec("ROLLBACK;");
+      return jsonError("Event does not exist", 404);
+    }
+
+    await D1.prepare("UPDATE et_members SET points = points + 10 WHERE id = ?;")
+      .bind(row.created_by)
+      .run();
+
+    await D1.exec("COMMIT;");
+  } catch (e) {
+    console.log(e);
+    await D1.exec("ROLLBACK;");
 
-  await context.env.D1.prepare(
-    "UPDATE events SET performed_at = ? WHERE id = ?;",
-  )
-    .bind(Date.now(), id)
-    .run();
+    return jsonError("Failed to update event data", 500);
+  }
 
   return new Response(null, {
     status: 204,

diff --git a/functions/api/events-team/events/[id]/forgotten.ts b/functions/api/events-team/events/[id]/forgotten.ts
@@ -1,11 +1,35 @@
+import { jsonError } from "../../../../common.js";
+
 export async function onRequestPost(context: RequestContext) {
   const id = context.params.id as string;
+  const { D1 } = context.env;
+
+  await D1.exec("BEGIN TRANSACTION;");
+
+  try {
+    const row = await D1.prepare(
+      "UPDATE events SET performed_at = 0 WHERE id = ? RETURNING created_by;",
+    )
+      .bind(id)
+      .first();
+
+    if (!row) {
+      await D1.exec("ROLLBACK;");
+      return jsonError("Nonexistent event cannot be marked as forgotten.", 404);
+    }
+
+    await D1.prepare("UPDATE et_members SET points = points - 5 WHERE id = ?;")
+      .bind(row.created_by)
+      .run();
+  } catch (e) {
+    console.log(e);
+    await D1.exec("ROLLBACK;");
 
-  await context.env.D1.prepare(
-    "UPDATE events SET performed_at = 0 WHERE id = ?;",
-  )
-    .bind(id)
-    .run();
+    return jsonError(
+      "Failed to mark event as forgotten, points were not changed.",
+      500,
+    );
+  }
 
   return new Response(null, {
     status: 204,