feat: Add security headers

Issue #19

Author: jrconlin

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "channelserver"
-version = "0.7.0"
+version = "0.8.0"
 authors = ["jr conlin<[email protected]"]
 
 [dependencies]

channelserver/Cargo.toml

@@ -34,8 +34,10 @@ use std::path::Path;
 use std::time::{Duration, Instant};
 
 use actix::Arbiter;
+use actix_web::dev::HttpResponseBuilder;
 use actix_web::server::HttpServer;
-use actix_web::{fs, http, ws, App, Error, HttpRequest, HttpResponse};
+use actix_web::{fs, http, ws, App, AsyncResponder, Error, HttpMessage, HttpRequest, HttpResponse};
+use futures::Future;
 
 mod channelid;
 mod logging;
@@ -78,7 +80,9 @@ fn channel_route(req: &HttpRequest<session::WsChannelSessionState>) -> Result<Ht
                         warn!(&req.state().log.log,
                             "Invalid ChannelID specified: {:?}", id;
                             "remote_ip" => &meta_info.remote);
-                        return Ok(HttpResponse::new(http::StatusCode::NOT_FOUND));
+                        let mut resp =
+                            HttpResponse::new(http::StatusCode::NOT_FOUND).into_builder();
+                        return Ok(add_headers(&mut resp).finish());
                     }
                 };
                 channel_id
@@ -94,6 +98,7 @@ fn channel_route(req: &HttpRequest<session::WsChannelSessionState>) -> Result<Ht
         "remote_ip" => &meta_info.remote
     );
 
+    // Cannot apply headers here.
     ws::start(
         req,
         session::WsChannelSession {
@@ -107,24 +112,52 @@ fn channel_route(req: &HttpRequest<session::WsChannelSessionState>) -> Result<Ht
     )
 }
 
+/// Inject the FoxSec headers into all HTTP responses
+fn add_headers<'a>(resp: &'a mut HttpResponseBuilder) -> &'a mut HttpResponseBuilder {
+    resp.header(
+        "Content-Security-Policy",
+        "default-src 'none'; img-src 'self'; script-src 'self'; style-src 'self'; report-uri /__cspreport__",
+    )
+    .header("X-Content-Type-Options", "nosniff")
+    .header("X-Frame-Options", "deny")
+    .header("X-XSS-Protection", "1; mode=block")
+    .header("Strict-Transport-Security", "max-age=63072000")
+}
+
 fn heartbeat(req: &HttpRequest<session::WsChannelSessionState>) -> Result<HttpResponse, Error> {
     // if there's more to check, add it here.
     let body = json!({"status": "ok", "version": env!("CARGO_PKG_VERSION")});
-    Ok(HttpResponse::Ok()
-        .content_type("application/json")
-        .body(body.to_string()))
+    Ok(add_headers(HttpResponse::Ok().content_type("application/json")).body(body.to_string()))
 }
 
 fn lbheartbeat(req: &HttpRequest<session::WsChannelSessionState>) -> Result<HttpResponse, Error> {
     // load balance heartbeat. Doesn't matter what's returned, aside from a 200
-    Ok(HttpResponse::Ok().into())
+    Ok(add_headers(&mut HttpResponse::Ok()).finish())
 }
 
 fn show_version(req: &HttpRequest<session::WsChannelSessionState>) -> Result<HttpResponse, Error> {
     // Return the contents of the version.json file.
-    Ok(HttpResponse::Ok()
-        .content_type("application/json")
-        .body(include_str!("../version.json")))
+    Ok(
+        add_headers(&mut HttpResponse::Ok().content_type("application/json"))
+            .body(include_str!("../version.json")),
+    )
+}
+
+/// Dump the "CSP report" as a warning message.
+fn cspreport(
+    req: &HttpRequest<session::WsChannelSessionState>,
+) -> Box<Future<Item = HttpResponse, Error = Error>> {
+    use std::str;
+
+    let log = req.state().log.clone();
+    req.body()
+        .from_err()
+        .and_then(move |body| {
+            let bstr = str::from_utf8(&body).unwrap();
+            warn!(log.log, "CSP Report"; "report"=> bstr);
+            Ok(add_headers(&mut HttpResponse::Ok()).finish())
+        })
+        .responder()
 }
 
 fn build_app(app: App<session::WsChannelSessionState>) -> App<session::WsChannelSessionState> {
@@ -141,6 +174,9 @@ fn build_app(app: App<session::WsChannelSessionState>) -> App<session::WsChannel
         })
         .resource("/__lbheartbeat__", |r| {
             r.method(http::Method::GET).f(lbheartbeat)
+        })
+        .resource("/__cspreport__", |r| {
+            r.method(http::Method::POST).f(cspreport)
         });
     // Only add a static handler if the static directory exists.
     if Path::new("static/").exists() {

channelserver/src/main.rs

@@ -11,9 +11,9 @@ pub struct HandlerError {
 
 #[derive(Clone, Eq, PartialEq, Debug, Fail)]
 pub enum HandlerErrorKind {
-    #[fail(display = "Excess Data Exchanged: _0")]
+    #[fail(display = "Excess Data Exchanged: {:?}", _0)]
     XSDataErr(String),
-    #[fail(display = "Excess Messages: _0")]
+    #[fail(display = "Excess Messages: {:?}", _0)]
     XSMessageErr(String),
     #[fail(display = "IO Error: {:?}", _0)]
     IOError(String),