refactor show_question_details

This commit is contained in:
Dmitry Belyaev 2022-10-04 00:07:25 +03:00
parent b3fcc66b1b
commit 0f837db0a2
Signed by: b4tman
GPG Key ID: 41A00BF15EA7E5F3
3 changed files with 45 additions and 48 deletions

2
Cargo.lock generated
View File

@ -1026,7 +1026,7 @@ dependencies = [
[[package]] [[package]]
name = "qchgk_web" name = "qchgk_web"
version = "0.1.0" version = "0.1.1"
dependencies = [ dependencies = [
"ledb", "ledb",
"ledb-derive", "ledb-derive",

View File

@ -1,6 +1,6 @@
[package] [package]
name = "qchgk_web" name = "qchgk_web"
version = "0.1.0" version = "0.1.1"
authors = ["Dmitry <b4tm4n@mail.ru>"] authors = ["Dmitry <b4tm4n@mail.ru>"]
edition = "2021" edition = "2021"

View File

@ -9,11 +9,6 @@ extern crate serde_json;
extern crate ledb_derive; extern crate ledb_derive;
extern crate ledb_types; extern crate ledb_types;
//#[macro_use]
//extern crate tera;
//use tera::Context;
#[macro_use] #[macro_use]
extern crate rocket; extern crate rocket;
extern crate rocket_contrib; extern crate rocket_contrib;
@ -28,6 +23,18 @@ use rand::Rng;
use ledb::{Options, Storage}; use ledb::{Options, Storage};
trait ErrorEmpty {
type Output;
fn err_empty(self) -> Result<Self::Output, ()>;
}
impl<T, E> ErrorEmpty for Result<T, E> {
type Output = T;
fn err_empty(self) -> Result<Self::Output, ()> {
self.map_err(|_| ())
}
}
#[derive(Debug, Default, Clone, Serialize, Deserialize, Document)] #[derive(Debug, Default, Clone, Serialize, Deserialize, Document)]
struct BatchInfo { struct BatchInfo {
#[document(primary)] #[document(primary)]
@ -120,66 +127,53 @@ fn random_question_id(database_distribution: &Uniform<u32>) -> u32 {
rng.sample(database_distribution) rng.sample(database_distribution)
} }
fn get_question(storage: &Storage, id: u32) -> Result<Option<Question>, ()> { fn get_question(storage: &Storage, id: u32) -> Result<Question, ()> {
if 0 == id { storage
return Ok(None);
}
let collection = storage
.collection("questions") .collection("questions")
.expect("collection \"questions\""); .err_empty()?
let last_id = collection.last_id().expect("\"questions\" last_id"); .get::<Question>(id)
.err_empty()?
if id > last_id { .ok_or(())
Err(())
} else {
let question = collection.get::<Question>(id);
if question.is_err() {
Err(())
} else {
Ok(question.unwrap())
}
}
} }
fn show_question_details( fn show_question_details(template_name: &'static str, data: &AppState, id: u32) -> Template {
template_name: &'static str, match get_question(&data.storage, id) {
data: &AppState, Ok(question) => {
id: u32,
) -> Result<Template, Redirect> {
let question = get_question(&data.storage, id);
if question.is_ok() {
let question = question.unwrap();
if question.is_some() {
let question = question.unwrap();
let mut context = serde_json::to_value(question).expect("question serialize"); let mut context = serde_json::to_value(question).expect("question serialize");
if context.is_object() { if context.is_object() {
let next_id = random_question_id(&data.database_distribution); let next_id = random_question_id(&data.database_distribution);
context["next"] = serde_json::to_value(next_id).expect("question id serialize"); context["next"] = serde_json::to_value(next_id).expect("question id serialize");
} }
Ok(Template::render(template_name, &context)) Template::render(template_name, &context)
} else {
Err(Redirect::permanent("/q/"))
} }
} else { Err(_) => {
use std::collections::HashMap; use std::collections::HashMap;
let context: HashMap<String, String> = HashMap::new(); let context: HashMap<String, String> = HashMap::new();
Ok(Template::render("404", &context)) Template::render("404", &context)
}
} }
} }
#[get("/q/<id>")] #[get("/q/<id>")]
fn show_question(data: State<AppState>, id: u32) -> Result<Template, Redirect> { fn show_question(data: State<AppState>, id: u32) -> Template {
show_question_details("question", data.inner(), id) show_question_details("question", data.inner(), id)
} }
#[get("/q/<id>/a")] #[get("/q/<id>/a")]
fn show_answer(data: State<AppState>, id: u32) -> Result<Template, Redirect> { fn show_answer(data: State<AppState>, id: u32) -> Template {
show_question_details("answer", data.inner(), id) show_question_details("answer", data.inner(), id)
} }
#[get("/q/0")]
fn question0() -> Redirect {
Redirect::to("/")
}
#[get("/q/0/a")]
fn answer0() -> Redirect {
Redirect::to("/")
}
#[get("/")] #[get("/")]
fn index(data: State<AppState>) -> Redirect { fn index(data: State<AppState>) -> Redirect {
let id = random_question_id(&data.database_distribution); let id = random_question_id(&data.database_distribution);
@ -211,7 +205,10 @@ fn rocket() -> Rocket {
rocket::ignite() rocket::ignite()
.manage(state) .manage(state)
.register(catchers![not_found]) .register(catchers![not_found])
.mount("/", routes![index, show_question, show_answer]) .mount(
"/",
routes![index, show_question, show_answer, question0, answer0],
)
.mount("/q", routes![index]) .mount("/q", routes![index])
.mount("/q/static", StaticFiles::from("static/")) .mount("/q/static", StaticFiles::from("static/"))
.attach(Template::fairing()) .attach(Template::fairing())