55 lines
1.5 KiB
Ruby
55 lines
1.5 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class IssuableExportCsvWorker # rubocop:disable Scalability/IdempotentWorker
|
|
include ApplicationWorker
|
|
|
|
data_consistency :always
|
|
|
|
sidekiq_options retry: 3
|
|
|
|
feature_category :team_planning
|
|
worker_resource_boundary :cpu
|
|
loggable_arguments 2
|
|
|
|
def perform(type, current_user_id, project_id, params)
|
|
user = User.find(current_user_id)
|
|
project = Project.find(project_id)
|
|
|
|
export_service(type, user, project, params).email(user)
|
|
rescue ActiveRecord::RecordNotFound => error
|
|
logger.error("Failed to export CSV (current_user_id:#{current_user_id}, project_id:#{project_id}): #{error.message}")
|
|
end
|
|
|
|
private
|
|
|
|
def export_service(type, user, project, params)
|
|
issuable_classes = issuable_classes_for(type.to_sym)
|
|
issuables = issuable_classes[:finder].new(user, parse_params(params, project.id)).execute
|
|
issuable_classes[:service].new(issuables, project)
|
|
end
|
|
|
|
def issuable_classes_for(type)
|
|
case type
|
|
when :issue
|
|
{ finder: IssuesFinder, service: Issues::ExportCsvService }
|
|
when :merge_request
|
|
{ finder: MergeRequestsFinder, service: MergeRequests::ExportCsvService }
|
|
else
|
|
raise ArgumentError, type_error_message(type)
|
|
end
|
|
end
|
|
|
|
def parse_params(params, project_id)
|
|
params
|
|
.with_indifferent_access
|
|
.except(:sort)
|
|
.merge(project_id: project_id)
|
|
end
|
|
|
|
def type_error_message(type)
|
|
"Type parameter must be :issue or :merge_request, it was #{type}"
|
|
end
|
|
end
|
|
|
|
IssuableExportCsvWorker.prepend_mod_with('IssuableExportCsvWorker')
|