mirror/Checkmate
1
0
Fork 0
mirror of https://github.com/bluewave-labs/Checkmate.git synced 2026-05-17 23:18:48 -05:00
Code Issues Packages Projects Releases Wiki Activity

format

Browse Source
This commit is contained in:
Alex Holliday
2026-01-16 18:17:55 +00:00
parent 95cd33ac06
commit 5784fec3d1
2 changed files with 19 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/src/service/infrastructure/SuperSimpleQueue/SuperSimpleQueue.ts
+18 -18
View File
@@ -217,24 +217,24 @@ class SuperSimpleQueue implements ISuperSimpleQueue {
};
getJobs = async () => {
const jobs = await this.scheduler.getJobs();
return jobs.map((job) => {
return {
monitorId: job.id,
monitorUrl: job?.data?.url || null,
monitorType: job?.data?.type || null,
monitorInterval: job?.data?.interval || null,
active: job.active,
lockedAt: job.lockedAt ?? null,
runCount: job.runCount ?? 0,
failCount: job.failCount ?? 0,
failReason: job.lastFailReason ?? null,
lastRunAt: job.lastRunAt ?? null,
lastFinishedAt: job.lastFinishedAt ?? null,
lastRunTook: job.lockedAt ? null : (job.lastFinishedAt ?? 0) - (job.lastRunAt ?? 0),
lastFailedAt: job.lastFailedAt ?? null,
};
});
const jobs = await this.scheduler.getJobs();
return jobs.map((job) => {
return {
monitorId: job.id,
monitorUrl: job?.data?.url || null,
monitorType: job?.data?.type || null,
monitorInterval: job?.data?.interval || null,
active: job.active,
lockedAt: job.lockedAt ?? null,
runCount: job.runCount ?? 0,
failCount: job.failCount ?? 0,
failReason: job.lastFailReason ?? null,
lastRunAt: job.lastRunAt ?? null,
lastFinishedAt: job.lastFinishedAt ?? null,
lastRunTook: job.lockedAt ? null : (job.lastFinishedAt ?? 0) - (job.lastRunAt ?? 0),
lastFailedAt: job.lastFailedAt ?? null,
};
});
};
flushQueues = async () => {
server/test/superSimpleQueueHelper.test.ts
+1 -3
View File
@@ -42,9 +42,7 @@ describe("SuperSimpleQueueHelper", () => {
const { helper } = createHelper({
networkService: { requestStatus: jest.fn().mockResolvedValue(networkResponse) },
statusService: {
updateMonitorStatus: jest
.fn()
.mockResolvedValue({ monitor: updatedMonitor, statusChanged: true, prevStatus: false }),
updateMonitorStatus: jest.fn().mockResolvedValue({ monitor: updatedMonitor, statusChanged: true, prevStatus: false }),
},
notificationService: { handleNotifications: jest.fn().mockResolvedValue(undefined) },
});