init client

Signed-off-by: remzi <[email protected]>

rucat_client/Cargo.toml

@@ -5,8 +5,4 @@ edition = "2021"
 
 [dependencies]
 rucat_common = {path = "../rucat_common"}
-serde_json = "1.0.135"
-tonic = "0.12.3"
-tokio = { version = "1.43.0", features = ["macros", "rt-multi-thread"] }
-tracing = {"version" = "0.1.41"}
-tracing-subscriber = {"version" = "0.3.19"}
+reqwest = { version = "0.12.12", features = ["json"] }

rucat_client/examples/engine.rs

@@ -0,0 +1,16 @@
+use ::rucat_client::engine::create_engine;
+use ::rucat_common::engine::{CreateEngineRequest, EngineType};
+use rucat_common::tokio;
+
+#[tokio::main]
+async fn main() -> Result<(), reqwest::Error> {
+    let request = CreateEngineRequest {
+        name: "spark0".to_owned(),
+        engine_type: EngineType::Spark,
+        version: "3.0.0".to_owned(),
+        config: None,
+    };
+    let id = create_engine(&request).await?;
+    println!("Engine created with id: {}", id);
+    Ok(())
+}

rucat_client/src/engine.rs

@@ -0,0 +1,16 @@
+//! Functions for managing the engine.
+
+use ::rucat_common::engine::{CreateEngineRequest, EngineId};
+
+pub async fn create_engine(request: &CreateEngineRequest) -> Result<EngineId, reqwest::Error> {
+    let client = reqwest::Client::new();
+    let id: EngineId = client
+        .post("http://localhost:3000/engine")
+        .json(request)
+        .send()
+        .await?
+        .json()
+        .await?;
+
+    Ok(id)
+}

rucat_client/src/lib.rs

@@ -0,0 +1 @@
+pub mod engine;