Insert inactivity notices into D1

functions/api/inactivity/new.ts

@@ -43,20 +43,25 @@ export async function onRequestPost(context: RequestContext) {
       status: 400,
     });
 
-  if (!departments.every(d => context.data.departments.includes(d)))
-    return new Response('{"error":"Cannot file a notice in a department you are not part of"}', {
+  if (!departments.every((d) => context.data.departments.includes(d)))
+    return new Response(
+      '{"error":"Cannot file a notice in a department you are not part of"}',
+      {
         headers: {
           "content-type": "application/json",
         },
         status: 400,
-    });
+      }
+    );
 
   const inactivityId =
     context.data.current_user.id +
     (context.request.headers.get("cf-ray") as string).split("-")[0] +
     Date.now().toString();
 
-  await context.env.DATA.put(`inactivity_${inactivityId}`, JSON.stringify({
+  await context.env.DATA.put(
+    `inactivity_${inactivityId}`,
+    JSON.stringify({
       created_at: Date.now(),
       departments,
       end,
@@ -67,9 +72,17 @@ export async function onRequestPost(context: RequestContext) {
         id: context.data.current_user.id,
         username: context.data.current_user.username,
       },
-  }), {
-    expirationTtl: 63072000
-  });
+    }),
+    {
+      expirationTtl: 63072000,
+    }
+  );
+
+  await context.env.D1.prepare(
+    "INSERT INTO inactivity_notices (created_at, id, user) VALUES (?, ?, ?);"
+  )
+    .bind(Date.now(), inactivityId, context.data.current_user.id)
+    .run();
 
   return new Response(null, {
     status: 204,