require 'xmpp4r'
require 'xmpp4r/muc/helper/simplemucclient'

class XMPPDiff < Oxidized::Hook
  def validate_cfg!
    raise KeyError, 'hook.jid is required' unless cfg.has_key?('jid')
    raise KeyError, 'hook.password is required' unless cfg.has_key?('password')
    raise KeyError, 'hook.channel is required' unless cfg.has_key?('channel')
    raise KeyError, 'hook.nick is required' unless cfg.has_key?('nick')
 end

  def run_hook(ctx)
    if ctx.node
      if ctx.event.to_s == "post_store"
        begin
          Timeout::timeout(15) do
            gitoutput = ctx.node.output.new
            diff = gitoutput.get_diff ctx.node, ctx.node.group, ctx.commitref, nil

            interesting = diff[:patch].lines.to_a[4..-1].any? { |line|
              ["+", "-"].include?(line[0]) and not ["#", "!"].include?(line[1])
            }
            interesting &&= diff[:patch].lines.to_a[5..-1].any? { |line| line[0] == '-' }
            interesting &&= diff[:patch].lines.to_a[5..-1].any? { |line| line[0] == '+' }

            if interesting
              log "Connecting to XMPP"
              client = Jabber::Client.new(Jabber::JID.new(cfg.jid))
              client.connect
              sleep 1
              client.auth(cfg.password)
              sleep 1

              log "Connected"

              m = Jabber::MUC::SimpleMUCClient.new(client)
              m.join(cfg.channel + "/" + cfg.nick)

              log "Joined"

              title = "#{ctx.node.name.to_s} #{ctx.node.group.to_s} #{ctx.node.model.class.name.to_s.downcase}"
              log "Posting diff as snippet to #{cfg.channel}"

              m.say(title + "\n\n" + diff[:patch].lines.to_a[4..-1].join)

              sleep 1

              client.close

              log "Finished"

            end
          end
        rescue Timeout::Error
          log "timed out"
        end
      end
    end
  end
end