WIP: working latest voting anchor

Author: MSzalowski

govtool/backend/sql/list-dreps.sql

@@ -37,7 +37,7 @@ LatestVoteEpoch AS (
     lvp.rn = 1
 ),
 RankedDRepRegistration AS (
-	SELECT
+  SELECT
       dr.id,
       dr.drep_hash_id,
       dr.deposit,
@@ -46,34 +46,52 @@ RankedDRepRegistration AS (
       tx.hash AS tx_hash
     FROM
       drep_registration dr
-	JOIN tx ON tx.id = dr.tx_id
+  JOIN tx ON tx.id = dr.tx_id
 ),
 FetchError AS (
-	SELECT
-		fetch_error as message,
-		voting_anchor_id
-	FROM
-		off_chain_vote_fetch_error
-	WHERE
-		fetch_time = (
-	SELECT
-		max(fetch_time)
-		FROM
-		off_chain_vote_fetch_error
-		)
-	GROUP BY
-		fetch_error,
-		voting_anchor_id
+  SELECT
+    fetch_error as message,
+    voting_anchor_id
+  FROM
+    off_chain_vote_fetch_error
+  WHERE
+    fetch_time = (
+  SELECT
+    MAX(fetch_time)
+  FROM
+    off_chain_vote_fetch_error
+    )
+  GROUP BY
+    fetch_error,
+    voting_anchor_id
 ),
-DRepData AS (
+LatestExistingVotingAnchor AS (
   SELECT
+    dr.id AS drep_registration_id,
+    dr.drep_hash_id,
+    va.id AS voting_anchor_id,
+    va.url,
+    encode(va.data_hash, 'hex') AS tx_hash
+  FROM
+    drep_registration dr
+  JOIN voting_anchor va ON dr.voting_anchor_id = va.id
+  JOIN off_chain_vote_data ocvd ON va.id = ocvd.voting_anchor_id
+  WHERE
+    ocvd.voting_anchor_id IS NOT NULL
+  ORDER BY
+    dr.tx_id DESC
+),
+DRepData AS (
+  SELECT DISTINCT ON (dh.raw)
     RankedDRepRegistration.id,
+    dh.id,
     -- encode(dh.raw, 'hex') drep_hash,
     dh.view,
     -- dh.has_script,
-    dr_voting_anchor.voting_anchor_id ,
-    dr_voting_anchor.url,
-    encode(dr_voting_anchor.data_hash, 'hex') metadata_hash,
+    leva.voting_anchor_id ,
+    leva.url,
+    ocvd.voting_anchor_id,
+    leva.tx_hash metadata_hash,
     COALESCE(RankedDRepRegistration.deposit, 0),
     DRepDistr.amount,
     (DRepActivity.epoch_no - GREATEST(COALESCE(voting_procedure_block.epoch_no, block_first_register.epoch_no), lve.epoch_no, newestRegister.epoch_no)) <= DRepActivity.drep_activity AS active,
@@ -90,27 +108,12 @@ DRepData AS (
   FROM
     drep_hash dh
     JOIN RankedDRepRegistration ON RankedDRepRegistration.drep_hash_id = dh.id AND RankedDRepRegistration.rn = 1
-    LEFT JOIN (
-    SELECT
-      dr.id,
-      dr.drep_hash_id,
-      dr.voting_anchor_id,
-      voting_anchor.url,
-      voting_anchor.data_hash,
-      ROW_NUMBER() OVER (PARTITION BY dr.drep_hash_id ORDER BY dr.tx_id DESC) AS rn,
-      tx.hash AS tx_hash
-    FROM
-      drep_registration dr
-      JOIN tx ON tx.id = dr.tx_id
-      JOIN voting_anchor ON voting_anchor.id = dr.voting_anchor_id
-    WHERE
-      COALESCE(dr.deposit, 0) >= 0
-    ) AS dr_voting_anchor ON dr_voting_anchor.drep_hash_id = dh.id AND dr_voting_anchor.rn = 1
     LEFT JOIN RankedDRepRegistration second_to_newest_drep_registration ON second_to_newest_drep_registration.drep_hash_id = dh.id AND second_to_newest_drep_registration.rn = 2
+    LEFT JOIN LatestExistingVotingAnchor leva ON leva.drep_hash_id = dh.id
     LEFT JOIN DRepDistr ON DRepDistr.hash_id = dh.id AND DRepDistr.rn = 1
-    LEFT JOIN FetchError fetch_error ON fetch_error.voting_anchor_id = dr_voting_anchor.voting_anchor_id
-    LEFT JOIN off_chain_vote_data ON off_chain_vote_data.voting_anchor_id = dr_voting_anchor.voting_anchor_id
-    LEFT JOIN off_chain_vote_drep_data ON off_chain_vote_drep_data.off_chain_vote_data_id = off_chain_vote_data.id 
+    LEFT JOIN FetchError fetch_error ON fetch_error.voting_anchor_id = leva.voting_anchor_id
+    LEFT JOIN off_chain_vote_data ocvd ON ocvd.voting_anchor_id = leva.voting_anchor_id
+    LEFT JOIN off_chain_vote_drep_data ON off_chain_vote_drep_data.off_chain_vote_data_id = ocvd.id 
     LEFT JOIN voting_procedure ON voting_procedure.drep_voter = dh.id
     LEFT JOIN tx voting_procedure_transaction ON voting_procedure_transaction.id = voting_procedure.tx_id
     LEFT JOIN block voting_procedure_block ON voting_procedure_block.id = voting_procedure_transaction.block_id
@@ -143,21 +146,22 @@ DRepData AS (
       dh.view ILIKE 'drep1km69g7ksf8t5g0h9d9tkrcd2tezxelx0wtr76rv2mrkl5nzd6v3'
   GROUP BY
     RankedDRepRegistration.id,
+    dh.id,
     voting_procedure_block.epoch_no,
     voting_procedure_block.epoch_no,
     dh.raw,
     second_to_newest_drep_registration.voting_anchor_id,
     dh.view,
     dh.has_script,
     RankedDRepRegistration.deposit,
-    dr_voting_anchor.voting_anchor_id,
-    dr_voting_anchor.url,
-    dr_voting_anchor.data_hash,
+    leva.voting_anchor_id,
+    leva.url,
+    ocvd.voting_anchor_id,
     DRepDistr.amount,
     DRepActivity.epoch_no,
     DRepActivity.drep_activity,
     lve.epoch_no,
-    dr_voting_anchor.tx_hash,
+    leva.tx_hash,
     newestRegister.time,
     newestRegister.epoch_no,
     fetch_error.message,