diff --git a/server/routers/gerbil/receiveBandwidth.ts b/server/routers/gerbil/receiveBandwidth.ts index 098a1b558..e06a6d5d0 100644 --- a/server/routers/gerbil/receiveBandwidth.ts +++ b/server/routers/gerbil/receiveBandwidth.ts @@ -97,6 +97,7 @@ export async function flushSiteBandwidthToDb(): Promise { accumulator = new Map(); const currentTime = new Date().toISOString(); + const currentTimeEpochSeconds = Math.floor(new Date().getTime() / 1000); // Sort by publicKey for consistent lock ordering across concurrent // writers — deadlock-prevention strategy. @@ -119,7 +120,8 @@ export async function flushSiteBandwidthToDb(): Promise { .set({ megabytesOut: sql`COALESCE(${sites.megabytesOut}, 0) + ${bytesIn}`, megabytesIn: sql`COALESCE(${sites.megabytesIn}, 0) + ${bytesOut}`, - lastBandwidthUpdate: currentTime + lastBandwidthUpdate: currentTime, + lastPing: currentTimeEpochSeconds }) .where(eq(sites.pubKey, publicKey)) .returning({ @@ -321,4 +323,4 @@ export const receiveBandwidth = async ( ) ); } -}; \ No newline at end of file +};