clean up expired events from user object

related to #11

src-ts/shared/handlers/auth-status.ts

@@ -1,11 +1,33 @@
 import { HttpFunctionResponse } from "@architect/shared/begin";
 import { withOptionalUser } from "../auth";
+import { updateUser, User } from "../user/storage";
 import { getJWTCookieName, getJWTSecret } from "../utils";
 
+async function invalidateMyEvents(user: User): Promise<void> {
+  let hasExpired = false;
+  const myEvents = user.myEvents ?? {};
+  const now = new Date();
+  for (const event of Object.values(myEvents)) {
+    const end = new Date(event.end);
+    if (end < now) {
+      delete myEvents[event.publicId];
+      hasExpired = true;
+    }
+  }
+
+  if (hasExpired) {
+    await updateUser(user);
+  }
+}
+
 export const handler = withOptionalUser(
   getJWTCookieName(),
   getJWTSecret(),
   async (_, user): Promise<HttpFunctionResponse> => {
+    if (user) {
+      await invalidateMyEvents(user);
+    }
+
     return {
       statusCode: 200,
       body: JSON.stringify({

src-ts/shared/user/storage.ts

@@ -7,7 +7,7 @@ const USER_TABLE = "USERS";
 const MyEvent = R.Record({
   publicId: R.String,
   summary: R.String,
-  start: R.String,
+  end: R.String,
 });
 export type MyEvent = R.Static<typeof MyEvent>;
 
@@ -61,19 +61,19 @@ export async function updateMyEvent(user: User, event: MyEvent): Promise<void> {
   }
 
   // include only expected fields
-  const { publicId, start, summary } = event;
+  const { publicId, end, summary } = event;
   const updatedUser = {
     ...user,
     myEvents: {
       ...user.myEvents,
-      [event.publicId]: { publicId, start, summary },
+      [event.publicId]: { publicId, end, summary },
     },
   };
   await updateUser(updatedUser);
 }
 
 function areEventsEqual(a: MyEvent, b: MyEvent): boolean {
   return (
-    a.publicId === b.publicId && a.start === b.start && a.summary === b.summary
+    a.publicId === b.publicId && a.end === b.end && a.summary === b.summary
   );
 }