2014-09-26 12:04:33 -04:00
|
|
|
Settings = require 'settings-sharelatex'
|
|
|
|
|
redis = require("redis-sharelatex")
|
|
|
|
|
rclientPub = redis.createClient(Settings.redis.web)
|
|
|
|
|
rclientSub = redis.createClient(Settings.redis.web)
|
2014-02-12 05:23:40 -05:00
|
|
|
|
|
|
|
|
module.exports = EditorRealTimeController =
|
|
|
|
|
rclientPub: rclientPub
|
|
|
|
|
rclientSub: rclientSub
|
|
|
|
|
|
|
|
|
|
emitToRoom: (room_id, message, payload...) ->
|
|
|
|
|
@rclientPub.publish "editor-events", JSON.stringify
|
|
|
|
|
room_id: room_id
|
|
|
|
|
message: message
|
|
|
|
|
payload: payload
|
|
|
|
|
|
|
|
|
|
emitToAll: (message, payload...) ->
|
|
|
|
|
@emitToRoom "all", message, payload...
|
|
|
|
|
|
|
|
|
|
listenForEditorEvents: () ->
|
|
|
|
|
@rclientSub.subscribe "editor-events"
|
|
|
|
|
@rclientSub.on "message", @_processEditorEvent.bind(@)
|
|
|
|
|
|
|
|
|
|
_processEditorEvent: (channel, message) ->
|
|
|
|
|
io = require('../../infrastructure/Server').io
|
|
|
|
|
message = JSON.parse(message)
|
|
|
|
|
if message.room_id == "all"
|
|
|
|
|
io.sockets.emit(message.message, message.payload...)
|
|
|
|
|
else
|
|
|
|
|
io.sockets.in(message.room_id).emit(message.message, message.payload...)
|
|
|
|
|
|
