Merge pull request #686 from swimos/example_apps_examples

Client examples for server applications

Author: SirCipher

example_apps/aggregations/Cargo.toml

@@ -6,8 +6,12 @@ publish = false
 
 [dependencies]
 swimos = { workspace = true, features = ["server", "agent"] }
+swimos_client = { workspace = true }
 swimos_form = { workspace = true }
 tokio = { workspace = true, features = ["rt-multi-thread", "macros"] }
 example-util = { path = "../example_util" }
 rand = { workspace = true }
-futures-util = { workspace = true }
+futures-util = { workspace = true }
+
+[[bin]]
+name = "aggregations_client"

example_apps/aggregations/src/bin/aggregations_client.rs

@@ -0,0 +1,40 @@
+use std::error::Error;
+use swimos_client::{BasicValueDownlinkLifecycle, RemotePath, SwimClientBuilder};
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn Error>> {
+    let host = "ws://127.0.0.1:8080";
+
+    let (client, task) = SwimClientBuilder::default().build().await;
+    let task_handle = tokio::spawn(task);
+
+    let client_handle = client.handle();
+
+    let car_lifecycle = BasicValueDownlinkLifecycle::default()
+        .on_event_blocking(|speed| println!("/cars/1 speed: {speed}"));
+    client_handle
+        .value_downlink::<u64>(RemotePath::new(host, "/cars/1", "speed"))
+        .lifecycle(car_lifecycle)
+        .open()
+        .await?;
+
+    let area_lifecycle = BasicValueDownlinkLifecycle::default()
+        .on_event_blocking(|speed| println!("/area/arbury average speed: {speed}"));
+    client_handle
+        .value_downlink::<f64>(RemotePath::new(host, "/area/arbury", "average_speed"))
+        .lifecycle(area_lifecycle)
+        .open()
+        .await?;
+
+    let city_lifecycle = BasicValueDownlinkLifecycle::default()
+        .on_event_blocking(|speed| println!("/city average speed: {speed}"));
+    client_handle
+        .value_downlink::<f64>(RemotePath::new(host, "/city", "average_speed"))
+        .lifecycle(city_lifecycle)
+        .open()
+        .await?;
+
+    task_handle.await?;
+
+    Ok(())
+}

example_apps/aggregations/src/main.rs

@@ -49,6 +49,7 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
     let aggregate_agent = AgentModel::new(CityAgent::default, CityLifecycle.into_lifecycle());
 
     let mut builder = ServerBuilder::with_plane_name("Example Plane")
+        .set_bind_addr("127.0.0.1:8080".parse()?)
         .add_route(RoutePattern::parse_str("/cars/:car_id")?, car_agent)
         .add_route(RoutePattern::parse_str("/city")?, aggregate_agent)
         .update_config(|config| {

example_apps/command_lane/Cargo.toml

@@ -6,6 +6,10 @@ publish = false
 
 [dependencies]
 swimos = { workspace = true, features = ["server", "agent"] }
+swimos_client = { workspace = true }
 swimos_form = { workspace = true }
 tokio = { workspace = true, features = ["rt-multi-thread", "macros"] }
 example-util = { path = "../example_util" }
+
+[[bin]]
+name = "command_client"

example_apps/command_lane/src/bin/command_client.rs

@@ -0,0 +1,36 @@
+use command_lane::Instruction;
+use std::error::Error;
+use swimos_client::{BasicValueDownlinkLifecycle, RemotePath, SwimClientBuilder};
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn Error>> {
+    let host = "ws://127.0.0.1:8080";
+
+    let (client, task) = SwimClientBuilder::default().build().await;
+    let task_handle = tokio::spawn(task);
+
+    let client_handle = client.handle();
+
+    let state_lifecycle =
+        BasicValueDownlinkLifecycle::default().on_event_blocking(|state| println!("{state}"));
+    client_handle
+        .value_downlink::<i32>(RemotePath::new(host, "/example/1", "lane"))
+        .lifecycle(state_lifecycle)
+        .open()
+        .await?;
+
+    let command_handle = client_handle
+        .value_downlink::<Instruction>(RemotePath::new(host, "/example/1", "command"))
+        .open()
+        .await?;
+
+    for i in 0..10 {
+        command_handle.set(Instruction::Add(i)).await?;
+    }
+
+    command_handle.set(Instruction::Zero).await?;
+
+    task_handle.await?;
+
+    Ok(())
+}

example_apps/command_lane/src/lib.rs

@@ -0,0 +1,3 @@
+mod model;
+
+pub use model::Instruction;

example_apps/command_lane/src/main.rs

@@ -35,6 +35,7 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
     let agent = AgentModel::new(ExampleAgent::default, lifecycle.into_lifecycle());
 
     let server = ServerBuilder::with_plane_name("Example Plane")
+        .set_bind_addr("127.0.0.1:8080".parse()?)
         .add_route(route, agent)
         .update_config(|config| {
             config.agent_runtime.inactive_timeout = Duration::from_secs(5 * 60);

example_apps/demand_lane/Cargo.toml

@@ -6,5 +6,9 @@ publish = false
 
 [dependencies]
 swimos = { workspace = true, features = ["server", "agent"] }
+swimos_client = { workspace = true }
 tokio = { workspace = true, features = ["rt-multi-thread", "macros"] }
 example-util = { path = "../example_util" }
+
+[[bin]]
+name = "demand_client"

example_apps/demand_lane/src/agent.rs

@@ -31,7 +31,7 @@ pub struct ExampleAgent {
 #[derive(Clone)]
 pub struct ExampleLifecycle;
 
-const CUE_PERIOD: Duration = Duration::from_secs(5);
+const CUE_PERIOD: Duration = Duration::from_secs(1);
 
 #[lifecycle(ExampleAgent)]
 impl ExampleLifecycle {

example_apps/demand_lane/src/bin/demand_client.rs

@@ -0,0 +1,34 @@
+use std::error::Error;
+use swimos_client::{BasicValueDownlinkLifecycle, RemotePath, SwimClientBuilder};
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn Error>> {
+    let host = "ws://127.0.0.1:8080";
+
+    let (client, task) = SwimClientBuilder::default().build().await;
+    let task_handle = tokio::spawn(task);
+
+    let client_handle = client.handle();
+
+    let state_lifecycle =
+        BasicValueDownlinkLifecycle::default().on_event_blocking(|state| println!("{state}"));
+    let state_view = client_handle
+        .value_downlink::<i32>(RemotePath::new(host, "/example/1", "lane"))
+        .lifecycle(state_lifecycle)
+        .open()
+        .await?;
+
+    let demand_lifecycle =
+        BasicValueDownlinkLifecycle::default().on_event_blocking(|state| println!("{state}"));
+    client_handle
+        .value_downlink::<i32>(RemotePath::new(host, "/example/1", "demand"))
+        .lifecycle(demand_lifecycle)
+        .open()
+        .await?;
+
+    state_view.set(13).await?;
+
+    task_handle.await?;
+
+    Ok(())
+}