From 8c6df359a5f27e0d02c28c04a000d17b0245ad9d Mon Sep 17 00:00:00 2001
From: Jasder <2053003901@@qq.com>
Date: Fri, 8 Jan 2021 18:07:48 +0800
Subject: [PATCH] ADD sync repo updated at time

---
 app/jobs/sync_repo_update_time_job.rb         | 25 +++++++++++++++++++
 app/models/project.rb                         |  5 ++++
 .../gitea/repository/get_by_id_service.rb     | 25 ++++++++++---------
 config/initializers/sidekiq.rb                |  5 ++++
 config/routes.rb                              |  1 +
 config/schedule.yml                           |  5 ++++
 6 files changed, 54 insertions(+), 12 deletions(-)
 create mode 100644 app/jobs/sync_repo_update_time_job.rb
 create mode 100644 config/schedule.yml

diff --git a/app/jobs/sync_repo_update_time_job.rb b/app/jobs/sync_repo_update_time_job.rb
new file mode 100644
index 000000000..c2337ab94
--- /dev/null
+++ b/app/jobs/sync_repo_update_time_job.rb
@@ -0,0 +1,25 @@
+class SyncRepoUpdateTimeJob < ApplicationJob
+  queue_as :default
+
+  def perform(*args)
+    # Do something later
+    Project.forge.find_each do |project|
+      update_repo_time!(project)
+    end
+  end
+
+  private
+  def gitea_repo_updated_at(project)
+    admin = User.where(admin: true).select(:id, :gitea_token, :gitea_uid).last
+
+    return nil if project.gpid.blank?
+
+    result = Gitea::Repository::GetByIdService.call(project.gpid, admin.gitea_token)
+
+    result[:status] === :success ? result[:body]['updated_at'] : nil
+  end
+
+  def update_repo_time!(project)
+    project.set_updated_on gitea_repo_updated_at(project)
+  end
+end
diff --git a/app/models/project.rb b/app/models/project.rb
index 887a6952c..190f37760 100644
--- a/app/models/project.rb
+++ b/app/models/project.rb
@@ -279,4 +279,9 @@ class Project < ApplicationRecord
     ps.increment!(:mirror_projects_count) unless ps.blank?
   end
 
+  def set_updated_on(time)
+    return if time.blank?
+    update_column(:updated_on, time)
+  end
+
 end
diff --git a/app/services/gitea/repository/get_by_id_service.rb b/app/services/gitea/repository/get_by_id_service.rb
index c633c6b71..74f45708c 100644
--- a/app/services/gitea/repository/get_by_id_service.rb
+++ b/app/services/gitea/repository/get_by_id_service.rb
@@ -1,31 +1,32 @@
 class Gitea::Repository::GetByIdService < Gitea::ClientService
-  attr_reader :owner, :repo_id
+  attr_reader :token, :id
 
-  def initialize(owner, repo_id)
-    @owner   = owner
-    @repo_id = repo_id
+  def initialize(id, token=nil)
+    @token = token
+    @id    = id
   end
 
   def call
     response = get(url, params)
-    render_result(response)
+
+    status, message, body = render_response(response)
+    json_format(status, message, body)
   end
 
   private
   def params
-    Hash.new.merge(token: owner.gitea_token)
+    Hash.new.merge(token: token)
   end
 
   def url
-    "/repositories/#{repo_id}".freeze
+    "/repositories/#{id}".freeze
   end
 
-  def render_result(response)
-    case response.status
-    when 200
-      JSON.parse(response.body)
+  def json_format(status, message, body)
+    case status
+    when 200 then success(body)
     else
-      nil
+      error(message, status)
     end
   end
 end
diff --git a/config/initializers/sidekiq.rb b/config/initializers/sidekiq.rb
index b3f2d0576..79a0e296f 100644
--- a/config/initializers/sidekiq.rb
+++ b/config/initializers/sidekiq.rb
@@ -3,6 +3,11 @@ sidekiq_url = redis_config["url"]
 
 Sidekiq.configure_server do |config|
   config.redis = { url: sidekiq_url }
+
+  schedule_file = "config/schedule.yml"
+  if File.exists?(schedule_file)
+    Sidekiq::Cron::Job.load_from_hash YAML.load_file(schedule_file)
+  end
 end
 
 Sidekiq.configure_client do |config|
diff --git a/config/routes.rb b/config/routes.rb
index c6282581b..f7b1edd77 100644
--- a/config/routes.rb
+++ b/config/routes.rb
@@ -1,6 +1,7 @@
 Rails.application.routes.draw do
 
   require 'sidekiq/web'
+  require 'sidekiq/cron/web'
   require 'admin_constraint'
 
   # mount Sidekiq::Web => '/sidekiq', :constraints => AdminConstraint.new
diff --git a/config/schedule.yml b/config/schedule.yml
new file mode 100644
index 000000000..2b4269ac4
--- /dev/null
+++ b/config/schedule.yml
@@ -0,0 +1,5 @@
+sync_gitea_repo_updated_at:
+  # second minute hour day month date
+  cron: "0 0 24 * *"
+  class: "SyncRepoUpdateTimeJob"
+  queue: default