broadcast event example

Signed-off-by: Matthew Fisher <[email protected]>

Author: Matthew Fisher

examples/README.md

@@ -10,43 +10,43 @@ In one terminal, run:
 
 ```
 cd bevy_simple_networking
-cargo run --example server
+cargo run --example simple_server
 ```
 
 In another terminal, run:
 
 ```
 cd bevy_simple_networking
-cargo run --example client
+cargo run --example simple_client
 ```
 
 You should see a message that the client connected in the server logs:
 
 ```
-$ cargo run --example server
+$ cargo run --example simple_server
    Compiling bevy_simple_networking v0.1.2 (/home/bacongobbler/code/bevy_simple_networking)
     Finished dev [unoptimized + debuginfo] target(s) in 8.54s
-     Running `target/debug/examples/server`
-Oct 12 15:17:01.024  INFO server: 127.0.0.1:37810: connected!
+     Running `target/debug/examples/simple_server`
+Oct 12 15:17:01.024  INFO simple_server: 127.0.0.1:37810: connected!
 ```
 
 And you should see a response from the server in the client logs:
 
 ```
-$ cargo run --example client
+$ cargo run --example simple_client
     Finished dev [unoptimized + debuginfo] target(s) in 0.09s
-     Running `target/debug/examples/client`
-Oct 12 16:16:17.097  INFO client: server sent a message: b"PONG"
+     Running `target/debug/examples/simple_client`
+Oct 12 16:16:17.097  INFO simple_client: server sent a message: b"PONG"
 ```
 
 Now close the client by pressing CTRL+C (CMD+C on MacOS). After a few seconds,
 you should see the following in the server logs:
 
 ```
- $ cargo run --example server
+ $ cargo run --example simple_server
    Compiling bevy_simple_networking v0.1.2 (/home/bacongobbler/code/bevy_simple_networking)
     Finished dev [unoptimized + debuginfo] target(s) in 8.54s
-     Running `target/debug/examples/server`
-Oct 12 15:17:01.024  INFO server: 127.0.0.1:37810: connected!
-Oct 12 15:17:07.024  INFO server: 127.0.0.1:37810: disconnected!
+     Running `target/debug/examples/simple_server`
+Oct 12 15:17:01.024  INFO simple_server: 127.0.0.1:37810: connected!
+Oct 12 15:17:07.024  INFO simple_server: 127.0.0.1:37810: disconnected!
 ```

examples/chat_client.rs

@@ -0,0 +1,45 @@
+use std::net::{SocketAddr, UdpSocket};
+
+use bevy::{log::LogPlugin, prelude::*};
+use bevy_simple_networking::{ClientPlugin, NetworkEvent};
+
+fn main() {
+    let remote_addr: SocketAddr = "127.0.0.1:4567".parse().expect("could not parse addr");
+    let socket = UdpSocket::bind("[::]:0").expect("could not bind socket");
+    socket
+        .connect(remote_addr)
+        .expect("could not connect to server");
+    socket
+        .set_nonblocking(true)
+        .expect("could not set socket to be nonblocking");
+
+    App::build()
+        .insert_resource(remote_addr)
+        .insert_resource(socket)
+        .add_plugins(MinimalPlugins)
+        .add_plugin(LogPlugin)
+        .add_plugin(ClientPlugin)
+        .add_system(connection_handler.system())
+        .run();
+}
+
+fn connection_handler(mut events: EventReader<NetworkEvent>) {
+    for event in events.iter() {
+        match event {
+            NetworkEvent::Message(_, msg) => {
+                info!("{:?}", msg);
+            }
+            NetworkEvent::SendError(err, msg) => {
+                error!(
+                    "NetworkEvent::SendError (payload [{:?}]): {:?}",
+                    msg.payload, err
+                );
+            }
+            NetworkEvent::RecvError(err) => {
+                error!("NetworkEvent::RecvError: {:?}", err);
+            }
+            // discard irrelevant events
+            _ => {}
+        }
+    }
+}

examples/chat_server.rs

@@ -0,0 +1,61 @@
+use std::{net::UdpSocket, time::Duration};
+
+use bevy::{app::ScheduleRunnerSettings, log::LogPlugin, prelude::*};
+use bevy_simple_networking::{NetworkEvent, NetworkResource, ServerPlugin, Transport};
+
+const LISTEN_ADDRESS: &str = "127.0.0.1:4567";
+
+fn main() {
+    let socket = UdpSocket::bind(LISTEN_ADDRESS).expect("could not bind socket");
+    socket
+        .set_nonblocking(true)
+        .expect("could not set socket to be nonblocking");
+    socket
+        .set_read_timeout(Some(Duration::from_secs(5)))
+        .expect("could not set read timeout");
+
+    info!("Server now listening on {}", LISTEN_ADDRESS);
+
+    App::build()
+        // run the server at a reduced tick rate (100 ticks per minute)
+        .insert_resource(ScheduleRunnerSettings::run_loop(Duration::from_secs_f32(
+            60. / 100.,
+        )))
+        .insert_resource(socket)
+        .add_plugins(MinimalPlugins)
+        .add_plugin(LogPlugin)
+        .add_plugin(ServerPlugin)
+        .add_system(connection_handler.system())
+        .run();
+}
+
+fn connection_handler(
+    net: Res<NetworkResource>,
+    mut events: EventReader<NetworkEvent>,
+    mut transport: ResMut<Transport>,
+) {
+    for event in events.iter() {
+        match event {
+            NetworkEvent::Connected(handle) => {
+                for (addr, _) in net.connections.iter() {
+                    transport.send(*addr, format!("{} has entered the chat", handle).as_bytes());
+                }
+            }
+            NetworkEvent::Disconnected(handle) => {
+                for (addr, _) in net.connections.iter() {
+                    transport.send(*addr, format!("{} has left the chat", handle).as_bytes());
+                }
+            }
+            NetworkEvent::SendError(err, msg) => {
+                info!(
+                    "NetworkEvent::SendError (payload [{:?}]): {:?}",
+                    msg.payload, err
+                );
+            }
+            NetworkEvent::RecvError(err) => {
+                info!("NetworkEvent::RecvError: {:?}", err);
+            }
+            _ => {}
+        }
+    }
+}