Update get_pool_update output

cardano-community · Jun 9, 2021 · a4bc552 · a4bc552
1 parent 0faa68f
commit a4bc552
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 7 deletions.
diff --git a/files/dbsync/queries/pool_metadata_verification.json b/files/dbsync/queries/pool_metadata_verification.json
@@ -50,9 +50,9 @@
         "  meta_hash_chain=$(jq -r '.meta_hash //empty' <<< \"${variables[query_Metadata]}\")",
         "  println \"$(printf \"  %-16s : ${FG_LGRAY}%s${NC}\" \"Hash Registered\" \"${meta_hash_chain}\")\"",
         "  printf '\\nHash Verification: '",
-        "  if [[ ${meta_hash_url} = ${meta_hash_chain} ]]; then println \"${FG_GREEN}MATCH!${NC}\"; else println \"${FG_YELLOW}MISSMATCH!${NC}\"; fi",
+        "  if [[ ${meta_hash_url} = ${meta_hash_chain} ]]; then println \"${FG_GREEN}MATCH!${NC}\"; else println \"${FG_YELLOW}MISMATCH!${NC}\"; fi",
         "else",
         "  println \"${FG_RED}Failed to download metadata from URL!${NC}\"",
         "fi"
     ]
-}
+}
diff --git a/files/dbsync/rpc/get_pool_update.json b/files/dbsync/rpc/get_pool_update.json
@@ -26,18 +26,22 @@
     "RETURNS JSON STABLE LANGUAGE PLPGSQL AS $$",
     "BEGIN",
       "RETURN ( SELECT json_agg(js) json_final FROM ( SELECT json_build_object(",
-          "'update_id', pu.id,",
-          "'hash_id', pu.hash_id,",
-          "'registered_tx_id', pu.registered_tx_id,",
+          "'vrf_key_hash', encode(pu.vrf_key_hash::bytea, 'hex'),",
+          "'reward_address', sa.view,",
+          "'owner_address', tout.address,",
           "'active_epoch_no', pu.active_epoch_no,",
           "'pledge', pu.pledge,",
           "'margin', pu.margin,",
           "'fixed_cost', pu.fixed_cost,",
-          "'reward_addr', RIGHT(encode(pu.reward_addr::bytea, 'hex'), -2),",
-          "'meta_id', pu.meta_id",
+          "'meta_url', pmd.url,",
+          "'meta_hash', encode(pmd.hash::bytea, 'hex')",
         ") js",
         "FROM pool_update AS pu",
         "INNER JOIN pool_hash AS ph ON pu.hash_id = ph.id",
+        "LEFT JOIN pool_retire AS pr ON pu.hash_id = pr.hash_id",
+        "LEFT JOIN pool_meta_data as pmd ON pmd.id = pu.meta_id",
+        "LEFT JOIN tx_out as tout ON tout.id = pu.registered_tx_id",
+        "LEFT JOIN stake_address as sa ON sa.hash_raw = pu.reward_addr",
         "WHERE ph.view = _pool_bech32",
         "AND CASE",
           "WHEN _state = 'active' AND pu.active_epoch_no <= _current_epoch_no THEN 'True'",