rojo-rbx/rojo
1
0
Fork 1
mirror of https://github.com/rojo-rbx/rojo.git synced 2026-04-24 06:35:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

plugin: Only move message cursor in response to retrieveMessages

Browse Source
This commit is contained in:
Lucien Greathouse
2019-10-04 11:13:10 -07:00
parent ece454e6dd
commit 5b57025b0b
2 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
plugin/src/ApiContext.lua
View File

@@ -131,13 +131,15 @@ function ApiContext:read(ids)
return Promise.reject("Server changed ID") return Promise.reject("Server changed ID")
end end
self.messageCursor = body.messageCursor
return body return body
end) end)
end end
function ApiContext:retrieveMessages() function ApiContext:retrieveMessages(initialCursor)
if initialCursor ~= nil then
self.messageCursor = initialCursor
end
local url = ("%s/api/subscribe/%s"):format(self.baseUrl, self.messageCursor) local url = ("%s/api/subscribe/%s"):format(self.baseUrl, self.messageCursor)
local function sendRequest() local function sendRequest()

6
plugin/src/Session.lua
View File

@@ -33,7 +33,7 @@ function Session.new(config)
end end
self.reconciler:reconcile(response.instances, api.rootInstanceId, game) self.reconciler:reconcile(response.instances, api.rootInstanceId, game)
return self:__processMessages() return self:__processMessages(response.messageCursor)
end) end)
:catch(function(message) :catch(function(message)
self.disconnected = true self.disconnected = true
@@ -43,12 +43,12 @@ function Session.new(config)
return not self.disconnected, setmetatable(self, Session) return not self.disconnected, setmetatable(self, Session)
end end
function Session:__processMessages() function Session:__processMessages(initialCursor)
if self.disconnected then if self.disconnected then
return Promise.resolve() return Promise.resolve()
end end
return self.api:retrieveMessages() return self.api:retrieveMessages(initialCursor)
:andThen(function(messages) :andThen(function(messages)
local promise = Promise.resolve(nil) local promise = Promise.resolve(nil)