#![feature(proc_macro_hygiene, decl_macro)]
-use rocket::{get,routes};
-use rocket_contrib::serve::StaticFiles;
-use rocket::response::Content;
use rocket::fairing;
+use rocket::{get, routes};
+use rocket::response::Content;
+use rocket_contrib::serve::StaticFiles;
use otter::imports::*;
return Ok(CheckedResourceLeaf {
safe_leaf, locn,
ctype: ctype.clone(),
- })
+ });
}
}
Err(UnknownResource{})
ptoken: &ia.raw_token,
layout,
};
- Template::render("loading",&c)
+ Template::render("loading", &c)
} else {
let c = FrontPageRenderContext { };
- Template::render("front",&c)
+ Template::render("front", &c)
}
}
#[get("/_/updates?<ctoken>&<gen>")]
#[throws(OE)]
fn updates<'r>(ctoken : InstanceAccess<ClientId>, gen: u64,
- cors: rocket_cors::Guard<'r>)
- -> impl response::Responder<'r> {
+ cors: rocket_cors::Guard<'r>)
+ -> impl response::Responder<'r> {
let gen = Generation(gen);
let iad = ctoken.i;
debug!("starting update stream {:?}", &iad);
let content = sse::content(iad, gen)?;
let content = DebugReader(content, client);
let content = response::Stream::chunked(content, 4096);
- const CTYPE : &str = "text/event-stream; charset=utf-8";
+ const CTYPE: &str = "text/event-stream; charset=utf-8";
let ctype = ContentType::parse_flexible(CTYPE).unwrap();
- cors.responder(response::content::Content(ctype,content))
-}
+ cors.responder(response::content::Content(ctype, content))
+}
#[get("/_/<leaf>")]
#[throws(io::Error)]
-fn resource<'r>(leaf : CheckedResourceLeaf) -> impl Responder<'r> {
+fn resource<'r>(leaf: CheckedResourceLeaf) -> impl Responder<'r> {
let path = match leaf.locn {
RL::Main => format!("{}/{}", config().template_dir, leaf.safe_leaf),
RL::Wasm(s) => format!("{}/{}", config().wasm_dir, s),
};
Content(leaf.ctype, NamedFile::open(path)?)
-}
+}
#[derive(Debug,Copy,Clone)]
struct ContentTypeFixup;
match response.content_type() {
None => {
response.set_header(ContentType::Plain);
- },
+ }
Some(ct) if ct == ContentType::GZIP => {
// the only thing we serve with a .gz extension are the
// compressed source code tarballs
header::Encoding::Gzip,
]));
response.set_header(ContentType::TAR);
- },
- _ => { /* hopefully OK */ },
+ }
+ _ => { /* hopefully OK */ }
}
}
}
let config_filename = env::args().nth(1);
ServerConfig::read(config_filename.as_ref().map(String::as_str))?;
- std::env::set_var("ROCKET_CLI_COLORS","off");
+ std::env::set_var("ROCKET_CLI_COLORS", "off");
let c = config();