mirror of
https://github.com/overleaf/overleaf.git
synced 2024-11-07 20:31:06 -05:00
38 lines
No EOL
1.4 KiB
CoffeeScript
38 lines
No EOL
1.4 KiB
CoffeeScript
Settings = require('settings-sharelatex')
|
|
rclient = require("redis-sharelatex").createClient(Settings.redis.web)
|
|
async = require "async"
|
|
|
|
module.exports = WebRedisManager =
|
|
getPendingUpdatesForDoc : (doc_id, callback)->
|
|
multi = rclient.multi()
|
|
multi.lrange "PendingUpdates:#{doc_id}", 0 , -1
|
|
multi.del "PendingUpdates:#{doc_id}"
|
|
multi.exec (error, replys) ->
|
|
return callback(error) if error?
|
|
jsonUpdates = replys[0]
|
|
updates = []
|
|
for jsonUpdate in jsonUpdates
|
|
try
|
|
update = JSON.parse jsonUpdate
|
|
catch e
|
|
return callback e
|
|
updates.push update
|
|
callback error, updates
|
|
|
|
getUpdatesLength: (doc_id, callback)->
|
|
rclient.llen "PendingUpdates:#{doc_id}", callback
|
|
|
|
pushUncompressedHistoryOps: (project_id, doc_id, ops = [], callback = (error, length) ->) ->
|
|
if ops.length == 0
|
|
return callback(new Error("cannot push no ops")) # This should never be called with no ops, but protect against a redis error if we sent an empty array to rpush
|
|
jsonOps = ops.map (op) -> JSON.stringify op
|
|
async.parallel [
|
|
(cb) -> rclient.rpush "UncompressedHistoryOps:#{doc_id}", jsonOps..., cb
|
|
(cb) -> rclient.sadd "DocsWithHistoryOps:#{project_id}", doc_id, cb
|
|
], (error, results) ->
|
|
return callback(error) if error?
|
|
[length, _] = results
|
|
callback(error, length)
|
|
|
|
sendData: (data) ->
|
|
rclient.publish "applied-ops", JSON.stringify(data) |