From cd3767a04065de99396be7b7461d0927b20c9429 Mon Sep 17 00:00:00 2001
From: Alex Holliday <ajhollid@gmail.com>
Date: Thu, 9 Jan 2025 20:50:08 -0800
Subject: [PATCH] new duration algorithm

---
 Server/db/mongo/modules/monitorModule.js      |  1 +
 .../db/mongo/modules/monitorModuleQueries.js  | 53 +++++++++++++++----
 2 files changed, 45 insertions(+), 9 deletions(-)

diff --git a/Server/db/mongo/modules/monitorModule.js b/Server/db/mongo/modules/monitorModule.js
index 745aecf88..d66cd310f 100644
--- a/Server/db/mongo/modules/monitorModule.js
+++ b/Server/db/mongo/modules/monitorModule.js
@@ -353,6 +353,7 @@ const getUptimeDetailsById = async (req) => {
 		const monitorStats = {
 			...monitor.toObject(),
 			stats: {
+				uptimeStreak: monitorData[0].uptimeStreak,
 				avgResponseTime: monitorData[0].avgResponseTime,
 				totalChecks: monitorData[0].totalChecks,
 				timeSinceLastCheck: monitorData[0].timeSinceLastCheck,
diff --git a/Server/db/mongo/modules/monitorModuleQueries.js b/Server/db/mongo/modules/monitorModuleQueries.js
index ccafbcbdc..18914c0c4 100644
--- a/Server/db/mongo/modules/monitorModuleQueries.js
+++ b/Server/db/mongo/modules/monitorModuleQueries.js
@@ -31,22 +31,43 @@ const buildUptimeDetailsPipeline = (monitor, dates, dateString) => {
 						},
 					},
 				],
-				uptimeDuration: [
-					{
-						$match: {
-							status: false,
-						},
-					},
+				uptimeStreak: [
 					{
 						$sort: {
-							createdAt: 1,
+							createdAt: -1,
 						},
 					},
 					{
 						$group: {
 							_id: null,
-							lastFalseCheck: {
-								$last: "$$ROOT",
+							checks: { $push: "$$ROOT" },
+						},
+					},
+					{
+						$project: {
+							streak: {
+								$reduce: {
+									input: "$checks",
+									initialValue: { checks: [], foundFalse: false },
+									in: {
+										$cond: [
+											{
+												$and: [
+													{ $not: "$$value.foundFalse" }, // Haven't found a false yet
+													{ $eq: ["$$this.status", true] }, // Current check is true
+												],
+											},
+											{
+												checks: { $concatArrays: ["$$value.checks", ["$$this"]] },
+												foundFalse: false,
+											},
+											{
+												checks: "$$value.checks",
+												foundFalse: true, // Mark that we found a false
+											},
+										],
+									},
+								},
 							},
 						},
 					},
@@ -188,6 +209,20 @@ const buildUptimeDetailsPipeline = (monitor, dates, dateString) => {
 		},
 		{
 			$project: {
+				uptimeStreak: {
+					$cond: [
+						{ $eq: [{ $size: { $first: "$uptimeStreak.streak.checks" } }, 0] },
+						0,
+						{
+							$subtract: [
+								new Date(),
+								{
+									$last: { $first: "$uptimeStreak.streak.checks.createdAt" },
+								},
+							],
+						},
+					],
+				},
 				avgResponseTime: {
 					$arrayElemAt: ["$aggregateData.avgResponseTime", 0],
 				},