| 1234567891011121314151617181920212223242526272829303132333435363738 |
- 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)
|
