copyTrees: add timeouts and order to sync function (#98)

ourzora · Jun 22, 2023 · 63acbae · 63acbae · vercel · Jun 22, 2023
1 parent 6af5137
commit 63acbae
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/cmd/api/main.go b/cmd/api/main.go
@@ -35,10 +35,13 @@ func check(err error) {
 }
 
 func copyTrees(ctx context.Context, db *pgxpool.Pool) {
+	ctx, done := context.WithTimeout(ctx, 5*time.Minute)
+	defer done()
 	t, err := db.Exec(ctx, `
 			insert into trees_proofs
 			(select root, proofs from trees
 			where root not in (select root from trees_proofs)
+			order by inserted_at desc
 			limit 5
 			for update skip locked)
 			`)