[autofix.ci] apply automated fixes
This commit is contained in:
parent
fe19f89c9d
commit
7002d95da1
@ -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);
|
||||
|
||||
Loading…
Reference in New Issue
Block a user