Paul Campbell
fd762e2bd2
All checks were successful
Rust / build (push) Successful in 1m50s
ci/woodpecker/push/cron-docker-builder Pipeline was successful
ci/woodpecker/push/push-next Pipeline was successful
ci/woodpecker/push/tag-created Pipeline was successful
ci/woodpecker/cron/cron-docker-builder Pipeline was successful
ci/woodpecker/cron/push-next Pipeline was successful
ci/woodpecker/cron/tag-created Pipeline was successful
Closes kemitix/git-next#94 Controlled shutdown includes attempting to unregister webhooks.
86 lines
2.6 KiB
Rust
86 lines
2.6 KiB
Rust
//
|
|
use actix::prelude::*;
|
|
use git_next_file_watcher_actor::{FileUpdated, FileWatcher};
|
|
use git_next_server_actor::Server;
|
|
use kxio::{fs::FileSystem, network::Network};
|
|
use std::path::PathBuf;
|
|
use tracing::{error, info, level_filters::LevelFilter};
|
|
|
|
pub use git_next_server_actor::{repository_factory, RepositoryFactory};
|
|
|
|
pub fn init(fs: FileSystem) {
|
|
let file_name = "git-next-server.toml";
|
|
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 {
|
|
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 fn start(
|
|
fs: FileSystem,
|
|
net: Network,
|
|
repo: Box<dyn RepositoryFactory>,
|
|
sleep_duration: std::time::Duration,
|
|
) {
|
|
init_logging();
|
|
|
|
info!("Starting Server...");
|
|
let execution = async move {
|
|
let server = Server::new(fs.clone(), net.clone(), repo, sleep_duration).start();
|
|
server.do_send(FileUpdated);
|
|
|
|
info!("Starting File Watcher...");
|
|
let fw = match FileWatcher::new("git-next-server.toml".into(), server.clone().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...");
|
|
server.do_send(git_next_server_actor::messages::Shutdown);
|
|
System::current().stop();
|
|
};
|
|
let system = System::new();
|
|
Arbiter::current().spawn(execution);
|
|
if let Err(err) = system.run() {
|
|
tracing::error!(?err, "")
|
|
};
|
|
}
|
|
|
|
pub fn init_logging() {
|
|
use tracing_subscriber::prelude::*;
|
|
use tracing_subscriber::EnvFilter;
|
|
|
|
let subscriber = tracing_subscriber::fmt::layer()
|
|
.with_target(false)
|
|
.with_file(true)
|
|
.with_line_number(true)
|
|
.with_filter(
|
|
EnvFilter::builder()
|
|
.with_default_directive(LevelFilter::INFO.into())
|
|
.from_env_lossy(),
|
|
);
|
|
tracing_subscriber::registry()
|
|
.with(console_subscriber::ConsoleLayer::builder().spawn())
|
|
.with(subscriber)
|
|
.init();
|
|
}
|