|
@@ -6,6 +6,7 @@ docUpdaterKeys = Settings.redis.documentupdater.key_schema
|
|
|
async = require("async")
|
|
async = require("async")
|
|
|
ProjectManager = require("./ProjectManager")
|
|
ProjectManager = require("./ProjectManager")
|
|
|
_ = require("lodash")
|
|
_ = require("lodash")
|
|
|
|
|
+logger = require("logger-sharelatex")
|
|
|
|
|
|
|
|
ProjectFlusher =
|
|
ProjectFlusher =
|
|
|
|
|
|
|
@@ -46,6 +47,7 @@ ProjectFlusher =
|
|
|
return ids
|
|
return ids
|
|
|
|
|
|
|
|
flushAllProjects: (options, callback)->
|
|
flushAllProjects: (options, callback)->
|
|
|
|
|
+ logger.log options:options, "flushing all projects"
|
|
|
ProjectFlusher._getKeys docUpdaterKeys.docsInProject({project_id:"*"}), options.limit, (error, project_keys) ->
|
|
ProjectFlusher._getKeys docUpdaterKeys.docsInProject({project_id:"*"}), options.limit, (error, project_keys) ->
|
|
|
if error?
|
|
if error?
|
|
|
logger.err err:error, "error getting keys for flushing"
|
|
logger.err err:error, "error getting keys for flushing"
|
|
@@ -64,6 +66,7 @@ ProjectFlusher =
|
|
|
failure.push(project_ids[i])
|
|
failure.push(project_ids[i])
|
|
|
else
|
|
else
|
|
|
success.push(project_ids[i])
|
|
success.push(project_ids[i])
|
|
|
|
|
+ logger.log success:success, failure:failure, "finished flushing all projects"
|
|
|
return callback(error, {success:success, failure:failure})
|
|
return callback(error, {success:success, failure:failure})
|
|
|
|
|
|
|
|
|
|
|