From 4a5d4bbb71c68dc41ea6263f77874c08e2219d37 Mon Sep 17 00:00:00 2001
From: Ben <wilsob12@gmail.com>
Date: Sun, 7 Jun 2026 21:26:22 -0400
Subject: [PATCH] Reduce dashboard Timescale query load

---
 .../user-agent-report/user-agent-report.service.ts       | 9 +--------
 src/ORM/client-statistics/client-statistics.service.ts   | 3 +--
 test/timescale-redis.integration-spec.ts                 | 1 -
 3 files changed, 2 insertions(+), 11 deletions(-)

diff --git a/src/ORM/_views/user-agent-report/user-agent-report.service.ts b/src/ORM/_views/user-agent-report/user-agent-report.service.ts
index ff9622b..d2eff3a 100644
--- a/src/ORM/_views/user-agent-report/user-agent-report.service.ts
+++ b/src/ORM/_views/user-agent-report/user-agent-report.service.ts
@@ -3,7 +3,6 @@ import { InjectRepository } from '@nestjs/typeorm';
 import { Repository } from 'typeorm';
 
 import { ClientEntity } from '../../client/client.entity';
-import { ShareAccountingService } from '../../share-accounting/share-accounting.service';
 import { UserAgentReportView } from './user-agent-report.view';
 import { RedisMessagingService } from '../../../services/redis-messaging.service';
 
@@ -16,16 +15,12 @@ export class UserAgentReportService {
         @InjectRepository(ClientEntity)
         private clientRepository: Repository<ClientEntity>,
         private redisMessagingService: RedisMessagingService,
-        private shareAccountingService: ShareAccountingService,
     ) {
 
     }
 
     public async getReport() {
         const presences = await this.redisMessagingService.getAllClientPresence();
-        const shareSummaries = await this.shareAccountingService.getSessionSummaries(
-            presences.map(presence => presence.clientId),
-        );
         const rows = new Map<string, {
             userAgent: string;
             count: number;
@@ -43,14 +38,12 @@ export class UserAgentReportService {
                 bestDifficulty: 0,
                 totalHashRate: 0,
             };
-            const shareSummary = shareSummaries.get(presence.clientId);
             row.count++;
             row.bestDifficulty = Math.max(
                 row.bestDifficulty,
                 Number(presence.bestDifficulty ?? 0),
-                Number(shareSummary?.bestSubmissionDifficulty ?? 0),
             );
-            row.totalHashRate += Number(shareSummary?.hashRateLast10Minutes ?? presence.hashRate ?? 0);
+            row.totalHashRate += Number(presence.hashRate ?? 0);
             rows.set(userAgent, row);
         });
 
diff --git a/src/ORM/client-statistics/client-statistics.service.ts b/src/ORM/client-statistics/client-statistics.service.ts
index 8cbfe28..1181dfd 100644
--- a/src/ORM/client-statistics/client-statistics.service.ts
+++ b/src/ORM/client-statistics/client-statistics.service.ts
@@ -6,7 +6,6 @@ const HASHES_PER_DIFFICULTY = 4294967296;
 const CHART_BUCKET_SECONDS = 600;
 const CHART_WINDOW = '24 hours';
 const SITE_CHART_WINDOW = '7 days';
-const REALTIME_WINDOW = '20 minutes';
 
 @Injectable()
 export class ClientStatisticsService {
@@ -67,7 +66,7 @@ export class ClientStatisticsService {
             WITH bounds AS (
                 SELECT
                     NOW() - INTERVAL '${windowSql}' AS since,
-                    time_bucket(INTERVAL '10 minutes', NOW() - INTERVAL '${REALTIME_WINDOW}') AS realtime_start
+                    time_bucket(INTERVAL '10 minutes', NOW()) AS realtime_start
             ),
             aggregate_rows AS (
                 SELECT
diff --git a/test/timescale-redis.integration-spec.ts b/test/timescale-redis.integration-spec.ts
index a82c606..7d3af97 100644
--- a/test/timescale-redis.integration-spec.ts
+++ b/test/timescale-redis.integration-spec.ts
@@ -187,7 +187,6 @@ describe('TimescaleDB and Redis integration', () => {
       dataSource.getRepository(UserAgentReportView),
       repository,
       redisMessagingService,
-      new ShareAccountingService(dataSource.getRepository(AcceptedShareEntity)),
     );
 
     const activeClient = await repository.save({