From 7002d95da1bd272dabe9d880e32410233a3d9019 Mon Sep 17 00:00:00 2001 From: "autofix-ci[bot]" <114827586+autofix-ci[bot]@users.noreply.github.com> Date: Wed, 14 Jan 2026 14:03:54 +0000 Subject: [PATCH] [autofix.ci] apply automated fixes --- .../test-push-api-determine-status.js | 82 ++++++++++--------- 1 file changed, 43 insertions(+), 39 deletions(-) diff --git a/test/backend-test/test-push-api-determine-status.js b/test/backend-test/test-push-api-determine-status.js index 0f4d4115f..fa9bef171 100644 --- a/test/backend-test/test-push-api-determine-status.js +++ b/test/backend-test/test-push-api-determine-status.js @@ -25,42 +25,46 @@ const createEntity = async (type, data) => { return entity; }; -const createUser = () => createEntity("user", { - username: `test-${++userCounter}-${Date.now()}`, - password: "Tellorian2003105$", - active: 1 -}); - -const createPushMonitor = (user, pushToken, maxretries) => createEntity("monitor", { - name: "Push Monitor", - active: 1, - user_id: user.id, - type: "push", - push_token: pushToken, - maxretries, - interval: 60 -}); - -const createHeartbeat = ({ monitorId, status, retries, time }) => createEntity("heartbeat", { - important: 0, - monitor_id: monitorId, - status, - msg: "No heartbeat in the time window", - time, - ping: null, - duration: 0, - down_count: 0, - retries -}); - -const startApiApp = () => new Promise((resolve) => { - const router = require("../../server/routers/api-router"); - const app = express().use(router); - const server = app.listen(0, () => { - const { port } = server.address(); - resolve({ server, url: `http://127.0.0.1:${port}` }); +const createUser = () => + createEntity("user", { + username: `test-${++userCounter}-${Date.now()}`, + password: "Tellorian2003105$", + active: 1, + }); + +const createPushMonitor = (user, pushToken, maxretries) => + createEntity("monitor", { + name: "Push Monitor", + active: 1, + user_id: user.id, + type: "push", + push_token: pushToken, + maxretries, + interval: 60, + }); + +const createHeartbeat = ({ monitorId, status, retries, time }) => + createEntity("heartbeat", { + important: 0, + monitor_id: monitorId, + status, + msg: "No heartbeat in the time window", + time, + ping: null, + duration: 0, + down_count: 0, + retries, + }); + +const startApiApp = () => + new Promise((resolve) => { + const router = require("../../server/routers/api-router"); + const app = express().use(router); + const server = app.listen(0, () => { + const { port } = server.address(); + resolve({ server, url: `http://127.0.0.1:${port}` }); + }); }); -}); describe("Push API determineStatus retries", () => { let api; @@ -90,10 +94,10 @@ describe("Push API determineStatus retries", () => { test("PENDING + retries >= maxretries + status=down => DOWN and retries reset to 0", async () => { const monitor = await createPushMonitor(await createUser(), "token-1", 3); await createHeartbeat({ monitorId: monitor.id, status: 2, retries: 3, time: isoNow() }); - + const res = await fetch(`${api.url}/api/push/token-1?status=down&msg=test`); assert.strictEqual(res.ok, true); - + const latest = await R.findOne("heartbeat", " monitor_id = ? ORDER BY id DESC", [monitor.id]); assert.ok(latest); assert.strictEqual(latest.status, 0); @@ -103,10 +107,10 @@ describe("Push API determineStatus retries", () => { test("PENDING + retries < maxretries + status=down => stays PENDING and retries increments", async () => { const monitor = await createPushMonitor(await createUser(), "token-2", 3); await createHeartbeat({ monitorId: monitor.id, status: 2, retries: 1, time: isoNow() }); - + const res = await fetch(`${api.url}/api/push/token-2?status=down&msg=test`); assert.strictEqual(res.ok, true); - + const latest = await R.findOne("heartbeat", " monitor_id = ? ORDER BY id DESC", [monitor.id]); assert.ok(latest); assert.strictEqual(latest.status, 2);