Sha256: 8fcb0d84201d7567c7b582cbe923d36296c98cfb55b9bd73380c3888a9e6b620
Contents?: true
Size: 1.52 KB
Versions: 51
Compression:
Stored size: 1.52 KB
Contents
# frozen_string_literal: true
module SdrClient
# The connection to the server
class Connection
include Dry::Monads[:result]
# @param [Integer] read_timeout the value in seconds to set the read timeout
def initialize(url:, token: Credentials.read, read_timeout: default_timeout, timeout: default_timeout)
@url = url
@token = token
@request_options = { read_timeout: read_timeout, timeout: timeout }
end
def connection
@connection ||= Faraday.new(url: url, request: request_options) do |conn|
conn.request :authorization, :Bearer, token
conn.adapter :net_http
end
end
# This is only available to certain blessed accounts (argo) as it gives the
# token that allows you to act as any other user. Thus the caller must authenticate
# the user (e.g. using Shibboleth) before calling this method with their email address.
# @param [String] the email address of the person to proxy to.
# @return [Result] the token for the account
def proxy(to)
response = connection.post("/v1/auth/proxy?to=#{to}")
case response.status
when 200
Success(response.body)
else
Failure("Status: #{response.status}\n#{response.body}")
end
end
delegate :put, :post, :get, to: :connection
private
attr_reader :url, :token, :request_options
# NOTE: This is the number of seconds it roughly takes for H2 to
# successfully shunt ~10GB files over to SDR API
def default_timeout
900
end
end
end
Version data entries
51 entries across 51 versions & 1 rubygems