feat(data-stream): add nkey auth (#32)

Co-authored-by: Pedro Nauck <pedronauck@gmail.com>

Author: lostman

crates/fuel-core-nats/nats.conf

@@ -1,4 +1,8 @@
-
+authorization: {
+  users: [
+    { nkey: UDMBGUBEOCJVCOXHSQGYRX4SGS3QEAEDIVNHDBD63YEKHSGPVO53I2NU }
+  ]
+}
 jetstream = {
     max_file_store = 21474836480
 }

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

@@ -44,15 +44,25 @@ pub struct Publisher {
 impl Publisher {
     pub async fn new(
         nats_url: &str,
+        nats_nkey: Option<String>,
         chain_id: ChainId,
         base_asset_id: AssetId,
         fuel_database: CombinedDatabase,
         block_subscription: Receiver<Arc<dyn Deref<Target = ImportResult> + Send + Sync>>,
     ) -> anyhow::Result<Self> {
         // Connect to the NATS server
-        let client = async_nats::connect(nats_url)
+        let client = match nats_nkey {
+            Some(nkey) => async_nats::connect_with_options(
+                nats_url,
+                async_nats::ConnectOptions::with_nkey(nkey),
+            )
             .await
-            .context(format!("Connecting to {nats_url}"))?;
+            .context(format!("Connecting to {nats_url}"))?,
+            None => async_nats::connect(nats_url)
+                .await
+                .context(format!("Connecting to {nats_url}"))?,
+        };
+
         let max_payload_size = client.server_info().max_payload;
         info!("NATS Publisher: max_payload_size={max_payload_size}");
         // Create a JetStream context

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

@@ -12,6 +12,8 @@ pub struct Cli {
         default_value = "localhost:4222"
     )]
     nats_url: String,
+    #[arg(long, value_name = "NKEY", env = "NATS_NKEY")]
+    nats_nkey: Option<String>,
     #[command(flatten)]
     fuel_core_config: run::Command,
 }
@@ -31,6 +33,7 @@ async fn main() -> anyhow::Result<()> {
 
     let publisher = fuel_core_nats::Publisher::new(
         &cli.nats_url,
+        cli.nats_nkey,
         chain_id,
         *base_asset_id,
         service.shared.database.clone(),