Compare commits
No commits in common. "5ea3b8da5beecb56cc094516c3b274f30ed5d7b1" and "b98769687b3d8c33d8a41ebf09aa5b6660ed79bf" have entirely different histories.
5ea3b8da5b
...
b98769687b
2 changed files with 33 additions and 63 deletions
67
src/main.rs
67
src/main.rs
|
@ -9,15 +9,13 @@ use hotwatch::{Event, Hotwatch};
|
||||||
use itertools::Itertools;
|
use itertools::Itertools;
|
||||||
use percent_encoding::{utf8_percent_encode, AsciiSet, CONTROLS};
|
use percent_encoding::{utf8_percent_encode, AsciiSet, CONTROLS};
|
||||||
use serde::Deserialize;
|
use serde::Deserialize;
|
||||||
use std::collections::HashMap;
|
use std::collections::{BTreeMap, HashMap};
|
||||||
use std::fmt;
|
use std::fmt;
|
||||||
use std::fs::{read_to_string, OpenOptions};
|
use std::fs::{File, OpenOptions};
|
||||||
use std::io::Write;
|
use std::io::Write;
|
||||||
use std::sync::{Arc, RwLock};
|
use std::sync::{Arc, RwLock};
|
||||||
use std::time::Duration;
|
use std::time::Duration;
|
||||||
|
|
||||||
mod template_args;
|
|
||||||
|
|
||||||
/// https://url.spec.whatwg.org/#fragment-percent-encode-set
|
/// https://url.spec.whatwg.org/#fragment-percent-encode-set
|
||||||
static FRAGMENT_ENCODE_SET: &AsciiSet =
|
static FRAGMENT_ENCODE_SET: &AsciiSet =
|
||||||
&CONTROLS.add(b' ').add(b'"').add(b'<').add(b'>').add(b'`');
|
&CONTROLS.add(b' ').add(b'"').add(b'<').add(b'>').add(b'`');
|
||||||
|
@ -77,20 +75,23 @@ fn hop(
|
||||||
let data = data.read().unwrap();
|
let data = data.read().unwrap();
|
||||||
|
|
||||||
match resolve_hop(&query.to, &data.routes, &data.default_route) {
|
match resolve_hop(&query.to, &data.routes, &data.default_route) {
|
||||||
(Some(path), args) => HttpResponse::Found()
|
(Some(path), args) => {
|
||||||
|
let mut template_args = HashMap::new();
|
||||||
|
template_args.insert(
|
||||||
|
"query",
|
||||||
|
utf8_percent_encode(&args, FRAGMENT_ENCODE_SET).to_string(),
|
||||||
|
);
|
||||||
|
|
||||||
|
HttpResponse::Found()
|
||||||
.header(
|
.header(
|
||||||
header::LOCATION,
|
header::LOCATION,
|
||||||
data
|
data
|
||||||
.renderer
|
.renderer
|
||||||
.render_template(
|
.render_template(&path, &template_args)
|
||||||
&path,
|
|
||||||
&template_args::query(
|
|
||||||
utf8_percent_encode(&args, FRAGMENT_ENCODE_SET).to_string(),
|
|
||||||
),
|
|
||||||
)
|
|
||||||
.unwrap(),
|
.unwrap(),
|
||||||
)
|
)
|
||||||
.finish(),
|
.finish()
|
||||||
|
}
|
||||||
(None, _) => HttpResponse::NotFound().body("not found"),
|
(None, _) => HttpResponse::NotFound().body("not found"),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -103,7 +104,7 @@ fn hop(
|
||||||
/// returns the remaining arguments. If none remain, an empty string is given.
|
/// returns the remaining arguments. If none remain, an empty string is given.
|
||||||
fn resolve_hop(
|
fn resolve_hop(
|
||||||
query: &str,
|
query: &str,
|
||||||
routes: &HashMap<String, String>,
|
routes: &BTreeMap<String, String>,
|
||||||
default_route: &Option<String>,
|
default_route: &Option<String>,
|
||||||
) -> (Option<String>, String) {
|
) -> (Option<String>, String) {
|
||||||
let mut split_args = query.split_ascii_whitespace().peekable();
|
let mut split_args = query.split_ascii_whitespace().peekable();
|
||||||
|
@ -132,34 +133,23 @@ fn resolve_hop(
|
||||||
#[get("/")]
|
#[get("/")]
|
||||||
fn index(data: Data<Arc<RwLock<State>>>) -> impl Responder {
|
fn index(data: Data<Arc<RwLock<State>>>) -> impl Responder {
|
||||||
let data = data.read().unwrap();
|
let data = data.read().unwrap();
|
||||||
HttpResponse::Ok().body(
|
let mut template_args = HashMap::new();
|
||||||
data
|
template_args.insert("hostname", &data.public_address);
|
||||||
.renderer
|
HttpResponse::Ok()
|
||||||
.render(
|
.body(data.renderer.render("index", &template_args).unwrap())
|
||||||
"index",
|
|
||||||
&template_args::hostname(data.public_address.clone()),
|
|
||||||
)
|
|
||||||
.unwrap(),
|
|
||||||
)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#[get("/bunbunsearch.xml")]
|
#[get("/bunbunsearch.xml")]
|
||||||
fn opensearch(data: Data<Arc<RwLock<State>>>) -> impl Responder {
|
fn opensearch(data: Data<Arc<RwLock<State>>>) -> impl Responder {
|
||||||
let data = data.read().unwrap();
|
let data = data.read().unwrap();
|
||||||
|
let mut template_args = HashMap::new();
|
||||||
|
template_args.insert("hostname", &data.public_address);
|
||||||
HttpResponse::Ok()
|
HttpResponse::Ok()
|
||||||
.header(
|
.header(
|
||||||
header::CONTENT_TYPE,
|
header::CONTENT_TYPE,
|
||||||
"application/opensearchdescription+xml",
|
"application/opensearchdescription+xml",
|
||||||
)
|
)
|
||||||
.body(
|
.body(data.renderer.render("opensearch", &template_args).unwrap())
|
||||||
data
|
|
||||||
.renderer
|
|
||||||
.render(
|
|
||||||
"opensearch",
|
|
||||||
&template_args::hostname(data.public_address.clone()),
|
|
||||||
)
|
|
||||||
.unwrap(),
|
|
||||||
)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Dynamic variables that either need to be present at runtime, or can be
|
/// Dynamic variables that either need to be present at runtime, or can be
|
||||||
|
@ -167,7 +157,7 @@ fn opensearch(data: Data<Arc<RwLock<State>>>) -> impl Responder {
|
||||||
struct State {
|
struct State {
|
||||||
public_address: String,
|
public_address: String,
|
||||||
default_route: Option<String>,
|
default_route: Option<String>,
|
||||||
routes: HashMap<String, String>,
|
routes: BTreeMap<String, String>,
|
||||||
renderer: Handlebars,
|
renderer: Handlebars,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -217,14 +207,14 @@ struct Config {
|
||||||
bind_address: String,
|
bind_address: String,
|
||||||
public_address: String,
|
public_address: String,
|
||||||
default_route: Option<String>,
|
default_route: Option<String>,
|
||||||
routes: HashMap<String, String>,
|
routes: BTreeMap<String, String>,
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Attempts to read the config file. If it doesn't exist, generate one a
|
/// Attempts to read the config file. If it doesn't exist, generate one a
|
||||||
/// default config file before attempting to parse it.
|
/// default config file before attempting to parse it.
|
||||||
fn read_config(config_file_path: &str) -> Result<Config, BunBunError> {
|
fn read_config(config_file_path: &str) -> Result<Config, BunBunError> {
|
||||||
let config_str = match read_to_string(config_file_path) {
|
let config_file = match File::open(config_file_path) {
|
||||||
Ok(conf_str) => conf_str,
|
Ok(file) => file,
|
||||||
Err(_) => {
|
Err(_) => {
|
||||||
eprintln!(
|
eprintln!(
|
||||||
"Unable to find a {} file. Creating default!",
|
"Unable to find a {} file. Creating default!",
|
||||||
|
@ -236,13 +226,10 @@ fn read_config(config_file_path: &str) -> Result<Config, BunBunError> {
|
||||||
.open(config_file_path)
|
.open(config_file_path)
|
||||||
.expect("Unable to write to directory!");
|
.expect("Unable to write to directory!");
|
||||||
fd.write_all(DEFAULT_CONFIG)?;
|
fd.write_all(DEFAULT_CONFIG)?;
|
||||||
String::from_utf8_lossy(DEFAULT_CONFIG).into_owned()
|
File::open(config_file_path)?
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
Ok(serde_yaml::from_reader(config_file)?)
|
||||||
// Reading from memory is faster than reading directly from a reader for some
|
|
||||||
// reason; see https://github.com/serde-rs/json/issues/160
|
|
||||||
Ok(serde_yaml::from_str(&config_str)?)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Returns an instance with all pre-generated templates included into the
|
/// Returns an instance with all pre-generated templates included into the
|
||||||
|
|
|
@ -1,17 +0,0 @@
|
||||||
use serde::Serialize;
|
|
||||||
|
|
||||||
pub fn query(query: String) -> impl Serialize {
|
|
||||||
#[derive(Serialize)]
|
|
||||||
struct TemplateArgs {
|
|
||||||
query: String,
|
|
||||||
}
|
|
||||||
TemplateArgs { query }
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn hostname(hostname: String) -> impl Serialize {
|
|
||||||
#[derive(Serialize)]
|
|
||||||
pub struct TemplateArgs {
|
|
||||||
pub hostname: String,
|
|
||||||
}
|
|
||||||
TemplateArgs { hostname }
|
|
||||||
}
|
|
Loading…
Reference in a new issue