add graphql data provider for data query

pallets/vc-management/src/assertion.rs

@@ -32,14 +32,13 @@ pub enum Assertion {
 	A1,
 	A2(ParameterString, ParameterString), // (guild_id, user_id)
 	A3(ParameterString, ParameterString), // (guild_id, user_id)
-	A4,
+	A4(Balance, ParameterString),         // (LIT_amount, timestamp, e.g.: 2022-10-16T00:00:00Z)
 	A5(ParameterString, ParameterString), // (twitter_account, tweet_id)
 	A6,
 	A7(Balance, u32), // (DOT_amount, year)
 	A8(u64),          // (tx_amount)
 	A9,
 	A10(Balance, u32), // (WBTC_amount, year)
 	A11(Balance, u32), // (ETH_amount, year)
-	A12(Balance, u32), // (LIT_amount, year)
 	A13(u32),          // (Karma_amount) - TODO: unsupported
 }

tee-worker/litentry/core/assertion-build/src/a3.rs

@@ -30,7 +30,7 @@ pub fn build(guild_id: ParameterString, handler: ParameterString) -> Result<()>
 	let mut client = DiscordLitentryClient::new();
 	match client.check_id_hubber(guild_id.into_inner(), handler.into_inner()) {
 		Err(e) => {
-			log::error!("error build assertion2: {:?}", e);
+			log::error!("error build assertion3: {:?}", e);
 			Err(Error::Assertion3Error(format!("{:?}", e)))
 		},
 		Ok(_response) => {

tee-worker/litentry/core/assertion-build/src/a4.rs

@@ -0,0 +1,99 @@
+// Copyright 2020-2022 Litentry Technologies GmbH.
+// This file is part of Litentry.
+//
+// Litentry is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// Litentry is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU General Public License for more details.
+//
+// You should have received a copy of the GNU General Public License
+// along with Litentry.  If not, see <https://www.gnu.org/licenses/>.
+
+#[cfg(all(feature = "std", feature = "sgx"))]
+compile_error!("feature \"std\" and feature \"sgx\" cannot be enabled at the same time");
+
+#[cfg(all(not(feature = "std"), feature = "sgx"))]
+extern crate sgx_tstd as std;
+
+use crate::{Error, Result};
+use std::{
+	str::from_utf8,
+	string::{String, ToString},
+	vec,
+	vec::Vec,
+};
+
+use lc_stf_task_sender::MaxIdentityLength;
+use litentry_primitives::{
+	EvmNetwork, Identity, IdentityHandle, IdentityWebType, SubstrateNetwork, Web3Network,
+};
+use sp_runtime::BoundedVec;
+
+use lc_data_providers::graphql::{
+	GraphQLClient, VerifiedCredentialsIsHodlerIn, VerifiedCredentialsNetwork,
+};
+
+// ERC20 LIT token address
+const LIT_TOKEN_ADDRESS: &str = "0xb59490aB09A0f526Cc7305822aC65f2Ab12f9723";
+
+pub fn build(
+	identities: BoundedVec<Identity, MaxIdentityLength>,
+	from_date: String,
+	min_balance: f64,
+) -> Result<()> {
+	let mut client = GraphQLClient::new();
+
+	for identity in identities {
+		let mut network = VerifiedCredentialsNetwork::Polkadot;
+		if let IdentityWebType::Web3(web3_type) = identity.web_type {
+			match web3_type {
+				Web3Network::Substrate(SubstrateNetwork::Litentry) =>
+					network = VerifiedCredentialsNetwork::Litentry,
+				Web3Network::Substrate(SubstrateNetwork::Litmus) =>
+					network = VerifiedCredentialsNetwork::Litmus,
+				Web3Network::Evm(EvmNetwork::Ethereum) =>
+					network = VerifiedCredentialsNetwork::Ethereum,
+				_ => (),
+			}
+		};
+
+		if network == VerifiedCredentialsNetwork::Litentry
+			|| network == VerifiedCredentialsNetwork::Litmus
+			|| network == VerifiedCredentialsNetwork::Ethereum
+		{
+			let mut addresses: Vec<String> = vec![];
+			match identity.handle {
+				IdentityHandle::Address20(addr) =>
+					addresses.push(from_utf8(&addr).unwrap().to_string()),
+				IdentityHandle::Address32(addr) =>
+					addresses.push(from_utf8(&addr).unwrap().to_string()),
+				IdentityHandle::String(addr) =>
+					addresses.push(from_utf8(&addr).unwrap().to_string()),
+			}
+			let mut tmp_token_addr = String::from("");
+			if network == VerifiedCredentialsNetwork::Ethereum {
+				tmp_token_addr = LIT_TOKEN_ADDRESS.to_string();
+			}
+			let credentials = VerifiedCredentialsIsHodlerIn {
+				addresses,
+				from_date: from_date.clone(),
+				network,
+				token_address: tmp_token_addr,
+				min_balance,
+			};
+			let is_hodler_out = client.check_verified_credentials_is_hodler(credentials);
+			if let Ok(_hodler_out) = is_hodler_out {
+				// TODO: generate VC
+
+				return Ok(())
+			}
+		}
+	}
+
+	Err(Error::Assertion4Error("no valid response".to_string()))
+}

tee-worker/litentry/core/assertion-build/src/a7.rs

@@ -0,0 +1,78 @@
+// Copyright 2020-2022 Litentry Technologies GmbH.
+// This file is part of Litentry.
+//
+// Litentry is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// Litentry is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU General Public License for more details.
+//
+// You should have received a copy of the GNU General Public License
+// along with Litentry.  If not, see <https://www.gnu.org/licenses/>.
+
+#[cfg(all(feature = "std", feature = "sgx"))]
+compile_error!("feature \"std\" and feature \"sgx\" cannot be enabled at the same time");
+
+#[cfg(all(not(feature = "std"), feature = "sgx"))]
+extern crate sgx_tstd as std;
+
+use crate::{Error, Result};
+use std::{
+	str::from_utf8,
+	string::{String, ToString},
+	vec,
+	vec::Vec,
+};
+
+use lc_stf_task_sender::MaxIdentityLength;
+use litentry_primitives::{
+	Identity, IdentityHandle, IdentityWebType, SubstrateNetwork, Web3Network,
+};
+use sp_runtime::BoundedVec;
+
+use lc_data_providers::graphql::{
+	GraphQLClient, VerifiedCredentialsIsHodlerIn, VerifiedCredentialsNetwork,
+};
+
+pub fn build(
+	identities: BoundedVec<Identity, MaxIdentityLength>,
+	from_date: String,
+	min_balance: f64,
+) -> Result<()> {
+	let mut client = GraphQLClient::new();
+
+	for identity in identities {
+		if let IdentityWebType::Web3(Web3Network::Substrate(SubstrateNetwork::Polkadot)) =
+			identity.web_type
+		{
+			let mut addresses: Vec<String> = vec![];
+			match identity.handle {
+				IdentityHandle::Address20(addr) =>
+					addresses.push(from_utf8(&addr).unwrap().to_string()),
+				IdentityHandle::Address32(addr) =>
+					addresses.push(from_utf8(&addr).unwrap().to_string()),
+				IdentityHandle::String(addr) =>
+					addresses.push(from_utf8(&addr).unwrap().to_string()),
+			}
+			let credentials = VerifiedCredentialsIsHodlerIn {
+				addresses,
+				from_date: from_date.clone(),
+				network: VerifiedCredentialsNetwork::Polkadot,
+				token_address: String::from(""),
+				min_balance,
+			};
+			let is_hodler_out = client.check_verified_credentials_is_hodler(credentials);
+			if let Ok(_hodler_out) = is_hodler_out {
+				// TODO: generate VC
+
+				return Ok(())
+			}
+		}
+	}
+
+	Err(Error::Assertion7Error("no valid response".to_string()))
+}

tee-worker/litentry/core/assertion-build/src/lib.rs

@@ -37,8 +37,10 @@ use std::{fmt::Debug, string::String};
 pub mod a1;
 pub mod a2;
 pub mod a3;
+pub mod a4;
 pub mod a5;
 pub mod a6;
+pub mod a7;
 
 pub type Result<T> = core::result::Result<T, Error>;
 
@@ -53,9 +55,15 @@ pub enum Error {
 	#[error("Assertion3 error: {0}")]
 	Assertion3Error(String),
 
+	#[error("Assertion4 error: {0}")]
+	Assertion4Error(String),
+
 	#[error("Assertion5 error: {0}")]
 	Assertion5Error(String),
 
+	#[error("Assertion7 error: {0}")]
+	Assertion7Error(String),
+
 	#[error("Other error: {0}")]
 	AssertionOtherError(String),
 }

tee-worker/litentry/core/data-providers/Cargo.toml

@@ -37,7 +37,7 @@ litentry-primitives = { path = "../../primitives", default-features = false }
 httpmock = "0.6"
 lc-mock-server = { path = "../mock-server" }
 sp-core = { git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.32", default-features = false }
-
+chrono = { version = "0.4.23" }
 
 [features]
 default = ["std"]