From 4a557a7de3510815ca3bcee7f9e9123dc372da1f Mon Sep 17 00:00:00 2001
From: eraden <adrian.wozniak@ita-prog.pl>
Date: Fri, 26 May 2023 09:11:28 +0200
Subject: [PATCH] Simple queue

---
 crates/event-bus-messages/src/lib.rs |  2 +-
 crates/local-event-bus/src/main.rs   | 13 +++----------
 crates/redis-event-bus/src/lib.rs    |  2 +-
 3 files changed, 5 insertions(+), 12 deletions(-)

diff --git a/crates/event-bus-messages/src/lib.rs b/crates/event-bus-messages/src/lib.rs
index 3eee901..9f79368 100644
--- a/crates/event-bus-messages/src/lib.rs
+++ b/crates/event-bus-messages/src/lib.rs
@@ -5,7 +5,7 @@ pub enum Msg {
 
 #[derive(Debug, serde::Deserialize, serde::Serialize)]
 pub struct Message {
-    pub index: usize,
+    pub offset: usize,
     pub payload: Msg,
 }
 
diff --git a/crates/local-event-bus/src/main.rs b/crates/local-event-bus/src/main.rs
index cef4996..87067f3 100644
--- a/crates/local-event-bus/src/main.rs
+++ b/crates/local-event-bus/src/main.rs
@@ -1,5 +1,6 @@
 use flumedb::*;
 use gumdrop::Options;
+use event_bus_adapter::*;
 
 #[derive(Debug, thiserror::Error)]
 enum Error {}
@@ -15,16 +16,8 @@ struct Opts {
 
 #[async_std::main]
 async fn main() -> Result<(), Error> {
-    let path = {
-        let args = std::env::args();
-        let mut iter = args.into_iter();
-        iter
-            .next();
-        iter.next()
-            .expect("Log file path not found. Please privide path to log file")
-    };
-    eprintln!("File: {path}");
-
+    let opts: Opts = Options::parse_args_default_or_exit();
+    let path = opts.log_path;
     let mut log = OffsetLog::<u32>::from_file(
         std::fs::OpenOptions::new()
             .append(true)
diff --git a/crates/redis-event-bus/src/lib.rs b/crates/redis-event-bus/src/lib.rs
index 381a084..89cbdf0 100644
--- a/crates/redis-event-bus/src/lib.rs
+++ b/crates/redis-event-bus/src/lib.rs
@@ -17,7 +17,7 @@ impl MessageSend for MessageSender {
     async fn send(&mut self, msg: Msg) {
         match (Message {
             payload: msg,
-            index: 0,
+            offset: 0,
         })
         .to_bytes()
         {