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
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
|
const mongoObjectId = require('mongodb').ObjectID
const trackerCollection = 'exerciseTracker'
const trackerUserCollection = 'exerciseTrackerUsers'
// Challenge 4v2 - Exercise Tracker - UI page
exports.uiPage = function (req, res) {
res.render('exercise/index')
}
exports.addUser = function (req, res) {
// lookup username; insert and return ID if not taken; otherwise return error message.
const collection = req.app.dbConn.getDB().collection(trackerUserCollection)
const lookup = collection.find({
username: req.body.username
}).toArray(function (err, documents) {
if (err) {
console.log(err)
res.status(500).send('Unable to complete action.')
} else {
if (documents.length > 0) { // username was found
res.status(400).send('Username \'' + req.body.username + '\' already taken.')
} else {
collection.insertOne({'username': req.body.username}, function (err, result) {
if (err) {
console.log(err)
res.status(500).send('500 server error; unable to save username.')
} else {
res.json({
'username': req.body.username,
'_id': result.insertedId
})
}
})
}
}
})
}
exports.addActivity = function (req, res) {
// given the userID, activity description, duration, and optionally, date
// look up the userID - if it exists, enter a new data entry about the activity to the database
// if the user id doesn't exist, respond with a 400 user not found message
var dateEpoch = new Date().getTime()
if (req.body.date) {
dateEpoch = new Date(req.body.date).getTime()
}
const collection = req.app.dbConn.getDB().collection(trackerUserCollection)
const lookup = collection.find({
'_id': mongoObjectId(req.body.userId)
}).toArray(function (err, documents) {
if (err) {
console.log(err)
res.status(500).send('Unable to complete action.')
} else {
if (documents.length > 0) { // user found
const updateCollection = req.app.dbConn.getDB().collection(trackerCollection)
const update = updateCollection.insertOne({
userId: documents[0]._id,
description: req.body.description,
duration: req.body.duration,
date: dateEpoch
}, function (err, result) {
if (err) {
console.log(err)
res.status(500).send('500 server error: unable to add entry.')
} else { // save successful
res.json({
'username': documents[0].username,
'description': req.body.description,
'duration': req.body.duration,
'_id': documents[0]._id,
'date': new Date(dateEpoch).toDateString()
})
}
})
} else {
res.status(400).send('Unable to locate userID: ' + req.body.userId)
}
}
})
}
exports.getUserLog = function (req, res) {
// return user exercise data given the user's id.
// Check for optional parameters and validate them:
var opts = {from: null, to: null, limit: 0}
var queryParams = {
'userId': mongoObjectId(req.query.userId)
}
if (req.query.from && req.query.to) {
if (!isNaN(Date.parse(req.query.from)) && !isNaN(Date.parse(req.query.to))) {
queryParams['date'] = {
$gte: Date.parse(req.query.from),
$lte: Date.parse(req.query.to)
}
}
} else if (req.query.to) {
if (!isNaN(Date.parse(req.query.to))) {
queryParams['date'] = { $lte: Date.parse(req.query.to) }
}
} else if (req.query.from) {
if (!isNaN(Date.parse(req.query.from))) {
queryParams['date'] = { $gte: Date.parse(req.query.from) }
}
}
if (req.query.limit && !isNaN(req.query.limit)) {
opts.limit = Math.ceil(Math.abs(req.query.limit))
}
if (!req.query.userId) {
res.status(400).send('Must query for an ID.')
} else {
const usersDb = req.app.dbConn.getDB().collection(trackerUserCollection)
const activitiesDb = req.app.dbConn.getDB().collection(trackerCollection)
const lookupUser = usersDb.find({
'_id': mongoObjectId(req.query.userId)
}).toArray(function (err, userDocs) {
if (err) {
console.log(err)
res.status(500).send('Unable to query user.')
} else {
if (userDocs.length > 0) { // user found, can find their stuff.
var activitiesCursor = activitiesDb.find(queryParams)
if (opts.limit) {
activitiesCursor = activitiesCursor.sort('date', 1).limit(opts.limit)
}
activitiesCursor.toArray(function (err, activitiesDocs) {
if (err) {
console.log(err)
res.status(500).send('Unable to query user activities.')
} else {
var resData = {
_id: req.query.userId,
username: userDocs[0].username,
count: activitiesDocs.length,
logData: []
}
for (var i = 0; i < activitiesDocs.length; i++) {
resData.logData.push({
'description': activitiesDocs[i].description,
'duration': activitiesDocs[i].duration,
'date': new Date(activitiesDocs[i].date).toDateString()
})
}
res.json(resData)
}
})
} else {
res.status(400).send('Unable to locate userID: ' + req.query.userId)
}
}
})
}
}
|