-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #71 from ReflectionsProjections/dev/alex/stats-ser…
…vice Stats Service
- Loading branch information
Showing
7 changed files
with
255 additions
and
12 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,195 @@ | ||
| import { Router } from "express"; | ||
| import { StatusCodes } from "http-status-codes"; | ||
| import { Database } from "../../database"; | ||
| import RoleChecker from "../../middleware/role-checker"; | ||
| import { Role } from "../auth/auth-models"; | ||
|
|
||
| const statsRouter = Router(); | ||
|
|
||
| // Get the number of people checked in (staff only) | ||
| statsRouter.get( | ||
| "/check-in", | ||
| RoleChecker([Role.enum.STAFF], false), | ||
| async (req, res, next) => { | ||
| try { | ||
| const attendees = await Database.ATTENDEES.find({ | ||
| events: { $ne: [] }, | ||
| }); | ||
|
|
||
| return res.status(StatusCodes.OK).json({ count: attendees.length }); | ||
| } catch (error) { | ||
| next(error); | ||
| } | ||
| } | ||
| ); | ||
|
|
||
| // Get the number of people eligible for merch item (staff only) | ||
| statsRouter.get( | ||
| "/merch-item/:PRICE", | ||
| RoleChecker([Role.enum.STAFF], false), | ||
| async (req, res, next) => { | ||
| try { | ||
| const price = req.params.PRICE; | ||
| if (!price) { | ||
| return res | ||
| .status(StatusCodes.BAD_REQUEST) | ||
| .json({ error: "MissingPriceParameter" }); | ||
| } | ||
| const attendees = await Database.ATTENDEES.find({ | ||
| points: { $gte: price }, | ||
| }); | ||
|
|
||
| return res.status(StatusCodes.OK).json({ count: attendees.length }); | ||
| } catch (error) { | ||
| next(error); | ||
| } | ||
| } | ||
| ); | ||
|
|
||
| // Get the number of priority attendees (staff only) | ||
| statsRouter.get( | ||
| "/priority-attendee", | ||
| RoleChecker([Role.enum.STAFF], false), | ||
| async (req, res, next) => { | ||
| try { | ||
| const attendees = await Database.ATTENDEES.find({ | ||
| hasCheckedIn: true, | ||
| }); | ||
|
|
||
| return res.status(StatusCodes.OK).json({ count: attendees.length }); | ||
| } catch (error) { | ||
| next(error); | ||
| } | ||
| } | ||
| ); | ||
|
|
||
| // Get the attendance of the past n events (staff only) | ||
| statsRouter.get( | ||
| "/attendance/:N", | ||
| RoleChecker([Role.enum.STAFF], false), | ||
| async (req, res, next) => { | ||
| try { | ||
| const numEvents = req.params.N; | ||
| if (!numEvents) { | ||
| return res | ||
| .status(StatusCodes.BAD_REQUEST) | ||
| .json({ error: "MissingNParameter" }); | ||
| } | ||
| const currentTime = new Date(); | ||
| const events = await Database.EVENTS.find({ | ||
| endTime: { $lt: currentTime }, | ||
| }) | ||
| .sort({ endTime: -1 }) | ||
| .limit(parseInt(numEvents)); | ||
|
|
||
| const attendanceCounts = events.map( | ||
| (event) => event.attendanceCount | ||
| ); | ||
|
|
||
| return res | ||
| .status(StatusCodes.OK) | ||
| .json({ attendanceCounts: attendanceCounts }); | ||
| } catch (error) { | ||
| next(error); | ||
| } | ||
| } | ||
| ); | ||
|
|
||
| // Get the dietary restriction breakdown/counts (staff only) | ||
| statsRouter.get( | ||
| "/dietary-restrictions", | ||
| RoleChecker([Role.enum.STAFF], true), | ||
| async (req, res, next) => { | ||
| try { | ||
| const results = await Promise.allSettled([ | ||
| Database.ATTENDEES.countDocuments({ | ||
| allergies: { $size: 0 }, | ||
| dietaryRestrictions: { $size: 0 }, | ||
| }), | ||
| Database.ATTENDEES.countDocuments({ | ||
| allergies: { $size: 0 }, | ||
| dietaryRestrictions: { $ne: [] }, | ||
| }), | ||
| Database.ATTENDEES.countDocuments({ | ||
| allergies: { $ne: [] }, | ||
| dietaryRestrictions: { $size: 0 }, | ||
| }), | ||
| Database.ATTENDEES.countDocuments({ | ||
| allergies: { $ne: [] }, | ||
| dietaryRestrictions: { $ne: [] }, | ||
| }), | ||
| Database.ATTENDEES.aggregate([ | ||
| { | ||
| $unwind: "$allergies", | ||
| }, | ||
| { | ||
| $group: { | ||
| _id: "$allergies", | ||
| count: { $sum: 1 }, | ||
| }, | ||
| }, | ||
| ]), | ||
| Database.ATTENDEES.aggregate([ | ||
| { | ||
| $unwind: "$dietaryRestrictions", | ||
| }, | ||
| { | ||
| $group: { | ||
| _id: "$dietaryRestrictions", | ||
| count: { $sum: 1 }, | ||
| }, | ||
| }, | ||
| ]), | ||
| ]); | ||
|
|
||
| for (let i = 0; i < results.length; i++) { | ||
| if (results[i].status === "rejected") { | ||
| return res | ||
| .status(StatusCodes.INTERNAL_SERVER_ERROR) | ||
| .send({ error: "InternalError" }); | ||
| } | ||
| } | ||
|
|
||
| type mongoQueryType = { | ||
| _id: string; | ||
| count: number; | ||
| }; | ||
| const allergyCounts: { [key: string]: number } = {}; | ||
| const unprocessedAllergyCounts = ( | ||
| results[4] as PromiseFulfilledResult<mongoQueryType[]> | ||
| ).value; | ||
| for (let i = 0; i < unprocessedAllergyCounts.length; i++) { | ||
| allergyCounts[unprocessedAllergyCounts[i]._id as string] = | ||
| unprocessedAllergyCounts[i].count; | ||
| } | ||
| const dietaryRestrictionCounts: { [key: string]: number } = {}; | ||
| const unprocessedDietaryRestrictionCountss = ( | ||
| results[5] as PromiseFulfilledResult<mongoQueryType[]> | ||
| ).value; | ||
| for ( | ||
| let i = 0; | ||
| i < unprocessedDietaryRestrictionCountss.length; | ||
| i++ | ||
| ) { | ||
| dietaryRestrictionCounts[ | ||
| unprocessedDietaryRestrictionCountss[i]._id as string | ||
| ] = unprocessedDietaryRestrictionCountss[i].count; | ||
| } | ||
|
|
||
| return res.status(StatusCodes.OK).json({ | ||
| none: (results[0] as PromiseFulfilledResult<number>).value, | ||
| dietaryRestrictions: ( | ||
| results[1] as PromiseFulfilledResult<number> | ||
| ).value, | ||
| allergies: (results[2] as PromiseFulfilledResult<number>).value, | ||
| both: (results[3] as PromiseFulfilledResult<number>).value, | ||
| allergyCounts: allergyCounts, | ||
| dietaryRestrictionCounts: dietaryRestrictionCounts, | ||
| }); | ||
| } catch (error) { | ||
| next(error); | ||
| } | ||
| } | ||
| ); | ||
|
|
||
| export default statsRouter; |