fix: add querier details to parseable.json on a fresh init

Author: Anirudhxx

server/src/handlers/http/cluster/mod.rs

@@ -849,8 +849,8 @@ pub async fn forward_create_stream_request(stream_name: &str) -> Result<(), Stre
     let staging_metadata = get_staging_metadata().unwrap().ok_or_else(|| {
         StreamError::Anyhow(anyhow::anyhow!("Failed to retrieve staging metadata"))
     })?;
-    let querier_endpoint = to_url_string(staging_metadata.querier_endpoint.unwrap());
-    let token = staging_metadata.querier_auth_token.unwrap();
+    let querier_endpoint = to_url_string(staging_metadata.querier_endpoint);
+    let token = staging_metadata.querier_auth_token;
 
     if !check_liveness(&querier_endpoint).await {
         log::warn!("Querier {} is not live", querier_endpoint);

server/src/storage/store_metadata.rs

@@ -22,6 +22,7 @@ use std::{
     path::PathBuf,
 };
 
+use base64::Engine;
 use bytes::Bytes;
 use once_cell::sync::OnceCell;
 use relative_path::RelativePathBuf;
@@ -63,12 +64,25 @@ pub struct StorageMetadata {
     pub roles: HashMap<String, Vec<DefaultPrivilege>>,
     #[serde(default)]
     pub default_role: Option<String>,
-    pub querier_endpoint: Option<String>,
-    pub querier_auth_token: Option<String>,
+    pub querier_endpoint: String,
+    pub querier_auth_token: String,
 }
 
 impl StorageMetadata {
     pub fn new() -> Self {
+        let querier_auth_token = format!(
+            "Basic {}",
+            base64::prelude::BASE64_STANDARD.encode(format!(
+                "{}:{}",
+                CONFIG.parseable.username, CONFIG.parseable.password
+            ))
+        );
+
+        let (querier_endpoint, querier_auth_token) = match CONFIG.parseable.mode {
+            Mode::All | Mode::Query => (CONFIG.parseable.address.clone(), querier_auth_token),
+            Mode::Ingest => (String::new(), String::new()),
+        };
+
         Self {
             version: CURRENT_STORAGE_METADATA_VERSION.to_string(),
             mode: CONFIG.storage_name.to_owned(),
@@ -80,11 +94,10 @@ impl StorageMetadata {
             streams: Vec::new(),
             roles: HashMap::default(),
             default_role: None,
-            querier_endpoint: None,
-            querier_auth_token: None,
+            querier_endpoint,
+            querier_auth_token,
         }
     }
-
     pub fn global() -> &'static StaticStorageMetadata {
         STORAGE_METADATA
             .get()