refactor(rust): propagate the async constraint when using an in-memor…

…y repository

examples/rust/example_projects/no_std/examples/01-node.rs

@@ -59,7 +59,7 @@ use ockam::{node, Context, Result};
 
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
 
     // Stop the node as soon as it starts.
     info!("Stop the node as soon as it starts.");

examples/rust/example_projects/no_std/examples/hello.rs

@@ -67,7 +67,7 @@ use ockam::{node, route, Context, Result};
 
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
     let bob = node.create_identity().await?;
 
     // Create a secure channel listener for Bob that will wait for requests to

examples/rust/file_transfer/examples/receiver.rs

@@ -79,7 +79,7 @@ impl Worker for FileReception {
 
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
-    let node = node(ctx);
+    let node = node(ctx).await?;
     let tcp = node.create_tcp_transport().await?;
 
     // Create an Identity to represent Receiver.

examples/rust/file_transfer/examples/sender.rs

@@ -33,7 +33,7 @@ struct Opt {
 async fn main(ctx: Context) -> Result<()> {
     let opt = Opt::from_args();
 
-    let node = node(ctx);
+    let node = node(ctx).await?;
     let tcp = node.create_tcp_transport().await?;
 
     // Create an Identity to represent Sender.

examples/rust/get_started/examples/01-node.rs

@@ -27,7 +27,7 @@ async fn main(ctx: Context) -> Result<()> {
     print_title(vec!["Run a node & stop it right away"]);
 
     // Create a node.
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
 
     // Stop the node as soon as it starts.
     node.stop().await

examples/rust/get_started/examples/02-worker.rs

@@ -6,7 +6,7 @@ use ockam::{node, Context, Result};
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
 
     // Start a worker, of type Echoer, at address "echoer"
     node.start_worker("echoer", Echoer).await?;

examples/rust/get_started/examples/03-routing-many-hops.rs

@@ -6,7 +6,7 @@ use ockam::{node, route, Context, Result};
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
 
     // Start an Echoer worker at address "echoer"
     node.start_worker("echoer", Echoer).await?;

examples/rust/get_started/examples/03-routing.rs

@@ -6,7 +6,7 @@ use ockam::{node, route, Context, Result};
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
 
     // Start a worker, of type Echoer, at address "echoer"
     node.start_worker("echoer", Echoer).await?;

examples/rust/get_started/examples/04-routing-over-transport-initiator.rs

@@ -5,7 +5,7 @@ use ockam::{node, route, Context, Result, TcpConnectionOptions, TcpTransportExte
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
 
     // Initialize the TCP Transport.
     let tcp = node.create_tcp_transport().await?;

examples/rust/get_started/examples/04-routing-over-transport-responder.rs

@@ -7,7 +7,7 @@ use ockam::{node, Context, Result, TcpListenerOptions, TcpTransportExtension};
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let node = node(ctx);
+    let node = node(ctx).await?;
 
     // Initialize the TCP Transport
     let tcp = node.create_tcp_transport().await?;

examples/rust/get_started/examples/04-routing-over-transport-two-hops-initiator.rs

@@ -5,7 +5,7 @@ use ockam::{node, route, Context, Result, TcpConnectionOptions, TcpTransportExte
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
 
     // Initialize the TCP Transport
     let tcp = node.create_tcp_transport().await?;

examples/rust/get_started/examples/04-routing-over-transport-two-hops-middle.rs

@@ -9,7 +9,7 @@ use ockam::{node, Context, Result, TcpConnectionOptions, TcpListenerOptions, Tcp
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let node = node(ctx);
+    let node = node(ctx).await?;
 
     // Initialize the TCP Transport
     let tcp = node.create_tcp_transport().await?;

examples/rust/get_started/examples/04-routing-over-transport-two-hops-responder.rs

@@ -7,7 +7,7 @@ use ockam::{node, Context, Result, TcpListenerOptions, TcpTransportExtension};
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let node = node(ctx);
+    let node = node(ctx).await?;
 
     // Initialize the TCP Transport
     let tcp = node.create_tcp_transport().await?;

examples/rust/get_started/examples/04-udp-transport-initiator.rs

@@ -6,7 +6,7 @@ use ockam_transport_udp::{UdpTransportExtension, UDP};
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
 
     // Initialize the UDP Transport
     let _udp = node.create_udp_transport().await?;

examples/rust/get_started/examples/04-udp-transport-responder.rs

@@ -8,7 +8,7 @@ use ockam_transport_udp::UdpTransportExtension;
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let node = node(ctx);
+    let node = node(ctx).await?;
 
     // Initialize the UDP Transport
     let udp = node.create_udp_transport().await?;

examples/rust/get_started/examples/04-unix-domain-socket-transport-initiator.rs

@@ -6,7 +6,7 @@ use ockam_transport_uds::{UdsTransportExtension, UDS};
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
 
     // Initialize the UDS Transport
     let uds = node.create_uds_transport().await?;

examples/rust/get_started/examples/04-unix-domain-socket-transport-responder.rs

@@ -8,7 +8,7 @@ use ockam_transport_uds::UdsTransportExtension;
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let node = node(ctx);
+    let node = node(ctx).await?;
 
     // Initialize the UDS Transport
     let uds = node.create_uds_transport().await?;

examples/rust/get_started/examples/05-secure-channel-over-two-transport-hops-initiator.rs

@@ -7,7 +7,7 @@ use ockam::{node, route, Context, Result, TcpConnectionOptions, TcpTransportExte
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
 
     // Create an Identity to represent Alice.
     let alice = node.create_identity().await?;

examples/rust/get_started/examples/05-secure-channel-over-two-transport-hops-middle.rs

@@ -9,7 +9,7 @@ use ockam::{node, Context, Result, TcpConnectionOptions, TcpListenerOptions, Tcp
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let node = node(ctx);
+    let node = node(ctx).await?;
 
     // Initialize the TCP Transport
     let tcp = node.create_tcp_transport().await?;

examples/rust/get_started/examples/05-secure-channel-over-two-transport-hops-responder.rs

@@ -8,7 +8,7 @@ use ockam::{node, Context, Result, TcpListenerOptions, TcpTransportExtension};
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let node = node(ctx);
+    let node = node(ctx).await?;
 
     // Initialize the TCP Transport.
     let tcp = node.create_tcp_transport().await?;

examples/rust/get_started/examples/06-credentials-exchange-client.rs

@@ -9,7 +9,7 @@ use ockam_vault::{EdDSACurve25519SecretKey, SigningSecret, SoftwareVaultForSigni
 
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
-    let identity_vault = SoftwareVaultForSigning::create();
+    let identity_vault = SoftwareVaultForSigning::create().await?;
     // Import the signing secret key to the Vault
     let secret = identity_vault
         .import_key(SigningSecret::EdDSACurve25519(EdDSACurve25519SecretKey::new(
@@ -21,10 +21,10 @@ async fn main(ctx: Context) -> Result<()> {
         .await?;
 
     // Create a default Vault but use the signing vault with our secret in it
-    let mut vault = Vault::create();
+    let mut vault = Vault::create().await?;
     vault.identity_vault = identity_vault;
 
-    let mut node = Node::builder().with_vault(vault).build(&ctx).await?;
+    let mut node = Node::builder().await?.with_vault(vault).build(&ctx).await?;
     // Initialize the TCP Transport
     let tcp = node.create_tcp_transport().await?;
 

examples/rust/get_started/examples/06-credentials-exchange-issuer.rs

@@ -1,15 +1,15 @@
+use ockam::{Context, Result, TcpListenerOptions};
+use ockam::{Node, TcpTransportExtension};
 use ockam::access_control::AllowAll;
 use ockam::access_control::IdentityIdAccessControl;
-use ockam::identity::SecureChannelListenerOptions;
 use ockam::identity::{CredentialsIssuer, Vault};
-use ockam::{Context, Result, TcpListenerOptions};
-use ockam::{Node, TcpTransportExtension};
+use ockam::identity::SecureChannelListenerOptions;
 use ockam_api::DefaultAddress;
 use ockam_vault::{EdDSACurve25519SecretKey, SigningSecret, SoftwareVaultForSigning};
 
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
-    let identity_vault = SoftwareVaultForSigning::create();
+    let identity_vault = SoftwareVaultForSigning::create().await?;
     // Import the signing secret key to the Vault
     let secret = identity_vault
         .import_key(SigningSecret::EdDSACurve25519(EdDSACurve25519SecretKey::new(
@@ -21,10 +21,10 @@ async fn main(ctx: Context) -> Result<()> {
         .await?;
 
     // Create a default Vault but use the signing vault with our secret in it
-    let mut vault = Vault::create();
+    let mut vault = Vault::create().await?;
     vault.identity_vault = identity_vault;
 
-    let node = Node::builder().with_vault(vault).build(&ctx).await?;
+    let node = Node::builder().await?.with_vault(vault).build(&ctx).await?;
 
     let issuer_identity = hex::decode("81a201583ba20101025835a4028201815820afbca9cf5d440147450f9f0d0a038a337b3fe5c17086163f2c54509558b62ef403f4041a64dd404a051a77a9434a0282018158407754214545cda6e7ff49136f67c9c7973ec309ca4087360a9f844aac961f8afe3f579a72c0c9530f3ff210f02b7c5f56e96ce12ee256b01d7628519800723805").unwrap();
     let issuer = node.import_private_identity(None, &issuer_identity, &secret).await?;
@@ -82,7 +82,7 @@ async fn main(ctx: Context) -> Result<()> {
         allow_known,
         AllowAll,
     )
-    .await?;
+        .await?;
 
     // Initialize TCP Transport, create a TCP listener, and wait for connections.
     let tcp = node.create_tcp_transport().await?;

examples/rust/get_started/examples/06-credentials-exchange-server.rs

@@ -14,7 +14,7 @@ use ockam_vault::{EdDSACurve25519SecretKey, SigningSecret, SoftwareVaultForSigni
 
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
-    let identity_vault = SoftwareVaultForSigning::create();
+    let identity_vault = SoftwareVaultForSigning::create().await?;
     // Import the signing secret key to the Vault
     let secret = identity_vault
         .import_key(SigningSecret::EdDSACurve25519(EdDSACurve25519SecretKey::new(
@@ -26,10 +26,10 @@ async fn main(ctx: Context) -> Result<()> {
         .await?;
 
     // Create a default Vault but use the signing vault with our secret in it
-    let mut vault = Vault::create();
+    let mut vault = Vault::create().await?;
     vault.identity_vault = identity_vault;
 
-    let node = Node::builder().with_vault(vault).build(&ctx).await?;
+    let node = Node::builder().await?.with_vault(vault).build(&ctx).await?;
 
     // Initialize the TCP Transport
     let tcp = node.create_tcp_transport().await?;

examples/rust/get_started/examples/09-streams-initiator.rs

@@ -4,7 +4,7 @@ use ockam_transport_tcp::TcpTransportExtension;
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
     let tcp = node.create_tcp_transport().await?;
 
     // Set the address of the Kafka node you created here. (e.g. "192.0.2.1:4000")

examples/rust/get_started/examples/09-streams-responder.rs

@@ -5,7 +5,7 @@ use ockam_transport_tcp::TcpTransportExtension;
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let node = node(ctx);
+    let node = node(ctx).await?;
     let tcp = node.create_tcp_transport().await?;
 
     // Start an echoer worker

examples/rust/get_started/examples/10-secure-channel-via-streams-initiator.rs

@@ -5,7 +5,7 @@ use ockam_transport_tcp::TcpTransportExtension;
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
     let tcp = node.create_tcp_transport().await?;
 
     // Set the address of the Kafka node you created here. (e.g. "192.0.2.1:4000")

examples/rust/get_started/examples/10-secure-channel-via-streams-responder.rs

@@ -6,7 +6,7 @@ use ockam_transport_tcp::TcpTransportExtension;
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let node = node(ctx);
+    let node = node(ctx).await?;
     let tcp = node.create_tcp_transport().await?;
 
     // Start an echoer worker

examples/rust/get_started/examples/11-attribute-based-authentication-control-plane.rs

@@ -50,7 +50,7 @@ async fn main(ctx: Context) -> Result<()> {
 /// start the control node
 async fn start_node(ctx: Context, project_information_path: &str, token: OneTimeCode) -> Result<()> {
     // Create a node with default implementations
-    let node = node(ctx);
+    let node = node(ctx).await?;
     // Initialize the TCP transport
     let tcp = node.create_tcp_transport().await?;
 

examples/rust/get_started/examples/11-attribute-based-authentication-edge-plane.rs

@@ -48,7 +48,7 @@ async fn main(ctx: Context) -> Result<()> {
 /// start the edge node
 async fn start_node(ctx: Context, project_information_path: &str, token: OneTimeCode) -> Result<()> {
     // Create a node with default implementations
-    let node = node(ctx);
+    let node = node(ctx).await?;
     // Use the TCP transport
     let tcp = node.create_tcp_transport().await?;
 
@@ -107,8 +107,11 @@ async fn start_node(ctx: Context, project_information_path: &str, token: OneTime
         .await?;
 
     // 3. create an access control policy checking the value of the "component" attribute of the caller
-    let access_control =
-        AbacAccessControl::create(identities().identity_attributes_repository(), "component", "control");
+    let access_control = AbacAccessControl::create(
+        identities().await?.identity_attributes_repository(),
+        "component",
+        "control",
+    );
 
     // 4. create a tcp inlet with the above policy
 

examples/rust/get_started/examples/alice.rs

@@ -6,7 +6,7 @@ use std::io;
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
     // Initialize the TCP Transport
     let tcp = node.create_tcp_transport().await?;
 

examples/rust/get_started/examples/bob.rs

@@ -24,7 +24,7 @@ impl Worker for Echoer {
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let node = node(ctx);
+    let node = node(ctx).await?;
     // Initialize the TCP Transport
     let tcp = node.create_tcp_transport().await?;
 

examples/rust/get_started/examples/hello.rs

@@ -4,7 +4,7 @@ use ockam::{node, route, Context, Result};
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create a node with default implementations
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
     // Create an Identity to represent Bob
     let bob = node.create_identity().await?;
 

examples/rust/get_started/examples/vault-and-identities.rs

@@ -4,7 +4,7 @@ use ockam::{Context, Result};
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Create default node to safely store secret keys for Alice
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
 
     // Create an Identity to represent Alice.
     let _alice = node.create_identity().await?;

examples/rust/ockam_kafka/examples/ockam_kafka_alice.rs

@@ -6,7 +6,7 @@ use std::io;
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Initialize the TCP Transport.
-    let mut node = node(ctx);
+    let mut node = node(ctx).await?;
     let tcp = node.create_tcp_transport().await?;
 
     // Create an Identity to represent Alice.

examples/rust/ockam_kafka/examples/ockam_kafka_bob.rs

@@ -22,7 +22,7 @@ impl Worker for Echoer {
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Initialize the TCP Transport.
-    let node = node(ctx);
+    let node = node(ctx).await?;
     let tcp = node.create_tcp_transport().await?;
 
     // Create an Identity to represent Bob.

examples/rust/tcp_inlet_and_outlet/examples/01-inlet-outlet.rs

@@ -4,7 +4,7 @@ use ockam_transport_tcp::TcpTransportExtension;
 #[ockam::node]
 async fn main(ctx: Context) -> Result<()> {
     // Initialize the TCP Transport.
-    let node = node(ctx);
+    let node = node(ctx).await?;
     let tcp = node.create_tcp_transport().await?;
 
     // Expect second command line argument to be the TCP address of a target TCP server.