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

refactor: Remove commented out code and unused imports in Monitor.ts

Browse Source
This commit is contained in:
Simon Larsen 2024-07-05 09:54:34 +01:00
parent b5fa564cb3
commit 0ecf3fa1e0
No known key found for this signature in database
GPG Key ID: 96C5DCA24769DBCA
1 changed files with 47 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

72
Ingestor/API/Monitor.ts
View File

@ -10,9 +10,9 @@ import BadDataException from "Common/Types/Exception/BadDataException";
import { JSONObject } from "Common/Types/JSON";
import ObjectID from "Common/Types/ObjectID";
import PositiveNumber from "Common/Types/PositiveNumber";
import Semaphore, {
SemaphoreMutex,
} from "CommonServer/Infrastructure/Semaphore";
// import Semaphore, {
// SemaphoreMutex,
// } from "CommonServer/Infrastructure/Semaphore";
import ClusterKeyAuthorization from "CommonServer/Middleware/ClusterKeyAuthorization";
import MonitorProbeService from "CommonServer/Services/MonitorProbeService";
import Query from "CommonServer/Types/Database/Query";
@ -198,16 +198,24 @@ router.post(
res: ExpressResponse,
next: NextFunction,
): Promise<void> => {
let mutex: SemaphoreMutex | null = null;
// let mutex: SemaphoreMutex | null = null;
logger.debug("Monitor list API called");
try {
const data: JSONObject = req.body;
const limit: number = (data["limit"] as number) || 100;
logger.debug("Monitor list API called with limit: " + limit);
logger.debug("Data:");
logger.debug(data);
if (
!(req as ProbeExpressRequest).probe ||
!(req as ProbeExpressRequest).probe?.id
) {
logger.error("Probe not found");
return Response.sendErrorResponse(
req,
res,
@ -218,6 +226,8 @@ router.post(
const probeId: ObjectID = (req as ProbeExpressRequest).probe!.id!;
if (!probeId) {
logger.error("Probe not found");
return Response.sendErrorResponse(
req,
res,
@ -225,15 +235,18 @@ router.post(
);
}
try {
mutex = await Semaphore.lock({
key: probeId.toString(),
});
} catch (err) {
logger.error(err);
}
// try {
// mutex = await Semaphore.lock({
// key: probeId.toString(),
// });
// } catch (err) {
// logger.error(err);
// }
//get list of monitors to be monitored
logger.debug("Fetching monitor list");
const monitorProbes: Array<MonitorProbe> =
await MonitorProbeService.findBy({
query: getMonitorFetchQuery((req as OneUptimeRequest).probe!.id!),
@ -257,6 +270,9 @@ router.post(
},
});
logger.debug("Fetched monitor list");
logger.debug(monitorProbes);
// update the lastMonitoredAt field of the monitors
for (const monitorProbe of monitorProbes) {
@ -289,13 +305,13 @@ router.post(
});
}
if (mutex) {
try {
await Semaphore.release(mutex);
} catch (err) {
logger.error(err);
}
}
// if (mutex) {
// try {
// await Semaphore.release(mutex);
// } catch (err) {
// logger.error(err);
// }
// }
const monitors: Array<Monitor> = monitorProbes
.map((monitorProbe: MonitorProbe) => {
@ -305,6 +321,9 @@ router.post(
return Boolean(monitor._id);
});
logger.debug("Populating secrets");
logger.debug(monitors);
// check if the monitor needs secrets to be filled.
const monitorsWithSecretPopulated: Array<Monitor> = [];
@ -316,6 +335,9 @@ router.post(
monitorsWithSecretPopulated.push(monitorWithSecrets);
}
logger.debug("Populated secrets");
logger.debug(monitorsWithSecretPopulated);
// return the list of monitors to be monitored
return Response.sendEntityArrayResponse(
@ -326,13 +348,13 @@ router.post(
Monitor,
);
} catch (err) {
try {
if (mutex) {
await Semaphore.release(mutex);
}
} catch (err) {
logger.error(err);
}
// try {
// if (mutex) {
// await Semaphore.release(mutex);
// }
// } catch (err) {
// logger.error(err);
// }
return next(err);
}