rosa-build/lib/abf_worker/publish_observer.rb

module AbfWorker
  class PublishObserver < AbfWorker::BaseObserver
    @queue = :publish_observer


    def self.perform(options)
      new(options, BuildList).perform
    end

    def perform
      return if status == STARTED # do nothing when publication started
      if options['type'] == 'resign'
        AbfWorker::BuildListsPublishTaskManager.unlock_repository options['id']
      else
        if options['extra']['regenerate'] # Regenerate metadata
          AbfWorker::BuildListsPublishTaskManager.unlock_rep_and_platform nil, options['extra']['lock_str']
        elsif options['extra']['create_container'] # Container has been created
          case status
          when COMPLETED
            subject.published_container
          when FAILED, CANCELED
            subject.fail_publish_container
          end
          update_results
        else
          update_rpm_builds
        end
      end
    end

    protected

    def update_rpm_builds
      build_lists = BuildList.where(:id => options['build_list_ids'])
      build_lists.each do |build_list| 
        update_results build_list
        case status
        when COMPLETED
          build_list.published
        when FAILED, CANCELED
          build_list.fail_publish
        end
        AbfWorker::BuildListsPublishTaskManager.unlock_build_list build_list
      end

      case status
      when COMPLETED
        AbfWorker::BuildListsPublishTaskManager.cleanup_completed options['projects_for_cleanup']
      when FAILED, CANCELED
        AbfWorker::BuildListsPublishTaskManager.cleanup_failed options['projects_for_cleanup']
      end

      AbfWorker::BuildListsPublishTaskManager.unlock_rep_and_platform(build_lists.first || subject)
    end

    def update_results(build_list = subject)
      results = (build_list.results || []).
        select{ |r| r['file_name'] !~ /^abfworker\:\:publish\-worker.*\.log$/ }
      results |= options['results']
      sort_results_and_save results, build_list
    end
  end
end