chore: Add endpoints to minibf

Cargo.toml

@@ -12,8 +12,8 @@ authors = ["Santiago Carmuega <[email protected]>"]
 
 
 [dependencies]
-pallas = { git = "https://github.com/txpipe/pallas.git", features = ["hardano", "applying"] }
-# pallas = { version = "^0.30.1", features = ["hardano", "applying"] }
+pallas = { git = "https://github.com/gonzalezzfelipe/pallas.git", branch = "fix/error-on-tx-validation", features = ["hardano", "applying"] }
+# pallas = { version = "0.32.0", features = ["hardano", "applying"] }
 # pallas = { path = "../pallas/pallas", features = ["hardano", "applying"] }
 
 # gasket = { git = "https://github.com/construkts/gasket-rs.git", features = ["derive"] }

src/ledger/pparams/mod.rs

@@ -9,7 +9,7 @@ use pallas::{
         traverse::MultiEraUpdate,
     },
 };
-use tracing::{debug, warn};
+use tracing::debug;
 
 mod hacks;
 mod summary;
@@ -363,7 +363,7 @@ fn apply_param_update(
             apply_field!(pparams, update, extra_entropy);
 
             if let Some(value) = update.alonzo_first_proposed_cost_models_for_script_languages() {
-                warn!(
+                debug!(
                     ?value,
                     "found new cost_models_for_script_languages update proposal"
                 );
@@ -399,7 +399,7 @@ fn apply_param_update(
             apply_field!(pparams, update, extra_entropy);
 
             if let Some(value) = update.babbage_first_proposed_cost_models_for_script_languages() {
-                warn!(
+                debug!(
                     ?value,
                     "found new cost_models_for_script_languages update proposal"
                 );
@@ -442,7 +442,7 @@ fn apply_param_update(
             apply_field!(pparams, update, minfee_refscript_cost_per_byte);
 
             if let Some(value) = update.conway_first_proposed_cost_models_for_script_languages() {
-                warn!(
+                debug!(
                     ?value,
                     "found new cost_models_for_script_languages update proposal"
                 );

src/serve/minibf/common.rs

@@ -0,0 +1,68 @@
+use rocket::{http::Status, FromFormField};
+
+#[derive(Default, Debug, Clone, FromFormField)]
+pub enum Order {
+    #[default]
+    Asc,
+    Desc,
+}
+
+#[derive(Debug, Clone)]
+pub struct Pagination {
+    pub count: u8,
+    pub page: u64,
+    pub order: Order,
+}
+impl Default for Pagination {
+    fn default() -> Self {
+        Pagination {
+            count: 100,
+            page: 1,
+            order: Order::Asc,
+        }
+    }
+}
+impl Pagination {
+    pub fn try_new(
+        count: Option<u8>,
+        page: Option<u64>,
+        order: Option<Order>,
+    ) -> Result<Self, Status> {
+        let count = match count {
+            Some(count) => {
+                if !(1..=100).contains(&count) {
+                    return Err(Status::BadRequest);
+                } else {
+                    count
+                }
+            }
+            None => 100,
+        };
+        let page = match page {
+            Some(page) => {
+                if page < 1 {
+                    return Err(Status::BadRequest);
+                } else {
+                    page
+                }
+            }
+            None => 1,
+        };
+        Ok(Self {
+            count,
+            page,
+            order: order.unwrap_or_default(),
+        })
+    }
+
+    pub fn from(&self) -> usize {
+        ((self.page - 1) * self.count as u64) as usize
+    }
+
+    pub fn to(&self) -> usize {
+        (self.count as u64 * self.page) as usize
+    }
+    pub fn includes(&self, i: usize) -> bool {
+        i > self.from() && i <= self.to()
+    }
+}

src/serve/minibf/mod.rs

@@ -1,13 +1,13 @@
-use pallas::ledger::{primitives::conway, traverse::MultiEraAsset};
-use rocket::{get, http::Status, routes, State};
+use pallas::ledger::traverse::wellknown::GenesisValues;
+use rocket::routes;
 use serde::{Deserialize, Serialize};
-use std::net::SocketAddr;
+use std::{net::SocketAddr, sync::Arc};
 use tokio_util::sync::CancellationToken;
 
-use crate::{
-    ledger::{EraCbor, TxoRef},
-    state::LedgerStore,
-};
+use crate::{ledger::pparams::Genesis, mempool::Mempool, state::LedgerStore, wal::redb::WalStore};
+
+mod common;
+mod routes;
 
 #[derive(Deserialize, Serialize, Clone)]
 pub struct Config {
@@ -16,7 +16,11 @@ pub struct Config {
 
 pub async fn serve(
     cfg: Config,
+    genesis: Arc<Genesis>,
+    genesis_values: GenesisValues,
+    wal: WalStore,
     ledger: LedgerStore,
+    mempool: Mempool,
     _exit: CancellationToken,
 ) -> Result<(), rocket::Error> {
     // TODO: connect cancellation token to rocket shutdown
@@ -34,104 +38,36 @@ pub async fn serve(
                 .merge(("address", cfg.listen_address.ip().to_string()))
                 .merge(("port", cfg.listen_address.port())),
         )
+        .manage(genesis)
+        .manage(genesis_values)
+        .manage(wal)
         .manage(ledger)
-        .mount("/", routes![address_utxos])
+        .manage(mempool)
+        .mount(
+            "/",
+            routes![
+                // Accounts
+                routes::accounts::stake_address::utxos::route,
+                // Addresses
+                routes::addresses::address::utxos::route,
+                routes::addresses::address::utxos::asset::route,
+                // Blocks
+                routes::blocks::latest::route,
+                routes::blocks::latest::txs::route,
+                routes::blocks::hash_or_number::route,
+                routes::blocks::hash_or_number::addresses::route,
+                routes::blocks::hash_or_number::next::route,
+                routes::blocks::hash_or_number::previous::route,
+                routes::blocks::hash_or_number::txs::route,
+                routes::blocks::slot::slot_number::route,
+                //Epoch
+                routes::epochs::latest::parameters::route,
+                // Submit
+                routes::tx::submit::route,
+            ],
+        )
         .launch()
         .await?;
 
     Ok(())
 }
-
-#[derive(Debug, Serialize, Deserialize)]
-struct Amount {
-    unit: String,
-    quantity: String,
-}
-
-impl Amount {
-    fn lovelace(quantity: u64) -> Self {
-        Self {
-            unit: "lovelace".to_string(),
-            quantity: quantity.to_string(),
-        }
-    }
-}
-
-#[derive(Debug, Serialize, Deserialize)]
-struct Utxo {
-    address: String,
-    tx_hash: String,
-    output_index: u32,
-    amount: Vec<Amount>,
-    data_hash: Option<String>,
-    inline_datum: Option<String>,
-    reference_script_hash: Option<String>,
-}
-
-impl From<MultiEraAsset<'_>> for Amount {
-    fn from(value: MultiEraAsset<'_>) -> Self {
-        Self {
-            unit: value.policy().to_string(),
-            quantity: value.any_coin().to_string(),
-        }
-    }
-}
-
-impl TryFrom<(TxoRef, EraCbor)> for Utxo {
-    type Error = Status;
-
-    fn try_from((txo, era): (TxoRef, EraCbor)) -> Result<Self, Self::Error> {
-        let parsed = pallas::ledger::traverse::MultiEraOutput::decode(era.0, &era.1)
-            .map_err(|_| Status::InternalServerError)?;
-
-        let value = parsed.value();
-        let lovelace = Amount::lovelace(value.coin());
-        let assets: Vec<Amount> = value
-            .assets()
-            .iter()
-            .flat_map(|x| x.assets())
-            .map(|x| x.into())
-            .collect();
-
-        Ok(Self {
-            tx_hash: txo.0.to_string(),
-            output_index: txo.1,
-            address: parsed
-                .address()
-                .map_err(|_| Status::InternalServerError)?
-                .to_string(),
-            amount: std::iter::once(lovelace).chain(assets).collect(),
-            data_hash: parsed.datum().and_then(|x| match x {
-                conway::PseudoDatumOption::Hash(hash) => Some(hash.to_string()),
-                conway::PseudoDatumOption::Data(_) => None,
-            }),
-            inline_datum: parsed.datum().and_then(|x| match x {
-                conway::PseudoDatumOption::Hash(_) => None,
-                conway::PseudoDatumOption::Data(x) => Some(hex::encode(x.raw_cbor())),
-            }),
-            reference_script_hash: None,
-        })
-    }
-}
-
-#[get("/addresses/<address>/utxos")]
-fn address_utxos(
-    address: String,
-    ledger: &State<LedgerStore>,
-) -> Result<rocket::serde::json::Json<Vec<Utxo>>, Status> {
-    let address = pallas::ledger::addresses::Address::from_bech32(&address)
-        .map_err(|_| Status::BadRequest)?;
-
-    let refs = ledger
-        .get_utxo_by_address(&address.to_vec())
-        .map_err(|_| Status::InternalServerError)?;
-
-    let utxos: Vec<_> = ledger
-        .get_utxos(refs.into_iter().collect())
-        .map_err(|_| Status::InternalServerError)?
-        .into_iter()
-        .map(|x| Utxo::try_from(x))
-        .collect::<Result<_, _>>()?;
-
-    Ok(rocket::serde::json::Json(utxos))
-}

src/serve/minibf/routes/accounts/mod.rs

@@ -0,0 +1 @@
+pub mod stake_address;