perf: speed up startup setup queries (#625)

refactored the queries for optimization

Co-authored-by: Gustavo Inacio <[email protected]>

Author: rotarur

.sqlx/query-fef5849dc64c15d1188d6398c93a59bfaafd9a38cf342739cdabf8b7bba073d3.json renamed to .sqlx/query-11a939012cce92b3c148c22f13b2e81089b7b27af2a1dd22a8c6b8da561b6ec1.json

@@ -415,17 +415,11 @@ impl State {
                     FROM scalar_tap_receipts
                     GROUP BY signer_address, allocation_id
                 )
-                SELECT DISTINCT
+                SELECT 
                     signer_address,
-                    (
-                        SELECT ARRAY
-                        (
-                            SELECT DISTINCT allocation_id
-                            FROM grouped
-                            WHERE signer_address = top.signer_address
-                        )
-                    ) AS allocation_ids
-                FROM grouped AS top
+                    ARRAY_AGG(allocation_id) AS allocation_ids
+                FROM grouped
+                GROUP BY signer_address
             "#
         )
         .fetch_all(&self.pgpool)
@@ -461,18 +455,11 @@ impl State {
 
         let nonfinal_ravs_sender_allocations_in_db = sqlx::query!(
             r#"
-                SELECT DISTINCT
+                SELECT
                     sender_address,
-                    (
-                        SELECT ARRAY
-                        (
-                            SELECT DISTINCT allocation_id
-                            FROM scalar_tap_ravs
-                            WHERE sender_address = top.sender_address
-                            AND NOT last
-                        )
-                    ) AS allocation_id
-                FROM scalar_tap_ravs AS top
+                    ARRAY_AGG(DISTINCT allocation_id) FILTER (WHERE NOT last) AS allocation_ids
+                FROM scalar_tap_ravs
+                GROUP BY sender_address
             "#
         )
         .fetch_all(&self.pgpool)
@@ -481,7 +468,7 @@ impl State {
 
         for row in nonfinal_ravs_sender_allocations_in_db {
             let allocation_ids = row
-                .allocation_id
+                .allocation_ids
                 .expect("all RAVs should have an allocation_id")
                 .iter()
                 .map(|allocation_id| {

.sqlx/query-67c8c6323c92732bb994593223ccb4f7b9b4a4bda786542c18b404d2287e78a7.json

@@ -34,3 +34,4 @@ psql-down:
 
 migrate:
      sqlx migrate run --database-url postgresql://postgres:postgres@127.0.0.1:5432
+