-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathhandler.js
More file actions
80 lines (75 loc) · 2.83 KB
/
handler.js
File metadata and controls
80 lines (75 loc) · 2.83 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
'use strict';
const doc = require('dynamodb-doc');
const dynamo = new doc.DynamoDB();
module.exports.hello = async (event) => {
return {
statusCode: 200,
body: JSON.stringify({
message: 'Roorkee.org moving to lambdas soon :)',
input: event,
}),
};
};
module.exports.microservice = (event, context, callback) => {
console.log('Received event:', JSON.stringify(event, null, 2));
const done = (err, res) => callback(null, {
statusCode: err ? '400' : '200',
body: err ? err.message : JSON.stringify(res),
headers: {
'Content-Type': 'application/json',
'Access-Control-Allow-Origin':'*',
'Access-Control-Allow-Headers': '*',
'Access-Control-Allow-Methods': 'GET, PUT, POST, OPTIONS, DELETE, HEAD',
"Access-Control-Allow-Credentials" : true,
'Version':'17.10.15.4'
},
});
switch (event.httpMethod) {
case 'OPTIONS':
callback(null, {
statusCode: '200',
headers: {
'Content-Type': 'application/json',
'Access-Control-Allow-Origin':'*',
'Access-Control-Allow-Headers': '*',
'Access-Control-Allow-Methods': 'GET, PUT, POST, OPTIONS, DELETE, HEAD',
"Access-Control-Allow-Credentials" : true,
'Version':'17.10.15.4'
},
});
break;
case 'DELETE':
dynamo.deleteItem(JSON.parse(event.body), done);
break;
case 'GET':
if (event.queryStringParameters.id){
dynamo.getItem({ TableName: event.queryStringParameters.TableName, Key: {id: event.queryStringParameters.id}}, done);
}
else if (event.queryStringParameters.filter){
var filterCol = ":"+event.queryStringParameters.filter;
var params = {
TableName : event.queryStringParameters.TableName,
FilterExpression: "#nm = "+filterCol,
ExpressionAttributeNames:{
"#nm": event.queryStringParameters.filter
},
ExpressionAttributeValues: {
[filterCol]: event.queryStringParameters.value
}
};
dynamo.scan(params, done);
}
else{
dynamo.scan({ TableName: event.queryStringParameters.TableName }, done);
}
break;
case 'POST':
dynamo.putItem(JSON.parse(event.body), done);
break;
case 'PUT':
dynamo.updateItem(JSON.parse(event.body), done);
break;
default:
done(new Error(`Unsupported method "${event.httpMethod}"`));
}
};