Skip to content

Commit f4e2ff9

Browse files
committed
feat: further scope nats' connection testing
1 parent c8b6885 commit f4e2ff9

File tree

1 file changed

+4
-21
lines changed
  • crates/fuel-core-nats/src

1 file changed

+4
-21
lines changed

crates/fuel-core-nats/src/lib.rs

+4-21
Original file line numberDiff line numberDiff line change
@@ -392,31 +392,14 @@ mod tests {
392392
#[tokio::test]
393393
async fn connects_to_nats() {
394394
let nats_nkey = None;
395-
let chain_id = ChainId::default();
396-
let base_asset_id = AssetId::default();
397-
let fuel_core_database = CombinedDatabase::default();
398-
let (_, blocks_subscription) =
399-
broadcast::channel::<Arc<dyn Deref<Target = ImportResult> + Send + Sync>>(1);
400-
401-
let publisher = Publisher::new(
402-
NATS_URL,
403-
nats_nkey,
404-
chain_id,
405-
base_asset_id,
406-
fuel_core_database,
407-
blocks_subscription,
408-
)
409-
.await
410-
.expect(&format!("Ensure NATS server is running at {NATS_URL}"));
395+
let nats = Publisher::connect_to_nats(NATS_URL, nats_nkey)
396+
.await
397+
.expect(&format!("Ensure NATS server is running at {NATS_URL}"));
411398

412-
assert!(publisher
413-
.nats
399+
assert!(nats
414400
.jetstream_messages
415401
.get_last_raw_message_by_subject("*")
416402
.await
417403
.is_err_and(|err| err.kind() == LastRawMessageErrorKind::NoMessageFound));
418-
419-
assert_eq!(publisher.chain_id, chain_id);
420-
assert_eq!(publisher.base_asset_id, base_asset_id);
421404
}
422405
}

0 commit comments

Comments
 (0)