Implement serving scheduler.wasm and query.wasm

doc/changelog.rst

@@ -11,6 +11,8 @@ Verwalter 0.13.0
   ``Content-Type: application/json``
 * feature: add support for ``query.wasm`` which might be used for
   overriding rendered roles and for custom queries
+* feature: you can fetch current scheduler (and query) via API
+  ``/v1/wasm/scheduler.wasm`` (only wasm scheduler though)
 
 
 .. _changelog-0.12.1:

src/daemon/frontend/disk.rs

@@ -28,6 +28,9 @@ lazy_static! {
         .no_encodings()       // always encoded
         .content_type(false)  // we replace content type
         .done();
+    static ref WASM: Arc<Config> = Config::new()
+        .no_encodings()       // never encode, so never out of sync
+        .done();
 }
 
 type ResponseFuture<S> = Box<Future<Item=server::EncoderDone<S>,
@@ -304,3 +307,20 @@ pub fn serve_backup<S>(name: String, head: &server::Head, schedule_dir: &Path)
         kind: Kind::Backup,
     }) as Request<S>)
 }
+
+pub fn serve_wasm<S>(head: &server::Head, file: PathBuf)
+    -> Result<Request<S>, server::Error>
+    where S: AsyncWrite + Send + 'static
+{
+    let inp = Input::from_headers(&*CONFIG, head.method(), head.headers());
+    let fut = POOL.spawn_fn(move || {
+        inp.probe_file(&file).map_err(|e| {
+            error!("Error reading wasm {:?}: {}", file, e);
+            Status::InternalServerError
+        })
+    });
+    Ok(Box::new(Codec {
+        fut: Some(fut),
+        kind: Kind::Backup,
+    }) as Request<S>)
+}

src/daemon/frontend/mod.rs

@@ -71,6 +71,16 @@ impl<S: AsyncWrite + Send + 'static> DispatcherTrait<S> for Dispatcher {
             Log(ref route) => {
                 log::serve(headers, &self.state, route)
             }
+            WasmScheduler => {
+                let path = self.state.options.config_dir
+                    .join("scheduler/v1/scheduler.wasm");
+                disk::serve_wasm(headers, path)
+            }
+            WasmQuery => {
+                let path = self.state.options.config_dir
+                    .join("scheduler/v1/query.wasm");
+                disk::serve_wasm(headers, path)
+            }
             NotFound => {
                 serve_error_page(Status::NotFound)
             }

src/daemon/frontend/routing.rs

@@ -52,6 +52,8 @@ pub enum Route {
     AlterStatic(String),
     Api(ApiRoute, Format),
     Log(LogRoute),
+    WasmScheduler,
+    WasmQuery,
     NotFound,
     BadContentType,
 }
@@ -162,6 +164,8 @@ fn parse_api(path: &str, content_type: Option<&[u8]>) -> Option<Route> {
             }
         ("query", _) => Some(Route::BadContentType),
         ("log", tail) => parse_log_route(tail).map(Log),
+        ("wasm", "scheduler.wasm") => Some(Route::WasmScheduler),
+        ("wasm", "query.wasm") => Some(Route::WasmQuery),
         _ => None,
     }
 }