56 lines
1.5 KiB
CoffeeScript
56 lines
1.5 KiB
CoffeeScript
|
|
|
|
#
|
|
# @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.
|
|
#
|
|
adaptConnector = (connector, engine, HB, execution_listener)->
|
|
send_ = (o)->
|
|
if o.uid.creator is HB.getUserId() and (typeof o.uid.op_number isnt "string")
|
|
connector.broadcast o
|
|
|
|
if connector.invokeSync?
|
|
HB.setInvokeSyncHandler connector.invokeSync
|
|
|
|
execution_listener.push send_
|
|
# For the XMPPConnector: lets send it as an array
|
|
# therefore, we have to restructure it later
|
|
encode_state_vector = (v)->
|
|
for name,value of v
|
|
user: name
|
|
state: value
|
|
parse_state_vector = (v)->
|
|
state_vector = {}
|
|
for s in v
|
|
state_vector[s.user] = s.state
|
|
state_vector
|
|
|
|
getStateVector = ()->
|
|
encode_state_vector HB.getOperationCounter()
|
|
|
|
getHB = (v)->
|
|
state_vector = parse_state_vector v
|
|
hb = HB._encode state_vector
|
|
for o in hb
|
|
o.fromHB = "true" # execute immediately
|
|
json =
|
|
hb: hb
|
|
state_vector: encode_state_vector HB.getOperationCounter()
|
|
json
|
|
|
|
applyHB = (hb)->
|
|
engine.applyOp hb
|
|
|
|
connector.getStateVector = getStateVector
|
|
connector.getHB = getHB
|
|
connector.applyHB = applyHB
|
|
|
|
connector.whenReceiving (sender, op)->
|
|
if op.uid.creator isnt HB.getUserId()
|
|
engine.applyOp op
|
|
|
|
if connector._whenBoundToY?
|
|
connector._whenBoundToY()
|
|
|
|
module.exports = adaptConnector |