-
Notifications
You must be signed in to change notification settings - Fork 0
/
handler.ts
123 lines (99 loc) · 2.62 KB
/
handler.ts
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
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
import { APIGatewayEvent, APIGatewayProxyResult } from 'aws-lambda';
import { DynamoDB } from 'aws-sdk';
import { User } from './dto';
import { response } from './response';
const tableName = process.env.TABLE || 'Users';
const dynamo = new DynamoDB.DocumentClient({
region: process.env.REGION || 'us-east-1',
});
const params = {
TableName: tableName,
};
export const helloWorld = async (event: APIGatewayEvent): Promise<APIGatewayProxyResult> => {
const data = {
message: 'First API Serverless function with DynamoDB executed successfully!',
queryString: event.queryStringParameters,
};
return response(200, data);
};
export const getAllUsers = async (): Promise<APIGatewayProxyResult> => {
const users = await dynamo.scan(params).promise();
const data = {
message: 'List all Users',
users: users.Items as User[]
}
return response(200, data);
};
export const getUser = async (event: APIGatewayEvent): Promise<APIGatewayProxyResult> => {
if (!event.pathParameters?.id) {
return response(400, { message: 'Bad Request' });
}
const user = await dynamo
.get({
...params,
Key: {
id: parseInt(event.pathParameters.id),
},
})
.promise();
if (!user.Item) {
return response(404, { message: 'User not found' });
}
return response(200, { user });
};
export const createUser = async (event: APIGatewayEvent): Promise<APIGatewayProxyResult> => {
const { name, age } = JSON.parse(event.body || '{}');
const user: User = {
id: Math.floor(1000 + Math.random() * 9000),
name,
age,
}
await dynamo.put({
...params,
Item: user,
}).promise();
const data = {
user,
message: `User ${user.id} Created`,
}
return response(200, data);
};
export const updateUser = async (event: APIGatewayEvent): Promise<APIGatewayProxyResult> => {
if (!event.pathParameters?.id) {
return response(400, { message: 'Bad Request' });
}
const { name, age } = JSON.parse(event.body || '{}');
const id = parseInt(event.pathParameters?.id);
const userExists = await dynamo
.get({
...params,
Key: {
id: id,
},
})
.promise();
if (!userExists.Item) {
return response(404, { message: 'User not found' });
}
await dynamo.put({
...params,
Item: {
id,
name,
age
},
}).promise();
return response (200, { message: `User id ${id} updated` });
};
export const removeUser = async (event: APIGatewayEvent): Promise<APIGatewayProxyResult> => {
const id = Number(event.pathParameters?.id);
await dynamo
.delete({
...params,
Key: {
id: id,
}
})
.promise();
return response(204);
};