122 lines
3.7 KiB
CoffeeScript
122 lines
3.7 KiB
CoffeeScript
|
|
#
|
|
# @overload createPeerJsConnector peerjs_options, callback
|
|
# @param {Object} peerjs_options Is the options object that is passed to PeerJs.
|
|
# @param {Function} callback The callback is called when the connector is initialized.
|
|
# @overload createPeerJsConnector peerjs_user_id, peerjs_options, callback
|
|
# @param {String} peerjs_user_id The user_id that is passed to PeerJs as the user_id and should be unique between all (also the unconnected) Peers.
|
|
# @param {Object} peerjs_options Is the options object that is passed to PeerJs.
|
|
# @param {Function} callback The callback is called when the connector is initialized.
|
|
#
|
|
createPeerJsConnector = ()->
|
|
peer = null
|
|
if arguments.length is 2
|
|
peer = new Peer arguments[0]
|
|
callback = arguments[1]
|
|
else
|
|
peer = new Peer arguments[0], arguments[1]
|
|
callback = arguments[2]
|
|
|
|
|
|
#
|
|
# @see http://peerjs.com
|
|
#
|
|
class PeerJsConnector
|
|
|
|
#
|
|
# @param {Engine} engine The transformation engine
|
|
# @param {HistoryBuffer} HB
|
|
# @param {Array<Function>} execution_listener You must ensure that whenever an operation is executed, every function in this Array is called.
|
|
# @param {Yatta} yatta The Yatta framework.
|
|
#
|
|
constructor: (@engine, @HB, @execution_listener, @yatta)->
|
|
|
|
@peer = peer
|
|
@connections = {}
|
|
|
|
@peer.on 'connection', (conn)=>
|
|
@addConnection conn
|
|
|
|
send_ = (o)=>
|
|
@send o
|
|
@execution_listener.push send_
|
|
|
|
connectToPeer: (id)->
|
|
if not @connections[id]? and id isnt @yatta.getUserId()
|
|
@addConnection peer.connect id
|
|
|
|
getAllConnectionIds: ()->
|
|
for conn_id of @connections
|
|
conn_id
|
|
|
|
#
|
|
# What this method does:
|
|
# * Send state vector
|
|
# * Receive HB -> apply them
|
|
# * Send connections
|
|
# * Receive Connections -> Connect to unknow connections
|
|
#
|
|
addConnection: (conn)->
|
|
@connections[conn.peer] = conn
|
|
initialized_me = false
|
|
initialized_him = false
|
|
conn.on 'data', (data)=>
|
|
if data is "empty_message"
|
|
# nop
|
|
else if data.HB?
|
|
initialized_me = true
|
|
@engine.applyOpsCheckDouble data.HB
|
|
conn.send
|
|
conns: @getAllConnectionIds()
|
|
else if data.op?
|
|
@engine.applyOp data.op
|
|
else if data.conns?
|
|
for conn_id in data.conns
|
|
@connectToPeer conn_id
|
|
else if data.state_vector?
|
|
if not initialized_him
|
|
# make sure, that it is sent only once
|
|
conn.send
|
|
HB: @yatta.getHistoryBuffer()._encode(data.state_vector)
|
|
initialized_him = true
|
|
else
|
|
throw new Error "Can't parse this operation"
|
|
|
|
sendStateVector = ()=>
|
|
conn.send
|
|
state_vector: @HB.getOperationCounter()
|
|
if not initialized_me
|
|
# Because of a bug in PeerJs,
|
|
# we never know if state vector was actually sent
|
|
setTimeout sendStateVector, 100
|
|
sendStateVector()
|
|
|
|
#
|
|
# This function is called whenever an operation was executed.
|
|
# @param {Operation} o The operation that was executed.
|
|
#
|
|
send: (o)->
|
|
if o.uid.creator is @HB.getUserId() and (typeof o.uid.op_number isnt "string")
|
|
for conn_id,conn of @connections
|
|
conn.send
|
|
op: o
|
|
|
|
#
|
|
# This function is called whenever an operation was received from another peer.
|
|
# @param {Operation} o The operation that was received.
|
|
#
|
|
receive: (o)->
|
|
if o.uid.creator isnt @HB.getUserId()
|
|
@engine.applyOp o
|
|
|
|
peer.on 'open', (id)->
|
|
callback PeerJsConnector, id
|
|
|
|
|
|
module.exports = createPeerJsConnector
|
|
if window?
|
|
if not window.Y?
|
|
window.Y = {}
|
|
window.Y.createPeerJsConnector = createPeerJsConnector
|
|
|