Basic Crux Client for Crux/state

Co-authored-by: Otávio Pace <otaviopp8@gmail.com>

.gitignore

@@ -1,2 +1,3 @@
 /target
 Cargo.lock
+datomic-pro-*.jar

Cargo.toml

@@ -5,10 +5,13 @@ authors = ["Julia Naomi <jnboeira@outlook.com>"]
 description = "Crate to parse and emit EDN"
 documentation = "https://docs.rs/transistor/"
 repository = "https://github.com/naomijub/transistor"
-keywords = ["DATOMIC", "Client", "database"]
+keywords = ["CRUX", "Client", "database"]
 license = "GPL-3.0-or-later"
 edition = "2018"
 
+
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
+reqwest = { version = "0.10.6", features = ["blocking"] }
+edn-rs = "0.5.3"

Makefile

@@ -0,0 +1,2 @@
+crux:
+	docker run -d -p 3000:3000 juxt/crux-standalone:20.02-1.7.0-alpha

README.md

@@ -1,3 +1,4 @@
 # Transistor
 
-A Datomic Client crate.
+A Crux Client crate.
+* Gave up on datomic already.

src/http/mod.rs

@@ -0,0 +1,49 @@
+use reqwest::{
+    header::{HeaderMap,AUTHORIZATION},
+    blocking::{Client}, 
+    Result
+};
+
+pub struct Crux {
+    host: String,
+    port: String,
+    headers: HeaderMap
+}
+
+impl Crux{
+    pub fn new(host: &str, port: &str) -> Self {
+        Self{host: host.to_string(), port: port.to_string(), headers: HeaderMap::new()}
+    }
+
+    pub fn with_authorization(mut self, authorization: &str) -> Self {
+        self.headers.insert(AUTHORIZATION, authorization.parse().unwrap());
+        self
+    }
+
+    fn uri(&self) -> String {
+        format!("http://{}:{}", self.host, self.port)
+    }
+
+    pub fn client(&self) -> CruxClient {
+        CruxClient {
+            client: reqwest::blocking::Client::new(),
+            uri: self.uri().clone(),
+            headers: self.headers.clone()
+        }
+    }
+}
+
+pub struct CruxClient {
+    client: Client,
+    uri: String, 
+    headers: HeaderMap,
+}
+
+impl CruxClient {
+    pub fn state(&self) -> Result<String> {
+        self.client.get(&self.uri)
+            .headers(self.headers.clone())
+            .send()?
+            .text()
+    }
+}

src/lib.rs

@@ -1,7 +1 @@
-#[cfg(test)]
-mod tests {
-    #[test]
-    fn it_works() {
-        assert_eq!(2 + 2, 4);
-    }
-}
+pub mod http;

src/main.rs

@@ -0,0 +1,9 @@
+mod http;
+
+use http::Crux;
+
+fn main() {
+    let body = Crux::new("localhost", "3000").client().state().unwrap();
+
+    println!("body = {:?}", body);
+}