update optimistic block imports

astriaorg · Oct 23, 2024 · 28a62d9 · 28a62d9
1 parent 4bb4ca0
commit 28a62d9
Show file tree

Hide file tree

Showing 4 changed files with 19 additions and 17 deletions.
diff --git a/crates/astria-core/src/generated/mod.rs b/crates/astria-core/src/generated/mod.rs
diff --git a/crates/astria-core/src/sequencerblock/v1alpha1/optimistic_block.rs b/crates/astria-core/src/sequencerblock/v1alpha1/optimistic_block.rs
@@ -1,7 +1,7 @@
 use bytes::Bytes;
 
 use crate::{
-    generated::sequencerblock::v1alpha1 as raw,
+    generated::sequencerblock::v1::optimisticblock::v1alpha1 as raw,
     Protobuf,
 };
 

diff --git a/crates/astria-sequencer/src/grpc/optimistic.rs b/crates/astria-sequencer/src/grpc/optimistic.rs
@@ -4,7 +4,7 @@ use std::{
 };
 
 use astria_core::{
-    generated::sequencerblock::v1alpha1::{
+    generated::sequencerblock::v1::optimisticblock::v1alpha1::{
         optimistic_block_service_server::OptimisticBlockService,
         GetBlockCommitmentStreamRequest,
         GetBlockCommitmentStreamResponse,
@@ -88,12 +88,7 @@ impl OptimisticBlockService for OptimisticBlockServer {
                         block: Some(raw_filtered_optimistic_block),
                     };
 
-                    match tx
-                        .send(Ok(
-                            get_optimistic_block_stream_response,
-                        ))
-                        .await
-                    {
+                    match tx.send(Ok(get_optimistic_block_stream_response)).await {
                         Ok(()) => {
                             debug!("sent optimistic block");
                         }
@@ -136,12 +131,7 @@ impl OptimisticBlockService for OptimisticBlockServer {
                         commitment: Some(sequencer_block_commit.to_raw()),
                     };
 
-                    match tx
-                        .send(Ok(
-                            get_block_commitment_stream_response,
-                        ))
-                        .await
-                    {
+                    match tx.send(Ok(get_block_commitment_stream_response)).await {
                         Ok(()) => {
                             debug!("sent block commitment");
                         }

diff --git a/crates/astria-sequencer/src/sequencer.rs b/crates/astria-sequencer/src/sequencer.rs
@@ -1,7 +1,7 @@
 use astria_core::{
-    generated::sequencerblock::{
-        v1::sequencer_service_server::SequencerServiceServer,
-        v1alpha1::optimistic_block_service_server::OptimisticBlockServiceServer,
+    generated::sequencerblock::v1::{
+        optimisticblock::v1alpha1::optimistic_block_service_server::OptimisticBlockServiceServer,
+        sequencer_service_server::SequencerServiceServer,
     },
     sequencerblock::{
         v1::SequencerBlock,