forked from Gitlink/forgeplus
60 lines
1.9 KiB
Ruby
60 lines
1.9 KiB
Ruby
class Projects::TransferService < ApplicationService
|
|
attr_accessor :project, :owner, :new_owner, :gitea_repo
|
|
|
|
def initialize(project, new_owner)
|
|
@project = project
|
|
@owner = project.owner
|
|
@new_owner = new_owner
|
|
end
|
|
|
|
def call
|
|
Rails.logger.info("###### Project transfer_service begin ######")
|
|
ActiveRecord::Base.transaction do
|
|
gitea_update_owner
|
|
update_owner
|
|
update_repo_url
|
|
update_visit_teams
|
|
update_fork_info
|
|
end
|
|
|
|
Rails.logger.info("##### Project transfer_service end ######")
|
|
|
|
@project.reload
|
|
end
|
|
|
|
private
|
|
def update_owner
|
|
# 转移项目需要移除原来的权限
|
|
project.members.update_all(team_user_id: nil)
|
|
project.members.map{|m| m.destroy! if m.user_id == owner.id || project.member(new_owner.id) || (new_owner.is_a?(Organization) && new_owner.is_member?(m.user_id)) }
|
|
project.update!(user_id: new_owner.id)
|
|
project.set_owner_permission(new_owner)
|
|
end
|
|
|
|
def update_repo_url
|
|
project.repository.update!(user_id: new_owner.id, url: @gitea_repo["clone_url"])
|
|
end
|
|
|
|
def update_visit_teams
|
|
if new_owner.is_a?(Organization)
|
|
# 为包含组织所有项目的团队创建项目访问权限
|
|
new_owner.build_permit_team_projects!(project.id)
|
|
else
|
|
project.team_projects.each(&:destroy!)
|
|
end
|
|
end
|
|
|
|
def update_fork_info
|
|
fork_user = ForkUser.find_by(user_id: @owner.id, fork_project_id: @project.id)
|
|
fork_user.update(user_id: @new_owner.id) if fork_user.present?
|
|
end
|
|
|
|
def gitea_update_owner
|
|
begin
|
|
@gitea_repo = $gitea_client.post_repos_transfer_by_owner_repo(owner&.login, project.identifier, {body: {new_owner: new_owner&.login}.to_json})
|
|
# @gitea_repo = Gitea::Repository::TransferService.call(owner&.gitea_token, owner&.login, project.identifier, new_owner&.login)
|
|
rescue Exception => e
|
|
Rails.logger.info("##### Project transfer_service, gitea transfer error #{e}")
|
|
end
|
|
end
|
|
end |