Skip to content

Commit

Permalink
Merge pull request #4167 from nymtech/bugfix/gateway-ws-listener-befo…
Browse files Browse the repository at this point in the history
…re-NR

start gateway websocket listener before embedded NR
  • Loading branch information
tommyv1987 authored Nov 24, 2023
2 parents bd83078 + 24746dc commit 17357da
Showing 1 changed file with 8 additions and 8 deletions.
16 changes: 8 additions & 8 deletions gateway/src/node/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -476,6 +476,13 @@ impl<St> Gateway<St> {
});
}

self.start_client_websocket_listener(
mix_forwarding_channel.clone(),
active_clients_store.clone(),
shutdown.subscribe().named("websocket::Listener"),
Arc::new(coconut_verifier),
);

let nr_request_filter = if self.config.network_requester.enabled {
let embedded_nr = self
.start_network_requester(
Expand All @@ -496,7 +503,7 @@ impl<St> Gateway<St> {
if self.config.ip_packet_router.enabled {
let embedded_ip_sp = self
.start_ip_packet_router(
mix_forwarding_channel.clone(),
mix_forwarding_channel,
shutdown.subscribe().named("ip_service_provider"),
)
.await?;
Expand All @@ -513,13 +520,6 @@ impl<St> Gateway<St> {
.with_maybe_network_request_filter(nr_request_filter)
.start(shutdown.subscribe().named("http-api"))?;

self.start_client_websocket_listener(
mix_forwarding_channel,
active_clients_store,
shutdown.subscribe().named("websocket::Listener"),
Arc::new(coconut_verifier),
);

// Once this is a bit more mature, make this a commandline flag instead of a compile time
// flag
#[cfg(feature = "wireguard")]
Expand Down

0 comments on commit 17357da

Please sign in to comment.