more feature split, ready to refactor into different modules now

Author: amunra

questdb-rs/src/ingress/conf.rs

@@ -22,9 +22,8 @@
  *
  ******************************************************************************/
 
-use std::ops::Deref;
-
 use crate::{Error, ErrorCode, Result};
+use std::ops::Deref;
 
 /// Wraps a SenderBuilder config setting with the intent of tracking
 /// whether the value was user-specified or defaulted.
@@ -73,3 +72,81 @@ impl<T: PartialEq> Deref for ConfigSetting<T> {
         }
     }
 }
+
+#[cfg(feature = "_sender-http")]
+#[derive(Debug, Clone)]
+pub(crate) struct HttpConfig {
+    pub(crate) request_min_throughput: ConfigSetting<u64>,
+    pub(crate) user_agent: String,
+    pub(crate) retry_timeout: ConfigSetting<std::time::Duration>,
+    pub(crate) request_timeout: ConfigSetting<std::time::Duration>,
+}
+
+#[cfg(feature = "_sender-http")]
+impl Default for HttpConfig {
+    fn default() -> Self {
+        Self {
+            request_min_throughput: ConfigSetting::new_default(102400), // 100 KiB/s
+            user_agent: concat!("questdb/rust/", env!("CARGO_PKG_VERSION")).to_string(),
+            retry_timeout: ConfigSetting::new_default(std::time::Duration::from_secs(10)),
+            request_timeout: ConfigSetting::new_default(std::time::Duration::from_secs(10)),
+        }
+    }
+}
+
+#[cfg(feature = "_sender-http")]
+#[derive(PartialEq, Debug, Clone)]
+pub(crate) struct BasicAuthParams {
+    pub(crate) username: String,
+    pub(crate) password: String,
+}
+
+#[cfg(feature = "_sender-http")]
+impl BasicAuthParams {
+    pub(crate) fn to_header_string(&self) -> String {
+        use base64ct::{Base64, Encoding};
+        let pair = format!("{}:{}", self.username, self.password);
+        let encoded = Base64::encode_string(pair.as_bytes());
+        format!("Basic {encoded}")
+    }
+}
+
+#[cfg(feature = "_sender-http")]
+#[derive(PartialEq, Debug, Clone)]
+pub(crate) struct TokenAuthParams {
+    pub(crate) token: String,
+}
+
+#[cfg(feature = "_sender-http")]
+impl TokenAuthParams {
+    pub(crate) fn to_header_string(&self) -> crate::Result<String> {
+        if self.token.contains('\n') {
+            return Err(crate::error::fmt!(
+                AuthError,
+                "Bad auth token: Should not contain new-line char."
+            ));
+        }
+        Ok(format!("Bearer {}", self.token))
+    }
+}
+
+#[cfg(feature = "_sender-tcp")]
+#[derive(PartialEq, Debug, Clone)]
+pub(crate) struct EcdsaAuthParams {
+    pub(crate) key_id: String,
+    pub(crate) priv_key: String,
+    pub(crate) pub_key_x: String,
+    pub(crate) pub_key_y: String,
+}
+
+#[derive(PartialEq, Debug, Clone)]
+pub(crate) enum AuthParams {
+    #[cfg(feature = "_sender-tcp")]
+    Ecdsa(EcdsaAuthParams),
+
+    #[cfg(feature = "_sender-http")]
+    Basic(BasicAuthParams),
+
+    #[cfg(feature = "_sender-http")]
+    Token(TokenAuthParams),
+}