Read review from Dynamo DB too

Author: sharathkumaranbu

constants.js

@@ -15,6 +15,9 @@ const busApiMeta = {
   }
 }
 
+const submissionIndex = 'submissionId-index'
+
 module.exports = {
-  busApiMeta
+  busApiMeta,
+  submissionIndex
 }

src/common/dbhelper.js

@@ -158,6 +158,23 @@ function * scanRecords (params) {
   })
 }
 
+/**
+ * Get records from DynamoDB based on the secondary index filter
+ * @param     {object} filter Secondary index filter to be applied on the database
+ * @return    {promise}
+ */
+function * queryRecords (filter) {
+  const dbClient = getDbClient()
+  return new Promise((resolve, reject) => {
+    dbClient.query(filter, (err, data) => {
+      if (err) {
+        reject(err)
+      }
+      resolve(data)
+    })
+  })
+}
+
 // exports the functions
 module.exports = {
   getDb,
@@ -168,5 +185,6 @@ module.exports = {
   getRecord,
   updateRecord,
   deleteRecord,
-  scanRecords
+  scanRecords,
+  queryRecords
 }

src/models/Review.js

@@ -3,19 +3,39 @@
  */
 
 const config = require('config')
+const { submissionIndex } = require('../../constants')
 
 const Review = {
   TableName: 'Review',
   KeySchema: [
     { AttributeName: 'id', KeyType: 'HASH' } // Partition key
   ],
   AttributeDefinitions: [
-    { AttributeName: 'id', AttributeType: 'S' } // S -> String
+    { AttributeName: 'id', AttributeType: 'S' }, // S -> String
+    { AttributeName: 'submissionId', AttributeType: 'S' }
   ],
   ProvisionedThroughput: {
     ReadCapacityUnits: config.aws.AWS_READ_UNITS,
     WriteCapacityUnits: config.aws.AWS_WRITE_UNITS
-  }
+  },
+  GlobalSecondaryIndexes: [
+    {
+      IndexName: submissionIndex,
+      KeySchema: [
+        {
+          AttributeName: 'submissionId',
+          KeyType: 'HASH'
+        }
+      ],
+      Projection: {
+        ProjectionType: 'ALL'
+      },
+      ProvisionedThroughput: {
+        ReadCapacityUnits: 1,
+        WriteCapacityUnits: 1
+      }
+    }
+  ]
 }
 
 module.exports = {

src/models/ReviewSummation.js

@@ -3,19 +3,39 @@
  */
 
 const config = require('config')
+const { submissionIndex } = require('../../constants')
 
 const ReviewSummation = {
   TableName: 'ReviewSummation',
   KeySchema: [
     { AttributeName: 'id', KeyType: 'HASH' } // Partition key
   ],
   AttributeDefinitions: [
-    { AttributeName: 'id', AttributeType: 'S' } // S -> String
+    { AttributeName: 'id', AttributeType: 'S' }, // S -> String
+    { AttributeName: 'submissionId', AttributeType: 'S' }
   ],
   ProvisionedThroughput: {
     ReadCapacityUnits: config.aws.AWS_READ_UNITS,
     WriteCapacityUnits: config.aws.AWS_WRITE_UNITS
-  }
+  },
+  GlobalSecondaryIndexes: [
+    {
+      IndexName: submissionIndex,
+      KeySchema: [
+        {
+          AttributeName: 'submissionId',
+          KeyType: 'HASH'
+        }
+      ],
+      Projection: {
+        ProjectionType: 'ALL'
+      },
+      ProvisionedThroughput: {
+        ReadCapacityUnits: 1,
+        WriteCapacityUnits: 1
+      }
+    }
+  ]
 }
 
 module.exports = {

src/services/SubmissionService.js

@@ -12,6 +12,7 @@ const uuid = require('uuid/v4')
 const dbhelper = require('../common/dbhelper')
 const helper = require('../common/helper')
 const { originator, mimeType, fileType, events } = require('../../constants').busApiMeta
+const { submissionIndex } = require('../../constants')
 const s3 = new AWS.S3()
 const logger = require('winston')
 
@@ -58,7 +59,34 @@ function * _getSubmission (submissionId) {
     }
   }
   const result = yield dbhelper.getRecord(filter)
-  return result.Item
+  const submission = result.Item
+  // Fetch associated reviews
+  const reviewFilter = {
+    TableName: 'Review',
+    IndexName: submissionIndex,
+    KeyConditionExpression: 'submissionId = :p_submissionId',
+    ExpressionAttributeValues: {
+      ':p_submissionId': submissionId
+    }
+  }
+  const review = yield dbhelper.queryRecords(reviewFilter)
+  if (review.Count !== 0) {
+    submission.review = review.Items
+  }
+  // Fetch associated review summations
+  const reviewSummationFilter = {
+    TableName: 'ReviewSummation',
+    IndexName: submissionIndex,
+    KeyConditionExpression: 'submissionId = :p_submissionId',
+    ExpressionAttributeValues: {
+      ':p_submissionId': submissionId
+    }
+  }
+  const reviewSummation = yield dbhelper.queryRecords(reviewSummationFilter)
+  if (reviewSummation.Count !== 0) {
+    submission.reviewSummation = reviewSummation.Items
+  }
+  return submission
 }
 
 /**