diff --git a/services/track-changes/app/coffee/MongoAWS.coffee b/services/track-changes/app/coffee/MongoAWS.coffee index c6712e29f1..42f41863a6 100644 --- a/services/track-changes/app/coffee/MongoAWS.coffee +++ b/services/track-changes/app/coffee/MongoAWS.coffee @@ -6,6 +6,7 @@ S3S = require 's3-streams' JSONStream = require "JSONStream" ReadlineStream = require "byline" zlib = require "zlib" +Metrics = require "./Metrics" DAYS = 24 * 3600 * 1000 # one day in milliseconds @@ -51,6 +52,7 @@ module.exports = MongoAWS = upload.on 'error', (err) -> callback(err) upload.on 'finish', () -> + Metrics.inc("archive-pack") logger.log {project_id, doc_id, pack_id}, "upload to s3 completed" callback(null) upload.write buf @@ -103,6 +105,7 @@ module.exports = MongoAWS = unArchivePack: (project_id, doc_id, pack_id, callback = (error) ->) -> MongoAWS.readArchivedPack project_id, doc_id, pack_id, (err, object) -> return callback(err) if err? + Metrics.inc("unarchive-pack") # allow the object to expire, we can always retrieve it again object.expiresAt = new Date(Date.now() + 7 * DAYS) logger.log {project_id, doc_id, pack_id}, "inserting object from s3" diff --git a/services/track-changes/app/coffee/PackManager.coffee b/services/track-changes/app/coffee/PackManager.coffee index b40e8ef46c..dd0a9c379c 100644 --- a/services/track-changes/app/coffee/PackManager.coffee +++ b/services/track-changes/app/coffee/PackManager.coffee @@ -4,6 +4,7 @@ _ = require "underscore" logger = require "logger-sharelatex" LockManager = require "./LockManager" MongoAWS = require "./MongoAWS" +Metrics = require "./Metrics" ProjectIterator = require "./ProjectIterator" # Sharejs operations are stored in a 'pack' object @@ -114,6 +115,7 @@ module.exports = PackManager = logger.log {project_id, doc_id, newUpdates}, "inserting updates into new pack" db.docHistory.save newPack, (err, result) -> return callback(err) if err? + Metrics.inc("insert-pack-" + if temporary then "temporary" else "permanent") if temporary return callback() else