From d977ea8945dfbffbde064c19ca2fbf1a94963412 Mon Sep 17 00:00:00 2001
From: Spencer Wohlers <4006420+seidior@users.noreply.github.com>
Date: Fri, 9 Aug 2024 11:46:02 -0400
Subject: [PATCH] chore: wip better error messages for failing test [skip ci]

---
 api/src/db/DynamoUserDataClient.ts | 87 +++++++++++++++++++-----------
 1 file changed, 55 insertions(+), 32 deletions(-)

diff --git a/api/src/db/DynamoUserDataClient.ts b/api/src/db/DynamoUserDataClient.ts
index 1998e7636b..bc73e9b1d8 100644
--- a/api/src/db/DynamoUserDataClient.ts
+++ b/api/src/db/DynamoUserDataClient.ts
@@ -49,18 +49,27 @@ export const DynamoUserDataClient = (db: DynamoDBDocumentClient, tableName: stri
         ":email": { S: email },
       },
     };
-    return db
-      .send(new QueryCommand(params))
-      .then(async (result) => {
-        if (!result.Items || result.Items.length !== 1) {
-          return;
-        }
-        return await doMigration(unmarshall(result.Items[0], unmarshallOptions).data);
-      })
-      .catch((error) => {
-        console.log(error);
-        throw new Error("Not found");
-      });
+    try {
+      const queryCommand = new QueryCommand(params);
+      return db
+        .send(queryCommand)
+        .then(async (result) => {
+          if (!result.Items || result.Items.length !== 1) {
+            return;
+          }
+          const unmarshalledItem = unmarshall(result.Items[0], unmarshallOptions);
+          console.log({ unmarshalledItem: JSON.stringify(unmarshalledItem, undefined, 2) });
+          const migratedData = await doMigration(unmarshalledItem.data);
+          console.log({ migratedData: JSON.stringify(migratedData, undefined, 2) });
+          return migratedData;
+        })
+        .catch((error) => {
+          console.log(error);
+          throw new Error(`Not found: ${error}`);
+        });
+    } catch (error) {
+      throw new Error(`problem with queryCommand: ${error}`);
+    }
   };
 
   const get = (userId: string): Promise<UserData> => {
@@ -70,22 +79,30 @@ export const DynamoUserDataClient = (db: DynamoDBDocumentClient, tableName: stri
         userId: userId,
       },
     };
-    return db
-      .send(new GetCommand(params))
-
-      .then(async (result) => {
-        if (!result.Item) {
-          throw new Error("Not found");
-        }
-        return await doMigration(result.Item.data);
-      })
-      .catch((error) => {
-        throw error;
-      });
+
+    try {
+      const getCommand = new GetCommand(params);
+
+      return db
+        .send(getCommand)
+
+        .then(async (result) => {
+          if (!result.Item) {
+            throw new Error("Not found");
+          }
+          return await doMigration(result.Item.data);
+        })
+        .catch((error) => {
+          throw new Error(`problem with db.send: ${error}`);
+        });
+    } catch (error) {
+      throw new Error(`problem with getcommand: ${error}`);
+    }
   };
 
   const put = (userData: UserData): Promise<UserData> => {
     const migratedData = migrateUserData(userData);
+    console.log(JSON.stringify(migratedData, undefined, 2));
     const params = {
       TableName: tableName,
       Item: {
@@ -95,14 +112,20 @@ export const DynamoUserDataClient = (db: DynamoDBDocumentClient, tableName: stri
       },
     };
 
-    return db
-      .send(new PutCommand(params))
-      .then(() => {
-        return migratedData;
-      })
-      .catch((error) => {
-        throw error;
-      });
+    try {
+      const putCommand = new PutCommand(params);
+
+      return db
+        .send(putCommand)
+        .then(() => {
+          return migratedData;
+        })
+        .catch((error) => {
+          throw new Error(`problem with db.send: ${error}`);
+        });
+    } catch (error) {
+      throw new Error(`problem with PutCommand: ${error}`);
+    }
   };
 
   const getNeedNewsletterUsers = (): Promise<UserData[]> => {