fix: recreating thread table with proper lsi (#261)

wasedatime · Mar 17, 2023 · a79f43b · a79f43b
1 parent 9179913
commit a79f43b
Show file tree

Hide file tree

Showing 2 changed files with 32 additions and 34 deletions.
diff --git a/lib/constructs/persistence/database.ts b/lib/constructs/persistence/database.ts
@@ -82,36 +82,36 @@ export class DynamoDatabase extends Construct {
       },
     );
 
-    // this.tables[Collection.THREAD] = new dynamodb.Table(
-    //   this,
-    //   'dynamodb-thread-table',
-    //   {
-    //     partitionKey: {
-    //       name: 'board_id',
-    //       type: dynamodb.AttributeType.STRING,
-    //     },
-    //     billingMode: dynamodb.BillingMode.PROVISIONED,
-    //     encryption: dynamodb.TableEncryption.DEFAULT,
-    //     removalPolicy: RemovalPolicy.DESTROY,
-    //     sortKey: { name: 'created_at', type: dynamodb.AttributeType.STRING },
-    //     tableName: 'forum-threads',
-    //     readCapacity: 15,
-    //     writeCapacity: 15,
-    //     pointInTimeRecovery: true,
-    //   },
-    // );
+    this.tables[Collection.THREAD] = new dynamodb.Table(
+      this,
+      'dynamodb-thread-table',
+      {
+        partitionKey: {
+          name: 'board_id',
+          type: dynamodb.AttributeType.STRING,
+        },
+        billingMode: dynamodb.BillingMode.PROVISIONED,
+        encryption: dynamodb.TableEncryption.DEFAULT,
+        removalPolicy: RemovalPolicy.DESTROY,
+        sortKey: { name: 'created_at', type: dynamodb.AttributeType.STRING },
+        tableName: 'forum-threads',
+        readCapacity: 15,
+        writeCapacity: 15,
+        pointInTimeRecovery: true,
+      },
+    );
 
-    // this.tables[Collection.THREAD].addLocalSecondaryIndex({
-    //   indexName: 'GroupIndex',
-    //   sortKey: { name: 'group_id', type: dynamodb.AttributeType.NUMBER },
-    //   projectionType: dynamodb.ProjectionType.ALL,
-    // });
+    this.tables[Collection.THREAD].addLocalSecondaryIndex({
+      indexName: 'GroupIndex',
+      sortKey: { name: 'group_id', type: dynamodb.AttributeType.STRING },
+      projectionType: dynamodb.ProjectionType.ALL,
+    });
 
-    // this.tables[Collection.THREAD].addLocalSecondaryIndex({
-    //   indexName: "TagIndex",
-    //   sortKey: { name: "tag_id", type: dynamodb.AttributeType.NUMBER },
-    //   projectionType: dynamodb.ProjectionType.ALL,
-    // });
+    this.tables[Collection.THREAD].addLocalSecondaryIndex({
+      indexName: 'TagIndex',
+      sortKey: { name: 'tag_id', type: dynamodb.AttributeType.STRING },
+      projectionType: dynamodb.ProjectionType.ALL,
+    });
 
     // this.tables[Collection.THREAD].addGlobalSecondaryIndex({
     //   indexName: "UidbyCreated_at",

diff --git a/lib/stacks/persistence.ts b/lib/stacks/persistence.ts
@@ -61,12 +61,10 @@ export class WasedaTimePersistenceLayer extends PersistenceLayer {
       syllabusDataPipeline.dataWarehouse.bucketName,
     );
 
-    // this.dataInterface.setEndpoint(
-    //   DataEndpoint.THREAD,
-    //   dynamoDatabase.tables[Collection.THREAD].tableName,
-    // );
-    // this.exportValue(dynamoDatabase.tables[Collection.THREAD].tableName);
-    // this.exportValue(dynamoDatabase.tables[Collection.THREAD].tableArn);
+    this.dataInterface.setEndpoint(
+      DataEndpoint.THREAD,
+      dynamoDatabase.tables[Collection.THREAD].tableName,
+    );
 
     this.dataInterface.setEndpoint(
       DataEndpoint.COMMENT,