109 lines
3.3 KiB
Ruby
109 lines
3.3 KiB
Ruby
require 'resque'
|
|
|
|
module JamRuby
|
|
class GoogleAnalyticsEvent
|
|
|
|
@queue = :google_analytics_event
|
|
|
|
CAT_SESS_SIZE = 'SessionSize'
|
|
ACTION_SESS_SIZE = 'Size'
|
|
CAT_SESS_DUR = 'SessionDuration'
|
|
ACTION_SESS_DUR = 'Duration'
|
|
CAT_BAND = 'Band'
|
|
ACTION_BAND_SESS = 'Session'
|
|
ACTION_BAND_REC = 'Recording'
|
|
|
|
@@log = Logging.logger[GoogleAnalyticsEvent]
|
|
|
|
SESSION_INTERVALS = [1, 5, 10, 15, 30, 45, 60, 90, 120, 180] # minutes
|
|
QUEUE_SESSION_TRACKER = :session_tracker
|
|
|
|
class SessionDurationTracker
|
|
@queue = QUEUE_SESSION_TRACKER
|
|
|
|
def self.perform(session_id, interval_idx)
|
|
return unless session = MusicSession.find(session_id)
|
|
interval_idx += 1
|
|
GoogleAnalyticsEvent.enqueue(CAT_SESS_DUR, ACTION_SESS_DUR, interval_idx)
|
|
|
|
if SESSION_INTERVALS.count-1 > interval_idx
|
|
next_time = session.created_at + SESSION_INTERVALS[interval_idx].minutes
|
|
Resque.enqueue_at(next_time,
|
|
self,
|
|
:session_id => session_id,
|
|
:interval_idx => interval_idx)
|
|
end
|
|
end
|
|
end
|
|
|
|
class BandSessionTracker
|
|
@queue = QUEUE_SESSION_TRACKER
|
|
|
|
def self.perform(session_id)
|
|
return unless session = MusicSession.find(session_id)
|
|
band = session.band
|
|
if band.in_real_session?(session)
|
|
GoogleAnalyticsEvent.enqueue(CAT_BAND, ACTION_BAND_SESS)
|
|
band.update_attributes!(did_real_session: true)
|
|
end if band
|
|
end
|
|
end
|
|
|
|
def self.track_session_duration(session)
|
|
Resque.enqueue_at(SESSION_INTERVALS[0].minute.from_now,
|
|
SessionDurationTracker,
|
|
:session_id => session.id,
|
|
:interval_idx => 0)
|
|
end
|
|
|
|
BAND_SESSION_MIN_DURATION = 15 # minutes
|
|
|
|
def self.track_band_real_session(session)
|
|
if session.band && !session.band.did_real_session?
|
|
Resque.enqueue_at(BAND_SESSION_MIN_DURATION.minutes.from_now,
|
|
BandSessionTracker,
|
|
:session_id => session.id)
|
|
end
|
|
end
|
|
|
|
def self.report_band_recording(band)
|
|
if band && 1 == Recording.where(:band_id => band.id).count
|
|
self.enqueue(CAT_BAND, ACTION_BAND_REC)
|
|
end
|
|
end
|
|
|
|
def self.report_session_participant(participant_count)
|
|
self.enqueue(CAT_SESS_SIZE, ACTION_SESS_SIZE, participant_count)
|
|
end
|
|
|
|
def self.enqueue(category, event, data=nil)
|
|
begin
|
|
Resque.enqueue(GoogleAnalyticsEvent, category, event, data)
|
|
true
|
|
rescue
|
|
# implies redis is down. but since there is no retry logic with this, we should at least log a warn in case we've configured something wrong
|
|
@@log.warn("unable to enqueue")
|
|
false
|
|
end
|
|
end
|
|
|
|
def self.perform(category, action, data)
|
|
@@log.info("starting (#{category}, #{action})")
|
|
raise "no google analytics tracking ID" unless APP_CONFIG.ga_ua
|
|
params = {
|
|
v: APP_CONFIG.ga_ua_version,
|
|
tid: APP_CONFIG.ga_ua,
|
|
cid: APP_CONFIG.ga_anonymous_client_id,
|
|
t: "event",
|
|
ec: category,
|
|
ea: action,
|
|
el: 'data',
|
|
ev: data.to_s
|
|
}
|
|
RestClient.post(APP_CONFIG.ga_endpoint, params: params, timeout: 8, open_timeout: 8)
|
|
@@log.info("done (#{category}, #{action})")
|
|
end
|
|
|
|
end
|
|
end
|