mirror of
https://github.com/overleaf/overleaf.git
synced 2024-09-23 02:55:13 -04:00
132 lines
3.3 KiB
CoffeeScript
132 lines
3.3 KiB
CoffeeScript
chai = require("chai")
|
|
expect = chai.expect
|
|
chai.should()
|
|
|
|
RealTimeClient = require "./helpers/RealTimeClient"
|
|
MockWebServer = require "./helpers/MockWebServer"
|
|
FixturesManager = require "./helpers/FixturesManager"
|
|
|
|
async = require "async"
|
|
|
|
describe "clientTracking", ->
|
|
describe "when a client updates its cursor location", ->
|
|
before (done) ->
|
|
async.series [
|
|
(cb) =>
|
|
FixturesManager.setUpProject {
|
|
privilegeLevel: "owner"
|
|
project: { name: "Test Project" }
|
|
}, (error, {@user_id, @project_id}) => cb()
|
|
|
|
(cb) =>
|
|
@clientA = RealTimeClient.connect()
|
|
@clientA.on "connect", cb
|
|
|
|
(cb) =>
|
|
@clientB = RealTimeClient.connect()
|
|
|
|
@clientB.on "connect", cb
|
|
|
|
(cb) =>
|
|
@clientA.emit "joinProject", {
|
|
project_id: @project_id
|
|
}, cb
|
|
|
|
(cb) =>
|
|
@clientB.emit "joinProject", {
|
|
project_id: @project_id
|
|
}, cb
|
|
|
|
(cb) =>
|
|
@updates = []
|
|
@clientB.on "clientTracking.clientUpdated", (data) =>
|
|
@updates.push data
|
|
|
|
@clientA.emit "clientTracking.updatePosition", {
|
|
row: @row = 42
|
|
column: @column = 36
|
|
doc_id: @doc_id = "mock-doc-id"
|
|
}, (error) ->
|
|
throw error if error?
|
|
setTimeout cb, 300 # Give the message a chance to reach client B.
|
|
], done
|
|
|
|
it "should tell other clients about the update", ->
|
|
@updates.should.deep.equal [
|
|
{
|
|
row: @row
|
|
column: @column
|
|
doc_id: @doc_id
|
|
id: @clientA.socket.sessionid
|
|
user_id: @user_id
|
|
name: "Joe Bloggs"
|
|
}
|
|
]
|
|
|
|
it "should record the update in getConnectedUsers", (done) ->
|
|
@clientB.emit "clientTracking.getConnectedUsers", (error, users) =>
|
|
for user in users
|
|
if user.client_id == @clientA.socket.sessionid
|
|
expect(user.cursorData).to.deep.equal({
|
|
row: @row
|
|
column: @column
|
|
doc_id: @doc_id
|
|
})
|
|
return done()
|
|
throw new Error("user was never found")
|
|
|
|
describe "when an anonymous client updates its cursor location", ->
|
|
before (done) ->
|
|
async.series [
|
|
(cb) =>
|
|
FixturesManager.setUpProject {
|
|
privilegeLevel: "owner"
|
|
project: { name: "Test Project" }
|
|
publicAccess: "readAndWrite"
|
|
}, (error, {@user_id, @project_id}) => cb()
|
|
|
|
(cb) =>
|
|
@clientA = RealTimeClient.connect()
|
|
@clientA.on "connect", cb
|
|
(cb) =>
|
|
@clientA.emit "joinProject", {
|
|
project_id: @project_id
|
|
}, cb
|
|
|
|
(cb) =>
|
|
RealTimeClient.setSession({}, cb)
|
|
|
|
(cb) =>
|
|
@anonymous = RealTimeClient.connect()
|
|
@anonymous.on "connect", cb
|
|
|
|
(cb) =>
|
|
@anonymous.emit "joinProject", {
|
|
project_id: @project_id
|
|
}, cb
|
|
|
|
(cb) =>
|
|
@updates = []
|
|
@clientA.on "clientTracking.clientUpdated", (data) =>
|
|
@updates.push data
|
|
|
|
@anonymous.emit "clientTracking.updatePosition", {
|
|
row: @row = 42
|
|
column: @column = 36
|
|
doc_id: @doc_id = "mock-doc-id"
|
|
}, (error) ->
|
|
throw error if error?
|
|
setTimeout cb, 300 # Give the message a chance to reach client B.
|
|
], done
|
|
|
|
it "should tell other clients about the update", ->
|
|
@updates.should.deep.equal [
|
|
{
|
|
row: @row
|
|
column: @column
|
|
doc_id: @doc_id
|
|
id: @anonymous.socket.sessionid
|
|
user_id: "anonymous-user"
|
|
name: "Anonymous"
|
|
}
|
|
]
|