mirror/fosrl.pangolin
1
0
Fork 0
mirror of https://github.com/fosrl/pangolin.git synced 2025-08-28 05:44:01 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Use an epoch number for the clients online to fix query

Browse source
This commit is contained in:
Owen 2025-08-13 20:26:50 -07:00
parent dc50190dc3
commit 285e24cdc7
No known key found for this signature in database
GPG key ID: 8271FDFFD9E0CCBD
3 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
server/db/pg/schema.ts
View file

@ -513,7 +513,7 @@ export const clients = pgTable("clients", {
megabytesIn: real("bytesIn"), megabytesIn: real("bytesIn"),
megabytesOut: real("bytesOut"), megabytesOut: real("bytesOut"),
lastBandwidthUpdate: varchar("lastBandwidthUpdate"), lastBandwidthUpdate: varchar("lastBandwidthUpdate"),
lastPing: varchar("lastPing"), lastPing: integer("lastPing"),
type: varchar("type").notNull(), // "olm" type: varchar("type").notNull(), // "olm"
online: boolean("online").notNull().default(false), online: boolean("online").notNull().default(false),
// endpoint: varchar("endpoint"), // endpoint: varchar("endpoint"),

2
server/db/sqlite/schema.ts
View file

@ -213,7 +213,7 @@ export const clients = sqliteTable("clients", {
megabytesIn: integer("bytesIn"), megabytesIn: integer("bytesIn"),
megabytesOut: integer("bytesOut"), megabytesOut: integer("bytesOut"),
lastBandwidthUpdate: text("lastBandwidthUpdate"), lastBandwidthUpdate: text("lastBandwidthUpdate"),
lastPing: text("lastPing"), lastPing: integer("lastPing"),
type: text("type").notNull(), // "olm" type: text("type").notNull(), // "olm"
online: integer("online", { mode: "boolean" }).notNull().default(false), online: integer("online", { mode: "boolean" }).notNull().default(false),
// endpoint: text("endpoint"), // endpoint: text("endpoint"),

4
server/routers/olm/handleOlmPingMessage.ts
View file

@ -28,7 +28,7 @@ export const startOfflineChecker = (): void => {
.set({ online: false }) .set({ online: false })
.where( .where(
eq(clients.online, true) && eq(clients.online, true) &&
(lt(clients.lastPing, twoMinutesAgo.toISOString()) || isNull(clients.lastPing)) (lt(clients.lastPing, twoMinutesAgo.getTime() / 1000) || isNull(clients.lastPing))
); );
} catch (error) { } catch (error) {
@ -72,7 +72,7 @@ export const handleOlmPingMessage: MessageHandler = async (context) => {
await db await db
.update(clients) .update(clients)
.set({ .set({
lastPing: new Date().toISOString(), lastPing: new Date().getTime() / 1000,
online: true, online: true,
}) })
.where(eq(clients.clientId, olm.clientId)); .where(eq(clients.clientId, olm.clientId));