From 147c1212d68e735073f7510ed500fa1254fc13f8 Mon Sep 17 00:00:00 2001
From: Ernst Rohlicek <ernst@rohlicek.at>
Date: Tue, 30 Aug 2022 04:12:18 +0200
Subject: [PATCH] flowd-rs: Change example network to fixed graph node spec
 (#207)

---
 flowd-rs/src/main.rs | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/flowd-rs/src/main.rs b/flowd-rs/src/main.rs
index ea002e4..4fe74e1 100644
--- a/flowd-rs/src/main.rs
+++ b/flowd-rs/src/main.rs
@@ -93,6 +93,13 @@ fn main() {
         }
     });
     graph.write().expect("lock poisoned").add_node("main_graph".to_owned(), "Repeat".to_owned(), "Repeat_1337".to_owned(), GraphNodeMetadata { x: 180, y: 72, height: Some(72), width: Some(72), label: Some("Repeat_1337".to_owned()) }).expect("add_node() failed");
+    // add components required for test suite
+    graph.write().expect("lock poisoned").add_node("main_graph".to_owned(), "Repeat".to_owned(), "Repeat_2ufmu".to_owned(), GraphNodeMetadata { x: 36, y: 216, height: Some(72), width: Some(72), label: Some("Repeat_2ufmu".to_owned()) }).expect("add_node() failed");
+    graph.write().expect("lock poisoned").add_node("main_graph".to_owned(), "Output".to_owned(), "Output_mwr5y".to_owned(), GraphNodeMetadata { x: 180, y: 216, height: Some(72), width: Some(72), label: Some("Output_mwr5y".to_owned()) }).expect("add_node() failed");
+    graph.write().expect("lock poisoned").add_node("main_graph".to_owned(), "Drop".to_owned(), "Drop_raux7".to_owned(), GraphNodeMetadata { x: 324, y: 216, height: Some(72), width: Some(72), label: Some("Drop_raux7".to_owned()) }).expect("add_node() failed");
+    graph.write().expect("lock poisoned").add_edge("main_graph".to_owned(), GraphEdge { source: GraphNodeSpec { process: "".to_owned(), port: "".to_owned(), index: None }, data: Some("test IIP data".to_owned()), target: GraphNodeSpec { process: "Repeat_2ufmu".to_owned(), port: "IN".to_owned(), index: None }, metadata: GraphEdgeMetadata::new(None, None, None) }).expect("add_edge() failed");
+    graph.write().expect("lock poisoned").add_edge("main_graph".to_owned(), GraphEdge { source: GraphNodeSpec { process: "Repeat_2ufmu".to_owned(), port: "OUT".to_owned(), index: None }, data: None, target: GraphNodeSpec { process: "Output_mwr5y".to_owned(), port: "IN".to_owned(), index: None }, metadata: GraphEdgeMetadata::new(None, None, None) }).expect("add_edge() failed");
+    graph.write().expect("lock poisoned").add_edge("main_graph".to_owned(), GraphEdge { source: GraphNodeSpec { process: "Output_mwr5y".to_owned(), port: "OUT".to_owned(), index: None }, data: None, target: GraphNodeSpec { process: "Drop_raux7".to_owned(), port: "IN".to_owned(), index: None }, metadata: GraphEdgeMetadata::new(None, None, None) }).expect("add_edge() failed");
 
     let bind_addr = "localhost:3569";
     let server = TcpListener::bind(bind_addr).unwrap();