mirrors/oneuptime
1
0
Fork 0
mirror of https://github.com/OneUptime/oneuptime synced 2024-11-21 14:49:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: Add API endpoint to get count of pending incoming request monitors

Browse Source
This commit is contained in:
Simon Larsen 2024-08-20 18:27:04 +01:00
parent 5237384d08
commit fe8aa54f1c
No known key found for this signature in database
GPG Key ID: 96C5DCA24769DBCA
1 changed files with 80 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

80
Ingestor/API/Monitor.ts
View File

@ -30,6 +30,7 @@ import Monitor from "Common/Models/DatabaseModels/Monitor";
import MonitorProbe from "Common/Models/DatabaseModels/MonitorProbe";
import MonitorService from "Common/Server/Services/MonitorService";
import ProjectService from "Common/Server/Services/ProjectService";
import MonitorType from "Common/Types/Monitor/MonitorType";
const router: ExpressRouter = Express.getRouter();
@ -119,6 +120,85 @@ router.get(
},
);
router.get(
"/monitor/pending-count/incoming-request",
ClusterKeyAuthorization.isAuthorizedServiceMiddleware,
async (
req: ExpressRequest,
res: ExpressResponse,
next: NextFunction,
): Promise<void> => {
try {
// get count of incoming request monitors which are not checked for heartbeat in last 2 minutes
const incomingMonitorPendingCount: PositiveNumber =
await MonitorService.countBy({
query: {
...MonitorService.getEnabledMonitorQuery(),
monitorType: MonitorType.IncomingRequest,
project: {
...ProjectService.getActiveProjectStatusQuery(),
},
incomingRequestMonitorHeartbeatCheckedAt:
QueryHelper.lessThanEqualToOrNull(
OneUptimeDate.addRemoveMinutes(
OneUptimeDate.getCurrentDate(),
-2,
),
),
},
props: {
isRoot: true,
},
});
const firstMonitorToBeFetched: Monitor | null =
await MonitorService.findOneBy({
query: {
...MonitorService.getEnabledMonitorQuery(),
monitorType: MonitorType.IncomingRequest,
project: {
...ProjectService.getActiveProjectStatusQuery(),
},
incomingRequestMonitorHeartbeatCheckedAt:
QueryHelper.lessThanEqualToOrNull(
OneUptimeDate.addRemoveMinutes(
OneUptimeDate.getCurrentDate(),
-2,
),
),
},
select: {
incomingRequestMonitorHeartbeatCheckedAt: true,
monitorSteps: true,
monitorType: true,
monitoringInterval: true,
},
sort: {
incomingRequestMonitorHeartbeatCheckedAt: SortOrder.Ascending,
},
props: {
isRoot: true,
},
});
return Response.sendJsonObjectResponse(req, res, {
incomingMonitorPendingCount: incomingMonitorPendingCount.toNumber(),
firstMonitorToBeFetched: firstMonitorToBeFetched,
incomingRequestMonitorHeartbeatCheckedAt:
firstMonitorToBeFetched?.incomingRequestMonitorHeartbeatCheckedAt,
friendlyIncomingRequestMonitorHeartbeatCheckedAt:
firstMonitorToBeFetched?.incomingRequestMonitorHeartbeatCheckedAt
? OneUptimeDate.getDateAsFormattedStringInMultipleTimezones({
date: firstMonitorToBeFetched?.incomingRequestMonitorHeartbeatCheckedAt,
})
: "",
});
} catch (err) {
return next(err);
}
},
);
// This API returns the count of the monitor waiting to be monitored.
router.get(
"/monitor/pending-count/:probeId",