feat: index tx_hash in ibc transfers (#5247)

Author: vacekj

crates/bin/pindexer/src/ibc/ibc.sql

@@ -13,5 +13,7 @@ CREATE TABLE IF NOT EXISTS ibc_transfer (
   -- The address on the other side.
   foreign_addr TEXT NOT NULL,
   -- What kind of transfer this is.
-  kind TEXT NOT NULL CHECK (kind IN ('inbound', 'outbound', 'refund_timeout', 'refund_error', 'refund_other'))
+  kind TEXT NOT NULL CHECK (kind IN ('inbound', 'outbound', 'refund_timeout', 'refund_error', 'refund_other')),
+  -- The transaction hash associated with this transfer
+  tx_hash BYTEA
 );

crates/bin/pindexer/src/ibc/mod.rs

@@ -1,7 +1,7 @@
 use anyhow::anyhow;
 use cometindex::{
     async_trait,
-    index::{EventBatch, EventBatchContext},
+    index::{EventBatch, EventBatchContext, Version},
     AppView, ContextualizedEvent, PgTransaction,
 };
 use penumbra_sdk_asset::Value;
@@ -176,15 +176,17 @@ async fn create_transfer(
     dbtx: &mut PgTransaction<'_>,
     height: u64,
     transfer: DatabaseTransfer,
+    tx_hash: &[u8],
 ) -> anyhow::Result<()> {
-    sqlx::query("INSERT INTO ibc_transfer VALUES (DEFAULT, $7, $1, $6::NUMERIC(39, 0) * $2::NUMERIC(39, 0), $3, $4, $5)")
+    sqlx::query("INSERT INTO ibc_transfer VALUES (DEFAULT, $7, $1, $6::NUMERIC(39, 0) * $2::NUMERIC(39, 0), $3, $4, $5, $8)")
         .bind(transfer.value.asset_id.to_bytes())
         .bind(transfer.value.amount.to_string())
         .bind(transfer.penumbra_addr.to_vec())
         .bind(transfer.foreign_addr)
         .bind(transfer.kind)
         .bind(if transfer.negate { -1i32 } else { 1i32 })
         .bind(i64::try_from(height)?)
+        .bind(tx_hash.to_vec())
         .execute(dbtx.as_mut())
         .await?;
     Ok(())
@@ -205,6 +207,20 @@ impl AppView for Component {
         "ibc".to_string()
     }
 
+    fn version(&self) -> Version {
+        Version::with_major(1)
+    }
+
+    async fn reset(&self, dbtx: &mut PgTransaction) -> Result<(), anyhow::Error> {
+        for statement in include_str!("reset.sql").split(";") {
+            let trimmed = statement.trim();
+            if !trimmed.is_empty() {
+                sqlx::query(trimmed).execute(dbtx.as_mut()).await?;
+            }
+        }
+        Ok(())
+    }
+
     async fn init_chain(
         &self,
         dbtx: &mut PgTransaction,
@@ -225,7 +241,15 @@ impl AppView for Component {
                 Err(_) => continue,
             };
             let transfer = parsed.db_transfer();
-            create_transfer(dbtx, event.block_height, transfer).await?;
+            create_transfer(
+                dbtx,
+                event.block_height,
+                transfer,
+                &event
+                    .tx_hash()
+                    .expect("IBC events should have associated transaction hash"),
+            )
+            .await?;
         }
         Ok(())
     }

crates/bin/pindexer/src/ibc/reset.sql

@@ -0,0 +1,2 @@
+-- Drop the IBC transfer table
+DROP TABLE IF EXISTS ibc_transfer CASCADE;