Sha256: 45e73221f421bb93c820068c92bf3a28bb15cf4793f9773ec26dd683d516a2bb
Contents?: true
Size: 1.54 KB
Versions: 8
Compression:
Stored size: 1.54 KB
Contents
# frozen_string_literal: true
module RudderAnalyticsSync
class Request
BASE_URL = 'https://hosted.rudderlabs.com'
DEFAULT_HEADERS = {
'Content-Type' => 'application/json',
'accept' => 'application/json'
}.freeze
attr_reader :write_key, :data_plane_url, :error_handler, :stub, :logger, :http_options
def initialize(client)
@write_key = client.config.write_key
@data_plane_url = client.config.data_plane_url || BASE_URL
@error_handler = client.config.on_error
@stub = client.config.stub
@logger = client.config.logger
@http_options = client.config.http_options
end
def post(path, payload, headers: DEFAULT_HEADERS) # rubocop:disable Metrics/AbcSize, Metrics/MethodLength
response = nil
status_code = nil
response_body = nil
uri = URI(data_plane_url)
payload = JSON.generate(payload)
if stub
logger.debug "stubbed request to \
#{path}: write key = #{write_key}, \
payload = #{payload}"
{ status: 200, error: nil }
else
Net::HTTP.start(uri.host, uri.port, :ENV, http_options) do |http|
request = Net::HTTP::Post.new(path, headers)
request.basic_auth write_key, nil
http.request(request, payload).tap do |res|
status_code = res.code
response_body = res.body
response = res
response.value
end
end
end
rescue StandardError => e
error_handler.call(status_code, response_body, e, response)
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems