Remove dependency to wasm timer

Author: aterentic-ethernal

Diff for: Cargo.lock

@@ -76,8 +76,6 @@ avail-rust = { workspace = true, default-features = false, features = ["wasm"] }
 blake2b_simd = "1.0.2"
 color-eyre = { workspace = true }
 ed25519-compact = "2.1.1"
-# NOTE: This is used due bug explained at: https://github.com/tomaka/wasm-timer/pull/13
-fluvio-wasm-timer = "0.2.5"
 hyper = { version = "0.14.23", features = ["http1"] }
 libp2p = { workspace = true, features = ["wasm-bindgen"] }
 libp2p-webrtc-websys = { workspace = true }

Diff for: core/Cargo.toml

@@ -1,6 +1,4 @@
 use color_eyre::{eyre::eyre, Result};
-#[cfg(target_arch = "wasm32")]
-use fluvio_wasm_timer::Interval;
 use futures::StreamExt;
 #[cfg(not(target_arch = "wasm32"))]
 use libp2p::mdns;
@@ -205,8 +203,9 @@ impl EventLoop {
 
 		#[cfg(not(target_arch = "wasm32"))]
 		let mut report_timer = interval(event_counter.report_interval);
+
 		#[cfg(target_arch = "wasm32")]
-		let mut report_timer = Interval::new(event_counter.report_interval);
+		let mut next_tick = Instant::now() + event_counter.report_interval;
 
 		loop {
 			#[cfg(not(target_arch = "wasm32"))]
@@ -237,6 +236,9 @@ impl EventLoop {
 				}
 			}
 
+			#[cfg(target_arch = "wasm32")]
+			let now = Instant::now();
+
 			#[cfg(target_arch = "wasm32")]
 			tokio::select! {
 				event = self.swarm.next() => {
@@ -253,9 +255,10 @@ impl EventLoop {
 						break;
 					},
 				},
-				_ = report_timer.next() => {
+				_ = tokio::time::sleep(next_tick.checked_duration_since(now).unwrap_or_default()) => {
 					debug!("Events per {}s: {:.2}", event_counter.duration_secs(), event_counter.count_events());
 					event_counter.reset_counter();
+					next_tick += event_counter.report_interval;
 				},
 				// if the shutdown was triggered,
 				// break the loop immediately, proceed to the cleanup phase