From 60a64a3bbe532205202e27fc3c391ad038d40577 Mon Sep 17 00:00:00 2001 From: boneyard93501 <4523011+boneyard93501@users.noreply.github.com> Date: Mon, 8 Mar 2021 11:49:48 -0600 Subject: [PATCH] rename ethqlite --- multi-service/air-scripts/block_tripper.clj | 53 --- multi-service/ethqlite/Cargo.lock | 416 ++++++++++++++++++ multi-service/{sqlite => ethqlite}/Cargo.toml | 9 +- .../{sqlite => ethqlite}/Config.toml | 0 multi-service/{sqlite => ethqlite}/build.sh | 0 .../ethqlite_cfg.json} | 0 .../{sqlite => ethqlite}/sqlite3_cfg.json | 0 multi-service/ethqlite/src/auth.rs | 32 ++ multi-service/ethqlite/src/crud.rs | 212 +++++++++ multi-service/ethqlite/src/main.rs | 123 ++++++ .../src/main.rs => ethqlite/src/main.rs.bk2} | 0 multi-service/ethqlite/src/paywall.rs | 63 +++ multi-service/sqlite/Cargo.lock | 241 ---------- 13 files changed, 851 insertions(+), 298 deletions(-) delete mode 100644 multi-service/air-scripts/block_tripper.clj create mode 100644 multi-service/ethqlite/Cargo.lock rename multi-service/{sqlite => ethqlite}/Cargo.toml (64%) rename multi-service/{sqlite => ethqlite}/Config.toml (100%) rename multi-service/{sqlite => ethqlite}/build.sh (100%) rename multi-service/{sqlite/sqlite_runner_cfg.json => ethqlite/ethqlite_cfg.json} (100%) rename multi-service/{sqlite => ethqlite}/sqlite3_cfg.json (100%) create mode 100644 multi-service/ethqlite/src/auth.rs create mode 100644 multi-service/ethqlite/src/crud.rs create mode 100644 multi-service/ethqlite/src/main.rs rename multi-service/{sqlite/src/main.rs => ethqlite/src/main.rs.bk2} (100%) create mode 100644 multi-service/ethqlite/src/paywall.rs delete mode 100644 multi-service/sqlite/Cargo.lock diff --git a/multi-service/air-scripts/block_tripper.clj b/multi-service/air-scripts/block_tripper.clj deleted file mode 100644 index ba45ac0..0000000 --- a/multi-service/air-scripts/block_tripper.clj +++ /dev/null @@ -1,53 +0,0 @@ -(xor - (seq - (seq - (seq - (seq - (call relay ("op" "identity") []) - (call node_1 (service_1 "get_latest_block") [api_key] hex_block_result) - ) - (seq - (call relay ("op" "identity") []) - (call %init_peer_id% (returnService "run") [hex_block_result]) - ) - ) - (seq - (seq - (call relay ("op" "identity") []) - (call node_2 (service_2 "hex_to_int") [hex_block_result] int_block_result) ; "0xb69e2e" - ; (call node_2 (service_2 "hex_to_int") ["0xb69e2e"] int_block_result) - ) - (seq - (call relay ("op" "identity") []) - (call %init_peer_id% (returnService "run") [int_block_result]) - ) - ) - ) - (seq - (par - (seq - (call relay ("op" "identity") []) - (call node_1 (service_1 "get_block") [api_key int_block_result] block_result) - ) - (seq - (call relay ("op" "identity") []) - (call %init_peer_id% (returnService "run") [block_result]) - ) - ) - (par - (seq - (call relay ("op" "identity") []) - (call node_1 (service_1 "get_block") [api_key int_block_result-1] block_result_1) - ) - (seq - (call relay ("op" "identity") []) - (call %init_peer_id% (returnService "run") [block_result_1]) - ) - ) - ) - ) - (seq - (call relay ("op" "identity") []) - (call %init_peer_id% (returnService "run") ["XOR FAILED" %last_error%]) - ) -) \ No newline at end of file diff --git a/multi-service/ethqlite/Cargo.lock b/multi-service/ethqlite/Cargo.lock new file mode 100644 index 0000000..560f43c --- /dev/null +++ b/multi-service/ethqlite/Cargo.lock @@ -0,0 +1,416 @@ +# This file is automatically @generated by Cargo. +# It is not intended for manual editing. +[[package]] +name = "arrayref" +version = "0.3.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "a4c527152e37cf757a3f78aae5a06fbeefdb07ccc535c980a3208ee3060dd544" + +[[package]] +name = "block-buffer" +version = "0.7.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c0940dc441f31689269e10ac70eb1002a3a1d3ad1390e030043662eb7fe4688b" +dependencies = [ + "block-padding", + "byte-tools", + "byteorder", + "generic-array", +] + +[[package]] +name = "block-padding" +version = "0.1.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "fa79dedbb091f449f1f39e53edf88d5dbe95f895dae6135a8d7b881fb5af73f5" +dependencies = [ + "byte-tools", +] + +[[package]] +name = "byte-tools" +version = "0.3.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e3b5ca7a04898ad4bcd41c90c5285445ff5b791899bb1b0abdd2a2aa791211d7" + +[[package]] +name = "byteorder" +version = "1.4.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ae44d1a3d5a19df61dd0c8beb138458ac2a53a7ac09eba97d55592540004306b" + +[[package]] +name = "cfg-if" +version = "1.0.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "baf1de4339761588bc0619e3cbc0120ee582ebb74b53b4efbf79117bd2da40fd" + +[[package]] +name = "crunchy" +version = "0.2.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "7a81dae078cea95a014a339291cec439d2f232ebe854a9d672b796c6afafa9b7" + +[[package]] +name = "crypto-mac" +version = "0.7.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "4434400df11d95d556bac068ddfedd482915eb18fe8bea89bc80b6e4b1c179e5" +dependencies = [ + "generic-array", + "subtle 1.0.0", +] + +[[package]] +name = "digest" +version = "0.8.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f3d0c8c8752312f9713efd397ff63acb9f85585afbf179282e720e7704954dd5" +dependencies = [ + "generic-array", +] + +[[package]] +name = "fake-simd" +version = "0.1.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e88a8acf291dafb59c2d96e8f59828f3838bb1a70398823ade51a84de6a6deed" + +[[package]] +name = "fce-sqlite-connector" +version = "0.2.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c02ba19dff7f195418416b249423384761a964447dc40e7427f448687ac60b56" +dependencies = [ + "fluence", +] + +[[package]] +name = "fluence" +version = "0.4.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "31068fe4873478f9c59f01230dc6f23d504d8c11a36d6b6c51693b20c6d2570e" +dependencies = [ + "fluence-sdk-macro", + "fluence-sdk-main", +] + +[[package]] +name = "fluence-sdk-macro" +version = "0.4.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "76ce80dc2d7c3db828fb31b95e75c372fde7a9a25dfa2b0d9beac07379b890a6" +dependencies = [ + "fluence-sdk-wit", +] + +[[package]] +name = "fluence-sdk-main" +version = "0.4.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "29cce53288e08ed86ebe36c64d8eb641a95e1d0f7f75da969b29e16ab0d7d406" +dependencies = [ + "fluence-sdk-macro", + "log", + "serde", +] + +[[package]] +name = "fluence-sdk-wit" +version = "0.4.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "56d835812bab8fb6f261b9e37355b9bf0a28a16123580145ce0fe44ef4363144" +dependencies = [ + "proc-macro2", + "quote", + "serde", + "serde_json", + "syn", + "uuid", +] + +[[package]] +name = "generic-array" +version = "0.12.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ffdf9f34f1447443d37393cc6c2b8313aebddcd96906caf34e54c68d8e57d7bd" +dependencies = [ + "typenum", +] + +[[package]] +name = "getrandom" +version = "0.1.16" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "8fc3cb4d91f53b50155bdcfd23f6a4c39ae1969c2ae85982b135750cccaf5fce" +dependencies = [ + "cfg-if", + "libc", + "wasi 0.9.0+wasi-snapshot-preview1", +] + +[[package]] +name = "getrandom" +version = "0.2.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c9495705279e7140bf035dde1f6e750c162df8b625267cd52cc44e0b156732c8" +dependencies = [ + "cfg-if", + "libc", + "wasi 0.10.2+wasi-snapshot-preview1", +] + +[[package]] +name = "hmac" +version = "0.7.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "5dcb5e64cda4c23119ab41ba960d1e170a774c8e4b9d9e6a9bc18aabf5e59695" +dependencies = [ + "crypto-mac", + "digest", +] + +[[package]] +name = "hmac-drbg" +version = "0.2.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c6e570451493f10f6581b48cdd530413b63ea9e780f544bfd3bdcaa0d89d1a7b" +dependencies = [ + "digest", + "generic-array", + "hmac", +] + +[[package]] +name = "itoa" +version = "0.4.7" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "dd25036021b0de88a0aff6b850051563c6516d0bf53f8638938edbb9de732736" + +[[package]] +name = "libc" +version = "0.2.87" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "265d751d31d6780a3f956bb5b8022feba2d94eeee5a84ba64f4212eedca42213" + +[[package]] +name = "libsecp256k1" +version = "0.3.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "1fc1e2c808481a63dc6da2074752fdd4336a3c8fcc68b83db6f1fd5224ae7962" +dependencies = [ + "arrayref", + "crunchy", + "digest", + "hmac-drbg", + "rand", + "sha2", + "subtle 2.4.0", + "typenum", +] + +[[package]] +name = "log" +version = "0.4.14" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "51b9bbe6c47d51fc3e1a9b945965946b4c44142ab8792c50835a980d362c2710" +dependencies = [ + "cfg-if", +] + +[[package]] +name = "once_cell" +version = "1.7.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "af8b08b04175473088b46763e51ee54da5f9a164bc162f615b91bc179dbf15a3" + +[[package]] +name = "opaque-debug" +version = "0.2.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "2839e79665f131bdb5782e51f2c6c9599c133c6098982a54c794358bf432529c" + +[[package]] +name = "ppv-lite86" +version = "0.2.10" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ac74c624d6b2d21f425f752262f42188365d7b8ff1aff74c82e45136510a4857" + +[[package]] +name = "proc-macro2" +version = "1.0.24" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "1e0704ee1a7e00d7bb417d0770ea303c1bccbabf0ef1667dae92b5967f5f8a71" +dependencies = [ + "unicode-xid", +] + +[[package]] +name = "quote" +version = "1.0.9" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c3d0b9745dc2debf507c8422de05d7226cc1f0644216dfdfead988f9b1ab32a7" +dependencies = [ + "proc-macro2", +] + +[[package]] +name = "rand" +version = "0.7.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "6a6b1679d49b24bbfe0c803429aa1874472f50d9b363131f0e89fc356b544d03" +dependencies = [ + "getrandom 0.1.16", + "libc", + "rand_chacha", + "rand_core", + "rand_hc", +] + +[[package]] +name = "rand_chacha" +version = "0.2.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f4c8ed856279c9737206bf725bf36935d8666ead7aa69b52be55af369d193402" +dependencies = [ + "ppv-lite86", + "rand_core", +] + +[[package]] +name = "rand_core" +version = "0.5.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "90bde5296fc891b0cef12a6d03ddccc162ce7b2aff54160af9338f8d40df6d19" +dependencies = [ + "getrandom 0.1.16", +] + +[[package]] +name = "rand_hc" +version = "0.2.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ca3129af7b92a17112d59ad498c6f81eaf463253766b90396d39ea7a39d6613c" +dependencies = [ + "rand_core", +] + +[[package]] +name = "ryu" +version = "1.0.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "71d301d4193d031abdd79ff7e3dd721168a9572ef3fe51a1517aba235bd8f86e" + +[[package]] +name = "serde" +version = "1.0.118" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "06c64263859d87aa2eb554587e2d23183398d617427327cf2b3d0ed8c69e4800" +dependencies = [ + "serde_derive", +] + +[[package]] +name = "serde_derive" +version = "1.0.118" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c84d3526699cd55261af4b941e4e725444df67aa4f9e6a3564f18030d12672df" +dependencies = [ + "proc-macro2", + "quote", + "syn", +] + +[[package]] +name = "serde_json" +version = "1.0.64" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "799e97dc9fdae36a5c8b8f2cae9ce2ee9fdce2058c57a93e6099d919fd982f79" +dependencies = [ + "itoa", + "ryu", + "serde", +] + +[[package]] +name = "sha2" +version = "0.8.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "a256f46ea78a0c0d9ff00077504903ac881a1dafdc20da66545699e7776b3e69" +dependencies = [ + "block-buffer", + "digest", + "fake-simd", + "opaque-debug", +] + +[[package]] +name = "sqlite-runner" +version = "0.1.0" +dependencies = [ + "fce-sqlite-connector", + "fluence", + "libsecp256k1", + "log", + "once_cell", + "serde", + "serde_json", + "uuid", +] + +[[package]] +name = "subtle" +version = "1.0.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "2d67a5a62ba6e01cb2192ff309324cb4875d0c451d55fe2319433abe7a05a8ee" + +[[package]] +name = "subtle" +version = "2.4.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "1e81da0851ada1f3e9d4312c704aa4f8806f0f9d69faaf8df2f3464b4a9437c2" + +[[package]] +name = "syn" +version = "1.0.60" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c700597eca8a5a762beb35753ef6b94df201c81cca676604f547495a0d7f0081" +dependencies = [ + "proc-macro2", + "quote", + "unicode-xid", +] + +[[package]] +name = "typenum" +version = "1.12.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "373c8a200f9e67a0c95e62a4f52fbf80c23b4381c05a17845531982fa99e6b33" + +[[package]] +name = "unicode-xid" +version = "0.2.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f7fe0bb3479651439c9112f72b6c505038574c9fbb575ed1bf3b797fa39dd564" + +[[package]] +name = "uuid" +version = "0.8.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "bc5cf98d8186244414c848017f0e2676b3fcb46807f6668a97dfe67359a3c4b7" +dependencies = [ + "getrandom 0.2.2", + "serde", +] + +[[package]] +name = "wasi" +version = "0.9.0+wasi-snapshot-preview1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "cccddf32554fecc6acb585f82a32a72e28b48f8c4c1883ddfeeeaa96f7d8e519" + +[[package]] +name = "wasi" +version = "0.10.2+wasi-snapshot-preview1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "fd6fbd9a79829dd1ad0cc20627bf1ed606756a7f77edff7b66b7064f9cb327c6" diff --git a/multi-service/sqlite/Cargo.toml b/multi-service/ethqlite/Cargo.toml similarity index 64% rename from multi-service/sqlite/Cargo.toml rename to multi-service/ethqlite/Cargo.toml index dd313df..d4f9d63 100644 --- a/multi-service/sqlite/Cargo.toml +++ b/multi-service/ethqlite/Cargo.toml @@ -1,18 +1,19 @@ [package] -name = "sqlite-runner" +name = "ethqlite" version = "0.1.0" authors = ["boneyard93501 <4523011+boneyard93501@users.noreply.github.com>"] edition = "2018" [[bin]] -name = "sqlite_runner" +name = "ethqlite" path = "src/main.rs" [dependencies] -fluence = { version="0.3.3", features = ["logger"]} +fluence = { version="0.4.2", features = ["logger"]} log = "0.4.8" fce-sqlite-connector = "=0.2.0" serde = {version = "1.0.118", features=["derive"]} serde_json = "1.0.64" once_cell = "1.4.1" -uuid = { version = "0.8.2", features = ["serde", "v4"] } \ No newline at end of file +uuid = { version = "0.8.2", features = ["serde", "v4"] } +libsecp256k1 = "0.3.5" \ No newline at end of file diff --git a/multi-service/sqlite/Config.toml b/multi-service/ethqlite/Config.toml similarity index 100% rename from multi-service/sqlite/Config.toml rename to multi-service/ethqlite/Config.toml diff --git a/multi-service/sqlite/build.sh b/multi-service/ethqlite/build.sh similarity index 100% rename from multi-service/sqlite/build.sh rename to multi-service/ethqlite/build.sh diff --git a/multi-service/sqlite/sqlite_runner_cfg.json b/multi-service/ethqlite/ethqlite_cfg.json similarity index 100% rename from multi-service/sqlite/sqlite_runner_cfg.json rename to multi-service/ethqlite/ethqlite_cfg.json diff --git a/multi-service/sqlite/sqlite3_cfg.json b/multi-service/ethqlite/sqlite3_cfg.json similarity index 100% rename from multi-service/sqlite/sqlite3_cfg.json rename to multi-service/ethqlite/sqlite3_cfg.json diff --git a/multi-service/ethqlite/src/auth.rs b/multi-service/ethqlite/src/auth.rs new file mode 100644 index 0000000..eb5c4e6 --- /dev/null +++ b/multi-service/ethqlite/src/auth.rs @@ -0,0 +1,32 @@ +/* + * Copyright 2021 Fluence Labs Limited + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +use fluence::{fce, CallParameters}; +use::fluence; +use crate::get_connection; + +pub fn is_owner() -> bool { + let meta = fluence::get_call_parameters(); + let caller = meta.init_peer_id; + let owner = meta.service_creator_peer_id; + + caller == owner +} + +#[fce] +pub fn am_i_owner() -> bool { + is_owner() +} \ No newline at end of file diff --git a/multi-service/ethqlite/src/crud.rs b/multi-service/ethqlite/src/crud.rs new file mode 100644 index 0000000..5426074 --- /dev/null +++ b/multi-service/ethqlite/src/crud.rs @@ -0,0 +1,212 @@ +/* + * Copyright 2021 Fluence Labs Limited + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +use crate::*; +use fluence::fce; +use fce_sqlite_connector; +use fce_sqlite_connector::{Connection, State, Value}; + + +fn create_table(conn: &Connection) -> std::result::Result<(), fce_sqlite_connector::Error> { + + let res = conn.execute( + " + create table if not exists reward_blocks ( + block_number integer not null primary key, + timestamp integer not null, + block_miner text not null, + block_reward integer not null + ); + + create table if not exists payments ( + tx_number text not null primary key, + chain_id integer not null, + timestamp integer not null, + balance integer not null, + unit text not null, + available integer not null, + unique(chain_id, tx_number) + ); + + create table if not exists costs ( + chain_id integer not null primary key, + query_cost integer not null, + cost_unit string not null , + currency string not null + ); + + insert or ignore into costs values(42, 10, 'gwei', 'eth'); + + create table if not exists security ( + peer_id Text not null, + service_id Text not null primary key, + fn_name Text not null, + json_path Text not null + ); + ", + ); + res +} + +#[fce] +pub fn update_reward_blocks(data_string: String) -> bool { + if !is_owner() { + return false; + } + + let obj:serde_json::Value = serde_json::from_str(&data_string).unwrap(); + let obj = obj["result"].clone(); + + let conn = fce_sqlite_connector::open(DB_PATH).unwrap(); + + let insert = "insert or ignore into reward_blocks values(?, ?, ?, ?)"; + let mut ins_cur = conn.prepare(insert).unwrap().cursor(); + + + let insert = ins_cur.bind( + &[Value::Integer(i64::from_str_radix(obj["blockNumber"].as_str().unwrap(), 10).unwrap()), + Value::Integer(i64::from_str_radix(obj["timeStamp"].as_str().unwrap(), 10).unwrap()), + Value::String(obj["blockMiner"].to_string()), + Value::Integer(i64::from_str_radix(obj["blockReward"].clone().as_str().unwrap(), 10).unwrap()), + ] + ); + + if insert.is_ok() { + ins_cur.next().unwrap(); + let mut select = conn.prepare("select * from reward_blocks").unwrap().cursor(); + while let Some(row) = select.next().unwrap() { + println!("select row {:?}", row); + println!("{}, {}", row[0].as_integer().unwrap(), row[2].as_string().unwrap()); + } + return true; + } + + false +} + +#[fce] +#[derive(Debug)] +pub struct RewardBlock { + pub block_number: i64, + pub timestamp: i64, + pub block_miner: String, + pub block_reward: String, +} + +impl RewardBlock { + fn from_row(row: &[Value]) -> Self { + RewardBlock { + block_number: row[0].as_integer().unwrap(), + timestamp: row[1].as_integer().unwrap(), + block_miner: row[2].as_string().unwrap().into(), + block_reward: row[3].as_integer().unwrap().to_string(), + } + } + + fn from_err() -> Self { + RewardBlock { + block_number: -1, + timestamp: -1, + block_miner: String::from(""), + block_reward: String::from(""), + } + } + +} + +#[fce] +pub fn get_latest_reward_block() -> RewardBlock { + // let db_path = "/tmp/db.sqlite"; + let conn = fce_sqlite_connector::open(DB_PATH).unwrap(); + let mut reward_block = RewardBlock::from_err(); + + let select = conn.prepare("select * from reward_blocks order by block_number desc limit 1"); + let result = match select { + Ok(s) => { + let mut select = s.cursor(); + while let Some(row) = select.next().unwrap() { + println!("get_latest_reward_block: {:?}", row); + reward_block = RewardBlock::from_row(row); + }; + return reward_block; + } + Err(e) => reward_block, + }; + result +} + + + +#[fce] +pub fn get_reward_block(block_number: u32) -> RewardBlock { + let conn = fce_sqlite_connector::open(DB_PATH).unwrap(); + + let mut reward_block = RewardBlock::from_err(); + let stmt = "select * from reward_blocks where block_number = ?"; + let select = conn.prepare(stmt); + match select { + Ok(s) => { + let mut select = s.cursor(); + select.bind(&[Value::Integer(block_number as i64)]).unwrap(); + while let Some(row) = select.next().unwrap() { + println!("get_reward_block: {:?}", row); + reward_block = RewardBlock::from_row(row); + }; + return reward_block; + } + Err(e) => reward_block + } +} + +#[fce] +#[derive(Debug)] +pub struct MinerRewards { + pub miner_address: String, + pub rewards: Vec +} +impl MinerRewards { + fn new(miner_address: String) -> Self { + let rewards:Vec = Vec::new(); + + MinerRewards { + miner_address, + rewards + } + } +} + +#[fce] +pub fn get_miner_rewards(miner_address: String) -> MinerRewards { + let conn = fce_sqlite_connector::open(DB_PATH).unwrap(); + + let stmt = "select block_reward from reward_blocks where block_miner = ?"; + let select = conn.prepare(stmt); + let mut miner_rewards = MinerRewards::new(miner_address.clone()); + + match select { + Ok(s) => { + let mut select = s.cursor(); + select.bind(&[Value::String(miner_address)]).unwrap(); + while let Some(row) = select.next().unwrap() { + println!("reward row {:?}", row); + miner_rewards.rewards.push(row[0].as_integer().unwrap().to_string()); + }; + } + Err(e) => log::error!("suck it"), //(format!("{:?}",e)) + }; + + miner_rewards +} diff --git a/multi-service/ethqlite/src/main.rs b/multi-service/ethqlite/src/main.rs new file mode 100644 index 0000000..0d07a66 --- /dev/null +++ b/multi-service/ethqlite/src/main.rs @@ -0,0 +1,123 @@ +/* + * Copyright 2021 Fluence Labs Limited + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +use fluence::fce; ///, WasmLoggerBuilder}; +use fluence; +use fluence::WasmLoggerBuilder; +use fce_sqlite_connector; +use fce_sqlite_connector::{Connection, State, Value}; + +use uuid::Uuid; + +use std::path::{Path, PathBuf}; +use serde::Deserialize; +use serde_json; + + +// const DB_PATH: &str = "/tmp/db_1.sqlite"; +const DB_PATH: &str = "/tmp/fluence_service_db.sqlite"; + + +mod crud; +mod auth; +mod paywall; + + +fn main() { + // WasmLoggerBuilder::new().build().unwrap(); +} + +const KOVAN_ACCT: &str = ""; + +pub enum EthereumChains { + MAINNET = 1, + ROPSTEN = 3, + RINKEBY = 4, + GOERLI = 5, + KOVAN = 42, + +} + +fn get_connection() -> Connection { + Connection::open(DB_PATH).unwrap() +} + + + +#[fce] +pub fn init_service() -> bool { + let conn = fce_sqlite_connector::open(DB_PATH).unwrap(); + let res = create_table(&conn); + match res { + Ok(_) => true, + Err(_) => false, + } +} + + + +pub fn is_owner() -> bool { + let meta = fluence::get_call_parameters(); + let caller = meta.init_peer_id; + let owner = meta.service_creator_peer_id; + + caller == owner +} + + +/* + +#[fce] +fn get_balance(reference_id: String, ) { + let conn = fce_sqlite_connector::open(DB_PATH).unwrap(); + + let stmt = "select balance from payments where block_miner = ?"; + let select = conn.prepare(stmt); + let mut miner_rewards = MinerRewards::new(miner_address.clone()); + +} + +fn update_payments() { + + +} + +#[fce] +pub struct AccountStatus { + +} + +fn check_funding(compute_units: u32) -> bool { + let conn = fce_sqlite_connector::open(DB_PATH).unwrap(); + + + let stmt = "select block_reward from reward_blocks where block_miner = ?"; + let select = conn.prepare(stmt); + let mut miner_rewards = MinerRewards::new(miner_address.clone()); + + match select { + Ok(s) => { + let mut select = s.cursor(); + select.bind(&[Value::String(miner_address)]).unwrap(); + while let Some(row) = select.next().unwrap() { + println!("reward row {:?}", row); + miner_rewards.rewards.push(row[0].as_integer().unwrap().to_string()); + }; + } + Err(e) => log::error!("suck it"), //(format!("{:?}", + +} +*/ \ No newline at end of file diff --git a/multi-service/sqlite/src/main.rs b/multi-service/ethqlite/src/main.rs.bk2 similarity index 100% rename from multi-service/sqlite/src/main.rs rename to multi-service/ethqlite/src/main.rs.bk2 diff --git a/multi-service/ethqlite/src/paywall.rs b/multi-service/ethqlite/src/paywall.rs new file mode 100644 index 0000000..003f8fd --- /dev/null +++ b/multi-service/ethqlite/src/paywall.rs @@ -0,0 +1,63 @@ +/* + * Copyright 2021 Fluence Labs Limited + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +use uuid::Uuid; + +use crate::get_connection; + + +pub fn sig_check(pub_key: &[u8], message: &[u8], signature: &[u8]) -> bool { + pk = PublicKey::from_bytes(pub_key); + + pk.verify(message, signature) +} + + +// pub fn query(user_id: String, signature: bytes) +pub struct DepositResult { + success: bool, + balance: String, + err_msg: String, +} + +impl DepositResult { + fn success(balance: String) -> Self { + DepositResult { + success: true, + balance, + err_msg: String::from(""), + } + } + + fn failure(err_msg: String, balance: String) -> Self { + DepositResult { + success: false, + balance, + err_msg, + } + } +} + +pub fn deposit(user_id:String, tx_id: String, chain_id: u32, pub_key: &[u8], signature: &[u8]) -> DepositResult { + let mut user_id:String = user_id; + if user_id.len() == 0 { + user_id = uuid:Uuid(); + } + + let stmt = "insert into table ??? where user_id = ? on conflict (user_id) do update set balance += ?"; + +} + diff --git a/multi-service/sqlite/Cargo.lock b/multi-service/sqlite/Cargo.lock deleted file mode 100644 index 850e080..0000000 --- a/multi-service/sqlite/Cargo.lock +++ /dev/null @@ -1,241 +0,0 @@ -# This file is automatically @generated by Cargo. -# It is not intended for manual editing. -[[package]] -name = "cfg-if" -version = "1.0.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "baf1de4339761588bc0619e3cbc0120ee582ebb74b53b4efbf79117bd2da40fd" - -[[package]] -name = "fce-sqlite-connector" -version = "0.2.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "c02ba19dff7f195418416b249423384761a964447dc40e7427f448687ac60b56" -dependencies = [ - "fluence 0.4.2", -] - -[[package]] -name = "fluence" -version = "0.3.3" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "84c621ecf5ba628a3a66c4571cb63b9e57de5b8e1ffbb4636873349d04ed9c4c" -dependencies = [ - "fluence-sdk-macro 0.3.3", - "fluence-sdk-main 0.3.3", -] - -[[package]] -name = "fluence" -version = "0.4.2" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "31068fe4873478f9c59f01230dc6f23d504d8c11a36d6b6c51693b20c6d2570e" -dependencies = [ - "fluence-sdk-macro 0.4.2", - "fluence-sdk-main 0.4.2", -] - -[[package]] -name = "fluence-sdk-macro" -version = "0.3.3" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "d3ed152de2a9f59c5494a5ead9d85b40cc1588696d10bb69129addebf0239efb" -dependencies = [ - "fluence-sdk-wit 0.3.3", -] - -[[package]] -name = "fluence-sdk-macro" -version = "0.4.2" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "76ce80dc2d7c3db828fb31b95e75c372fde7a9a25dfa2b0d9beac07379b890a6" -dependencies = [ - "fluence-sdk-wit 0.4.2", -] - -[[package]] -name = "fluence-sdk-main" -version = "0.3.3" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "5ed74c32aded592c2a4c2d11a4586369e2d9f793e6c7b500a2a22f4a61769784" -dependencies = [ - "fluence-sdk-macro 0.3.3", - "log", - "serde", -] - -[[package]] -name = "fluence-sdk-main" -version = "0.4.2" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "29cce53288e08ed86ebe36c64d8eb641a95e1d0f7f75da969b29e16ab0d7d406" -dependencies = [ - "fluence-sdk-macro 0.4.2", - "log", - "serde", -] - -[[package]] -name = "fluence-sdk-wit" -version = "0.3.3" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "a65bb11a2ebb063b8809e43c1837d32e44c12ba3c281e55f2fcf5c5819a6a9ad" -dependencies = [ - "proc-macro2", - "quote", - "serde", - "serde_json", - "syn", - "uuid", -] - -[[package]] -name = "fluence-sdk-wit" -version = "0.4.2" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "56d835812bab8fb6f261b9e37355b9bf0a28a16123580145ce0fe44ef4363144" -dependencies = [ - "proc-macro2", - "quote", - "serde", - "serde_json", - "syn", - "uuid", -] - -[[package]] -name = "getrandom" -version = "0.2.2" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "c9495705279e7140bf035dde1f6e750c162df8b625267cd52cc44e0b156732c8" -dependencies = [ - "cfg-if", - "libc", - "wasi", -] - -[[package]] -name = "itoa" -version = "0.4.7" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "dd25036021b0de88a0aff6b850051563c6516d0bf53f8638938edbb9de732736" - -[[package]] -name = "libc" -version = "0.2.87" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "265d751d31d6780a3f956bb5b8022feba2d94eeee5a84ba64f4212eedca42213" - -[[package]] -name = "log" -version = "0.4.14" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "51b9bbe6c47d51fc3e1a9b945965946b4c44142ab8792c50835a980d362c2710" -dependencies = [ - "cfg-if", -] - -[[package]] -name = "once_cell" -version = "1.7.2" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "af8b08b04175473088b46763e51ee54da5f9a164bc162f615b91bc179dbf15a3" - -[[package]] -name = "proc-macro2" -version = "1.0.24" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "1e0704ee1a7e00d7bb417d0770ea303c1bccbabf0ef1667dae92b5967f5f8a71" -dependencies = [ - "unicode-xid", -] - -[[package]] -name = "quote" -version = "1.0.9" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "c3d0b9745dc2debf507c8422de05d7226cc1f0644216dfdfead988f9b1ab32a7" -dependencies = [ - "proc-macro2", -] - -[[package]] -name = "ryu" -version = "1.0.5" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "71d301d4193d031abdd79ff7e3dd721168a9572ef3fe51a1517aba235bd8f86e" - -[[package]] -name = "serde" -version = "1.0.118" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "06c64263859d87aa2eb554587e2d23183398d617427327cf2b3d0ed8c69e4800" -dependencies = [ - "serde_derive", -] - -[[package]] -name = "serde_derive" -version = "1.0.118" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "c84d3526699cd55261af4b941e4e725444df67aa4f9e6a3564f18030d12672df" -dependencies = [ - "proc-macro2", - "quote", - "syn", -] - -[[package]] -name = "serde_json" -version = "1.0.64" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "799e97dc9fdae36a5c8b8f2cae9ce2ee9fdce2058c57a93e6099d919fd982f79" -dependencies = [ - "itoa", - "ryu", - "serde", -] - -[[package]] -name = "sqlite-runner" -version = "0.1.0" -dependencies = [ - "fce-sqlite-connector", - "fluence 0.3.3", - "log", - "once_cell", - "serde", - "serde_json", -] - -[[package]] -name = "syn" -version = "1.0.60" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "c700597eca8a5a762beb35753ef6b94df201c81cca676604f547495a0d7f0081" -dependencies = [ - "proc-macro2", - "quote", - "unicode-xid", -] - -[[package]] -name = "unicode-xid" -version = "0.2.1" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "f7fe0bb3479651439c9112f72b6c505038574c9fbb575ed1bf3b797fa39dd564" - -[[package]] -name = "uuid" -version = "0.8.2" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "bc5cf98d8186244414c848017f0e2676b3fcb46807f6668a97dfe67359a3c4b7" -dependencies = [ - "getrandom", -] - -[[package]] -name = "wasi" -version = "0.10.2+wasi-snapshot-preview1" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "fd6fbd9a79829dd1ad0cc20627bf1ed606756a7f77edff7b66b7064f9cb327c6"