feat(users router): write to both but only fail RDS

icssc · Dec 7, 2024 · 97153af · 97153af
1 parent 7d87792
commit 97153af
Showing 1 changed file with 13 additions and 2 deletions.
diff --git a/apps/backend/src/routers/users.ts b/apps/backend/src/routers/users.ts
@@ -8,6 +8,8 @@ import { mangleDupliateScheduleNames } from 'src/lib/formatting';
 import { RDS } from 'src/lib/rds';
 import { TRPCError } from '@trpc/server';
 import { procedure, router } from '../trpc';
+import { ddbClient } from '$db/ddb';
+
 
 const userInputSchema = type([{ userId: 'string' }, '|', { googleId: 'string' }]);
 
@@ -52,8 +54,17 @@ const usersRouter = router({
                 // Mangle duplicate schedule names
                 data.userData.schedules = mangleDupliateScheduleNames(data.userData.schedules);
 
-                await RDS.upsertGuestUserData(db, data)
-                    .catch((error) => console.error('Failed to upsert user data:', error));
+                // Await both, but only throw if RDS save fails.
+                const results = await Promise.allSettled([
+                    ddbClient.insertItem(data)
+                        .catch((error) => console.error('DDB Failed to save user data:', error)),
+                    RDS.upsertGuestUserData(db, data)
+                        .catch((error) => console.error('RDS Failed to upsert user data:', error))
+                ]);
+
+                if (results[1].status === 'rejected') {
+                    throw results[1].reason;
+                }
             }
         ),
 });