# encoding: utf-8

module Github
  class Repos::PubSubHubbub < API
    OPTIONS = {
      :headers => {
        CONTENT_TYPE => 'application/x-www-form-urlencoded'
      }
    }

    # Subscribe to existing topic/event through pubsubhubbub
    #
    # = Parameters
    # * topic - Required string - The URI of the GitHub repository to subscribe to. The path must be in the format of /:user/:repo/events/:event.
    # * callback - Required string - The URI to receive the updates to the topic.
    #
    # = Examples
    #  github = Github.new :oauth_token => '...'
    #  github.repos.pubsubhubbub.subscribe
    #    'https://github.com/:user/:repo/events/push',
    #    'github://Email?address=peter-murach@gmail.com',
    #    :verify => 'sync',
    #    :secret => '...'
    #
    def subscribe(topic, callback, params={})
      assert_presence_of topic, callback
      normalize! params
      _merge_action!("subscribe", topic, callback, params)

      post_request("/hub", params, OPTIONS)
    end

    # Unsubscribe from existing topic/event through pubsubhubbub
    #
    # = Parameters
    # * topic - Required string - The URI of the GitHub repository to unsubscribe from. The path must be in the format of /:user/:repo/events/:event.
    # * callback - Required string - The URI to unsubscribe the topic from.
    #
    # = Examples
    #  github = Github.new :oauth_token => '...'
    #  github.repos.pubsubhubbub.unsubscribe
    #    'https://github.com/:user/:repo/events/push',
    #    'github://Email?address=peter-murach@gmail.com',
    #    :verify => 'sync',
    #    :secret => '...'
    #
    def unsubscribe(topic, callback, params={})
      assert_presence_of topic, callback
      normalize! params
      _merge_action!("unsubscribe", topic, callback, params)

      post_request("/hub", params, OPTIONS)
    end

    # Subscribe repository to service hook through pubsubhubbub
    #
    # = Parameters
    # * repo-name - Required string,
    # * service-name - Required string
    # * <tt>:event</tt> - Required hash key for the type of event. The default event is <tt>push</tt>
    #
    # = Examples
    #  github = Github.new :oauth_token => '...'
    #  github.repos.pubsubhubbub.subscribe_service 'user-name', 'repo-name', 'campfire',
    #    :subdomain => 'github',
    #    :room => 'Commits',
    #    :token => 'abc123',
    #    :event => 'watch'
    #
    def subscribe_service(user_name, repo_name, service_name, params={})
      assert_presence_of user_name, repo_name, service_name
      normalize! params
      event = params.delete('event') || 'push'
      topic = "https://github.com/#{user_name}/#{repo_name}/events/#{event}"
      callback = "github://#{service_name}?#{params.serialize}"

      subscribe(topic, callback)
    end
    alias :subscribe_repository :subscribe_service
    alias :subscribe_repo :subscribe_service

    # Subscribe repository to service hook through pubsubhubbub
    #
    # = Parameters
    # * repo-name - Required string,
    # * service-name - Required string
    # * <tt>:event</tt> - Optional hash key for the type of event. The default event is <tt>push</tt>
    #
    # = Examples
    #  github = Github.new :oauth_token => '...'
    #  github.repos.pubsubhubbub.unsubscribe_service 'user-name', 'repo-name', 'campfire'
    #
    def unsubscribe_service(user_name, repo_name, service_name, params={})
      assert_presence_of user_name, repo_name, service_name
      normalize! params
      event = params.delete('event') || 'push'
      topic = "https://github.com/#{user_name}/#{repo_name}/events/#{event}"
      callback = "github://#{service_name}"

      unsubscribe(topic, callback)
    end
    alias :unsubscribe_repository :unsubscribe_service
    alias :unsubscribe_repo :unsubscribe_service

  private

    def _merge_action!(action, topic, callback, params) # :nodoc:
      options = {
        "hub.mode"     => action.to_s,
        "hub.topic"    => topic.to_s,
        "hub.callback" => callback,
        "hub.verify"   => params.delete('verify') || 'sync',
        "hub.secret"   => params.delete('secret') || ''
      }
      params.merge! options
    end

  end # Repos::PubSubHubbub
end # Github