Welcome to mirror list, hosted at ThFree Co, Russian Federation.

client.rb « gitlab_import « gitlab « lib - gitlab.com/gitlab-org/gitlab-foss.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
blob: 86474159f8b3ef9fbcbf0dbc2d3c45e5863a1d03 (plain)
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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
# frozen_string_literal: true

module Gitlab
  module GitlabImport
    class Client
      attr_reader :client, :api

      PER_PAGE = 100

      def initialize(access_token)
        @client = ::OAuth2::Client.new(
          config.app_id,
          config.app_secret,
          gitlab_options
        )

        if access_token
          @api = OAuth2::AccessToken.from_hash(@client, access_token: access_token)
        end
      end

      def authorize_url(redirect_uri)
        client.auth_code.authorize_url({
          redirect_uri: redirect_uri,
          scope: "api"
        })
      end

      def get_token(code, redirect_uri)
        client.auth_code.get_token(code, redirect_uri: redirect_uri).token
      end

      def user
        api.get("/api/v4/user").parsed
      end

      def issues(project_identifier, **kwargs)
        lazy_page_iterator(**kwargs) do |page, per_page|
          api.get("/api/v4/projects/#{project_identifier}/issues?per_page=#{per_page}&page=#{page}").parsed
        end
      end

      def issue_comments(project_identifier, issue_id, **kwargs)
        lazy_page_iterator(**kwargs) do |page, per_page|
          api.get("/api/v4/projects/#{project_identifier}/issues/#{issue_id}/notes?per_page=#{per_page}&page=#{page}").parsed
        end
      end

      def project(id)
        api.get("/api/v4/projects/#{id}").parsed
      end

      def projects(**kwargs)
        lazy_page_iterator(**kwargs) do |page, per_page|
          api.get("/api/v4/projects?per_page=#{per_page}&page=#{page}&simple=true&membership=true").parsed
        end
      end

      private

      def lazy_page_iterator(starting_page: 1, page_limit: nil, per_page: PER_PAGE)
        Enumerator.new do |y|
          page = starting_page
          page_limit = (starting_page - 1) + page_limit if page_limit

          loop do
            items = yield(page, per_page)

            items.each do |item|
              y << item
            end

            break if items.empty? || items.size < per_page || (page_limit && page >= page_limit)

            page += 1
          end
        end
      end

      def config
        Gitlab::Auth::OAuth::Provider.config_for('gitlab')
      end

      def gitlab_options
        OmniAuth::Strategies::GitLab.default_options[:client_options].to_h.symbolize_keys
      end
    end
  end
end