Spaces:
Configuration error
Configuration error
File size: 2,874 Bytes
eeb3436 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 | function createRuntimeState() {
const state = {
startedAt: new Date().toISOString(),
startedAtMs: Date.now(),
db: {
healthy: false,
lastCheckAt: null,
lastError: null,
},
mqtt: {
connected: false,
topicFilter: null,
lastConnectedAt: null,
lastDisconnectedAt: null,
lastError: null,
lastMessageAt: null,
messagesReceived: 0,
messagesAccepted: 0,
messagesRejected: 0,
lastRejectReason: null,
queueBacklog: 0,
},
jobs: {
offlineScannerRuns: 0,
offlineScannerLastRunAt: null,
offlineScannerLastError: null,
},
};
return {
markDbHealthy() {
state.db.healthy = true;
state.db.lastCheckAt = new Date().toISOString();
state.db.lastError = null;
},
markDbError(error) {
state.db.healthy = false;
state.db.lastCheckAt = new Date().toISOString();
state.db.lastError = {
at: new Date().toISOString(),
message: error && error.message ? error.message : String(error),
};
},
markMqttConnected(topicFilter) {
state.mqtt.connected = true;
state.mqtt.topicFilter = topicFilter;
state.mqtt.lastConnectedAt = new Date().toISOString();
},
markMqttDisconnected() {
state.mqtt.connected = false;
state.mqtt.lastDisconnectedAt = new Date().toISOString();
},
markMqttError(error) {
state.mqtt.lastError = {
at: new Date().toISOString(),
message: error && error.message ? error.message : String(error),
};
},
markMqttMessageReceived() {
state.mqtt.messagesReceived += 1;
state.mqtt.lastMessageAt = new Date().toISOString();
},
markMqttMessageAccepted() {
state.mqtt.messagesAccepted += 1;
state.mqtt.lastRejectReason = null;
},
markMqttMessageRejected(reason) {
state.mqtt.messagesRejected += 1;
state.mqtt.lastRejectReason = reason;
},
setMqttQueueBacklog(size) {
state.mqtt.queueBacklog = size;
},
markOfflineScanRun() {
state.jobs.offlineScannerRuns += 1;
state.jobs.offlineScannerLastRunAt = new Date().toISOString();
state.jobs.offlineScannerLastError = null;
},
markOfflineScanError(error) {
state.jobs.offlineScannerRuns += 1;
state.jobs.offlineScannerLastRunAt = new Date().toISOString();
state.jobs.offlineScannerLastError = {
at: new Date().toISOString(),
message: error && error.message ? error.message : String(error),
};
},
snapshot() {
return {
startedAt: state.startedAt,
uptimeSeconds: Math.floor((Date.now() - state.startedAtMs) / 1000),
db: { ...state.db },
mqtt: { ...state.mqtt },
jobs: { ...state.jobs },
};
},
};
}
module.exports = {
createRuntimeState,
};
|