feat(rust): persist application data in a database

examples/rust/example_projects/no_std/Cargo.toml

@@ -52,7 +52,7 @@ log-semihosting = []
 log-uart = []
 
 [dependencies]
-ockam = { path = "../../../../implementations/rust/ockam/ockam", default_features = false, features = ["software_vault"] }
+ockam = { path = "../../../../implementations/rust/ockam/ockam", optional = true, default_features = false, features = ["software_vault"] }
 
 alloc-cortex-m = { version = "0.4.1", optional = true }
 cortex-m = { version = "0.7.2", optional = true }

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/Cargo.toml

@@ -18,6 +18,7 @@ std = [
   "serde_json/default",
   "ockam_multiaddr/std",
   "ockam_api/std",
+  "storage",
 ]
 
 # Feature: "no_std" enables functionality required for platforms
@@ -27,6 +28,7 @@ no_std = ["ockam/no_std"]
 # Feature: "alloc" enables support for heap allocation on "no_std"
 # platforms, requires nightly.
 alloc = ["ockam/alloc", "serde_json/alloc"]
+storage = ["ockam_api/storage"]
 
 [dependencies]
 anyhow = "1"

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

@@ -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 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("81825837830101583285f68200815820afbca9cf5d440147450f9f0d0a038a337b3fe5c17086163f2c54509558b62ef4f41a654cf97d1a7818fc7d8200815840650c4c939b96142546559aed99c52b64aa8a2f7b242b46534f7f8d0c5cc083d2c97210b93e9bca990e9cb9301acc2b634ffb80be314025f9adc870713e6fde0d").unwrap();
     let issuer = node.import_private_identity(None, &issuer_identity, &secret).await?;
@@ -48,14 +48,14 @@ async fn main(ctx: Context) -> Result<()> {
     // For a different application this attested attribute set can be different and
     // distinct for each identifier, but for this example we'll keep things simple.
     let credential_issuer = CredentialsIssuer::new(
-        node.identities().repository(),
+        node.identities().identity_attributes_repository(),
         node.credentials(),
         &issuer,
         "trust_context".into(),
     );
     for identifier in known_identifiers.iter() {
         node.identities()
-            .repository()
+            .identity_attributes_repository()
             .put_attribute_value(identifier, b"cluster".to_vec(), b"production".to_vec())
             .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?;
@@ -90,7 +90,7 @@ async fn main(ctx: Context) -> Result<()> {
         DefaultAddress::ECHO_SERVICE,
         &sc_listener_options.spawner_flow_control_id(),
     );
-    let allow_production = AbacAccessControl::create(node.identities_repository(), "cluster", "production");
+    let allow_production = AbacAccessControl::create(node.identity_attributes_repository(), "cluster", "production");
     node.start_worker_with_access_control(DefaultAddress::ECHO_SERVICE, Echoer, allow_production, AllowAll)
         .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