Adding Zenoh-Flow Examples Target

Cargo.toml

@@ -19,6 +19,7 @@ members = [
   "zenoh-flow-derive",
   "zenoh-flow-plugin",
   "zfctl",
+  "examples",
 ]
 
 [workspace.package]

README.md

@@ -41,3 +41,5 @@ The best way to learn Zenoh-Flow is to go through our [getting started guide](ht
 We encourage you to look at the examples available in our [examples repository](https://github.com/ZettaScaleLabs/zenoh-flow-examples).
 
 🚗 If you still want more, we also ported an [Autonomous Driving Pipeline](https://github.com/ZettaScaleLabs/stunt)!
+
+compile the examples using "cargo build --examples" 

examples/Cargo.toml

@@ -0,0 +1,42 @@
+[package]
+name = "zenoh-flow-examples"
+version.workspace = true
+repository.workspace = true
+homepage.workspace = true
+categories.workspace = true
+description.workspace = true
+edition.workspace = true
+license.workspace = true
+readme = "README.md"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[profile.dev]
+debug = true
+
+[profile.release]
+debug = true
+
+[dev-dependencies]
+async-std = "1.12"
+async-trait = "0.1"
+prost = "0.11"
+zenoh-flow = { path = "../zenoh-flow/" }
+
+[build-dependencies]
+rustc_version = "0.4.0"
+
+[[example]]
+name = "greetings-maker"
+path = "examples/greetings-maker/src/lib.rs"
+crate-type = ["cdylib"]
+
+[[example]]
+name = "file-writer"
+path = "examples/file-writer/src/lib.rs"
+crate-type = ["cdylib"]
+
+[[example]]
+name = "period-miss-detector"
+path = "examples/period-miss-detector/src/lib.rs"
+crate-type = ["cdylib"]

examples/README.md

@@ -0,0 +1,76 @@
+# Zenoh-Flow examples
+
+## How to run
+
+### Build
+
+We can create all the zenoh-flow node libraries used in the examples with the following command:
+   ```bash
+  cargo build --examples
+   ```
+
+Alternatively, we can create a single library of a zenoh-flow node with the following command:
+   ```bash
+  cargo build --example name_node 
+
+  i.e.
+  cargo build --example greetings-maker
+   ```
+
+### Update the paths
+
+For each YAML file in the list below, check that the paths and filenames are
+correct:
+- flows/period-miss-detector.yaml 
+- flows/getting-started.yaml
+- examples/file-writer/file-writer.yaml
+- examples/greetings-maker/greetings-maker.yaml
+- examples/period-miss-detector/period-miss-detector.yaml
+
+### Launch
+
+#### 1st terminal: Zenoh
+
+```shell
+cd ~/dev/zenoh && ./target/debug/zenohd -c ~/.config/zenoh-flow/zenoh.json
+```
+
+#### 2nd terminal: Zenoh-Flow daemon
+
+```shell
+cd ~/dev/zenoh-flow/ && ./target/debug/zenoh-flow-daemon -c ~/.config/zenoh-flow/runtime.yaml
+```
+
+#### 3rd terminal: launch the flow
+
+```shell
+cd ~/dev/zenoh-flow && ./target/debug/zfctl launch ~/dev/zenoh-flow/examples/data-flow.yaml
+```
+
+Then, if the flow was successfully launched, put values at regular intervals into the "greetings-maker" example:
+
+```shell
+# If you have compiled the `z_put` example of Zenoh in debug
+$ZENOH/target/debug/examples/z_put -k "zf/getting-started/hello" -v "Alice"
+```
+
+Alternatively, in the "period-miss-detector" example, put values at regular intervals with:
+
+```shell
+cd ~/dev/zenoh && ./target/debug/examples/z_put -k "zf/period-miss-detector" -v "3.1416"
+```
+#### 4rd terminal:
+
+The Sink node used in both examples creates a text file where the node writes the strings it receives.
+We can see the "getting-started" test file with:
+
+```
+tail -f /tmp/greetings.txt
+```
+
+Alternatively we can run the following command to see  "period-miss-detector" text result:
+
+```
+tail -f /tmp/period-log.txt
+```
+

examples/examples/file-writer/file-writer.yaml

@@ -0,0 +1,14 @@
+id: file-writer
+
+vars:
+  BASE_DIR: "/path/to/zenoh-flow"
+
+# Do not forget to change the extension depending on your operating system!
+# Linux   -> .so
+# Windows -> .dll (and remove the "lib" in front)
+# MacOS   -> .dylib
+uri: "file://{{ BASE_DIR }}/target/debug/examples/libfile_writer.dylib"
+# If the compilation is in release:
+# uri: file:///absolute/path/to/target/release/libfile_writer.so
+
+inputs: [in]

examples/examples/file-writer/src/lib.rs

@@ -0,0 +1,71 @@
+//
+// Copyright (c) 2022 ZettaScale Technology
+//
+// This program and the accompanying materials are made available under the
+// terms of the Eclipse Public License 2.0 which is available at
+// http://www.eclipse.org/legal/epl-2.0, or the Apache License, Version 2.0
+// which is available at https://www.apache.org/licenses/LICENSE-2.0.
+//
+// SPDX-License-Identifier: EPL-2.0 OR Apache-2.0
+//
+// Contributors:
+//   ZettaScale Zenoh Team, <[email protected]>
+//
+
+use async_std::{fs::File, io::WriteExt, sync::Mutex};
+use prost::Message as pMessage;
+use zenoh_flow::{anyhow, prelude::*};
+
+#[export_sink]
+pub struct FileWriter {
+    input: Input<String>,
+    file: Mutex<File>,
+}
+
+#[async_trait::async_trait]
+impl Node for FileWriter {
+    async fn iteration(&self) -> Result<()> {
+        let (message, _) = self.input.recv().await?;
+
+        if let Message::Data(greeting) = message {
+            let mut file = self.file.lock().await;
+            file.write_all(greeting.as_bytes())
+                .await
+                .map_err(|e| zferror!(ErrorKind::IOError, "{:?}", e))?;
+            return file
+                .flush()
+                .await
+                .map_err(|e| zferror!(ErrorKind::IOError, "{:?}", e).into());
+        }
+
+        Ok(())
+    }
+}
+
+#[async_trait::async_trait]
+impl Sink for FileWriter {
+    async fn new(
+        _context: Context,
+        configuration: Option<Configuration>,
+        mut inputs: Inputs,
+    ) -> Result<Self> {
+        let file_path = match &configuration {
+            Some(conf) => conf["file"]
+                .as_str()
+                .ok_or_else(|| zferror!(ErrorKind::InvalidState))?,
+            None => "/tmp/greetings.txt",
+        };
+
+        Ok(FileWriter {
+            file: Mutex::new(
+                File::create(file_path) //File::create("/tmp/greetings.txt")
+                    .await
+                    .expect("Could not create '/tmp/greetings.txt'"),
+            ),
+            input: inputs
+                .take("in")
+                .expect("No Input called 'in' found")
+                .typed(|bytes| String::decode(bytes).map_err(|e| anyhow!(e))),
+        })
+    }
+}

examples/examples/greetings-maker/greetings-maker.yaml

@@ -0,0 +1,15 @@
+id: greetings-maker
+
+vars:
+  BASE_DIR: "/path/to/zenoh-flow"
+
+# Do not forget to change the extension depending on your operating system!
+# Linux   -> .so
+# Windows -> .dll (and remove the "lib" in front)
+# MacOS   -> .dylib
+uri: "file://{{ BASE_DIR }}/target/debug/examples/libgreetings_maker.dylib"
+# If the compilation is in release:
+# uri: file:///absolute/path/to/target/release/libgreetings_maker.so
+
+inputs: [name]
+outputs: [greeting]

examples/examples/greetings-maker/src/lib.rs

@@ -0,0 +1,64 @@
+//
+// Copyright (c) 2022 ZettaScale Technology
+//
+// This program and the accompanying materials are made available under the
+// terms of the Eclipse Public License 2.0 which is available at
+// http://www.eclipse.org/legal/epl-2.0, or the Apache License, Version 2.0
+// which is available at https://www.apache.org/licenses/LICENSE-2.0.
+//
+// SPDX-License-Identifier: EPL-2.0 OR Apache-2.0
+//
+// Contributors:
+//   ZettaScale Zenoh Team, <[email protected]>
+//
+
+use prost::Message as pMessage;
+use zenoh_flow::{anyhow, prelude::*};
+
+#[export_operator]
+pub struct GreetingsMaker {
+    input: Input<String>,
+    output: Output<String>,
+}
+
+#[async_trait::async_trait]
+impl Operator for GreetingsMaker {
+    async fn new(
+        _context: Context,
+        _configuration: Option<Configuration>,
+        mut inputs: Inputs,
+        mut outputs: Outputs,
+    ) -> Result<Self> {
+        Ok(GreetingsMaker {
+            input: inputs
+                .take("name")
+                .expect("No input 'name' found")
+                .typed(|bytes| String::from_utf8(bytes.into()).map_err(|e| anyhow!(e))),
+            output: outputs
+                .take("greeting")
+                .expect("No output 'greeting' found")
+                .typed(|buffer, data: &String| data.encode(buffer).map_err(|e| anyhow!(e))),
+        })
+    }
+}
+
+#[async_trait::async_trait]
+impl Node for GreetingsMaker {
+    async fn iteration(&self) -> Result<()> {
+        let (message, _) = self.input.recv().await?;
+        if let Message::Data(characters) = message {
+            let name = characters.trim_end();
+
+            let greetings = match name {
+                "Sofia" | "Leonardo" => format!("Ciao, {}!\n", name),
+                "Lucia" | "Martin" => format!("¡Hola, {}!\n", name),
+                "Jade" | "Gabriel" => format!("Bonjour, {} !\n", name),
+                _ => format!("Hello, {}!\n", name),
+            };
+
+            return self.output.send(greetings, None).await;
+        }
+
+        Ok(())
+    }
+}

examples/examples/period-miss-detector/period-miss-detector.yaml

@@ -0,0 +1,15 @@
+id: period-miss-detector
+
+vars:
+  BASE_DIR: "/path/to/zenoh-flow"
+
+# Do not forget to change the extension depending on your operating system!
+# Linux   -> .so
+# Windows -> .dll (and remove the "lib" in front)
+# MacOS   -> .dylib
+uri: "file://{{ BASE_DIR }}/target/debug/examples/libperiod_miss_detector.dylib"
+# If the compilation is in release:
+# uri: file:///absolute/path/to/target/release/libperiod_miss_detector.dylib
+
+inputs: [in]
+outputs: [out]