Class: Aspera::CosNode

Inherits:
Rest
  • Object
show all
Defined in:
lib/aspera/cos_node.rb

Instance Attribute Summary collapse

Attributes inherited from Rest

#params

Instance Method Summary collapse

Methods inherited from Rest

basic_creds, build_uri, #call, #cancel, #create, debug=, #delete, insecure, insecure=, #oauth_token, #read, #update, user_agent, user_agent=

Constructor Details

#initialize(bucket_name, storage_endpoint, instance_id, api_key, auth_url = 'https://iam.cloud.ibm.com/identity') ⇒ CosNode 



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
 
# File 'lib/aspera/cos_node.rb', line 8

def initialize(bucket_name,storage_endpoint,instance_id,api_key,auth_url='https://iam.cloud.ibm.com/identity')
  s3_api=Aspera::Rest.new({
    :base_url => storage_endpoint,
    :not_auth_codes => ['401','403'],
    :headers  => {'ibm-service-instance-id' => instance_id},
    :auth     => {
    :type       => :oauth2,
    :base_url   => auth_url,
    :grant      => :ibm_apikey,
    :api_key    => api_key
    }})
  # read FASP connection information for bucket
  xml_result_text=s3_api.call({:operation=>'GET',:subpath=>bucket_name,:headers=>{'Accept'=>'application/xml'},:url_params=>{'faspConnectionInfo'=>nil}})[:http].body
  ats_info=XmlSimple.xml_in(xml_result_text, {'ForceArray' => false})
  Aspera::Log.dump('ats_info',ats_info)
  # get delegated token
  delegated_oauth=Oauth.new({
    :type       => :oauth2,
    :base_url   => auth_url,
    :grant      => :delegated_refresh,
    :api_key    => api_key,
    :token_field=> 'delegated_refresh_token'
  })
  # to be placed in rest call header and in transfer tags
  aspera_storage_credentials={
    'type'  => 'token',
    'token' => {'delegated_refresh_token'=>delegated_oauth.get_authorization().gsub(/^Bearer /,'')}
  }
  # transfer spec addition
  @add_ts={'tags'=>{'aspera'=>{'node'=>{'storage_credentials'=>aspera_storage_credentials}}}}
  # set a general addon to transfer spec
  # here we choose to use the add_request_param
  #self.transfer.option_transfer_spec_deep_merge(@add_ts)
  super({
    :base_url => ats_info['ATSEndpoint'],
    :headers  => {'X-Aspera-Storage-Credentials'=>JSON.generate(aspera_storage_credentials)},
    :auth     => {
    :type     => :basic,
    :username => ats_info['AccessKey']['Id'],
    :password => ats_info['AccessKey']['Secret']}})
end

Instance Attribute Details

#add_ts ⇒ Object (readonly)

Returns the value of attribute add_ts.



7
8
9
 
# File 'lib/aspera/cos_node.rb', line 7

def add_ts
  @add_ts
end