Add logs for builder tx (#25)

* little fix

* little fix

Author: SozinM

src/main.rs

@@ -15,6 +15,7 @@ use {
 	},
 	reth_optimism_rpc::OpEthApiBuilder,
 	std::sync::{Arc, atomic::AtomicU64},
+	tracing::warn,
 };
 
 mod args;
@@ -155,13 +156,15 @@ fn build_flashblocks_pipeline(
 	)
 		.into_pipeline();
 
-	let flashblock_building_pipeline_steps =
-		if let Some(ref signer) = cli_args.builder_signer {
-			flashblock_building_pipeline_steps
-				.with_epilogue(BuilderEpilogue::with_signer(signer.clone().into()))
-		} else {
-			flashblock_building_pipeline_steps
-		};
+	let flashblock_building_pipeline_steps = if let Some(ref signer) =
+		cli_args.builder_signer
+	{
+		flashblock_building_pipeline_steps
+			.with_epilogue(BuilderEpilogue::with_signer(signer.clone().into()))
+	} else {
+		warn!("BUILDER_SECRET_KEY is not specified, skipping builder transactions");
+		flashblock_building_pipeline_steps
+	};
 
 	let flashblock_building_pipeline = flashblock_building_pipeline_steps
 		.with_epilogue(PublishFlashblock::new(

src/publish.rs

@@ -36,7 +36,7 @@ use {
 		accept_async,
 		tungstenite::{Message, Utf8Bytes},
 	},
-	tracing::{debug, trace},
+	tracing::{debug, error, trace},
 };
 
 /// Flashblocks pipeline step for publishing flashblocks to external
@@ -91,7 +91,7 @@ impl PublishFlashblock {
 
 impl Step<Flashblocks> for PublishFlashblock {
 	async fn step(
-		self: std::sync::Arc<Self>,
+		self: Arc<Self>,
 		payload: Checkpoint<Flashblocks>,
 		ctx: StepContext<Flashblocks>,
 	) -> ControlFlow<Flashblocks> {
@@ -100,7 +100,7 @@ impl Step<Flashblocks> for PublishFlashblock {
 		if self.flashblock_number.load(Ordering::Relaxed)
 			>= self.max_flashblocks.load(Ordering::Relaxed)
 		{
-			tracing::trace!("Stopping flashblocks production");
+			trace!("Stopping flashblocks production");
 			// We have reached maximum number of flashblocks, stop sending them
 			return ControlFlow::Break(payload);
 		}
@@ -116,7 +116,7 @@ impl Step<Flashblocks> for PublishFlashblock {
 
 		let sealed_block = payload.build_payload();
 		if let Err(e) = sealed_block {
-			tracing::error!("Failed to build sealed block: {:?}", e);
+			error!("Failed to build sealed block: {:?}", e);
 			return ControlFlow::Break(payload);
 		}
 		let sealed_block = sealed_block.expect("sealed block is ok");