openSUSE/open-build-service

class UpdateNotificationEvents
  cattr_accessor :semaphore

  def initialize
    self.class.semaphore = semaphore || Mutex.new
  end

  def create_events
    Event::Base.transaction do
      data = type = nil
      @last.elements('notification') do |e|
        type = e['type']
        data = {}
        e.elements('data') do |d|
          data[d['key']] = d['_content']
        end
        retries = 10
        begin
          event = Event::Factory.new_from_type(type, data)
          event.save!
        rescue ActiveRecord::StatementInvalid => e
          retries -= 1
          retry if retries.positive?
          Airbrake.notify("Failed to create Event : #{type.inspect}: #{data} #{e}")
        rescue StandardError => e
          if Rails.env.test?
            # make debug output useful in test suite, not just showing backtrace to Airbrake
            Rails.logger.error "ERROR: #{e.inspect}: #{e.backtrace}"
            Rails.logger.info e.inspect
            Rails.logger.info e.backtrace
          end
          Airbrake.notify("Failed to create Event : #{type.inspect}: #{data} #{e}")
        end
      end
    end

    BackendInfo.lastnotification_nr = Integer(@last['next'])
  end

  def perform
    if semaphore.locked?
      Rails.logger.debug 'skip lastnotifications, still locked'
      return
    end

    # pick first admin so we can see all projects - as this function is called from delayed job
    User.session ||= User.get_default_admin

    loop do
      semaphore.synchronize do
        nr = BackendInfo.lastnotification_nr
        # 0 is a bad start
        nr = 1 if nr.zero?

        begin
          @last = Xmlhash.parse(Backend::Api::Server.last_notifications(nr))
        rescue Net::ReadTimeout, EOFError, Backend::Error
          return
        end

        if @last['sync'] == 'lost'
          # we're doomed, but we can't help - it's not supposed to happen
          BackendInfo.lastnotification_nr = Integer(@last['next'])
          return
        end

        create_events
      end

      break if !defined?(@last) || @last['limit_reached'].blank?
    end
  end
end