# 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/account/repo/deploy_event' require 'dato/api_error' require 'cacert' module Dato module Account class Client REPOS = { account: Repo::Account, sites: Repo::Site, deploy_events: Repo::DeployEvent }.freeze attr_reader :token, :base_url, :schema, :extra_headers def initialize(token, options = {}) @token = token @base_url = options[:base_url] || 'https://account-api.datocms.com' @extra_headers = options[: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