From 877fd1af35109bbaddd9d6b06da02fbc012680fc Mon Sep 17 00:00:00 2001 From: Lucien Greathouse Date: Tue, 10 Sep 2019 16:42:14 -0700 Subject: [PATCH] Make /api/subscribe hang forever instead of returning no messages --- src/web/api.rs | 19 +++++++++++-------- src/web/interface.rs | 2 +- 2 files changed, 12 insertions(+), 9 deletions(-) diff --git a/src/web/api.rs b/src/web/api.rs index 885c941b..63f46d34 100644 --- a/src/web/api.rs +++ b/src/web/api.rs @@ -78,16 +78,19 @@ impl ApiService { } }; - let message_queue = self.serve_session.message_queue(); - let message_cursor = message_queue.cursor(); + // Temporary response to prevent Rojo plugin from sending too many + // requests, this will hang the request until it times out. + Box::new(future::empty()) - let messages = Vec::new(); // TODO + // let message_queue = self.serve_session.message_queue(); + // let message_cursor = message_queue.cursor(); + // let messages = Vec::new(); - json_ok(SubscribeResponse { - session_id: self.serve_session.session_id(), - message_cursor, - messages, - }) + // json_ok(SubscribeResponse { + // session_id: self.serve_session.session_id(), + // message_cursor, + // messages, + // }) } fn handle_api_read(&self, request: Request) -> ::Future { diff --git a/src/web/interface.rs b/src/web/interface.rs index 18f62104..b62c77f5 100644 --- a/src/web/interface.rs +++ b/src/web/interface.rs @@ -5,7 +5,7 @@ use std::{ collections::{HashMap, HashSet}, }; -use rbx_dom_weak::{RbxId, RbxInstance, RbxValue}; +use rbx_dom_weak::{RbxId, RbxValue}; use serde::{Deserialize, Serialize}; use crate::{session_id::SessionId, snapshot::InstanceWithMeta};