git-next/crates/server/src/lib.rs

78 lines
2.1 KiB
Rust
Raw Normal View History

mod actors;
2024-04-07 13:47:39 +01:00
mod config;
pub mod gitforge;
2024-04-07 13:47:39 +01:00
2024-04-07 20:16:04 +01:00
use actix::prelude::*;
use git_next_git::Repository;
2024-05-11 18:57:18 +01:00
use kxio::{fs::FileSystem, network::Network};
2024-04-07 20:16:04 +01:00
use std::path::PathBuf;
use tracing::{error, info, level_filters::LevelFilter};
2024-05-11 18:57:18 +01:00
use crate::actors::{
file_watcher::{self, FileUpdated},
server::Server,
};
2024-04-07 16:09:16 +01:00
pub fn init(fs: FileSystem) {
let file_name = "git-next-server.toml";
2024-04-28 08:05:09 +01:00
let pathbuf = PathBuf::from(file_name);
let Ok(exists) = fs.path_exists(&pathbuf) else {
eprintln!("Could not check if file exist: {}", file_name);
return;
};
if exists {
eprintln!(
"The configuration file already exists at {} - not overwritting it.",
file_name
);
} else {
2024-05-11 18:57:18 +01:00
match fs.file_write(&pathbuf, include_str!("../../../server-default.toml")) {
Ok(_) => println!("Created a default configuration file at {}", file_name),
Err(e) => {
eprintln!("Failed to write to the configuration file: {}", e)
}
}
}
}
pub async fn start(fs: FileSystem, net: Network, repo: Repository) {
init_logging();
info!("Starting Server...");
let server = Server::new(fs.clone(), net.clone(), repo).start();
server.do_send(FileUpdated);
info!("Starting File Watcher...");
let fw = match file_watcher::FileWatcher::new("git-next-server.toml".into(), server.recipient())
{
Ok(fw) => fw,
Err(err) => {
error!(?err, "Failed to start file watcher");
return;
}
};
fw.start();
info!("Server running - Press Ctrl-C to stop...");
let _ = actix_rt::signal::ctrl_c().await;
info!("Ctrl-C received, shutting down...");
}
pub fn init_logging() {
use tracing_subscriber::prelude::*;
let subscriber = tracing_subscriber::fmt::layer()
// NOTE: set RUSTLOG in ${root}/.cargo/config
.with_target(false)
.with_file(true)
.with_line_number(true)
.with_filter(LevelFilter::INFO);
tracing_subscriber::registry()
.with(console_subscriber::ConsoleLayer::builder().spawn())
.with(subscriber)
.init();
}