fix teeracle treading

app-libs/oracle/src/metrics_exporter.rs

@@ -83,7 +83,7 @@ where
 	fn record_response_time(&self, source: String, timer: Instant) {
 		self.update_metrics(vec![ExchangeRateOracleMetric::ResponseTime(
 			source,
-			timer.elapsed().as_millis(),
+			timer.elapsed().as_secs().into(),
 		)]);
 	}
 

service/src/teeracle/mod.rs

@@ -121,29 +121,26 @@ where
 	// Send the extrinsics to the parentchain and wait for InBlock confirmation.
 	for call in extrinsics.into_iter() {
 		let node_api_clone = node_api.clone();
-		tokio_handle.spawn(async move {
-			let encoded_extrinsic = call.encode();
-			debug!("Hex encoded extrinsic to be sent: {}", hex_encode(&encoded_extrinsic));
-
-			println!("[>] Update oracle data (send the extrinsic)");
-			let extrinsic_hash = match node_api_clone.submit_and_watch_opaque_extrinsic_until(
-				&encoded_extrinsic.into(),
-				XtStatus::InBlock,
-			) {
-				Err(e) => {
-					error!("Failed to send extrinsic: {:?}", e);
-					set_extrinsics_inclusion_success(false);
-					return
-				},
-				Ok(report) => {
-					set_extrinsics_inclusion_success(true);
+		let encoded_extrinsic = call.encode();
+		debug!("Hex encoded extrinsic to be sent: {}", hex_encode(&encoded_extrinsic));
+
+		println!("[>] Update oracle data (send the extrinsic)");
+		match node_api_clone
+			.submit_and_watch_opaque_extrinsic_until(&encoded_extrinsic.into(), XtStatus::InBlock)
+		{
+			Err(e) => {
+				error!("Failed to send extrinsic: {:?}", e);
+				set_extrinsics_inclusion_success(false);
+				continue
+			},
+			Ok(report) => {
+				set_extrinsics_inclusion_success(true);
+				println!(
+					"[<] Extrinsic got included into a block. Hash: {:?}\n",
 					report.extrinsic_hash
-				},
-			};
-
-			println!("[<] Extrinsic got included into a block. Hash: {:?}\n", extrinsic_hash);
-		});
+				);
+			},
+		};
 	}
-
 	Ok(())
 }

service/src/teeracle/teeracle_metrics.rs

@@ -30,7 +30,7 @@ lazy_static! {
 		register_gauge_vec!("integritee_teeracle_exchange_rate", "Exchange rates partitioned into source and trading pair", &["source", "trading_pair"])
 			.unwrap();
 	static ref RESPONSE_TIME: IntGaugeVec =
-		register_int_gauge_vec!("integritee_teeracle_response_times", "Response times in ms for requests that the oracle makes", &["source"])
+		register_int_gauge_vec!("integritee_teeracle_response_times", "Response times in for requests that the oracle makes [s]", &["source"])
 			.unwrap();
 	static ref NUMBER_OF_REQUESTS: IntCounterVec =
 		register_int_counter_vec!("integritee_teeracle_number_of_requests", "Number of requests made per source", &["source"])