summaryrefslogtreecommitdiff
path: root/lib/api/helpers.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/api/helpers.rb')
-rw-r--r--lib/api/helpers.rb250
1 files changed, 0 insertions, 250 deletions
diff --git a/lib/api/helpers.rb b/lib/api/helpers.rb
deleted file mode 100644
index be133a2920b..00000000000
--- a/lib/api/helpers.rb
+++ /dev/null
@@ -1,250 +0,0 @@
-module API
- module APIHelpers
- PRIVATE_TOKEN_HEADER = "HTTP_PRIVATE_TOKEN"
- PRIVATE_TOKEN_PARAM = :private_token
- SUDO_HEADER ="HTTP_SUDO"
- SUDO_PARAM = :sudo
-
- def parse_boolean(value)
- [ true, 1, '1', 't', 'T', 'true', 'TRUE', 'on', 'ON' ].include?(value)
- end
-
- def current_user
- private_token = (params[PRIVATE_TOKEN_PARAM] || env[PRIVATE_TOKEN_HEADER]).to_s
- @current_user ||= (User.find_by(authentication_token: private_token) || doorkeeper_guard)
-
- unless @current_user && Gitlab::UserAccess.allowed?(@current_user)
- return nil
- end
-
- identifier = sudo_identifier()
-
- # If the sudo is the current user do nothing
- if identifier && !(@current_user.id == identifier || @current_user.username == identifier)
- render_api_error!('403 Forbidden: Must be admin to use sudo', 403) unless @current_user.is_admin?
- @current_user = User.by_username_or_id(identifier)
- not_found!("No user id or username for: #{identifier}") if @current_user.nil?
- end
-
- @current_user
- end
-
- def sudo_identifier()
- identifier ||= params[SUDO_PARAM] ||= env[SUDO_HEADER]
-
- # Regex for integers
- if !!(identifier =~ /^[0-9]+$/)
- identifier.to_i
- else
- identifier
- end
- end
-
- def user_project
- @project ||= find_project(params[:id])
- @project || not_found!("Project")
- end
-
- def find_project(id)
- project = Project.find_with_namespace(id) || Project.find_by(id: id)
-
- if project && can?(current_user, :read_project, project)
- project
- else
- nil
- end
- end
-
- def find_group(id)
- begin
- group = Group.find(id)
- rescue ActiveRecord::RecordNotFound
- group = Group.find_by!(path: id)
- end
-
- if can?(current_user, :read_group, group)
- group
- else
- forbidden!("#{current_user.username} lacks sufficient "\
- "access to #{group.name}")
- end
- end
-
- def paginate(relation)
- per_page = params[:per_page].to_i
- paginated = relation.page(params[:page]).per(per_page)
- add_pagination_headers(paginated, per_page)
-
- paginated
- end
-
- def authenticate!
- unauthorized! unless current_user
- end
-
- def authenticate_by_gitlab_shell_token!
- input = params['secret_token'].try(:chomp)
- unless Devise.secure_compare(secret_token, input)
- unauthorized!
- end
- end
-
- def authenticated_as_admin!
- forbidden! unless current_user.is_admin?
- end
-
- def authorize!(action, subject)
- unless abilities.allowed?(current_user, action, subject)
- forbidden!
- end
- end
-
- def authorize_push_project
- authorize! :push_code, user_project
- end
-
- def authorize_admin_project
- authorize! :admin_project, user_project
- end
-
- def can?(object, action, subject)
- abilities.allowed?(object, action, subject)
- end
-
- # Checks the occurrences of required attributes, each attribute must be present in the params hash
- # or a Bad Request error is invoked.
- #
- # Parameters:
- # keys (required) - A hash consisting of keys that must be present
- def required_attributes!(keys)
- keys.each do |key|
- bad_request!(key) unless params[key].present?
- end
- end
-
- def attributes_for_keys(keys)
- attrs = {}
-
- keys.each do |key|
- if params[key].present? or (params.has_key?(key) and params[key] == false)
- attrs[key] = params[key]
- end
- end
-
- ActionController::Parameters.new(attrs).permit!
- end
-
- # Helper method for validating all labels against its names
- def validate_label_params(params)
- errors = {}
-
- if params[:labels].present?
- params[:labels].split(',').each do |label_name|
- label = user_project.labels.create_with(
- color: Label::DEFAULT_COLOR).find_or_initialize_by(
- title: label_name.strip)
-
- if label.invalid?
- errors[label.title] = label.errors
- end
- end
- end
-
- errors
- end
-
- def validate_access_level?(level)
- Gitlab::Access.options_with_owner.values.include? level.to_i
- end
-
- def issuable_order_by
- if params["order_by"] == 'updated_at'
- 'updated_at'
- else
- 'created_at'
- end
- end
-
- def issuable_sort
- if params["sort"] == 'asc'
- :asc
- else
- :desc
- end
- end
-
- # error helpers
-
- def forbidden!(reason = nil)
- message = ['403 Forbidden']
- message << " - #{reason}" if reason
- render_api_error!(message.join(' '), 403)
- end
-
- def bad_request!(attribute)
- message = ["400 (Bad request)"]
- message << "\"" + attribute.to_s + "\" not given"
- render_api_error!(message.join(' '), 400)
- end
-
- def not_found!(resource = nil)
- message = ["404"]
- message << resource if resource
- message << "Not Found"
- render_api_error!(message.join(' '), 404)
- end
-
- def unauthorized!
- render_api_error!('401 Unauthorized', 401)
- end
-
- def not_allowed!
- render_api_error!('405 Method Not Allowed', 405)
- end
-
- def conflict!(message = nil)
- render_api_error!(message || '409 Conflict', 409)
- end
-
- def render_validation_error!(model)
- if model.errors.any?
- render_api_error!(model.errors.messages || '400 Bad Request', 400)
- end
- end
-
- def render_api_error!(message, status)
- error!({ 'message' => message }, status)
- end
-
- private
-
- def add_pagination_headers(paginated, per_page)
- request_url = request.url.split('?').first
-
- links = []
- links << %(<#{request_url}?page=#{paginated.current_page - 1}&per_page=#{per_page}>; rel="prev") unless paginated.first_page?
- links << %(<#{request_url}?page=#{paginated.current_page + 1}&per_page=#{per_page}>; rel="next") unless paginated.last_page?
- links << %(<#{request_url}?page=1&per_page=#{per_page}>; rel="first")
- links << %(<#{request_url}?page=#{paginated.total_pages}&per_page=#{per_page}>; rel="last")
-
- header 'Link', links.join(', ')
- end
-
- def abilities
- @abilities ||= begin
- abilities = Six.new
- abilities << Ability
- abilities
- end
- end
-
- def secret_token
- File.read(Rails.root.join('.gitlab_shell_secret')).chomp
- end
-
- def handle_member_errors(errors)
- error!(errors[:access_level], 422) if errors[:access_level].any?
- not_found!(errors)
- end
- end
-end