36 lines
1.1 KiB
Rust
36 lines
1.1 KiB
Rust
|
use std::sync::{Arc, LazyLock};
|
||
|
|
|
||
|
|
use anyhow::Result;
|
||
|
|
use common::config_util;
|
||
|
|
use config::ServiceConfig;
|
||
|
|
use session::SessionManager;
|
||
|
|
|
||
|
|
mod config;
|
||
|
|
mod gateway_connection;
|
||
|
|
mod logic;
|
||
|
|
mod player_save_task;
|
||
|
|
mod service_message_handler;
|
||
|
|
mod session;
|
||
|
|
|
||
|
|
#[tokio::main]
|
||
|
|
async fn main() -> Result<()> {
|
||
|
|
static CONFIG: LazyLock<ServiceConfig> =
|
||
|
|
LazyLock::new(|| config_util::load_or_create("gameserver.toml"));
|
||
|
|
static SESSION_MGR: LazyLock<SessionManager> = LazyLock::new(SessionManager::default);
|
||
|
|
|
||
|
|
::common::splash::print_splash();
|
||
|
|
::common::logging::init(::tracing::Level::DEBUG);
|
||
|
|
shorekeeper_data::load_json_data("assets/logic/json")?;
|
||
|
|
|
||
|
|
let database = Arc::new(shorekeeper_database::connect_to(&CONFIG.database).await?);
|
||
|
|
shorekeeper_database::run_migrations(database.as_ref()).await?;
|
||
|
|
|
||
|
|
logic::thread_mgr::start_logic_threads(1);
|
||
|
|
|
||
|
|
player_save_task::start(database.clone());
|
||
|
|
gateway_connection::init(CONFIG.service_id, &CONFIG.gateway_end_point);
|
||
|
|
service_message_handler::run(&CONFIG.service_end_point, &SESSION_MGR, database).await?;
|
||
|
|
|
||
|
|
Ok(())
|
||
|
|
}
|