Example API structure

Author: alecarg

.gitignore

@@ -0,0 +1,2 @@
+.dynamodb/
+node_modules/

app.js

@@ -0,0 +1,7 @@
+const express = require('express');
+const bodyParser = require('body-parser');
+
+const app = express();
+app.use(bodyParser.json({ strict: false }));
+
+module.exports = app;

db.json

@@ -1,4 +1,5 @@
 {
+  "This-is-mock-data-only-and-can-be-deleted": "This has nothing to do with dynamoDb",
   "events": [
     {
       "id": "1",

dynamoDb.js

@@ -0,0 +1,18 @@
+const AWS = require('aws-sdk');
+
+const IS_OFFLINE = 'true'; // process.env.IS_OFFLINE
+
+let dynamoDb;
+if (IS_OFFLINE === 'true') {
+  dynamoDb = new AWS.DynamoDB.DocumentClient({
+    region: 'localhost',
+    endpoint: 'http://localhost:8000',
+    accessKeyId: 'test',
+    secretAccessKey: 'test'
+  })
+  console.log(dynamoDb);
+} else {
+  dynamoDb = new AWS.DynamoDB.DocumentClient();
+};
+
+module.exports = dynamoDb;

index.js

@@ -0,0 +1,34 @@
+const serverless = require('serverless-http');
+const dynamoDb = require('../../dynamoDb');
+const app = require('../../app');
+
+// createUser
+
+const USERS_TABLE = process.env.USERS_TABLE;
+
+app.post('/users', function (req, res) {
+  const { userId, name } = req.body;
+  if (typeof userId !== 'string') {
+    res.status(400).json({ error: '"userId" must be a string' });
+  } else if (typeof name !== 'string') {
+    res.status(400).json({ error: '"name" must be a string' });
+  }
+
+  const params = {
+    TableName: USERS_TABLE,
+    Item: {
+      userId: userId,
+      name: name,
+    },
+  };
+
+  dynamoDb.put(params, (error) => {
+    if (error) {
+      console.log(error);
+      res.status(400).json({ error: 'Could not create user' });
+    }
+    res.json({ userId, name });
+  });
+})
+
+module.exports.handler = serverless(app);

routes/users/create.js

@@ -0,0 +1,31 @@
+const serverless = require('serverless-http');
+const dynamoDb = require('../../dynamoDb');
+const app = require('../../app');
+
+// getUser
+
+const USERS_TABLE = process.env.USERS_TABLE;
+
+app.get('/users/:userId', function (req, res) {
+  const params = {
+    TableName: USERS_TABLE,
+    Key: {
+      userId: req.params.userId,
+    },
+  }
+
+  dynamoDb.get(params, (error, result) => {
+    if (error) {
+      console.log(error);
+      res.status(400).json({ error: 'Could not get user' });
+    }
+    if (result.Item) {
+      const {userId, name} = result.Item;
+      res.json({ userId, name });
+    } else {
+      res.status(404).json({ error: "User not found" });
+    }
+  });
+})
+
+module.exports.handler = serverless(app);

routes/users/get.js

@@ -34,17 +34,14 @@ provider:
     USERS_TABLE: ${self:custom.tableName}
 
 functions:
-  app:
-    handler: index.handler
-    events:
-      - http: ANY /
-      - http: 'ANY {proxy+}'
+
   getUser:
-    handler: index.handler
+    handler: routes/users/get.handler
     events:
       - http: 'GET /users/{proxy+}'
+
   createUser:
-    handler: index.handler
+    handler: routes/users/create.handler
     events:
       - http: 'POST /users'