Adding support for email identity

tee-worker/enclave-runtime/src/rpc/common_api.rs

@@ -29,7 +29,7 @@ use itp_utils::{FromHexPrefixed, ToHexPrefixed};
 use its_rpc_handler::direct_top_pool_api::add_top_pool_direct_rpc_methods;
 use jsonrpc_core::{serde_json::json, IoHandler, Params, Value};
 use lc_data_providers::DataProviderConfig;
-use lc_identity_verification::web2::twitter;
+use lc_identity_verification::web2::{email, twitter};
 use litentry_macros::{if_development, if_development_or};
 use litentry_primitives::{aes_decrypt, AesRequest, DecryptableRequest, Identity};
 use log::debug;
@@ -418,6 +418,8 @@ pub fn add_common_api<Author, GetterExecutor, AccessShieldingKey, OcallApi, Stat
 		Ok(Value::String(format!("hello, {}", parsed)))
 	});
 
+	let twitter_client_id = data_provider_config.twitter_client_id.clone();
+
 	io_handler.add_sync_method("identity_getTwitterAuthorizeUrl", move |params: Params| {
 		debug!("worker_api_direct rpc was called: identity_getTwitterAuthorizeUrl");
 
@@ -435,10 +437,7 @@ pub fn add_common_api<Author, GetterExecutor, AccessShieldingKey, OcallApi, Stat
 							"Could not parse identity"
 						))),
 				};
-				let authorize_data = twitter::get_authorize_data(
-					&data_provider_config.twitter_client_id,
-					&redirect_url,
-				);
+				let authorize_data = twitter::get_authorize_data(&twitter_client_id, &redirect_url);
 				match twitter::OAuthStore::save_data(
 					account_id,
 					authorize_data.code_verifier,
@@ -460,6 +459,50 @@ pub fn add_common_api<Author, GetterExecutor, AccessShieldingKey, OcallApi, Stat
 			Err(_) => Ok(json!(compute_hex_encoded_return_error("Could not parse params"))),
 		}
 	});
+
+	io_handler.add_sync_method("identity_requestEmailVerification", move |params: Params| {
+		match params.parse::<(String, String)>() {
+			Ok((encoded_did, email)) => {
+				let account_id = match Identity::from_did(encoded_did.as_str()) {
+					Ok(identity) =>
+						if let Some(account_id) = identity.to_account_id() {
+							account_id
+						} else {
+							return Ok(json!(compute_hex_encoded_return_error("Invalid identity")))
+						},
+					Err(_) =>
+						return Ok(json!(compute_hex_encoded_return_error(
+							"Could not parse identity"
+						))),
+				};
+				let mut mailer = email::sendgrid_mailer::SendGridMailer::new(
+					data_provider_config.sendgrid_api_key.clone(),
+					data_provider_config.sendgrid_from_email.clone(),
+				);
+				let verification_code = email::generate_verification_code();
+
+				match email::VerificationCodeStore::insert(account_id, verification_code.clone()) {
+					Ok(_) => {
+						if let Err(_) =
+							email::send_verification_email(&mut mailer, email, verification_code)
+						{
+							return Ok(json!(compute_hex_encoded_return_error(
+								"Could not send verification email"
+							)))
+						}
+						let json_value =
+							RpcReturnValue::new(vec![], false, DirectRequestStatus::Ok);
+						Ok(json!(json_value.to_hex()))
+					},
+					Err(_) =>
+						return Ok(json!(compute_hex_encoded_return_error(
+							"Could not save verification code"
+						))),
+				}
+			},
+			Err(_) => Ok(json!(compute_hex_encoded_return_error("Could not parse params"))),
+		}
+	});
 }
 
 #[deprecated(note = "`state_executeAesGetter` should be preferred")]