hakowork/rojo
3
0
Fork 0
mirror of https://github.com/rojo-rbx/rojo.git synced 2026-10-20 17:41:37 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Make /api/subscribe hang forever instead of returning no messages

Browse source
This commit is contained in:
Lucien Greathouse 2019-09-10 16:42:14 -07:00
parent fc01eecdcb
commit 877fd1af35
2 changed files with 12 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

19
src/web/api.rs
View file

@ -78,16 +78,19 @@ impl ApiService {
} }
}; };
let message_queue = self.serve_session.message_queue(); // Temporary response to prevent Rojo plugin from sending too many
let message_cursor = message_queue.cursor(); // 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 { // json_ok(SubscribeResponse {
session_id: self.serve_session.session_id(), // session_id: self.serve_session.session_id(),
message_cursor, // message_cursor,
messages, // messages,
}) // })
} }
fn handle_api_read(&self, request: Request<Body>) -> <ApiService as Service>::Future { fn handle_api_read(&self, request: Request<Body>) -> <ApiService as Service>::Future {

2
src/web/interface.rs
View file

@ -5,7 +5,7 @@ use std::{
collections::{HashMap, HashSet}, collections::{HashMap, HashSet},
}; };
use rbx_dom_weak::{RbxId, RbxInstance, RbxValue}; use rbx_dom_weak::{RbxId, RbxValue};
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use crate::{session_id::SessionId, snapshot::InstanceWithMeta}; use crate::{session_id::SessionId, snapshot::InstanceWithMeta};