diff --git a/README.md b/README.md
index 4da211bfd01aae1ba7de4f58461ab970dfd3f769..a5c4a6801378223a90c4fb3afd9a3693ed407efb 100644
--- a/README.md
+++ b/README.md
@@ -8,6 +8,11 @@ It could also be seen as a starter for setting up Mirage, allowing the developpe
Complete code is available at https://gitlab.ippon.fr/bpinel/ember-aws-ehipster
+A full tutorial is available on the Ippon Blog :
+* in english: https://blog.ippon.tech/a-guinea-pig-in-the-cloud/
+* in french: https://blog.ippon.fr/2019/03/19/un-cochon-dinde-dans-le-cloud/
+
+
Installation
------------------------------------------------------------------------------
diff --git a/blueprints/ember-aws-ehipster/files/__root__/__cloud__/lambda/lambda-jsonapi.js b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/lambda/lambda-jsonapi.js
new file mode 100644
index 0000000000000000000000000000000000000000..90bf51a08e55f5370c6d4ee5865ac224ef096742
--- /dev/null
+++ b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/lambda/lambda-jsonapi.js
@@ -0,0 +1,312 @@
+'use strict';
+const AWS = require('aws-sdk');
+const dynamo = new AWS.DynamoDB.DocumentClient();
+const tableName = 'JsonApiTable';
+const EPOCH = 1545907609050;
+const MAX_OBJECTS=1000; // Max number of objects returned by finder
+
+// Instagram inspired --> https://instagram-engineering.com/sharding-ids-at-instagram-1cf5a71e5a5c
+function generateRowId(subid) {
+ var ts = new Date().getTime() - EPOCH; // limit to recent
+ // 41 bits for time in milliseconds (gives us 41 years of IDs with a custom epoch
+ var randid = Math.floor(Math.random() * 512);
+ ts = (ts * 64); // bit-shift << 6
+ // Given shard (if any...)
+ ts = ts + subid;
+ // random value
+ return (ts * 512) + (randid % 512);
+ }
+
+ const createObject = (obj) => {
+ let objout = { "type": obj.ObjectType,
+ "id": obj.Id,
+ "attributes": {},
+ "relationships": {}
+ };
+ for (var attr in obj) {
+ if (attr !== 'ObjectType' && attr !== 'Id') {
+ if(!attr.endsWith('_id')) {
+ objout.attributes[attr] = obj[attr];
+ } else {
+ let relationDetails = attr.split('_');
+ if (obj[attr].startsWith('[')) {
+ // hasMany relationship
+ let idsArray = obj[attr].substring(1, obj[attr].length-1).split(',');
+ let relData = [];
+ for (let l=0;l<idsArray.length;l++) {
+ let relObject = {"type": relationDetails[0], "id": Number(idsArray[l]) };
+ relData.push(relObject); }
+ objout.relationships[relationDetails[0]] = {
+ "links": {
+ "self": "/"+obj.ObjectType+"/"+obj.Id+"/relationships/"+relationDetails[0],
+ "related": "/"+obj.ObjectType+"/"+obj.Id+"/"+relationDetails[0]
+ },
+ "data": relData
+ };
+ } else {
+ // belongsTo relationship
+ objout.relationships[relationDetails[0]] = {
+ "links": {
+ "self": "/"+obj.ObjectType+"/"+obj.Id+"/relationships/"+relationDetails[0],
+ "related": "/"+obj.ObjectType+"/"+obj.Id+"/"+relationDetails[0]
+ },
+ "data": {"type": relationDetails[1], "id": Number(obj[attr])}
+ };
+ }
+ }
+ } else {
+ objout[(attr==='ObjectType')?'type':'id'] = obj[attr];
+ }
+ }
+ console.log('Return object is '+JSON.stringify(objout));
+ return objout;
+}
+
+ const handlingData = (data) => {
+ if (Array.isArray(data)) {
+ let outdata = [];
+ for (let i=0;i<data.length;i++){
+ outdata.push(createObject(data[i]));
+ }
+ return outdata;
+ } else {
+ return createObject(data);
+ }
+ }
+
+ const handlingRelationships = (data) => {
+ if (Array.isArray(data)) {
+ console.warn("Not handling correctly relationship when retrieving list of objects");
+ } else {
+
+ }
+ return {};
+ }
+
+ const createResponse = (statusCode, body) => {
+ console.log("Body is "+JSON.stringify(body));
+ return {
+ 'statusCode': statusCode,
+ 'data': handlingData(body),
+ 'relationships': handlingRelationships(body)
+ }
+ };
+
+ const buildQuery = (queryParams, type) => {
+ let filterExpression = [];
+ let params = {
+ TableName: tableName,
+ KeyConditionExpression: 'ObjectType = :objectType',
+ FilterExpression: "",
+ ExpressionAttributeValues: {':objectType': type}
+ }
+ for (var filter in queryParams) {
+ //"filter[email]": "klaroutte@yopmail.com",
+ if (filter.startsWith('filter')){
+ let attr = filter.substring(7, filter.length-1);
+ let value = queryParams[filter];
+ filterExpression.push(attr+" = :"+attr);
+ params["ExpressionAttributeValues"][":"+attr] = value;
+ }
+ params["FilterExpression"] = filterExpression.join(' and ');
+ }
+ console.log('Query is '+JSON.stringify(params));
+ return params;
+}
+
+const getMethod = (event, context, callback) => {
+ let params = {
+ TableName: tableName,
+ },
+ type = event.params.path.type,
+ query = event.params.querystring,
+ id = Number(event.params.path.id),
+ dbGet = {};
+
+ if (id) {
+ params.Key = {
+ 'ObjectType': type,
+ 'Id': id
+ };
+ dbGet = (params) => { return dynamo.get(params).promise() };
+ console.log('Ehipster lambda GET single value with params: ', params);
+ } else if (Object.keys(query).length === 0) {
+ // No filter expression
+ params.KeyConditionExpression = 'ObjectType = :objectType';
+ params.ExpressionAttributeValues = { ':objectType': type };
+ dbGet = (params) => { return dynamo.query(params).promise() };
+ console.log('Ehipster lambda GET multiple values with params: ', params);
+ } else {
+ // Use filter expression
+ params = buildQuery(query, type);
+ dbGet = (params) => { return dynamo.query(params).promise() };
+ console.log('Ehipster lambda GET query values with params: ', params);
+ }
+
+ dbGet(params).then( (data) => {
+ //console.log('Ehipster lambda GET data received: ', data);
+
+ if (id && !data.Item) {
+ callback(null, createResponse(404, "ITEM NOT FOUND"));
+ return;
+ } else if (id && data.Item) {
+ console.log(`RETRIEVED ITEM SUCCESSFULLY WITH doc = ${data.Item}`);
+ callback(null, createResponse(200, data.Item));
+ } else {
+ console.log('SCANNING TABLE');
+ console.log(`RETRIEVED ITEMS SUCCESSFULLY WITH doc = ${data.Items}`);
+ callback(null, createResponse(200, data.Items));
+ }
+
+ }).catch( (err) => {
+ console.log(`GET ITEM FAILED FOR Entry = ${params}, WITH ERROR: ${err}`);
+ callback(null, createResponse(500, err));
+ });
+};
+
+ const putMethod = (event, context, callback) => {
+ const body=event['body-json'];
+ const attrs = body.data.attributes;
+ const relations = body.data.relationships;
+ // Without any body content, there is nothing to put...
+ if (!body || !attrs) {
+ callback(null, createResponse(500, 'No content found in body'));
+ return;
+ }
+ // Retrieving the type and generating a new id for created item
+ let type = event.params.path.type,
+ id = generateRowId(1);
+ // Final content contains at least these two fields + the atributes
+ let content = {
+ "ObjectType": type,
+ "Id": id
+ };
+ // Adding attributes as column in dynamoDb
+ for (var prop in attrs) {
+ if (attrs[prop] != null && attrs[prop].length>0)
+ // Empty field cannot be persisted
+ content[prop] = attrs[prop];
+ }
+ // Dealing with relationships if any
+ if (relations){
+ for (var relName in relations) {
+ let newCol = relName+'_'+type+'_id';
+ let relData = relations[relName]["data"];
+ if (!Array.isArray(relData)) {
+ content[newCol] = relData["id"];
+ } else {
+ let ids = [];
+ for (var i=0; i<relData.length;i++){
+ let currentData = relData[i];
+ ids.push(currentData["id"]);
+ }
+ content[newCol] = '['+ids.join(',')+']';
+ }
+ }
+ }
+
+ const entry = {
+ TableName: tableName,
+ Item: content
+ };
+ console.log('Try saving entity of type '+type+' and content '+JSON.stringify(entry));
+ //let dbPut = (entry) => { return dynamo.put(entry).promise() };
+ dynamo.put(entry, function(err, data) {
+ if (err) {
+ console.log("Error", err);
+ callback(null, createResponse(500, 'Error '+err));
+ } else {
+ body.data.id = id;
+ body['statusCode'] = 200;
+ console.log(`PUT ITEM SUCCEEDED WITH data=`+JSON.stringify(body));
+ callback(null, body);
+ }
+ });
+ };
+
+const patchMethod = (event, context, callback) => {
+
+ const body=event['body-json'];
+ const attrs = body.data.attributes;
+ let updateExpressionList = [];
+ let expressionAttributeList = [];
+ for (var attr in attrs) {
+ updateExpressionList.push(attr+' = :'+attr);
+ expressionAttributeList[':'+attr] = attrs[attr];
+ }
+ let updateExpression = 'set '+updateExpressionList.join(',');
+ let type = event.params.path.type,
+ id = Number(event.params.path.id),
+ params = {
+ 'TableName': tableName,
+ 'Key': {
+ 'ObjectType': type,
+ 'Id': id
+ },
+ 'UpdateExpression': updateExpression,
+ 'ExpressionAttributeValues': expressionAttributeList,
+ 'ReturnValues': 'UPDATED_NEW'
+ };
+ let dbUpdate = (params) => { return dynamo.update(params).promise() };
+ dbUpdate(params).then( (data) => {
+ if (!data.Attributes) {
+ callback(null, createResponse(404, "ITEM NOT FOUND FOR UPDATE"));
+ return;
+ }
+ console.log(`UPDATE ITEM OF TYPE ${type} SUCCESSFULLY WITH id = ${id}`);
+ callback(null, body);
+ }).catch( (err) => {
+ console.log(`UPDATE ITEM OF TYPE ${type} FAILED FOR id = ${id}, WITH ERROR: ${err}`);
+ callback(null, createResponse(500, err));
+ });
+};
+
+ const deleteMethod = (event, context, callback) => {
+ let type = event.params.path.type,
+ id = Number(event.params.path.id),
+ params = {
+ 'TableName': tableName,
+ 'Key': {
+ 'ObjectType': type,
+ 'Id': id
+ },
+ 'ReturnValues': 'ALL_OLD'
+ };
+ let dbDelete = (params) => { return dynamo.delete(params).promise() };
+ dbDelete(params).then( (data) => {
+ if (!data.Attributes) {
+ callback(null, createResponse(404, "ITEM NOT FOUND FOR DELETION"));
+ return;
+ }
+ console.log(`DELETED ITEM OF TYPE ${type} SUCCESSFULLY WITH id = ${id}`);
+ const empty = {'data': []};
+ callback(null, empty);
+ }).catch( (err) => {
+ console.log(`DELETE ITEM OF TYPE ${type} FAILED FOR id = ${id}, WITH ERROR: ${err}`);
+ callback(null, createResponse(500, err));
+ });
+ };
+
+
+exports.handler = (event, context, callback) => {
+ console.log("JSONAPILambda ********************** Received Event *******************\n"+ JSON.stringify(event));
+ console.log("JSONAPILambda httpMethod="+event.context.httpMethod);
+ switch ( event.context.httpMethod ) {
+ case 'GET':
+ getMethod(event,context,callback);
+ break;
+ case 'PUT':
+ case 'POST':
+ putMethod(event,context,callback);
+ break;
+ case 'PATCH':
+ patchMethod(event,context,callback);
+ break;
+ case 'DELETE':
+ deleteMethod(event,context,callback);
+ break;
+ default:
+ callback(null, createResponse(500, 'Unsupported Method: ' + context.httpMethod));
+ break;
+ }
+};
diff --git a/blueprints/ember-aws-ehipster/files/__root__/__cloud__/lambda/lambda-jsonapi.zip b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/lambda/lambda-jsonapi.zip
new file mode 100644
index 0000000000000000000000000000000000000000..fb4eac2a27d3db4151f6fb735403749b18eaf9d4
Binary files /dev/null and b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/lambda/lambda-jsonapi.zip differ
diff --git a/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/README.md b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/README.md
new file mode 100644
index 0000000000000000000000000000000000000000..518115d20fb406ad166d89e77948fec405d30744
--- /dev/null
+++ b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/README.md
@@ -0,0 +1,28 @@
+Installing AWS infrastructure through Terraform scripts
+==============================================================================
+
+This file explains how to set up the expected infrastructure awaited to implement the JSON API.
+The installation is based on Terraform (https://www.terraform.io/)
+
+It expects that both AWS CLI and Terraform have been previously installed and set up correctly.
+The AWS Credentials should also have been set up
+
+How it works
+------------------------------------------------------------------------------
+AWS JSON API server relies on 3 main components, plus the needed IAM roles :
+- A DynamoDB table manipuling all serialized objects
+- A lambda function in charge of the translation from JSON API format to dynamoDB objects and managing the relationships and the optional parameters provided in the request
+- An API Gateway configured to received the REST HTTP requests and proxying the Lambda
+
+It also create three S3 buckets, one for storing the lambda code (nammed lambda-jsonapi-code-bucket) and the two other for receiving the ‘staging’ and ‘production’ version of the application (respectively nammed ember-aws-ehipster-staging and ember-aws-ehipster-production)
+
+Several Terraform files are available, each one creating the needed component and their relationships with each other.
+
+Installation
+------------------------------------------------------------------------------
+
+One this is done, simply run the terraform script :
+```
+terraform init
+terraform apply -var bucket_name=<bucket name for static web site>
+```
\ No newline at end of file
diff --git a/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/api-gateway.tf b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/api-gateway.tf
new file mode 100644
index 0000000000000000000000000000000000000000..df3f2e07d2b9578a1ec864e00798800bfdf847c0
--- /dev/null
+++ b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/api-gateway.tf
@@ -0,0 +1,365 @@
+
+resource "aws_api_gateway_rest_api" "jsonapi" {
+ name = "JsonApiRestGateway"
+ description = "HTTP request front API for JSON API rest persistance"
+ minimum_compression_size = 4096
+}
+
+# Path /{type}
+resource "aws_api_gateway_resource" "typePath" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ parent_id = "${aws_api_gateway_rest_api.jsonapi.root_resource_id}"
+ path_part = "{type}"
+}
+
+# Path /{type}/{id}
+resource "aws_api_gateway_resource" "typeIdPath" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ parent_id = "${aws_api_gateway_resource.typePath.id}"
+ path_part = "{id}"
+}
+
+# GET on path /{type}
+resource "aws_api_gateway_method" "typePathGet" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typePath.id}"
+ http_method = "GET"
+ authorization = "NONE"
+}
+# OPTIONS on path /{type} for supporting CORS
+resource "aws_api_gateway_method" "typePathOptions" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typePath.id}"
+ http_method = "OPTIONS"
+ authorization = "NONE"
+}
+resource "aws_api_gateway_method_response" "typeOptions200" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typePath.id}"
+ http_method = "${aws_api_gateway_method.typePathOptions.http_method}"
+ status_code = "200"
+ response_models {
+ "application/json" = "Empty"
+ }
+ response_parameters {
+ "method.response.header.Access-Control-Allow-Headers" = true,
+ "method.response.header.Access-Control-Allow-Methods" = true,
+ "method.response.header.Access-Control-Allow-Origin" = true
+ }
+}
+resource "aws_api_gateway_integration" "typeOptionsIntegration" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typePath.id}"
+ http_method = "${aws_api_gateway_method.typePathOptions.http_method}"
+ type = "MOCK"
+ passthrough_behavior = "WHEN_NO_TEMPLATES"
+ request_templates {
+ "application/json" = "{\"statusCode\": 200}"
+ }
+}
+resource "aws_api_gateway_integration_response" "typeOptionsIntegrationResponse" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typePath.id}"
+ http_method = "${aws_api_gateway_method.typePathOptions.http_method}"
+ status_code = "${aws_api_gateway_method_response.typeOptions200.status_code}"
+ response_parameters = {
+ "method.response.header.Access-Control-Allow-Headers" = "'Content-Type,Access-Control-Allow-Origin,X-Amz-Date,Authorization,X-Requested-With,X-Requested-By,X-Api-Key,X-Amz-Security-Token'",
+ "method.response.header.Access-Control-Allow-Methods" = "'GET,OPTIONS,POST'",
+ "method.response.header.Access-Control-Allow-Origin" = "'*'"
+ }
+}
+# POST on path /{type}
+resource "aws_api_gateway_method" "typePathPost" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typePath.id}"
+ http_method = "POST"
+ authorization = "NONE"
+}
+
+# GET on path /{type}/{id}
+resource "aws_api_gateway_method" "typeIdPathGet" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typeIdPath.id}"
+ http_method = "GET"
+ authorization = "NONE"
+}
+# OPTIONS on path /{type}/{id}
+resource "aws_api_gateway_method" "typeIdPathOptions" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typeIdPath.id}"
+ http_method = "OPTIONS"
+ authorization = "NONE"
+}
+resource "aws_api_gateway_method_response" "typeIdOptions200" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typeIdPath.id}"
+ http_method = "${aws_api_gateway_method.typeIdPathOptions.http_method}"
+ status_code = "200"
+ response_models {
+ "application/json" = "Empty"
+ }
+ response_parameters {
+ "method.response.header.Access-Control-Allow-Headers" = true,
+ "method.response.header.Access-Control-Allow-Methods" = true,
+ "method.response.header.Access-Control-Allow-Origin" = true
+ }
+}
+resource "aws_api_gateway_integration" "typeIdOptionsIntegration" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typeIdPath.id}"
+ http_method = "${aws_api_gateway_method.typeIdPathOptions.http_method}"
+ type = "MOCK"
+ passthrough_behavior = "WHEN_NO_TEMPLATES"
+ request_templates {
+ "application/json" = "{\"statusCode\": 200}"
+ }
+}
+resource "aws_api_gateway_integration_response" "typeIdOptionsIntegrationResponse" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typeIdPath.id}"
+ http_method = "${aws_api_gateway_method.typeIdPathOptions.http_method}"
+ status_code = "${aws_api_gateway_method_response.typeIdOptions200.status_code}"
+ response_parameters = {
+ "method.response.header.Access-Control-Allow-Headers" = "'Content-Type,Access-Control-Allow-Origin,X-Amz-Date,Authorization,X-Requested-With,X-Requested-By,X-Api-Key,X-Amz-Security-Token'",
+ "method.response.header.Access-Control-Allow-Methods" = "'GET,OPTIONS,DELETE,PATCH'",
+ "method.response.header.Access-Control-Allow-Origin" = "'*'"
+ }
+}
+# DELETE on path /{type}/{id}
+resource "aws_api_gateway_method" "typeIdPathDelete" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typeIdPath.id}"
+ http_method = "DELETE"
+ authorization = "NONE"
+}
+
+# PATCH on path /{type}/{id}
+resource "aws_api_gateway_method" "typeIdPathPatch" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typeIdPath.id}"
+ http_method = "PATCH"
+ authorization = "NONE"
+}
+
+##############################################
+# GET on {type}
+# Setup Integration Request for GET on {type}
+resource "aws_api_gateway_integration" "lambdaJsonTypeGet" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_method.typePathGet.resource_id}"
+ http_method = "${aws_api_gateway_method.typePathGet.http_method}"
+
+ integration_http_method = "POST"
+ type = "AWS"
+ uri = "${aws_lambda_function.lambda-jsonapi.invoke_arn}"
+ # Transforms the incoming XML request to JSON
+ passthrough_behavior = "WHEN_NO_TEMPLATES"
+ request_templates {
+ "application/json" = "${file("template.vm")}"
+ }
+}
+# Setup Integration Response for status code 200 and GET on {type}
+resource "aws_api_gateway_method_response" "200TypeGet" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_method.typePathGet.resource_id}"
+ http_method = "${aws_api_gateway_method.typePathGet.http_method}"
+ status_code = "200"
+ response_parameters {
+ "method.response.header.Access-Control-Allow-Origin" = true
+ }
+}
+
+resource "aws_api_gateway_integration_response" "200TypeGetIntegrationResponse" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typePath.id}"
+ http_method = "${aws_api_gateway_method.typePathGet.http_method}"
+ status_code = "${aws_api_gateway_method_response.200TypeGet.status_code}"
+ response_templates = {
+ "application/json" = ""
+ }
+ response_parameters {
+ "method.response.header.Access-Control-Allow-Origin" = "'*'"
+ }
+ depends_on = ["aws_api_gateway_integration.lambdaJsonTypeGet"]
+}
+##############################################
+# POST on {type}
+# Setup Integration Request for POST on {type}
+resource "aws_api_gateway_integration" "lambdaJsonTypePost" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_method.typePathPost.resource_id}"
+ http_method = "${aws_api_gateway_method.typePathPost.http_method}"
+
+ integration_http_method = "POST"
+ type = "AWS"
+ uri = "${aws_lambda_function.lambda-jsonapi.invoke_arn}"
+ # Transforms the incoming XML request to JSON
+ passthrough_behavior = "WHEN_NO_TEMPLATES"
+ request_templates {
+ "application/json" = "${file("template.vm")}"
+ }
+}
+# Setup Integration Response for status code 200 and POST on {type}
+resource "aws_api_gateway_method_response" "200TypePost" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typePath.id}"
+ http_method = "${aws_api_gateway_method.typePathPost.http_method}"
+ status_code = "200"
+ response_parameters {
+ "method.response.header.Access-Control-Allow-Origin" = true
+ }
+}
+
+resource "aws_api_gateway_integration_response" "200TypePostIntegrationResponse" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typePath.id}"
+ http_method = "${aws_api_gateway_method.typePathPost.http_method}"
+ status_code = "${aws_api_gateway_method_response.200TypePost.status_code}"
+ response_templates = {
+ "application/json" = ""
+ }
+ response_parameters {
+ "method.response.header.Access-Control-Allow-Origin" = "'*'"
+ }
+ depends_on = ["aws_api_gateway_integration.lambdaJsonTypePost"]
+}
+##############################################
+# GET on {type}/{id}
+# Setup Integration Request for GET on {type}/{id}
+resource "aws_api_gateway_integration" "lambdaJsonTypeIdGet" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_method.typeIdPathGet.resource_id}"
+ http_method = "${aws_api_gateway_method.typeIdPathGet.http_method}"
+
+ integration_http_method = "POST"
+ type = "AWS"
+ uri = "${aws_lambda_function.lambda-jsonapi.invoke_arn}"
+ # Transforms the incoming XML request to JSON
+ passthrough_behavior = "WHEN_NO_TEMPLATES"
+ request_templates {
+ "application/json" = "${file("template.vm")}"
+ }
+}
+# Setup Integration Response for status code 200 and GET on {type}/{id}
+resource "aws_api_gateway_method_response" "200TypeIdGet" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_method.typeIdPathGet.resource_id}"
+ http_method = "${aws_api_gateway_method.typeIdPathGet.http_method}"
+ status_code = "200"
+ response_parameters {
+ "method.response.header.Access-Control-Allow-Origin" = true
+ }
+}
+
+resource "aws_api_gateway_integration_response" "200TypeIdGetIntegrationResponse" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typeIdPath.id}"
+ http_method = "${aws_api_gateway_method.typeIdPathGet.http_method}"
+ status_code = "${aws_api_gateway_method_response.200TypeIdGet.status_code}"
+ response_templates = {
+ "application/json" = ""
+ }
+ response_parameters {
+ "method.response.header.Access-Control-Allow-Origin" = "'*'"
+ }
+ depends_on=["aws_api_gateway_integration.lambdaJsonTypeIdGet"]
+}
+##############################################
+# DELETE on {type}/{id}
+# Setup Integration Request for DELETE on {type}/{id}
+resource "aws_api_gateway_integration" "lambdaJsonTypeIdDelete" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_method.typeIdPathDelete.resource_id}"
+ http_method = "${aws_api_gateway_method.typeIdPathDelete.http_method}"
+
+ integration_http_method = "POST"
+ type = "AWS"
+ uri = "${aws_lambda_function.lambda-jsonapi.invoke_arn}"
+ # Transforms the incoming XML request to JSON
+ passthrough_behavior = "WHEN_NO_TEMPLATES"
+ request_templates {
+ "application/json" = "${file("template.vm")}"
+ }
+}
+# Setup Integration Response for status code 200 and DELETE on {type}/{id}
+resource "aws_api_gateway_method_response" "200TypeIdDelete" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_method.typeIdPathDelete.resource_id}"
+ http_method = "${aws_api_gateway_method.typeIdPathDelete.http_method}"
+ status_code = "200"
+ response_parameters {
+ "method.response.header.Access-Control-Allow-Origin" = true
+ }
+}
+resource "aws_api_gateway_integration_response" "200TypeIdDeleteIntegrationResponse" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typeIdPath.id}"
+ http_method = "${aws_api_gateway_method.typeIdPathDelete.http_method}"
+ status_code = "${aws_api_gateway_method_response.200TypeIdDelete.status_code}"
+ response_templates = {
+ "application/json" = ""
+ }
+ response_parameters {
+ "method.response.header.Access-Control-Allow-Origin" = "'*'"
+ }
+ depends_on= ["aws_api_gateway_integration.lambdaJsonTypeIdDelete"]
+}
+##############################################
+# PATCH on {type}/{id}
+# Setup Integration Request for PATCH on {type}/{id}
+resource "aws_api_gateway_integration" "lambdaJsonTypeIdPatch" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_method.typeIdPathPatch.resource_id}"
+ http_method = "${aws_api_gateway_method.typeIdPathPatch.http_method}"
+
+ integration_http_method = "POST"
+ type = "AWS"
+ uri = "${aws_lambda_function.lambda-jsonapi.invoke_arn}"
+ # Transforms the incoming XML request to JSON
+ passthrough_behavior = "WHEN_NO_TEMPLATES"
+ request_templates {
+ "application/json" = "${file("template.vm")}"
+ }
+}
+# Setup Integration Response for status code 200 and PATCH on {type}/{id}
+resource "aws_api_gateway_method_response" "200TypeIdPatch" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_method.typeIdPathPatch.resource_id}"
+ http_method = "${aws_api_gateway_method.typeIdPathPatch.http_method}"
+ status_code = "200"
+ response_parameters {
+ "method.response.header.Access-Control-Allow-Origin" = true
+ }
+}
+resource "aws_api_gateway_integration_response" "200TypeIdPatchIntegrationResponse" {
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ resource_id = "${aws_api_gateway_resource.typeIdPath.id}"
+ http_method = "${aws_api_gateway_method.typeIdPathPatch.http_method}"
+ status_code = "${aws_api_gateway_method_response.200TypeIdPatch.status_code}"
+ response_templates = {
+ "application/json" = ""
+ }
+ response_parameters {
+ "method.response.header.Access-Control-Allow-Origin" = "'*'"
+ }
+ depends_on = ["aws_api_gateway_integration.lambdaJsonTypeIdPatch"]
+}
+
+resource "aws_api_gateway_deployment" "jsonapiDeployment" {
+ depends_on = [
+ "aws_api_gateway_integration.typeOptionsIntegration",
+ "aws_api_gateway_integration.lambdaJsonTypeGet",
+ "aws_api_gateway_integration.lambdaJsonTypePost",
+ "aws_api_gateway_integration.typeIdOptionsIntegration",
+ "aws_api_gateway_integration.lambdaJsonTypeIdGet",
+ "aws_api_gateway_integration.lambdaJsonTypeIdPatch",
+ "aws_api_gateway_integration.lambdaJsonTypeIdDelete"
+ ]
+
+ rest_api_id = "${aws_api_gateway_rest_api.jsonapi.id}"
+ stage_name = "staging"
+}
+
+output "base_url" {
+ value = "${aws_api_gateway_deployment.jsonapiDeployment.invoke_url}"
+}
\ No newline at end of file
diff --git a/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/bucket.tf b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/bucket.tf
new file mode 100644
index 0000000000000000000000000000000000000000..0e7b86d9a3c614a3cb94cc43844bf25b005c65ed
--- /dev/null
+++ b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/bucket.tf
@@ -0,0 +1,155 @@
+variable "bucket_name_production" {
+ type = "string"
+ default = "ember-aws-ehipster-production"
+}
+variable "bucket_name_staging" {
+ type = "string"
+ default = "ember-aws-ehipster-staging"
+}
+
+resource "aws_s3_bucket" "lambda-bucket" {
+ bucket = "lambda-jsonapi-code-bucket"
+ acl = "public-read"
+}
+resource "aws_s3_bucket_object" "lambda-bucket-code" {
+ bucket = "${aws_s3_bucket.lambda-bucket.bucket}"
+ key = "v1.0.0/lambda-jsonapi.zip"
+ source = "../lambda/lambda-jsonapi.zip"
+ etag = "${md5(file("../lambda/lambda-jsonapi.zip"))}"
+}
+
+resource "aws_s3_bucket" "production" {
+ bucket = "${var.bucket_name_production}"
+ acl = "public-read"
+
+ website {
+ index_document = "index.html"
+ error_document = "index.html"
+ }
+}
+resource "aws_s3_bucket" "staging" {
+ bucket = "${var.bucket_name_staging}"
+ acl = "public-read"
+
+ website {
+ index_document = "index.html"
+ error_document = "index.html"
+ }
+}
+
+
+locals {
+ s3_origin_id = "S3Origin"
+}
+
+resource "aws_cloudfront_distribution" "s3_distribution_production" {
+ origin {
+ domain_name = "${element(split("/","${aws_s3_bucket.production.website_endpoint}"),2)}"
+ origin_id = "${local.s3_origin_id}"
+
+ custom_origin_config {
+ http_port = 80
+ https_port = 443
+ origin_protocol_policy = "http-only"
+ origin_ssl_protocols = ["SSLv3", "TLSv1.1", "TLSv1.2"]
+ }
+ }
+
+ enabled = true
+ http_version = "http2"
+ is_ipv6_enabled = true
+ comment = "Production ehipster ClondFront"
+ default_root_object = "index.html"
+
+ default_cache_behavior {
+ allowed_methods = ["DELETE", "GET", "HEAD", "OPTIONS", "PATCH", "POST", "PUT"]
+ compress = true
+ cached_methods = ["GET", "HEAD"]
+ target_origin_id = "${local.s3_origin_id}"
+
+ forwarded_values {
+ query_string = true
+
+ cookies {
+ forward = "none"
+ }
+ }
+
+ viewer_protocol_policy = "redirect-to-https"
+ min_ttl = 0
+ default_ttl = 3600
+ max_ttl = 86400
+ }
+
+ price_class = "PriceClass_All"
+
+ restrictions {
+ geo_restriction {
+ restriction_type = "none"
+ }
+ }
+
+ tags = {
+ Environment = "production"
+ }
+
+ viewer_certificate {
+ cloudfront_default_certificate = true
+ }
+}
+
+resource "aws_cloudfront_distribution" "s3_distribution_staging" {
+ origin {
+ domain_name = "${element(split("/","${aws_s3_bucket.staging.website_endpoint}"),2)}"
+ origin_id = "${local.s3_origin_id}"
+
+ custom_origin_config {
+ http_port = 80
+ https_port = 443
+ origin_protocol_policy = "http-only"
+ origin_ssl_protocols = ["SSLv3", "TLSv1.1", "TLSv1.2"]
+ }
+ }
+
+ enabled = true
+ http_version = "http2"
+ is_ipv6_enabled = true
+ comment = "Staging ehipster ClondFront"
+ default_root_object = "index.html"
+
+ default_cache_behavior {
+ allowed_methods = ["DELETE", "GET", "HEAD", "OPTIONS", "PATCH", "POST", "PUT"]
+ compress = true
+ cached_methods = ["GET", "HEAD"]
+ target_origin_id = "${local.s3_origin_id}"
+
+ forwarded_values {
+ query_string = true
+
+ cookies {
+ forward = "none"
+ }
+ }
+
+ viewer_protocol_policy = "redirect-to-https"
+ min_ttl = 0
+ default_ttl = 3600
+ max_ttl = 86400
+ }
+
+ price_class = "PriceClass_All"
+
+ restrictions {
+ geo_restriction {
+ restriction_type = "none"
+ }
+ }
+
+ tags = {
+ Environment = "staging"
+ }
+
+ viewer_certificate {
+ cloudfront_default_certificate = true
+ }
+}
diff --git a/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/dynamodb.tf b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/dynamodb.tf
new file mode 100644
index 0000000000000000000000000000000000000000..1790e772fa820ae3e95c594744df98e7a2b345c0
--- /dev/null
+++ b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/dynamodb.tf
@@ -0,0 +1,16 @@
+resource "aws_dynamodb_table" "JsonApiTable" {
+ name = "JsonApiTable"
+ read_capacity = 3
+ write_capacity = 3
+ hash_key = "ObjectType"
+ range_key = "Id"
+
+ attribute {
+ name = "ObjectType"
+ type = "S"
+ }
+ attribute {
+ name = "Id"
+ type = "N"
+ }
+}
diff --git a/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/iam.tf b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/iam.tf
new file mode 100644
index 0000000000000000000000000000000000000000..04cd4a6075bf3de0e04b7a4421ae471ab42b2f52
--- /dev/null
+++ b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/iam.tf
@@ -0,0 +1,30 @@
+
+resource "aws_iam_role" "lambda_jsonapi" {
+ name = "lambda_jsonapi"
+ path = "/"
+
+ assume_role_policy = <<POLICY
+{
+ "Version": "2012-10-17",
+ "Statement": [
+ {
+ "Effect": "Allow",
+ "Principal": {
+ "Service": "lambda.amazonaws.com"
+ },
+ "Action": "sts:AssumeRole"
+ }
+ ]
+}
+POLICY
+}
+
+resource "aws_iam_role_policy_attachment" "lambda_jsonapi_AmazonDynamoDBFullAccess" {
+ role = "${aws_iam_role.lambda_jsonapi.name}"
+ policy_arn = "arn:aws:iam::aws:policy/AmazonDynamoDBFullAccess"
+}
+
+resource "aws_iam_role_policy_attachment" "lambda_jsonapi_CloudWatchFullAccess" {
+ role = "${aws_iam_role.lambda_jsonapi.name}"
+ policy_arn = "arn:aws:iam::aws:policy/CloudWatchFullAccess"
+}
diff --git a/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/lambda.tf b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/lambda.tf
new file mode 100644
index 0000000000000000000000000000000000000000..27252efdc5bd1dce7ee47ea880943ce296d3192b
--- /dev/null
+++ b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/lambda.tf
@@ -0,0 +1,40 @@
+variable "region" {
+ default = "us-east-1"
+}
+
+provider "aws" {
+ region = "${var.region}"
+}
+
+resource "aws_lambda_function" "lambda-jsonapi" {
+ function_name = "lambda-jsonapi"
+
+ # The bucket name as created before running terraform scripts with "aws s3api create-bucket"
+ s3_bucket = "${aws_s3_bucket.lambda-bucket.bucket}"
+ s3_key = "${aws_s3_bucket_object.lambda-bucket-code.key}"
+
+ # "main" is the filename within the zip file (main.js) and "handler"
+ # is the name of the property under which the handler function was
+ # exported in that file.
+ handler = "lambda-jsonapi.handler"
+ runtime = "nodejs8.10"
+
+ role = "${aws_iam_role.lambda_jsonapi.arn}"
+
+ depends_on = ["aws_s3_bucket.lambda-bucket"]
+}
+
+
+# Allow API Gateway to access the defined lambda function
+resource "aws_lambda_permission" "apigw" {
+ statement_id = "AllowAPIGatewayInvoke"
+ action = "lambda:InvokeFunction"
+ function_name = "${aws_lambda_function.lambda-jsonapi.arn}"
+ principal = "apigateway.amazonaws.com"
+
+ # The /*/* portion grants access from any method on any resource
+ # within the API Gateway "REST API".
+ source_arn = "${aws_api_gateway_deployment.jsonapiDeployment.execution_arn}/*/*"
+
+ depends_on = ["aws_iam_role.lambda_jsonapi"]
+}
\ No newline at end of file
diff --git a/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/template.vm b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/template.vm
new file mode 100644
index 0000000000000000000000000000000000000000..94b4befc53d01ef1398c338726df8e402cc3a927
--- /dev/null
+++ b/blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/template.vm
@@ -0,0 +1,36 @@
+#set($allParams = $input.params())
+{
+"body-json" : $input.json('$'),
+"params" : {
+#foreach($type in $allParams.keySet())
+ #set($params = $allParams.get($type))
+"$type" : {
+ #foreach($paramName in $params.keySet())
+ "$paramName" : "$util.escapeJavaScript($params.get($paramName))"
+ #if($foreach.hasNext),#end
+ #end
+}
+ #if($foreach.hasNext),#end
+#end
+},
+"context" : {
+ "httpMethod" : "$context.httpMethod",
+ "account-id" : "$context.identity.accountId",
+ "api-id" : "$context.apiId",
+ "api-key" : "$context.identity.apiKey",
+ "authorizer-principal-id" : "$context.authorizer.principalId",
+ "caller" : "$context.identity.caller",
+ "cognito-authentication-provider" : "$context.identity.cognitoAuthenticationProvider",
+ "cognito-authentication-type" : "$context.identity.cognitoAuthenticationType",
+ "cognito-identity-id" : "$context.identity.cognitoIdentityId",
+ "cognito-identity-pool-id" : "$context.identity.cognitoIdentityPoolId",
+ "stage" : "$context.stage",
+ "source-ip" : "$context.identity.sourceIp",
+ "user" : "$context.identity.user",
+ "user-agent" : "$context.identity.userAgent",
+ "user-arn" : "$context.identity.userArn",
+ "request-id" : "$context.requestId",
+ "resource-id" : "$context.resourceId",
+ "resource-path" : "$context.resourcePath"
+ }
+}
\ No newline at end of file
diff --git a/blueprints/ember-aws-ehipster/index.js b/blueprints/ember-aws-ehipster/index.js
index d5c32047068f9b97a7abf74a441b3d2b49c47ba2..c365960b7038b70b48ddf8c2137612a9446f3b8d 100644
--- a/blueprints/ember-aws-ehipster/index.js
+++ b/blueprints/ember-aws-ehipster/index.js
@@ -23,7 +23,8 @@ module.exports = {
return 'app';
}
},
- __mirage__() { return '../mirage'}
+ __mirage__() { return '../mirage'},
+ __cloud__() { return '../cloud'}
}
},
@@ -65,6 +66,10 @@ module.exports = {
let routerLine = "\tthis.route('entity-factory', function() {\n\t});\n";
addLineToFile(this, routerPath, /Router\.map\(function\(\) {/, routerLine);
+ // Add special rules to lint config file
+ let lintPath = ".template-lintrc.js";
+ let lintLines = ",\trules: {\n\t\t\"attribute-indentation\": false,\n\t\t\"block-indentation\": false\n\t}\n";
+ addLineToFile(this, lintPath, /extends: 'recommended'/, lintLines);
}
};
diff --git a/blueprints/entity-factory/files/__root__/routes/entity-factory/__name__.js b/blueprints/entity-factory/files/__root__/routes/entity-factory/__name__.js
index ab6b83d62b5a14a1a8cdc795cdc5704a80dea487..964ec0f05b2809e77aa40e806abf36afc1a6d0e0 100644
--- a/blueprints/entity-factory/files/__root__/routes/entity-factory/__name__.js
+++ b/blueprints/entity-factory/files/__root__/routes/entity-factory/__name__.js
@@ -1,8 +1,9 @@
import Route from '@ember/routing/route';
+import { hash } from 'rsvp';
export default Route.extend({
model() {
- return Ember.RSVP.hash({
+ return hash({
<%=routeLoadModels%>
});
},
diff --git a/cloud/lambda-jsonapi-test.js b/cloud/lambda-jsonapi-test.js
index b9e8b5b5ef0fc601427842c8605031d225064ccc..7e64f4c9199388ed68876f856e20b6bec9fa4780 100644
--- a/cloud/lambda-jsonapi-test.js
+++ b/cloud/lambda-jsonapi-test.js
@@ -37,6 +37,9 @@ function generateRowId(subid) {
objout.attributes[attr] = obj[attr];
} else {
let relationDetails = attr.split('_');
+ if (obj[attr] == null || typeof(obj[attr]) == "undefined" ) {
+ console.log("HUDSON, WE HAVE A PROBLEM with attr "+attr);
+ }
if (obj[attr].startsWith('[')) {
// hasMany relationship
let idsArray = obj[attr].substring(1, obj[attr].length-1).split(',');
diff --git a/cloud/lambda/lambda-jsonapi.js b/cloud/lambda/lambda-jsonapi.js
index 90bf51a08e55f5370c6d4ee5865ac224ef096742..61cb68937a126113e6b5b3079815218816345352 100644
--- a/cloud/lambda/lambda-jsonapi.js
+++ b/cloud/lambda/lambda-jsonapi.js
@@ -29,8 +29,8 @@ function generateRowId(subid) {
objout.attributes[attr] = obj[attr];
} else {
let relationDetails = attr.split('_');
- if (obj[attr].startsWith('[')) {
- // hasMany relationship
+ if (typeof obj[attr] == "string" && obj[attr].startsWith('[')) {
+ // hasMany relationship
let idsArray = obj[attr].substring(1, obj[attr].length-1).split(',');
let relData = [];
for (let l=0;l<idsArray.length;l++) {
diff --git a/package.json b/package.json
index a42cb1464933c5261cfa270123a4fc03ab46c737..9becdf415a5f6b3a7942c8b0988d3279dfb540b3 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
{
"name": "ember-aws-ehipster",
- "version": "0.4.3",
+ "version": "0.5.5",
"description": "Attempt to build a complete web application using serverless architecture on AWS",
"keywords": [
"ember-addon",