224 lines
8.4 KiB
Ruby
224 lines
8.4 KiB
Ruby
class RepositoriesController < ApplicationController
|
||
include ApplicationHelper
|
||
include OperateProjectAbilityAble
|
||
before_action :require_login, only: %i[edit update create_file update_file delete_file sync_mirror]
|
||
before_action :find_project, except: [:tags, :commit, :sync_mirror]
|
||
before_action :authorizate!, except: [:sync_mirror, :tags, :commit]
|
||
before_action :find_repository_by_id, only: %i[commit sync_mirror tags]
|
||
before_action :authorizate_user_can_edit_repo!, only: %i[sync_mirror]
|
||
before_action :get_ref, only: %i[entries sub_entries]
|
||
before_action :get_latest_commit, :get_ref, only: %i[entries sub_entries]
|
||
|
||
def show
|
||
@branches_count = Gitea::Repository::Branches::ListService.new(@project.owner, @project.identifier).call&.size
|
||
@commits_count = Gitea::Repository::Commits::ListService.new(@project.owner.login, @project.identifier,
|
||
sha: params[:sha], page: params[:page], limit: params[:limit], token: current_user&.gitea_token).call[:total_count]
|
||
@tags_count = Gitea::Repository::Tags::ListService.new(current_user&.gitea_token, @project.owner.login, @project.identifier).call&.size
|
||
@result = Gitea::Repository::GetService.new(@project.owner, @project.identifier).call
|
||
@project_fork_id = @project.try(:forked_from_project_id)
|
||
if @project_fork_id.present?
|
||
@fork_project = Project.find_by(id: @project_fork_id)
|
||
@fork_project_user = @fork_project.owner
|
||
end
|
||
rescue Exception => e
|
||
uid_logger_error(e.message)
|
||
tip_exception(e.message)
|
||
end
|
||
|
||
def entries
|
||
@project.increment!(:visits)
|
||
|
||
@entries = Gitea::Repository::Entries::ListService.new(@project.owner, @project.identifier, ref: @ref).call
|
||
@entries = @entries.sort_by{ |hash| hash['type'] }
|
||
end
|
||
|
||
def sub_entries
|
||
file_path_uri = URI.parse(URI.encode(params[:filepath].to_s.strip))
|
||
interactor = Repositories::EntriesInteractor.call(@project.owner, @project.identifier, file_path_uri, ref: @ref)
|
||
if interactor.success?
|
||
@sub_entries = interactor.result
|
||
@sub_entries = [] << @sub_entries unless @sub_entries.is_a? Array
|
||
@sub_entries = @sub_entries.sort_by{ |hash| hash['type'] }
|
||
else
|
||
render_error(interactor.error)
|
||
end
|
||
end
|
||
|
||
def commits
|
||
@project_owner = @project.owner
|
||
@hash_commit = Gitea::Repository::Commits::ListService.new(@project_owner.login, @project.identifier,
|
||
sha: params[:sha], page: params[:page], limit: params[:limit], token: current_user&.gitea_token).call
|
||
end
|
||
|
||
def commit
|
||
@commit = Gitea::Repository::Commits::GetService.new(@repo.user.login, @repo.identifier, params[:sha], current_user.gitea_token).call
|
||
end
|
||
|
||
def tags
|
||
@tags = Gitea::Repository::Tags::ListService.new(current_user&.gitea_token, @repo.user.login, @repo.identifier, {page: params[:page], limit: params[:limit]}).call
|
||
end
|
||
|
||
def edit
|
||
end
|
||
|
||
def create_file
|
||
interactor = Gitea::CreateFileInteractor.call(current_user, content_params)
|
||
if interactor.success?
|
||
@file = interactor.result
|
||
create_new_pr(params)
|
||
else
|
||
render_error(interactor.error)
|
||
end
|
||
end
|
||
|
||
def update_file
|
||
interactor = Gitea::UpdateFileInteractor.call(current_user, params.merge(identifier: @project.identifier))
|
||
if interactor.success?
|
||
@file = interactor.result
|
||
create_new_pr(params)
|
||
render_result(1, "更新成功")
|
||
else
|
||
render_error(interactor.error)
|
||
end
|
||
end
|
||
|
||
def delete_file
|
||
interactor = Gitea::DeleteFileInteractor.call(current_user, params.merge(identifier: @project.identifier))
|
||
if interactor.success?
|
||
@file = interactor.result
|
||
render_result(1, "文件删除成功")
|
||
else
|
||
render_error(interactor.error)
|
||
end
|
||
end
|
||
|
||
def repo_hook
|
||
hook_type = request.headers["X-Gitea-Event"].to_s # 获取推送的方式
|
||
ownername = @project.owner.try(:login)
|
||
reponame = @project.identifier
|
||
username = current_user.try(:login)
|
||
user_params = {
|
||
"ownername": ownername,
|
||
"username": username,
|
||
"reponame": reponame
|
||
}
|
||
uploadPushInfo = hook_params(hook_type, params).merge(user_params)
|
||
chain_params = {
|
||
type: hook_type,
|
||
uploadPushInfo: uploadPushInfo
|
||
}.merge(user_params)
|
||
ProjectCreateChainJob.perform_later(chain_params)
|
||
@project.update_attribute(:token, @project.token + uploadPushInfo[:modificationLines].to_i)
|
||
end
|
||
|
||
def sync_mirror
|
||
@repo&.mirror.set_status!(Mirror.statuses[:waiting])
|
||
SyncMirroredRepositoryJob.perform_later(@repo.id, current_user.id)
|
||
render_ok
|
||
end
|
||
|
||
private
|
||
|
||
def find_project
|
||
@project = Project.find params[:id]
|
||
render_not_found("未找到相关的仓库") unless @project
|
||
end
|
||
|
||
def authorizate!
|
||
if @project.repository.hidden? && !@project.member?(current_user)
|
||
render_forbidden
|
||
end
|
||
end
|
||
|
||
# TODO 获取最新commit信息
|
||
def get_latest_commit
|
||
@latest_commit = Gitea::Repository::Commits::ListService.new(@project.owner.login, @project.identifier,
|
||
sha: get_ref, page: 1, limit: 1, token: current_user&.gitea_token).call
|
||
@latest_commit = @latest_commit.blank? ? nil : @latest_commit[:body][0]
|
||
end
|
||
|
||
def get_ref
|
||
@ref = params[:ref] || "master"
|
||
end
|
||
|
||
def content_params
|
||
{
|
||
filepath: params[:filepath],
|
||
branch: params[:branch],
|
||
new_branch: params[:new_branch],
|
||
content: params[:content],
|
||
message: params[:message],
|
||
identifier: @project.identifier
|
||
}
|
||
end
|
||
|
||
def hook_params(hook_type, params)
|
||
if hook_type == "push"
|
||
# TODO hook返回的记录中，暂时没有文件代码数量的增减，暂时根据 commits数量来计算
|
||
uploadPushInfo = {
|
||
"shas": params["commits"].present? ? params["commits"].map{|c| c["id"]} : "",
|
||
"branch": params["ref"].to_s.split("/").last,
|
||
"modificationLines": params["commits"].length
|
||
}
|
||
elsif hook_type == "pull_request" && params["action"].to_s == "closed" #合并请求合并后才会有上链操作
|
||
uploadPushInfo = {
|
||
"source_branch": params["head"]["ref"].to_s.split("/").last,
|
||
"target_branch": params["base"]["ref"].to_s.split("/").last,
|
||
"source_project_id": params["head"]["repo_id"].to_i, #现在是为gitea上仓库的id
|
||
"target_project_id": params["base"]["repo_id"].to_i,
|
||
"shas": [params["pull_request"]["merge_commit_sha"], params["pull_request"]["merge_base"]],
|
||
"modificationLines": 1 #pull_request中没有commits数量
|
||
}
|
||
else
|
||
uploadPushInfo = {}
|
||
end
|
||
|
||
return uploadPushInfo
|
||
end
|
||
|
||
def create_new_pr(params)
|
||
if params[:new_branch].present? && params[:new_branch] != params[:branch]
|
||
local_params = {
|
||
title: params[:message], #标题
|
||
body: params[:content], #内容
|
||
head: params[:new_branch], #源分支
|
||
base: params[:branch], #目标分支
|
||
milestone: 0 #里程碑,未与本地的里程碑关联
|
||
|
||
}
|
||
requests_params = local_params.merge({
|
||
assignee: current_user.try(:login),
|
||
assignees: [],
|
||
labels: [],
|
||
due_date: Time.now
|
||
})
|
||
|
||
issue_params = {
|
||
author_id: current_user.id,
|
||
project_id: @project.id,
|
||
subject: params[:message],
|
||
description: params[:content],
|
||
assigned_to_id: nil,
|
||
fixed_version_id: nil,
|
||
issue_tags_value: nil,
|
||
issue_classify: "pull_request",
|
||
issue_type: "1",
|
||
tracker_id: 2,
|
||
status_id: 1,
|
||
priority_id: 1
|
||
}
|
||
@pull_issue = Issue.new(issue_params)
|
||
if @pull_issue.save!
|
||
local_requests = PullRequest.new(local_params.merge(user_id: current_user.try(:id), project_id: @project.id, issue_id: @pull_issue.id))
|
||
if local_requests.save
|
||
gitea_request = Gitea::PullRequest::CreateService.new(current_user.try(:gitea_token), @project.owner, @project.try(:identifier), requests_params).call
|
||
if gitea_request && local_requests.update_attributes(gpid: gitea_request["number"])
|
||
local_requests.project_trends.create(user_id: current_user.id, project_id: @project.id, action_type: "create")
|
||
end
|
||
end
|
||
end
|
||
end
|
||
end
|
||
|
||
end
|