Transport upgrade

Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "subsquid-worker"
 license = "AGPL-3.0-or-later"
-version = "1.0.3"
+version = "1.0.4-rc1"
 edition = "2021"
 
 [[bin]]
@@ -48,9 +48,9 @@ tracing-opentelemetry = "0.22.0"
 tracing-subscriber = { version = "0.3.18", features = ["env-filter"] }
 walkdir = "2.5.0"
 
-contract-client = { git = "https://github.com/subsquid/subsquid-network.git", version = "1.0.3" }
-subsquid-messages = { git = "https://github.com/subsquid/subsquid-network.git", version = "1.0.1" }
-subsquid-network-transport = { git = "https://github.com/subsquid/subsquid-network.git", version = "1.0.5", features = ["worker", "metrics"] }
+contract-client = { git = "https://github.com/subsquid/subsquid-network.git", version = "1.0.4" }
+subsquid-messages = { git = "https://github.com/subsquid/subsquid-network.git", version = "1.0.2" }
+subsquid-network-transport = { git = "https://github.com/subsquid/subsquid-network.git", version = "1.0.11", features = ["worker", "metrics"] }
 
 [target.'cfg(not(target_env = "msvc"))'.dependencies]
 tikv-jemallocator = "0.5"

src/controller/p2p.rs

@@ -60,7 +60,7 @@ pub async fn create_p2p_controller(
     logs_collector_id: PeerId,
     data_dir: PathBuf,
     ping_interval: Duration,
-) -> Result<P2PController<impl Stream<Item = WorkerEvent>>> {
+) -> Result<P2PController<impl Stream<Item=WorkerEvent>>> {
     let worker_id = transport_builder.local_peer_id();
     info!("Local peer ID: {worker_id}");
     check_peer_id(worker_id, data_dir.join("peer_id"));
@@ -85,7 +85,7 @@ pub async fn create_p2p_controller(
     })
 }
 
-impl<EventStream: Stream<Item = WorkerEvent>> P2PController<EventStream> {
+impl<EventStream: Stream<Item=WorkerEvent>> P2PController<EventStream> {
     pub async fn run(&self, cancellation_token: CancellationToken) {
         run_all!(
             cancellation_token,
@@ -214,10 +214,6 @@ impl<EventStream: Stream<Item = WorkerEvent>> P2PController<EventStream> {
     fn handle_pong(&self, pong: Pong) {
         use subsquid_messages::pong::Status;
         match pong.status {
-            Some(Status::NotRegistered(())) => {
-                error!("Worker not registered on chain");
-                metrics::set_status(metrics::WorkerStatus::NotRegistered);
-            }
             Some(Status::UnsupportedVersion(())) => {
                 error!("Worker version not supported by the scheduler");
                 metrics::set_status(metrics::WorkerStatus::UnsupportedVersion);