Sha256: aa489e3aabc6904a204a88d391fac7726868ebec04e9abdadd8786c21f3ffedc
Contents?: true
Size: 1.95 KB
Versions: 7
Compression:
Stored size: 1.95 KB
Contents
# frozen_string_literal: true
require 'faraday'
require 'faraday_middleware'
require 'json'
require 'active_support/core_ext/hash/indifferent_access'
require 'dato/version'
require 'dato/account/repo/account'
require 'dato/account/repo/site'
require 'dato/api_error'
require 'cacert'
module Dato
module Account
class Client
REPOS = {
account: Repo::Account,
sites: Repo::Site
}.freeze
attr_reader :token, :base_url, :schema, :extra_headers
def initialize(
token,
base_url: 'https://account-api.datocms.com',
extra_headers: {}
)
@base_url = base_url
@token = token
@extra_headers = extra_headers
end
REPOS.each do |method_name, repo_klass|
define_method method_name do
instance_variable_set(
"@#{method_name}",
instance_variable_get("@#{method_name}") ||
repo_klass.new(self)
)
end
end
def request(*args)
connection.send(*args).body.with_indifferent_access
rescue Faraday::SSLError => e
raise e if ENV['SSL_CERT_FILE'] == Cacert.pem
Cacert.set_in_env
request(*args)
rescue Faraday::ConnectionFailed, Faraday::TimeoutError => e
raise e
rescue Faraday::ClientError => e
raise ApiError, e
end
private
def connection
options = {
url: base_url,
headers: extra_headers.merge(
'Accept' => 'application/json',
'Content-Type' => 'application/json',
'Authorization' => "Bearer #{@token}",
'User-Agent' => "ruby-client v#{Dato::VERSION}"
)
}
@connection ||= Faraday.new(options) do |c|
c.request :json
c.response :json, content_type: /\bjson$/
c.response :raise_error
c.use FaradayMiddleware::FollowRedirects
c.adapter :net_http
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems