cartodb/lib/resque/tracking_jobs.rb

require 'hubspot/events_api'
require 'carto/tracking/services/pubsub_tracker'

module Resque
  module TrackingJobs
    module SendPubSubEvent
      @queue = :tracker

      def self.perform(user_id, name, properties)
        PubSubTracker.instance.send_event(:metrics, user_id, name, properties)
      end
    end

    module SendSegmentEvent
      ANONYMOUS_SEGMENT_USER_ID = '00000000-0000-0000-0000-000000000000'.freeze

      @queue = :tracker

      def self.perform(user_id, name, properties)
        return unless segment_api_key = Cartodb.get_config(:segment, 'api_key')

        segment = Segment::Analytics.new(write_key: segment_api_key)
        segment.track(user_id: user_id || ANONYMOUS_SEGMENT_USER_ID, event: name, properties: properties)
        segment.flush
      rescue => exception
        CartoDB::Logger.warning(message: 'Can\'t report to Segment',
                                exception: exception,
                                event: name,
                                properties: properties)
      end
    end

    module SendHubspotEvent
      @queue = :tracker

      def self.perform(id, params)
        events_api = ::Hubspot::EventsAPI.instance
        return unless events_api.enabled?

        code, body = events_api.report(id, params: params)

        unless code == '200' && body.present?
          message = 'Carto::Tracking: Hubspot service error'
          CartoDB::Logger.error(message: message, event_id: id, params: params)
        end
      end
    end
  end
end