249 lines
9.5 KiB
Ruby
249 lines
9.5 KiB
Ruby
|
||
class PullRequestsController < ApplicationController
|
||
before_filter :find_project_and_repository
|
||
before_filter :connect_gitlab, :only => [:index, :show, :create, :accept_pull_request, :pull_request_commits, :pull_request_changes, :new,
|
||
:update_pull_request, :pull_request_comments, :create_pull_request_comment]
|
||
layout "base_projects"
|
||
include PullRequestsHelper
|
||
include ApplicationHelper
|
||
|
||
# 返回json格式
|
||
def index
|
||
type = params[:type]
|
||
case type
|
||
when nil, "1"
|
||
@requests = @g.merge_requests(@project.gpid).select{|request| request.state == "opened" || request.state == "reopened"}
|
||
when "2"
|
||
@requests = @g.merge_requests(@project.gpid).select{|request| request.state == "merged"}
|
||
when "3"
|
||
@requests = @g.merge_requests(@project.gpid).select{|request| request.state == "closed"}
|
||
end
|
||
@requests_opened_count = @requests.count
|
||
@requests_merged_count = @g.merge_requests(@project.gpid).select{|request| request.state == "merged"}.count
|
||
@requests_closed_count = @g.merge_requests(@project.gpid).select{|request| request.state == "closed"}.count
|
||
|
||
@limit = 10
|
||
@is_remote = true
|
||
@count = type_count(type, @requests_opened_count, @requests_merged_count, @requests_closed_count)
|
||
@pages = Paginator.new @count, @limit, params['page'] || 1
|
||
@offset ||= @pages.offset
|
||
@requests = paginateHelper @requests, 10
|
||
respond_to do |format|
|
||
format.html
|
||
format.js
|
||
end
|
||
end
|
||
|
||
# 主要取源项目和目标项目分支及标识（用户名/版本库名）
|
||
def new
|
||
identifier = get_rep_identifier_by_project @project
|
||
@source_project_name = "#{get_user_name(@project.user_id)}/#{identifier}"
|
||
@source_rev = @g.branches(@project.gpid).map{|b| b.name}
|
||
|
||
# 获取forked源项目信息
|
||
if @project.forked_from_project_id
|
||
@forked_project = Project.find(@project.forked_from_project_id)
|
||
identifier = get_rep_identifier_by_project @forked_project
|
||
@forked_project_name = "#{get_user_name(@forked_project.user_id)}/#{identifier}"
|
||
@forked_rev = @g.branches(@forked_project.gpid).map{|b| b.name}
|
||
end
|
||
end
|
||
|
||
# Creates a merge request.
|
||
# If the operation is successful, 200 and the newly created merge request is returned. If an error occurs, an error number and a message explaining the reason is returned.
|
||
#
|
||
# @example
|
||
# Gitlab.create_merge_request(5, 'New merge request',
|
||
# :source_branch => 'source_branch', :target_branch => 'target_branch')
|
||
# Gitlab.create_merge_request(5, 'New merge request',
|
||
# :source_branch => 'source_branch', :target_branch => 'target_branch', :assignee_id => 42)
|
||
#
|
||
# @param [Integer] project The ID of a project.
|
||
# @param [String] title The title of a merge request.
|
||
# @param [Hash] options A customizable set of options.
|
||
# @option options [String] :source_branch (required) The source branch name.
|
||
# @option options [String] :target_branch (required) The target branch name.
|
||
# @option options [Integer] :assignee_id (optional) The ID of a user to assign merge request.
|
||
# @return [Gitlab::ObjectifiedHash] Information about created merge request.
|
||
def create
|
||
title = params[:title]
|
||
description = params[:description]
|
||
source_branch = params[:source_branch]
|
||
target_branch = params[:target_branch]
|
||
begin
|
||
# 如果传送了目标项目ID，则PR请求发至目标项目
|
||
if params[:forked_project_id] && params[:source_project] == "forked_project_name"
|
||
target_project_id = params[:forked_project_id].to_i
|
||
request = @g.create_merge_request(@project.gpid, title, User.current.gid, :description => description, :source_branch => source_branch, :target_branch => target_branch, :target_project_id => target_project_id)
|
||
@fork_project_name = Project.find(@project.forked_from_project_id).try(:name)
|
||
@fork_pr_message = true if @fork_project_name
|
||
else
|
||
request = @g.create_merge_request(@project.gpid, title, User.current.gid, :description => description, :source_branch => source_branch, :target_branch => target_branch)
|
||
respond_to do |format|
|
||
format.js{redirect_to project_pull_request_path(request.id, :project_id => @project.id)}
|
||
end
|
||
end
|
||
rescue Exception => e
|
||
@message = e.message
|
||
end
|
||
end
|
||
|
||
def show
|
||
@type = params[:type]
|
||
@request = @g.merge_request(@project.gpid, params[:id])
|
||
@commits = @g.merge_request_commits(@project.gpid, params[:id].to_i)
|
||
@commits_count = @commits.count
|
||
@changes = @g.merge_request_changes(@project.gpid, params[:id]).try(:changes)
|
||
@changes_count = @changes.count
|
||
@comments = @g.merge_request_comments(@project.gpid, params[:id])
|
||
@comments_count = @comments.count
|
||
|
||
@limit = 10
|
||
@is_remote = true
|
||
@count = @comments_count
|
||
@pages = Paginator.new @count, @limit, params['page'] || 1
|
||
@offset ||= @pages.offset
|
||
@comments = paginateHelper @comments, 10
|
||
end
|
||
|
||
# Accept a merge request.
|
||
# If merge success you get 200 OK.
|
||
# Accept a merge request.
|
||
#
|
||
# @example
|
||
# Gitlab.accept_pull_rquest(5, 1)
|
||
#
|
||
# @param [Integer] project The ID of a project.
|
||
# @param [Integer] id The ID of a merge request.
|
||
# @return [Gitlab::ObjectifiedHash]
|
||
def accept_pull_request
|
||
begin
|
||
status = @g.accept_merge_rquest(@project.gpid, params[:id], User.current.gid)
|
||
PullRequest.create(:pull_request_id => status.id, :user_id => User.current.id, :gpid => status.project_id)
|
||
respond_to do |format|
|
||
format.js{redirect_to project_pull_request_path(status.id, :project_id => @project.id)}
|
||
end
|
||
rescue Exception => e
|
||
@message = e.message
|
||
end
|
||
end
|
||
|
||
# Updates a merge request.
|
||
#
|
||
# @example
|
||
# Gitlab.update_merge_request(5, 42, :title => 'New title')
|
||
#
|
||
# @param [Integer] project The ID of a project.
|
||
# @param [Integer] id The ID of a merge request.
|
||
# @param [Hash] options A customizable set of options.
|
||
# @option options [String] :title The title of a merge request.
|
||
# @option options [String] :source_branch The source branch name.
|
||
# @option options [String] :target_branch The target branch name.
|
||
# @option options [Integer] :assignee_id The ID of a user to assign merge request.
|
||
# @option options [String] :state_event New state (close|reopen|merge).
|
||
# @return [Gitlab::ObjectifiedHash] Information about updated merge request.
|
||
def update_pull_request
|
||
begin
|
||
@g.update_merge_request(@project.gpid, params[:id], :state_event => params[:state])
|
||
respond_to do |format|
|
||
format.html{redirect_to project_pull_request_path(params[:id], :project_id => @project.id)}
|
||
end
|
||
rescue Exception => e
|
||
@message = e.message
|
||
end
|
||
end
|
||
|
||
# Creates a merge request.
|
||
#
|
||
# @example
|
||
# Gitlab.create_merge_request(5, 'New merge request',
|
||
# :source_branch => 'source_branch', :target_branch => 'target_branch')
|
||
# Gitlab.create_merge_request(5, 'New merge request',
|
||
# :source_branch => 'source_branch', :target_branch => 'target_branch', :assignee_id => 42)
|
||
def create_pull_request_comment
|
||
content = params[:pull_request_comment]
|
||
begin
|
||
@comments = @g.create_merge_request_comment(@project.gpid, params[:id], content, User.current.gid)
|
||
respond_to do |format|
|
||
format.html{redirect_to project_pull_request_path(params[:id], :project_id => @project.id)}
|
||
end
|
||
rescue Exception => e
|
||
@message = e.message
|
||
end
|
||
end
|
||
|
||
# Gets the comments on a merge request.
|
||
#
|
||
# @example
|
||
# Gitlab.merge_request_comments(5, 1)
|
||
def pull_request_comments
|
||
begin
|
||
@comments = @g.merge_request_comments(@project.gpid, params[:id])
|
||
@comments_count = @comments.count
|
||
|
||
@limit = 10
|
||
@is_remote = true
|
||
@count = @comments_count
|
||
@pages = Paginator.new @count, @limit, params['page'] || 1
|
||
@offset ||= @pages.offset
|
||
@comments = paginateHelper @comments, 10
|
||
rescue Exception => e
|
||
@message = e.message
|
||
end
|
||
end
|
||
|
||
# Get a list of merge request commits.
|
||
# Parameters:
|
||
# id (required) - The ID of a project
|
||
# merge_request_id (required) - The ID of MR
|
||
def pull_request_commits
|
||
begin
|
||
@commits = @g.merge_request_commits(@project.gpid, params[:id])
|
||
@commits_count = @commits.count
|
||
|
||
@limit = 10
|
||
@is_remote = true
|
||
@count = @commits_count
|
||
@pages = Paginator.new @count, @limit, params['page'] || 1
|
||
@offset ||= @pages.offset
|
||
@commits = paginateHelper @commits, 10
|
||
rescue Exception => e
|
||
@message = e.message
|
||
end
|
||
end
|
||
|
||
# Shows information about the merge request including its files and changes. With GitLab 8.2 the return fields upvotes and downvotes are deprecated and always return 0.
|
||
# Parameters:
|
||
# id (required) - The ID of a project
|
||
# merge_request_id (required) - The ID of MR
|
||
def pull_request_changes
|
||
begin
|
||
@changes = @g.merge_request_changes(@project.gpid, params[:id]).try(:changes)
|
||
@changes_count = @changes.count
|
||
|
||
@limit = 10
|
||
@is_remote = true
|
||
@count = @changes_count
|
||
@pages = Paginator.new @count, @limit, params['page'] || 1
|
||
@offset ||= @pages.offset
|
||
@changes = paginateHelper @changes, 10
|
||
rescue Exception => e
|
||
@message = e.message
|
||
end
|
||
end
|
||
|
||
private
|
||
def connect_gitlab
|
||
@g = Gitlab.client
|
||
end
|
||
|
||
def find_project_and_repository
|
||
@project = Project.find(params[:project_id])
|
||
render_404 if @project.gpid.blank?
|
||
@repository = Repository.where(:project_id => @project.id, :type => "Repository::Gitlab")
|
||
rescue ActiveRecord::RecordNotFound
|
||
render_404
|
||
end
|
||
|
||
end
|