Skip to content

Commit

Permalink
style: lint fix
Browse files Browse the repository at this point in the history
  • Loading branch information
Franco Méndez committed Oct 21, 2019
1 parent 75c3f05 commit ab11e95
Show file tree
Hide file tree
Showing 5 changed files with 114 additions and 82 deletions.
49 changes: 26 additions & 23 deletions accept_slot.js
Original file line number Diff line number Diff line change
Expand Up @@ -4,38 +4,41 @@ const uuidv4 = require('uuid/v4');
const moment = require('moment');

async function acceptSlot(slotId, slotStatus) {
let data = await dynamoDB.transactWrite({
TransactItems: [
let data = await dynamoDB
.transactWrite({
TransactItems: [
{
Update: {
TableName: process.env.dynamodb_table_name_slots,
Key: {
"slot_id": tripId
},
UpdateExpression: "set accepted = :slot_status",
ExpressionAttributeValues: {
":slot_status": slotStatus
}
Update: {
TableName: process.env.dynamodb_table_name_slots,
Key: {
slot_id: tripId
},
UpdateExpression: 'set accepted = :slot_status',
ExpressionAttributeValues: {
':slot_status': slotStatus
}
}
},
{
Update: {
TableName: process.env.dynamodb_table_name_trips,
Key: {
"trip_id": tripId
},
UpdateExpression: "set available_seats = available_seats - :requested_seats",
ExpressionAttributeValues: {
":requested_seats": 1
}
Update: {
TableName: process.env.dynamodb_table_name_trips,
Key: {
trip_id: tripId
},
UpdateExpression:
'set available_seats = available_seats - :requested_seats',
ExpressionAttributeValues: {
':requested_seats': 1
}
}
}
]
}).promise();
]
})
.promise();
return data;
}

exports.handler = async (event) => {
exports.handler = async event => {
let tripId = event.trip_id;
let userId = event.user_id;

Expand Down
51 changes: 27 additions & 24 deletions create_slot.js
Original file line number Diff line number Diff line change
Expand Up @@ -4,40 +4,43 @@ const uuidv4 = require('uuid/v4');
const moment = require('moment');

async function createSlot(tripId, userId) {
let slotId = 'slo_'+uuidv4();
let slotId = 'slo_' + uuidv4();
let createdAt = moment().format('YYYY-MM-DDTHH:mm:ss-04:00');
let data = await dynamoDB.transactWrite({
TransactItems: [
let data = await dynamoDB
.transactWrite({
TransactItems: [
{
Put: {
TableName: process.env.dynamodb_table_name_slots,
Item: {
"slot_id": slotId,
"trip_id": tripId,
"user_id": userId,
"slot_status": "requested",
"created_at": createdAt
}
Put: {
TableName: process.env.dynamodb_table_name_slots,
Item: {
slot_id: slotId,
trip_id: tripId,
user_id: userId,
slot_status: 'requested',
created_at: createdAt
}
}
},
{
Update: {
TableName: process.env.dynamodb_table_name_trips,
Key: {
"trip_id": tripId
},
UpdateExpression: "set available_seats = available_seats - :requested_seats",
ExpressionAttributeValues: {
":requested_seats": 1
}
Update: {
TableName: process.env.dynamodb_table_name_trips,
Key: {
trip_id: tripId
},
UpdateExpression:
'set available_seats = available_seats - :requested_seats',
ExpressionAttributeValues: {
':requested_seats': 1
}
}
}
]
}).promise();
]
})
.promise();
return data;
}

exports.handler = async (event) => {
exports.handler = async event => {
let tripId = event.trip_id;
let userId = event.user_id;

Expand Down
36 changes: 18 additions & 18 deletions create_trips.js
Original file line number Diff line number Diff line change
@@ -1,28 +1,28 @@
const aws = require('aws-sdk');
const dynamoDB = new aws.DynamoDB.DocumentClient();
const dynamoDB = new aws.DynamoDB.DocumentClient();
const uuidv4 = require('uuid/v4');
const moment = require('moment');

async function createTrip(carId, driverId, etd, routePoints) {
let tripId = 'tri_'+uuidv4();
let createdAt = moment().format('YYYY-MM-DDTHH:mm:ss-04:00');
let params = {
TableName : process.env.dynamodb_table_name,
Item: {
"trip_id": tripId,
"car_id": carId,
"driver_id": driverId,
"etd": etd,
"route_points": routePoints,
"trip_status": "open",
"created_at": createdAt
}
};
let data = await dynamoDB.put(params).promise();
return data;
let tripId = 'tri_' + uuidv4();
let createdAt = moment().format('YYYY-MM-DDTHH:mm:ss-04:00');
let params = {
TableName: process.env.dynamodb_table_name,
Item: {
trip_id: tripId,
car_id: carId,
driver_id: driverId,
etd: etd,
route_points: routePoints,
trip_status: 'open',
created_at: createdAt
}
};
let data = await dynamoDB.put(params).promise();
return data;
}

exports.handler = async (event) => {
exports.handler = async event => {
let carId = event.car_id;
let driverId = event.driver_id;
let etd = event.etd;
Expand Down
33 changes: 17 additions & 16 deletions get_trips.js
Original file line number Diff line number Diff line change
@@ -1,20 +1,21 @@
const {parallelScan} = require('@shelf/dynamodb-parallel-scan');
const { parallelScan } = require('@shelf/dynamodb-parallel-scan');

async function getTrips(){
let params = {
TableName: process.env.dynamodb_table_name,
ProjectionExpression: "trip_id, etd, driver_id, available_seats, route_points"
};
let data = await parallelScan(params, {concurrency: 1000});
return data;
async function getTrips() {
let params = {
TableName: process.env.dynamodb_table_name,
ProjectionExpression:
'trip_id, etd, driver_id, available_seats, route_points'
};
let data = await parallelScan(params, { concurrency: 1000 });
return data;
}

exports.handler = async (event) => {
let query = await getTrips();
const response = {
statusCode: 200,
headers: {'Access-Control-Allow-Origin': '*'},
body: JSON.stringify(query)
};
return response;
exports.handler = async event => {
let query = await getTrips();
const response = {
statusCode: 200,
headers: { 'Access-Control-Allow-Origin': '*' },
body: JSON.stringify(query)
};
return response;
};
27 changes: 26 additions & 1 deletion yarn.lock
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,16 @@
esutils "^2.0.2"
js-tokens "^4.0.0"

"@shelf/dynamodb-parallel-scan@^1.0.2":
version "1.0.2"
resolved "https://registry.yarnpkg.com/@shelf/dynamodb-parallel-scan/-/dynamodb-parallel-scan-1.0.2.tgz#71254e8e23faff747ce0296426355dadc2c461ca"
integrity sha512-gdAgW+nZr2XE5dhALLOsbp4wJgWQv/lakSgPmErudGBfy2DrPTIh7ZNMZlA1jge/PJm5sa37lahlFoz40YG9rw==
dependencies:
debug "4.1.1"
lodash.clonedeep "4.5.0"
lodash.times "4.3.2"
p-map "2.0.0"

acorn-jsx@^5.0.2:
version "5.1.0"
resolved "https://registry.yarnpkg.com/acorn-jsx/-/acorn-jsx-5.1.0.tgz#294adb71b57398b0680015f0a38c563ee1db5384"
Expand Down Expand Up @@ -144,7 +154,7 @@ cross-spawn@^6.0.5:
shebang-command "^1.2.0"
which "^1.2.9"

debug@^4.0.1:
debug@4.1.1, debug@^4.0.1:
version "4.1.1"
resolved "https://registry.yarnpkg.com/debug/-/debug-4.1.1.tgz#3b72260255109c6b589cee050f1d516139664791"
integrity sha512-pYAIzeRo8J6KPEaJ0VWOh5Pzkbw/RetuzehGM7QRRX5he4fPHx2rdKMB256ehJCkX+XRQm16eZLqLNS8RSZXZw==
Expand Down Expand Up @@ -504,6 +514,16 @@ levn@^0.3.0, levn@~0.3.0:
prelude-ls "~1.1.2"
type-check "~0.3.2"

lodash.clonedeep@4.5.0:
version "4.5.0"
resolved "https://registry.yarnpkg.com/lodash.clonedeep/-/lodash.clonedeep-4.5.0.tgz#e23f3f9c4f8fbdde872529c1071857a086e5ccef"
integrity sha1-4j8/nE+Pvd6HJSnBBxhXoIblzO8=

lodash.times@4.3.2:
version "4.3.2"
resolved "https://registry.yarnpkg.com/lodash.times/-/lodash.times-4.3.2.tgz#3e1f2565c431754d54ab57f2ed1741939285ca1d"
integrity sha1-Ph8lZcQxdU1Uq1fy7RdBk5KFyh0=

lodash@^4.17.12, lodash@^4.17.14:
version "4.17.15"
resolved "https://registry.yarnpkg.com/lodash/-/lodash-4.17.15.tgz#b447f6670a0455bbfeedd11392eff330ea097548"
Expand Down Expand Up @@ -584,6 +604,11 @@ os-tmpdir@~1.0.2:
resolved "https://registry.yarnpkg.com/os-tmpdir/-/os-tmpdir-1.0.2.tgz#bbe67406c79aa85c5cfec766fe5734555dfa1274"
integrity sha1-u+Z0BseaqFxc/sdm/lc0VV36EnQ=

p-map@2.0.0:
version "2.0.0"
resolved "https://registry.yarnpkg.com/p-map/-/p-map-2.0.0.tgz#be18c5a5adeb8e156460651421aceca56c213a50"
integrity sha512-GO107XdrSUmtHxVoi60qc9tUl/KkNKm+X2CF4P9amalpGxv5YqVPJNfSb0wcA+syCopkZvYYIzW8OVTQW59x/w==

parent-module@^1.0.0:
version "1.0.1"
resolved "https://registry.yarnpkg.com/parent-module/-/parent-module-1.0.1.tgz#691d2709e78c79fae3a156622452d00762caaaa2"
Expand Down

0 comments on commit ab11e95

Please sign in to comment.