require 'xmpp4r/roster'

class JabberNotifier
  attr_accessor :subscribers, :account, :password

  def initialize(project = nil)
    @subscribers = []
    @account = ''
    @password = ''
  end

  def connect
    CruiseControl::Log.debug("Jabber notifier: connecting to #{@account}")
    @client = Jabber::Client.new(@account)
    @client.connect
    CruiseControl::Log.debug("Jabber notifier: authenticating")
    @client.auth(@password)
  end

  def disconnect
    CruiseControl::Log.debug("Jabber notifier: disconnecting from #{@account}")
    @client.close if @client.respond_to?(:is_connected?) && @client.is_connected?
  end

  def reconnect
    disconnect
    connect
  end

  def connected?
    @client.respond_to?(:is_connected?) && @client.is_connected?
  end

  def build_broken(broken_build, previous_build)
    if @subscribers.empty?
      CruiseControl::Log.debug("Jabber notifier: no subscribers registered, 'build broken' ignored")
    else
      CruiseControl::Log.debug("Jabber notifier: sending 'build fixed' notice")
      notify("#{broken_build.project.name} Build #{broken_build.label} - BROKEN")
    end
  end

  def build_fixed(fixed_build, previous_build)
    if @subscribers.empty?
      CruiseControl::Log.debug("Jabber notifier: no subscribers registered, 'build fixed' ignored")
    else
      CruiseControl::Log.debug("Jabber notifier: sending 'build fixed' notice")
      notify("#{fixed_build.project.name} Build #{fixed_build.label} - FIXED")
    end
  end

  def notify(message)
    connect
    begin
      @subscribers.each do |subscriber|
        jid = Jabber::JID::new(subscriber)
        msg = Jabber::Message.new(jid)
        msg.type = :normal
        msg.body = message
        attempts = 0
        CruiseControl::Log.debug("Jabber notifier: sending '#{message}' to #{subscriber}")
        begin
          attempts += 1
          @client.send(msg)
        rescue Errno::EPIPE, IOError => e
          CruiseControl::Log.debug("Jabber notifier: #{e.message}")
          sleep 0.33
          reconnect
          retry unless attempts > 3
          raise
        end
      end
    ensure
      disconnect rescue nil
    end
  end

  def subscribe(subscriber)
    request = Jabber::Presence.new.set_type(:subscribe)
    request.to = subscriber
    @client.send(request)
  end

  def unsubscribe(subscriber)
    request = Jabber::Presence.new.set_type(:unsubscribe)
    request.to = subscriber
    @client.send(request)
    @client.send(request.set_type(:unsubscribed))
  end

end