61 lines
2.6 KiB
TypeScript
61 lines
2.6 KiB
TypeScript
/**
|
|
* While in production we will monitor the readers if we have not gotten a heartbeat in the last 5 min we will send a reboot command along with an email.
|
|
*/
|
|
|
|
import {eq, sql} from "drizzle-orm";
|
|
import {db} from "../../../../database/dbclient.js";
|
|
import {rfidReaders} from "../../../../database/schema/rfidReaders.js";
|
|
import {createLog} from "../../logger/logger.js";
|
|
|
|
export const newHeartBeat = async (reader: string) => {
|
|
/**
|
|
* When a heat beat is sent over for a reader we want to update the reader.
|
|
*/
|
|
|
|
try {
|
|
const heatBeat = await db
|
|
.update(rfidReaders)
|
|
.set({lastHeartBeat: sql`NOW()`})
|
|
.where(eq(rfidReaders.reader, reader));
|
|
createLog("info", "rfid", "rfid", `${reader} just updated its heatBeat.`);
|
|
return {success: true, message: `${reader} just updated its heatBeat.`};
|
|
} catch (error) {
|
|
createLog("error", "rfid", "rfid", `${reader} encountered an error while updating the heatbeat, ${error}`);
|
|
return {success: false, message: `${reader} encountered an error while updating the heatbeat, ${error}`};
|
|
}
|
|
};
|
|
|
|
export const badRead = async (reader: string) => {
|
|
/**
|
|
* When we have a bad read we want to make sure the reader shows this was well.
|
|
*/
|
|
try {
|
|
const badRead = await db
|
|
.update(rfidReaders)
|
|
.set({lastTrigger: sql`NOW()`, lastTriggerGood: false})
|
|
.where(eq(rfidReaders.reader, reader));
|
|
createLog("info", "rfid", "rfid", `${reader} just Triggered a bad read.`);
|
|
return {success: true, message: `${reader} just Triggered a bad read.`};
|
|
} catch (error) {
|
|
createLog("error", "rfid", "rfid", `${reader} encountered an error while updating the heatbeat, ${error}`);
|
|
return {success: false, message: `${reader} encountered an error while updating the heatbeat, ${error}`};
|
|
}
|
|
};
|
|
|
|
export const goodRead = async (reader: string) => {
|
|
/**
|
|
* When we have a bad read we want to make sure the reader shows this was well.
|
|
*/
|
|
try {
|
|
const goodRead = await db
|
|
.update(rfidReaders)
|
|
.set({lastTrigger: sql`NOW()`, lastTriggerGood: true})
|
|
.where(eq(rfidReaders.reader, reader));
|
|
createLog("info", "rfid", "rfid", `${reader} just Triggered a good read.`);
|
|
return {success: true, message: `${reader} just Triggered a good read.`};
|
|
} catch (error) {
|
|
createLog("error", "rfid", "rfid", `${reader} encountered an error while updating the heatbeat, ${error}`);
|
|
return {success: false, message: `${reader} encountered an error while updating the heatbeat, ${error}`};
|
|
}
|
|
};
|