debian-mirror-gitlab/app/models/namespace/root_storage_statistics.rb

71 lines
2.1 KiB
Ruby
Raw Normal View History

2019-09-30 21:07:59 +05:30
# frozen_string_literal: true
class Namespace::RootStorageStatistics < ApplicationRecord
2020-07-28 23:09:34 +05:30
SNIPPETS_SIZE_STAT_NAME = 'snippets_size'.freeze
2020-11-24 15:15:51 +05:30
STATISTICS_ATTRIBUTES = %W(
storage_size
repository_size
wiki_size
lfs_objects_size
build_artifacts_size
packages_size
#{SNIPPETS_SIZE_STAT_NAME}
pipeline_artifacts_size
).freeze
2019-09-30 21:07:59 +05:30
self.primary_key = :namespace_id
belongs_to :namespace
has_one :route, through: :namespace
2019-12-04 20:38:33 +05:30
scope :for_namespace_ids, ->(namespace_ids) { where(namespace_id: namespace_ids) }
2019-09-30 21:07:59 +05:30
delegate :all_projects, to: :namespace
def recalculate!
2020-07-28 23:09:34 +05:30
update!(merged_attributes)
2019-09-30 21:07:59 +05:30
end
private
2020-07-28 23:09:34 +05:30
def merged_attributes
attributes_from_project_statistics.merge!(attributes_from_personal_snippets) { |key, v1, v2| v1 + v2 }
end
2019-09-30 21:07:59 +05:30
def attributes_from_project_statistics
from_project_statistics
.take
.attributes
.slice(*STATISTICS_ATTRIBUTES)
end
def from_project_statistics
all_projects
.joins('INNER JOIN project_statistics ps ON ps.project_id = projects.id')
.select(
'COALESCE(SUM(ps.storage_size), 0) AS storage_size',
'COALESCE(SUM(ps.repository_size), 0) AS repository_size',
'COALESCE(SUM(ps.wiki_size), 0) AS wiki_size',
'COALESCE(SUM(ps.lfs_objects_size), 0) AS lfs_objects_size',
'COALESCE(SUM(ps.build_artifacts_size), 0) AS build_artifacts_size',
2020-07-28 23:09:34 +05:30
'COALESCE(SUM(ps.packages_size), 0) AS packages_size',
2020-11-24 15:15:51 +05:30
"COALESCE(SUM(ps.snippets_size), 0) AS #{SNIPPETS_SIZE_STAT_NAME}",
'COALESCE(SUM(ps.pipeline_artifacts_size), 0) AS pipeline_artifacts_size'
2019-09-30 21:07:59 +05:30
)
end
2020-07-28 23:09:34 +05:30
def attributes_from_personal_snippets
# Return if the type of namespace does not belong to a user
return {} unless namespace.type.nil?
from_personal_snippets.take.slice(SNIPPETS_SIZE_STAT_NAME)
end
def from_personal_snippets
PersonalSnippet
.joins('INNER JOIN snippet_statistics s ON s.snippet_id = snippets.id')
.where(author: namespace.owner_id)
.select("COALESCE(SUM(s.repository_size), 0) AS #{SNIPPETS_SIZE_STAT_NAME}")
end
2019-09-30 21:07:59 +05:30
end