diff --git a/src/service.rs b/src/service.rs index 96c5da3..0bc870c 100644 --- a/src/service.rs +++ b/src/service.rs @@ -23,6 +23,7 @@ use hotshot_types::{ vid::{VidCommitment, VidPrecomputeData}, }; use lru::LruCache; +use vbs::version::StaticVersionType; use crate::WaitAndKeep; use crate::{ @@ -814,18 +815,18 @@ impl ReadState for ProxyGlobalState { } } -async fn connect_to_events_service( +async fn connect_to_events_service( hotshot_events_api_url: Url, ) -> Option<( surf_disco::socket::Connection< Event, surf_disco::socket::Unsupported, EventStreamError, - V::Base, + ApiVer, >, GeneralStaticCommittee::SignatureKey>, )> { - let client = surf_disco::Client::::new( + let client = surf_disco::Client::::new( hotshot_events_api_url.clone(), ); @@ -874,7 +875,10 @@ async fn connect_to_events_service( /* Running Non-Permissioned Builder Service */ -pub async fn run_non_permissioned_standalone_builder_service( +pub async fn run_non_permissioned_standalone_builder_service< + Types: NodeType, + ApiVer: StaticVersionType, +>( // sending a DA proposal from the hotshot to the builder states da_sender: BroadcastSender>, @@ -891,7 +895,7 @@ pub async fn run_non_permissioned_standalone_builder_service>>, ) -> Result<(), anyhow::Error> { // connection to the events stream - let connected = connect_to_events_service::<_, V>(hotshot_events_api_url.clone()).await; + let connected = connect_to_events_service::<_, ApiVer>(hotshot_events_api_url.clone()).await; if connected.is_none() { return Err(anyhow!( "failed to connect to API at {hotshot_events_api_url}" @@ -975,7 +979,7 @@ pub async fn run_non_permissioned_standalone_builder_service { tracing::error!("Event stream ended"); let connected = - connect_to_events_service::<_, V>(hotshot_events_api_url.clone()).await; + connect_to_events_service::<_, ApiVer>(hotshot_events_api_url.clone()).await; if connected.is_none() { return Err(anyhow!( "failed to reconnect to API at {hotshot_events_api_url}"