78 lines
1.9 KiB
Ruby
78 lines
1.9 KiB
Ruby
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 issues(project_identifier)
|
|
lazy_page_iterator(PER_PAGE) do |page|
|
|
api.get("/api/v3/projects/#{project_identifier}/issues?per_page=#{PER_PAGE}&page=#{page}").parsed
|
|
end
|
|
end
|
|
|
|
def issue_comments(project_identifier, issue_id)
|
|
lazy_page_iterator(PER_PAGE) do |page|
|
|
api.get("/api/v3/projects/#{project_identifier}/issues/#{issue_id}/notes?per_page=#{PER_PAGE}&page=#{page}").parsed
|
|
end
|
|
end
|
|
|
|
def project(id)
|
|
api.get("/api/v3/projects/#{id}").parsed
|
|
end
|
|
|
|
def projects
|
|
lazy_page_iterator(PER_PAGE) do |page|
|
|
api.get("/api/v3/projects?per_page=#{PER_PAGE}&page=#{page}").parsed
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
def lazy_page_iterator(per_page)
|
|
Enumerator.new do |y|
|
|
page = 1
|
|
loop do
|
|
items = yield(page)
|
|
items.each do |item|
|
|
y << item
|
|
end
|
|
break if items.empty? || items.size < per_page
|
|
page += 1
|
|
end
|
|
end
|
|
end
|
|
|
|
def config
|
|
Gitlab.config.omniauth.providers.find{|provider| provider.name == "gitlab"}
|
|
end
|
|
|
|
def gitlab_options
|
|
OmniAuth::Strategies::GitLab.default_options[:client_options].dup
|
|
end
|
|
end
|
|
end
|
|
end
|