Sg/update caryatid

Cargo.toml

@@ -39,11 +39,11 @@ members = [
 resolver = "2"
 
 [workspace.dependencies]
-caryatid_sdk = "0.12"
-caryatid_process = "0.12"
-caryatid_module_rest_server = "0.14"
-caryatid_module_clock = "0.12"
-caryatid_module_spy = "0.12"
+caryatid_sdk = "0.13"
+caryatid_process = "0.13"
+caryatid_module_rest_server = "0.15"
+caryatid_module_clock = "0.13"
+caryatid_module_spy = "0.13"
 anyhow = "1.0"
 chrono = "0.4"
 clap = { version = "4.5", features = ["derive", "string"] }

common/tests/loc_over_bus.rs

@@ -8,7 +8,7 @@ use std::{
 };
 
 use anyhow::Result;
-use caryatid_sdk::{module, Context, Module};
+use caryatid_sdk::{module, Context};
 use serde::{Deserialize, Serialize};
 use tempfile::NamedTempFile;
 use tokio::{sync::watch, time::timeout};

modules/accounts_state/src/accounts_state.rs

@@ -9,7 +9,7 @@ use acropolis_common::{
 };
 use anyhow::Result;
 use bigdecimal::Zero;
-use caryatid_sdk::{message_bus::Subscription, module, Context, Module};
+use caryatid_sdk::{message_bus::Subscription, module, Context};
 use config::Config;
 use std::sync::Arc;
 use tokio::{join, sync::Mutex};

modules/address_state/src/address_state.rs

@@ -17,7 +17,7 @@ use acropolis_common::{
     BlockInfo, BlockStatus,
 };
 use anyhow::Result;
-use caryatid_sdk::{module, Context, Module, Subscription};
+use caryatid_sdk::{module, Context, Subscription};
 use config::Config;
 use tokio::sync::{mpsc, Mutex};
 use tracing::{error, info};

modules/assets_state/src/assets_state.rs

@@ -16,7 +16,7 @@ use acropolis_common::{
     BlockInfo, BlockStatus,
 };
 use anyhow::Result;
-use caryatid_sdk::{module, Context, Module, Subscription};
+use caryatid_sdk::{module, Context, Subscription};
 use config::Config;
 use std::sync::Arc;
 use tokio::sync::Mutex;

modules/block_kes_validator/src/block_kes_validator.rs

@@ -7,7 +7,7 @@ use acropolis_common::{
     BlockInfo, BlockStatus,
 };
 use anyhow::Result;
-use caryatid_sdk::{module, Context, Module, Subscription};
+use caryatid_sdk::{module, Context, Subscription};
 use config::Config;
 use std::sync::Arc;
 use tokio::sync::Mutex;

modules/block_unpacker/src/block_unpacker.rs

@@ -3,7 +3,7 @@
 
 use acropolis_common::messages::{CardanoMessage, Message, RawTxsMessage};
 use anyhow::Result;
-use caryatid_sdk::{module, Context, Module};
+use caryatid_sdk::{module, Context};
 use config::Config;
 use pallas::ledger::traverse::MultiEraBlock;
 use std::sync::Arc;

modules/block_vrf_validator/src/block_vrf_validator.rs

@@ -7,7 +7,7 @@ use acropolis_common::{
     BlockInfo, BlockStatus,
 };
 use anyhow::Result;
-use caryatid_sdk::{module, Context, Module, Subscription};
+use caryatid_sdk::{module, Context, Subscription};
 use config::Config;
 use std::sync::Arc;
 use tokio::sync::Mutex;

modules/chain_store/Cargo.toml

@@ -7,7 +7,7 @@ description = "Chain Store Tracker"
 license = "Apache-2.0"
 
 [dependencies]
-caryatid_sdk = "0.12"
+caryatid_sdk = { workspace = true }
 acropolis_common = { path = "../../common" }
 acropolis_codec = { path = "../../codec" }
 anyhow = "1.0"

modules/chain_store/src/chain_store.rs

@@ -20,7 +20,7 @@ use acropolis_common::{
     BechOrdAddress, BlockHash, GenesisDelegate, HeavyDelegate, PoolId, TxHash,
 };
 use anyhow::{bail, Result};
-use caryatid_sdk::{module, Context, Module};
+use caryatid_sdk::{module, Context};
 use config::Config;
 use std::collections::{BTreeMap, HashMap};
 use std::sync::Arc;

modules/consensus/src/consensus.rs

@@ -6,7 +6,7 @@ use acropolis_common::{
     validation::ValidationStatus,
 };
 use anyhow::Result;
-use caryatid_sdk::{module, Context, Module};
+use caryatid_sdk::{module, Context};
 use config::Config;
 use futures::future::try_join_all;
 use std::sync::Arc;

modules/drdd_state/src/drdd_state.rs

@@ -5,7 +5,7 @@ use acropolis_common::{
     rest_helper::handle_rest_with_query_parameters,
 };
 use anyhow::Result;
-use caryatid_sdk::{module, Context, Module};
+use caryatid_sdk::{module, Context};
 use config::Config;
 use std::sync::Arc;
 use tokio::sync::Mutex;

modules/drep_state/src/drep_state.rs

@@ -12,7 +12,7 @@ use acropolis_common::{
     BlockInfo, BlockStatus,
 };
 use anyhow::Result;
-use caryatid_sdk::{module, Context, Module, Subscription};
+use caryatid_sdk::{module, Context, Subscription};
 use config::Config;
 use std::sync::Arc;
 use tokio::sync::Mutex;

modules/epochs_state/src/epochs_state.rs

@@ -11,7 +11,7 @@ use acropolis_common::{
     BlockInfo, BlockStatus,
 };
 use anyhow::Result;
-use caryatid_sdk::{message_bus::Subscription, module, Context, Module};
+use caryatid_sdk::{message_bus::Subscription, module, Context};
 use config::Config;
 use pallas::ledger::traverse::MultiEraHeader;
 use std::sync::Arc;

modules/genesis_bootstrapper/src/genesis_bootstrapper.rs

@@ -14,7 +14,7 @@ use acropolis_common::{
 };
 use anyhow::Result;
 use blake2::{digest::consts::U32, Blake2b, Digest};
-use caryatid_sdk::{module, Context, Module};
+use caryatid_sdk::{module, Context};
 use config::Config;
 use pallas::ledger::configs::{
     byron::{genesis_utxos, GenesisFile as ByronGenesisFile},

modules/governance_state/src/governance_state.rs

@@ -14,7 +14,7 @@ use acropolis_common::{
     BlockInfo,
 };
 use anyhow::{anyhow, Result};
-use caryatid_sdk::{message_bus::Subscription, module, Context, Module};
+use caryatid_sdk::{message_bus::Subscription, module, Context};
 use config::Config;
 use std::sync::Arc;
 use tokio::sync::Mutex;

modules/historical_accounts_state/src/historical_accounts_state.rs

@@ -10,7 +10,7 @@ use acropolis_common::{
     BlockInfo, BlockStatus,
 };
 use anyhow::Result;
-use caryatid_sdk::{message_bus::Subscription, module, Context, Module};
+use caryatid_sdk::{message_bus::Subscription, module, Context};
 use config::Config;
 use std::sync::Arc;
 use tokio::sync::{mpsc, Mutex};

modules/historical_epochs_state/src/historical_epochs_state.rs

@@ -14,7 +14,7 @@ use acropolis_common::{
     BlockInfo, BlockStatus,
 };
 use anyhow::Result;
-use caryatid_sdk::{message_bus::Subscription, module, Context, Module};
+use caryatid_sdk::{message_bus::Subscription, module, Context};
 use config::Config;
 use std::sync::Arc;
 use tokio::sync::{mpsc, Mutex};

modules/mithril_snapshot_fetcher/src/mithril_snapshot_fetcher.rs

@@ -7,7 +7,7 @@ use acropolis_common::{
     BlockHash, BlockInfo, BlockStatus, Era,
 };
 use anyhow::{anyhow, bail, Result};
-use caryatid_sdk::{module, Context, Module};
+use caryatid_sdk::{module, Context};
 use chrono::{Duration, Utc};
 use config::Config;
 use mithril_client::{

modules/parameters_state/src/parameters_state.rs

@@ -11,7 +11,7 @@ use acropolis_common::{
     BlockInfo, BlockStatus,
 };
 use anyhow::Result;
-use caryatid_sdk::{message_bus::Subscription, module, Context, Module};
+use caryatid_sdk::{message_bus::Subscription, module, Context};
 use config::Config;
 use std::sync::Arc;
 use tokio::sync::Mutex;

modules/peer_network_interface/src/peer_network_interface.rs

@@ -10,7 +10,7 @@ use acropolis_common::{
     upstream_cache::{UpstreamCache, UpstreamCacheRecord},
 };
 use anyhow::{Result, bail};
-use caryatid_sdk::{Context, Module, Subscription, module};
+use caryatid_sdk::{Context, Subscription, module};
 use config::Config;
 use pallas::network::miniprotocols::Point;
 use tokio::sync::mpsc;

modules/rest_blockfrost/src/rest_blockfrost.rs

@@ -8,7 +8,7 @@ use acropolis_common::{
     rest_helper::{handle_rest_with_path_and_query_parameters, handle_rest_with_path_parameter},
 };
 use anyhow::Result;
-use caryatid_sdk::{module, Context, Module};
+use caryatid_sdk::{module, Context};
 use config::Config;
 use tracing::info;
 

modules/snapshot_bootstrapper/src/snapshot_bootstrapper.rs

@@ -15,7 +15,7 @@ use acropolis_common::{
     BlockHash, BlockInfo, BlockStatus, Era, GenesisDelegates,
 };
 use anyhow::Result;
-use caryatid_sdk::{module, Context, Module};
+use caryatid_sdk::{module, Context};
 use config::Config;
 use tokio::time::Instant;
 use tracing::{error, info, info_span, Instrument};

modules/spdd_state/src/spdd_state.rs

@@ -7,7 +7,7 @@ use acropolis_common::{
     rest_helper::handle_rest_with_query_parameters,
 };
 use anyhow::Result;
-use caryatid_sdk::{module, Context, Module};
+use caryatid_sdk::{module, Context};
 use config::Config;
 use std::sync::Arc;
 use tokio::sync::Mutex;

modules/spo_state/src/spo_state.rs

@@ -17,7 +17,7 @@ use acropolis_common::{
     BlockInfo, BlockStatus, Era, PoolId,
 };
 use anyhow::Result;
-use caryatid_sdk::{module, Context, Module, Subscription};
+use caryatid_sdk::{module, Context, Subscription};
 use config::Config;
 use pallas::ledger::traverse::MultiEraHeader;
 use std::sync::Arc;

modules/stake_delta_filter/src/stake_delta_filter.rs

@@ -6,7 +6,7 @@ use acropolis_common::{
     NetworkId,
 };
 use anyhow::{anyhow, Result};
-use caryatid_sdk::{module, Context, Module};
+use caryatid_sdk::{module, Context};
 use config::Config;
 use serde::Deserialize;
 use std::{path::Path, sync::Arc};

modules/tx_submitter/src/tx_submitter.rs

@@ -8,7 +8,7 @@ use acropolis_common::{
     messages::{Command, CommandResponse, Message},
 };
 use anyhow::{Context as _, Result, bail};
-use caryatid_sdk::{Context, Module, module};
+use caryatid_sdk::{Context, module};
 use config::Config;
 use futures::stream::{FuturesUnordered, StreamExt};
 use peer::PeerConfig;

modules/tx_unpacker/src/tx_unpacker.rs

@@ -9,7 +9,7 @@ use acropolis_common::{
     },
     *,
 };
-use caryatid_sdk::{module, Context, Module};
+use caryatid_sdk::{module, Context};
 use std::{clone::Clone, fmt::Debug, sync::Arc};
 
 use anyhow::Result;

modules/utxo_state/src/utxo_state.rs

@@ -5,7 +5,7 @@ use acropolis_common::{
     messages::{CardanoMessage, Message, StateQuery, StateQueryResponse},
     queries::utxos::{UTxOStateQuery, UTxOStateQueryResponse, DEFAULT_UTXOS_QUERY_TOPIC},
 };
-use caryatid_sdk::{module, Context, Module};
+use caryatid_sdk::{module, Context};
 
 use acropolis_common::queries::errors::QueryError;
 use anyhow::{anyhow, Result};

processes/golden_tests/src/test_module.rs

@@ -7,7 +7,7 @@ use acropolis_common::{
     BlockHash, BlockInfo, BlockStatus, Era,
 };
 use anyhow::{Context as AnyhowContext, Result};
-use caryatid_sdk::{module, Context, Module};
+use caryatid_sdk::{module, Context};
 use config::Config;
 use std::sync::Arc;
 

processes/replayer/src/playback.rs

@@ -8,7 +8,7 @@ use acropolis_common::{
     BlockHash, BlockInfo,
 };
 use anyhow::{anyhow, bail, ensure, Result};
-use caryatid_sdk::{module, Context, Module};
+use caryatid_sdk::{module, Context};
 use config::Config;
 use std::collections::HashMap;
 use std::fs::read_to_string;

processes/replayer/src/recorder.rs

@@ -8,7 +8,7 @@ use acropolis_common::{
     BlockInfo,
 };
 use anyhow::{anyhow, Result};
-use caryatid_sdk::{module, Context, Module, Subscription};
+use caryatid_sdk::{module, Context, Subscription};
 use config::Config;
 use std::{fs::File, io::Write, sync::Arc};
 use tracing::{error, info};

processes/replayer/src/recorder_alonzo_governance.rs

@@ -5,7 +5,7 @@ use acropolis_common::{
     AlonzoBabbageUpdateProposal, BlockInfo, GenesisKeyhash, ProtocolParamUpdate,
 };
 use anyhow::{anyhow, Result};
-use caryatid_sdk::{module, Context, Module, Subscription};
+use caryatid_sdk::{module, Context, Subscription};
 use config::Config;
 use serde_with::{base64::Base64, serde_as};
 use std::{fs::File, io::Write, sync::Arc};

processes/tx_submitter_cli/src/main.rs

@@ -7,7 +7,7 @@ use acropolis_common::{
 use acropolis_module_tx_submitter::TxSubmitter;
 use anyhow::{Result, bail};
 use caryatid_process::Process;
-use caryatid_sdk::{Context, Module, module};
+use caryatid_sdk::{Context, module};
 use clap::Parser;
 use config::{Config, File};
 use tokio::{fs, select, sync::mpsc};