fix(cat-gateway): Fix cardano/assets endpoint.

catalyst-gateway/bin/src/db/index/queries/staked_ada/get_assets_by_stake_address.rs

@@ -1,7 +1,6 @@
 //! Get assets by stake address.
 use std::sync::Arc;
 
-use cardano_blockchain_types::{Slot, StakeAddress};
 use scylla::{
     prepared_statement::PreparedStatement, transport::iterator::TypedRowStream, DeserializeRow,
     SerializeRow, Session,
@@ -31,7 +30,9 @@ pub(crate) struct GetAssetsByStakeAddressParams {
 
 impl GetAssetsByStakeAddressParams {
     /// Creates a new [`GetAssetsByStakeAddressParams`].
-    pub(crate) fn new(stake_address: StakeAddress, slot_no: Slot) -> Self {
+    pub(crate) fn new<StakeAddressT: Into<DbStakeAddress>, SlotNoT: Into<DbSlot>>(
+        stake_address: StakeAddressT, slot_no: SlotNoT,
+    ) -> Self {
         Self {
             stake_address: stake_address.into(),
             slot_no: slot_no.into(),

catalyst-gateway/bin/src/db/index/queries/staked_ada/get_txo_by_stake_address.rs

@@ -1,7 +1,6 @@
 //! Get the TXO by Stake Address
 use std::sync::Arc;
 
-use cardano_blockchain_types::{Slot, StakeAddress};
 use scylla::{
     prepared_statement::PreparedStatement, transport::iterator::TypedRowStream, DeserializeRow,
     SerializeRow, Session,
@@ -30,7 +29,9 @@ pub(crate) struct GetTxoByStakeAddressQueryParams {
 
 impl GetTxoByStakeAddressQueryParams {
     /// Creates a new [`GetTxoByStakeAddressQueryParams`].
-    pub(crate) fn new(stake_address: StakeAddress, slot_no: Slot) -> Self {
+    pub(crate) fn new<StakeAddressT: Into<DbStakeAddress>, SlotNoT: Into<DbSlot>>(
+        stake_address: StakeAddressT, slot_no: SlotNoT,
+    ) -> Self {
         Self {
             stake_address: stake_address.into(),
             slot_no: slot_no.into(),

catalyst-gateway/bin/src/db/index/tests/scylla_queries.rs

@@ -36,7 +36,7 @@ async fn test_get_assets_by_stake_addr() {
 
     let mut row_stream = GetAssetsByStakeAddressQuery::execute(
         &session,
-        GetAssetsByStakeAddressParams::new(stake_address_1(), u64::MAX.into()),
+        GetAssetsByStakeAddressParams::new(stake_address_1(), u64::MAX),
     )
     .await
     .unwrap();
@@ -241,10 +241,7 @@ async fn test_get_txo_by_stake_address() {
 
     let mut row_stream = GetTxoByStakeAddressQuery::execute(
         &session,
-        GetTxoByStakeAddressQueryParams::new(
-            stake_address_1(),
-            u64::try_from(i64::MAX).unwrap().into(),
-        ),
+        GetTxoByStakeAddressQueryParams::new(stake_address_1(), u64::try_from(i64::MAX).unwrap()),
     )
     .await
     .unwrap();

catalyst-gateway/bin/src/db/types/slot.rs

@@ -7,6 +7,8 @@ use scylla::_macro_internal::{
     SerializeValue, TypeCheckError, WrittenCellProof,
 };
 
+use crate::service::common::types::cardano::slot_no::SlotNo;
+
 /// A `Slot` wrapper that can be stored to and load from a database.\
 #[allow(clippy::module_name_repetitions)]
 #[derive(Debug, Copy, Clone, PartialEq, Eq, PartialOrd, Ord, Hash)]
@@ -42,6 +44,12 @@ impl From<DbSlot> for BigInt {
     }
 }
 
+impl From<SlotNo> for DbSlot {
+    fn from(value: SlotNo) -> Self {
+        Self(value.into())
+    }
+}
+
 impl SerializeValue for DbSlot {
     fn serialize<'b>(
         &self, typ: &ColumnType, writer: CellWriter<'b>,