#![feature(proc_macro_hygiene, decl_macro)] #![feature(type_alias_enum_variants)] #[macro_use] extern crate lazy_static; #[macro_use] extern crate rocket; extern crate askama; mod highlight; mod io; mod params; use highlight::highlight; use io::{generate_id, get_paste, store_paste}; use params::{HostHeader, IsPlaintextRequest}; use askama::{MarkupDisplay, Template}; use rocket::http::{ContentType, Status}; use rocket::request::Form; use rocket::response::content::{Content, Html}; use rocket::response::Redirect; use rocket::Data; use std::io::Read; /// /// Homepage /// #[derive(Template)] #[template(path = "index.html")] struct Index; #[get("/")] fn index() -> Result, Status> { Index .render() .map(|h| Html(h)) .map_err(|_| Status::InternalServerError) } /// /// Submit Paste /// #[derive(FromForm)] struct IndexForm { val: String, } #[post("/", data = "")] fn submit(input: Form) -> Redirect { let id = generate_id(); let uri = uri!(show_paste: &id); store_paste(id, input.into_inner().val); Redirect::to(uri) } #[put("/", data = "")] fn submit_raw(input: Data, host: HostHeader) -> std::io::Result { let mut data = String::new(); input.open().take(1024 * 1000).read_to_string(&mut data)?; let id = generate_id(); let uri = uri!(show_paste: &id); store_paste(id, data); match *host { Some(host) => Ok(format!("https://{}{}", host, uri)), None => Ok(format!("{}", uri)), } } /// /// Show paste page /// #[derive(Template)] #[template(path = "paste.html")] struct ShowPaste { content: MarkupDisplay, } #[get("/")] fn show_paste(key: String, plaintext: IsPlaintextRequest) -> Result, Status> { let mut splitter = key.splitn(2, '.'); let key = splitter.next().ok_or_else(|| Status::NotFound)?; let ext = splitter.next(); // get() returns a read-only lock, we're not going to be writing to this key // again so we can hold this for as long as we want let entry = get_paste(key).ok_or_else(|| Status::NotFound)?; if *plaintext { Ok(Content(ContentType::Plain, entry)) } else { let content = match ext { None => MarkupDisplay::Unsafe(entry), Some(extension) => highlight(&entry, extension) .map(|h| MarkupDisplay::Safe(h)) .ok_or_else(|| Status::NotFound)?, }; ShowPaste { content } .render() .map(|html| Content(ContentType::HTML, html)) .map_err(|_| Status::InternalServerError) } } fn main() { rocket::ignite() .mount("/", routes![index, submit, submit_raw, show_paste]) .launch(); }