initial commit

Cargo.toml

@@ -0,0 +1,12 @@
+[package]
+name = "backend_services"
+version = "0.1.0"
+authors = ["josojo <[email protected]>"]
+edition = "2018"
+
+[dependencies]
+mongodb = "0.3.2"
+serde_json = "1.0"
+serde_derive = "1.0"
+serde = "1.0"
+bson = "0.9.1" 

README.md

@@ -0,0 +1,40 @@
+# Running pepper with snarks from this repo
+
+
+## Prerequisits:
+
+(These prerequisits will soon be dockerized)
+
+Install mongodb("0.3.2") and run it using:
+
+```sh
+sudo systemctl start mongodb
+
+``` 
+- do not use any authentification for the database.
+
+
+Install rust & cargo ("1.31") - older versions would not be compatible with newest mongodb drivers.
+
+
+
+## Setup:
+
+In order to load the first data into the data base, run:
+
+
+```sh
+cargo run --bin database_setup
+
+```
+
+## Running the code:
+
+Running 
+
+```sh
+cargo run --bin backend_services
+
+```
+
+will start a listener for the data base and run some c++ executions based on the data.

src/bin/database_setup.rs

@@ -0,0 +1,78 @@
+const ACCOUNTS: i32 = 8;
+const TOKENS: i32 = 4;
+const SIZE_BALANCE: usize = (ACCOUNTS * TOKENS) as usize;
+
+extern crate serde_json;
+extern crate serde;
+
+#[macro_use]
+extern crate serde_derive;
+
+#[derive(Serialize, Deserialize)]
+struct State {
+  	curState: String,
+   	prevState: String,
+  	nextStates: String,
+   	slot: i32,
+   	balances: [i64; SIZE_BALANCE]
+}
+
+extern crate mongodb;
+use mongodb::{bson, doc};
+use mongodb::{Client, ThreadedClient};
+use mongodb::db::ThreadedDatabase;
+
+
+fn main() {
+
+    let client = Client::connect("localhost", 27017)
+        .expect("Failed to initialize standalone client.");
+
+    let coll = client.db("dfusion").collection("CurrentState");
+
+    let doc = doc! {
+        "CurrentState": "0000000000000000000000000000000000000000",
+    };
+
+    // Insert document into 'dfusion.CurrentState' collection
+    coll.insert_one(doc.clone(), None)
+        .ok().expect("Failed to insert CurrentState.");
+
+    let coll = client.db("dfusion").collection("State");
+
+
+	let state = State {
+	    curState: "0000000000000000000000000000000000000000".to_owned(),
+    	prevState: "0000000000000000000000000000000000000000".to_owned(),
+    	nextStates: "0000000000000000000000000000000000000000".to_owned(),
+    	slot: 0,
+    	balances: [0; SIZE_BALANCE]
+	};
+
+    let document = serde_json::to_string(&state).ok().expect("Failed to convert first State");
+
+	println!("{}", document);
+
+    //    let document: String = String::from(r#"{"curState":"0000000000000000000000000000000000000000","prevState":"0000000000000000000000000000000000000000","nextStates":"0000000000000000000000000000000000000000","slot":0,"balances":[0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0]}"#);
+    //	let temp = doc!( r#document#);
+    let temp = doc! {"curState":"0000000000000000000000000000000000000000","prevState":"0000000000000000000000000000000000000000","nextStates":"0000000000000000000000000000000000000000","slot":0,"balances":[0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0]};
+
+	 // Insert document into 'dfusion.CurrentState' collection
+    coll.insert_one(temp.clone(), None)
+        .ok().expect("Failed to insert CurrentState.");
+
+    let coll = client.db("dfusion").collection("Deposits");
+
+    let doc2 = doc! {
+        "depositHash": "0000000000000000000000000000000000000000",
+        "depositIndex": "0000000000000000000000000000000000000000",
+        "slot": 1,
+        "addressIndex": 0,
+        "tokenIndex": 1,
+        "amount": 55465465,
+    };
+
+    // Insert document into 'dfusion.CurrentState' collection
+    coll.insert_one(doc2.clone(), None)
+        .ok().expect("Failed to insert Deposit");    
+}

src/main.rs

@@ -0,0 +1,67 @@
+extern crate serde_json;
+extern crate serde;
+
+
+const ACCOUNTS: i32 = 8;
+const TOKENS: i32 = 4;
+const SIZE_BALANCE: usize = (ACCOUNTS * TOKENS) as usize;
+
+#[macro_use]
+extern crate serde_derive;
+
+#[derive(Serialize, Deserialize)]
+struct State {
+  	curState: String,
+   	prevState: String,
+  	nextStates: String,
+   	slot: i32,
+   	balances: [i64; SIZE_BALANCE]
+}
+/*
+impl State {
+    fn getNextState(&self) -> std::string::String {
+        self.nextStates
+    }
+}*/
+extern crate mongodb;
+use mongodb::{Bson, bson, doc};
+use mongodb::{Client, ThreadedClient};
+use mongodb::db::ThreadedDatabase;
+
+
+fn main() {
+    let client = Client::connect("localhost", 27017)
+        .expect("Failed to initialize standalone client.");
+
+    let coll = client.db("dfusion").collection("CurrentState");
+
+
+    // Find the document and receive a cursor
+    let mut cursor = coll.find(None, None)
+        .ok().expect("Failed to execute find.");
+
+    let item = cursor.next();
+
+    let cur_state; 
+    // cursor.next() returns an Option<Result<Document>>
+    match item {
+        Some(Ok(doc)) => match doc.get("CurrentState") {
+            Some(&Bson::String(ref CurrentState)) => {cur_state = &CurrentState; println!("{}", cur_state)},
+            _ => panic!("Expected title to be a string!"),
+        },
+        Some(Err(_)) => panic!("Failed to get next from server!"),
+        None => panic!("Server returned no results!"),
+    }
+
+    let coll = client.db("dfusion").collection("State");
+
+
+    let cursor = match coll.find(Some(doc! { "curState"	: "0x0000000000000000000000000000000000000000", },) , None) {
+	    Ok(cursor) => cursor,
+	    Err(error) => panic!("The following error occured: {}", error)
+	};
+
+	for doc in cursor {
+	    println!("{}", doc.unwrap());       
+	}
+}