Add the default channels as described in RFC 0003

eventbus.yml

@@ -8,13 +8,15 @@ heartbeat: 30
 #
 # NOTE: there is a default "all" channel which is used to broadcast information
 # to all clients.
-channels:
+#
-  # Stateful channels where clients may reconnect and pick up where they left
+# WARN: Channels are not merged with the default configuration, and will overwrite
-  # off in the channel
+# channels:
-  stateful:
+#   stateful:
-    - tasks
+#     - audit
-    - audit
+#     - tasks.for_auction
-  # Stateless channels are those which operate on a "pub/sub" model, if a
+#     - tasks.auction
-  # client misses a message, it's gone
+#     - tasks.bids
-  stateless:
+#   stateless:
-    - all
+#     - all
+#     - tasks.started
+#     - tasks.finished

eventbus/src/lib.rs

@@ -7,6 +7,7 @@ extern crate serde_json;
 
 use actix::Message;
 use serde::{Deserialize, Serialize};
+use serde_json::Value;
 
 pub mod bus;
 pub mod client;
@@ -35,5 +36,9 @@ pub enum Command {
          * The channel the client wishes to unsubscribe from
          */
         channel: String,
-    }
+    },
+    Publish {
+        channel: String,
+        payload: Value,
+    },
 }

eventbus/static/eventbus.yml

@@ -5,5 +5,10 @@ heartbeat: 60
 channels:
   stateful:
     - audit
+    - tasks.for_auction
+    - tasks.auction
+    - tasks.bids
   stateless:
     - all
+    - tasks.started
+    - tasks.finished