Compare commits
3 Commits
aec2e87472
...
665bbaadfb
| Author | SHA1 | Date | |
|---|---|---|---|
|
665bbaadfb
|
|||
|
fb40a5a862
|
|||
|
2a6cd616be
|
1689
Cargo.lock
generated
1689
Cargo.lock
generated
File diff suppressed because it is too large
Load Diff
23
Cargo.toml
23
Cargo.toml
@@ -6,19 +6,26 @@ edition = "2018"
|
||||
|
||||
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
||||
|
||||
|
||||
[dependencies]
|
||||
actix-files="0.1"
|
||||
actix-web = "1.0"
|
||||
rand="0.7"
|
||||
serde="1.0"
|
||||
serde_derive="1.0"
|
||||
serde_json="1.0"
|
||||
ledb="0.2"
|
||||
ledb-derive="0.2"
|
||||
ledb-types="0.2"
|
||||
lmdb-zero="0.4"
|
||||
rand="0.7"
|
||||
env_logger = "0.6"
|
||||
tera = "0.11"
|
||||
# actix="0.7"
|
||||
# tokio="0.1"
|
||||
# futures="0.1"
|
||||
rocket="0.4"
|
||||
|
||||
# lmdb-zero="0.4"
|
||||
|
||||
[dependencies.rocket_contrib]
|
||||
version = "0.4"
|
||||
default-features = false
|
||||
features = ["serve", "tera_templates"]
|
||||
|
||||
[profile.release]
|
||||
opt-level = 3
|
||||
debug = false
|
||||
lto = true
|
||||
|
||||
193
src/main.rs
193
src/main.rs
@@ -1,45 +1,30 @@
|
||||
// extern crate actix;
|
||||
extern crate actix_files;
|
||||
extern crate actix_web;
|
||||
#![feature(proc_macro_hygiene, decl_macro)]
|
||||
|
||||
extern crate serde;
|
||||
#[macro_use]
|
||||
extern crate serde_derive;
|
||||
#[macro_use]
|
||||
extern crate ledb;
|
||||
extern crate serde_json;
|
||||
#[macro_use]
|
||||
extern crate ledb;
|
||||
#[macro_use]
|
||||
extern crate ledb_derive;
|
||||
extern crate env_logger;
|
||||
extern crate ledb_types;
|
||||
|
||||
//#[macro_use]
|
||||
//extern crate tera;
|
||||
|
||||
//use tera::Context;
|
||||
|
||||
#[macro_use]
|
||||
extern crate tera;
|
||||
extern crate rocket;
|
||||
extern crate rocket_contrib;
|
||||
|
||||
use tera::Context;
|
||||
use rocket::response::Redirect;
|
||||
use rocket::{Rocket, State};
|
||||
use rocket_contrib::serve::StaticFiles;
|
||||
use rocket_contrib::templates::Template;
|
||||
|
||||
// extern crate futures;
|
||||
|
||||
// extern crate tokio;
|
||||
|
||||
use actix_web::{
|
||||
error, guard, http::header, http::Method, middleware::Logger, middleware::NormalizePath, web,
|
||||
App, Error, HttpRequest, HttpResponse, HttpServer, Responder, Result,
|
||||
};
|
||||
use std::cell::Cell;
|
||||
|
||||
use rand::seq::IteratorRandom;
|
||||
use std::time::Instant;
|
||||
|
||||
use std::{fs, io};
|
||||
// use tokio::spawn;
|
||||
// use futures::{Future};
|
||||
|
||||
// use actix::Actor;
|
||||
// use actix::System;
|
||||
|
||||
//use crate::tokio::prelude::Future;
|
||||
|
||||
//use ledb_actix::{Document, Options, Storage, StorageAddrExt};
|
||||
use rand::distributions::Uniform;
|
||||
use rand::Rng;
|
||||
|
||||
use ledb::{Options, Storage};
|
||||
|
||||
@@ -118,32 +103,50 @@ struct Question {
|
||||
|
||||
struct AppState {
|
||||
storage: Storage,
|
||||
template: tera::Tera,
|
||||
database_distribution: Uniform<u32>,
|
||||
}
|
||||
|
||||
fn get_question(storage: &Storage, id: u32) -> Result<Option<Question>, Error> {
|
||||
fn get_database_distribution(storage: &Storage) -> Uniform<u32> {
|
||||
let collection = storage
|
||||
.collection("questions")
|
||||
.expect("collection \"questions\"");
|
||||
let last_id = collection.last_id().expect("\"questions\" last_id");
|
||||
|
||||
rand::distributions::Uniform::new_inclusive(1u32, last_id)
|
||||
}
|
||||
|
||||
fn random_question_id(database_distribution: &Uniform<u32>) -> u32 {
|
||||
let mut rng = rand::thread_rng();
|
||||
rng.sample(database_distribution)
|
||||
}
|
||||
|
||||
fn get_question(storage: &Storage, id: u32) -> Result<Option<Question>, ()> {
|
||||
if 0 == id {
|
||||
return Ok(None);
|
||||
}
|
||||
|
||||
let collection = storage.collection("questions").unwrap();
|
||||
let last_id = collection.last_id().unwrap();
|
||||
let collection = storage
|
||||
.collection("questions")
|
||||
.expect("collection \"questions\"");
|
||||
let last_id = collection.last_id().expect("\"questions\" last_id");
|
||||
|
||||
if id > last_id {
|
||||
Err(Error::from(()))
|
||||
Err(())
|
||||
} else {
|
||||
let question = collection.get::<Question>(id);
|
||||
if question.is_err() {
|
||||
Err(Error::from(()))
|
||||
Err(())
|
||||
} else {
|
||||
Ok(question.unwrap())
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
fn show_question_details(template_file: &str, data: web::Data<AppState>, id: web::Path<u32>) -> Result<HttpResponse, Error> {
|
||||
let id = id.into_inner();
|
||||
|
||||
fn show_question_details(
|
||||
template_name: &'static str,
|
||||
data: &AppState,
|
||||
id: u32,
|
||||
) -> Result<Template, Redirect> {
|
||||
let question = get_question(&data.storage, id);
|
||||
|
||||
if question.is_ok() {
|
||||
@@ -151,85 +154,69 @@ fn show_question_details(template_file: &str, data: web::Data<AppState>, id: web
|
||||
|
||||
if question.is_some() {
|
||||
let question = question.unwrap();
|
||||
let body = data.template.render(template_file, &question).unwrap();
|
||||
Ok(HttpResponse::Ok().content_type("text/html").body(body))
|
||||
let mut context = serde_json::to_value(question).expect("question serialize");
|
||||
if context.is_object() {
|
||||
let next_id = random_question_id(&data.database_distribution);
|
||||
context["next"] = serde_json::to_value(next_id).expect("question id serialize");
|
||||
}
|
||||
Ok(Template::render(template_name, &context))
|
||||
} else {
|
||||
Ok(HttpResponse::Found()
|
||||
.header(header::LOCATION, "/q/")
|
||||
.finish())
|
||||
Err(Redirect::permanent("/q/"))
|
||||
}
|
||||
} else {
|
||||
let context = Context::new();
|
||||
Ok(HttpResponse::with_body(
|
||||
actix_web::http::StatusCode::NOT_FOUND,
|
||||
actix_web::dev::Body::from(data.template.render("404.html", &context).unwrap()),
|
||||
))
|
||||
use std::collections::HashMap;
|
||||
let context: HashMap<String, String> = HashMap::new();
|
||||
Ok(Template::render("404", &context))
|
||||
}
|
||||
}
|
||||
|
||||
fn show_question(data: web::Data<AppState>, id: web::Path<u32>) -> Result<HttpResponse, Error> {
|
||||
show_question_details("question.html", data, id)
|
||||
#[get("/q/<id>")]
|
||||
fn show_question(data: State<AppState>, id: u32) -> Result<Template, Redirect> {
|
||||
show_question_details("question", data.inner(), id)
|
||||
}
|
||||
|
||||
fn show_answer(data: web::Data<AppState>, id: web::Path<u32>) -> Result<HttpResponse, Error> {
|
||||
show_question_details("answer.html", data, id)
|
||||
#[get("/q/<id>/a")]
|
||||
fn show_answer(data: State<AppState>, id: u32) -> Result<Template, Redirect> {
|
||||
show_question_details("answer", data.inner(), id)
|
||||
}
|
||||
|
||||
fn index(data: web::Data<AppState>, req: HttpRequest) -> Result<HttpResponse, Error> {
|
||||
let collection = data.storage.collection("questions").unwrap();
|
||||
let mut rng = rand::thread_rng();
|
||||
let last_id = collection.last_id().unwrap();
|
||||
let id = (1..(last_id + 1)).choose(&mut rng).unwrap();
|
||||
|
||||
let url = req.url_for("question", &[format!("{}", id)])?;
|
||||
|
||||
Ok(HttpResponse::Found()
|
||||
.header(header::LOCATION, url.as_str())
|
||||
.finish())
|
||||
#[get("/")]
|
||||
fn index(data: State<AppState>) -> Redirect {
|
||||
let id = random_question_id(&data.database_distribution);
|
||||
Redirect::temporary(format!("/q/{}", id))
|
||||
}
|
||||
|
||||
fn main() {
|
||||
std::env::set_var("RUST_LOG", "actix_web=info");
|
||||
env_logger::init();
|
||||
#[catch(404)]
|
||||
fn not_found(_req: &rocket::Request) -> Template {
|
||||
use std::collections::HashMap;
|
||||
let context: HashMap<String, String> = HashMap::new();
|
||||
Template::render("404", &context)
|
||||
}
|
||||
|
||||
let options: Options = serde_json::from_value(json!({
|
||||
fn rocket() -> Rocket {
|
||||
let options: Options = serde_json::from_value(serde_json::json!({
|
||||
"read_only": true,
|
||||
"no_lock": true,
|
||||
}))
|
||||
.unwrap();
|
||||
|
||||
let storage = Storage::new("db", options).unwrap();
|
||||
|
||||
HttpServer::new(move || {
|
||||
let data = AppState {
|
||||
storage: storage.clone(),
|
||||
template: compile_templates!("./templates/**/*"),
|
||||
let mut state = AppState {
|
||||
storage: Storage::new("db", options).expect("open db"),
|
||||
database_distribution: Uniform::new(1, 3),
|
||||
};
|
||||
App::new()
|
||||
.wrap(Logger::default())
|
||||
.data(data)
|
||||
.route("/q", web::to(index))
|
||||
.service(
|
||||
web::scope("/q")
|
||||
.service(actix_files::Files::new("/static", "./static"))
|
||||
.service(
|
||||
web::resource("/{id}")
|
||||
.name("question") // <- set resource name, then it could be used in `url_for`
|
||||
.guard(guard::Get())
|
||||
.to(show_question),
|
||||
)
|
||||
.service(
|
||||
web::resource("/{id}/a/")
|
||||
.name("answer") // <- set resource name, then it could be used in `url_for`
|
||||
.guard(guard::Get())
|
||||
.to(show_answer),
|
||||
)
|
||||
.route("/", web::to(index))
|
||||
)
|
||||
.route("/", web::to(index))
|
||||
})
|
||||
.bind("127.0.0.1:8088")
|
||||
.unwrap()
|
||||
.run()
|
||||
.unwrap();
|
||||
state.database_distribution = get_database_distribution(&state.storage);
|
||||
|
||||
let state = state;
|
||||
|
||||
rocket::ignite()
|
||||
.manage(state)
|
||||
.register(catchers![not_found])
|
||||
.mount("/", routes![index, show_question, show_answer])
|
||||
.mount("/q", routes![index])
|
||||
.mount("/q/static", StaticFiles::from("static/"))
|
||||
.attach(Template::fairing())
|
||||
}
|
||||
|
||||
fn main() {
|
||||
rocket().launch();
|
||||
}
|
||||
|
||||
7
static/bootstrap.min.css
vendored
Normal file
7
static/bootstrap.min.css
vendored
Normal file
File diff suppressed because one or more lines are too long
@@ -9,3 +9,17 @@ body {
|
||||
.content-block-inner {
|
||||
margin: auto;
|
||||
}
|
||||
|
||||
.footer {
|
||||
widows: 100%;
|
||||
text-align: center;
|
||||
z-index: -1;
|
||||
}
|
||||
|
||||
details {
|
||||
text-align: center;
|
||||
}
|
||||
|
||||
#details {
|
||||
text-align: justify;
|
||||
}
|
||||
@@ -1,4 +1,4 @@
|
||||
{% extends "base.html" %}
|
||||
{% extends "base" %}
|
||||
{% block title %}404{% endblock title %}
|
||||
{% block content %}
|
||||
<h1>404 - Could not find that page</h1>
|
||||
@@ -1,5 +1,7 @@
|
||||
{% extends "base.html" %} {% block title %} Ответ {% endblock title %}
|
||||
|
||||
{% extends "base" %} {% block title %} Ответ {% endblock title %}
|
||||
{% block nav %}
|
||||
<li class="nav-item"><a class="nav-link text-primary" href="/q/{{ next }}">Ещё</a></li>
|
||||
{% endblock nav %}
|
||||
{% block content %}
|
||||
<!-- <h1>{{ id }}</h1> -->
|
||||
<div class="content-block">
|
||||
@@ -15,7 +17,7 @@
|
||||
<hr/>
|
||||
<p>
|
||||
<!-- <h2> Ответ: </h2> -->
|
||||
<h1>{{ answer }}</h1>
|
||||
<h1 class="d-flex justify-content-center text-center">{{ answer }}</h1>
|
||||
</p>
|
||||
<hr/><br><br/><details>
|
||||
<div id="details">
|
||||
@@ -1,13 +0,0 @@
|
||||
<!DOCTYPE html>
|
||||
<html>
|
||||
<head>
|
||||
<meta charset="utf-8" />
|
||||
<link rel="stylesheet" href="https://maxcdn.bootstrapcdn.com/bootstrap/4.0.0/css/bootstrap.min.css" integrity="sha384-Gn5384xqQ1aoWXA+058RXPxPg6fy4IWvTNh0E263XmFcJlSAwiGgFAW/dAiS6JXm" crossorigin="anonymous">
|
||||
<link rel="stylesheet" type="text/css" href="/q/static/style.css" />
|
||||
<title>{% block title %}{% endblock title %}</title>
|
||||
</head>
|
||||
<body>
|
||||
{% include "nav.html" %}
|
||||
<div id="content" class="container">{% block content %}{% endblock content %}</div>
|
||||
</body>
|
||||
</html>
|
||||
28
templates/base.html.tera
Normal file
28
templates/base.html.tera
Normal file
@@ -0,0 +1,28 @@
|
||||
<!DOCTYPE html>
|
||||
<html>
|
||||
<head>
|
||||
<meta charset="utf-8" />
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1">
|
||||
<link rel="stylesheet" type="text/css" href="/q/static/bootstrap.min.css">
|
||||
<link rel="stylesheet" type="text/css" href="/q/static/style.css" />
|
||||
<title>{% block title %}{% endblock title %}</title>
|
||||
</head>
|
||||
<body>
|
||||
<header>
|
||||
<nav class="navbar navbar-expand-sm container sticky-top navbar-light justify-content-center">
|
||||
<ul class="nav navbar-nav">
|
||||
{% include "nav" %}
|
||||
{% block nav %}{% endblock nav %}
|
||||
</ul>
|
||||
</nav><hr/>
|
||||
</header>
|
||||
<article>
|
||||
<div id="content" class="container">{% block content %}{% endblock content %}</div>
|
||||
</article>
|
||||
<footer class="footer fixed-bottom">
|
||||
<hr/>
|
||||
<p class="text-secondary">Источник: <a class="text-secondary" href="https://db.chgk.info/">db.chgk.info</a></p>
|
||||
</footer>
|
||||
<!-- Yandex.Metrika counter --> <script type="text/javascript" > (function (d, w, c) { (w[c] = w[c] || []).push(function() { try { w.yaCounter48214757 = new Ya.Metrika2({ id:48214757, clickmap:true, trackLinks:true, accurateTrackBounce:true, trackHash:true, ut:"noindex" }); } catch(e) { } }); var n = d.getElementsByTagName("script")[0], s = d.createElement("script"), f = function () { n.parentNode.insertBefore(s, n); }; s.type = "text/javascript"; s.async = true; s.src = "https://mc.yandex.ru/metrika/tag.js"; if (w.opera == "[object Opera]") { d.addEventListener("DOMContentLoaded", f, false); } else { f(); } })(document, window, "yandex_metrika_callbacks2"); </script> <noscript><div><img src="https://mc.yandex.ru/watch/48214757?ut=noindex" style="position:absolute; left:-9999px;" alt="" /></div></noscript> <!-- /Yandex.Metrika counter -->
|
||||
</body>
|
||||
</html>
|
||||
@@ -1,3 +0,0 @@
|
||||
<nav class="nav nav-pills container justify-content-center">
|
||||
<a class="nav-link" href="/q/">Ещё</a>
|
||||
</nav>
|
||||
1
templates/nav.html.tera
Normal file
1
templates/nav.html.tera
Normal file
@@ -0,0 +1 @@
|
||||
<li class="nav-item"><a class="nav-link text-info" href="/">Главная</a></li>
|
||||
@@ -1,17 +0,0 @@
|
||||
{% extends "base.html" %} {% block title %} Вопрос {% endblock title %}
|
||||
|
||||
{% block content %}
|
||||
<!-- <h1>{{ id }}</h1> -->
|
||||
<div class="content-block"><div id="question" class="content-block-inner">
|
||||
<p>
|
||||
<h3> {{ description }} </h3>
|
||||
</p>
|
||||
</div></div>
|
||||
<br/>
|
||||
<br/>
|
||||
<br/><details>
|
||||
<nav class="nav nav-pills container justify-content-center">
|
||||
<a class="nav-link" href="/q/{{ num }}/a/">Ответ</a>
|
||||
</nav></details>
|
||||
|
||||
{% endblock content %}
|
||||
19
templates/question.html.tera
Normal file
19
templates/question.html.tera
Normal file
@@ -0,0 +1,19 @@
|
||||
{% extends "base" %} {% block title %} Вопрос {% endblock title %}
|
||||
{% block nav %}
|
||||
<li class="nav-item"><a class="nav-link text-primary" href="/q/{{ next }}">Ещё</a></li>
|
||||
{% endblock nav %}
|
||||
{% block content %}
|
||||
<!-- <h1>{{ id }}</h1> -->
|
||||
<div class="content-block"><div id="question" class="content-block-inner">
|
||||
<p>
|
||||
<h3> {{ description }} </h3>
|
||||
</p>
|
||||
</div></div>
|
||||
<br/>
|
||||
<br/>
|
||||
<br/><details>
|
||||
<summary>Ответ</summary><br/>
|
||||
<a class="btn btn-dark" href="/q/{{ num }}/a/">Показать ответ</a>
|
||||
</details>
|
||||
|
||||
{% endblock content %}
|
||||
Reference in New Issue
Block a user