Merge branch 'main' of https://github.com/swimos/swim-rust into dependencies

Author: SirCipher

Cargo.toml

@@ -37,6 +37,7 @@ members = [
     "example_apps/tutorial_app",
     "example_apps/tutorial_app/model",
     "example_apps/tutorial_app/generator",
+    "example_apps/join_map",
     "example_apps/join_value",
 ]
 

example_apps/join_map/Cargo.toml

@@ -0,0 +1,9 @@
+[package]
+name = "join_map"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+swimos = { path = "../../swimos", features = ["server", "agent"] }
+tokio = { workspace = true, features = ["rt-multi-thread", "macros"] }
+example-util = { path = "../example_util" }

example_apps/join_map/src/agents.rs

@@ -0,0 +1,76 @@
+use swimos::{
+    agent::agent_lifecycle::utility::HandlerContext,
+    agent::event_handler::{EventHandler, HandlerActionExt},
+    agent::lanes::{JoinMapLane, MapLane},
+    agent::projections,
+    agent::{lifecycle, AgentLaneModel},
+};
+
+#[derive(AgentLaneModel)]
+#[projections]
+pub struct StreetStatisticsAgent {
+    state: MapLane<String, u64>,
+}
+
+#[derive(Clone)]
+pub struct StreetStatisticsLifecycle;
+
+#[lifecycle(StreetStatisticsAgent)]
+impl StreetStatisticsLifecycle {}
+
+#[derive(AgentLaneModel)]
+#[projections]
+pub struct AggregatedStatisticsAgent {
+    streets: JoinMapLane<String, String, u64>,
+}
+
+#[derive(Clone)]
+pub struct AggregatedLifecycle;
+
+#[lifecycle(AggregatedStatisticsAgent)]
+impl AggregatedLifecycle {
+    #[on_start]
+    pub fn on_start(
+        &self,
+        context: HandlerContext<AggregatedStatisticsAgent>,
+    ) -> impl EventHandler<AggregatedStatisticsAgent> {
+        let california_downlink = context.add_map_downlink(
+            AggregatedStatisticsAgent::STREETS,
+            "california".to_string(),
+            None,
+            "/state/california",
+            "state",
+        );
+        let texas_downlink = context.add_map_downlink(
+            AggregatedStatisticsAgent::STREETS,
+            "texas".to_string(),
+            None,
+            "/state/texas",
+            "state",
+        );
+        let florida_downlink = context.add_map_downlink(
+            AggregatedStatisticsAgent::STREETS,
+            "florida".to_string(),
+            None,
+            "/state/florida",
+            "state",
+        );
+
+        context
+            .get_agent_uri()
+            .and_then(move |uri| context.effect(move || println!("Starting agent at: {}", uri)))
+            .followed_by(california_downlink)
+            .followed_by(texas_downlink)
+            .followed_by(florida_downlink)
+    }
+
+    #[on_stop]
+    pub fn on_stop(
+        &self,
+        context: HandlerContext<AggregatedStatisticsAgent>,
+    ) -> impl EventHandler<AggregatedStatisticsAgent> {
+        context
+            .get_agent_uri()
+            .and_then(move |uri| context.effect(move || println!("Stopping agent at: {}", uri)))
+    }
+}

example_apps/join_map/src/main.rs

@@ -0,0 +1,59 @@
+// Copyright 2015-2023 Swim Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+mod agents;
+
+use crate::agents::{
+    AggregatedLifecycle, AggregatedStatisticsAgent, StreetStatisticsAgent,
+    StreetStatisticsLifecycle,
+};
+use example_util::{example_logging, manage_handle};
+use std::{error::Error, time::Duration};
+use swimos::{
+    agent::agent_model::AgentModel, route::RoutePattern, server::Server, server::ServerBuilder,
+};
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
+    example_logging()?;
+
+    let street_route = RoutePattern::parse_str("/state/:name")?;
+    let street_agent = AgentModel::new(
+        StreetStatisticsAgent::default,
+        StreetStatisticsLifecycle.into_lifecycle(),
+    );
+
+    let aggregated_route = RoutePattern::parse_str("/join/state/:name")?;
+    let aggregated_agent = AgentModel::new(
+        AggregatedStatisticsAgent::default,
+        AggregatedLifecycle.into_lifecycle(),
+    );
+
+    let server = ServerBuilder::with_plane_name("Statistics Plane")
+        .add_route(street_route, street_agent)
+        .add_route(aggregated_route, aggregated_agent)
+        .update_config(|config| {
+            config.agent_runtime.inactive_timeout = Duration::from_secs(5 * 60);
+        })
+        .build()
+        .await?;
+
+    let (task, handle) = server.run();
+    let shutdown = manage_handle(handle);
+    let (_, result) = tokio::join!(shutdown, task);
+
+    result?;
+    println!("Server stopped successfully.");
+    Ok(())
+}