Class: Aspera::Agent::Desktop

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

Overview

Client: Aspera for Desktop

Instance Method Summary collapse

Methods inherited from Base

#wait_for_completion

Constructor Details

#initialize(**base_options) ⇒ Desktop

Returns a new instance of Desktop.

Raises:



21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
 
# File 'lib/aspera/agent/desktop.rb', line 21

def initialize(**base_options)
  @application_id = SecureRandom.uuid
  @transfer_id = nil
  super
  raise Error, 'Using client requires a graphical environment' unless Environment.instance.graphical?
  method_index = 0
  begin
    # curl 'http://127.0.0.1:33024/' -X POST -H 'content-type: application/json' --data-raw '{"jsonrpc":"2.0","params":[],"id":999999,"method":"rpc.discover"}'
    # https://playground.open-rpc.org/?schemaUrl=http://127.0.0.1:33024
    @client_app_api = Aspera::JsonRpcClient.new(Aspera::Rest.new(base_url: aspera_client_api_url))
    client_info = @client_app_api.get_info
    Log.dump(:client_version, client_info)
    Log.log.info('Client was reached') if method_index > 0
  rescue Errno::ECONNREFUSED => e
    start_url = START_URIS[method_index]
    method_index += 1
    raise StandardError, "Unable to start #{Products::Desktop::APP_NAME} #{method_index} times" if start_url.nil?
    Log.log.warn{"#{Products::Desktop::APP_NAME} is not started (#{e}). Trying to start it ##{method_index}..."}
    Environment.instance.open_uri_graphical(start_url)
    sleep(SLEEP_SEC_BETWEEN_RETRY)
    retry
  end
end

Instance Method Details

#start_transfer(transfer_spec, token_regenerator: nil) ⇒ Object

:reek:UnusedParameters token_regenerator



46
47
48
49
50
51
52
53
54
 
# File 'lib/aspera/agent/desktop.rb', line 46

def start_transfer(transfer_spec, token_regenerator: nil)
  Transfer::Spec.fix_transferd_resume_policy(transfer_spec)
  @request_id = SecureRandom.uuid
  # if there is a token, we ask the client app to use well known ssh private keys
  # instead of asking password
  transfer_spec['authentication'] = 'token' if transfer_spec.key?('token')
  result = @client_app_api.start_transfer(app_id: @application_id, desktop_spec: {}, transfer_spec: transfer_spec)
  @transfer_id = result['uuid']
end

#wait_for_transfers_completion ⇒ Object 



56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
 
# File 'lib/aspera/agent/desktop.rb', line 56

def wait_for_transfers_completion
  started = false
  pre_calc = false
  begin
    loop do
      transfer = @client_app_api.get_transfer(app_id: @application_id, transfer_id: @transfer_id)
      case transfer['status']
      when 'initiating', 'queued'
        notify_progress(:sessions_init, info: transfer['status'])
      when 'running'
        if !started
          notify_progress(:session_start, session_id: @transfer_id)
          started = true
        end
        if !pre_calc && (transfer['bytes_expected'] != 0)
          notify_progress(:session_size, session_id: @transfer_id, info: transfer['bytes_expected'])
          pre_calc = true
        else
          notify_progress(:transfer, session_id: @transfer_id, info: transfer['bytes_written'])
        end
      when 'completed'
        notify_progress(:session_end, session_id: @transfer_id)
        notify_progress(:end)
        break
      when 'failed'
        notify_progress(:session_end, session_id: @transfer_id)
        notify_progress(:end)
        raise Transfer::Error, transfer['error_desc']
      when 'cancelled'
        notify_progress(:session_end, session_id: @transfer_id)
        notify_progress(:end)
        raise Transfer::Error, 'Transfer cancelled by user'
      else
        notify_progress(:session_end, session_id: @transfer_id)
        notify_progress(:end)
        raise Transfer::Error, "unknown status: #{transfer['status']}: #{transfer['error_desc']}"
      end
      sleep(1)
    end
  rescue StandardError => e
    return [e]
  end
  return [:success]
end