From f0207bab0218ba3222b277a908dbf42303f5b09c Mon Sep 17 00:00:00 2001 From: "Alex Pooley (@zuedev)" Date: Fri, 24 Jul 2026 17:40:27 +0100 Subject: add database stuff to repo --- .../volumes/pocketbase/pb_hooks/main.pb.js | 29 ++++++++++++++++++++++ 1 file changed, 29 insertions(+) create mode 100644 174bg/database/volumes/pocketbase/pb_hooks/main.pb.js (limited to '174bg/database/volumes/pocketbase/pb_hooks/main.pb.js') diff --git a/174bg/database/volumes/pocketbase/pb_hooks/main.pb.js b/174bg/database/volumes/pocketbase/pb_hooks/main.pb.js new file mode 100644 index 0000000..b7d385d --- /dev/null +++ b/174bg/database/volumes/pocketbase/pb_hooks/main.pb.js @@ -0,0 +1,29 @@ +routerAdd("GET", "/heartbeat", (e) => { + try { + const result = new DynamicModel({ + "value": nullString(), + }) + + let dateNow = Date.now(); + + try { + $app.db() + .newQuery(`SELECT value FROM key_value_store WHERE key = "heartbeat"`) + .one(result); + } catch (error) { + return e.json(404, { "error": "Heartbeat not found" }); + } + + let heartbeatValue = parseInt(result.value); + let timeDifference = dateNow - heartbeatValue; + let withinThreshold = timeDifference <= 60000; // 60 seconds threshold + + return e.json(200, { "timeDifference": timeDifference, "withinThreshold": withinThreshold }); + } catch (error) { + return e.json(500, { "error": "Internal Server Error", "details": error.message }); + } +}); + +cronAdd("heartbeat", "* * * * *", () => { + $app.db().newQuery(`UPDATE key_value_store SET value = ${Date.now()} WHERE key = "heartbeat"`).execute() +}) \ No newline at end of file -- cgit v1.2.3