diff --git a/server/src/web/api.rs b/server/src/web/api.rs index deb6efb4..2bbc96f2 100644 --- a/server/src/web/api.rs +++ b/server/src/web/api.rs @@ -10,8 +10,8 @@ use std::{ use futures::{future, Future}; use hyper::{ service::Service, - StatusCode, header, + StatusCode, Method, Body, Request, @@ -153,7 +153,7 @@ impl ApiService { /// Retrieve any messages past the given cursor index, and if /// there weren't any, subscribe to receive any new messages. fn handle_api_subscribe(&self, request: Request) -> Response { - let argument = &request.uri().path()["/api/subscribe".len()..]; + let argument = &request.uri().path()["/api/subscribe/".len()..]; let cursor: u32 = match argument.parse() { Ok(v) => v, Err(err) => { @@ -206,7 +206,7 @@ impl ApiService { } fn handle_api_read(&self, request: Request) -> Response { - let argument = &request.uri().path()["/api/subscribe".len()..]; + let argument = &request.uri().path()["/api/read/".len()..]; let requested_ids: Option> = argument .split(',') .map(RbxId::parse_str) diff --git a/server/src/web/mod.rs b/server/src/web/mod.rs index 35be0e3b..cd01f8d7 100644 --- a/server/src/web/mod.rs +++ b/server/src/web/mod.rs @@ -5,6 +5,7 @@ mod interface; use std::sync::Arc; +use log::trace; use futures::{ future::{self, FutureResult}, Future, @@ -38,6 +39,8 @@ impl Service for RootService { type Future = Box, Error = Self::Error> + Send>; fn call(&mut self, request: Request) -> Self::Future { + trace!("{} {}", request.method(), request.uri().path()); + if request.uri().path().starts_with("/api") { self.api.call(request) } else {