feat(cat-gateway): impl Query for InsertUnstakedTxoAsset

Author: saibatizoku

catalyst-gateway/bin/src/db/index/block/txo/insert_unstaked_txo_asset.rs

@@ -1,14 +1,14 @@
 //! Insert Unstaked TXO Native Assets into the DB.
 
-use std::sync::Arc;
+use std::{fmt, sync::Arc};
 
 use cardano_blockchain_types::{Slot, TransactionId, TxnIndex, TxnOutputOffset};
 use scylla::{SerializeRow, Session};
 use tracing::error;
 
 use crate::{
     db::{
-        index::queries::{PreparedQueries, SizedBatch},
+        index::queries::{PreparedQueries, Query, QueryKind, SizedBatch},
         types::{DbSlot, DbTransactionId, DbTxnIndex, DbTxnOutputOffset},
     },
     settings::cassandra_db,
@@ -37,6 +37,22 @@ pub(crate) struct Params {
     value: num_bigint::BigInt,
 }
 
+impl fmt::Display for Params {
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        write!(f, "{INSERT_UNSTAKED_TXO_ASSET_QUERY}")
+    }
+}
+
+impl Query for Params {
+    async fn prepare_query(
+        session: &Arc<Session>, cfg: &cassandra_db::EnvVars,
+    ) -> anyhow::Result<crate::db::index::queries::QueryKind> {
+        Params::prepare_batch(session, cfg)
+            .await
+            .map(QueryKind::Batch)
+    }
+}
+
 impl Params {
     /// Create a new record for this transaction.
     ///