Shreevaths taking over for Saicharan - Project status summary API for donut chart (backend)

package.json

@@ -52,7 +52,6 @@
   },
   "dependencies": {
     "@azure/storage-blob": "^12.26.0",
-    "mongoose": "^5.13.23",
     "@babel/cli": "^7.15.4",
     "@babel/core": "^7.10.2",
     "@babel/node": "^7.14.9",
@@ -70,6 +69,7 @@
     "compression": "^1.8.0",
     "cors": "^2.8.4",
     "cron": "^1.8.2",
+    "dayjs": "^1.11.13",
     "dotenv": "^5.0.1",
     "dropbox": "^10.34.0",
     "express": "^4.17.1",
@@ -82,6 +82,7 @@
     "moment": "^2.29.4",
     "moment-timezone": "^0.5.35",
     "mongodb": "^3.7.3",
+    "mongoose": "^5.13.23",
     "mongoose-validator": "^2.1.0",
     "multer": "^1.4.5-lts.1",
     "node-cache": "^5.1.2",

src/app.js

@@ -5,6 +5,7 @@ const app = express();
 const logger = require('./startup/logger');
 const globalErrorHandler = require('./utilities/errorHandling/globalErrorHandler');
 const experienceRoutes = require('./routes/applicantAnalyticsRoutes');
+
 logger.init();
 
 // The request handler must be the first middleware on the app
@@ -14,6 +15,7 @@ require('./startup/compression')(app);
 require('./startup/cors')(app);
 require('./startup/bodyParser')(app);
 require('./startup/middleware')(app);
+
 require('./startup/routes')(app);
 
 // The error handler must be before any other error middleware and after all controllers

src/controllers/projectStatus.controller.js

@@ -0,0 +1,26 @@
+const dayjs = require('dayjs');
+const { getProjectStatusSummary } = require('../services/projectStatus.service');
+
+exports.fetchProjectStatus = async (req, res) => {
+  try {
+    const { startDate, endDate } = req.query;
+
+    // Validate dates
+    if (startDate && !dayjs(startDate, 'YYYY-MM-DD', true).isValid()) {
+      return res.status(400).json({ message: 'Invalid startDate (YYYY-MM-DD)' });
+    }
+    if (endDate && !dayjs(endDate, 'YYYY-MM-DD', true).isValid()) {
+      return res.status(400).json({ message: 'Invalid endDate (YYYY-MM-DD)' });
+    }
+    if (startDate && endDate && dayjs(startDate).isAfter(dayjs(endDate))) {
+      return res.status(400).json({ message: 'startDate cannot be after endDate' });
+    }
+
+    const data = await getProjectStatusSummary({ startDate, endDate });
+    return res.json(data);
+  } catch (err) {
+    // eslint-disable-next-line no-console
+    console.error('fetchProjectStatus error:', err);
+    return res.status(500).json({ message: 'Internal server error' });
+  }
+};

src/models/projectStatus.js

@@ -0,0 +1,23 @@
+const mongoose = require('mongoose');
+
+const { Schema } = mongoose;
+
+const projectStatusSchema = new Schema(
+  {
+    name: { type: String, required: true },
+    status: {
+      type: String,
+      enum: ['Active', 'Completed', 'Delayed'],
+      required: true,
+    },
+    startDate: { type: Date, required: true },
+    completionDate: { type: Date },
+  },
+  { timestamps: true },
+);
+
+// Indexes for faster queries
+projectStatusSchema.index({ status: 1 });
+projectStatusSchema.index({ startDate: 1 });
+
+module.exports = mongoose.model('ProjectStatus', projectStatusSchema, 'projectStatus');

src/routes/projectStatusRouter.js

@@ -0,0 +1,16 @@
+const express = require('express');
+
+const router = express.Router();
+const { fetchProjectStatus } = require('../controllers/projectStatus.controller');
+
+//  Quick sanity check endpoint
+router.get('/status', (req, res) => {
+  console.log(' Project status route hit!');
+  res.json({ message: ' projectStatus route is working!' });
+});
+
+// Main API endpoint
+router.get('/summary', fetchProjectStatus);
+
+// Export the router directly (not a function)
+module.exports = router;

src/services/projectStatus.service.js

@@ -0,0 +1,50 @@
+const dayjs = require('dayjs');
+const ProjectStatus = require('../models/projectStatus');
+
+// Utility to compute percentages safely
+const calcPct = (count, total) => (total ? Number(((count / total) * 100).toFixed(1)) : 0.0);
+
+async function getProjectStatusSummary({ startDate, endDate }) {
+  const match = {};
+
+  if (startDate || endDate) {
+    match.startDate = {};
+    if (startDate) match.startDate.$gte = dayjs(startDate).startOf('day').toDate();
+    if (endDate) match.startDate.$lte = dayjs(endDate).endOf('day').toDate();
+  }
+
+  const pipeline = [
+    Object.keys(match).length ? { $match: match } : null,
+    { $group: { _id: '$status', count: { $sum: 1 } } },
+  ].filter(Boolean);
+
+  const rows = await ProjectStatus.aggregate(pipeline);
+
+  // Normalize counts
+  const counts = { active: 0, completed: 0, delayed: 0 };
+  rows.forEach((r) => {
+    if (r._id === 'Active') counts.active = r.count;
+    if (r._id === 'Completed') counts.completed = r.count;
+    if (r._id === 'Delayed') counts.delayed = r.count;
+  });
+
+  const totalProjects = counts.active + counts.completed + counts.delayed;
+
+  return {
+    totalProjects,
+    activeProjects: counts.active,
+    completedProjects: counts.completed,
+    delayedProjects: counts.delayed,
+    percentages: {
+      active: calcPct(counts.active, totalProjects),
+      completed: calcPct(counts.completed, totalProjects),
+      delayed: calcPct(counts.delayed, totalProjects),
+    },
+    window: {
+      startDate: startDate || null,
+      endDate: endDate || null,
+    },
+  };
+}
+
+module.exports = { getProjectStatusSummary };

src/startup/routes.js

@@ -36,6 +36,8 @@ const blueSquareEmailAssignment = require('../models/BlueSquareEmailAssignment')
 const hgnformRouter = require('../routes/hgnformRouter');
 const hgnFormResponseRouter = require('../routes/hgnFormResponseRouter');
 
+const projectStatusRouter = require('../routes/projectStatusRouter');
+
 const questionnaireAnalyticsRouter = require('../routes/questionnaireAnalyticsRouter');
 const weeklySummaryAIPrompt = require('../models/weeklySummaryAIPrompt');
 
@@ -262,6 +264,8 @@ const tagRouter = require('../routes/tagRouter')(tag);
 const applicantVolunteerRatioRouter = require('../routes/applicantVolunteerRatioRouter');
 
 module.exports = function (app) {
+  app.use('/api/project-status', projectStatusRouter);
+
   app.use('/api', forgotPwdRouter);
   app.use('/api', loginRouter);
   app.use('/api', forcePwdRouter);