qa/qa/runtime/api/repository_storage_moves.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

# frozen_string_literal: true

module QA
  module Runtime
    module API
      module RepositoryStorageMoves
        extend self
        extend Support::Api

        RepositoryStorageMovesError = Class.new(RuntimeError)

        def has_status?(project, status, destination_storage = Env.additional_repository_storage)
          find_any do |move|
            next unless move[:project][:path_with_namespace] == project.path_with_namespace

            QA::Runtime::Logger.debug("Move data: #{move}")

            move[:state] == status &&
            move[:destination_storage_name] == destination_storage
          end
        end

        def find_any
          Logger.debug('Getting repository storage moves')

          Support::Waiter.wait_until do
            with_paginated_response_body(Request.new(api_client, '/project_repository_storage_moves', per_page: '100').url) do |page|
              break true if page.any? { |item| yield item }
            end
          end
        end

        private

        def api_client
          @api_client ||= Client.as_admin
        end
      end
    end
  end
end