Detect orphaned repositories and namespaces in any storage

2 files changed, 87 insertions, 0 deletions

diff --git a/lib/system_check/orphans/namespace_check.rb b/lib/system_check/orphans/namespace_check.rb
new file mode 100644
index 00000000000..1963cbfc985
--- /dev/null
+++ b/lib/system_check/orphans/namespace_check.rb
@@ -0,0 +1,37 @@
+module SystemCheck
+  module Orphans
+    class NamespaceCheck < SystemCheck::BaseCheck
+      set_name 'Orphaned namespaces:'
+
+      def multi_check
+        Gitlab.config.repositories.storages.each do |name, repository_storage|
+          $stdout.puts
+          $stdout.puts "* Storage: #{name} (#{repository_storage['path']})".color(:yellow)
+          toplevel_namespace_dirs = Dir.glob(File.join(repository_storage['path'], '*')).map{|p| File.basename(p)}
+
+          orphans = (toplevel_namespace_dirs - existing_namespaces)
+          if orphans.empty?
+            $stdout.puts "* No orphaned namespaces for #{name} storage".color(:green)
+            next
+          end
+
+          orphans.each do |orphan|
+            $stdout.puts " - #{orphan}".color(:red)
+          end
+        end
+
+        clear_namespaces! # releases memory when check finishes
+      end
+
+      private
+
+      def existing_namespaces
+        @namespaces ||= Namespace.all.pluck(:path)
+      end
+
+      def clear_namespaces!
+        @namespaces = nil
+      end
+    end
+  end
+end
diff --git a/lib/system_check/orphans/repository_check.rb b/lib/system_check/orphans/repository_check.rb
new file mode 100644
index 00000000000..1de6bec165b
--- /dev/null
+++ b/lib/system_check/orphans/repository_check.rb
@@ -0,0 +1,50 @@
+module SystemCheck
+  module Orphans
+    class RepositoryCheck < SystemCheck::BaseCheck
+      set_name 'Orphaned repositories:'
+
+      def multi_check
+        Gitlab.config.repositories.storages.each do |name, repository_storage|
+          $stdout.puts
+          $stdout.puts "* Storage: #{name} (#{repository_storage['path']})".color(:yellow)
+
+          repositories = toplevel_namespace_dirs(repository_storage['path']).map do |path|
+            namespace = File.basename(path)
+            Dir.glob(File.join(path, '*')).map {|repo| "#{namespace}/#{File.basename(repo)}"}
+          end.try(:flatten!)
+
+          orphans = (repositories - list_repositories(name))
+          if orphans.empty?
+            $stdout.puts "* No orphaned repositories for #{name} storage".color(:green)
+            next
+          end
+
+          orphans.each do |orphan|
+            $stdout.puts " - #{orphan}".color(:red)
+          end
+        end
+      end
+
+      private
+
+      def list_repositories(storage_name)
+        sql = "
+          SELECT
+            CONCAT(n.path, '/', p.path, '.git') repo,
+            CONCAT(n.path, '/', p.path, '.wiki.git') wiki
+          FROM projects p
+            JOIN namespaces n
+              ON (p.namespace_id = n.id)
+          WHERE (p.repository_storage LIKE ?)
+        "
+
+        query = ActiveRecord::Base.send(:sanitize_sql_array, [sql, storage_name])
+        ActiveRecord::Base.connection.select_all(query).rows.try(:flatten!)
+      end
+
+      def toplevel_namespace_dirs(storage_path)
+        Dir.glob(File.join(storage_path, '*'))
+      end
+    end
+  end
+end