Merge branch 'pre_trustie_server' into trustie_server
This commit is contained in:
commit
44226dc981
3
Gemfile
3
Gemfile
|
|
@ -71,6 +71,9 @@ group :development do
|
|||
gem 'web-console', '>= 3.3.0'
|
||||
gem 'listen', '>= 3.0.5', '< 3.2'
|
||||
gem 'spring'
|
||||
gem 'pry-rails'
|
||||
gem 'pry-remote'
|
||||
gem 'byebug', platforms: [:mri,:mingw,:x64_mingw]
|
||||
gem 'spring-watcher-listen', '~> 2.0.0'
|
||||
gem "annotate", "~> 2.6.0"
|
||||
end
|
||||
|
|
|
|||
52
Gemfile.lock
52
Gemfile.lock
|
|
@ -1,5 +1,5 @@
|
|||
GEM
|
||||
remote: https://gems.ruby-china.com/
|
||||
remote: https://mirrors.cloud.tencent.com/rubygems/
|
||||
specs:
|
||||
aasm (5.0.6)
|
||||
concurrent-ruby (~> 1.0)
|
||||
|
|
@ -84,6 +84,7 @@ GEM
|
|||
builder (3.2.4)
|
||||
bulk_insert (1.7.0)
|
||||
activerecord (>= 3.2.0)
|
||||
byebug (11.1.3)
|
||||
capybara (3.15.1)
|
||||
addressable
|
||||
mini_mime (>= 0.1.3)
|
||||
|
|
@ -99,6 +100,7 @@ GEM
|
|||
archive-zip (~> 0.10)
|
||||
nokogiri (~> 1.8)
|
||||
chunky_png (1.3.11)
|
||||
coderay (1.1.3)
|
||||
concurrent-ruby (1.1.6)
|
||||
connection_pool (2.2.2)
|
||||
crass (1.0.6)
|
||||
|
|
@ -106,6 +108,8 @@ GEM
|
|||
activerecord (>= 3.1.0, < 7)
|
||||
diff-lcs (1.3)
|
||||
diffy (3.3.0)
|
||||
domain_name (0.5.20190701)
|
||||
unf (>= 0.0.5, < 1.0.0)
|
||||
doorkeeper (5.5.1)
|
||||
railties (>= 5)
|
||||
doorkeeper-jwt (0.4.1)
|
||||
|
|
@ -133,6 +137,8 @@ GEM
|
|||
fugit (1.4.1)
|
||||
et-orbi (~> 1.1, >= 1.1.8)
|
||||
raabro (~> 1.4)
|
||||
gitea-client (1.4.1)
|
||||
rest-client (~> 2.1.0)
|
||||
globalid (0.4.2)
|
||||
activesupport (>= 4.2.0)
|
||||
grape-entity (0.7.1)
|
||||
|
|
@ -143,6 +149,9 @@ GEM
|
|||
harmonious_dictionary (0.0.1)
|
||||
hashie (3.6.0)
|
||||
htmlentities (4.3.4)
|
||||
http-accept (1.7.0)
|
||||
http-cookie (1.0.5)
|
||||
domain_name (~> 0.5)
|
||||
i18n (1.8.2)
|
||||
concurrent-ruby (~> 1.0)
|
||||
io-like (0.3.1)
|
||||
|
|
@ -180,6 +189,9 @@ GEM
|
|||
mimemagic (~> 0.3.2)
|
||||
maruku (0.7.3)
|
||||
method_source (0.9.2)
|
||||
mime-types (3.4.1)
|
||||
mime-types-data (~> 3.2015)
|
||||
mime-types-data (3.2023.0218.1)
|
||||
mimemagic (0.3.10)
|
||||
nokogiri (~> 1)
|
||||
rake
|
||||
|
|
@ -193,6 +205,7 @@ GEM
|
|||
mustermann (1.1.1)
|
||||
ruby2_keywords (~> 0.0.1)
|
||||
mysql2 (0.5.3)
|
||||
netrc (0.11.0)
|
||||
nio4r (2.5.2)
|
||||
nokogiri (1.10.8)
|
||||
mini_portile2 (~> 2.4.0)
|
||||
|
|
@ -209,9 +222,21 @@ GEM
|
|||
addressable (~> 2.3)
|
||||
nokogiri (~> 1.5)
|
||||
omniauth (~> 1.2)
|
||||
omniauth-gitee (1.0.0)
|
||||
omniauth (>= 1.5, < 3.0)
|
||||
omniauth-oauth2 (>= 1.4.0, < 2.0)
|
||||
omniauth-github (1.4.0)
|
||||
omniauth (~> 1.5)
|
||||
omniauth-oauth2 (>= 1.4.0, < 2.0)
|
||||
omniauth-oauth2 (1.6.0)
|
||||
oauth2 (~> 1.1)
|
||||
omniauth (~> 1.9)
|
||||
omniauth-rails_csrf_protection (0.1.2)
|
||||
actionpack (>= 4.2)
|
||||
omniauth (>= 1.3.1)
|
||||
omniauth-wechat-oauth2 (0.2.2)
|
||||
omniauth (>= 1.3.2)
|
||||
omniauth-oauth2 (>= 1.1.1)
|
||||
parallel (1.19.1)
|
||||
parser (2.7.1.1)
|
||||
ast (~> 2.4.0)
|
||||
|
|
@ -221,6 +246,14 @@ GEM
|
|||
popper_js (1.16.0)
|
||||
powerpack (0.1.2)
|
||||
prettier (0.18.2)
|
||||
pry (0.12.2)
|
||||
coderay (~> 1.1.0)
|
||||
method_source (~> 0.9.0)
|
||||
pry-rails (0.3.9)
|
||||
pry (>= 0.10.4)
|
||||
pry-remote (0.1.8)
|
||||
pry (~> 0.9)
|
||||
slop (~> 3.0)
|
||||
public_suffix (4.0.3)
|
||||
puma (3.12.2)
|
||||
raabro (1.4.0)
|
||||
|
|
@ -292,6 +325,11 @@ GEM
|
|||
regexp_parser (1.7.0)
|
||||
request_store (1.5.0)
|
||||
rack (>= 1.4)
|
||||
rest-client (2.1.0)
|
||||
http-accept (>= 1.7.0, < 2.0)
|
||||
http-cookie (>= 1.0.2, < 2.0)
|
||||
mime-types (>= 1.16, < 4.0)
|
||||
netrc (~> 0.8)
|
||||
reverse_markdown (1.4.0)
|
||||
nokogiri
|
||||
roo (2.8.3)
|
||||
|
|
@ -380,6 +418,7 @@ GEM
|
|||
rack (~> 2.0)
|
||||
rack-protection (= 2.0.8.1)
|
||||
tilt (~> 2.0)
|
||||
slop (3.6.0)
|
||||
solargraph (0.38.6)
|
||||
backport (~> 1.1)
|
||||
benchmark
|
||||
|
|
@ -418,6 +457,9 @@ GEM
|
|||
thread_safe (~> 0.1)
|
||||
uglifier (4.2.0)
|
||||
execjs (>= 0.3.0, < 3)
|
||||
unf (0.1.4)
|
||||
unf_ext
|
||||
unf_ext (0.0.8.2)
|
||||
unicode-display_width (1.6.1)
|
||||
web-console (3.7.0)
|
||||
actionview (>= 5.0)
|
||||
|
|
@ -448,6 +490,7 @@ DEPENDENCIES
|
|||
bootsnap (>= 1.1.0)
|
||||
bootstrap (~> 4.3.1)
|
||||
bulk_insert
|
||||
byebug
|
||||
capybara (>= 2.15, < 4.0)
|
||||
chartkick
|
||||
chinese_pinyin
|
||||
|
|
@ -459,6 +502,7 @@ DEPENDENCIES
|
|||
enumerize
|
||||
faraday (~> 0.15.4)
|
||||
font-awesome-sass (= 4.7.0)
|
||||
gitea-client (~> 1.4.1)
|
||||
grape-entity (~> 0.7.1)
|
||||
groupdate (~> 4.1.0)
|
||||
harmonious_dictionary (~> 0.0.1)
|
||||
|
|
@ -472,10 +516,16 @@ DEPENDENCIES
|
|||
oauth2
|
||||
omniauth (~> 1.9.0)
|
||||
omniauth-cas
|
||||
omniauth-gitee (~> 1.0.0)
|
||||
omniauth-github
|
||||
omniauth-oauth2 (~> 1.6.0)
|
||||
omniauth-rails_csrf_protection
|
||||
omniauth-wechat-oauth2
|
||||
parallel (~> 1.19, >= 1.19.1)
|
||||
pdfkit
|
||||
prettier
|
||||
pry-rails
|
||||
pry-remote
|
||||
puma (~> 3.11)
|
||||
rack-cors
|
||||
rack-mini-profiler
|
||||
|
|
|
|||
|
|
@ -27,6 +27,7 @@ class Api::V1::Issues::JournalsController < Api::V1::BaseController
|
|||
end
|
||||
|
||||
def destroy
|
||||
TouchWebhookJob.set(wait: 5.seconds).perform_later('IssueComment', @issue&.id, current_user.id, @journal.id, 'deleted', JSON.parse(@journal.to_builder.target!))
|
||||
if @journal.destroy!
|
||||
render_ok
|
||||
else
|
||||
|
|
|
|||
|
|
@ -10,7 +10,7 @@ class Api::V1::IssuesController < Api::V1::BaseController
|
|||
@opened_issues_count = @object_result[:opened_issues_count]
|
||||
@closed_issues_count = @object_result[:closed_issues_count]
|
||||
if params[:only_name].present?
|
||||
@issues = kaminary_select_paginate(@object_result[:data])
|
||||
@issues = kaminary_select_paginate(@object_result[:data].select(:id, :subject, :project_issues_index, :updated_on, :created_on))
|
||||
else
|
||||
@issues = kaminari_paginate(@object_result[:data])
|
||||
end
|
||||
|
|
|
|||
|
|
@ -31,14 +31,17 @@ class AttachmentsController < ApplicationController
|
|||
|
||||
def get_file
|
||||
normal_status(-1, "参数缺失") if params[:download_url].blank?
|
||||
url = base_url.starts_with?("https:") ? URI.encode(params[:download_url].to_s.gsub("http:", "https:")) : URI.encode(params[:download_url].to_s)
|
||||
url = base_url.starts_with?("https:") ? params[:download_url].to_s.gsub("http:", "https:") : params[:download_url].to_s
|
||||
if url.starts_with?(base_url) && !url.starts_with?("#{base_url}/repo")
|
||||
domain = GiteaService.gitea_config[:domain]
|
||||
api_url = GiteaService.gitea_config[:base_url]
|
||||
url = ("/repos"+url.split(base_url + "/api")[1]).gsub('?filepath=', '/').gsub('&', '?')
|
||||
request_url = [domain, api_url, url, "?ref=#{params[:ref]}&access_token=#{User.where(admin: true).take&.gitea_token}"].join
|
||||
url = ("/repos"+url.split(base_url + "/api")[1])
|
||||
filepath, ref = url.split("/")[-1].split("?")
|
||||
url.gsub!(url.split("/")[-1], '')
|
||||
puts filepath
|
||||
request_url = [domain, api_url, url, CGI.escape(filepath), "?ref=#{CGI.escape(ref.split('ref=')[1])}&access_token=#{User.where(admin: true).take&.gitea_token}"].join
|
||||
response = Faraday.get(request_url)
|
||||
filename = url.to_s.split("/").pop()
|
||||
filename = filepath
|
||||
else
|
||||
response = Faraday.get(url)
|
||||
filename = params[:download_url].to_s.split("/").pop()
|
||||
|
|
|
|||
|
|
@ -46,6 +46,7 @@ class JournalsController < ApplicationController
|
|||
end
|
||||
Rails.logger.info "[ATME] maybe to at such users: #{@atme_receivers.pluck(:login)}"
|
||||
AtmeService.call(current_user, @atme_receivers, journal) if @atme_receivers.size > 0
|
||||
TouchWebhookJob.set(wait: 5.seconds).perform_later('PullRequestComment', @issue&.id, current_user.id, journal.id, 'created', {})
|
||||
# @issue.project_trends.create(user_id: current_user.id, project_id: @project.id, action_type: "journal")
|
||||
|
||||
# author: zxh
|
||||
|
|
@ -66,6 +67,7 @@ class JournalsController < ApplicationController
|
|||
|
||||
def destroy
|
||||
if @journal.destroy #如果有子评论，子评论删除吗？
|
||||
TouchWebhookJob.set(wait: 5.seconds).perform_later('PullRequestComment', @issue&.id, current_user.id, @journal.id, 'deleted', JSON.parse(@journal.to_builder.target!))
|
||||
Journal.children_journals(@journal.id).destroy_all
|
||||
normal_status(0, "评论删除成功")
|
||||
else
|
||||
|
|
|
|||
|
|
@ -0,0 +1,56 @@
|
|||
class Organizations::IsPinnedProjectsController < Organizations::BaseController
|
||||
before_action :load_organization
|
||||
|
||||
def index
|
||||
@is_pinned_projects = @organization.pinned_projects.order(position: :desc, created_at: :asc).includes(project: [:project_category, :project_language, :repository]).order(position: :desc)
|
||||
@is_pinned_projects = kaminari_paginate(@is_pinned_projects)
|
||||
end
|
||||
|
||||
def pin
|
||||
project_ids = params[:is_pinned_project_ids] || []
|
||||
@organization.is_pinned_project_ids = project_ids
|
||||
|
||||
render_ok
|
||||
rescue ActiveRecord::RecordNotFound => e
|
||||
render_not_found
|
||||
rescue Exception => e
|
||||
uid_logger_error(e.message)
|
||||
tip_exception(e.message)
|
||||
end
|
||||
|
||||
def update
|
||||
@pinned_project = PinnedProject.find_by_id(params[:id])
|
||||
@pinned_project.attributes = pinned_project_params
|
||||
if @pinned_project.save
|
||||
render_ok
|
||||
else
|
||||
render_error
|
||||
end
|
||||
rescue Exception => e
|
||||
uid_logger_error(e.message)
|
||||
tip_exception(e.message)
|
||||
end
|
||||
|
||||
private
|
||||
|
||||
def load_organization
|
||||
@organization = Organization.find_by(login: params[:organization_id]) || Organization.find_by(id: params[:organization_id])
|
||||
return render_not_found("组织不存在") if @organization.nil?
|
||||
return render_forbidden("没有查看组织的权限") if org_limited_condition || org_privacy_condition
|
||||
end
|
||||
|
||||
# def is_pinned_project_ids
|
||||
# if params[:is_pinned_project_ids].present?
|
||||
# return params[:is_pinned_project_ids].select { |id| @organization.full_member_projects.visible.pluck(:id).include?(id.to_i) }
|
||||
# end
|
||||
# if params[:is_pinned_project_id].present?
|
||||
# return @organization.is_pinned_project_ids unless @organization.full_member_projects.visible.pluck(:id).include?(params[:is_pinned_project_id].to_i)
|
||||
# return @organization.is_pinned_project_ids.include?(params[:is_pinned_project_id].to_i) ? @organization.is_pinned_project_ids : @organization.is_pinned_project_ids.push(params[:is_pinned_project_id].to_i)
|
||||
# end
|
||||
# end
|
||||
|
||||
def pinned_project_params
|
||||
params.require(:pinned_project).permit(:position)
|
||||
end
|
||||
|
||||
end
|
||||
|
|
@ -1,8 +1,8 @@
|
|||
class Organizations::OrganizationsController < Organizations::BaseController
|
||||
before_action :require_login, except: [:index, :show, :recommend]
|
||||
before_action :require_profile_completed, only: [:create]
|
||||
before_action :require_login, except: [:index, :show, :recommend, :languages]
|
||||
# before_action :require_profile_completed, only: [:create]
|
||||
before_action :convert_image!, only: [:create, :update]
|
||||
before_action :load_organization, only: [:show, :update, :destroy]
|
||||
before_action :load_organization, only: [:show, :update, :destroy, :update_news, :update_memo, :update_other, :languages]
|
||||
before_action :check_user_can_edit_org, only: [:update, :destroy]
|
||||
|
||||
def index
|
||||
|
|
@ -62,6 +62,45 @@ class Organizations::OrganizationsController < Organizations::BaseController
|
|||
tip_exception(e.message)
|
||||
end
|
||||
|
||||
def update_news
|
||||
@organization.organization_extension.update_attributes!(news_banner_id: params[:news_banner_id],
|
||||
news_title: params[:news_title],
|
||||
news_url: params[:news_url],
|
||||
news_content: params[:news_content])
|
||||
render_ok
|
||||
end
|
||||
|
||||
def update_memo
|
||||
@organization.organization_extension.update_attributes!(memo: params[:memo])
|
||||
render_ok
|
||||
end
|
||||
|
||||
def update_other
|
||||
@organization.organization_extension.update_attributes!(news_banner_id: params[:news_banner_id],
|
||||
news_content: params[:news_content],
|
||||
news_title: params[:news_title],
|
||||
news_url: params[:news_url],
|
||||
memo: params[:memo])
|
||||
render_ok
|
||||
end
|
||||
|
||||
def languages
|
||||
projects = @organization.projects
|
||||
projects_count = @organization.projects.count
|
||||
|
||||
languages_hash = Rails.cache.fetch("query/organizations/languages/#{@organization.id}", :expires_in => 1.days) do
|
||||
total_languages(projects)
|
||||
end
|
||||
|
||||
languages_hash = languages_hash.sort { |x, y| y[1] <=> x[1] }
|
||||
sort_hash = Hash[*languages_hash.flatten]
|
||||
# Rails.logger.info "languages_hash=============#{sort_hash}"
|
||||
sort_hash= sort_hash.transform_values { |v|
|
||||
ActionController::Base.helpers.number_to_percentage((v / projects_count), precision: 1)
|
||||
}.select { |k, v| v != "0.0%" }
|
||||
render json: sort_hash
|
||||
end
|
||||
|
||||
def destroy
|
||||
tip_exception("密码不正确") unless current_user.check_password?(password)
|
||||
ActiveRecord::Base.transaction do
|
||||
|
|
@ -144,5 +183,28 @@ class Organizations::OrganizationsController < Organizations::BaseController
|
|||
# 更新对应所属分类下的项目数量（私有）
|
||||
project.project_category.decrement!(:private_projects_count, 1) if project.project_category.present?
|
||||
end
|
||||
|
||||
def total_languages(projects)
|
||||
languages_hash ={}
|
||||
projects.each do |p|
|
||||
result = Gitea::Repository::Languages::ListService.call(p.owner.login,
|
||||
p.identifier, current_user&.gitea_token)
|
||||
next unless result[:status] === :success
|
||||
total_byte_size = result[:body].values.sum
|
||||
hash = result[:body].transform_values { |v|
|
||||
(v * 100.0 / total_byte_size).to_f
|
||||
}
|
||||
|
||||
hash.each do |key,value|
|
||||
# Rails.logger.info "key=============#{key}:#{value}"
|
||||
if languages_hash.has_key?(key)
|
||||
languages_hash[key] = languages_hash[key] + value
|
||||
else
|
||||
languages_hash[key] = value
|
||||
end
|
||||
end
|
||||
end
|
||||
languages_hash
|
||||
end
|
||||
|
||||
end
|
||||
|
|
@ -39,10 +39,10 @@ class ProjectsController < ApplicationController
|
|||
|
||||
category_id = params[:category_id]
|
||||
@total_count =
|
||||
if category_id.blank? && params[:search].blank?
|
||||
if category_id.blank? && params[:search].blank? && params[:topic_id].blank?
|
||||
# 默认查询时count性能问题处理
|
||||
ProjectCategory.sum("projects_count") - Project.visible.joins("left join organization_extensions on organization_extensions.organization_id = projects.user_id").where("organization_extensions.visibility =2").count
|
||||
elsif params[:search].present?
|
||||
elsif params[:search].present? || params[:topic_id].present?
|
||||
@projects.total_count
|
||||
else
|
||||
cate = ProjectCategory.find_by(id: category_id)
|
||||
|
|
@ -130,7 +130,7 @@ class ProjectsController < ApplicationController
|
|||
# TODO:
|
||||
# 临时特殊处理修改website、lesson_url操作方法
|
||||
if project_params.has_key?("website")
|
||||
if params[:project_topic_names].present? && params[:project_topic_names].is_a?(Array)
|
||||
if params[:project_topic_names].is_a?(Array)
|
||||
ProjectTopicRalate.where(project: @project).destroy_all
|
||||
params[:project_topic_names].each do |name|
|
||||
project_topic = ProjectTopic.find_or_create_by!(name: name.downcase)
|
||||
|
|
|
|||
|
|
@ -318,15 +318,10 @@ class PullRequestsController < ApplicationController
|
|||
body: params[:body], #内容
|
||||
head: params[:head], #源分支
|
||||
base: params[:base], #目标分支
|
||||
milestone: 0, #里程碑,未与本地的里程碑关联
|
||||
# milestone: 0, #里程碑,未与本地的里程碑关联
|
||||
}
|
||||
assignee_login = User.find_by_id(params[:assigned_to_id])&.login
|
||||
@requests_params = @local_params.merge({
|
||||
# assignees: ["#{params[:assigned_login].to_s}"],
|
||||
assignees: ["#{assignee_login.to_s}"],
|
||||
labels: params[:issue_tag_ids]
|
||||
# due_date: Time.now
|
||||
})
|
||||
@requests_params = @local_params.merge({assignees: [assignee_login.to_s].reject!(&:empty?)})
|
||||
@issue_params = {
|
||||
author_id: current_user.id,
|
||||
project_id: @project.id,
|
||||
|
|
|
|||
|
|
@ -279,7 +279,7 @@ class RepositoriesController < ApplicationController
|
|||
domain = GiteaService.gitea_config[:domain]
|
||||
api_url = GiteaService.gitea_config[:base_url]
|
||||
|
||||
url = "/repos/#{@owner.login}/#{@repository.identifier}/raw/#{Addressable::URI.escape(params[:filepath])}?ref=#{Addressable::URI.escape(params[:ref])}"
|
||||
url = "/repos/#{@owner.login}/#{@repository.identifier}/raw/#{CGI.escape(params[:filepath])}?ref=#{CGI.escape(params[:ref])}"
|
||||
file_path = [domain, api_url, url].join
|
||||
file_path = [file_path, "access_token=#{@owner&.gitea_token}"].join("&")
|
||||
|
||||
|
|
|
|||
|
|
@ -4,7 +4,7 @@ class Projects::CreateForm < BaseForm
|
|||
:blockchain, :blockchain_token_all, :blockchain_init_token
|
||||
|
||||
validates :user_id, :name, :repository_name, presence: true
|
||||
validates :repository_name, format: { with: CustomRegexp::REPOSITORY_NAME_REGEX, multiline: true, message: "项目标识只能包含数字,字母,下划线(_),中划线(-),英文句号(.),必须以数字和字母开头，不能以下划线/中划线开头和结尾" }
|
||||
validates :repository_name, format: { with: CustomRegexp::REPOSITORY_NAME_REGEX, multiline: true, message: "项目标识只能包含数字,字母,下划线(_),中划线(-),英文句号(.),必须以数字和字母开头，不能以下划线/中划线/英文句号开头和结尾" }
|
||||
|
||||
validates :name, length: { maximum: 50 }
|
||||
validates :repository_name, length: { maximum: 100 }
|
||||
|
|
|
|||
|
|
@ -3,7 +3,7 @@ class Projects::MigrateForm < BaseForm
|
|||
:project_language_id, :clone_addr, :private, :is_mirror, :auth_username, :auth_password, :owner
|
||||
|
||||
validates :user_id, :name, :repository_name, :clone_addr, presence: true
|
||||
validates :repository_name, format: { with: CustomRegexp::REPOSITORY_NAME_REGEX, multiline: true, message: "项目标识只能包含数字,字母,下划线(_),中划线(-),英文句号(.),必须以数字和字母开头，不能以下划线/中划线开头和结尾" }
|
||||
validates :repository_name, format: { with: CustomRegexp::REPOSITORY_NAME_REGEX, multiline: true, message: "项目标识只能包含数字,字母,下划线(_),中划线(-),英文句号(.),必须以数字和字母开头，不能以下划线/中划线/英文句号开头和结尾" }
|
||||
validates :clone_addr, format: { with: CustomRegexp::URL_REGEX, multiline: true, message: "地址格式不正确" }
|
||||
validates :name, length: { maximum: 50 }
|
||||
validates :repository_name, length: { maximum: 100 }
|
||||
|
|
|
|||
|
|
@ -3,7 +3,7 @@ class Projects::UpdateForm < BaseForm
|
|||
validates :name, presence: true
|
||||
validates :name, length: { maximum: 50 }
|
||||
validates :description, length: { maximum: 200 }
|
||||
validates :identifier, format: { with: CustomRegexp::REPOSITORY_NAME_REGEX, multiline: true, message: '项目标识只能包含数字,字母,下划线(_),中划线(-),英文句号(.),必须以数字和字母开头，不能以下划线/中划线开头和结尾' }
|
||||
validates :identifier, format: { with: CustomRegexp::REPOSITORY_NAME_REGEX, multiline: true, message: '项目标识只能包含数字,字母,下划线(_),中划线(-),英文句号(.),必须以数字和字母开头，不能以下划线/中划线/英文句号开头和结尾' }
|
||||
|
||||
validate do
|
||||
check_project_category(project_category_id)
|
||||
|
|
|
|||
|
|
@ -22,7 +22,7 @@ module ProjectsHelper
|
|||
end
|
||||
|
||||
def render_download_file_url(owner, repository, filepath, ref)
|
||||
[base_url, "/api/#{owner&.login}/#{repository.identifier}/raw?filepath=#{filepath}&ref=#{ref}"].join
|
||||
[base_url, "/api/#{owner&.login}/#{repository.identifier}/raw/#{CGI.escape(filepath)}?ref=#{CGI.escape(ref)}"].join
|
||||
end
|
||||
|
||||
def render_http_url(project)
|
||||
|
|
|
|||
|
|
@ -0,0 +1,79 @@
|
|||
class TouchWebhookJob < ApplicationJob
|
||||
queue_as :webhook
|
||||
|
||||
def perform(source, *args)
|
||||
case source
|
||||
when 'IssueCreate'
|
||||
issue_id, sender_id = args[0], args[1]
|
||||
issue = Issue.find_by_id issue_id
|
||||
sender = User.find_by_id sender_id
|
||||
return if issue.nil? || sender.nil?
|
||||
issue.project.webhooks.each do |webhook|
|
||||
next unless webhook.events["events"]["issues"]
|
||||
_, _, @webhook_task = Webhook::IssueClient.new(webhook, issue, sender,"issues").do_request
|
||||
Rails.logger.info "Touch Webhook Response result: #{@webhook_task.response_content}"
|
||||
end
|
||||
when 'IssueUpdate'
|
||||
issue_id, sender_id, changes = args[0], args[1], args[2]
|
||||
issue = Issue.find_by_id issue_id
|
||||
sender = User.find_by_id sender_id
|
||||
return if issue.nil? || sender.nil? || !changes.is_a?(Hash) || changes.blank?
|
||||
issue.project.webhooks.each do |webhook|
|
||||
next unless webhook.events["events"]["issues"]
|
||||
_, _, @webhook_task = Webhook::IssueClient.new(webhook, issue, sender, "issues", changes.stringify_keys).do_request
|
||||
Rails.logger.info "Touch Webhook Response result: #{@webhook_task.response_content}"
|
||||
end
|
||||
|
||||
when 'IssueAssign'
|
||||
issue_id, sender_id, changes = args[0], args[1], args[2]
|
||||
issue = Issue.find_by_id issue_id
|
||||
sender = User.find_by_id sender_id
|
||||
return if issue.nil? || sender.nil?
|
||||
issue.project.webhooks.each do |webhook|
|
||||
next unless webhook.events["events"]["issue_assign"]
|
||||
_, _, @webhook_task = Webhook::IssueClient.new(webhook, issue, sender, "issue_assign", changes.stringify_keys).do_request
|
||||
Rails.logger.info "Touch Webhook Response result: #{@webhook_task.response_content}"
|
||||
end
|
||||
|
||||
when 'IssueLabel'
|
||||
issue_id, sender_id, changes = args[0], args[1], args[2]
|
||||
issue = Issue.find_by_id issue_id
|
||||
sender = User.find_by_id sender_id
|
||||
return if issue.nil? || sender.nil?
|
||||
issue.project.webhooks.each do |webhook|
|
||||
next unless webhook.events["events"]["issue_label"]
|
||||
_, _, @webhook_task = Webhook::IssueClient.new(webhook, issue, sender, "issue_label", changes.stringify_keys).do_request
|
||||
Rails.logger.info "Touch Webhook Response result: #{@webhook_task.response_content}"
|
||||
end
|
||||
|
||||
when 'IssueComment'
|
||||
issue_id, sender_id, comment_id, action_type, comment_json = args[0], args[1], args[2], args[3], args[4]
|
||||
issue = Issue.find_by_id issue_id
|
||||
comment = issue.comment_journals.find_by_id comment_id
|
||||
sender = User.find_by_id sender_id
|
||||
return if issue.nil? || sender.nil?
|
||||
return if action_type == 'edited' && comment_json.blank?
|
||||
|
||||
issue.project.webhooks.each do |webhook|
|
||||
next unless webhook.events["events"]["issue_comment"]
|
||||
_, _, @webhook_task = Webhook::IssueCommentClient.new(webhook, issue, comment, sender, "issue_comment", action_type, comment_json).do_request
|
||||
Rails.logger.info "Touch Webhook Response result: #{@webhook_task.response_content}"
|
||||
end
|
||||
|
||||
when 'PullRequestComment'
|
||||
issue_id, sender_id, comment_id, action_type, comment_json = args[0], args[1], args[2], args[3], args[4]
|
||||
issue = Issue.find_by_id(issue_id)
|
||||
comment = issue.comment_journals.find_by_id comment_id
|
||||
sender = User.find_by_id sender_id
|
||||
pull = issue.try(:pull_request)
|
||||
return if pull.nil? || sender.nil?
|
||||
return if action_type == 'edited' && comment_json.blank?
|
||||
|
||||
pull.project.webhooks.each do |webhook|
|
||||
next unless webhook.events["events"]["pull_request_comment"]
|
||||
_, _, @webhook_task = Webhook::PullCommentClient.new(webhook, pull, comment, sender, "pull_request_comment", action_type, comment_json).do_request
|
||||
Rails.logger.info "Touch Webhook Response result: #{@webhook_task.response_content}"
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
@ -10,6 +10,6 @@ module CustomRegexp
|
|||
IP = /^((\d|[1-9]\d|1\d{2}|2[0-4]\d|25[0-5])\.){3}(\d|[1-9]\d|1\d{2}|2[0-4]\d|25[0-5])$/
|
||||
|
||||
URL_REGEX = /\A(?:(?:https?|ftp):\/\/)(?:\S+(?::\S*)?@)?(?:(?!10(?:\.\d{1,3}){3})(?!127(?:\.\d{1,3}){3})(?!169\.254(?:\.\d{1,3}){2})(?!192\.168(?:\.\d{1,3}){2})(?!172\.(?:1[6-9]|2\d|3[0-1])(?:\.\d{1,3}){2})(?:[1-9]\d?|1\d\d|2[01]\d|22[0-3])(?:\.(?:1?\d{1,2}|2[0-4]\d|25[0-5])){2}(?:\.(?:[1-9]\d?|1\d\d|2[0-4]\d|25[0-4]))|(?:(?:[a-z\u00a1-\uffff0-9]+-?)*[a-z\u00a1-\uffff0-9]+)(?:\.(?:[a-z\u00a1-\uffff0-9]+-?)*[a-z\u00a1-\uffff0-9]+)*(?:\.(?:[a-z\u00a1-\uffff]{2,})))(?::\d{2,5})?(?:\/[^\s]*)?\z/i
|
||||
REPOSITORY_NAME_REGEX = /^[a-zA-Z0-9][a-zA-Z0-9\-\_\.]+$/ #只含有数字、字母、下划线不能以下划线开头和结尾
|
||||
REPOSITORY_NAME_REGEX = /^[a-zA-Z0-9][a-zA-Z0-9\-\_\.]+[a-zA-Z0-9]$/ #只含有数字、字母、下划线不能以下划线开头和结尾
|
||||
MD_REGEX = /^.+(\.[m|M][d|D])$/
|
||||
end
|
||||
|
|
|
|||
|
|
@ -1,42 +1,42 @@
|
|||
# == Schema Information
|
||||
#
|
||||
# Table name: attachments
|
||||
#
|
||||
# id :integer not null, primary key
|
||||
# container_id :integer
|
||||
# container_type :string(30)
|
||||
# filename :string(255) default(""), not null
|
||||
# disk_filename :string(255) default(""), not null
|
||||
# filesize :integer default("0"), not null
|
||||
# content_type :string(255) default("")
|
||||
# digest :string(60) default(""), not null
|
||||
# downloads :integer default("0"), not null
|
||||
# author_id :integer default("0"), not null
|
||||
# created_on :datetime
|
||||
# description :text(65535)
|
||||
# disk_directory :string(255)
|
||||
# attachtype :integer default("1")
|
||||
# is_public :integer default("1")
|
||||
# copy_from :string(255)
|
||||
# quotes :integer default("0")
|
||||
# is_publish :integer default("1")
|
||||
# publish_time :datetime
|
||||
# resource_bank_id :integer
|
||||
# unified_setting :boolean default("1")
|
||||
# cloud_url :string(255) default("")
|
||||
# course_second_category_id :integer default("0")
|
||||
# delay_publish :boolean default("0")
|
||||
# link :string(255)
|
||||
# clone_id :integer
|
||||
#
|
||||
# Indexes
|
||||
#
|
||||
# index_attachments_on_author_id (author_id)
|
||||
# index_attachments_on_clone_id (clone_id)
|
||||
# index_attachments_on_container_id_and_container_type (container_id,container_type)
|
||||
# index_attachments_on_created_on (created_on)
|
||||
#
|
||||
|
||||
# == Schema Information
|
||||
#
|
||||
# Table name: attachments
|
||||
#
|
||||
# id :integer not null, primary key
|
||||
# container_id :integer
|
||||
# container_type :string(30)
|
||||
# filename :string(255) default(""), not null
|
||||
# disk_filename :string(255) default(""), not null
|
||||
# filesize :integer default("0"), not null
|
||||
# content_type :string(255) default("")
|
||||
# digest :string(60) default(""), not null
|
||||
# downloads :integer default("0"), not null
|
||||
# author_id :integer default("0"), not null
|
||||
# created_on :datetime
|
||||
# description :text(65535)
|
||||
# disk_directory :string(255)
|
||||
# attachtype :integer default("1")
|
||||
# is_public :integer default("1")
|
||||
# copy_from :string(255)
|
||||
# quotes :integer default("0")
|
||||
# is_publish :integer default("1")
|
||||
# publish_time :datetime
|
||||
# resource_bank_id :integer
|
||||
# unified_setting :boolean default("1")
|
||||
# cloud_url :string(255) default("")
|
||||
# course_second_category_id :integer default("0")
|
||||
# delay_publish :boolean default("0")
|
||||
# link :string(255)
|
||||
# clone_id :integer
|
||||
#
|
||||
# Indexes
|
||||
#
|
||||
# index_attachments_on_author_id (author_id)
|
||||
# index_attachments_on_clone_id (clone_id)
|
||||
# index_attachments_on_container_id_and_container_type (container_id,container_type)
|
||||
# index_attachments_on_created_on (created_on)
|
||||
#
|
||||
|
||||
|
||||
|
||||
class Attachment < ApplicationRecord
|
||||
|
|
@ -184,4 +184,14 @@ class Attachment < ApplicationRecord
|
|||
is_pdf
|
||||
end
|
||||
|
||||
def to_builder
|
||||
Jbuilder.new do |attachment|
|
||||
attachment.id self.id
|
||||
attachment.title self.title
|
||||
attachment.filesize self.filesize
|
||||
attachment.is_pdf self.is_pdf?
|
||||
attachment.created_on self.created_on.strftime("%Y-%m-%d %H:%M")
|
||||
attachment.content_type self.content_type
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
|
|||
|
|
@ -1,6 +1,7 @@
|
|||
class Gitea::WebhookTask < Gitea::Base
|
||||
serialize :payload_content, JSON
|
||||
serialize :request_content, JSON
|
||||
serialize :response_content, JSON
|
||||
|
||||
self.inheritance_column = nil
|
||||
|
||||
|
|
@ -10,9 +11,4 @@ class Gitea::WebhookTask < Gitea::Base
|
|||
|
||||
enum type: {gogs: 1, slack: 2, gitea: 3, discord: 4, dingtalk: 5, telegram: 6, msteams: 7, feishu: 8, matrix: 9}
|
||||
|
||||
def response_content_json
|
||||
JSON.parse(response_content)
|
||||
rescue
|
||||
{}
|
||||
end
|
||||
end
|
||||
|
|
@ -219,4 +219,30 @@ class Issue < ApplicationRecord
|
|||
SendTemplateMessageJob.perform_later('IssueExpire', self.id) if Site.has_notice_menu? && self.due_date == Date.today + 1.days
|
||||
end
|
||||
|
||||
def to_builder
|
||||
Jbuilder.new do |issue|
|
||||
issue.(self, :id, :project_issues_index, :subject, :description, :branch_name, :start_date, :due_date)
|
||||
issue.created_at self.created_on.strftime("%Y-%m-%d %H:%M")
|
||||
issue.updated_at self.updated_on.strftime("%Y-%m-%d %H:%M")
|
||||
issue.tags self.show_issue_tags.map{|t| JSON.parse(t.to_builder.target!)}
|
||||
issue.status self.issue_status.to_builder
|
||||
if self.priority.present?
|
||||
issue.priority self.priority.to_builder
|
||||
else
|
||||
issue.priority nil
|
||||
end
|
||||
if self.version.present?
|
||||
issue.milestone self.version.to_builder
|
||||
else
|
||||
issue.milestone nil
|
||||
end
|
||||
issue.author self.user.to_builder
|
||||
issue.assigners self.show_assigners.map{|t| JSON.parse(t.to_builder.target!)}
|
||||
issue.participants self.participants.distinct.map{|t| JSON.parse(t.to_builder.target!)}
|
||||
issue.comment_journals_count self.comment_journals.size
|
||||
issue.operate_journals_count self.operate_journals.size
|
||||
issue.attachments self.attachments.map{|t| JSON.parse(t.to_builder.target!)}
|
||||
end
|
||||
end
|
||||
|
||||
end
|
||||
|
|
|
|||
|
|
@ -32,4 +32,10 @@ class IssuePriority < ApplicationRecord
|
|||
end
|
||||
end
|
||||
end
|
||||
|
||||
def to_builder
|
||||
Jbuilder.new do |priority|
|
||||
priority.(self, :id, :name)
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
|
|||
|
|
@ -44,4 +44,10 @@ class IssueStatus < ApplicationRecord
|
|||
end
|
||||
end
|
||||
end
|
||||
|
||||
def to_builder
|
||||
Jbuilder.new do |status|
|
||||
status.(self, :id, :name)
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
|
|||
|
|
@ -53,4 +53,11 @@ class IssueTag < ApplicationRecord
|
|||
self.update_column(:pull_requests_count, pull_request_issues.size)
|
||||
end
|
||||
|
||||
|
||||
def to_builder
|
||||
Jbuilder.new do |tag|
|
||||
tag.(self, :id, :name, :description)
|
||||
end
|
||||
end
|
||||
|
||||
end
|
||||
|
|
|
|||
|
|
@ -272,5 +272,15 @@ class Journal < ApplicationRecord
|
|||
send_details
|
||||
end
|
||||
|
||||
|
||||
def to_builder
|
||||
Jbuilder.new do |journal|
|
||||
journal.(self, :id, :notes, :comments_count)
|
||||
if self.parent_journal.present?
|
||||
journal.parent_journal self.parent_journal.to_builder
|
||||
end
|
||||
if self.reply_journal.present?
|
||||
journal.reply_journal self.reply_journal.to_builder
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
|
|||
|
|
@ -39,15 +39,18 @@
|
|||
# business :boolean default("0")
|
||||
# profile_completed :boolean default("0")
|
||||
# laboratory_id :integer
|
||||
# is_shixun_marker :boolean default("0")
|
||||
# admin_visitable :boolean default("0")
|
||||
# collaborator :boolean default("0")
|
||||
# platform :string(255) default("0")
|
||||
# gitea_token :string(255)
|
||||
# gitea_uid :integer
|
||||
# is_shixun_marker :boolean default("0")
|
||||
# is_sync_pwd :boolean default("1")
|
||||
# watchers_count :integer default("0")
|
||||
# devops_step :integer default("0")
|
||||
# gitea_token :string(255)
|
||||
# platform :string(255)
|
||||
# sponsor_certification :integer default("0")
|
||||
# sponsor_num :integer default("0")
|
||||
# sponsored_num :integer default("0")
|
||||
# sponsor_description :text(65535)
|
||||
# award_time :datetime
|
||||
#
|
||||
# Indexes
|
||||
#
|
||||
|
|
@ -55,9 +58,8 @@
|
|||
# index_users_on_homepage_engineer (homepage_engineer)
|
||||
# index_users_on_homepage_teacher (homepage_teacher)
|
||||
# index_users_on_laboratory_id (laboratory_id)
|
||||
# index_users_on_login (login) UNIQUE
|
||||
# index_users_on_mail (mail) UNIQUE
|
||||
# index_users_on_phone (phone) UNIQUE
|
||||
# index_users_on_login (login)
|
||||
# index_users_on_mail (mail)
|
||||
# index_users_on_type (type)
|
||||
#
|
||||
|
||||
|
|
@ -71,13 +73,16 @@ class Organization < Owner
|
|||
has_many :teams, dependent: :destroy
|
||||
has_many :organization_users, dependent: :destroy
|
||||
has_many :team_users, dependent: :destroy
|
||||
has_many :pinned_projects, class_name: 'PinnedProject', foreign_key: :user_id, dependent: :destroy
|
||||
has_many :is_pinned_projects, through: :pinned_projects, source: :project, validate: false
|
||||
|
||||
validates :login, presence: true
|
||||
validates_uniqueness_of :login, :if => Proc.new { |user| user.login_changed? && user.login.present? }, case_sensitive: false
|
||||
validates :login, format: { with: NAME_REGEX, multiline: true, message: "只能含有数字、字母、下划线且不能以下划线开头和结尾" }
|
||||
|
||||
delegate :description, :website, :location, :repo_admin_change_team_access, :recommend,
|
||||
:visibility, :max_repo_creation, :num_projects, :num_users, :num_teams, to: :organization_extension, allow_nil: true
|
||||
:visibility, :max_repo_creation, :num_projects, :num_users, :num_teams,
|
||||
:news_banner_id, :news_content, :memo, :news_title, :news_url, to: :organization_extension, allow_nil: true
|
||||
|
||||
scope :with_visibility, ->(visibility) { joins(:organization_extension).where(organization_extensions: {visibility: visibility}) if visibility.present? }
|
||||
|
||||
|
|
|
|||
|
|
@ -16,6 +16,9 @@
|
|||
# num_users :integer default("0")
|
||||
# num_teams :integer default("0")
|
||||
# recommend :boolean default("0")
|
||||
# news_banner_id :integer
|
||||
# news_content :text(65535)
|
||||
# memo :text(65535)
|
||||
#
|
||||
# Indexes
|
||||
#
|
||||
|
|
|
|||
|
|
@ -67,6 +67,7 @@ class Owner < ApplicationRecord
|
|||
has_many :projects, foreign_key: :user_id, dependent: :destroy
|
||||
has_many :repositories, foreign_key: :user_id, dependent: :destroy
|
||||
has_many :applied_transfer_projects, dependent: :destroy
|
||||
has_many :pinned_projects, foreign_key: :user_id, dependent: :destroy
|
||||
|
||||
scope :like, lambda { |keywords|
|
||||
# 表情处理
|
||||
|
|
|
|||
|
|
@ -17,6 +17,7 @@
|
|||
|
||||
class PinnedProject < ApplicationRecord
|
||||
|
||||
belongs_to :user
|
||||
# belongs_to :user
|
||||
belongs_to :owner, class_name: 'Owner', foreign_key: :user_id, optional: true
|
||||
belongs_to :project
|
||||
end
|
||||
|
|
|
|||
|
|
@ -3,7 +3,7 @@
|
|||
# Table name: projects
|
||||
#
|
||||
# id :integer not null, primary key
|
||||
# name :string(255) default(""), not null
|
||||
# name :string(255)
|
||||
# description :text(4294967295)
|
||||
# homepage :string(255) default("")
|
||||
# is_public :boolean default("1"), not null
|
||||
|
|
@ -122,7 +122,7 @@ class Project < ApplicationRecord
|
|||
has_many :project_units, dependent: :destroy
|
||||
has_one :applied_transfer_project,-> { order created_at: :desc }, dependent: :destroy
|
||||
has_many :pinned_projects, dependent: :destroy
|
||||
has_many :has_pinned_users, through: :pinned_projects, source: :user
|
||||
has_many :has_pinned_users, through: :pinned_projects, source: :owner
|
||||
has_many :webhooks, class_name: "Gitea::Webhook", primary_key: :gpid, foreign_key: :repo_id
|
||||
has_many :user_trace_tasks, dependent: :destroy
|
||||
has_many :project_invite_links, dependent: :destroy
|
||||
|
|
@ -477,4 +477,58 @@ class Project < ApplicationRecord
|
|||
return JSON.parse(cache_result)
|
||||
end
|
||||
end
|
||||
def to_builder
|
||||
Jbuilder.new do |project|
|
||||
project.id self.id
|
||||
project.identifier self.identifier
|
||||
project.name self.name
|
||||
project.description Nokogiri::HTML(self.description).text
|
||||
project.visits self.visits
|
||||
project.praises_count self.praises_count.to_i
|
||||
project.watchers_count self.watchers_count.to_i
|
||||
project.issues_count self.issues_count.to_i
|
||||
project.pull_requests_count self.pull_requests_count.to_i
|
||||
project.forked_count self.forked_count.to_i
|
||||
project.is_public self.is_public
|
||||
project.mirror_url self.repository&.mirror_url
|
||||
project.type self&.project_type
|
||||
project.created_at self.created_on.strftime("%Y-%m-%d %H:%M")
|
||||
project.updated_at self.updated_on.strftime("%Y-%m-%d %H:%M")
|
||||
project.forked_from_project_id self.forked_from_project_id
|
||||
project.platform self.platform
|
||||
project.author do
|
||||
if self.educoder?
|
||||
project_educoder = self.project_educoder
|
||||
project.name project_educoder&.owner
|
||||
project.type 'Educoder'
|
||||
project.login project_educoder&.repo_name.split('/')[0]
|
||||
project.image_url render_educoder_avatar_url(self.project_educoder)
|
||||
else
|
||||
user = self.owner
|
||||
project.name user.try(:show_real_name)
|
||||
project.type user&.type
|
||||
project.login user.login
|
||||
project.image_url user.get_letter_avatar_url
|
||||
end
|
||||
end
|
||||
|
||||
project.category do
|
||||
if self.project_category.blank?
|
||||
project.nil!
|
||||
else
|
||||
project.id self.project_category.id
|
||||
project.name self.project_category.name
|
||||
end
|
||||
end
|
||||
project.language do
|
||||
if self.project_language.blank?
|
||||
project.nil!
|
||||
else
|
||||
project.id self.project_language.id
|
||||
project.name self.project_language.name
|
||||
end
|
||||
end
|
||||
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
|
|||
|
|
@ -119,4 +119,37 @@ class PullRequest < ApplicationRecord
|
|||
|
||||
JSON.parse file_names
|
||||
end
|
||||
|
||||
def to_builder
|
||||
Jbuilder.new do |pull|
|
||||
pull.(self, :id, :gitea_number, :title, :body, :base, :head, :is_original, :comments_count)
|
||||
pull.user self.user.to_builder
|
||||
if self.fork_project.present?
|
||||
pull.fork_project self.fork_project.to_builder
|
||||
else
|
||||
pull.fork_project nil
|
||||
end
|
||||
pull.created_at self.created_at.strftime("%Y-%m-%d %H:%M")
|
||||
pull.updated_at self.updated_at.strftime("%Y-%m-%d %H:%M")
|
||||
pull.status self.pr_status
|
||||
pull.url self.pr_url
|
||||
end
|
||||
end
|
||||
|
||||
def pr_url
|
||||
return nil if self.project.nil?
|
||||
"#{Rails.application.config_for(:configuration)['platform_url']}/#{self.project.owner.login}/#{self.project.name}/pulls/#{self.id}"
|
||||
end
|
||||
|
||||
def pr_status
|
||||
case status
|
||||
when 0
|
||||
"OPEN"
|
||||
when 1
|
||||
"MERGED"
|
||||
when 2
|
||||
"CLOSED"
|
||||
end
|
||||
end
|
||||
|
||||
end
|
||||
|
|
|
|||
|
|
@ -868,6 +868,16 @@ class User < Owner
|
|||
end
|
||||
end
|
||||
|
||||
def to_builder
|
||||
Jbuilder.new do |user|
|
||||
user.(self, :id, :login)
|
||||
user.name self.real_name
|
||||
user.email self.mail
|
||||
user.image_url self.get_letter_avatar_url
|
||||
end
|
||||
end
|
||||
|
||||
|
||||
protected
|
||||
def validate_password_length
|
||||
# 管理员的初始密码是5位
|
||||
|
|
|
|||
|
|
@ -55,6 +55,12 @@ class Version < ApplicationRecord
|
|||
User.select(:login, :lastname,:firstname, :nickname)&.find_by_id(self.user_id)
|
||||
end
|
||||
|
||||
def to_builder
|
||||
Jbuilder.new do |version|
|
||||
version.(self, :id, :name, :description, :effective_date)
|
||||
end
|
||||
end
|
||||
|
||||
private
|
||||
def send_create_message_to_notice_system
|
||||
SendTemplateMessageJob.perform_later('ProjectMilestone', self.id, self.user_id) if Site.has_notice_menu?
|
||||
|
|
|
|||
|
|
@ -82,7 +82,11 @@ class Api::V1::Issues::CreateService < ApplicationService
|
|||
SendTemplateMessageJob.perform_later('IssueAssigned', current_user.id, @created_issue&.id, assigner_ids) unless assigner_ids.blank?
|
||||
SendTemplateMessageJob.perform_later('ProjectIssue', current_user.id, @created_issue&.id)
|
||||
end
|
||||
|
||||
|
||||
# 触发webhook
|
||||
TouchWebhookJob.set(wait: 5.seconds).perform_later('IssueCreate', @created_issue&.id, current_user.id)
|
||||
TouchWebhookJob.set(wait: 5.seconds).perform_later('IssueLabel', @created_issue&.id, current_user.id, {issue_tag_ids: [[], issue_tag_ids]}) unless issue_tag_ids.blank?
|
||||
TouchWebhookJob.set(wait: 5.seconds).perform_later('IssueAssign', @created_issue&.id, current_user.id, {assigner_ids: [[], assigner_ids]}) unless assigner_ids.blank?
|
||||
unlock("Api::V1::Issues::CreateService:#{project.id}") # 结束写数据，解锁
|
||||
end
|
||||
|
||||
|
|
|
|||
|
|
@ -43,7 +43,7 @@ class Api::V1::Issues::Journals::CreateService < ApplicationService
|
|||
|
||||
# @信息发送
|
||||
AtmeService.call(current_user, @atme_receivers, @created_journal) unless receivers_login.blank?
|
||||
|
||||
TouchWebhookJob.set(wait: 5.seconds).perform_later('IssueComment', @issue&.id, @current_user.id, @created_journal.id, 'created', {})
|
||||
unlock("Api::V1::Issues::Journals::CreateService:#{@issue.id}")
|
||||
|
||||
@created_journal
|
||||
|
|
|
|||
|
|
@ -38,6 +38,7 @@ class Api::V1::Issues::Journals::UpdateService < ApplicationService
|
|||
|
||||
# @信息发送
|
||||
AtmeService.call(current_user, @atme_receivers, @created_journal) unless receivers_login.blank?
|
||||
TouchWebhookJob.set(wait: 5.seconds).perform_later('IssueComment', @issue&.id, @current_user.id, @updated_journal.id, 'edited', @updated_journal.previous_changes.slice(:notes).stringify_keys)
|
||||
|
||||
unlock("Api::V1::Issues::Journals::UpdateService:#{@issue.id}:#{@journal.id}")
|
||||
|
||||
|
|
|
|||
|
|
@ -90,8 +90,8 @@ class Api::V1::Issues::ListService < ApplicationService
|
|||
end
|
||||
|
||||
if only_name.present?
|
||||
scope = issues.select(:id, :subject, :project_issues_index)
|
||||
scope = scope.reorder("project_issues_index asc").distinct
|
||||
scope = issues.select(:id, :subject, :project_issues_index, :updated_on, :created_on)
|
||||
scope = scope.reorder("#{sort_by} #{sort_direction}").distinct
|
||||
else
|
||||
scope = issues.includes(:priority, :issue_status, :user, :show_assigners, :show_issue_tags, :version, :comment_journals)
|
||||
scope = scope.reorder("#{sort_by} #{sort_direction}").distinct
|
||||
|
|
|
|||
|
|
@ -5,7 +5,7 @@ class Api::V1::Issues::UpdateService < ApplicationService
|
|||
|
||||
attr_reader :project, :issue, :current_user
|
||||
attr_reader :status_id, :priority_id, :milestone_id, :branch_name, :start_date, :due_date, :subject, :description, :blockchain_token_num
|
||||
attr_reader :issue_tag_ids, :assigner_ids, :attachment_ids, :receivers_login
|
||||
attr_reader :issue_tag_ids, :assigner_ids, :attachment_ids, :receivers_login, :before_issue_tag_ids, :before_assigner_ids
|
||||
attr_accessor :add_assigner_ids, :previous_issue_changes, :updated_issue, :atme_receivers
|
||||
|
||||
validates :project, :issue, :current_user, presence: true
|
||||
|
|
@ -26,6 +26,8 @@ class Api::V1::Issues::UpdateService < ApplicationService
|
|||
@blockchain_token_num = params[:blockchain_token_num]
|
||||
@issue_tag_ids = params[:issue_tag_ids]
|
||||
@assigner_ids = params[:assigner_ids]
|
||||
@before_issue_tag_ids = issue.issue_tags.pluck(:id)
|
||||
@before_assigner_ids = issue.assigners.pluck(:id)
|
||||
@attachment_ids = params[:attachment_ids]
|
||||
@receivers_login = params[:receivers_login]
|
||||
@add_assigner_ids = []
|
||||
|
|
@ -82,7 +84,12 @@ class Api::V1::Issues::UpdateService < ApplicationService
|
|||
end
|
||||
|
||||
unlock("Api::V1::Issues::UpdateService:#{project.id}:#{issue.id}")
|
||||
|
||||
# 触发webhook
|
||||
Rails.logger.info "################### 触发webhook"
|
||||
TouchWebhookJob.set(wait: 5.seconds).perform_later('IssueUpdate', @updated_issue&.id, current_user.id, previous_issue_changes.except(:issue_tags_value, :assigned_to_id))
|
||||
TouchWebhookJob.set(wait: 5.seconds).perform_later('IssueLabel', @issue&.id, current_user.id, {issue_tag_ids: [before_issue_tag_ids, issue_tag_ids]}) unless issue_tag_ids.nil?
|
||||
TouchWebhookJob.set(wait: 5.seconds).perform_later('IssueAssign', @issue&.id, current_user.id, {assigner_ids: [before_assigner_ids, assigner_ids]}) unless assigner_ids.nil?
|
||||
|
||||
return @updated_issue
|
||||
end
|
||||
end
|
||||
|
|
@ -128,7 +135,7 @@ class Api::V1::Issues::UpdateService < ApplicationService
|
|||
end
|
||||
|
||||
def build_previous_issue_changes
|
||||
@previous_issue_changes.merge!(@updated_issue.previous_changes.slice("status_id", "priority_id", "fixed_version_id", "issue_tags_value", "branch_name").symbolize_keys)
|
||||
@previous_issue_changes.merge!(@updated_issue.previous_changes.slice("status_id", "priority_id", "fixed_version_id", "issue_tags_value", "branch_name", "subject", "description").symbolize_keys)
|
||||
if @updated_issue.previous_changes[:start_date].present?
|
||||
@previous_issue_changes.merge!(start_date: [@updated_issue.previous_changes[:start_date][0].to_s, @updated_issue.previous_changes[:start_date][1].to_s])
|
||||
end
|
||||
|
|
|
|||
|
|
@ -0,0 +1,120 @@
|
|||
module Webhook::Client
|
||||
|
||||
# uuid SecureRandom.uuid
|
||||
# hmac = OpenSSL::HMAC.new(secret, OpenSSL::Digest::SHA1.new)
|
||||
# message = Gitea::WebhookTask.last.read_attribute_before_type_cast("payload_content")
|
||||
# hmac.update(message)
|
||||
# sha1 = hmac.digest.unpack('H*').first
|
||||
|
||||
attr_reader :uuid, :event, :http_method, :content_type, :url, :secret, :payload_content, :webhook
|
||||
attr_accessor :request_content, :response_content, :webhook_task
|
||||
|
||||
def initialize(opts)
|
||||
@uuid = opts[:uuid]
|
||||
@event = opts[:event]
|
||||
@webhook = opts[:webhook]
|
||||
@http_method = @webhook.http_method
|
||||
@content_type = @webhook.content_type
|
||||
@url = @webhook.url
|
||||
@secret = @webhook.secret
|
||||
@payload_content = opts[:payload_content]
|
||||
@request_content = {}
|
||||
@response_content = {}
|
||||
@webhook_task = Gitea::WebhookTask.create(
|
||||
hook_id: @webhook.id,
|
||||
uuid: @uuid,
|
||||
payload_content: @payload_content,
|
||||
event_type: @event,
|
||||
is_delivered: true
|
||||
)
|
||||
end
|
||||
|
||||
def do_request
|
||||
headers = {}
|
||||
headers['Content-Type'] = trans_content_type
|
||||
headers["X-Gitea-Delivery"] = @uuid
|
||||
headers["X-Gitea-Event"] = @event
|
||||
headers["X-Gitea-Event-Type"] = @event
|
||||
headers["X-Gitea-Signature"] = signatureSHA256
|
||||
headers["X-Gogs-Delivery"] = @uuid
|
||||
headers["X-Gogs-Event"] = @event
|
||||
headers["X-Gogs-Event-Type"] = @event
|
||||
headers["X-Gogs-Signature"] = signatureSHA256
|
||||
headers["X-Hub-Signature"] = "sha1=" + signatureSHA1
|
||||
headers["X-Hub-Signature-256"] = "sha256=" + signatureSHA256
|
||||
headers["X-GitHub-Delivery"] = @uuid
|
||||
headers["X-GitHub-Event"] = @event
|
||||
headers["X-GitHub-Event-Type"] = @event
|
||||
@request_content["url"] = @url
|
||||
@request_content["http_method"] = @http_method
|
||||
@request_content["headers"] = headers
|
||||
|
||||
begin
|
||||
|
||||
response = RestClient::Request.execute(method: trans_http_method, url: @url, headers: headers, payload: @webhook_task.read_attribute_before_type_cast("payload_content")) {|response, request, result| response }
|
||||
|
||||
@response_content["status"] = response.code
|
||||
@response_content["headers"] = response.headers
|
||||
@response_content["body"] = response.body
|
||||
|
||||
rescue => e
|
||||
@response_content["status"] = 500
|
||||
@response_content["headers"] = {}
|
||||
@response_content["body"] = e.message
|
||||
end
|
||||
|
||||
@webhook_task.update_attributes({
|
||||
delivered: Time.now.to_i * 1000000000,
|
||||
is_succeed: @response_content["status"] < 300,
|
||||
request_content: @request_content,
|
||||
response_content: @response_content
|
||||
})
|
||||
|
||||
|
||||
return @request_content, @response_content, @webhook_task
|
||||
end
|
||||
|
||||
def request_content
|
||||
@request_content
|
||||
end
|
||||
|
||||
def response_content
|
||||
@response_content
|
||||
end
|
||||
|
||||
def webhook_task
|
||||
@webhook_task
|
||||
end
|
||||
|
||||
private
|
||||
def signatureSHA1
|
||||
hmac = OpenSSL::HMAC.new(@secret, OpenSSL::Digest::SHA1.new)
|
||||
message = @payload_content
|
||||
|
||||
hmac.digest.unpack('H*').first
|
||||
end
|
||||
|
||||
def signatureSHA256
|
||||
hmac = OpenSSL::HMAC.new(@secret, OpenSSL::Digest::SHA256.new)
|
||||
message = @payload_content
|
||||
|
||||
hmac.digest.unpack('H*').first
|
||||
end
|
||||
|
||||
def trans_content_type
|
||||
if @content_type == "form"
|
||||
return "application/x-www-form-urlencoded"
|
||||
else
|
||||
return "application/json"
|
||||
end
|
||||
end
|
||||
|
||||
def trans_http_method
|
||||
if @http_method == "GET"
|
||||
return :get
|
||||
else
|
||||
return :post
|
||||
end
|
||||
end
|
||||
|
||||
end
|
||||
|
|
@ -0,0 +1,117 @@
|
|||
class Webhook::IssueClient
|
||||
|
||||
include Webhook::Client
|
||||
|
||||
attr_accessor :webhook, :issue, :sender, :event, :changes
|
||||
attr_accessor :webhook_task
|
||||
|
||||
def initialize(webhook, issue, sender, event, changes={})
|
||||
@webhook = webhook
|
||||
@issue = issue.reload
|
||||
@sender = sender.reload
|
||||
@event = event
|
||||
@changes = changes
|
||||
|
||||
# 构建client参数
|
||||
super({
|
||||
uuid: SecureRandom.uuid,
|
||||
event: @event,
|
||||
webhook: @webhook,
|
||||
payload_content: payload_content
|
||||
})
|
||||
end
|
||||
|
||||
def payload_content
|
||||
case @event
|
||||
when "issues"
|
||||
issue_payload_content
|
||||
when "issue_assign"
|
||||
issue_assign_payload_content
|
||||
when "issue_label"
|
||||
issue_label_payload_content
|
||||
end
|
||||
end
|
||||
|
||||
def issue_payload_content
|
||||
if @changes.blank?
|
||||
{
|
||||
"action": "opened",
|
||||
"number": @issue.project_issues_index,
|
||||
"issue": JSON.parse(@issue.to_builder.target!),
|
||||
"project": JSON.parse(@issue.project.to_builder.target!),
|
||||
"sender": JSON.parse(@sender.to_builder.target!)
|
||||
}
|
||||
else
|
||||
if @changes.has_key?("status_id")
|
||||
before_status = IssueStatus.find_by_id(@changes["status_id"][0])
|
||||
after_status = IssueStatus.find_by_id(@changes["status_id"][1])
|
||||
@changes["status"] = []
|
||||
@changes["status"].append(before_status.present? ? JSON.parse(before_status.to_builder.target!) : {})
|
||||
@changes["status"].append(after_status.present? ? JSON.parse(after_status.to_builder.target!) : {})
|
||||
@changes.delete("status_id")
|
||||
end
|
||||
if @changes.has_key?("fixed_version_id")
|
||||
before_milestone = Version.find_by_id(@changes["fixed_version_id"][0])
|
||||
after_milestone = Version.find_by_id(@changes["fixed_version_id"][1])
|
||||
@changes["milestone"] = []
|
||||
@changes["milestone"].append(before_milestone.present? ? JSON.parse(before_milestone.to_builder.target!) : {})
|
||||
@changes["milestone"].append(after_milestone.present? ? JSON.parse(after_milestone.to_builder.target!) : {})
|
||||
@changes.delete("fixed_version_id")
|
||||
end
|
||||
if @changes.has_key?("priority_id")
|
||||
before_priority = IssuePriority.find_by_id(@changes["priority_id"][0])
|
||||
after_priority = IssuePriority.find_by_id(@changes["priority_id"][1])
|
||||
@changes["priority"] = []
|
||||
@changes["priority"].append(before_priority.present? ? JSON.parse(before_priority.to_builder.target!) : {})
|
||||
@changes["priority"].append(after_priority.present? ? JSON.parse(after_priority.to_builder.target!) : {})
|
||||
@changes.delete("priority_id")
|
||||
end
|
||||
{
|
||||
"action": "edited",
|
||||
"number": @issue.project_issues_index,
|
||||
"changes": @changes,
|
||||
"issue": JSON.parse(@issue.to_builder.target!),
|
||||
"project": JSON.parse(@issue.project.to_builder.target!),
|
||||
"sender": JSON.parse(@sender.to_builder.target!)
|
||||
}
|
||||
end
|
||||
end
|
||||
|
||||
def issue_assign_payload_content
|
||||
if @changes.has_key?("assigner_ids")
|
||||
before_assigners = User.where(id: @changes["assigner_ids"][0])
|
||||
after_assigners = User.where(id: @changes["assigner_ids"][1])
|
||||
@changes["assigners"] = []
|
||||
@changes["assigners"].append(before_assigners.blank? ? [] : before_assigners.map{|a|JSON.parse(a.to_builder.target!)})
|
||||
@changes["assigners"].append(after_assigners.blank? ? [] : after_assigners.map{|a|JSON.parse(a.to_builder.target!)})
|
||||
@changes.delete("assigner_ids")
|
||||
end
|
||||
{
|
||||
"action": @changes["assigners"].blank? ? "unassigned" : "assigned",
|
||||
"number": @issue.project_issues_index,
|
||||
"changes": @changes,
|
||||
"issue": JSON.parse(@issue.to_builder.target!),
|
||||
"project": JSON.parse(@issue.project.to_builder.target!),
|
||||
"sender": JSON.parse(@sender.to_builder.target!)
|
||||
}
|
||||
end
|
||||
|
||||
def issue_label_payload_content
|
||||
if @changes.has_key?("issue_tag_ids")
|
||||
before_issue_tags = IssueTag.where(id: @changes["issue_tag_ids"][0])
|
||||
after_issue_tags = IssueTag.where(id: @changes["issue_tag_ids"][1])
|
||||
@changes["issue_tags"] = []
|
||||
@changes["issue_tags"].append(before_issue_tags.blank? ? [] : before_issue_tags.map{|t|JSON.parse(t.to_builder.target!)})
|
||||
@changes["issue_tags"].append(after_issue_tags.blank? ? [] : after_issue_tags.map{|t|JSON.parse(t.to_builder.target!)})
|
||||
@changes.delete("issue_tag_ids")
|
||||
end
|
||||
{
|
||||
"action": @changes["issue_tags"].blank? ? "label_cleared" : "label_updated",
|
||||
"changes": @changes,
|
||||
"number": @issue.project_issues_index,
|
||||
"issue": JSON.parse(@issue.to_builder.target!),
|
||||
"project": JSON.parse(@issue.project.to_builder.target!),
|
||||
"sender": JSON.parse(@sender.to_builder.target!)
|
||||
}
|
||||
end
|
||||
end
|
||||
|
|
@ -0,0 +1,45 @@
|
|||
class Webhook::IssueCommentClient
|
||||
|
||||
include Webhook::Client
|
||||
|
||||
attr_accessor :webhook, :issue, :journal, :sender, :event, :action_type, :comment_json
|
||||
|
||||
def initialize(webhook, issue, journal, sender, event, action_type, comment_json={})
|
||||
@webhook = webhook
|
||||
@issue = issue.reload
|
||||
@journal = journal.present? ? journal.reload : nil
|
||||
@sender = sender.reload
|
||||
@event = event
|
||||
@action_type = action_type
|
||||
@comment_json = comment_json
|
||||
|
||||
# 构建client参数
|
||||
super({
|
||||
uuid: SecureRandom.uuid,
|
||||
event: @event,
|
||||
webhook: @webhook,
|
||||
payload_content: payload_content
|
||||
})
|
||||
end
|
||||
|
||||
|
||||
|
||||
private
|
||||
|
||||
def payload_content
|
||||
payload_content = {
|
||||
"action": @action_type,
|
||||
"issue": JSON.parse(@issue.to_builder.target!),
|
||||
"journal": @journal.present? ? JSON.parse(@journal.to_builder.target!) : @comment_json,
|
||||
"project": JSON.parse(@issue.project.to_builder.target!),
|
||||
"sender": JSON.parse(@sender.to_builder.target!),
|
||||
"is_pull": false
|
||||
}
|
||||
|
||||
payload_content.merge!({
|
||||
"changes": @comment_json,
|
||||
}) if @action_type == "edited"
|
||||
|
||||
payload_content
|
||||
end
|
||||
end
|
||||
|
|
@ -0,0 +1,43 @@
|
|||
class Webhook::PullCommentClient
|
||||
include Webhook::Client
|
||||
|
||||
attr_accessor :webhook, :pull, :journal, :sender, :event, :action_type, :comment_json
|
||||
|
||||
def initialize(webhook, pull, journal, sender, event, action_type='created', comment_json={})
|
||||
@webhook = webhook
|
||||
@pull = pull.reload
|
||||
@journal = journal.present? ? journal.reload : nil
|
||||
@sender = sender.reload
|
||||
@event = event
|
||||
@action_type = action_type
|
||||
@comment_json = comment_json
|
||||
# 构建client参数
|
||||
super({
|
||||
uuid: SecureRandom.uuid,
|
||||
event: @event,
|
||||
webhook: @webhook,
|
||||
payload_content: payload_content
|
||||
})
|
||||
end
|
||||
|
||||
private
|
||||
|
||||
def payload_content
|
||||
payload_content = {
|
||||
"action": @action_type,
|
||||
"number": @pull.gitea_number,
|
||||
"pull_request": JSON.parse(@pull.to_builder.target!),
|
||||
"comment": @journal.present? ? JSON.parse(@journal.to_builder.target!) : @comment_json,
|
||||
"project": JSON.parse(@pull.project.to_builder.target!),
|
||||
"sender": JSON.parse(@sender.to_builder.target!),
|
||||
"is_pull": true
|
||||
}
|
||||
|
||||
payload_content.merge!({
|
||||
"changes": @comment_json
|
||||
}) if @action_type == "edited"
|
||||
|
||||
payload_content
|
||||
end
|
||||
|
||||
end
|
||||
|
|
@ -3,12 +3,7 @@ json.type webhook["type"]
|
|||
json.content_type webhook['config']['content_type']
|
||||
json.http_method webhook['config']['http_method']
|
||||
json.url webhook['config']['url']
|
||||
event = webhook.events
|
||||
if event["send_everything"]
|
||||
json.events event["events"].keys.collect{|i| %w(pull_request issues).include?(i) ? i + "_only" : i}
|
||||
else
|
||||
json.events event["events"].select{|k, v| v}.keys.collect{|i| %w(pull_request issues).include?(i) ? i + "_only" : i}
|
||||
end
|
||||
json.events webhook["events"].collect{|i| %w(pull_request issues).include?(i) ? i + "_only" : i}
|
||||
json.active webhook['active']
|
||||
json.branch_filter webhook['branch_filter']
|
||||
json.created_at format_time(webhook['created_at'].to_time)
|
||||
|
|
@ -1,6 +1,6 @@
|
|||
json.total_count @hooktasks.total_count
|
||||
json.hooktasks @hooktasks.each do |task|
|
||||
json.(task, :id, :event_type, :type, :uuid, :is_succeed, :is_delivered, :payload_content, :request_content)
|
||||
json.response_content task.response_content_json
|
||||
json.response_content task.response_content
|
||||
json.delivered_time Time.at(task.delivered*10**-9).strftime("%Y-%m-%d %H:%M:%S")
|
||||
end
|
||||
|
|
@ -0,0 +1,7 @@
|
|||
json.total_count @is_pinned_projects.total_count
|
||||
json.projects @is_pinned_projects.each do |project|
|
||||
json.partial! "projects/project_detail", project: project&.project
|
||||
json.id project.id
|
||||
json.position project.position
|
||||
json.project_id project.project_id
|
||||
end
|
||||
|
|
@ -11,4 +11,9 @@ json.num_projects organization.num_projects
|
|||
json.num_users organization.num_users
|
||||
json.num_teams organization.num_teams
|
||||
json.avatar_url url_to_avatar(organization)
|
||||
json.created_at organization.created_on.strftime("%Y-%m-%d")
|
||||
json.created_at organization.created_on.strftime("%Y-%m-%d")
|
||||
json.news_banner_id organization.news_banner_id
|
||||
json.news_content organization.news_content
|
||||
json.memo organization.memo
|
||||
json.news_title organization.news_title
|
||||
json.news_url organization.news_url
|
||||
|
|
@ -2,6 +2,6 @@ json.id @webhook["id"]
|
|||
json.type @webhook["type"]
|
||||
json.content_type @webhook["config"]["content_type"]
|
||||
json.url @webhook["config"]["url"]
|
||||
json.events @webhook["events"]
|
||||
json.events @webhook["events"].collect{|i| %w(pull_request issues).include?(i) ? i + "_only" : i}
|
||||
json.active @webhook["active"]
|
||||
json.create_time @webhook["created_at"].to_time.strftime("%Y-%m-%d %H:%M:%S")
|
||||
|
|
@ -1,6 +1,6 @@
|
|||
json.total_count @tasks.total_count
|
||||
json.tasks @tasks.each do |task|
|
||||
json.(task, :id, :event_type, :type, :uuid, :is_succeed, :is_delivered, :payload_content, :request_content)
|
||||
json.response_content task.response_content_json
|
||||
json.delivered_time Time.at(task.delivered*10**-9).strftime("%Y-%m-%d %H:%M:%S")
|
||||
json.(task, :id, :event_type, :uuid, :is_succeed, :is_delivered, :payload_content, :request_content)
|
||||
json.response_content task.response_content
|
||||
json.delivered_time task.delivered.present? ? Time.at(task.delivered*10**-9).strftime("%Y-%m-%d %H:%M:%S") : nil
|
||||
end
|
||||
|
|
@ -17,14 +17,15 @@ if @project.forge?
|
|||
json.content (direct_download || image_type || is_dir) ? nil : decode64_content(entry, @owner, @repository, @ref, @path)
|
||||
json.target entry['target']
|
||||
|
||||
download_url =
|
||||
if image_type
|
||||
dir_path = [@owner.login, @repository.identifier, "raw/branch", @ref].join('/')
|
||||
is_dir ? "" : render_download_image_url(dir_path, entry['path'], decode64_content(entry, @owner, @repository, @ref))
|
||||
else
|
||||
# entry['download_url']
|
||||
is_dir ? "" : render_download_file_url(@owner, @repository, entry['path'].to_s, @ref)
|
||||
end
|
||||
download_url = is_dir ? "" : render_download_file_url(@owner, @repository, entry['path'].to_s, @ref)
|
||||
# if image_type
|
||||
# # dir_path = [@owner.login, @repository.identifier, "raw/branch", @ref].join('/')
|
||||
# # is_dir ? "" : render_download_image_url(dir_path, entry['path'], decode64_content(entry, @owner, @repository, @ref))
|
||||
# is_dir ? "" : render_gitea_raw_url(entry['download_url'])
|
||||
# else
|
||||
# # entry['download_url']
|
||||
# is_dir ? "" : render_download_file_url(@owner, @repository, entry['path'].to_s, @ref)
|
||||
# end
|
||||
json.download_url download_url
|
||||
|
||||
json.direct_download direct_download
|
||||
|
|
|
|||
|
|
@ -168,6 +168,17 @@ Rails.application.routes.draw do
|
|||
end
|
||||
end
|
||||
get :recommend, on: :collection
|
||||
resources :is_pinned_projects, only: [:index, :update] do
|
||||
collection do
|
||||
post :pin
|
||||
end
|
||||
end
|
||||
member do
|
||||
post :update_news
|
||||
post :update_memo
|
||||
post :update_other
|
||||
get :languages
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
|
|
@ -523,7 +534,7 @@ Rails.application.routes.draw do
|
|||
get 'readme'
|
||||
get 'languages'
|
||||
get 'archive/:archive', to: 'repositories#archive', as: "archive", constraints: { archive: /.+/, format: /(zip|gzip)/ }
|
||||
get 'raw', to: 'repositories#raw', as: "raw"
|
||||
get 'raw/*filepath', to: 'repositories#raw', as: "raw", constraints: { filepath: /.+/}
|
||||
end
|
||||
end
|
||||
|
||||
|
|
|
|||
|
|
@ -9,3 +9,4 @@
|
|||
- [mailers, 101]
|
||||
- [cache, 10]
|
||||
- [message, 20]
|
||||
- [webhook, 20]
|
||||
|
|
|
|||
|
|
@ -0,0 +1,7 @@
|
|||
class AddOrganizationExtensionsNews < ActiveRecord::Migration[5.2]
|
||||
def change
|
||||
add_column :organization_extensions, :news_banner_id, :integer
|
||||
add_column :organization_extensions, :news_content, :text
|
||||
add_column :organization_extensions, :memo, :text
|
||||
end
|
||||
end
|
||||
|
|
@ -0,0 +1,6 @@
|
|||
class AddOrganizationExtensionsNewsTitle < ActiveRecord::Migration[5.2]
|
||||
def change
|
||||
add_column :organization_extensions, :news_title, :string
|
||||
add_column :organization_extensions, :news_url, :string
|
||||
end
|
||||
end
|
||||
|
|
@ -0,0 +1,7 @@
|
|||
class ChangeWebhookTaskFieldCharacter < ActiveRecord::Migration[5.2]
|
||||
def change
|
||||
Gitea::Base.connection.execute("ALTER TABLE `hook_task` MODIFY `payload_content` longtext CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;")
|
||||
Gitea::Base.connection.execute("ALTER TABLE `hook_task` MODIFY `request_content` longtext CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;")
|
||||
Gitea::Base.connection.execute("ALTER TABLE `hook_task` MODIFY `response_content` longtext CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;")
|
||||
end
|
||||
end
|
||||
Loading…
Reference in New Issue