rough implementations

mm2src/kdf_walletconnect/Cargo.toml

@@ -7,6 +7,7 @@ edition = "2021"
 
 [dependencies]
 # chacha20poly1305 = "0.10"
+chrono = { version = "0.4.23", "features" = ["serde"] }
 common = { path = "../common" }
 derive_more = "0.99"
 futures = { version = "0.3", package = "futures", features = [

mm2src/kdf_walletconnect/src/error.rs

@@ -1,26 +1,38 @@
 use derive_more::Display;
 use pairing_api::PairingClientError;
 use relay_client::error::{ClientError, Error};
-use relay_rpc::rpc::PublishError;
+use relay_rpc::rpc::{PublishError, SubscriptionError};
 use serde::{Deserialize, Serialize};
 
 #[derive(Debug, Display, Serialize, Deserialize)]
-pub enum WalletConnectClientError {
+pub enum WalletConnectCtxError {
     PairingError(String),
     EncodeError(String),
     PublishError(String),
     ClientError(String),
     PairingNotFound(String),
+    SubscriptionError(String),
+    InternalError(String),
+    SerdeError(String),
+    UnsuccessfulResponse(String)
 }
 
-impl From<PairingClientError> for WalletConnectClientError {
-    fn from(error: PairingClientError) -> Self { WalletConnectClientError::PairingError(error.to_string()) }
+impl From<PairingClientError> for WalletConnectCtxError {
+    fn from(error: PairingClientError) -> Self { WalletConnectCtxError::PairingError(error.to_string()) }
 }
 
-impl From<ClientError> for WalletConnectClientError {
-    fn from(error: ClientError) -> Self { WalletConnectClientError::ClientError(error.to_string()) }
+impl From<ClientError> for WalletConnectCtxError {
+    fn from(error: ClientError) -> Self { WalletConnectCtxError::ClientError(error.to_string()) }
 }
 
-impl From<Error<PublishError>> for WalletConnectClientError {
-    fn from(error: Error<PublishError>) -> Self { WalletConnectClientError::PublishError(format!("{error:?}")) }
+impl From<Error<PublishError>> for WalletConnectCtxError {
+    fn from(error: Error<PublishError>) -> Self { WalletConnectCtxError::PublishError(format!("{error:?}")) }
+}
+
+impl From<Error<SubscriptionError>> for WalletConnectCtxError {
+    fn from(error: Error<SubscriptionError>) -> Self { WalletConnectCtxError::SubscriptionError(format!("{error:?}")) }
+}
+
+impl From<serde_json::Error> for WalletConnectCtxError {
+    fn from(value: serde_json::Error) -> Self { WalletConnectCtxError::SerdeError(value.to_string()) }
 }

mm2src/kdf_walletconnect/src/handler.rs

@@ -1,11 +1,7 @@
-use std::time::Duration;
-
 use common::log::info;
 use futures::channel::mpsc::UnboundedSender;
 use relay_client::{error::ClientError,
-                   websocket::{CloseFrame, ConnectionHandler, PublishedMessage},
-                   ConnectionOptions};
-use relay_rpc::auth::{ed25519_dalek::SigningKey, AuthToken};
+                   websocket::{CloseFrame, ConnectionHandler, PublishedMessage}};
 
 pub struct Handler {
     name: &'static str,
@@ -44,15 +40,3 @@ impl ConnectionHandler for Handler {
         info!("\n[{}] outbound error: {error}", self.name);
     }
 }
-
-fn create_conn_opts(relay_address: &str, project_id: &str) -> ConnectionOptions {
-    let key = SigningKey::generate(&mut rand::thread_rng());
-
-    let auth = AuthToken::new("https://komodefi.com")
-        .aud(relay_address)
-        .ttl(Duration::from_secs(60 * 60))
-        .as_jwt(&key)
-        .unwrap();
-
-    ConnectionOptions::new(project_id, auth).with_address(relay_address)
-}