class RemoteSubject < ActiveRecord::Base
  include SocialStream::Models::Subject
  # Create absolute routes
  include Rails.application.routes.url_helpers

  attr_reader :url_helper
  attr_accessible :webfinger_id

  # Save webfinger_info hash into the database
  serialize :webfinger_info

  validates_uniqueness_of :webfinger_id

  before_validation :fill_information,
                    :on => :create

  after_create  :subscribe_to_public_feed
  after_destroy :unsubscribe_to_public_feed

  scope :webfinger_alias, lambda { |uri|
    where('webfinger_info LIKE ?', "%aliases%#{ uri }%")
  }
  
  #validates_format_of :webfinger_slug, :with => Devise.email_regexp, :allow_blank => true
  
  class << self
    def find_or_create_by_webfinger_uri!(uri)
      if uri =~ /^https?:\/\//
        records = webfinger_alias(uri)

        # SQL scope is not reliable
        if records.present?
          return records.find{ |r| r.webfinger_aliases.include?(uri) }
        end

        # TODO: create by http uri?

        raise ::ActiveRecord::RecordNotFound
      end

      id = uri.dup

      if id =~ /^acct:/
        id.gsub!('acct:', '')
      end

      find_or_create_by_webfinger_id!(id)
    end
  end
  
  # Return the slug in the webfinger_id
  def webfinger_slug
    splitted_webfinger_id.first
  end

  # Return the origin url in the webfinger_id
  def webfinger_url
    splitted_webfinger_id.last
  end

  # URL of the activity feed from this {RemoteSubject}
  def public_feed_url
    webfinger_info[:updates_from]
  end

  # URL of the Salmon endpoint for this {RemoteSubject}
  def salmon_url
    webfinger_info[:salmon]
  end

  # Webfinger Alias
  def webfinger_aliases
    webfinger_info[:aliases]
  end

  # Fetch the webfinger again
  def refresh_webfinger!
    fill_webfinger_info

    save!
  end

  private

  def splitted_webfinger_id
    @splitted_webfinger_id ||=
      webfinger_id.split('@')
  end

  def fill_information
    fill_webfinger_info

    self.name = webfinger_id
  end

  def fill_webfinger_info
    self.webfinger_info = build_webfinger_info
    self.rsa_key = finger.magic_key
  end

  def build_webfinger_info
    {
      updates_from: finger.links[:updates_from],
      salmon:       finger.links[:salmon],
      aliases:      finger.alias
    }
  end

  def finger
    @finger ||=
      fetch_finger
  end

  def fetch_finger
    finger = 
      Proudhon::Finger.fetch webfinger_id

    # FIXME custom error
    raise ::ActiveRecord::RecordNotFound if finger.blank?

    finger
  end

  def subscribe_to_public_feed
    return if public_feed_url.blank?

    atom = Proudhon::Atom.from_uri(public_feed_url)

    atom.subscribe(pshb_url(:host => SocialStream::Ostatus.pshb_host))
  end

  def unsubscribe_to_public_feed
    return if public_feed_url.blank?

    atom = Proudhon::Atom.from_uri(public_feed_url)

    atom.unsubscribe(pshb_url(:host => SocialStream::Ostatus.pshb_host))
  end
end