add client for dolos minibf

Author: kpinter-iohk

Cargo.lock

@@ -118,7 +118,7 @@ ed25519-zebra = { version = "4.0.3" }
 ed25519 = { version = "2.2.2" }
 figment = { version = "0.10.19", features = ["env", "test"] }
 fraction = { version = "0.15.3", default-features = false }
-futures = { version = "0.3.30", features = ["thread-pool"] }
+futures = { version = "0.3.31", features = ["thread-pool"] }
 hex = { version = "0.4.3", features = ["alloc"], default-features = false }
 hex-literal = "1.0.0"
 itertools = "0.14.0"
@@ -185,6 +185,9 @@ derive-where = { version = "1.2.7", default-features = false }
 once_cell = { version = "1.21.3", default-features = false }
 paste = { version = "1.0.15" }
 fork-tree = { version = "13.0.1" }
+ureq = { version = "3.1.2", default-features = false }
+url = { version = "2.5.7", default-features = false }
+blockfrost-openapi = { version = "0.1.75", default-features = false }
 
 # substrate dependencies
 frame-benchmarking = { default-features = false, git = "https://github.com/paritytech/polkadot-sdk.git", tag = "polkadot-stable2509" }

Cargo.toml

@@ -27,6 +27,17 @@ sp-block-participation = { workspace = true, features = [
 sp-partner-chains-bridge = { workspace = true, optional = true, features = [
     "std",
 ] }
+serde = { workspace = true }
+serde_json = { workspace = true }
+log = { workspace = true }
+blockfrost-openapi = { workspace = true }
+ureq = { workspace = true, features = ["json"] }
+url = { workspace = true }
+thiserror = { workspace = true }
+partner-chains-plutus-data = { workspace = true }
+futures = { workspace = true }
+cardano-serialization-lib = { workspace = true }
+itertools = { workspace = true }
 
 [features]
 default = []

toolkit/data-sources/dolos/Cargo.toml

@@ -0,0 +1,92 @@
+use async_trait::async_trait;
+use blockfrost_openapi::models::{
+	address_transactions_content_inner::AddressTransactionsContentInner,
+	address_utxo_content_inner::AddressUtxoContentInner,
+	asset_addresses_inner::AssetAddressesInner, asset_transactions_inner::AssetTransactionsInner,
+	block_content::BlockContent, epoch_param_content::EpochParamContent,
+	epoch_stake_pool_content_inner::EpochStakePoolContentInner,
+	pool_history_inner::PoolHistoryInner, pool_list_extended_inner::PoolListExtendedInner,
+	tx_content::TxContent, tx_content_utxo::TxContentUtxo,
+};
+use sidechain_domain::*;
+
+pub enum McBlockId {
+	McBlockHash(McBlockHash),
+	McBlockNumber(McBlockNumber),
+	Raw(String), // makes you think
+}
+
+impl From<McBlockHash> for McBlockId {
+	fn from(value: McBlockHash) -> Self {
+		McBlockId::McBlockHash(value)
+	}
+}
+
+impl From<McBlockNumber> for McBlockId {
+	fn from(value: McBlockNumber) -> Self {
+		McBlockId::McBlockNumber(value)
+	}
+}
+
+impl From<String> for McBlockId {
+	fn from(value: String) -> Self {
+		McBlockId::Raw(value)
+	}
+}
+
+impl std::fmt::Display for McBlockId {
+	fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+		match self {
+			McBlockId::McBlockHash(mc_block_hash) => mc_block_hash.fmt(f),
+			McBlockId::McBlockNumber(mc_block_number) => mc_block_number.fmt(f),
+			McBlockId::Raw(str) => str.fmt(f),
+		}
+	}
+}
+
+#[async_trait]
+pub trait MiniBFApi {
+	async fn addresses_utxos(
+		&self,
+		address: MainchainAddress,
+	) -> Result<Vec<AddressUtxoContentInner>, String>;
+	async fn addresses_transactions(
+		&self,
+		address: MainchainAddress,
+	) -> Result<Vec<AddressTransactionsContentInner>, String>;
+
+	async fn assets_transactions(
+		&self,
+		asset_id: AssetId,
+	) -> Result<Vec<AssetTransactionsInner>, String>;
+	async fn assets_addresses(&self, asset_id: AssetId)
+	-> Result<Vec<AssetAddressesInner>, String>;
+
+	async fn blocks_latest(&self) -> Result<BlockContent, String>;
+	async fn blocks_by_id(&self, id: impl Into<McBlockId> + Send) -> Result<BlockContent, String>;
+	async fn blocks_slot(&self, slot_number: McSlotNumber) -> Result<BlockContent, String>;
+	async fn blocks_next(
+		&self,
+		hash: impl Into<McBlockId> + Send,
+	) -> Result<Vec<BlockContent>, String>;
+	async fn blocks_txs(&self, id: impl Into<McBlockId> + Send) -> Result<Vec<String>, String>;
+
+	async fn epochs_blocks(&self, epoch_number: McEpochNumber) -> Result<Vec<String>, String>;
+	async fn epochs_parameters(
+		&self,
+		epoch_number: McEpochNumber,
+	) -> Result<EpochParamContent, String>;
+	async fn epochs_stakes_by_pool(
+		&self,
+		epoch_number: McEpochNumber,
+		pool_id: &str,
+	) -> Result<Vec<EpochStakePoolContentInner>, String>;
+
+	async fn pools_history(&self, pool_id: &str) -> Result<Vec<PoolHistoryInner>, String>;
+	async fn pools_extended(&self) -> Result<Vec<PoolListExtendedInner>, String>;
+
+	async fn scripts_datum_hash(&self, datum_hash: &str) -> Result<Vec<serde_json::Value>, String>;
+
+	async fn transaction_by_hash(&self, tx_hash: McTxHash) -> Result<TxContent, String>;
+	async fn transactions_utxos(&self, tx_hash: McTxHash) -> Result<TxContentUtxo, String>;
+}

toolkit/data-sources/dolos/src/client/api.rs

@@ -0,0 +1,21 @@
+use blockfrost_openapi::models::block_content::BlockContent;
+use sidechain_domain::*;
+
+pub fn from_block_content(value: BlockContent) -> Result<MainchainBlock, String> {
+	Ok(MainchainBlock {
+		number: value
+			.height
+			.map(|n| sidechain_domain::McBlockNumber(n as u32))
+			.ok_or("number missing")?,
+		hash: McBlockHash::decode_hex(&value.hash)?,
+		epoch: value
+			.epoch
+			.map(|n| sidechain_domain::McEpochNumber(n as u32))
+			.ok_or("epoch missing")?,
+		slot: value
+			.slot
+			.map(|n| sidechain_domain::McSlotNumber(n as u64))
+			.ok_or("slot missing")?,
+		timestamp: value.time as u64,
+	})
+}