Initial development of resource-info-fetcher

Author: sbernauer

Cargo.lock

@@ -47,6 +47,7 @@ tar = "0.4"
 tokio = { version = "1.52", features = ["full"] }
 tracing = "0.1"
 url = "2.5"
+urlencoding = "2.1"
 uuid = "1.10"
 
 [patch."https://github.com/stackabletech/operator-rs.git"]

Cargo.toml

@@ -0,0 +1 @@
+__datahub_system

Tiltfile

@@ -0,0 +1 @@
+datahub-demo-system-secret

_TEST/clientId

@@ -0,0 +1,8 @@
+{
+    "backend": {
+        "dataHub": {
+            "hostname": "localhost",
+            "port": 8080
+        }
+    }
+}

_TEST/clientSecret

@@ -0,0 +1,22 @@
+[package]
+name = "info-fetcher-commons"
+description = "Common shared code between info fetchers"
+version.workspace = true
+authors.workspace = true
+license.workspace = true
+edition.workspace = true
+repository.workspace = true
+publish = false
+
+[dependencies]
+stackable-operator.workspace = true
+
+axum.workspace = true
+hyper.workspace = true
+native-tls.workspace = true
+reqwest.workspace = true
+rustls-pki-types.workspace = true
+serde.workspace = true
+serde_json.workspace = true
+snafu.workspace = true
+tokio.workspace = true

_TEST/rif.json

@@ -0,0 +1,33 @@
+use std::{
+    fs::File,
+    io::BufReader,
+    path::{Path, PathBuf},
+};
+
+use serde::de::DeserializeOwned;
+use snafu::{ResultExt, Snafu};
+
+#[derive(Snafu, Debug)]
+pub enum ConfigError {
+    #[snafu(display("failed to open config file from {path:?}"))]
+    OpenFile {
+        source: std::io::Error,
+        path: PathBuf,
+    },
+
+    #[snafu(display("unable to read config file from {path:?}"))]
+    ParseConfigFile {
+        source: serde_json::Error,
+        path: PathBuf,
+    },
+}
+
+pub fn read_config_file<C>(path: &Path) -> Result<C, ConfigError>
+where
+    C: DeserializeOwned,
+{
+    let file = File::open(path).with_context(|_| OpenFileSnafu { path })?;
+    let reader = BufReader::new(file);
+
+    serde_json::from_reader(reader).with_context(|_| ParseConfigFileSnafu { path })
+}

rust/info-fetcher-commons/Cargo.toml

@@ -0,0 +1,3 @@
+pub mod config;
+pub mod http_error;
+pub mod utils;