Merge pull request 'gitea升级为gitea_hat相关修改' (#32) from yystopf/forgeplus:hh_gitea_upgrade into feature_gitea_upgrade
This commit is contained in:
commit
c65896c11d
2
Gemfile
2
Gemfile
|
@ -140,4 +140,4 @@ gem 'doorkeeper'
|
||||||
|
|
||||||
gem 'doorkeeper-jwt'
|
gem 'doorkeeper-jwt'
|
||||||
|
|
||||||
gem 'gitea-client', '~> 0.11.6'
|
gem 'gitea-client', '~> 1.4.1'
|
||||||
|
|
|
@ -75,6 +75,7 @@ gitea:
|
||||||
access_key_secret: 'password'
|
access_key_secret: 'password'
|
||||||
domain: 'http://www.gitea.example.com'
|
domain: 'http://www.gitea.example.com'
|
||||||
base_url: '/api/v1'
|
base_url: '/api/v1'
|
||||||
|
hat_base_url: '/api/hat'
|
||||||
```
|
```
|
||||||
|
|
||||||
#### 6. 安装redis环境
|
#### 6. 安装redis环境
|
||||||
|
|
|
@ -4,6 +4,7 @@ class Api::V1::Projects::TagsController < Api::V1::BaseController
|
||||||
def index
|
def index
|
||||||
@release_tags = @repository.version_releases.pluck(:tag_name)
|
@release_tags = @repository.version_releases.pluck(:tag_name)
|
||||||
@result_object = Api::V1::Projects::Tags::ListService.call(@project, {page: page, limit: limit}, current_user&.gitea_token)
|
@result_object = Api::V1::Projects::Tags::ListService.call(@project, {page: page, limit: limit}, current_user&.gitea_token)
|
||||||
|
puts @result_object
|
||||||
end
|
end
|
||||||
|
|
||||||
before_action :require_operate_above, only: [:destroy]
|
before_action :require_operate_above, only: [:destroy]
|
||||||
|
|
|
@ -166,8 +166,9 @@ class RepositoriesController < ApplicationController
|
||||||
if params[:filepath].present? || @project.educoder?
|
if params[:filepath].present? || @project.educoder?
|
||||||
@contributors = []
|
@contributors = []
|
||||||
else
|
else
|
||||||
result = Gitea::Repository::Contributors::GetService.call(@owner, @repository.identifier)
|
result = Gitea::Repository::Contributors::GetService.call(@owner, @repository.identifier, {page: params[:page], limit: params[:limit]})
|
||||||
@contributors = result.is_a?(Hash) && result.key?(:status) ? [] : result
|
@total_count = result[:total_count]
|
||||||
|
@contributors = result.is_a?(Hash) ? result[:body] : []
|
||||||
end
|
end
|
||||||
rescue
|
rescue
|
||||||
@contributors = []
|
@contributors = []
|
||||||
|
|
|
@ -32,7 +32,7 @@ class Api::V1::Projects::BlameService < ApplicationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def load_gitea_data
|
def load_gitea_data
|
||||||
@gitea_data = $gitea_client.get_repos_blame_by_owner_repo(owner, repo, {query: request_params})
|
@gitea_data = $gitea_hat_client.get_repos_blame_by_owner_repo(owner, repo, {query: request_params})
|
||||||
raise Error, '获取项目blame失败!' unless @gitea_data.is_a?(Hash)
|
raise Error, '获取项目blame失败!' unless @gitea_data.is_a?(Hash)
|
||||||
end
|
end
|
||||||
end
|
end
|
|
@ -24,7 +24,7 @@ class Api::V1::Projects::Branches::AllListService < ApplicationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def load_gitea_data
|
def load_gitea_data
|
||||||
@gitea_data = $gitea_client.get_repos_branch_name_set_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
@gitea_data = $gitea_hat_client.get_repos_branch_name_set_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
||||||
raise Error, '获取所有分支失败!' unless @gitea_data.is_a?(Hash)
|
raise Error, '获取所有分支失败!' unless @gitea_data.is_a?(Array)
|
||||||
end
|
end
|
||||||
end
|
end
|
|
@ -44,9 +44,9 @@ class Api::V1::Projects::Branches::CreateService < ApplicationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def check_branch_exist
|
def check_branch_exist
|
||||||
result = $gitea_client.get_repos_branch_name_set_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
result = $gitea_hat_client.get_repos_branch_name_set_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
||||||
raise Error, '查询分支名称失败!' unless result.is_a?(Hash)
|
raise Error, '查询分支名称失败!' unless result.is_a?(Array)
|
||||||
raise Error, '旧分支不存在!' if !result['branch_name'].include?(@old_branch_name)
|
raise Error, '旧分支不存在!' if !result.include?(@old_branch_name)
|
||||||
raise Error, '新分支已存在!' if result['branch_name'].include?(@new_branch_name)
|
raise Error, '新分支已存在!' if result.include?(@new_branch_name)
|
||||||
end
|
end
|
||||||
end
|
end
|
|
@ -40,8 +40,8 @@ class Api::V1::Projects::Branches::DeleteService < ApplicationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def check_branch_exist
|
def check_branch_exist
|
||||||
result = $gitea_client.get_repos_branch_name_set_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
result = $gitea_hat_client.get_repos_branch_name_set_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
||||||
raise Error, '查询分支名称失败!' unless result.is_a?(Hash)
|
raise Error, '查询分支名称失败!' unless result.is_a?(Array)
|
||||||
raise Error, '分支不存在!' if !result['branch_name'].include?(@branch_name)
|
raise Error, '分支不存在!' if !result.include?(@branch_name)
|
||||||
end
|
end
|
||||||
end
|
end
|
|
@ -1,7 +1,7 @@
|
||||||
class Api::V1::Projects::Branches::ListService < ApplicationService
|
class Api::V1::Projects::Branches::ListService < ApplicationService
|
||||||
|
|
||||||
attr_accessor :project, :token, :owner, :repo, :name, :page, :limit
|
attr_accessor :project, :token, :owner, :repo, :name, :page, :limit
|
||||||
attr_accessor :gitea_data
|
attr_accessor :gitea_data, :gitea_repo_data
|
||||||
|
|
||||||
def initialize(project, params, token=nil)
|
def initialize(project, params, token=nil)
|
||||||
@project = project
|
@project = project
|
||||||
|
@ -15,8 +15,11 @@ class Api::V1::Projects::Branches::ListService < ApplicationService
|
||||||
|
|
||||||
def call
|
def call
|
||||||
load_gitea_data
|
load_gitea_data
|
||||||
|
load_default_branch
|
||||||
|
|
||||||
gitea_data
|
@gitea_data[:default_branch] = @gitea_repo_data["default_branch"]
|
||||||
|
|
||||||
|
@gitea_data
|
||||||
end
|
end
|
||||||
|
|
||||||
private
|
private
|
||||||
|
@ -32,9 +35,12 @@ class Api::V1::Projects::Branches::ListService < ApplicationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def load_gitea_data
|
def load_gitea_data
|
||||||
puts request_params
|
@gitea_data = $gitea_hat_client.get_repos_branches_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
||||||
@gitea_data = $gitea_client.get_repos_branches_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
|
||||||
puts @gitea_data
|
|
||||||
raise Error, '获取分支列表失败!' unless @gitea_data.is_a?(Hash)
|
raise Error, '获取分支列表失败!' unless @gitea_data.is_a?(Hash)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
def load_default_branch
|
||||||
|
@gitea_repo_data = $gitea_client.get_repos_by_owner_repo(owner, repo) rescue nil
|
||||||
|
raise Error, '获取仓库信息失败!' unless @gitea_data.is_a?(Hash)
|
||||||
|
end
|
||||||
end
|
end
|
|
@ -48,8 +48,8 @@ class Api::V1::Projects::Branches::UpdateDefaultBranchService < ApplicationServi
|
||||||
end
|
end
|
||||||
|
|
||||||
def check_branch_exist
|
def check_branch_exist
|
||||||
result = $gitea_client.get_repos_branch_name_set_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
result = $gitea_hat_client.get_repos_branch_name_set_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
||||||
raise Error, '查询分支名称失败!' unless result.is_a?(Hash)
|
raise Error, '查询分支名称失败!' unless result.is_a?(Array)
|
||||||
raise Error, '新默认分支不存在!' if !result['branch_name'].include?(@new_default_branch)
|
raise Error, '新默认分支不存在!' if !result.include?(@new_default_branch)
|
||||||
end
|
end
|
||||||
end
|
end
|
|
@ -28,7 +28,7 @@ class Api::V1::Projects::CodeStats::ListService < ApplicationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def load_gitea_data
|
def load_gitea_data
|
||||||
@gitea_data = $gitea_client.get_repos_code_stats_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
@gitea_data = $gitea_hat_client.get_repos_code_stats_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
||||||
raise Error, '获取贡献者贡献度失败!' unless @gitea_data.is_a?(Hash)
|
raise Error, '获取贡献者贡献度失败!' unless @gitea_data.is_a?(Hash)
|
||||||
end
|
end
|
||||||
end
|
end
|
|
@ -29,7 +29,7 @@ class Api::V1::Projects::Commits::DiffService < ApplicationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def load_gitea_data
|
def load_gitea_data
|
||||||
@gitea_data = $gitea_client.get_repos_commits_diff_by_owner_repo_sha(owner, repo, sha, {query: request_params}) rescue nil
|
@gitea_data = $gitea_hat_client.get_repos_commits_diff_by_owner_repo_sha(owner, repo, sha, {query: request_params}) rescue nil
|
||||||
raise Error, '获取提交对比失败!' unless @gitea_data.is_a?(Hash)
|
raise Error, '获取提交对比失败!' unless @gitea_data.is_a?(Hash)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -78,12 +78,12 @@ class Api::V1::Projects::Contents::BatchCreateService < ApplicationService
|
||||||
|
|
||||||
def excute_data_to_gitea
|
def excute_data_to_gitea
|
||||||
puts request_body.to_json
|
puts request_body.to_json
|
||||||
@gitea_data = $gitea_client.post_repos_contents_batch_by_owner_repo(owner, repo, {body: request_body.to_json, query: request_params}) rescue nil
|
@gitea_data = $gitea_hat_client.post_repos_contents_batch_by_owner_repo(owner, repo, {body: request_body.to_json, query: request_params}) rescue nil
|
||||||
raise Error, '提交文件失败!' unless @gitea_data.is_a?(Hash)
|
raise Error, '提交文件失败!' unless @gitea_data.is_a?(Hash)
|
||||||
end
|
end
|
||||||
|
|
||||||
def check_branch_exist
|
def check_branch_exist
|
||||||
result = $gitea_client.get_repos_branch_name_set_by_owner_repo(owner, repo, {query: request_params} ) rescue nil
|
result = $gitea_hat_client.get_repos_branch_name_set_by_owner_repo(owner, repo, {query: request_params} ) rescue nil
|
||||||
raise Error, '查询分支名称失败!' unless result.is_a?(Hash)
|
raise Error, '查询分支名称失败!' unless result.is_a?(Hash)
|
||||||
raise Error, '分支不存在!' unless result['branch_name'].include?(branch)
|
raise Error, '分支不存在!' unless result['branch_name'].include?(branch)
|
||||||
raise Error, '分支已存在!' if result['branch_name'].include?(new_branch) && !new_branch.nil?
|
raise Error, '分支已存在!' if result['branch_name'].include?(new_branch) && !new_branch.nil?
|
||||||
|
|
|
@ -45,6 +45,6 @@ class Api::V1::Projects::GetService < ApplicationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def load_gitea_branch_tag_count
|
def load_gitea_branch_tag_count
|
||||||
@gitea_branch_tag_count = $gitea_client.get_repos_branch_tag_count_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
@gitea_branch_tag_count = $gitea_hat_client.get_repos_branch_tag_count_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
||||||
end
|
end
|
||||||
end
|
end
|
|
@ -26,7 +26,7 @@ class Api::V1::Projects::Pulls::GetService < ApplicationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def load_gitea_data
|
def load_gitea_data
|
||||||
@gitea_data = $gitea_client.get_repos_pulls_by_owner_repo_index(owner, repo, index, {query: request_params})
|
@gitea_data = $gitea_hat_client.get_repos_pulls_by_owner_repo_index(owner, repo, index, {query: request_params})
|
||||||
# raise Error, '获取合并请求失败!' unless @gitea_data.is_a?(Hash)
|
# raise Error, '获取合并请求失败!' unless @gitea_data.is_a?(Hash)
|
||||||
end
|
end
|
||||||
end
|
end
|
|
@ -30,7 +30,7 @@ class Api::V1::Projects::Pulls::Versions::GetDiffService < ApplicationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def load_gitea_data
|
def load_gitea_data
|
||||||
@gitea_data = $gitea_client.get_repos_pulls_versions_diff_by_owner_repo_index_version_id(owner, repo, index, version_id, {query: request_params})
|
@gitea_data = $gitea_hat_client.get_repos_pulls_versions_diff_by_owner_repo_index_id(owner, repo, index, version_id, {query: request_params})
|
||||||
raise Error, '获取合并请求版本diff失败!' unless @gitea_data.is_a?(Hash)
|
raise Error, '获取合并请求版本diff失败!' unless @gitea_data.is_a?(Hash)
|
||||||
end
|
end
|
||||||
end
|
end
|
|
@ -30,7 +30,7 @@ class Api::V1::Projects::Pulls::Versions::ListService < ApplicationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def load_gitea_data
|
def load_gitea_data
|
||||||
@gitea_data = $gitea_client.get_repos_pulls_versions_by_owner_repo_index(owner, repo, index, {query: request_params})
|
@gitea_data = $gitea_hat_client.get_repos_pulls_versions_by_owner_repo_index(owner, repo, index, {query: request_params})
|
||||||
raise Error, '获取合并请求版本失败!' unless @gitea_data.is_a?(Hash)
|
raise Error, '获取合并请求版本失败!' unless @gitea_data.is_a?(Hash)
|
||||||
end
|
end
|
||||||
end
|
end
|
|
@ -40,7 +40,7 @@ class Api::V1::Projects::Tags::DeleteService < ApplicationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def check_tag_exist
|
def check_tag_exist
|
||||||
result = $gitea_client.get_repos_tag_name_set_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
result = $gitea_hat_client.get_repos_tag_name_set_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
||||||
raise Error, '查询标签名称失败!' unless result.is_a?(Array)
|
raise Error, '查询标签名称失败!' unless result.is_a?(Array)
|
||||||
raise Error, '标签不存在!' if !result.include?(@tag_name)
|
raise Error, '标签不存在!' if !result.include?(@tag_name)
|
||||||
end
|
end
|
||||||
|
|
|
@ -30,7 +30,7 @@ class Api::V1::Projects::Tags::ListService < ApplicationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def load_gitea_data
|
def load_gitea_data
|
||||||
@gitea_data = $gitea_client.get_repos_tags_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
@gitea_data = $gitea_hat_client.get_repos_tags_by_owner_repo(owner, repo, {query: request_params}) rescue nil
|
||||||
raise Error, '获取标签列表失败!' unless @gitea_data.is_a?(Hash)
|
raise Error, '获取标签列表失败!' unless @gitea_data.is_a?(Hash)
|
||||||
end
|
end
|
||||||
end
|
end
|
|
@ -58,6 +58,6 @@ class Api::V1::Projects::Webhooks::CreateService < ApplicationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def excute_data_to_gitea
|
def excute_data_to_gitea
|
||||||
@gitea_data = $gitea_client.post_repos_hooks_by_owner_repo(owner, repo, {body: request_body.to_json, query: request_params}) rescue nil
|
@gitea_data = $gitea_hat_client.post_repos_hooks_by_owner_repo(owner, repo, {body: request_body.to_json, query: request_params}) rescue nil
|
||||||
end
|
end
|
||||||
end
|
end
|
|
@ -30,6 +30,6 @@ class Api::V1::Projects::Webhooks::ListService < ApplicationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def load_gitea_data
|
def load_gitea_data
|
||||||
@gitea_data = $gitea_client.get_repos_hooks_hooktasks_by_owner_repo(owner, repo, id, {query: request_params}) rescue nil
|
@gitea_data = $gitea_hat_client.get_repos_hooks_hooktasks_by_owner_repo(owner, repo, id, {query: request_params}) rescue nil
|
||||||
end
|
end
|
||||||
end
|
end
|
|
@ -58,6 +58,6 @@ class Api::V1::Projects::Webhooks::UpdateService < ApplicationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def excute_data_to_gitea
|
def excute_data_to_gitea
|
||||||
@gitea_data = $gitea_client.patch_repos_hooks_by_owner_repo_id(owner, repo, id, {body: request_body.to_json, query: request_params}) rescue nil
|
@gitea_data = $gitea_hat_client.patch_repos_hooks_by_owner_repo_id(owner, repo, id, {body: request_body.to_json, query: request_params}) rescue nil
|
||||||
end
|
end
|
||||||
end
|
end
|
|
@ -18,19 +18,19 @@ class Gitea::ClientService < ApplicationService
|
||||||
# token: {},
|
# token: {},
|
||||||
# data: {}
|
# data: {}
|
||||||
# }
|
# }
|
||||||
def post(url, params={})
|
def post(url, params={}, is_hat=false)
|
||||||
puts "[gitea] request params: #{params}"
|
puts "[gitea] request params: #{params}"
|
||||||
auth_token = authen_params(params[:token])
|
auth_token = authen_params(params[:token])
|
||||||
conn(auth_token).post do |req|
|
conn(auth_token).post do |req|
|
||||||
req.url full_url(url)
|
req.url full_url(url, "post", is_hat)
|
||||||
req.body = params[:data].to_json
|
req.body = params[:data].to_json
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
def get(url, params={})
|
def get(url, params={}, is_hat = false)
|
||||||
auth_token = authen_params(params[:token])
|
auth_token = authen_params(params[:token])
|
||||||
conn(auth_token).get do |req|
|
conn(auth_token).get do |req|
|
||||||
req.url full_url(url, 'get')
|
req.url full_url(url, 'get', is_hat)
|
||||||
params.except(:token).each_pair do |key, value|
|
params.except(:token).each_pair do |key, value|
|
||||||
req.params["#{key}"] = value
|
req.params["#{key}"] = value
|
||||||
end
|
end
|
||||||
|
@ -41,27 +41,27 @@ class Gitea::ClientService < ApplicationService
|
||||||
# end #=> 响应头
|
# end #=> 响应头
|
||||||
end
|
end
|
||||||
|
|
||||||
def delete(url, params={})
|
def delete(url, params={}, is_hat = false)
|
||||||
auth_token = authen_params(params[:token])
|
auth_token = authen_params(params[:token])
|
||||||
conn(auth_token).delete do |req|
|
conn(auth_token).delete do |req|
|
||||||
req.url full_url(url)
|
req.url full_url(url, "delete", is_hat)
|
||||||
req.body = params[:data].to_json
|
req.body = params[:data].to_json
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
def patch(url, params={})
|
def patch(url, params={}, is_hat=false)
|
||||||
puts "[gitea] request params: #{params}"
|
puts "[gitea] request params: #{params}"
|
||||||
auth_token = authen_params(params[:token])
|
auth_token = authen_params(params[:token])
|
||||||
conn(auth_token).patch do |req|
|
conn(auth_token).patch do |req|
|
||||||
req.url full_url(url)
|
req.url full_url(url, 'patch', is_hat)
|
||||||
req.body = params[:data].to_json
|
req.body = params[:data].to_json
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
def put(url, params={})
|
def put(url, params={}, is_hat=false)
|
||||||
puts "[gitea] put request params: #{params}"
|
puts "[gitea] put request params: #{params}"
|
||||||
conn(authen_params(params[:token])).put do |req|
|
conn(authen_params(params[:token])).put do |req|
|
||||||
req.url full_url(url)
|
req.url full_url(url, "put", is_hat)
|
||||||
req.body = params[:data].to_json
|
req.body = params[:data].to_json
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
@ -99,16 +99,20 @@ class Gitea::ClientService < ApplicationService
|
||||||
GiteaService.gitea_config[:base_url]
|
GiteaService.gitea_config[:base_url]
|
||||||
end
|
end
|
||||||
|
|
||||||
|
def hat_base_url
|
||||||
|
GiteaService.gitea_config[:hat_base_url]
|
||||||
|
end
|
||||||
|
|
||||||
def domain
|
def domain
|
||||||
GiteaService.gitea_config[:domain]
|
GiteaService.gitea_config[:domain]
|
||||||
end
|
end
|
||||||
|
|
||||||
def api_url
|
def api_url(is_hat=false)
|
||||||
[domain, base_url].join('')
|
is_hat ? [domain, hat_base_url].join('') : [domain, base_url].join('')
|
||||||
end
|
end
|
||||||
|
|
||||||
def full_url(api_rest, action='post')
|
def full_url(api_rest, action='post', is_hat=false)
|
||||||
url = [api_url, api_rest].join('').freeze
|
url = [api_url(is_hat), api_rest].join('').freeze
|
||||||
url = action === 'get' ? url : URI.escape(url)
|
url = action === 'get' ? url : URI.escape(url)
|
||||||
url = URI.escape(url) unless url.ascii_only?
|
url = URI.escape(url) unless url.ascii_only?
|
||||||
puts "[gitea] request url: #{url}"
|
puts "[gitea] request url: #{url}"
|
||||||
|
|
|
@ -24,7 +24,7 @@ class Gitea::Hooks::CreateService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = post(url, params)
|
response = post(url, params, true)
|
||||||
render_201_response(response)
|
render_201_response(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -7,7 +7,7 @@ class Gitea::Organization::CreateService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = post(url, request_params)
|
response = post(url, request_params, true)
|
||||||
render_status(response)
|
render_status(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -8,7 +8,7 @@ class Gitea::Organization::UpdateService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = patch(url, request_params)
|
response = patch(url, request_params, true)
|
||||||
render_status(response)
|
render_status(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -16,7 +16,7 @@ class Gitea::PullRequest::CommitsService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_result(response)
|
render_result(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -17,7 +17,7 @@ class Gitea::PullRequest::FilesService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params.merge(token: token))
|
response = get(url, params.merge(token: token), true)
|
||||||
render_result(response)
|
render_result(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -12,7 +12,7 @@ class Gitea::PullRequest::GetService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_result(response)
|
render_result(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -27,7 +27,7 @@ class Gitea::PullRequest::UpdateService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = patch(url, request_params)
|
response = patch(url, request_params, true)
|
||||||
|
|
||||||
status, message, body = render_response(response)
|
status, message, body = render_response(response)
|
||||||
json_format(status, message, body)
|
json_format(status, message, body)
|
||||||
|
|
|
@ -8,7 +8,7 @@ class Gitea::Repository::Branches::ListNameService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_200_response(response)
|
render_200_response(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -7,7 +7,7 @@ class Gitea::Repository::Branches::ListSliceService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_200_response(response)
|
render_200_response(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -14,7 +14,7 @@ class Gitea::Repository::Commits::CompareService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_status(response)
|
render_status(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -14,7 +14,7 @@ class Gitea::Repository::Commits::FileListService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_result(response)
|
render_result(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -14,7 +14,7 @@ class Gitea::Repository::Commits::GetService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_status(response)
|
render_status(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -13,7 +13,7 @@ class Gitea::Repository::Commits::ListSliceService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_result(response)
|
render_result(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -1,22 +1,38 @@
|
||||||
class Gitea::Repository::Contributors::GetService < Gitea::ClientService
|
class Gitea::Repository::Contributors::GetService < Gitea::ClientService
|
||||||
attr_reader :owner, :repo_name
|
attr_reader :owner, :repo_name, :page, :limit
|
||||||
|
|
||||||
def initialize(owner, repo_name)
|
def initialize(owner, repo_name, params={})
|
||||||
@owner = owner
|
@owner = owner
|
||||||
@repo_name = repo_name
|
@repo_name = repo_name
|
||||||
|
@page = params[:page] || 1
|
||||||
|
@limit = params[:limit] || 20
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_status(response)
|
render_result(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
private
|
private
|
||||||
def params
|
def params
|
||||||
Hash.new.merge(token: owner.gitea_token)
|
Hash.new.merge(token: owner.gitea_token, page: page, limit: limit)
|
||||||
end
|
end
|
||||||
|
|
||||||
def url
|
def url
|
||||||
"/repos/#{owner.login}/#{repo_name}/contributors"
|
"/repos/#{owner.login}/#{repo_name}/contributors"
|
||||||
end
|
end
|
||||||
|
|
||||||
|
def render_result(response)
|
||||||
|
case response.status
|
||||||
|
when 200
|
||||||
|
result = {}
|
||||||
|
headers = response.headers.to_hash
|
||||||
|
body = JSON.parse(response.body)
|
||||||
|
total_count = headers["x-total"]
|
||||||
|
result.merge(total_count: total_count.to_i, body: body)
|
||||||
|
else
|
||||||
|
nil
|
||||||
|
# {status: -1, message: "#{body['message']}"}
|
||||||
|
end
|
||||||
|
end
|
||||||
end
|
end
|
|
@ -13,7 +13,7 @@ class Gitea::Repository::Entries::GetService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_result(response)
|
render_result(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -10,7 +10,7 @@ class Gitea::Repository::Entries::ListService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_result(response)
|
render_result(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -10,7 +10,7 @@ class Gitea::Repository::Files::GetService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_status(response)
|
render_status(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -11,7 +11,7 @@ module Gitea
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_result(response)
|
render_result(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -10,7 +10,7 @@ class Gitea::Repository::Readme::DirService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
status, message, body = render_response(response)
|
status, message, body = render_response(response)
|
||||||
json_format(status, message, body)
|
json_format(status, message, body)
|
||||||
end
|
end
|
||||||
|
|
|
@ -15,7 +15,7 @@ class Gitea::Repository::Readme::GetService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
status, message, body = render_response(response)
|
status, message, body = render_response(response)
|
||||||
json_format(status, message, body)
|
json_format(status, message, body)
|
||||||
end
|
end
|
||||||
|
|
|
@ -8,7 +8,7 @@ class Gitea::Repository::Tags::ListNameService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_200_response(response)
|
render_200_response(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -11,7 +11,7 @@ class Gitea::Repository::Tags::ListService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, request_params)
|
response = get(url, request_params, true)
|
||||||
render_result(response)
|
render_result(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -9,7 +9,7 @@ class Gitea::Repository::TransferService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = post(url, request_params)
|
response = post(url, request_params, true)
|
||||||
render_status(response)
|
render_status(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -8,7 +8,7 @@ class Gitea::Repository::Webhooks::CreateService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = post(url, request_params)
|
response = post(url, request_params, true)
|
||||||
render_response(response)
|
render_response(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -11,7 +11,7 @@ class Gitea::Repository::Webhooks::TasksService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_response(response)
|
render_response(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -9,7 +9,7 @@ class Gitea::Repository::Webhooks::UpdateService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = patch(url, data_params)
|
response = patch(url, data_params, true)
|
||||||
render_response(response)
|
render_response(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -8,7 +8,7 @@ class Gitea::User::HeadmapService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_response(response)
|
render_response(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -24,7 +24,7 @@ class Gitea::User::UpdateService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
patch(url, data_params)
|
patch(url, data_params, true)
|
||||||
end
|
end
|
||||||
|
|
||||||
private
|
private
|
||||||
|
|
|
@ -18,7 +18,7 @@ class Gitea::Versions::CreateService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = post(url, request_params)
|
response = post(url, request_params, true)
|
||||||
render_status(response)
|
render_status(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -12,7 +12,7 @@ class Gitea::Versions::GetService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_result(response)
|
render_result(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -11,7 +11,7 @@ class Gitea::Versions::ListService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
response = get(url, params)
|
response = get(url, params, true)
|
||||||
render_result(response)
|
render_result(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -19,7 +19,7 @@ class Gitea::Versions::UpdateService < Gitea::ClientService
|
||||||
end
|
end
|
||||||
|
|
||||||
def call
|
def call
|
||||||
patch(url, request_params)
|
patch(url, request_params, true)
|
||||||
end
|
end
|
||||||
|
|
||||||
private
|
private
|
||||||
|
|
|
@ -51,7 +51,7 @@ class Projects::TransferService < ApplicationService
|
||||||
|
|
||||||
def gitea_update_owner
|
def gitea_update_owner
|
||||||
begin
|
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_hat_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)
|
# @gitea_repo = Gitea::Repository::TransferService.call(owner&.gitea_token, owner&.login, project.identifier, new_owner&.login)
|
||||||
rescue Exception => e
|
rescue Exception => e
|
||||||
Rails.logger.info("##### Project transfer_service, gitea transfer error #{e}")
|
Rails.logger.info("##### Project transfer_service, gitea transfer error #{e}")
|
||||||
|
|
|
@ -17,10 +17,10 @@ end
|
||||||
json.protected branch['protected']
|
json.protected branch['protected']
|
||||||
json.user_can_push branch['user_can_push']
|
json.user_can_push branch['user_can_push']
|
||||||
json.user_can_merge branch['user_can_merge']
|
json.user_can_merge branch['user_can_merge']
|
||||||
json.commit_id branch['commit_id']
|
json.commit_id branch['commit']['id']
|
||||||
json.commit_time_from_now time_from_now(branch['commit']['timestamp'].to_time)
|
json.commit_time_from_now time_from_now(branch['commit']['timestamp'].to_time)
|
||||||
json.commit_time branch['commit_time']
|
json.commit_time branch['commit']['timestamp']
|
||||||
json.default_branch branch['default_branch']
|
json.default_branch default_branch || nil
|
||||||
json.http_url render_http_url(@project)
|
json.http_url render_http_url(@project)
|
||||||
json.zip_url render_zip_url(@owner, @project.repository, branch['name'])
|
json.zip_url render_zip_url(@owner, @project.repository, branch['name'])
|
||||||
json.tar_url render_tar_url(@owner, @project.repository, branch['name'])
|
json.tar_url render_tar_url(@owner, @project.repository, branch['name'])
|
|
@ -1 +1 @@
|
||||||
json.partial! "api/v1/projects/branches/simple_gitea_detail", branch: @result_object
|
json.partial! "api/v1/projects/branches/simple_gitea_detail", branch: @result_object, default_branch: @result_object[:default_branch]
|
||||||
|
|
|
@ -1,4 +1,5 @@
|
||||||
json.total_count @result_object[:total_data].to_i
|
json.total_count @result_object[:total_data].to_i
|
||||||
json.branches @result_object[:data].each do |branch|
|
json.branches @result_object[:data].each do |branch|
|
||||||
json.partial! "api/v1/projects/branches/simple_gitea_detail", branch: branch
|
json.partial! "api/v1/projects/branches/simple_gitea_detail", branch: branch, default_branch: @result_object[:default_branch]
|
||||||
|
|
||||||
end
|
end
|
|
@ -12,10 +12,10 @@ if tag.present? && tag.is_a?(Hash)
|
||||||
json.commit do
|
json.commit do
|
||||||
json.sha tag['commit']['sha']
|
json.sha tag['commit']['sha']
|
||||||
json.message tag['commit']['message']
|
json.message tag['commit']['message']
|
||||||
json.time_ago time_from_now(tag['commit']['commiter']['date'].to_time)
|
json.time_ago time_from_now(tag['commit']['committer']['date'].to_time)
|
||||||
json.created_at_unix tag['commit']['commiter']['date'].to_time.to_i
|
json.created_at_unix tag['commit']['committer']['date'].to_time.to_i
|
||||||
json.committer do
|
json.committer do
|
||||||
json.partial! 'api/v1/users/commit_user', user: render_cache_commit_author(tag['commit']['commiter']), name: tag['commit']['commiter']['name']
|
json.partial! 'api/v1/users/commit_user', user: render_cache_commit_author(tag['commit']['committer']), name: tag['commit']['committer']['name']
|
||||||
end
|
end
|
||||||
json.author do
|
json.author do
|
||||||
json.partial! 'api/v1/users/commit_user', user: render_cache_commit_author(tag['commit']['author']), name: tag['commit']['author']['name']
|
json.partial! 'api/v1/users/commit_user', user: render_cache_commit_author(tag['commit']['author']), name: tag['commit']['author']['name']
|
||||||
|
|
|
@ -1,15 +1,15 @@
|
||||||
user = $redis_cache.hgetall("v2-owner-common:#{contributor["login"]}-#{contributor["email"]}")
|
user = $redis_cache.hgetall("v2-owner-common:#{contributor["name"]}-#{contributor["email"]}")
|
||||||
if user.blank?
|
if user.blank?
|
||||||
json.contributions contributor["contributions"]
|
json.contributions contributor["commits"]
|
||||||
# json.gid contributor["id"]
|
# json.id contributor["id"]
|
||||||
json.login contributor["login"]
|
json.name contributor["name"]
|
||||||
json.type nil
|
json.type nil
|
||||||
json.name contributor["login"]
|
json.name contributor["name"]
|
||||||
json.image_url User::Avatar.get_letter_avatar_url(contributor["login"])
|
json.image_url User::Avatar.get_letter_avatar_url(contributor["name"])
|
||||||
else
|
else
|
||||||
json.contributions contributor["contributions"]
|
json.contributions contributor["commits"]
|
||||||
# json.gid contributor["id"]
|
json.id user["id"]
|
||||||
json.login user["login"]
|
json.name user["name"]
|
||||||
json.type user["type"]
|
json.type user["type"]
|
||||||
json.name user["name"]
|
json.name user["name"]
|
||||||
json.image_url user["avatar_url"]
|
json.image_url user["avatar_url"]
|
||||||
|
|
|
@ -1,4 +1,4 @@
|
||||||
total_count = @contributors.size
|
total_count = @total_count
|
||||||
json.list @contributors.each do |contributor|
|
json.list @contributors.each do |contributor|
|
||||||
json.partial! 'contributor', locals: { contributor: contributor }
|
json.partial! 'contributor', locals: { contributor: contributor }
|
||||||
end
|
end
|
||||||
|
|
|
@ -14,10 +14,10 @@ json.tags @tags do |tag|
|
||||||
json.commit do
|
json.commit do
|
||||||
json.sha tag['commit']['sha']
|
json.sha tag['commit']['sha']
|
||||||
json.message tag['commit']['message']
|
json.message tag['commit']['message']
|
||||||
json.time_ago time_from_now(tag['commit']['commiter']['date'].to_time)
|
json.time_ago time_from_now(tag['commit']['committer']['date'].to_time)
|
||||||
json.created_at_unix tag['commit']['commiter']['date'].to_time.to_i
|
json.created_at_unix tag['commit']['committer']['date'].to_time.to_i
|
||||||
json.committer do
|
json.committer do
|
||||||
json.partial! 'commit_author', user: render_cache_commit_author(tag['commit']['commiter']), name: tag['commit']['commiter']['name']
|
json.partial! 'commit_author', user: render_cache_commit_author(tag['commit']['committer']), name: tag['commit']['committer']['name']
|
||||||
end
|
end
|
||||||
json.author do
|
json.author do
|
||||||
json.partial! 'commit_author', user: render_cache_commit_author(tag['commit']['author']), name: tag['commit']['author']['name']
|
json.partial! 'commit_author', user: render_cache_commit_author(tag['commit']['author']), name: tag['commit']['author']['name']
|
||||||
|
|
|
@ -55,6 +55,7 @@ default: &default
|
||||||
access_key_secret: ''
|
access_key_secret: ''
|
||||||
domain: 'https://testgit.trustie.net'
|
domain: 'https://testgit.trustie.net'
|
||||||
base_url: '/api/v1'
|
base_url: '/api/v1'
|
||||||
|
hat_base_url: '/api/hat'
|
||||||
accelerator:
|
accelerator:
|
||||||
access_key_id: ''
|
access_key_id: ''
|
||||||
access_key_secret: ''
|
access_key_secret: ''
|
||||||
|
|
|
@ -7,5 +7,14 @@ $gitea_client = Gitea::Api::Client.new({
|
||||||
domain: gitea_config[:domain],
|
domain: gitea_config[:domain],
|
||||||
base_url: gitea_config[:base_url],
|
base_url: gitea_config[:base_url],
|
||||||
username: gitea_config[:access_key_id],
|
username: gitea_config[:access_key_id],
|
||||||
password: gitea_config[:access_key_secret]
|
password: gitea_config[:access_key_secret],
|
||||||
|
log_filepath: "log/gitea-client.log"
|
||||||
|
})
|
||||||
|
|
||||||
|
$gitea_hat_client = Gitea::Api::Hat::Client.new({
|
||||||
|
domain: gitea_config[:domain],
|
||||||
|
hat_base_url: gitea_config[:hat_base_url],
|
||||||
|
username: gitea_config[:access_key_id],
|
||||||
|
password: gitea_config[:access_key_secret],
|
||||||
|
log_filepath: "log/gitea-client.log"
|
||||||
})
|
})
|
Loading…
Reference in New Issue