remove unused code.

Author: larryl3u

protocol-units/execution/maptos/util/src/config/health_server.rs

@@ -1,7 +1,4 @@
 use super::common::{default_health_server_hostname, default_health_server_port};
-use anyhow::Error;
-use poem::listener::TcpListener;
-use poem::{get, handler, IntoResponse, Response, Route, Server};
 use serde::{Deserialize, Serialize};
 
 // An additional health server to be used by the indexer(or any other service).
@@ -19,21 +16,3 @@ impl Default for Config {
 		Self { hostname: default_health_server_hostname(), port: default_health_server_port() }
 	}
 }
-
-impl Config {
-	pub async fn run(self) -> Result<(), anyhow::Error> {
-		let url = format!("{}:{}", self.hostname, self.port);
-		run_service(url).await
-	}
-}
-
-pub async fn run_service(url: String) -> Result<(), Error> {
-	let route = Route::new().at("/health", get(health));
-	tracing::info!("Start health check access on :{url} .");
-	Server::new(TcpListener::bind(url)).run(route).await.map_err(Into::into)
-}
-
-#[handler]
-async fn health() -> Response {
-	"{\"OK\": \"healthy\"}".into_response()
-}

protocol-units/execution/maptos/util/src/config/metrics_server.rs

@@ -1,9 +1,5 @@
 use super::common::{default_metrics_server_hostname, default_metrics_server_port};
-use poem::http::StatusCode;
-use poem::{get, handler, listener::TcpListener, IntoResponse, Route, Server};
-use prometheus::{gather, Encoder, TextEncoder};
 use serde::{Deserialize, Serialize};
-use tokio::task::JoinHandle;
 
 #[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
 pub struct MetricsConfig {
@@ -21,44 +17,3 @@ impl Default for MetricsConfig {
 		}
 	}
 }
-
-impl MetricsConfig {
-	pub async fn start_metrics_server(&self) -> Result<JoinHandle<()>, anyhow::Error> {
-		let bind_address = format!("{}:{}", self.listen_hostname, self.listen_port);
-
-		let metrics_route = Route::new().at("/metrics", get(metrics_handler));
-
-		let server_handle = tokio::spawn(async move {
-			let listener = TcpListener::bind(&bind_address);
-			tracing::info!("Starting Prometheus metrics server on http://{}/metrics", bind_address);
-
-			if let Err(e) = Server::new(listener).run(metrics_route).await {
-				tracing::error!("Metrics server error: {}", e);
-			}
-		});
-
-		Ok(server_handle)
-	}
-}
-
-#[handler]
-async fn metrics_handler() -> impl IntoResponse {
-	let metrics = gather();
-	let encoder = TextEncoder::new();
-	let mut buffer = vec![];
-
-	match encoder.encode(&metrics, &mut buffer) {
-		Ok(_) => match String::from_utf8(buffer) {
-			Ok(metrics_text) => poem::Response::builder()
-				.status(StatusCode::OK)
-				.header("content-type", "text/plain")
-				.body(metrics_text),
-			Err(_) => poem::Response::builder()
-				.status(StatusCode::INTERNAL_SERVER_ERROR)
-				.body("Error encoding metrics"),
-		},
-		Err(_) => poem::Response::builder()
-			.status(StatusCode::INTERNAL_SERVER_ERROR)
-			.body("Error gathering metrics"),
-	}
-}