require 'net/http' require 'openssl' require 'json' require_relative 'gitlab_config' require_relative 'gitlab_logger' class GitlabNet def allowed?(cmd, repo, key, ref) project_name = repo.gsub("'", "") project_name = project_name.gsub(/\.git\Z/, "") project_name = project_name.gsub(/\A\//, "") key_id = key.gsub("key-", "") url = "#{host}/allowed?key_id=#{key_id}&action=#{cmd}&ref=#{ref}&project=#{project_name}" resp = get(url) !!(resp.code == '200' && resp.body == 'true') end def discover(key) key_id = key.gsub("key-", "") resp = get("#{host}/discover?key_id=#{key_id}") JSON.parse(resp.body) rescue nil end def check get("#{host}/check") end protected def config @config ||= GitlabConfig.new end def host "#{config.gitlab_url}/api/v3/internal" end def get(url) $logger.debug "Performing GET #{url}" url = URI.parse(url) http = Net::HTTP.new(url.host, url.port) if URI::HTTPS === url http.use_ssl = true http.cert_store = cert_store if config.http_settings['self_signed_cert'] http.verify_mode = OpenSSL::SSL::VERIFY_NONE end end request = Net::HTTP::Get.new(url.request_uri) if config.http_settings['user'] && config.http_settings['password'] request.basic_auth config.http_settings['user'], config.http_settings['password'] end http.start {|http| http.request(request) }.tap do |resp| if resp.code == "200" $logger.debug { "Received response #{resp.code} => <#{resp.body}>." } else $logger.error { "API call failed: #{resp.code} => <#{resp.body}>." } end end end def cert_store @cert_store ||= OpenSSL::X509::Store.new.tap { |store| store.set_default_paths if ca_file = config.http_settings['ca_file'] store.add_file(ca_file) end if ca_path = config.http_settings['ca_path'] store.add_path(ca_path) end } end end