src/api/app/controllers/webui/package_controller.rb
require 'project'
class Webui::PackageController < Webui::WebuiController
require_dependency 'opensuse/validator'
include ParsePackageDiff
include Webui::PackageHelper
include Webui::ManageRelationships
include BuildLogSupport
before_action :set_project, only: [:show, :index, :users, :dependency, :binary, :binaries, :requests, :statistics, :revisions,
:branch_diff_info, :rdiff, :save_new, :save, :remove, :add_file, :save_file,
:remove_file, :save_person, :save_group, :remove_role, :view_file, :abort_build, :trigger_rebuild,
:trigger_services, :wipe_binaries, :buildresult, :rpmlint_result, :rpmlint_log, :meta, :save_meta, :files,
:binary_download]
before_action :require_package, only: [:show, :dependency, :binary, :binaries, :requests, :statistics, :revisions,
:branch_diff_info, :rdiff, :save, :save_meta, :remove, :add_file, :save_file,
:remove_file, :save_person, :save_group, :remove_role, :view_file, :abort_build, :trigger_rebuild,
:trigger_services, :wipe_binaries, :buildresult, :rpmlint_result, :rpmlint_log, :meta, :files, :users,
:binary_download]
before_action :validate_xml, only: [:save_meta]
before_action :require_repository, only: [:binary, :binary_download]
before_action :require_architecture, only: [:binary, :binary_download]
before_action :check_ajax, only: [:update_build_log, :devel_project, :buildresult, :rpmlint_result]
# make sure it's after the require_, it requires both
before_action :require_login, except: [:show, :index, :dependency, :branch_diff_info, :binary, :binaries,
:users, :requests, :statistics, :commit, :revisions, :rdiff, :view_file, :live_build_log,
:update_build_log, :devel_project, :buildresult, :rpmlint_result, :rpmlint_log, :meta, :files]
before_action :check_build_log_access, only: [:live_build_log, :update_build_log]
before_action :check_package_name_for_new, only: [:save_new]
before_action :handle_parameters_for_rpmlint_log, only: [:rpmlint_log]
prepend_before_action :lockout_spiders, only: [:revisions, :dependency, :rdiff, :binary, :binaries, :requests, :binary_download]
after_action :verify_authorized, only: [:remove_file, :remove, :save_file, :abort_build, :trigger_rebuild, :wipe_binaries, :save_meta, :save, :abort_build]
def index
render json: PackageDatatable.new(params, view_context: view_context, project: @project)
end
def show
if request.bot?
params.delete(:rev)
params.delete(:srcmd5)
@expand = 0
elsif params[:expand]
@expand = params[:expand].to_i
else
@expand = 1
end
@srcmd5 = params[:srcmd5]
@revision_parameter = params[:rev]
@bugowners_mail = (@package.bugowner_emails + @project.bugowner_emails).uniq
@revision = params[:rev]
@failures = 0
@is_current_rev = false
if set_file_details
if @forced_unexpand.blank? && @service_running.blank?
@is_current_rev = (@revision == @current_rev)
elsif @service_running
flash.clear
flash.now[:notice] = "Service currently running (<a href='#{package_show_path(project: @project, package: @package)}'>reload page</a>)."
else
@more_info = @package.service_error
flash.now[:error] = "Files could not be expanded: #{@forced_unexpand}"
end
elsif @revision_parameter
flash[:error] = "No such revision: #{@revision_parameter}"
redirect_back(fallback_location: { controller: :package, action: :show, project: @project, package: @package })
return
end
@comments = @package.comments.includes(:user)
@comment = Comment.new
@services = @files.any? { |file| file[:name] == '_service' }
end
def main_object
@package # used by mixins
end
# rubocop:disable Lint/NonLocalExitFromIterator
def dependency
dependant_project = Project.find_by_name(params[:dependant_project]) || Project.find_remote_project(params[:dependant_project]).try(:first)
unless dependant_project
flash[:error] = "Project '#{params[:dependant_project]}' is invalid."
redirect_back(fallback_location: root_path)
return
end
unless Architecture.archcache.include?(params[:arch])
flash[:error] = "Architecture '#{params[:arch]}' is invalid."
redirect_back(fallback_location: project_show_path(project: @project.name))
return
end
# FIXME: It can't check repositories of remote projects
project_repositories = dependant_project.remoteurl.blank? ? dependant_project.repositories.pluck(:name) : []
[:repository, :dependant_repository].each do |repo_key|
next if project_repositories.include?(params[repo_key])
flash[:error] = "Repository '#{params[repo_key]}' is invalid."
redirect_back(fallback_location: project_show_path(project: @project.name))
return
end
@arch = params[:arch]
@repository = params[:repository]
@dependant_repository = params[:dependant_repository]
@dependant_project = params[:dependant_project]
@package_name = "#{params[:package]}:#{params[:dependant_name]}"
# Ensure it really is just a file name, no '/..', etc.
@filename = File.basename(params[:filename])
@fileinfo = Backend::Api::BuildResults::Binaries.fileinfo_ext(params[:dependant_project], '_repository', params[:dependant_repository],
@arch, params[:dependant_name])
return if @fileinfo # avoid displaying an error for non-existing packages
redirect_back(fallback_location: { action: :binary, project: params[:project], package: params[:package],
repository: @repository, arch: @arch, filename: @filename })
end
# rubocop:enable Lint/NonLocalExitFromIterator
def statistics
@repository = params[:repository]
@package_name = params[:package]
@statistics = LocalBuildStatistic::ForPackage.new(package: @package_name,
project: @project.name,
repository: @repository,
architecture: params[:arch]).results
end
def binary
@package_name = params[:package]
# Ensure it really is just a file name, no '/..', etc.
@filename = File.basename(params[:filename])
@fileinfo = Backend::Api::BuildResults::Binaries.fileinfo_ext(@project, @package_name, @repository.name, @arch.name, @filename)
unless @fileinfo
raise ActiveRecord::RecordNotFound, 'Not Found'
end
url_generator = ::PackageControllerService::URLGenerator.new(project: @project, package: @package_name,
user: User.possibly_nobody, arch: @arch,
repository: @repository, filename: @filename)
@download_url = url_generator.download_url_for_file_in_repo
logger.debug "accepting #{request.accepts.join(',')} format:#{request.format}"
# little trick to give users eager to download binaries a single click
redirect_to(@download_url) && return if request.format != Mime[:html] && @download_url
end
def binaries
@repository = params[:repository]
@package_name = params[:package]
results_from_backend = Buildresult.find_hashed(project: @project, package: @package_name, repository: @repository, view: ['binarylist', 'status'])
if results_from_backend.empty?
raise ActiveRecord::RecordNotFound, 'Not Found'
end
@buildresults = []
repository = Repository.find_by_project_and_name(@project.to_s, @repository)
results_from_backend.elements('result') do |result|
build_results_set = { arch: result['arch'], statistics: false, repocode: result['state'], binaries: [] }
result.get('binarylist').try(:elements, 'binary') do |binary|
if binary['filename'] == '_statistics'
build_results_set[:statistics] = true
else
links = links_for_binaries_action(@project, @package_name, repository, result['arch'], binary['filename'])
build_results_set[:binaries] << { filename: binary['filename'], size: binary['size'], links: links }
end
end
@buildresults << build_results_set
end
rescue Backend::Error => e
flash[:error] = e.message
redirect_back(fallback_location: { controller: :package, action: :show, project: @project, package: @package })
end
def users
@users = [@project.users, @package.users].flatten.uniq
@groups = [@project.groups, @package.groups].flatten.uniq
@roles = Role.local_roles
end
def requests
@default_request_type = params[:type] if params[:type]
@default_request_state = params[:state] if params[:state]
end
def revisions
unless @package.check_source_access?
flash[:error] = 'Could not access revisions'
redirect_to action: :show, project: @project.name, package: @package.name
return
end
revision = (params[:rev] || @package.rev).to_i
per_page = params['show_all'] ? revision : 20
@revisions = Kaminari.paginate_array((1..revision).to_a.reverse).page(params[:page]).per(per_page)
end
# FIXME: This should be in Webui::RequestController
def submit_request
target_project_name = params[:targetproject].try(:strip)
package_name = params[:package].strip
project_name = params[:project].strip
if params[:targetpackage].blank?
target_package_name = package_name
else
target_package_name = params[:targetpackage].try(:strip)
end
if target_project_name.blank?
flash[:error] = 'Please provide a target for the submit request'
redirect_to action: :show, project: project_name, package: package_name
return
end
req = nil
begin
BsRequest.transaction do
req = BsRequest.new(state: 'new')
req.description = params[:description]
opts = { source_project: project_name,
source_package: package_name,
target_project: target_project_name,
target_package: target_package_name }
if params[:sourceupdate]
opts[:sourceupdate] = params[:sourceupdate]
elsif params[:project].include?(':branches:')
opts[:sourceupdate] = 'update' # Avoid auto-removal of branch
end
opts[:source_rev] = params[:rev] if params[:rev]
action = BsRequestActionSubmit.new(opts)
req.bs_request_actions << action
req.set_add_revision
req.save!
end
rescue BsRequestAction::Errors::DiffError => e
flash[:error] = "Unable to diff sources: #{e.message}"
rescue BsRequestAction::MissingAction => e
flash[:error] = 'Unable to submit, sources are unchanged'
rescue ::Project::UnknownObjectError,
BsRequestAction::UnknownProject,
BsRequestAction::UnknownTargetPackage => e
redirect_back(fallback_location: root_path, error: "Unable to submit (missing target): #{e.message}")
return
rescue APIError, ActiveRecord::RecordInvalid => e
flash[:error] = "Unable to submit: #{e.message}"
rescue ActiveRecord::RecordInvalid => e
flash[:error] = "Unable to submit: #{e.message}"
end
if flash[:error]
if package_name.blank?
redirect_to(project_show_path(project: project_name))
else
redirect_to(package_show_path(project: project_name, package: package_name))
end
return
end
# Supersede logic has to be below addition as we need the new request id
supersede_errors = []
if params[:supersede_request_numbers]
params[:supersede_request_numbers].each do |request_number|
begin
r = BsRequest.find_by_number!(request_number)
opts = {
newstate: 'superseded',
reason: "Superseded by request #{req.number}",
superseded_by: req.number
}
r.change_state(opts)
rescue APIError => e
supersede_errors << e.message.to_s
end
end
end
if supersede_errors.any?
supersede_notice = 'Superseding failed: '
supersede_notice += supersede_errors.join('. ')
end
flash[:success] = "Created <a href='#{request_show_path(req.number)}'>submit request #{req.number}</a>\
to <a href='#{project_show_path(target_project_name)}'>#{target_project_name}</a>
#{supersede_notice}"
redirect_to(action: 'show', project: project_name, package: package_name)
end
def rdiff
@last_rev = @package.dir_hash['rev']
@linkinfo = @package.linkinfo
if params[:oproject]
@oproject = ::Project.find_by_name(params[:oproject])
@opackage = @oproject.find_package(params[:opackage]) if @oproject && params[:opackage]
end
@last_req = find_last_req
@rev = params[:rev] || @last_rev
@linkrev = params[:linkrev]
options = {}
[:orev, :opackage, :oproject, :linkrev, :olinkrev].each do |k|
options[k] = params[k] if params[k].present?
end
options[:rev] = @rev if @rev
options[:filelimit] = 0 if params[:full_diff] && User.session
options[:tarlimit] = 0 if params[:full_diff] && User.session
return unless get_diff(@project.name, @package.name, options)
# we only look at [0] because this is a generic function for multi diffs - but we're sure we get one
filenames = sorted_filenames_from_sourcediff(@rdiff)[0]
@files = filenames['files']
@not_full_diff = @files.any? { |file| file[1]['diff'].try(:[], 'shown') }
@filenames = filenames['filenames']
# FIXME: moved from the old view, needs refactoring
@submit_url_opts = {}
if @oproject && @opackage && !@oproject.find_attribute('OBS', 'RejectRequests') && !@opackage.find_attribute('OBS', 'RejectRequests')
@submit_message = "Submit to #{@oproject.name}/#{@opackage.name}"
@submit_url_opts[:target_project] = @oproject.name
@submit_url_opts[:targetpackage] = @opackage.name
elsif @rev != @last_rev
@submit_message = "Revert #{@project.name}/#{@package.name} to revision #{@rev}"
@submit_url_opts[:target_project] = @project.name
end
end
def save_new
@package = @project.packages.build(name: @package_name)
@package.title = params[:title]
@package.description = params[:description]
if params[:source_protection]
@package.flags.build(flag: :sourceaccess, status: :disable)
end
if params[:disable_publishing]
@package.flags.build(flag: :publish, status: :disable)
end
if @package.save
flash[:success] = "Package '#{@package.name}' was created successfully"
redirect_to action: :show, project: params[:project], package: @package_name
else
flash[:error] = "Failed to create package '#{@package}'"
redirect_to controller: :project, action: :show, project: params[:project]
end
end
def branch_diff_info
linked_package = @package.backend_package.links_to
target_project = target_package = description = ''
if linked_package
target_project = linked_package.project.name
target_package = linked_package.name
description = @package.commit_message(target_project, target_package)
end
render json: {
'targetProject': target_project,
'targetPackage': target_package,
'description': description,
'cleanupSource': @project.branch? # We should remove the package if this request is a branch
}
end
def branch
params.fetch(:linked_project) { raise ArgumentError, 'Linked Project parameter missing' }
params.fetch(:linked_package) { raise ArgumentError, 'Linked Package parameter missing' }
# Full permission check happens in BranchPackage.new(branch_params).branch command
# Are we linking a package from a remote instance?
# Then just try, the remote instance will handle checking for existence authorization etc.
if Project.find_remote_project(params[:linked_project])
source_project_name = params[:linked_project]
source_package_name = params[:linked_package]
else
options = { use_source: false, follow_project_links: true, follow_multibuild: true }
source_package = Package.get_by_project_and_name(params[:linked_project], params[:linked_package], options)
source_project_name = source_package.project.name
source_package_name = source_package.name
authorize source_package, :branch?
end
branch_params = {
project: source_project_name,
package: source_package_name
}
# Set the branch to the current revision if revision is present
if params[:current_revision].present?
options = { project: source_project_name, package: source_package_name, expand: 1 }
options[:rev] = params[:revision] if params[:revision].present?
dirhash = Directory.hashed(options)
branch_params[:rev] = dirhash['xsrcmd5'] || dirhash['rev']
unless branch_params[:rev]
flash[:error] = dirhash['error'] || 'Package has no source revision yet'
redirect_back(fallback_location: root_path)
return
end
end
branch_params[:target_project] = params[:target_project] if params[:target_project].present?
branch_params[:target_package] = params[:target_package] if params[:target_package].present?
branch_params[:add_repositories_rebuild] = params[:add_repositories_rebuild] if params[:add_repositories_rebuild].present?
branch_params[:autocleanup] = params[:autocleanup] if params[:autocleanup].present?
branched_package = BranchPackage.new(branch_params).branch
created_project_name = branched_package[:data][:targetproject]
created_package_name = branched_package[:data][:targetpackage]
Event::BranchCommand.create(project: source_project_name, package: source_package_name,
targetproject: created_project_name, targetpackage: created_package_name,
user: User.session!.login)
branched_package_object = Package.find_by_project_and_name(created_project_name, created_package_name)
if request.env['HTTP_REFERER'] == image_templates_url && branched_package_object.kiwi_image?
redirect_to(import_kiwi_image_path(branched_package_object.id))
else
flash[:success] = 'Successfully branched package'
redirect_to(package_show_path(project: created_project_name, package: created_package_name))
end
rescue BranchPackage::DoubleBranchPackageError => e
flash[:notice] = 'You have already branched this package'
redirect_to(package_show_path(project: e.project, package: e.package))
rescue Package::UnknownObjectError, Project::UnknownObjectError
flash[:error] = 'Failed to branch: Package does not exist.'
redirect_back(fallback_location: root_path)
rescue ArgumentError => e
flash[:error] = "Failed to branch: #{e.message}"
redirect_back(fallback_location: root_path)
rescue CreateProjectNoPermission
flash[:error] = 'Sorry, you are not authorized to create this Project.'
redirect_back(fallback_location: root_path)
rescue APIError, ActiveRecord::RecordInvalid => e
flash[:error] = "Failed to branch: #{e.message}"
redirect_back(fallback_location: root_path)
end
def save
authorize @package, :update?
@package.title = params[:title]
@package.description = params[:description]
if @package.save
flash[:success] = "Package data for '#{@package.name}' was saved successfully"
else
flash[:error] = "Failed to save package '#{@package.name}': #{@package.errors.full_messages.to_sentence}"
end
redirect_to action: :show, project: params[:project], package: params[:package]
end
def remove
authorize @package, :destroy?
# Don't check weak dependencies if we force
@package.check_weak_dependencies? unless params[:force]
if @package.errors.empty?
@package.destroy
redirect_to(project_show_path(@project), success: 'Package was successfully removed.')
else
redirect_to(package_show_path(project: @project, package: @package),
error: "Package can't be removed: #{@package.errors.full_messages.to_sentence}")
end
end
def trigger_services
authorize @package, :update?
begin
Backend::Api::Sources::Package.trigger_services(@project.name, @package.name, User.session!.to_s)
flash[:success] = 'Services successfully triggered'
rescue Timeout::Error => e
flash[:error] = "Services couldn't be triggered: " + e.message
rescue Backend::Error => e
flash[:error] = "Services couldn't be triggered: " + Xmlhash::XMLHash.new(error: e.summary)[:error]
end
redirect_to package_show_path(@project, @package)
end
def add_file
set_file_details
end
def save_file
authorize @package, :update?
file = params[:file]
file_url = params[:file_url]
filename = params[:filename]
errors = []
begin
if file.present?
# We are getting an uploaded file
filename = file.original_filename if filename.blank?
@package.save_file(file: file, filename: filename, comment: params[:comment])
elsif file_url.present?
# we have a remote file URI, so we have to download and save it
services = @package.services
# detects automatically git://, src.rpm formats
services.addDownloadURL(file_url, filename)
unless services.save
errors << "Failed to add file from URL '#{file_url}'"
end
elsif filename.present? # No file is provided so we just create an empty new file (touch)
@package.save_file(filename: filename)
else
errors << 'No file or URI given'
end
rescue APIError => e
errors << e.message
rescue Backend::Error => e
errors << Xmlhash::XMLHash.new(error: e.summary)[:error]
rescue StandardError => e
errors << e.message
end
if errors.empty?
message = "The file '#{filename}' has been successfully saved."
# We have to check if it's an AJAX request or not
if request.xhr?
flash.now[:success] = message
else
redirect_to({ action: :show, project: @project, package: @package }, success: message)
return
end
else
message = "Error while creating '#{filename}' file: #{errors.compact.join("\n")}."
# We have to check if it's an AJAX request or not
if request.xhr?
flash.now[:error] = message
status = 400
else
redirect_back(fallback_location: root_path, error: message)
return
end
end
status ||= 200
render layout: false, status: status, partial: 'layouts/webui/flash', object: flash
end
def remove_file
authorize @package, :update?
filename = params[:filename]
begin
@package.delete_file(filename)
flash[:success] = "File '#{filename}' removed successfully"
rescue Backend::NotFoundError
flash[:error] = "Failed to remove file '#{filename}'"
end
redirect_to action: :show, project: @project, package: @package
end
def view_file
@filename = params[:filename] || params[:file] || ''
if Package.is_binary_file?(@filename) # We don't want to display binary files
flash[:error] = "Unable to display binary file #{@filename}"
redirect_back(fallback_location: { action: :show, project: @project, package: @package })
return
end
@rev = params[:rev]
@expand = params[:expand]
@addeditlink = false
if User.possibly_nobody.can_modify?(@package) && @rev.blank?
begin
files = package_files(@rev, @expand)
rescue Backend::Error
files = []
end
files.each do |file|
if file[:name] == @filename
@addeditlink = file[:editable]
break
end
end
end
begin
@file = @package.source_file(@filename, fetch_from_params(:rev, :expand))
rescue Backend::NotFoundError
flash[:error] = "File not found: #{@filename}"
redirect_to action: :show, package: @package, project: @project
return
rescue Backend::Error => e
flash[:error] = "Error: #{e}"
redirect_back(fallback_location: { action: :show, project: @project, package: @package })
return
end
render(template: 'webui/package/simple_file_view') && return if @spider_bot
end
def live_build_log
@repo = @project.repositories.find_by(name: params[:repository]).try(:name)
unless @repo
flash[:error] = "Couldn't find repository '#{params[:repository]}'. Are you sure it still exists?"
redirect_to(package_show_path(@project, @package))
return
end
@arch = Architecture.archcache[params[:arch]].try(:name)
unless @arch
flash[:error] = "Couldn't find architecture '#{params[:arch]}'. Are you sure it still exists?"
redirect_to(package_show_path(@project, @package))
return
end
@offset = 0
@status = get_status(@project, @package, @repo, @arch)
@what_depends_on = Package.what_depends_on(@project, @package, @repo, @arch)
@finished = Buildresult.final_status?(status)
set_job_status
end
def update_build_log
# Make sure objects don't contain invalid chars (eg. '../')
@repo = @project.repositories.find_by(name: params[:repository]).try(:name)
unless @repo
@errors = "Couldn't find repository '#{params[:repository]}'. We don't have build log for this repository"
return
end
@arch = Architecture.archcache[params[:arch]].try(:name)
unless @arch
@errors = "Couldn't find architecture '#{params[:arch]}'. We don't have build log for this architecture"
return
end
begin
@maxsize = 1024 * 64
@first_request = params[:initial] == '1'
@offset = params[:offset].to_i
@status = get_status(@project, @package, @repo, @arch)
@finished = Buildresult.final_status?(@status)
@size = get_size_of_log(@project, @package, @repo, @arch)
chunk_start = @offset
chunk_end = @offset + @maxsize
# Start at the most recent part to not get the full log from the begining just the last 64k
if @first_request && (@finished || @size >= @maxsize)
chunk_start = [0, @size - @maxsize].max
chunk_end = @size
end
@log_chunk = get_log_chunk(@project, @package, @repo, @arch, chunk_start, chunk_end)
# retry the last chunk again, because build compare overwrites last log lines
if @log_chunk.length.zero? && !@first_request && !@finished
@log_chunk = get_log_chunk(@project, @package, @repo, @arch, chunk_start, chunk_end)
@finished = true
end
old_offset = @offset
@offset = [chunk_end, @size].min
rescue Timeout::Error, IOError
@log_chunk = ''
rescue Backend::Error => e
if %r{Logfile is not that big}.match?(e.summary)
@log_chunk = ''
elsif /start out of range/.match?(e.summary)
# probably build compare has cut log and offset is wrong, reset offset
@log_chunk = ''
@offset = old_offset
else
@log_chunk = "No live log available: #{e.summary}\n"
@finished = true
end
end
logger.debug 'finished ' + @finished.to_s
end
def abort_build
authorize @package, :update?
if @package.abort_build(params)
flash[:success] = "Triggered abort build for #{@project.name}/#{@package.name} successfully."
redirect_to package_show_path(project: @project, package: @package)
else
flash[:error] = "Error while triggering abort build for #{@project.name}/#{@package.name}: #{@package.errors.full_messages.to_sentence}."
redirect_to package_live_build_log_path(project: @project, package: @package, repository: params[:repository], arch: params[:arch])
end
end
def trigger_rebuild
authorize @package, :update?
if @package.rebuild(params)
flash[:success] = "Triggered rebuild for #{@project.name}/#{@package.name} successfully."
redirect_to package_show_path(project: @project, package: @package)
else
flash[:error] = "Error while triggering rebuild for #{@project.name}/#{@package.name}: #{@package.errors.full_messages.to_sentence}."
redirect_to package_binaries_path(project: @project, package: @package, repository: params[:repository])
end
end
def wipe_binaries
authorize @package, :update?
if @package.wipe_binaries(params)
flash[:success] = "Triggered wipe binaries for #{@project.name}/#{@package.name} successfully."
else
flash[:error] = "Error while triggering wipe binaries for #{@project.name}/#{@package.name}: #{@package.errors.full_messages.to_sentence}."
end
redirect_to package_binaries_path(project: @project, package: @package, repository: params[:repository])
end
def devel_project
tgt_pkg = Package.find_by_project_and_name(params[:project], params[:package])
render plain: tgt_pkg.try(:develpackage).try(:project).to_s
end
def buildresult
if @project.repositories.any?
show_all = params[:show_all] == 'true'
@index = params[:index]
@buildresults = @package.buildresult(@project, show_all)
render partial: 'buildstatus', locals: { buildresults: @buildresults,
index: @index,
project: @project,
collapsed_repositories: params.fetch(:collapsedRepositories, {}) }
else
render partial: 'no_repositories', locals: { project: @project }
end
end
def rpmlint_result
@repo_arch_hash = {}
@buildresult = Buildresult.find_hashed(project: @project.to_param, package: @package.to_param, view: 'status')
repos = [] # Temp var
if @buildresult
@buildresult.elements('result') do |result|
if result.value('repository') != 'images' &&
(result.value('status') && result.value('status').value('code') != 'excluded')
hash_key = valid_xml_id(elide(result.value('repository'), 30))
@repo_arch_hash[hash_key] ||= []
@repo_arch_hash[hash_key] << result['arch']
repos << result.value('repository')
end
end
end
@repo_list = repos.uniq.collect do |repo_name|
[repo_name, valid_xml_id(elide(repo_name, 30))]
end
if @repo_list.empty?
render partial: 'no_repositories', locals: { project: @project }
else
render partial: 'rpmlint_result', locals: { index: params[:index], project: @project, package: @package,
repository_list: @repo_list, repo_arch_hash: @repo_arch_hash }
end
end
def rpmlint_log
begin
@log = Backend::Api::BuildResults::Binaries.rpmlint_log(params[:project], params[:package], params[:repository], params[:architecture])
@log.encode!(xml: :text)
render partial: 'rpmlint_log'
rescue Backend::NotFoundError
render plain: 'No rpmlint log'
end
end
def meta
@meta = @package.render_xml
end
def save_meta
errors = []
authorize @package, :save_meta_update?
if FlagHelper.xml_disabled_for?(@meta_xml, 'sourceaccess')
errors << 'admin rights are required to raise the protection level of a package'
end
if @meta_xml['project'] && @meta_xml['project'] != @project.name
errors << 'project name in xml data does not match resource path component'
end
if @meta_xml['name'] && @meta_xml['name'] != @package.name
errors << 'package name in xml data does not match resource path component'
end
if errors.empty?
begin
@package.update_from_xml(@meta_xml)
flash.now[:success] = 'The Meta file has been successfully saved.'
status = 200
rescue Backend::Error, NotFoundError => e
flash.now[:error] = "Error while saving the Meta file: #{e}."
status = 400
end
else
flash.now[:error] = "Error while saving the Meta file: #{errors.compact.join("\n")}."
status = 400
end
render layout: false, status: status, partial: 'layouts/webui/flash', object: flash
end
def binary_download
package_name = params[:package]
architecture = Architecture.find_by_name(params[:arch]).name
filename = File.basename(params[:filename]) # Ensure it really is just a file name, no '/..', etc.
repository = Repository.find_by_project_and_name(@project.to_s, params[:repository].to_s)
url_generator = ::PackageControllerService::URLGenerator.new(project: @project, package: package_name,
user: User.possibly_nobody, arch: architecture,
repository: repository, filename: filename)
download_url = url_generator.download_url_for_file_in_repo
if download_url
redirect_to download_url
else
redirect_back(fallback_location: root_path)
end
end
private
def validate_xml
Suse::Validator.validate('package', params[:meta])
@meta_xml = Xmlhash.parse(params[:meta])
rescue Suse::ValidationError => e
flash.now[:error] = "Error while saving the Meta file: #{e}."
render layout: false, status: 400, partial: 'layouts/webui/flash', object: flash
end
def package_files(rev = nil, expand = nil)
query = {}
query[:expand] = expand if expand
query[:rev] = rev if rev
dir_xml = @package.source_file(nil, query)
return [] if dir_xml.blank?
dir = Xmlhash.parse(dir_xml)
@serviceinfo = dir.elements('serviceinfo').first
files = []
dir.elements('entry') do |entry|
file = Hash[*[:name, :size, :mtime, :md5].map! { |x| [x, entry.value(x.to_s)] }.flatten]
file[:viewable] = !Package.is_binary_file?(file[:name]) && file[:size].to_i < 2**20 # max. 1 MB
file[:editable] = file[:viewable] && !file[:name].match?(/^_service[_:]/)
file[:srcmd5] = dir.value('srcmd5')
files << file
end
files
end
# Basically backend stores date in /source (package sources) and /build (package
# build related). Logically build logs are stored in /build. Though build logs also
# contain information related to source packages.
# Thus before giving access to the build log, we need to ensure user has source access
# rights.
#
# This before_filter checks source permissions for packages that belong to remote projects,
# to local projects and local projects that link to other project's packages.
#
# If the check succeeds it sets @project and @package variables.
def check_build_log_access
if ::Project.exists_by_name(params[:project])
@project = ::Project.get_by_name(params[:project])
else
redirect_to root_path, error: "Couldn't find project '#{params[:project]}'. Are you sure it still exists?"
return false
end
begin
@package = Package.get_by_project_and_name(@project, params[:package], use_source: false,
follow_multibuild: true,
follow_project_links: true)
rescue Package::UnknownObjectError
redirect_to project_show_path(@project.to_param),
error: "Couldn't find package '#{params[:package]}' in " \
"project '#{@project.to_param}'. Are you sure it exists?"
return false
end
# package is nil for remote projects
if @package && !@package.check_source_access?
redirect_to package_show_path(project: @project.name, package: @package.name),
error: 'Could not access build log'
return false
end
@can_modify = User.possibly_nobody.can_modify?(@project) || User.possibly_nobody.can_modify?(@package)
# for remote and multibuild / local link packages
@package = params[:package] if @package.try(:name) != params[:package]
true
end
def links_for_binaries_action(project, package_name, repository, architecture, filename)
download_url = package_binary_download_path(project: project.name, package: package_name,
repository: repository.name, arch: architecture, filename: filename)
cloud_upload = User.session && uploadable?(filename, architecture)
{ details?: filename != 'rpmlint.log', download_url: download_url, cloud_upload?: cloud_upload }
end
def require_architecture
@arch = Architecture.archcache[params[:arch]]
return if @arch
flash[:error] = "Couldn't find architecture '#{params[:arch]}'"
redirect_to package_binaries_path(project: @project, package: @package, repository: @repository.name)
end
def require_repository
@repository = @project.repositories.find_by(name: params[:repository])
return if @repository
flash[:error] = "Couldn't find repository '#{params[:repository]}'"
redirect_to package_show_path(project: @project, package: @package)
end
def handle_parameters_for_rpmlint_log
params.require([:project, :package, :repository, :architecture])
end
def set_file_details
@forced_unexpand ||= ''
# check source access
@files = []
return false unless @package.check_source_access?
set_linkinfo
begin
@current_rev = @package.rev
@revision = @current_rev if !@revision && !@srcmd5 # on very first page load only
@files = package_files(@srcmd5 || @revision, @expand)
rescue Backend::Error => e
# TODO: crudest hack ever!
if e.summary == 'service in progress' && @expand == 1
@expand = 0
@service_running = true
# silently in this case
return set_file_details
end
if @expand == 1
@forced_unexpand = e.details || e.summary
@expand = 0
return set_file_details
end
return false
end
true
end
def set_linkinfo
return unless @package.is_link?
linked_package = @package.backend_package.links_to
return set_remote_linkinfo unless linked_package
@linkinfo = { package: linked_package, error: @package.backend_package.error }
@linkinfo[:diff] = true if linked_package.backend_package.verifymd5 != @package.backend_package.verifymd5
end
def set_remote_linkinfo
linkinfo = @package.linkinfo
return unless linkinfo && linkinfo['package'] && linkinfo['project']
return unless Package.exists_on_backend?(linkinfo['package'], linkinfo['project'])
@linkinfo = { remote_project: linkinfo['project'], package: linkinfo['package'] }
end
def check_package_name_for_new
@package_name = params[:name]
@package_title = params[:title]
@package_description = params[:description]
unless Package.valid_name?(@package_name)
flash[:error] = "Invalid package name: '#{@package_name}'"
redirect_to controller: :project, action: :new_package, project: @project
return false
end
if Package.exists_by_project_and_name(@project.name, @package_name)
flash[:error] = "Package '#{@package_name}' already exists in project '#{@project}'"
redirect_to controller: :project, action: :new_package, project: @project
return false
end
unless User.possibly_nobody.can_create_package_in?(@project)
flash[:error] = "You can't create packages in #{@project.name}"
redirect_to controller: :project, action: :new_package, project: @project
return false
end
true
end
def find_last_req
if @oproject && @opackage
last_req = BsRequestAction.where(target_project: @oproject,
target_package: @opackage,
source_project: @package.project,
source_package: @package.name).order(:bs_request_id).last
return unless last_req
last_req = last_req.bs_request
if last_req.state != :declined
return # ignore all !declined
end
return {
id: last_req.number,
decliner: last_req.commenter,
when: last_req.updated_at,
comment: last_req.comment
}
end
return
end
def get_diff(project, package, options = {})
options[:view] = :xml
options[:withissues] = 1
begin
@rdiff = Backend::Api::Sources::Package.source_diff(project, package, options.merge(expand: 1))
rescue Backend::Error => e
flash[:error] = 'Problem getting expanded diff: ' + e.summary
begin
@rdiff = Backend::Api::Sources::Package.source_diff(project, package, options.merge(expand: 0))
rescue Backend::Error => e
flash[:error] = 'Error getting diff: ' + e.summary
redirect_back(fallback_location: package_show_path(project: @project, package: @package))
return false
end
end
true
end
def fetch_from_params(*arr)
opts = {}
arr.each do |k|
opts[k] = params[k] if params[k].present?
end
opts
end
def set_job_status
@percent = nil
begin
jobstatus = get_job_status(@project, @package, @repo, @arch)
if jobstatus.present?
js = Xmlhash.parse(jobstatus)
@workerid = js.get('workerid')
@buildtime = Time.now.to_i - js.get('starttime').to_i
ld = js.get('lastduration')
@percent = (@buildtime * 100) / ld.to_i if ld.present?
end
rescue
@workerid = nil
@buildtime = nil
end
end
end