Add a prefix to http server logs

Author: Alenar

mithril-aggregator/src/http_server/routes/certificate_routes.rs

@@ -44,7 +44,7 @@ mod handlers {
     pub async fn certificate_pending(
         certificate_pending_store: Arc<CertificatePendingStore>,
     ) -> Result<impl warp::Reply, Infallible> {
-        debug!("certificate_pending");
+        debug!("⇄ HTTP SERVER: certificate_pending");
 
         match certificate_pending_store.get().await {
             Ok(Some(certificate_pending)) => Ok(reply::json(&certificate_pending, StatusCode::OK)),
@@ -61,7 +61,10 @@ mod handlers {
         certificate_hash: String,
         certificate_store: Arc<CertificateStore>,
     ) -> Result<impl warp::Reply, Infallible> {
-        debug!("certificate_certificate_hash/{}", certificate_hash);
+        debug!(
+            "⇄ HTTP SERVER: certificate_certificate_hash/{}",
+            certificate_hash
+        );
 
         match certificate_store.get_from_hash(&certificate_hash).await {
             Ok(Some(certificate)) => Ok(reply::json(&certificate, StatusCode::OK)),

mithril-aggregator/src/http_server/routes/epoch_routes.rs

@@ -37,7 +37,7 @@ mod handlers {
         protocol_parameters_store: Arc<ProtocolParametersStore>,
         multi_signer: MultiSignerWrapper,
     ) -> Result<impl warp::Reply, Infallible> {
-        debug!("epoch_settings");
+        debug!("⇄ HTTP SERVER: epoch_settings");
 
         match multi_signer.read().await.get_current_beacon().await {
             Some(beacon) => match protocol_parameters_store

mithril-aggregator/src/http_server/routes/signatures_routes.rs

@@ -34,7 +34,7 @@ mod handlers {
         signature: entities::SingleSignatures,
         multi_signer: MultiSignerWrapper,
     ) -> Result<impl warp::Reply, Infallible> {
-        debug!("register_signatures/{:?}", signature);
+        debug!("⇄ HTTP SERVER: register_signatures/{:?}", signature);
 
         let mut multi_signer = multi_signer.write().await;
         match multi_signer.register_single_signature(&signature).await {

mithril-aggregator/src/http_server/routes/signer_routes.rs

@@ -35,7 +35,7 @@ mod handlers {
         signer: entities::Signer,
         multi_signer: MultiSignerWrapper,
     ) -> Result<impl warp::Reply, Infallible> {
-        debug!("register_signer/{:?}", signer);
+        debug!("⇄ HTTP SERVER: register_signer/{:?}", signer);
 
         let mut multi_signer = multi_signer.write().await;
         match key_decode_hex(&signer.verification_key) {

mithril-aggregator/src/http_server/routes/snapshot_routes.rs

@@ -68,7 +68,7 @@ mod handlers {
     pub async fn snapshots(
         snapshot_store: Arc<dyn SnapshotStore>,
     ) -> Result<impl warp::Reply, Infallible> {
-        debug!("snapshots");
+        debug!("⇄ HTTP SERVER: snapshots");
 
         match snapshot_store.list_snapshots().await {
             Ok(snapshots) => Ok(reply::json(&snapshots, StatusCode::OK)),
@@ -86,7 +86,7 @@ mod handlers {
     ) -> Result<impl warp::Reply, Infallible> {
         let filepath = reply.path().to_path_buf();
         debug!(
-            "ensure_downloaded_file_is_a_snapshot / file: `{}`",
+            "⇄ HTTP SERVER: ensure_downloaded_file_is_a_snapshot / file: `{}`",
             filepath.display()
         );
 
@@ -115,7 +115,7 @@ mod handlers {
         config: Configuration,
         snapshot_store: Arc<dyn SnapshotStore>,
     ) -> Result<impl warp::Reply, Infallible> {
-        debug!("snapshot_download/{}", digest);
+        debug!("⇄ HTTP SERVER: snapshot_download/{}", digest);
 
         match snapshot_store.get_snapshot_details(digest).await {
             Ok(Some(snapshot)) => {
@@ -150,7 +150,7 @@ mod handlers {
         digest: String,
         snapshot_store: Arc<dyn SnapshotStore>,
     ) -> Result<impl warp::Reply, Infallible> {
-        debug!("snapshot_digest/{}", digest);
+        debug!("⇄ HTTP SERVER: snapshot_digest/{}", digest);
 
         match snapshot_store.get_snapshot_details(digest).await {
             Ok(snapshot) => match snapshot {