refactor: 🔨 move bus module to root

.vscode/settings.json

@@ -33,6 +33,6 @@
         "rustler.db-shm": true,
         "rustler.db-wal": true,
         "rustler.db.bkp": true
-    }
-    // "editor.formatOnSave": true
+    },
+    "editor.formatOnSave": true
 }

examples/bus-pub.rs

@@ -3,9 +3,9 @@ mod binance;
 use {
     eyre::{set_hook, DefaultHandler, Result},
     lool::s,
-    rustler_core::rustlers::{
+    rustler_core::{
         bus::{self, PublisherTrait},
-        MarketHourType, Quote,
+        rustlers::{MarketHourType, Quote},
     },
 };
 

examples/bus-sub.rs

@@ -1,8 +1,8 @@
 use {
     eyre::{set_hook, DefaultHandler, Result},
-    rustler_core::rustlers::{
+    rustler_core::{
         bus::{self, SubscriberTrait},
-        Quote, Ticker,
+        rustlers::{Quote, Ticker},
     },
     rxrust::observable::{ObservableExt, ObservableItem},
 };

examples/rustler.rs

@@ -6,9 +6,10 @@ use {
     eyre::{set_hook, DefaultHandler, Result},
     lool::logger::{info, ConsoleLogger, Level},
     rustler_core::{
+        bus,
         entities::db::get_connection,
         grpc, rustlerjar,
-        rustlers::{bus, svc::RustlersSvc, Quote},
+        rustlers::{svc::RustlersSvc, Quote},
     },
     tokio::join,
 };

lib/bus/redis/publish.rs

@@ -1,6 +1,6 @@
 use {
     super::{key, BusMessage, PrefixedPubSub, RedisClient, KEY_PREFIX},
-    crate::rustlers::bus::PublisherTrait,
+    crate::bus::PublisherTrait,
     eyre::Result,
     redis::{aio::MultiplexedConnection, AsyncCommands},
     tonic::async_trait,

lib/bus/redis/subscribe.rs

@@ -1,6 +1,6 @@
 use {
     super::{key, PrefixedPubSub, RedisClient, KEY_PREFIX},
-    crate::rustlers::bus::{BusMessage, SubscriberTrait},
+    crate::bus::{BusMessage, SubscriberTrait},
     eyre::Result,
     futures::StreamExt,
     lool::{fail, s},

lib/lib.rs

@@ -1,3 +1,4 @@
+pub mod bus;
 pub mod entities;
 pub mod grpc;
 pub mod rustlers;

lib/rustlers/mod.rs

@@ -1,6 +1,5 @@
 mod rustler;
 
-pub mod bus;
 pub mod rustlerjar;
 pub mod svc;
 pub use rustler::*;

lib/rustlers/rustler.rs

@@ -2,11 +2,11 @@ pub extern crate chrono;
 pub extern crate eyre;
 
 use {
-    super::{
+    super::svc::RustlerMsg,
+    crate::{
         bus::{BusMessage, ToBusKey, ToBusVal, ToFromBusMessage},
-        svc::RustlerMsg,
+        entities::{market, ticker},
     },
-    crate::entities::{market, ticker},
     async_trait::async_trait,
     chrono::{DateTime, Local},
     eyre::Result,

lib/rustlers/svc.rs

@@ -5,8 +5,9 @@ use {
         MarketHourType,
     },
     crate::{
+        bus::PublisherTrait,
         entities::{market, sea_orm::DatabaseConnection, ticker},
-        rustlers::{bus::PublisherTrait, Quote},
+        rustlers::Quote,
     },
     eyre::Result,
     lool::{

🐎 rustler-core.code-workspace

@@ -17,7 +17,7 @@
             {
                 "name": "redis",
                 "base": "database",
-                "color": "deep-orange-400",
+                "color": "red-400",
                 "folderNames": ["redis"]
             },
             {