Net Mk1 - example using docker-compose

.dockerignore

@@ -0,0 +1 @@
+target

core/net/examples/docker/README.md

@@ -0,0 +1,8 @@
+# Net Mk1 Example
+
+## Test
+
+```
+cd core/net/examples/docker
+docker-compose up
+```

core/net/examples/docker/docker-compose.yaml

@@ -0,0 +1,21 @@
+version: "3.0"
+services:
+        hub:
+                build:
+                        context: ../../../..
+                        dockerfile: core/net/examples/docker/hub.Dockerfile
+                image: hub
+        provider-1:
+                build:
+                        context: ../../../..
+                        dockerfile: core/net/examples/docker/provider-1.Dockerfile
+                image: provider-1
+                depends_on:
+                        - hub
+        provider-2:
+                build:
+                        context: ../../../..
+                        dockerfile: core/net/examples/docker/provider-2.Dockerfile
+                image: provider-2
+                depends_on:
+                        - provider-1

core/net/examples/docker/hub.Dockerfile

@@ -0,0 +1,8 @@
+FROM rust:1.40
+
+WORKDIR /usr/src/yagna-net
+COPY . .
+
+RUN cargo build --examples --bins
+EXPOSE 9000
+CMD [ "cargo", "run", "--bin", "ya-sb-router", "--", "-l", "0.0.0.0:9000" ]

core/net/examples/docker/listen.sh

@@ -0,0 +1,3 @@
+#!/bin/bash
+cargo run --bin ya-sb-router &
+cargo run --example listen

core/net/examples/docker/provider-1.Dockerfile

@@ -0,0 +1,9 @@
+FROM rust:1.40
+
+WORKDIR /usr/src/yagna-net
+COPY . .
+
+RUN cargo build --examples --bins
+EXPOSE 9000
+
+CMD ./core/net/examples/docker/listen.sh

core/net/examples/docker/provider-2.Dockerfile

@@ -0,0 +1,9 @@
+FROM rust:1.40
+
+WORKDIR /usr/src/yagna-net
+COPY . .
+
+RUN cargo build --examples --bins
+EXPOSE 9000
+
+CMD ./core/net/examples/docker/send_message.sh

core/net/examples/docker/send_message.sh

@@ -0,0 +1,3 @@
+#!/bin/bash
+cargo run --bin ya-sb-router &
+cargo run --example send_message

core/net/examples/listen.rs

@@ -5,7 +5,7 @@ use futures03::future::TryFutureExt;
 fn main() -> std::io::Result<()> {
     System::run(|| {
         Arbiter::spawn(
-            ya_net::init_service_future("127.0.0.1:9000", "0x789")
+            ya_net::init_service_future("hub:9000", "0x789")
                 .map_err(|e| eprintln!("Error: {}", e))
                 .compat()
                 .map(|r| {

core/net/examples/send_message.rs

@@ -5,7 +5,7 @@ use futures03::future::TryFutureExt;
 fn main() -> std::io::Result<()> {
     System::run(|| {
         Arbiter::spawn(
-            ya_net::init_service_future("127.0.0.1:9000", "0x123")
+            ya_net::init_service_future("hub:9000", "0x123")
                 .and_then(|_| {
                     ya_net::send_message_future("0x123", "0x789/test", "Test".as_bytes().to_vec())
                         .map_err(|e| {

core/net/src/lib.rs

@@ -3,6 +3,7 @@ use futures03::compat::Future01CompatExt;
 use futures03::future::Future as Future03;
 use ya_service_bus::connection;
 use ya_service_bus::{untyped as bus, Error};
+use std::net::ToSocketAddrs;
 
 pub const SERVICE_ID: &str = "/net";
 
@@ -15,7 +16,7 @@ pub fn init_service_future(
     source_node_id: &str,
 ) -> impl Future03<Output = Result<(), std::io::Error>> {
     let source_node_id_clone = format!("{}/{}", SERVICE_ID, source_node_id);
-    connection::tcp(&hub_addr.parse().unwrap())
+    connection::tcp(&hub_addr.to_socket_addrs().unwrap().next().unwrap())
         .and_then(move |c| {
             let connection_ref = connection::connect_with_handler(
                 c,