forgeplus/app/controllers/projects_controller.rb

class ProjectsController < ApplicationController
  include ApplicationHelper
  include OperateProjectAbilityAble
  include ProjectsHelper
  include Acceleratorable

  before_action :require_login, except: %i[index branches group_type_list simple show fork_users praise_users watch_users recommend about menu_list]
  before_action :load_repository, except: %i[index group_type_list migrate create recommend]
  before_action :authorizate_user_can_edit_project!, only: %i[update]
  before_action :project_public?, only: %i[fork_users praise_users watch_users]

  def menu_list
    menu = []

    menu.append(menu_hash_by_name("home"))
    menu.append(menu_hash_by_name("code")) if @project.has_menu_permission("code")
    menu.append(menu_hash_by_name("issues")) if @project.has_menu_permission("issues")
    menu.append(menu_hash_by_name("pulls")) if @project.has_menu_permission("pulls")
    menu.append(menu_hash_by_name("devops")) if @project.has_menu_permission("devops")
    menu.append(menu_hash_by_name("versions")) if @project.has_menu_permission("versions")
    menu.append(menu_hash_by_name("resources")) if @project.has_menu_permission("resources")
    menu.append(menu_hash_by_name("activity"))
    # menu.append(menu_hash_by_name("gantt"))
    # menu.append(menu_hash_by_name("sonar"))
    # menu.append(menu_hash_by_name("setting")) if current_user.admin? || @project.manager?(current_user)
    menu.append(menu_hash_by_name("sonar"))
    menu.append(menu_hash_by_name("setting")) if current_user.admin? || @project.manager?(current_user)
    menu.append(menu_hash_by_name("quit")) if !current_user.admin? && @project.member(current_user.id) && @project.forge?

    render json: menu
  end

  def index
    scope = Projects::ListQuery.call(params, current_user)

    # @projects = kaminari_paginate(scope)
    @total_count = scope.size
    @projects = paginate scope.includes(:project_category, :project_language, :repository, :project_educoder, :owner, :project_units, :applied_projects)
    # category_id = params[:category_id]
    # @total_count =
    #   if category_id.blank?
    #     ps = ProjectStatistic.first
    #     ps.common_projects_count + ps.mirror_projects_count unless ps.blank?
    #   else
    #     cate = ProjectCategory.find_by(id: category_id)
    #     cate&.projects_count || 0
    #   end
  end

  def create
    ActiveRecord::Base.transaction do
      Projects::CreateForm.new(project_params).validate!
      @project = Projects::CreateService.new(current_user, project_params).call

      # TODO: fix Educoder shixun
      if @project.persisted?
        ProjectScore.create(:project_id => @project.id, :score => 0) if @project.project_score.nil?

        project_info = ProjectInfo.new(:user_id => current_user.id, :project_id => @project.id)
        @project.project_infos << project_info
      end
    end
  rescue Exception => e
    uid_logger_error(e.message)
    tip_exception(e.message)
  end

  def migrate
    Projects::MigrateForm.new(mirror_params).validate!

    @project = 
      if enable_accelerator?(mirror_params[:clone_addr])
        source_clone_url = mirror_params[:clone_addr]
        uid_logger("########## 已动加速器 ##########")
        result = Gitea::Accelerator::MigrateService.call(mirror_params)
        if result[:status] == :success
          Rails.logger.info "########## 加速镜像成功 ########## "
          Projects::MigrateService.call(current_user, 
            mirror_params.merge(source_clone_url: source_clone_url, 
              clone_addr: accelerator_url(mirror_params[:repository_name])))
        else
          Projects::MigrateService.call(current_user, mirror_params)
        end
      else
        Projects::MigrateService.call(current_user, mirror_params)
      end
  rescue Exception => e
    uid_logger_error(e.message)
    tip_exception(e.message)
  end

  def branches
    return @branches = [] unless @project.forge?

    result = Gitea::Repository::Branches::ListService.call(@owner, @project.identifier)
    @branches =  result.is_a?(Hash) && result.key?(:status) ? [] : result
  end

  def group_type_list
    # project_statics = ProjectStatistic.first

    @project_statics_list = [
      {
        project_type: 'common',
        name: '开源托管项目',
        projects_count: Project.common.visible.size || 0
      },
      {
        project_type: 'mirror',
        name: '开源镜像项目',
        projects_count:  Project.sync_mirror.visible.count + Project.mirror.visible.count || 0
      }
    ]

    # projects = Project.no_anomory_projects.visible
    # @project_group_list = projects.group(:project_type).size
  end

  def update
    ActiveRecord::Base.transaction do
      # TODO:
      # 临时特殊处理修改website、lesson_url操作方法
      if project_params.has_key?("website")
        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)
            project_topic.project_topic_ralates.find_or_create_by!(project: @project)
          end
        end
        @project.update(project_params)
      elsif project_params.has_key?("default_branch") && project_params[:default_branch].present?
        @project.update(default_branch: project_params[:default_branch])
        gitea_params = {
          default_branch: @project.default_branch
        }
        Gitea::Repository::UpdateService.call(@owner, @project.identifier, gitea_params)
      else
        validate_params = project_params.slice(:name, :description, 
          :project_category_id, :project_language_id, :private, :join_project_need_verify)
  
        Projects::UpdateForm.new(validate_params).validate!
  
        private = @project.forked_from_project.present? ? !@project.forked_from_project.is_public : params[:private] || false

        new_project_params = project_params.except(:private).merge(is_public: !private)
        @project.update_attributes!(new_project_params)
        @project.forked_projects.update_all(is_public: @project.is_public)
        gitea_params = {
          private: private,
          default_branch: @project.default_branch,
          website: @project.website
        }
        if [true, false].include? private
          Gitea::Repository::UpdateService.call(@owner, @project.identifier, gitea_params)
          @project.repository.update_column(:hidden, private)
        end
      end
    end
  rescue Exception => e
    uid_logger_error(e.message)
    tip_exception(e.message)
  end

  def show
  end

  def destroy
    if current_user.admin? || @project.manager?(current_user)
      ActiveRecord::Base.transaction do
        Gitea::Repository::DeleteService.new(@project.owner, @project.identifier).call
        @project.destroy!
        @project.forked_projects.update_all(forked_from_project_id: nil)
        render_ok
      end
    else
      render_forbidden('你没有权限操作')
    end
  rescue Exception => e
    uid_logger_error(e.message)
    tip_exception(e.message)
  end

  def watch_users
    watchers = @project.watchers.includes(:user).order("watchers.created_at desc").distinct
    @watchers_count = watchers.size
    @watchers = paginate(watchers)
  end

  def praise_users
    praises = @project.praise_treads.includes(:user).order("praise_treads.created_at desc").distinct
    @praises_count = praises.size
    @praises = paginate(praises)
  end

  def fork_users
    fork_users = @project.fork_users.includes(:user, :project, :fork_project).order("fork_users.created_at desc").distinct
    @forks_count = fork_users.size
    @fork_users = paginate(fork_users)
  end

  def simple
    json_response(@project, current_user)
  end

  def recommend
    @projects = Project.recommend.includes(:repository, :project_category, :owner).order(visits: :desc)
  end

  def about
    @project_detail = @project.project_detail
    @attachments = Array(@project_detail&.attachments) if request.get?
    ActiveRecord::Base.transaction do
      if request.post?
        require_login
        authorizate_user_can_edit_project!
        unless @project_detail.present?
          @project_detail = ProjectDetail.new(
            content: params[:content],
            project_id: @project.id)
        else
          @project_detail.content = params[:content]
        end
        if @project_detail.save!
          attachment_ids = Array(params[:attachment_ids])
          logger.info "=============> #{Array(params[:attachment_ids])}"
          @attachments =  Attachment.where(id: attachment_ids)
          @attachments.update_all(
            container_id: @project_detail.id,
            container_type: @project_detail.model_name.name,
            author_id: current_user.id,
            description: "")
        end
      end
    end
  end


  private
  def project_params
    params.permit(:user_id, :name, :description, :repository_name, :website, :lesson_url, :default_branch, :identifier,
                  :project_category_id, :project_language_id, :license_id, :ignore_id, :private, :join_project_need_verify)
  end

  def mirror_params
    params.permit(:user_id, :name, :description, :repository_name, :is_mirror, :auth_username,
                  :auth_password, :project_category_id, :project_language_id, :clone_addr, :private)
  end

  def project_public?
    return if @project.is_public?

    if current_user
      return if current_user.admin? || @project.member?(current_user.id)
      render_forbidden('你没有权限访问.')
    else
      render_unauthorized('你还未登录.')
    end
  end
end