mirror of
https://github.com/overleaf/overleaf.git
synced 2025-04-05 02:36:52 +00:00
[misc] test/acceptance: ReceiveUpdateTests: add 2nd project/3rd client
...and check for cross project leakage.
This commit is contained in:
Jakob Ackermann
Jakob Ackermann
parent
56fda1f9b0
commit
83e3ff0ed7
1 changed files with 105 additions and 20 deletions
|
|
@ -13,7 +13,7 @@ redis = require "redis-sharelatex"
|
|||
rclient = redis.createClient(settings.redis.pubsub)
|
||||
|
||||
describe "receiveUpdate", ->
|
||||
before (done) ->
|
||||
beforeEach (done) ->
|
||||
@lines = ["test", "doc", "lines"]
|
||||
@version = 42
|
||||
@ops = ["mock", "doc", "ops"]
|
||||
|
|
@ -52,15 +52,52 @@ describe "receiveUpdate", ->
|
|||
|
||||
(cb) =>
|
||||
@clientB.emit "joinDoc", @doc_id, cb
|
||||
|
||||
(cb) =>
|
||||
FixturesManager.setUpProject {
|
||||
privilegeLevel: "owner"
|
||||
project: {name: "Test Project"}
|
||||
}, (error, {user_id: @user_id_second, project_id: @project_id_second}) => cb()
|
||||
|
||||
(cb) =>
|
||||
FixturesManager.setUpDoc @project_id_second, {@lines, @version, @ops}, (e, {doc_id: @doc_id_second}) =>
|
||||
cb(e)
|
||||
|
||||
(cb) =>
|
||||
@clientC = RealTimeClient.connect()
|
||||
@clientC.on "connectionAccepted", cb
|
||||
|
||||
(cb) =>
|
||||
@clientC.emit "joinProject", {
|
||||
project_id: @project_id_second
|
||||
}, cb
|
||||
(cb) =>
|
||||
@clientC.emit "joinDoc", @doc_id_second, cb
|
||||
|
||||
(cb) =>
|
||||
@clientAUpdates = []
|
||||
@clientA.on "otUpdateApplied", (update) => @clientAUpdates.push(update)
|
||||
@clientBUpdates = []
|
||||
@clientB.on "otUpdateApplied", (update) => @clientBUpdates.push(update)
|
||||
@clientCUpdates = []
|
||||
@clientC.on "otUpdateApplied", (update) => @clientCUpdates.push(update)
|
||||
|
||||
@clientAErrors = []
|
||||
@clientA.on "otUpdateError", (error) => @clientAErrors.push(error)
|
||||
@clientBErrors = []
|
||||
@clientB.on "otUpdateError", (error) => @clientBErrors.push(error)
|
||||
@clientCErrors = []
|
||||
@clientC.on "otUpdateError", (error) => @clientCErrors.push(error)
|
||||
cb()
|
||||
], done
|
||||
|
||||
|
||||
afterEach () ->
|
||||
@clientA?.disconnect()
|
||||
@clientB?.disconnect()
|
||||
@clientC?.disconnect()
|
||||
|
||||
describe "with an update from clientA", ->
|
||||
before (done) ->
|
||||
@clientAUpdates = []
|
||||
@clientA.on "otUpdateApplied", (update) => @clientAUpdates.push(update)
|
||||
@clientBUpdates = []
|
||||
@clientB.on "otUpdateApplied", (update) => @clientBUpdates.push(update)
|
||||
|
||||
beforeEach (done) ->
|
||||
@update = {
|
||||
doc_id: @doc_id
|
||||
op:
|
||||
|
|
@ -80,21 +117,69 @@ describe "receiveUpdate", ->
|
|||
@clientAUpdates.should.deep.equal [{
|
||||
v: @version, doc: @doc_id
|
||||
}]
|
||||
|
||||
describe "with an error", ->
|
||||
before (done) ->
|
||||
@clientAErrors = []
|
||||
@clientA.on "otUpdateError", (error) => @clientAErrors.push(error)
|
||||
@clientBErrors = []
|
||||
@clientB.on "otUpdateError", (error) => @clientBErrors.push(error)
|
||||
|
||||
|
||||
it "should send nothing to clientC", ->
|
||||
@clientCUpdates.should.deep.equal []
|
||||
|
||||
describe "with an update from clientC", ->
|
||||
beforeEach (done) ->
|
||||
@update = {
|
||||
doc_id: @doc_id_second
|
||||
op:
|
||||
meta:
|
||||
source: @clientC.publicId
|
||||
v: @version
|
||||
doc: @doc_id_second
|
||||
op: [{i: "update from clientC", p: 50}]
|
||||
}
|
||||
rclient.publish "applied-ops", JSON.stringify(@update)
|
||||
setTimeout done, 200 # Give clients time to get message
|
||||
|
||||
it "should send nothing to clientA", ->
|
||||
@clientAUpdates.should.deep.equal []
|
||||
|
||||
it "should send nothing to clientB", ->
|
||||
@clientBUpdates.should.deep.equal []
|
||||
|
||||
it "should send an ack to clientC", ->
|
||||
@clientCUpdates.should.deep.equal [{
|
||||
v: @version, doc: @doc_id_second
|
||||
}]
|
||||
|
||||
describe "with an error for the first project", ->
|
||||
beforeEach (done) ->
|
||||
rclient.publish "applied-ops", JSON.stringify({doc_id: @doc_id, error: @error = "something went wrong"})
|
||||
setTimeout done, 200 # Give clients time to get message
|
||||
|
||||
it "should send the error to both clients", ->
|
||||
|
||||
it "should send the error to the clients in the first project", ->
|
||||
@clientAErrors.should.deep.equal [@error]
|
||||
@clientBErrors.should.deep.equal [@error]
|
||||
|
||||
it "should disconnect the clients", ->
|
||||
|
||||
it "should not send any errors to the client in the second project", ->
|
||||
@clientCErrors.should.deep.equal []
|
||||
|
||||
it "should disconnect the clients of the first project", ->
|
||||
@clientA.socket.connected.should.equal false
|
||||
@clientB.socket.connected.should.equal false
|
||||
|
||||
it "should not disconnect the client in the second project", ->
|
||||
@clientC.socket.connected.should.equal true
|
||||
|
||||
describe "with an error for the second project", ->
|
||||
beforeEach (done) ->
|
||||
rclient.publish "applied-ops", JSON.stringify({doc_id: @doc_id_second, error: @error = "something went wrong"})
|
||||
setTimeout done, 200 # Give clients time to get message
|
||||
|
||||
it "should not send any errors to the clients in the first project", ->
|
||||
@clientAErrors.should.deep.equal []
|
||||
@clientBErrors.should.deep.equal []
|
||||
|
||||
it "should send the error to the client in the second project", ->
|
||||
@clientCErrors.should.deep.equal [@error]
|
||||
|
||||
it "should not disconnect the clients of the first project", ->
|
||||
@clientA.socket.connected.should.equal true
|
||||
@clientB.socket.connected.should.equal true
|
||||
|
||||
it "should disconnect the client in the second project", ->
|
||||
@clientC.socket.connected.should.equal false
|
||||
|
|
|
|||
Loading…
Reference in a new issue