add: utility to constantly refresh skubelb
This commit is contained in:
871
Cargo.lock
generated
871
Cargo.lock
generated
File diff suppressed because it is too large
Load Diff
@@ -11,5 +11,6 @@ dir-diff = "0.3.3"
|
|||||||
env_logger = "0.11.7"
|
env_logger = "0.11.7"
|
||||||
include_directory = "0.1.1"
|
include_directory = "0.1.1"
|
||||||
log = "0.4.27"
|
log = "0.4.27"
|
||||||
|
reqwest = { version = "0.12.23", features = ["blocking"] }
|
||||||
rouille = "3.6.2"
|
rouille = "3.6.2"
|
||||||
tempdir = "0.3.7"
|
tempdir = "0.3.7"
|
||||||
|
|||||||
42
src/bin/handler.rs
Normal file
42
src/bin/handler.rs
Normal file
@@ -0,0 +1,42 @@
|
|||||||
|
use std::thread::sleep;
|
||||||
|
use std::time::Duration;
|
||||||
|
|
||||||
|
use clap::Parser;
|
||||||
|
|
||||||
|
use log::error;
|
||||||
|
|
||||||
|
use anyhow::Result;
|
||||||
|
use env_logger::Env;
|
||||||
|
|
||||||
|
/// Implements a client that constantly refreshes with the server.
|
||||||
|
#[derive(Parser, Debug)]
|
||||||
|
#[command(version, about, long_about = None)]
|
||||||
|
struct Args {
|
||||||
|
/// The skubelb server we should register with
|
||||||
|
#[arg(short, long)]
|
||||||
|
server: String,
|
||||||
|
|
||||||
|
/// The listen address that should be sent to skubelb.
|
||||||
|
#[arg(short, long)]
|
||||||
|
listen: String,
|
||||||
|
}
|
||||||
|
|
||||||
|
fn main() {
|
||||||
|
// Log info and above by default
|
||||||
|
env_logger::Builder::from_env(Env::default().default_filter_or("info")).init();
|
||||||
|
let args = Args::parse();
|
||||||
|
|
||||||
|
match handle(&args.server, &args.listen) {
|
||||||
|
Ok(_) => (),
|
||||||
|
Err(e) => error!("{}", e),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn handle(remote: &str, listen: &str) -> Result<()> {
|
||||||
|
let client = reqwest::blocking::Client::new();
|
||||||
|
let url = format!("http://{}/register/{}", remote, listen);
|
||||||
|
loop {
|
||||||
|
sleep(Duration::from_secs(20));
|
||||||
|
client.post(&url).send()?;
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user