fix(server): add wait until table exists before inserting

kritish-dhaubanjar · Jan 21, 2025 · 65fdf53 · 65fdf53
1 parent f7fe18f
commit 65fdf53
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/server/src/services/table.service.js b/server/src/services/table.service.js
@@ -2,6 +2,7 @@ import AWS from "../config/aws";
 import { OPERATIONS } from "../constants/dynamodb";
 import { constructSchema } from "../utils/dynamodb";
 import DatabaseServiceProvider from "./database.service";
+import { waitUntilTableExists } from "@aws-sdk/client-dynamodb";
 
 export default class TableServiceProvider {
   /**
@@ -140,7 +141,12 @@ export default class TableServiceProvider {
     const { Table } = await DatabaseServiceProvider.SOURCE.TableService.describe(tableName);
 
     await Promise.allSettled([DatabaseServiceProvider.TARGET.TableService.destroy(tableName)]);
-    await DatabaseServiceProvider.TARGET.TableService.create(constructSchema(Table));
+    await Promise.allSettled([DatabaseServiceProvider.TARGET.TableService.create(constructSchema(Table))]);
+
+    await waitUntilTableExists(
+      { client: DatabaseServiceProvider.TARGET.AWS.dynamodb, maxWaitTime: 60 },
+      { TableName: tableName },
+    );
 
     const params = { Limit: 100 };
     const schema = Table.KeySchema.map(({ AttributeName }) => AttributeName);