overleaf/services/web/app/coffee/Features/Analytics/AnalyticsManager.coffee

110 lines
2.6 KiB
CoffeeScript
Raw Normal View History

settings = require "settings-sharelatex"
2016-08-10 11:42:56 -04:00
logger = require "logger-sharelatex"
_ = require "underscore"
2018-02-12 10:16:21 -05:00
request = require "requestretry"
Errors = require '../Errors/Errors'
2016-08-10 11:42:56 -04:00
2018-03-19 06:09:45 -04:00
makeFaultTolerantRequest = (userId, options, callback) ->
if userId+"" == settings.smokeTest?.userId+""
return callback()
options = Object.assign(options, {
delayStrategy: exponentialBackoffStrategy()
2018-03-19 10:46:18 -04:00
timeout: 30000
2018-03-19 06:09:45 -04:00
})
if settings.overleaf?
options.qs = Object.assign({}, options.qs, { fromV2: 1 })
makeRequest(options, callback)
makeRequest = (opts, callback)->
if settings.apis?.analytics?.url?
urlPath = opts.url
opts.url = "#{settings.apis.analytics.url}#{urlPath}"
2018-03-19 05:56:44 -04:00
request opts, (err) ->
if err?
logger.err { err: err }, 'Request to analytics failed'
callback() # Do not wait for all the attempts
else
callback(new Errors.ServiceNotConfiguredError('Analytics service not configured'))
2016-08-10 11:42:56 -04:00
# Set an exponential backoff to retry calls to analytics. First retry will
# happen after 4s, then 8, 16, 32, 64...
exponentialBackoffStrategy = () ->
attempts = 1 # This won't be called until there has been 1 failure
() ->
attempts += 1
exponentialBackoffDelay(attempts)
exponentialBackoffDelay = (attempts) ->
delay = 2 ** attempts * 1000
logger.warn "Error comunicating with the analytics service. " +
"Will try again attempt #{attempts} in #{delay}ms"
delay
module.exports =
2017-03-22 12:01:26 -04:00
identifyUser: (user_id, old_user_id, callback = (error)->)->
opts =
body:
old_user_id:old_user_id
json:true
method:"POST"
timeout:1000
2017-03-22 11:50:49 -04:00
url: "/user/#{user_id}/identify"
makeRequest opts, callback
recordEvent: (user_id, event, segmentation = {}, callback = (error) ->) ->
opts =
body:
event:event
segmentation:segmentation
json:true
method:"POST"
url: "/user/#{user_id}/event"
maxAttempts: 7 # Give up after ~ 8min
2018-03-19 06:09:45 -04:00
makeFaultTolerantRequest user_id, opts, callback
updateEditingSession: (userId, projectId, countryCode, callback = (error) ->) ->
query =
userId: userId
projectId: projectId
2018-03-19 06:09:45 -04:00
if countryCode
query.countryCode = countryCode
2018-03-19 06:09:45 -04:00
opts =
method: "PUT"
2018-01-23 07:47:51 -05:00
url: "/editingSession"
qs: query
maxAttempts: 6 # Give up after ~ 4min
2018-03-19 06:09:45 -04:00
makeFaultTolerantRequest userId, opts, callback
getLastOccurrence: (user_id, event, callback = (error) ->) ->
opts =
body:
event:event
json:true
method:"POST"
timeout:1000
url: "/user/#{user_id}/event/last_occurrence"
makeRequest opts, (err, response, body)->
2018-01-22 10:00:56 -05:00
if err?
console.log response, opts
logger.err {user_id, err}, "error getting last occurance of event"
return callback err
else
return callback null, body