You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
100 lines
2.7 KiB
100 lines
2.7 KiB
require 'rollbar'
|
|
require 'singleton'
|
|
require_relative '../carto/http/client'
|
|
|
|
|
|
# Development info: http://developers.hubspot.com/docs/overview
|
|
module CartoDB
|
|
class Hubspot
|
|
|
|
include Singleton
|
|
include ::LoggerHelper
|
|
|
|
attr_reader :event_ids, :form_ids, :token
|
|
|
|
def initialize
|
|
metrics = Cartodb.config[:metrics]
|
|
if metrics.present? && metrics['hubspot'].present? && metrics['hubspot'].is_a?(Hash)
|
|
config = metrics['hubspot']
|
|
@enabled = true
|
|
@events_host = config.fetch('events_host')
|
|
@event_ids = config.fetch('event_ids')
|
|
@form_ids = config.fetch('form_ids')
|
|
@token = config.fetch('token')
|
|
else
|
|
@enabled = false
|
|
end
|
|
end
|
|
|
|
def enabled?
|
|
@enabled == true
|
|
end
|
|
|
|
def track_import_failed(payload)
|
|
track_event('import_failed', payload)
|
|
end
|
|
|
|
def track_geocoding_failed(payload)
|
|
track_event('geocoding_failed', payload)
|
|
end
|
|
|
|
def track_import_success(payload)
|
|
track_event('import_success', payload)
|
|
end
|
|
|
|
def track_geocoding_success(payload)
|
|
track_event('geocoding_success', payload)
|
|
end
|
|
|
|
|
|
private
|
|
|
|
def track_event(event_name, metric_payload)
|
|
return self unless enabled?
|
|
|
|
event_id = event_ids[event_name]
|
|
|
|
#remove the log from the payload
|
|
payload = metric_payload.select {|k,v| k != :log }
|
|
|
|
response = get_events("/v1/event/?_a=#{@token}&_n=#{event_id}&email=#{payload[:email]}")
|
|
|
|
unless (!response.nil? && response.code == 200)
|
|
log_error(message: 'Hubspot error tracking event', payload: payload, event: { id: event_id })
|
|
end
|
|
|
|
self
|
|
end
|
|
|
|
def get_events(endpoint, valid_response_codes = [ 200 ])
|
|
send_request(events_url(endpoint), 'GET', nil, valid_response_codes)
|
|
end
|
|
|
|
def events_url(endpoint)
|
|
"#{@events_host}#{endpoint}"
|
|
end
|
|
|
|
def send_request(url, method, content = nil, valid_response_codes = [ 200 ])
|
|
http_client = Carto::Http::Client.get('hubspot')
|
|
response = http_client.request(
|
|
url,
|
|
method: method,
|
|
headers: { "Content-Type" => "application/json" },
|
|
body: content.nil? ? nil : content.to_json,
|
|
ssl_verifypeer: true,
|
|
timeout: 600
|
|
).run
|
|
|
|
if !valid_response_codes.include?(response.code)
|
|
raise "Hubspot error #{response.code}"
|
|
end
|
|
|
|
response
|
|
rescue StandardError => e
|
|
log_error(exception: e, request: { url: url, body: content }, error_detail: response)
|
|
nil
|
|
end
|
|
|
|
end
|
|
end
|