src: Move projec code to lib

joaoantoniocardoso · Oct 4, 2024 · 4334383 · 4334383
1 parent 83f683d
commit 4334383
Show file tree

Hide file tree

Showing 32 changed files with 23 additions and 20 deletions.
diff --git a/src/cli.rs → src/lib/cli.rs b/src/cli.rs → src/lib/cli.rs
diff --git a/src/drivers/fake.rs → src/lib/drivers/fake.rs b/src/drivers/fake.rs → src/lib/drivers/fake.rs
@@ -1,11 +1,11 @@
 use std::sync::Arc;
 
 use anyhow::Result;
-use mavlink_server::callbacks::{Callbacks, MessageCallback};
 use tokio::sync::{broadcast, RwLock};
 use tracing::*;
 
 use crate::{
+    callbacks::{Callbacks, MessageCallback},
     drivers::{Driver, DriverInfo},
     protocol::{read_all_messages, Protocol},
     stats::{

diff --git a/src/drivers/mod.rs → src/lib/drivers/mod.rs b/src/drivers/mod.rs → src/lib/drivers/mod.rs
@@ -231,11 +231,13 @@ mod tests {
 
     use anyhow::{anyhow, Result};
     use mavlink::MAVLinkV2MessageRaw;
-    use mavlink_server::callbacks::{Callbacks, MessageCallback};
     use tokio::sync::RwLock;
     use tracing::*;
 
-    use crate::stats::{accumulated::driver::AccumulatedDriverStats, driver::DriverUuid};
+    use crate::{
+        callbacks::{Callbacks, MessageCallback},
+        stats::{accumulated::driver::AccumulatedDriverStats, driver::DriverUuid},
+    };
 
     use super::*;
 

diff --git a/src/drivers/rest/data.rs → src/lib/drivers/rest/data.rs b/src/drivers/rest/data.rs → src/lib/drivers/rest/data.rs
diff --git a/src/drivers/rest/mod.rs → src/lib/drivers/rest/mod.rs b/src/drivers/rest/mod.rs → src/lib/drivers/rest/mod.rs
@@ -3,12 +3,12 @@ pub mod data;
 use std::sync::Arc;
 
 use anyhow::Result;
-use mavlink_server::callbacks::{Callbacks, MessageCallback};
 use serde::{Deserialize, Serialize};
 use tokio::sync::{broadcast, RwLock};
 use tracing::*;
 
 use crate::{
+    callbacks::{Callbacks, MessageCallback},
     drivers::{Driver, DriverInfo},
     protocol::Protocol,
     stats::{

diff --git a/src/drivers/serial/mod.rs → src/lib/drivers/serial/mod.rs b/src/drivers/serial/mod.rs → src/lib/drivers/serial/mod.rs
@@ -1,7 +1,6 @@
 use std::sync::Arc;
 
 use anyhow::Result;
-use mavlink_server::callbacks::{Callbacks, MessageCallback};
 use tokio::{
     io::{AsyncReadExt, AsyncWriteExt},
     sync::{broadcast, Mutex, RwLock},
@@ -10,6 +9,7 @@ use tokio_serial::{self, SerialPortBuilderExt};
 use tracing::*;
 
 use crate::{
+    callbacks::{Callbacks, MessageCallback},
     drivers::{Driver, DriverInfo},
     protocol::{read_all_messages, Protocol},
     stats::{

diff --git a/src/drivers/tcp/client.rs → src/lib/drivers/tcp/client.rs b/src/drivers/tcp/client.rs → src/lib/drivers/tcp/client.rs
@@ -1,14 +1,14 @@
 use std::sync::Arc;
 
 use anyhow::Result;
-use mavlink_server::callbacks::{Callbacks, MessageCallback};
 use tokio::{
     net::TcpStream,
     sync::{broadcast, RwLock},
 };
 use tracing::*;
 
 use crate::{
+    callbacks::{Callbacks, MessageCallback},
     drivers::{
         tcp::{tcp_receive_task, tcp_send_task},
         Driver, DriverInfo,

diff --git a/src/drivers/tcp/mod.rs → src/lib/drivers/tcp/mod.rs b/src/drivers/tcp/mod.rs → src/lib/drivers/tcp/mod.rs
@@ -1,7 +1,6 @@
 use std::sync::Arc;
 
 use anyhow::Result;
-use mavlink_server::callbacks::Callbacks;
 use tokio::{
     io::{AsyncReadExt, AsyncWriteExt},
     net::tcp::{OwnedReadHalf, OwnedWriteHalf},
@@ -10,6 +9,7 @@ use tokio::{
 use tracing::*;
 
 use crate::{
+    callbacks::Callbacks,
     protocol::{read_all_messages, Protocol},
     stats::accumulated::driver::AccumulatedDriverStats,
 };

diff --git a/src/drivers/tcp/server.rs → src/lib/drivers/tcp/server.rs b/src/drivers/tcp/server.rs → src/lib/drivers/tcp/server.rs
@@ -1,14 +1,14 @@
 use std::sync::Arc;
 
 use anyhow::Result;
-use mavlink_server::callbacks::{Callbacks, MessageCallback};
 use tokio::{
     net::{TcpListener, TcpStream},
     sync::{broadcast, RwLock},
 };
 use tracing::*;
 
 use crate::{
+    callbacks::{Callbacks, MessageCallback},
     drivers::{
         tcp::{tcp_receive_task, tcp_send_task},
         Driver, DriverInfo,

diff --git a/src/drivers/tlog/mod.rs → src/lib/drivers/tlog/mod.rs b/src/drivers/tlog/mod.rs → src/lib/drivers/tlog/mod.rs
diff --git a/src/drivers/tlog/reader.rs → src/lib/drivers/tlog/reader.rs b/src/drivers/tlog/reader.rs → src/lib/drivers/tlog/reader.rs
@@ -3,11 +3,11 @@ use std::{path::PathBuf, sync::Arc};
 use anyhow::{Context, Result};
 use chrono::DateTime;
 use mavlink::ardupilotmega::MavMessage;
-use mavlink_server::callbacks::{Callbacks, MessageCallback};
 use tokio::sync::{broadcast, RwLock};
 use tracing::*;
 
 use crate::{
+    callbacks::{Callbacks, MessageCallback},
     drivers::{Driver, DriverInfo},
     protocol::Protocol,
     stats::{

diff --git a/src/drivers/tlog/writer.rs → src/lib/drivers/tlog/writer.rs b/src/drivers/tlog/writer.rs → src/lib/drivers/tlog/writer.rs
@@ -1,14 +1,14 @@
 use std::{path::PathBuf, sync::Arc};
 
 use anyhow::Result;
-use mavlink_server::callbacks::{Callbacks, MessageCallback};
 use tokio::{
     io::{AsyncWriteExt, BufWriter},
     sync::{broadcast, RwLock},
 };
 use tracing::*;
 
 use crate::{
+    callbacks::{Callbacks, MessageCallback},
     drivers::{Driver, DriverInfo},
     protocol::Protocol,
     stats::{

diff --git a/src/drivers/udp/client.rs → src/lib/drivers/udp/client.rs b/src/drivers/udp/client.rs → src/lib/drivers/udp/client.rs
@@ -1,14 +1,14 @@
 use std::sync::Arc;
 
 use anyhow::Result;
-use mavlink_server::callbacks::{Callbacks, MessageCallback};
 use tokio::{
     net::UdpSocket,
     sync::{broadcast, RwLock},
 };
 use tracing::*;
 
 use crate::{
+    callbacks::{Callbacks, MessageCallback},
     drivers::{Driver, DriverInfo},
     protocol::{read_all_messages, Protocol},
     stats::{

diff --git a/src/drivers/udp/mod.rs → src/lib/drivers/udp/mod.rs b/src/drivers/udp/mod.rs → src/lib/drivers/udp/mod.rs
diff --git a/src/drivers/udp/server.rs → src/lib/drivers/udp/server.rs b/src/drivers/udp/server.rs → src/lib/drivers/udp/server.rs
@@ -1,14 +1,14 @@
 use std::{collections::HashMap, sync::Arc};
 
 use anyhow::Result;
-use mavlink_server::callbacks::{Callbacks, MessageCallback};
 use tokio::{
     net::UdpSocket,
     sync::{broadcast, RwLock},
 };
 use tracing::*;
 
 use crate::{
+    callbacks::{Callbacks, MessageCallback},
     drivers::{Driver, DriverInfo},
     protocol::{read_all_messages, Protocol},
     stats::{

diff --git a/src/hub/actor.rs → src/lib/hub/actor.rs b/src/hub/actor.rs → src/lib/hub/actor.rs
diff --git a/src/hub/mod.rs → src/lib/hub/mod.rs b/src/hub/mod.rs → src/lib/hub/mod.rs
diff --git a/src/hub/protocol.rs → src/lib/hub/protocol.rs b/src/hub/protocol.rs → src/lib/hub/protocol.rs
diff --git a/src/logger.rs → src/lib/logger.rs b/src/logger.rs → src/lib/logger.rs
diff --git a/src/lib/mod.rs b/src/lib/mod.rs
@@ -1 +1,8 @@
 pub mod callbacks;
+pub mod cli;
+pub mod drivers;
+pub mod hub;
+pub mod logger;
+pub mod protocol;
+pub mod stats;
+pub mod web;
diff --git a/src/protocol.rs → src/lib/protocol.rs b/src/protocol.rs → src/lib/protocol.rs
diff --git a/src/stats/accumulated/driver.rs → src/lib/stats/accumulated/driver.rs b/src/stats/accumulated/driver.rs → src/lib/stats/accumulated/driver.rs
diff --git a/src/stats/accumulated/messages.rs → src/lib/stats/accumulated/messages.rs b/src/stats/accumulated/messages.rs → src/lib/stats/accumulated/messages.rs
diff --git a/src/stats/accumulated/mod.rs → src/lib/stats/accumulated/mod.rs b/src/stats/accumulated/mod.rs → src/lib/stats/accumulated/mod.rs
diff --git a/src/stats/actor.rs → src/lib/stats/actor.rs b/src/stats/actor.rs → src/lib/stats/actor.rs
diff --git a/src/stats/driver.rs → src/lib/stats/driver.rs b/src/stats/driver.rs → src/lib/stats/driver.rs
diff --git a/src/stats/messages.rs → src/lib/stats/messages.rs b/src/stats/messages.rs → src/lib/stats/messages.rs
diff --git a/src/stats/mod.rs → src/lib/stats/mod.rs b/src/stats/mod.rs → src/lib/stats/mod.rs
diff --git a/src/stats/protocol.rs → src/lib/stats/protocol.rs b/src/stats/protocol.rs → src/lib/stats/protocol.rs
diff --git a/src/web/endpoints.rs → src/lib/web/endpoints.rs b/src/web/endpoints.rs → src/lib/web/endpoints.rs
diff --git a/src/web/mod.rs → src/lib/web/mod.rs b/src/web/mod.rs → src/lib/web/mod.rs
diff --git a/src/main.rs b/src/main.rs
@@ -1,14 +1,8 @@
-mod cli;
-mod drivers;
-mod hub;
-mod logger;
-mod protocol;
-mod stats;
-mod web;
-
 use anyhow::*;
 use tracing::*;
 
+use mavlink_server::{cli, hub, logger, web};
+
 #[tokio::main(flavor = "multi_thread", worker_threads = 10)]
 async fn main() -> Result<()> {
     // CLI should be started before logger to allow control over verbosity