Class: Aspera::Agent::Httpgw

Inherits:
Base
  • Object
show all
Defined in:
lib/aspera/agent/httpgw.rb

Instance Method Summary collapse

Methods inherited from Base

agent_list, factory_create, #wait_for_completion

Instance Method Details

#start_transfer(transfer_spec, token_regenerator: nil) ⇒ Object

start FASP transfer based on transfer spec (hash table) note that it is asynchronous HTTP download only supports file list



15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/aspera/agent/httpgw.rb', line 15

def start_transfer(transfer_spec, token_regenerator: nil)
  raise 'GW URL must be set' if @gw_api.nil?
  Aspera.assert_type(transfer_spec['paths'], Array){'paths'}
  Aspera.assert_type(transfer_spec['token'], String){'only token based transfer is supported in GW'}
  Log.log.debug{Log.dump(:user_spec, transfer_spec)}
  transfer_spec['authentication'] ||= 'token'
  case transfer_spec['direction']
  when Transfer::Spec::DIRECTION_SEND
    @gw_api.upload(transfer_spec)
  when Transfer::Spec::DIRECTION_RECEIVE
    @gw_api.download(transfer_spec)
  else Aspera.error_unexpected_value(transfer_spec['direction']){'direction'}
  end
end

#wait_for_transfers_completion ⇒ Object

wait for completion of all jobs started

Returns:

  • list of :success or error message



32
33
34
35
 
# File 'lib/aspera/agent/httpgw.rb', line 32

def wait_for_transfers_completion
  # well ... transfer was done in "start"
  return [:success]
end