pixies

1import schedule from 'node-schedule';
2import { triggerEvent } from "../controller/integrations.js";
3
4let currentState = "ping";
5let job;
6
7export const setState = (state = "ping") => {
8    currentState = state;
9};
10
11export const sendPing = async (type, message) => {
12    await triggerEvent("minutePassed", {type, message});
13};
14
15export const sendCurrent = async () => {
16    if (currentState === "ping") await sendPing();
17};
18
19export const sendError = async (error = "Unknown error") => {
20    await triggerEvent("testFailed", error);
21};
22
23export const sendRunning = async () => {
24    await triggerEvent("testStarted");
25};
26
27export const sendFinished = async (data) => {
28    await triggerEvent("testFinished", data);
29};
30
31export const startTimer = () => {
32    job = schedule.scheduleJob('* * * * *', () => sendCurrent());
33};
34
35export const stopTimer = () => {
36    if (job !== undefined) {
37        job.cancel();
38        job = undefined;
39    }
40};