joshuafhiggins/realm-chat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

less logging maybe

Browse Source
This commit is contained in:
Joshua Higgins
2024-10-15 22:36:29 -04:00
Unverified
parent 129b32d168
commit 54a0b7b00b
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
server/src/main.rs
View File

@@ -15,6 +15,7 @@ use tarpc::server::incoming::Incoming;
use tarpc::server::BaseChannel; use tarpc::server::BaseChannel;
use tokio::sync::Mutex; use tokio::sync::Mutex;
use tracing::{info, subscriber, warn}; use tracing::{info, subscriber, warn};
use tracing::instrument::WithSubscriber;
use realm_server::events::*; use realm_server::events::*;
use realm_server::server::RealmChatServer; use realm_server::server::RealmChatServer;
use realm_server::types::{RealmChat}; use realm_server::types::{RealmChat};
@@ -98,7 +99,15 @@ async fn main() -> anyhow::Result<()> {
// the generated World trait. // the generated World trait.
.map(|channel| { .map(|channel| {
let server = RealmChatServer::new(env::var("SERVER_ID").expect("SERVER_ID must be set"), channel.transport().peer_addr().unwrap(), db_pool.clone()); let server = RealmChatServer::new(env::var("SERVER_ID").expect("SERVER_ID must be set"), channel.transport().peer_addr().unwrap(), db_pool.clone());
channel.execute(server.serve()).for_each(spawn) let tarpc_subscriber = tracing_subscriber::fmt()
.compact()
.with_file(false)
.with_line_number(false)
.with_thread_ids(true)
.with_target(false)
.finish();
channel.execute(server.serve()).for_each(spawn).with_subscriber(tarpc_subscriber)
}) })
// Max 10 channels. // Max 10 channels.
.buffer_unordered(4096) .buffer_unordered(4096)