-
Notifications
You must be signed in to change notification settings - Fork 0
/
orderManager.js
110 lines (97 loc) · 3.01 KB
/
orderManager.js
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
'use strict'
const { v1: uuidv1 } = require('uuid');
const AWS = require('aws-sdk');
const dynamo = new AWS.DynamoDB.DocumentClient();
const kinesis = new AWS.Kinesis();
const TABLE_NAME = process.env.orderTableName;
const STREAM_NAME = process.env.orderStreamName;
module.exports.createOrder = body => {
return {
orderId: uuidv1(),
name: body.name,
address: body.address,
productId: body.productId,
quantity: body.quantity,
orderDate: Date.now(),
eventType: 'order_placed'
};
}
module.exports.placeNewOrder = order => {
return saveNewOrder(order).then(() => {
return placeOrderInStream(order);
});
}
const saveNewOrder = order => {
return dynamo.put({
TableName: TABLE_NAME,
Item: order
}).promise();
}
const placeOrderInStream = order => {
return kinesis.putRecord({
Data: JSON.stringify(order),
PartitionKey: order.orderId,
StreamName: STREAM_NAME
}).promise();
}
module.exports.fulfillOrder = (orderId, fulfillmentId) => {
const orderUpdateData = getOrderUpdateData(orderId, fulfillmentId);
return saveUpdatedOrder(orderUpdateData).then(updatedOrder => {
return placeOrderInStream(updatedOrder);
});
}
const getOrderUpdateData = (orderId, fulfillmentId) => {
return {
key: {
orderId: orderId
},
expression: "set fulfillmentId=:fulfillId, fulfillmentDate=:fulfillDate, eventType=:eventType",
values: {
":fulfillId": fulfillmentId,
":fulfillDate": Date.now(),
":eventType": "order_fulfilled"
}
};
}
const saveUpdatedOrder = orderUpdateData => {
return dynamo.update({
TableName: TABLE_NAME,
Key: orderUpdateData.key,
UpdateExpression: orderUpdateData.expression,
ExpressionAttributeValues: orderUpdateData.values,
ReturnValues: 'ALL_NEW'
}).promise().then(updatedOrder => {
return updatedOrder.Attributes;
});
}
module.exports.updateOrderForDelivery = orderId => {
const orderUpdateForDeliveryData = getOrderUpdateForDeliveryData(orderId);
return saveUpdatedOrder(orderUpdateForDeliveryData);
}
const getOrderUpdateForDeliveryData = orderId => {
return {
key: {
orderId: orderId
},
expression: "set sentToDeliveryDate=:sentToDeliveryDate",
values: {
":sentToDeliveryDate": Date.now()
}
}
}
module.exports.updateOrderDeliveryData = (orderId, deliveryCompanyId) => {
const orderDeliveryUpdateData = getOrderDeliveryUpdateData(orderId, deliveryCompanyId);
return saveUpdatedOrder(orderDeliveryUpdateData);
}
const getOrderDeliveryUpdateData = (orderId, deliveryCompanyId) => {
return {
key: {
orderId: orderId
},
expression: "set deliveryCompanyId=:deliveryCompanyId, deliveryDate=:deliveryDate",
values: {
":deliveryCompanyId": deliveryCompanyId,
":deliveryDate": Date.now()
}
};
}