zksync_contract_verification_server 0.1.0

ZKsync contract verification server
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

use anyhow::Context as _;
use tokio::sync::watch;
use zksync_config::ContractVerifierConfig;
use zksync_dal::ConnectionPool;

use self::api_decl::RestApi;

mod api_decl;
mod api_impl;
mod metrics;

pub async fn start_server(
    master_connection_pool: ConnectionPool<zksync_dal::Core>,
    replica_connection_pool: ConnectionPool<zksync_dal::Core>,
    config: ContractVerifierConfig,
    mut stop_receiver: watch::Receiver<bool>,
) -> anyhow::Result<()> {
    let bind_address = config.bind_addr();
    let api = RestApi::new(master_connection_pool, replica_connection_pool).into_router();

    let listener = tokio::net::TcpListener::bind(bind_address)
        .await
        .context("Cannot bind to the specified address")?;
    axum::serve(listener, api)
        .with_graceful_shutdown(async move {
            if stop_receiver.changed().await.is_err() {
                tracing::warn!("Stop signal sender for contract verification server was dropped without sending a signal");
            }
            tracing::info!("Stop signal received, contract verification server is shutting down");
        })
        .await
        .context("Contract verification handler server failed")?;
    tracing::info!("Contract verification handler server shut down");
    Ok(())
}