1 files changed, 57 insertions, 0 deletions
diff --git a/ofborg/tickborg/src/stats.rs b/ofborg/tickborg/src/stats.rs
new file mode 100644
index 0000000000..16705e6a68
--- /dev/null
+++ b/ofborg/tickborg/src/stats.rs
@@ -0,0 +1,57 @@
+use lapin::options::BasicPublishOptions;
+
+include!(concat!(env!("OUT_DIR"), "/events.rs"));
+
+#[macro_use]
+mod macros {
+    #[macro_export]
+    macro_rules! my_macro(() => (FooBar));
+}
+
+pub trait SysEvents: Send {
+    fn notify(&mut self, event: Event) -> impl std::future::Future<Output = ()>;
+}
+
+#[derive(serde::Serialize, serde::Deserialize, Debug)]
+pub struct EventMessage {
+    pub sender: String,
+    pub events: Vec<Event>,
+}
+
+pub struct RabbitMq<C> {
+    identity: String,
+    channel: C,
+}
+
+impl RabbitMq<lapin::Channel> {
+    pub fn from_lapin(identity: &str, channel: lapin::Channel) -> Self {
+        RabbitMq {
+            identity: identity.to_owned(),
+            channel,
+        }
+    }
+}
+
+impl SysEvents for RabbitMq<lapin::Channel> {
+    async fn notify(&mut self, event: Event) {
+        let props = lapin::BasicProperties::default().with_content_type("application/json".into());
+        let _confirmaton = self
+            .channel
+            .basic_publish(
+                "stats".into(),
+                "".into(),
+                BasicPublishOptions::default(),
+                &serde_json::to_string(&EventMessage {
+                    sender: self.identity.clone(),
+                    events: vec![event],
+                })
+                .unwrap()
+                .into_bytes(),
+                props,
+            )
+            .await
+            .unwrap()
+            .await
+            .unwrap();
+    }
+}