class Service < ActiveRecord::Base
  PROVIDER_TO_ENV_MAP = {'37signals' => 'THIRTY_SEVEN_SIGNALS'}

  attr_accessible :provider, :name, :token, :secret, :refresh_token, :expires_at, :global, :options

  serialize :options, Hash

  belongs_to :user, :inverse_of => :services
  has_many :agents, :inverse_of => :service

  validates_presence_of :user_id, :provider, :name, :token

  before_destroy :disable_agents

  scope :available_to_user, lambda { |user| where("services.user_id = ? or services.global = true", user.id) }
  scope :by_name, lambda { |dir = 'desc'| order("services.name #{dir}") }

  def disable_agents
    agents.each do |agent|
      agent.service_id = nil
      agent.disabled = true
      agent.save!(validate: false)
    end
  end

  def toggle_availability!
    self.global = !self.global
    self.save!
  end

  def prepare_request
    if expires_at && Time.now > expires_at
      refresh_token!
    end
  end

  def refresh_token!
    response = HTTParty.post(endpoint, query: {
                  type:          'refresh',
                  client_id:     oauth_key,
                  client_secret: oauth_secret,
                  refresh_token: refresh_token
    })
    data = JSON.parse(response.body)
    update(expires_at: Time.now + data['expires_in'], token: data['access_token'], refresh_token: data['refresh_token'].presence || refresh_token)
  end

  def endpoint
    client_options = "OmniAuth::Strategies::#{OmniAuth::Utils.camelize(self.provider)}".constantize.default_options['client_options']
    URI.join(client_options['site'], client_options['token_url'])
  end

  def provider_to_env
    PROVIDER_TO_ENV_MAP[provider].presence || provider.upcase
  end

  def oauth_key
    ENV["#{provider_to_env}_OAUTH_KEY"]
  end

  def oauth_secret
    ENV["#{provider_to_env}_OAUTH_SECRET"]
  end

  def self.provider_specific_options(omniauth)
    case omniauth['provider']
      when '37signals'
        { user_id: omniauth['extra']['accounts'][0]['id'] }
      else
        {}
    end
  end

  def self.initialize_or_update_via_omniauth(omniauth)
    find_or_initialize_by(provider: omniauth['provider'], name: omniauth['info']['nickname'] || omniauth['info']['name']).tap do |service|
      service.assign_attributes token: omniauth['credentials']['token'],
                                secret: omniauth['credentials']['secret'],
                                refresh_token: omniauth['credentials']['refresh_token'],
                                expires_at: omniauth['credentials']['expires_at'] && Time.at(omniauth['credentials']['expires_at']),
                                options: provider_specific_options(omniauth)
    end
  end
end