abstract_sendgrid_client.rb

module SendgridToolkit
  class AbstractSendgridClient

    def initialize(api_user = nil, api_key = nil)
      @api_user = api_user || SendgridToolkit.api_user || ENV['SMTP_USERNAME']
      @api_key = api_key || SendgridToolkit.api_key || ENV['SMTP_PASSWORD']

      raise SendgridToolkit::NoAPIUserSpecified if @api_user.nil? || @api_user.length == 0
      raise SendgridToolkit::NoAPIKeySpecified if @api_key.nil? || @api_key.length == 0
    end

    protected

    def api_post(module_name, action_name, opts = {})
      base_path = compose_base_path(module_name, action_name)
      response = HTTParty.post("https://#{SendgridToolkit.base_uri}/#{base_path}.json",
                               :body => get_credentials.merge(opts),
                               :format => :json)
      if response.code > 403
        raise(SendgridToolkit::SendgridServerError, "The SendGrid server returned an error. #{response.inspect}")
      elsif has_error?(response) &&
          response['error'].respond_to?(:has_key?) &&
          response['error'].has_key?('code') &&
          [401, 403].include?(response['error']['code'].to_i)
        raise SendgridToolkit::AuthenticationFailed
      elsif has_error?(response)
        raise(SendgridToolkit::APIError, response['error'])
      end
      response
    end

    def get_credentials
      {:api_user => @api_user, :api_key => @api_key}
    end

    def compose_base_path(module_name, action_name)
      "#{module_name}.#{action_name}"
    end

    private
    def has_error?(response)
      response.kind_of?(Hash) && response.has_key?('error')
    end
  end
end