Merge pull request #1928 from oasisprotocol/kostko/feature/rofl-tx-su…

…bmgr

runtime-sdk/modules/rofl: Add transaction submission manager

runtime-sdk/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "oasis-runtime-sdk"
-version = "0.9.1"
+version = "0.9.5"
 authors = ["Oasis Protocol Foundation <[email protected]>"]
 edition = "2021"
 license = "Apache-2.0"
@@ -38,7 +38,7 @@ rand = "0.8.5"
 rand_core = { version = "0.6.4", default-features = false }
 slog = "2.7.0"
 tiny-keccak = { version = "2.0", features = ["tuple_hash"] }
-tokio = { version = "1.38", features = ["rt"] }
+tokio = { version = "1.38", features = ["rt", "rt-multi-thread", "sync", "time", "macros"] }
 tokio-retry = "0.3.0"
 zeroize = "1.8"
 lru = "0.12.3"

runtime-sdk/src/crypto/signature/mod.rs

@@ -406,6 +406,45 @@ pub trait Signer: Send + Sync {
     fn sign_raw(&self, message: &[u8]) -> Result<Signature, Error>;
 }
 
+impl<T: Signer + ?Sized> Signer for std::sync::Arc<T> {
+    fn random(_rng: &mut impl RngCore) -> Result<Self, Error>
+    where
+        Self: Sized,
+    {
+        Err(Error::InvalidArgument)
+    }
+
+    fn new_from_seed(_seed: &[u8]) -> Result<Self, Error>
+    where
+        Self: Sized,
+    {
+        Err(Error::InvalidArgument)
+    }
+
+    fn from_bytes(_bytes: &[u8]) -> Result<Self, Error>
+    where
+        Self: Sized,
+    {
+        Err(Error::InvalidArgument)
+    }
+
+    fn to_bytes(&self) -> Vec<u8> {
+        T::to_bytes(self)
+    }
+
+    fn public_key(&self) -> PublicKey {
+        T::public_key(self)
+    }
+
+    fn sign(&self, context: &[u8], message: &[u8]) -> Result<Signature, Error> {
+        T::sign(self, context, message)
+    }
+
+    fn sign_raw(&self, message: &[u8]) -> Result<Signature, Error> {
+        T::sign_raw(self, message)
+    }
+}
+
 impl<T: CoreSigner> Signer for &T {
     fn random(_rng: &mut impl RngCore) -> Result<Self, Error>
     where
@@ -446,6 +485,46 @@ impl<T: CoreSigner> Signer for &T {
     }
 }
 
+impl Signer for crate::core::identity::Identity {
+    fn random(_rng: &mut impl RngCore) -> Result<Self, Error>
+    where
+        Self: Sized,
+    {
+        Err(Error::InvalidArgument)
+    }
+
+    fn new_from_seed(_seed: &[u8]) -> Result<Self, Error>
+    where
+        Self: Sized,
+    {
+        Err(Error::InvalidArgument)
+    }
+
+    fn from_bytes(_bytes: &[u8]) -> Result<Self, Error>
+    where
+        Self: Sized,
+    {
+        Err(Error::InvalidArgument)
+    }
+
+    fn to_bytes(&self) -> Vec<u8> {
+        vec![]
+    }
+
+    fn public_key(&self) -> PublicKey {
+        PublicKey::Ed25519(self.public().into())
+    }
+
+    fn sign(&self, context: &[u8], message: &[u8]) -> Result<Signature, Error> {
+        let raw_sig = CoreSigner::sign(self, context, message).map_err(|_| Error::SigningError)?;
+        Ok(Signature(raw_sig.as_ref().into()))
+    }
+
+    fn sign_raw(&self, _message: &[u8]) -> Result<Signature, Error> {
+        Err(Error::InvalidArgument)
+    }
+}
+
 /// A memory-backed signer.
 pub enum MemorySigner {
     Ed25519(ed25519::MemorySigner),