03b020f2e4
Previously we scheduled a worker to just some this but we were running into performance issues when the build table was getting too large. So now we've updated the code such that this column is updated immediately and incremented/decremented by the correct amount whenever artifacts are created or deleted. We've also added the performance optimization that we do not update this statistic if a project is deleted because it could result in many updates for a project with many builds.
48 lines
1.3 KiB
Ruby
48 lines
1.3 KiB
Ruby
class ProjectStatistics < ActiveRecord::Base
|
|
belongs_to :project
|
|
belongs_to :namespace
|
|
|
|
before_save :update_storage_size
|
|
|
|
COLUMNS_TO_REFRESH = [:repository_size, :lfs_objects_size, :commit_count].freeze
|
|
INCREMENTABLE_COLUMNS = [:build_artifacts_size].freeze
|
|
|
|
def total_repository_size
|
|
repository_size + lfs_objects_size
|
|
end
|
|
|
|
def refresh!(only: nil)
|
|
COLUMNS_TO_REFRESH.each do |column, generator|
|
|
if only.blank? || only.include?(column)
|
|
public_send("update_#{column}") # rubocop:disable GitlabSecurity/PublicSend
|
|
end
|
|
end
|
|
|
|
save!
|
|
end
|
|
|
|
def update_commit_count
|
|
self.commit_count = project.repository.commit_count
|
|
end
|
|
|
|
# Repository#size needs to be converted from MB to Byte.
|
|
def update_repository_size
|
|
self.repository_size = project.repository.size * 1.megabyte
|
|
end
|
|
|
|
def update_lfs_objects_size
|
|
self.lfs_objects_size = project.lfs_objects.sum(:size)
|
|
end
|
|
|
|
def update_storage_size
|
|
self.storage_size = repository_size + lfs_objects_size + build_artifacts_size
|
|
end
|
|
|
|
def self.increment_statistic(project_id, key, amount)
|
|
raise ArgumentError, "Cannot increment attribute: #{key}" unless key.in?(INCREMENTABLE_COLUMNS)
|
|
return if amount == 0
|
|
|
|
where(project_id: project_id)
|
|
.update_all(["#{key} = COALESCE(#{key}, 0) + (?)", amount])
|
|
end
|
|
end
|