Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

1 change: 1 addition & 0 deletions networks/movement/indexer-v2/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@ tracing-subscriber = { workspace = true }
maptos-execution-util = { workspace = true }
clap = { workspace = true }
reqwest = { workspace = true, features = ["json"] }
movement-config = { workspace = true }
serde_json = { workspace = true }
tempfile = { workspace = true }
processor-v2 = { workspace = true }
Expand Down
35 changes: 15 additions & 20 deletions networks/movement/indexer-v2/src/main.rs
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
use aptos_indexer_processor_sdk::server_framework::RunnableConfig;
use godfig::{backend::config_file::ConfigFile, Godfig};
use maptos_execution_util::config::Config;
use movement_config::Config;
use movement_health::run_service;
use movement_tracing::simple_metrics::start_metrics_server;
use processor_v2::config::indexer_processor_config::IndexerProcessorConfig;
Expand All @@ -13,25 +13,21 @@ fn main() -> Result<(), anyhow::Error> {
let runtime = get_maptos_runtime();

runtime.block_on(async move {
let maptos_config = load_maptos_config().await.expect("Failed to load maptos config");
let runnable_processor_config: IndexerProcessorConfig =
maptos_config.indexer_processor_v2.clone().into();

let config = load_maptos_config().await.expect("Failed to load maptos config");
let indexer_config = config.execution_config.maptos_config.indexer_processor_v2;
let runnable_processor_config: IndexerProcessorConfig = indexer_config.clone().into();
let metrics_config = indexer_config.metrics_config.clone();
let metrics_handle = tokio::spawn(async move {
let res = start_metrics_server(
maptos_config.indexer_processor_v2.metrics_config.listen_hostname,
maptos_config.indexer_processor_v2.metrics_config.listen_port,
)
.await;
let res =
start_metrics_server(metrics_config.listen_hostname, metrics_config.listen_port)
.await;
tracing::info!("Metrics server started: {:?}", res);
res
});

let health_config = indexer_config.health_config.clone();
let health_handle = tokio::spawn(async move {
let res = run_service(
maptos_config.indexer_processor_v2.health_config.hostname,
maptos_config.indexer_processor_v2.health_config.port,
)
.await;
let res = run_service(health_config.hostname, health_config.port).await;
tracing::info!("Health server started: {:?}", res);
res
});
Expand Down Expand Up @@ -94,13 +90,12 @@ async fn load_maptos_config() -> anyhow::Result<Config> {
// get the config file
let dot_movement = dot_movement::DotMovement::try_from_env()?;

// Load Maptos config
let maptos_config = {
// Load config
let config = {
let config_file = dot_movement.try_get_or_create_config_file().await?;
let godfig: Godfig<maptos_execution_util::config::Config, ConfigFile> =
Godfig::new(ConfigFile::new(config_file), vec!["maptos_config".to_string()]);
let godfig: Godfig<Config, ConfigFile> = Godfig::new(ConfigFile::new(config_file), vec![]);
godfig.try_wait_for_ready().await
}?;

Ok(maptos_config)
Ok(config)
}
2 changes: 1 addition & 1 deletion networks/movement/movement-full-node/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ movement-tracing = { workspace = true }
movement-config = { workspace = true }
dot-movement = { workspace = true }
godfig = { workspace = true }
tracing-subscriber = { workspace = true }
aptos-logger = { workspace = true }
console-subscriber = { workspace = true }
rocksdb = { workspace = true }
tracing = { workspace = true }
Expand Down
9 changes: 2 additions & 7 deletions networks/movement/movement-full-node/src/main.rs
Original file line number Diff line number Diff line change
@@ -1,16 +1,11 @@
#![forbid(unsafe_code)]
use clap::*;
use movement_full_node::MovementFullNode;
use tracing_subscriber::EnvFilter;

#[tokio::main]
async fn main() -> Result<(), anyhow::Error> {
// Initialize default tracing
tracing_subscriber::fmt()
.with_env_filter(
EnvFilter::try_from_default_env().unwrap_or_else(|_| EnvFilter::new("info")),
)
.init();
// Initialize aptos logger
aptos_logger::Logger::builder().level(aptos_logger::Level::Info).build();

// Initialize telemetry if MOVEMENT_METRICS_ADDR is set
if std::env::var("MOVEMENT_METRICS_ADDR").is_ok() {
Expand Down
Loading