From 502569324950b010d7f929bd1cfa7fcb23a88b07 Mon Sep 17 00:00:00 2001 From: chinyuchan Date: Mon, 18 Mar 2024 12:05:00 +0800 Subject: [PATCH] fix. --- indexer/src/main.rs | 6 ++---- scanner/src/main.rs | 2 +- 2 files changed, 3 insertions(+), 5 deletions(-) diff --git a/indexer/src/main.rs b/indexer/src/main.rs index db59051..2074dc8 100644 --- a/indexer/src/main.rs +++ b/indexer/src/main.rs @@ -18,7 +18,6 @@ use log::info; use serde::{Deserialize, Serialize}; use sqlx::pool::PoolOptions; use sqlx::{PgPool, Pool, Postgres}; -use std::env; use std::fs::File; use std::io::Read; use std::sync::Arc; @@ -57,7 +56,7 @@ async fn main() -> Result<()> { tracing_subscriber::fmt::init(); let config = Config::new("./config.toml")?; - info!("listen at: {}", config.listen); + info!("listening at: {}", config.listen); info!("EVM RPC: {}", config.evm_rpc); info!("staking contract: {}", config.staking); info!("reward contract: {}", config.reward); @@ -68,10 +67,9 @@ async fn main() -> Result<()> { let reward_addr: Address = config.reward.parse()?; let reward = RewardContract::new(reward_addr, Arc::new(provider)); - let db_url = env::var("DATABASE_URL").expect("missing env var `DATABASE_URL`"); let pool: Pool = PoolOptions::new() .max_connections(10) - .connect(db_url.as_str()) + .connect(&config.db_url) .await .expect("can't connect to database"); info!("Connecting db...ok"); diff --git a/scanner/src/main.rs b/scanner/src/main.rs index fdfe14a..0d5f91a 100644 --- a/scanner/src/main.rs +++ b/scanner/src/main.rs @@ -62,7 +62,7 @@ async fn main() -> Result<()> { let rpc_url: Url = args.node.parse().expect("parse node url"); - info!("Start syncing..."); + info!("Starting syncing..."); let scanner = Scanner::new(DEFAULT_RPC_RETRIES, num_cpus::get(), rpc_url, storage) .expect("failed to new scanner"); let _ = scanner.run(start, interval).await;