backup

Author: jacksoncharles

api/create.js

@@ -12,11 +12,11 @@ module.exports.create = (event, context, callback) => {
     const requestBody = JSON.parse(event.body); // User submitted data
 
     // Grab the individual elements of the post.
+    const userId = requestBody.userId;
+    const parentId = requestBody.parentId;
+    const correctAnswer = requestBody.correctAnswer;
     const title = requestBody.title;
     const body = requestBody.body;
-    const user_id = requestBody.user_id;
-    const parent_id = requestBody.parent_id;
-
 
     /**
      * Save the post to permanent storage
@@ -29,7 +29,7 @@ module.exports.create = (event, context, callback) => {
         console.log('Submitting post');
 
         const postDetail = {
-            TableName: process.env.POST_TABLE,
+            TableName: process.env.DYNAMODB_TABLE,
             Item: post,
         };
 
@@ -48,20 +48,22 @@ module.exports.create = (event, context, callback) => {
         const timestamp = new Date().getTime();
         return {
             id: uuid.v1(),
-            user_id: data.user_id,
-            parent_id: data.parent_id,
+            userId: data.userId,
+            parentId: data.parentId,
+            correctAnswer: data.correctAnswer,
             title: data.title,
             body: data.body,
             createdAt: timestamp,
-            updatedAt: timestamp
+            updatedAt: timestamp,
+            dummyHashKey: 'OK'
         };
     };
 
     // Validate the submitted data
     if (
         typeof title !== 'string' || 
         typeof body !== 'string' || 
-        typeof user_id !== 'number'
+        typeof userId !== 'number'
     ) {
         console.error('Validation Failed');
         callback(new Error('Couldn\'t submit post because of validation errors.'));

api/delete.js

@@ -7,7 +7,7 @@ const dynamoDb = new AWS.DynamoDB.DocumentClient();
 module.exports.delete = (event, context, callback) => {
 
   const params = {
-    TableName: process.env.POST_TABLE,
+    TableName: process.env.DYNAMODB_TABLE,
     Key: {
       id: event.pathParameters.id,
     },

api/get.js

@@ -7,7 +7,7 @@ const dynamoDb = new AWS.DynamoDB.DocumentClient();
 module.exports.get = (event, context, callback) => {
 
     const params = {
-        TableName: process.env.POST_TABLE,
+        TableName: process.env.DYNAMODB_TABLE,
         Key: {
             id: event.pathParameters.id,
         },

api/list.js

@@ -1,27 +1,76 @@
 'use strict';
 
 const AWS = require('aws-sdk'); // eslint-disable-line import/no-extraneous-dependencies
-
 const dynamoDb = new AWS.DynamoDB.DocumentClient();
+
+/*
+var params = {
+     TableName: process.env.DYNAMODB_TABLE,
+     Limit: 10
+};
+
 var params = {
-  TableName: process.env.POST_TABLE,
-  Limit: 10
+
+     TableName: process.env.DYNAMODB_TABLE,
+     IndexName: "UpdatedAtIndex",
+     ScanIndexForward: true
 };
+*/
+
+const params = {
+     TableName: process.env.DYNAMODB_TABLE,
+     Limit: 5,
+     IndexName: 'UpdatedAtIndex',
+     KeyConditionExpression: 'dummyHashKey = :x',
+     ExpressionAttributeValues: {
+          ':x': 'OK'
+     },
+     ProjectionExpression: "id, userId, parentId, correctAnswer, title, body, createdAt, updatedAt"
+}
+
 
 module.exports.list = (event, context, callback) => {
 
+     // Do we have any parameters?
+     /*
      if( event.queryStringParameters !== null && typeof event.queryStringParameters === 'object' ) {
 
-          if( event.queryStringParameters.hasOwnProperty('limit') ) {
+          // Do we have a limit clause?
+          if( event.queryStringParameters.hasOwnProperty('limit') ) params.Limit = event.queryStringParameters.limit;
 
-               params.Limit = event.queryStringParameters.limit;
-          }
+          // Do we have a page number?
      }
+     */
+     dynamoDb.query(params, function(error, data) {
+
+          // Handle potential errors
+          if (error) {
+
+               console.error(error);
+               callback(null, {
+                    statusCode: error.statusCode || 501,
+                    headers: { 'Content-Type': 'text/plain' },
+                    body: 'Couldn\'t fetch the posts.',
+               });
+
+               return;
+          }
+
+          // Create a response
+          const response = {
+               statusCode: 200,
+               body: JSON.stringify(data),
+          };
+
+          callback(null, response);
+
+     });
 
-     // fetch all posts from the database
+     // Fetch all posts from the database
+     /*
      dynamoDb.scan(params, (error, result) => {
 
-          // handle potential errors
+          // Handle potential errors
           if (error) {
 
                console.error(error);
@@ -34,12 +83,13 @@ module.exports.list = (event, context, callback) => {
                return;
           }
 
-          // create a response
+          // Create a response
           const response = {
                statusCode: 200,
                body: JSON.stringify(result.Items),
           };
 
           callback(null, response);
      });
+     */
 };

api/update.js

@@ -26,16 +26,16 @@ module.exports.update = (event, context, callback) => {
     }
 
     const params = {
-        TableName: process.env.POST_TABLE,
+        TableName: process.env.DYNAMODB_TABLE,
         Key: {
             id: event.pathParameters.id,
         },
         ExpressionAttributeValues: {
             ':title': data.title,
             ':body': data.body,
-            ':updatedAt': timestamp,
+            ':updated_at': timestamp,
         },
-        UpdateExpression: 'SET title = :title, body = :body, updatedAt = :updatedAt',
+        UpdateExpression: 'SET title = :title, body = :body, updated_at = :updated_at',
         ReturnValues: 'ALL_NEW',
     };
 

serverless.yml

@@ -40,7 +40,7 @@ provider:
 #            - "Ref" : "ServerlessDeploymentBucket"
 #            - "/*"
   environment:
-    POST_TABLE: ${self:service}-${opt:stage, self:provider.stage}
+    DYNAMODB_TABLE: posts
   iamRoleStatements:
     - Effect: Allow
       Action:
@@ -169,14 +169,35 @@ resources:
         AttributeDefinitions:
           -
             AttributeName: "id"
-            AttributeType: "S"   
+            AttributeType: "S"
+          -
+            AttributeName: "updatedAt"
+            AttributeType: "N"
+          -
+            AttributeName: "dummyHashKey"
+            AttributeType: "S"
         KeySchema:
           -
             AttributeName: "id"
             KeyType: "HASH"
+        GlobalSecondaryIndexes:
+          -
+            IndexName: UpdatedAtIndex
+            KeySchema:
+              -
+                AttributeName: "dummyHashKey"
+                KeyType: HASH
+              -
+                AttributeName: "updatedAt"
+                KeyType: RANGE
+            Projection:
+              ProjectionType: KEYS_ONLY
+            ProvisionedThroughput:
+              ReadCapacityUnits: 1
+              WriteCapacityUnits: 1
         ProvisionedThroughput:
           ReadCapacityUnits: 1
           WriteCapacityUnits: 1
         StreamSpecification:
           StreamViewType: "NEW_AND_OLD_IMAGES"
-        TableName: ${self:provider.environment.POST_TABLE}
+        TableName: ${self:provider.environment.DYNAMODB_TABLE}