From b8b14843099706f24817451dfff117769cc23d2d Mon Sep 17 00:00:00 2001
From: bertrand <bpinel@ippon.fr>
Date: Fri, 12 Apr 2019 17:58:54 +0200
Subject: [PATCH] Add provision of Cloud directory in project file
---
README.md | 5 +
.../__cloud__/lambda/lambda-jsonapi.js | 312 +++++++++++++++
.../__cloud__/lambda/lambda-jsonapi.zip | Bin 0 -> 3338 bytes
.../__root__/__cloud__/terraform/README.md | 28 ++
.../__cloud__/terraform/api-gateway.tf | 365 ++++++++++++++++++
.../__root__/__cloud__/terraform/bucket.tf | 155 ++++++++
.../__root__/__cloud__/terraform/dynamodb.tf | 16 +
.../files/__root__/__cloud__/terraform/iam.tf | 30 ++
.../__root__/__cloud__/terraform/lambda.tf | 40 ++
.../__root__/__cloud__/terraform/template.vm | 36 ++
blueprints/ember-aws-ehipster/index.js | 7 +-
.../routes/entity-factory/__name__.js | 3 +-
cloud/lambda-jsonapi-test.js | 3 +
cloud/lambda/lambda-jsonapi.js | 4 +-
package.json | 2 +-
15 files changed, 1001 insertions(+), 5 deletions(-)
create mode 100644 blueprints/ember-aws-ehipster/files/__root__/__cloud__/lambda/lambda-jsonapi.js
create mode 100644 blueprints/ember-aws-ehipster/files/__root__/__cloud__/lambda/lambda-jsonapi.zip
create mode 100644 blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/README.md
create mode 100644 blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/api-gateway.tf
create mode 100644 blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/bucket.tf
create mode 100644 blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/dynamodb.tf
create mode 100644 blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/iam.tf
create mode 100644 blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/lambda.tf
create mode 100644 blueprints/ember-aws-ehipster/files/__root__/__cloud__/terraform/template.vm
diff --git a/README.md b/README.md
index 4da211b..a5c4a68 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 0000000..90bf51a
--- /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
GIT binary patch
literal 3338
zcmZ|ScQhM-w+HY<>|J6M6??|0s##ilmD(ey3M%&AMQlmY*ehmZmnw>)lv1md+G>}^
zrfN%h{k`|!JMW$Q$G!i2?_c-ab3TT8AYw2803Ziolk^SzZxW4-sR4jIC;)H^zyWZ#
z_kcUvi@ExFdD?rsh`aiknNk2im0FHA(joOW0l`!NAn^$h0Qm0}du(n&^O~pak$tff
z$?Dxw`=}o#j179!23wc!Wjvb`Hu#8Wp2N9sC4*=BPa>DY@Z2NhQ9kK^o3XtD_k#8p
z&fL}<u?&R*?s*D(1uh)FGyIqBQfYNI@k#uX0R+X);TY?Ry0e(80lQuR!?+^xX(+tp
zY<j0}!d>O{v5@28#K;reH6PCTI=Y7&Z^5ax$j`n8i*UYKBW$wFE<OwnIP}}8fLK3l
zp@oJ1X}UU~!+S;UL1^A8T-BP_=%1brRNauF8v0@d_zF{lk5C3Cw5AnS4CBbh`-4du
zK>ff#KrjG7$nUkIXa3D!&xBcAlyxjD*NbRv=|4UdPxiD_cj+l*_hOScJzsc2blxvc
zbzWDr&y2a6n2WlZP*ysmD_3lU=9NQJ256EIYZb>*o$SQo-vpqQ=?Qm;iX<Xbk*dPY
zoS#|)4&uwznvq_P7U)Oy%nc-<lD<zP;B_H`&qp=kQuauDW)P1YNe706O6`mAfbdH1
zM|(RV!P{D6VcUWn8uvDReEYx4{~nb7>C(aFfBOkuULOS^fdbkL{`&8a^vD_5{AQ9}
zBN;nYlApZ+W}pO#$;1hSLc)3VQdS1gs{O_2bK#J`d4$TXaI#5tb!|+myCz|C=}$*!
z6lsKXBF4zNC^d-4)?TwO&$P1b)*zC%j_1Nl-uBfY%eA&&t^gPpCJrS+k^HDkA7w9#
z$CM+)eB#6CVkf^}@z>s2%M<)YZC@h%Y`BPx3cSu`30kdKd7KU{<KTjD&OG9mJ|2Ji
z2%$&ON^~aV6g?DZq@T!oU%WMBpj)M`ZZ>orxGcizJusY&n`I?V3DGU|x8p);bq6lR
zM755Rkv?;hBWOp3kofTu6i6w0QV2@|(^XokYUE-ym4?@Oe>wHTnM;MqRnMgyg$-AQ
ztQ)JC&>2A?E3rD&iJWHX(6280e@rA5;Y0023@$`u2Lh-_ucP%SAGmjt=fdCecO0rY
z+W7XX0Da#^^g7nUI}kFK^2JP2wVRwZ5Vm*tUO;VeoR&S=b>DaQL&-ygi8v}~l1(;q
zs}P0U+Sb!tZLOoJB^ddK4JUnDB(SaiF8fx!_lwkF?gEi1-c;=R>ywTu^CBhQ62yg+
zqj3h9{HVF_PUpE<rUI}NQ+@VYRXyMH){6A(TB*pSo8(&xT5nrGbatpZlj$R~P50W*
zt7Hz+G(R`v>3&vVS8s-{1ct14lCPY+zW&txIFw#(YKv~VY&3zI%|=gdYdgL)sBrj&
zzFfY;H!bha1)Med`00ZQq4xoM!X(vC_L&bEw_)bbVtv-6BR(oT{NuRd*cfK9WMjcC
zHMna3?&F`<bisXjTtIz3JClTM1}^o369Z;Ebr2w+vI`Jqc#%bFrXow%OdTy2mMp0-
zCPm)l<Y0zyq?R70^f^dO-U*y-0l&V;kdwBFa|N$ZUUQtiuJktV^>=C0i0f#^WSOrQ
z6sddeLB%nj&51Ug+2#k+7e-3TL1;$JE-qHnqADZg40v2VKYmI``QPQ3x@TudtQO7k
zwPIE#k|2FRk2D>Q1?%U}^6d7+c1x$GhRg+1Hl!xA*?oi1dRR610-~pQ;Mt6{K58zy
zfhPm#S*2ZgFJN9KPIAzal_2_>B8zL^nc%ysR?(eLT+nFRGisUh9e2|&Rf2WE8|5f?
zO7!W7KB5a?475CUAYr`0ooS7!OX8Y8g(9*tkb9Ei(V9M|t?E?7^RRc;Z-N3Y&e^lh
zIN&%3o(JF;c|HOX5&SKd*KEFbX+pf-3fOD<1C0Wcy02x984o)%u74^&T@wlPC$-;%
z9AV6!4Dkzz>>-fGOeg*cn`$9G=O!j^H!|(RHtIKBR+_rIwF^b2;+&?24r793T`OZ?
zpss9B3?*c0TDM(>b86Bk=`cFa*I)KlW+sdsk7dV&qpj8z#^y=Xvp+EjtHJ`zTrn+~
z#xXYFDwQ_Urojs7g8tdEHgMZe6N&|QOh;HtSnVxZ%HmkJ;w)|m5vjFVSkWOqq=KzV
zdr>?TC42v@x71Nr6%_$1J2P{K8jkbkbi6M0P0+?9?84!Om7hUpHdW1Esl~(l>vZb3
z6p4)~`B^TfW!*@~=Ugs^fpoNj$IUH|*GPWKRZ3zk74{tx)dXq&_VFDKwqIks>9w^p
zH(uV3?Ip7>tLmJ;AiBu5328Yl92T;)c&btC$}RR|XVB_R3}~dbK{c4^U9!InaZBLs
zepnZSNi16K)W(I%yvum$CG_!}u^!fo-&ZehroP?)`$3HfrMs=QA*hd+wLjG{FN1jY
z;SE;ZE;5BP?s{s(p^Sr%JdI#$?kV9VQLToVZsx90tcOSZA>5P$D!MEiGEe)(WQTg{
zt*WCIENU&r1gPWxn)n7P^Y!CroIk><7ED#|mj<tD9G#wIvp<OF*rk&o`@4Lp#IxVt
zrmV1SXM4x42um<nqKogsa1}<Yc7+X$D@8z!8gg?Xu-bAJz3{lTlU{iXt;NR1?m0!N
z-A<*gY&?|xymdbQ*0mYd`(-8}U%I_b_GDs<<4uwP>L^;*;yO`=pD%LZ4i<3IkI%+I
z%6PuLIOEbkeJ3oxY4^0yj<ZLK>pf!m@fq-YvOl5%xg2=$;cH>G!=DBw^n3~uB7Yu!
z#`ucYd7&9uzfE5P0zBaEgl8bseq}b1cudV)0(wQ?%zCH2yr&$S1?JsaS)u4l<3&%%
z%ZRunK|>3jkJBW2b06OD!Rd!Q1m{$XX&oT}ypz?p!77F&JO=%zrazuQs4gX5YEqJC
zg@D|IPm+*3oxu`-pf7Ms2H*_xw=mRl$K9w!sNAUilwHH9nn<Z1dh{8~PuRO>7+2JD
zUs-wmt8lPeXo605JaF_N)zfb0d$A7hyP7Oms*hXEeLWAPLuv;+L|SNvGzz2XDbtJh
z*2)p%0k?e>{fJV)$kJk9S*=~Ac1p5%UgF#7EO(+qr%n9czY%#QTieFOi!8i`=Pv09
zBg@pEIXS8hrU`Jc!Pzomz-ZOQ$-5Gj^(f904Ul+Rp3}Lyaw#h**2{WCcT~y!rG+dr
zQ{qrAAb^B95S*|!{)7V|2f>nxRB#s(n}_AXD+_+!scIa1o=9O?Rds9s`4e7n8hYy^
za}Lf8`c`H37VW5Rj%=rNJ@RdC2VS+uh~EC~Nk`acxynb1BWc9sP{*<KKgHWd3iKtK
z+I@Eib^2<$x2e6&*hU9jxQyq*?-zuAzMb7<T6~w?H8bC_vP`7UU6JQgQcz`8s<!Cx
zd+ui&o#d{7flvBtxztAUmFh_oKzNxT*ncXyK9+$_fMu=EV9%T>lYVK+(@evPG&;*x
zX&xS7&X0A{Ks4|KSmZe0jocR0!A?5*in;magLy_{=#$pp9GiR0Xc&XLZMq8P0la?A
zam=8Ae?R^?g|Cm2G`cH-uA1ITvRk9zRlb&+TPxEeW;KQBK|yPy@XC1*RatEf-RD?Y
zX2_2$PQ=qWhGxY0dclh21ZUOw6m326`y=!Aw1DcmyI&M(14~la4#0hDdHGr?(PF;n
zyN!`H!|bH=2IId)1_xtwyDynf`mz{bp{tV8weD0%?aGaHDsCj;@ZXfFV`uoAfela!
zP^br<u74WwMNZ64>j*S@qVZO7_e>dkvaI-=I`gi9@u~VBsEh5glAE-(bUTkIRmH%T
zoiKgjas`@HQ|i)x7`DhTI3dMX07+jxU<uz0>3z{!TFdz5Y!O5y6QHj7AXL+<8Abov
zR#fP`=-4GBo7qqjeEC&#??S9+A_e-8Y5&dcHARKFp;=vRbD_64iCLhZlc^|6=3;%A
z@6jp&htJunD(EWKb>5}0dbpZo%$=`k#Wv2o-&&w{?UcQH^5pV!_r)CAq^_;ZHUY-T
zUB78HZg(=$LCWL-o_!U8U{9_kJ7B0F>Ii08-29U17^$WeQ78H%?i(#GMNa2~U?HVT
zL)ks+GC^~v#h2YE?BfW#3+{De8WA1Hc)CdIjrx01VT)DrT9;*Sv1^F#?N<u#<EdHE
zz_+u;2)W~?33;DE1v$8q!Ij~)!oj5)eym}da9^9^@vtaMw#Nda;jl-0EYr3vs0OCk
zC1RIJ*Vp;0djD`UTWYCv<uB#e?>N265$fOB-ems2ob6p57R%E=qy#sszb3U#KT|8_
zr!lst-4Uk0$tN*ciUb<!0f{(4{~u3S|FH!C_@@s5F6uwi|A7^f|G~=tf{LLY3F&_V
Pz<*`&uNV9i4*>9A`F=0G
literal 0
HcmV?d00001
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 0000000..518115d
--- /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 0000000..df3f2e0
--- /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 0000000..0e7b86d
--- /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 0000000..1790e77
--- /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 0000000..04cd4a6
--- /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 0000000..27252ef
--- /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 0000000..94b4bef
--- /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 d5c3204..c365960 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 ab6b83d..964ec0f 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 b9e8b5b..7e64f4c 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 90bf51a..61cb689 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 a42cb14..9becdf4 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",
--
GitLab