chore: improve project structure

Author: imLinguin

.gitmodules

@@ -1,3 +1,3 @@
-[submodule "src/proto"]
-	path = src/proto
+[submodule "proto"]
+	path = proto
 	url = https://github.com/Yepoleb/gog_protocols

build.rs

@@ -4,15 +4,15 @@ fn main() {
     Codegen::new()
         .protoc()
         .protoc_path(&protoc_bin_vendored::protoc_bin_path().unwrap())
-        .includes(["src/proto"])
-        .input("src/proto/gog.protocols.pb.proto")
-        .input("src/proto/galaxy.protocols.webbroker_service.proto")
-        .input("src/proto/galaxy.protocols.overlay_for_peer.proto")
-        .input("src/proto/galaxy.protocols.communication_service.proto")
-        .input("src/proto/galaxy.common.protocols.peer_to_server.proto")
-        .input("src/proto/galaxy.common.protocols.peer_to_peer.proto")
-        .input("src/proto/galaxy.common.protocols.peer_common.proto")
-        .input("src/proto/galaxy.common.protocols.connection.proto")
+        .includes(["proto"])
+        .input("proto/gog.protocols.pb.proto")
+        .input("proto/galaxy.protocols.webbroker_service.proto")
+        .input("proto/galaxy.protocols.overlay_for_peer.proto")
+        .input("proto/galaxy.protocols.communication_service.proto")
+        .input("proto/galaxy.common.protocols.peer_to_server.proto")
+        .input("proto/galaxy.common.protocols.peer_to_peer.proto")
+        .input("proto/galaxy.common.protocols.peer_common.proto")
+        .input("proto/galaxy.common.protocols.connection.proto")
         .cargo_out_dir("proto")
         .run_from_script();
 }

src/api/handlers.rs

@@ -80,7 +80,6 @@ pub async fn handle_message(
     user_info: Arc<UserInfo>,
     reqwest_client: &Client,
 ) -> Result<(), MessageHandlingError> {
-    info!("Parsing header of size {}", h_size);
     let payload = utils::parse_payload(h_size, socket).await;
 
     let payload = match payload {

src/api/handlers/webbroker.rs

@@ -17,7 +17,7 @@ pub async fn entry_point(payload: &ProtoPayload) -> Result<ProtoPayload, Message
         subscribe_topic_request(payload).await
     } else {
         warn!(
-            "Recieved unsupported webbroker message type {}",
+            "Received unsupported webbroker message type {}",
             message_type
         );
         Err(MessageHandlingError::new(

src/main.rs

@@ -1,7 +1,7 @@
 use std::{collections::HashMap, sync::Arc};
 
 use clap::Parser;
-use env_logger::Env;
+use env_logger::{Env, Target, Builder};
 use log::{error, info, warn};
 use reqwest::Client;
 use tokio::net::TcpListener;
@@ -29,8 +29,8 @@ struct Args {
 #[tokio::main]
 async fn main() {
     let args = Args::parse();
-    let logger_env = Env::new().default_filter_or("info");
-    env_logger::init_from_env(logger_env);
+    let env = Env::new().filter_or("COMET_LOG", "info");
+    Builder::from_env(env).target(Target::Stderr).init();
 
     let access_token: String;
     let refresh_token: String;