Skip to content

Commit 320f633

Browse files
committed
resolve comments on the PR
1 parent 2de8005 commit 320f633

File tree

3 files changed

+9
-32
lines changed

3 files changed

+9
-32
lines changed

models/monitor.js

Lines changed: 4 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,7 @@ const { Conflict, NotFound } = require("http-errors");
22
const fireStore = require("../utils/firestore");
33
const trackedProgressesCollection = fireStore.collection("trackedProgresses");
44
const { assertUserOrTaskExists } = require("../utils/progresses");
5-
const {
6-
buildTrackedProgressQueryByType,
7-
buildQueryForFetchingDocsOfType,
8-
getTrackedProgressDocs,
9-
buildQueryToFetchTrackedDoc,
10-
} = require("../utils/monitor");
5+
const { buildQueryByTypeId, buildQueryForFetchingDocsOfType, getTrackedProgressDocs } = require("../utils/monitor");
116
const { RESPONSE_MESSAGES } = require("../constants/monitor");
127
const { RESOURCE_NOT_FOUND, RESOURCE_ALREADY_TRACKED } = RESPONSE_MESSAGES;
138

@@ -27,7 +22,7 @@ const { RESOURCE_NOT_FOUND, RESOURCE_ALREADY_TRACKED } = RESPONSE_MESSAGES;
2722
const createTrackedProgressDocument = async (documentData) => {
2823
const { userId, taskId } = documentData;
2924
await assertUserOrTaskExists({ userId, taskId });
30-
const query = buildTrackedProgressQueryByType({ userId, taskId });
25+
const query = buildQueryByTypeId({ userId, taskId });
3126
const existingDocumentSnapshot = await query.get();
3227
if (!existingDocumentSnapshot.empty) {
3328
throw new Conflict(RESOURCE_ALREADY_TRACKED);
@@ -59,7 +54,7 @@ const createTrackedProgressDocument = async (documentData) => {
5954
const updateTrackedProgressDocument = async (req) => {
6055
const { type, typeId } = req.params;
6156
const updatedData = { type, [`${type}Id`]: typeId };
62-
const query = buildTrackedProgressQueryByType(updatedData);
57+
const query = buildQueryByTypeId(updatedData);
6358
const existingDocumentSnapshot = await query.get();
6459
if (existingDocumentSnapshot.empty) {
6560
throw new NotFound(RESOURCE_NOT_FOUND);
@@ -85,7 +80,7 @@ const getTrackedProgressDocuments = async (reqQuery) => {
8580
const { userId, taskId } = reqQuery;
8681
if (userId || taskId) {
8782
await assertUserOrTaskExists({ userId, taskId });
88-
query = buildQueryToFetchTrackedDoc(reqQuery);
83+
query = buildQueryByTypeId(reqQuery);
8984
docsData = (await getTrackedProgressDocs(query))[0];
9085
} else {
9186
query = buildQueryForFetchingDocsOfType(reqQuery);

test/integration/monitor.js

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,16 +24,16 @@ const cookieName = config.get("userToken.cookieName");
2424
const { expect } = chai;
2525

2626
describe("Test the tracked Progress API", function () {
27-
let userId0, userId1, superUser;
27+
let userId0, userId1, superUserId;
2828
let userIdToken0, superUserToken;
2929
let taskId0, taskId1;
3030

3131
beforeEach(async function () {
3232
userId0 = await addUser(userData0);
3333
userIdToken0 = authService.generateAuthToken({ userId: userId0 });
3434
userId1 = await addUser(userData1);
35-
superUser = await addUser(superUserData);
36-
superUserToken = authService.generateAuthToken({ userId: superUser });
35+
superUserId = await addUser(superUserData);
36+
superUserToken = authService.generateAuthToken({ userId: superUserId });
3737

3838
const taskObject0 = await updateTask(taskData[0]);
3939
taskId0 = taskObject0.taskId;

utils/monitor.js

Lines changed: 2 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ const { RESOURCE_NOT_FOUND } = RESPONSE_MESSAGES;
1212
* @param {string} queryParams.taskId - The ID of the task (optional).
1313
* @returns {Firestore.Query} - A Firestore query to check if a document exists.
1414
*/
15-
const buildTrackedProgressQueryByType = (queryParams) => {
15+
const buildQueryByTypeId = (queryParams) => {
1616
const { userId, taskId } = queryParams;
1717
if (userId) {
1818
return trackedProgressesCollection.where("type", "==", "user").where("userId", "==", userId);
@@ -38,23 +38,6 @@ const buildQueryForFetchingDocsOfType = (queryParams) => {
3838
return query;
3939
};
4040

41-
/**
42-
* Builds a Firestore query for fetching a specific tracked progress document based on the provided query parameters.
43-
*
44-
* @param {Object} queryParams - The query parameters for fetching a specific tracked progress document.
45-
* @param {string} queryParams.userId - The userId of the tracked progress document
46-
* @param {string} queryParams.taskId - The taskId of the tracked progress document
47-
* @returns {Firestore.Query} - A Firestore query for fetching a specific tracked progress document.
48-
*/
49-
const buildQueryToFetchTrackedDoc = (queryParams) => {
50-
const { userId, taskId } = queryParams;
51-
if (userId) {
52-
return trackedProgressesCollection.where("type", "==", "user").where("userId", "==", userId);
53-
} else {
54-
return trackedProgressesCollection.where("type", "==", "task").where("taskId", "==", taskId);
55-
}
56-
};
57-
5841
/**
5942
* Retrieves progress documents from Firestore based on the given query.
6043
* @param {Query} query - A Firestore query object for fetching progress documents.
@@ -74,8 +57,7 @@ const getTrackedProgressDocs = async (query) => {
7457
};
7558

7659
module.exports = {
77-
buildTrackedProgressQueryByType,
60+
buildQueryByTypeId,
7861
buildQueryForFetchingDocsOfType,
7962
getTrackedProgressDocs,
80-
buildQueryToFetchTrackedDoc,
8163
};

0 commit comments

Comments
 (0)