From b3ddd839e6070f0c77009061e278aa75529e949d Mon Sep 17 00:00:00 2001
From: Brian Gough <bjg@network-theory.co.uk>
Date: Tue, 26 Jan 2016 11:28:02 +0000
Subject: [PATCH] add logging of raw updates

---
 services/track-changes/app.coffee                | 16 +++++++++++++++-
 .../app/coffee/UpdatesManager.coffee             |  1 +
 2 files changed, 16 insertions(+), 1 deletion(-)

diff --git a/services/track-changes/app.coffee b/services/track-changes/app.coffee
index 63c2949d25..2faeec2286 100644
--- a/services/track-changes/app.coffee
+++ b/services/track-changes/app.coffee
@@ -1,10 +1,24 @@
 Settings = require "settings-sharelatex"
 logger = require "logger-sharelatex"
-logger.initialize("track-changes")
+TrackChangesLogger = logger.initialize("track-changes").logger
 
 if Settings.sentry?.dsn?
 	logger.initializeErrorReporting(Settings.sentry.dsn)
 
+# log updates as truncated strings
+truncateFn = (updates) ->
+		JSON.stringify updates, (key, value) ->
+			if typeof value == 'string' && (len = value.length) > 80
+				return value.substr(0,32) + "...(message of length #{len} truncated)..." + value.substr(-32)
+			else
+				return value
+
+TrackChangesLogger.addSerializers {
+	rawUpdates: truncateFn
+	newUpdates: truncateFn
+	lastUpdate: truncateFn
+}
+
 Path = require "path"
 Metrics = require "metrics-sharelatex"
 Metrics.initialize("track-changes")
diff --git a/services/track-changes/app/coffee/UpdatesManager.coffee b/services/track-changes/app/coffee/UpdatesManager.coffee
index 6332951734..1047d98240 100644
--- a/services/track-changes/app/coffee/UpdatesManager.coffee
+++ b/services/track-changes/app/coffee/UpdatesManager.coffee
@@ -102,6 +102,7 @@ module.exports = UpdatesManager =
 					# parse the redis strings into ShareJs updates
 					RedisManager.expandDocUpdates docUpdates, (error, rawUpdates) ->
 						return callback(error) if error?
+						logger.log project_id: project_id, doc_id: doc_id, rawUpdates: rawUpdates, "retrieved raw updates from redis"
 						UpdatesManager.compressAndSaveRawUpdates project_id, doc_id, rawUpdates, temporary, (error) ->
 							return callback(error) if error?
 							logger.log project_id: project_id, doc_id: doc_id, "compressed and saved doc updates"