From 24cc79dc5bdc3bb8203f131d2741d0ccfce7987e Mon Sep 17 00:00:00 2001
From: Ryan Smith <r@32k.io>
Date: Mon, 16 Oct 2023 09:18:41 -0700
Subject: [PATCH] e2pg: perf. speed up main dashboard query

---
 e2pg/e2pg.go | 30 +++++++++++++++++-------------
 1 file changed, 17 insertions(+), 13 deletions(-)

diff --git a/e2pg/e2pg.go b/e2pg/e2pg.go
index 22d95bdc..cc1777f5 100644
--- a/e2pg/e2pg.go
+++ b/e2pg/e2pg.go
@@ -479,19 +479,23 @@ func TaskUpdate1(ctx context.Context, pg wpg.Conn, id string) (TaskUpdate, error
 
 func TaskUpdates(ctx context.Context, pg wpg.Conn) ([]TaskUpdate, error) {
 	rows, _ := pg.Query(ctx, `
-		select distinct on (id)
-			id,
-			num,
-			hash,
-			coalesce(src_num, 0) src_num,
-			coalesce(src_hash, '\x00') src_hash,
-			coalesce(nblocks, 0) nblocks,
-			coalesce(nrows, 0) nrows,
-			coalesce(latency, '0')::interval latency,
-			coalesce(dstat, '{}') dstat
-		from e2pg.task
-		order by id, num desc;
-	`)
+        with f as (
+            select id, max(num) num
+            from e2pg.task group by 1
+        )
+        select
+                f.id,
+                f.num,
+                hash,
+                coalesce(src_num, 0) src_num,
+                coalesce(src_hash, '\x00') src_hash,
+                coalesce(nblocks, 0) nblocks,
+                coalesce(nrows, 0) nrows,
+                coalesce(latency, '0')::interval latency,
+                coalesce(dstat, '{}') dstat
+        from f
+        left join e2pg.task on e2pg.task.id = f.id and e2pg.task.num = f.num;
+    `)
 	return pgx.CollectRows(rows, pgx.RowToStructByName[TaskUpdate])
 }