|
|
@@ -7,49 +7,49 @@ module.exports = ProjectHistoryRedisManager =
|
|
|
queueOps: (project_id, ops..., callback) ->
|
|
|
rclient.rpush projectHistoryKeys.projectHistoryOps({project_id}), ops..., callback
|
|
|
|
|
|
- queueRenameEntity: (project_id, entity_type, entity_id, user_id, update, callback) ->
|
|
|
- update =
|
|
|
- pathname: update.pathname
|
|
|
- new_pathname: update.newPathname
|
|
|
+ queueRenameEntity: (project_id, entity_type, entity_id, user_id, projectUpdate, callback) ->
|
|
|
+ projectUpdate =
|
|
|
+ pathname: projectUpdate.pathname
|
|
|
+ new_pathname: projectUpdate.newPathname
|
|
|
meta:
|
|
|
user_id: user_id
|
|
|
ts: new Date()
|
|
|
- version: update.version
|
|
|
- update[entity_type] = entity_id
|
|
|
+ version: projectUpdate.version
|
|
|
+ projectUpdate[entity_type] = entity_id
|
|
|
|
|
|
- logger.log {project_id, update}, "queue rename operation to project-history"
|
|
|
- jsonUpdate = JSON.stringify(update)
|
|
|
+ logger.log {project_id, projectUpdate}, "queue rename operation to project-history"
|
|
|
+ jsonUpdate = JSON.stringify(projectUpdate)
|
|
|
|
|
|
ProjectHistoryRedisManager.queueOps project_id, jsonUpdate, callback
|
|
|
|
|
|
- queueAddEntity: (project_id, entity_type, entitiy_id, user_id, update, callback = (error) ->) ->
|
|
|
- update =
|
|
|
- pathname: update.pathname
|
|
|
- docLines: update.docLines
|
|
|
- url: update.url
|
|
|
+ queueAddEntity: (project_id, entity_type, entitiy_id, user_id, projectUpdate, callback = (error) ->) ->
|
|
|
+ projectUpdate =
|
|
|
+ pathname: projectUpdate.pathname
|
|
|
+ docLines: projectUpdate.docLines
|
|
|
+ url: projectUpdate.url
|
|
|
meta:
|
|
|
user_id: user_id
|
|
|
ts: new Date()
|
|
|
- version: update.version
|
|
|
- update[entity_type] = entitiy_id
|
|
|
+ version: projectUpdate.version
|
|
|
+ projectUpdate[entity_type] = entitiy_id
|
|
|
|
|
|
- logger.log {project_id, update}, "queue add operation to project-history"
|
|
|
- jsonUpdate = JSON.stringify(update)
|
|
|
+ logger.log {project_id, projectUpdate}, "queue add operation to project-history"
|
|
|
+ jsonUpdate = JSON.stringify(projectUpdate)
|
|
|
|
|
|
ProjectHistoryRedisManager.queueOps project_id, jsonUpdate, callback
|
|
|
|
|
|
queueResyncProjectStructure: (project_id, docs, files, callback) ->
|
|
|
logger.log {project_id, docs, files}, "queue project structure resync"
|
|
|
- update =
|
|
|
+ projectUpdate =
|
|
|
resyncProjectStructure: { docs, files }
|
|
|
meta:
|
|
|
ts: new Date()
|
|
|
- jsonUpdate = JSON.stringify update
|
|
|
+ jsonUpdate = JSON.stringify projectUpdate
|
|
|
ProjectHistoryRedisManager.queueOps project_id, jsonUpdate, callback
|
|
|
|
|
|
queueResyncDocContent: (project_id, doc_id, lines, version, pathname, callback) ->
|
|
|
logger.log {project_id, doc_id, lines, version, pathname}, "queue doc content resync"
|
|
|
- update =
|
|
|
+ projectUpdate =
|
|
|
resyncDocContent:
|
|
|
content: lines.join("\n"),
|
|
|
version: version
|
|
|
@@ -57,5 +57,5 @@ module.exports = ProjectHistoryRedisManager =
|
|
|
doc: doc_id
|
|
|
meta:
|
|
|
ts: new Date()
|
|
|
- jsonUpdate = JSON.stringify update
|
|
|
+ jsonUpdate = JSON.stringify projectUpdate
|
|
|
ProjectHistoryRedisManager.queueOps project_id, jsonUpdate, callback
|