mirror of
https://github.com/overleaf/overleaf.git
synced 2024-12-04 04:06:39 -05:00
40 lines
1.6 KiB
CoffeeScript
40 lines
1.6 KiB
CoffeeScript
|
logger = require "logger-sharelatex"
|
||
|
|
settings = require 'settings-sharelatex'
|
||
|
|
redis = require("redis-sharelatex")
|
||
|
|
rclient = redis.createClient(settings.redis.web)
|
||
|
|
|
||
|
|
module.exports = DocumentUpdaterController =
|
||
|
|
# DocumentUpdaterController is responsible for updates that come via Redis
|
||
|
|
# Pub/Sub from the document updater.
|
||
|
|
|
||
|
|
listenForUpdatesFromDocumentUpdater: (io) ->
|
||
|
|
rclient.subscribe "applied-ops"
|
||
|
|
rclient.on "message", (channel, message) ->
|
||
|
|
DocumentUpdaterController._processMessageFromDocumentUpdater(io, channel, message)
|
||
|
|
|
||
|
|
_processMessageFromDocumentUpdater: (io, channel, message) ->
|
||
|
|
message = JSON.parse message
|
||
|
|
if message.op?
|
||
|
|
DocumentUpdaterController._applyUpdateFromDocumentUpdater(io, message.doc_id, message.op)
|
||
|
|
else if message.error?
|
||
|
|
DocumentUpdaterController._processErrorFromDocumentUpdater(io, message.doc_id, message.error, message)
|
||
|
|
|
||
|
|
_applyUpdateFromDocumentUpdater: (io, doc_id, update) ->
|
||
|
|
for client in io.sockets.clients(doc_id)
|
||
|
|
if client.id == update.meta.source
|
||
|
|
logger.log doc_id: doc_id, version: update.v, source: update.meta?.source, "distributing update to sender"
|
||
|
|
client.emit "otUpdateApplied", v: update.v, doc: update.doc
|
||
|
|
else
|
||
|
|
logger.log doc_id: doc_id, version: update.v, source: update.meta?.source, client_id: client.id, "distributing update to collaborator"
|
||
|
|
client.emit "otUpdateApplied", update
|
||
|
|
|
||
|
|
_processErrorFromDocumentUpdater: (io, doc_id, error, message) ->
|
||
|
|
logger.error err: error, doc_id: doc_id, "error from document updater"
|
||
|
|
for client in io.sockets.clients(doc_id)
|
||
|
|
client.emit "otUpdateError", error, message
|
||
|
|
client.disconnect()
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|