class Radar::Api::TransactionImporter::Processor

Public Instance Methods

process_authenticate(seqid, iprot, oprot) click to toggle source
# File gen/radar/api/transaction_importer.rb, line 74
def process_authenticate(seqid, iprot, oprot)
  args = read_args(iprot, Authenticate_args)
  result = Authenticate_result.new()
  begin
    result.success = @handler.authenticate(args.username, args.password, args.user)
  rescue ::Radar::Api::ApplicationError => app_error
    result.app_error = app_error
  rescue ::Radar::Api::AuthenticationError => auth_error
    result.auth_error = auth_error
  rescue ::Radar::Api::SystemUnavailableError => system_unavailable
    result.system_unavailable = system_unavailable
  end
  write_result(result, oprot, 'authenticate', seqid)
end
process_fetch(seqid, iprot, oprot) click to toggle source
# File gen/radar/api/transaction_importer.rb, line 89
def process_fetch(seqid, iprot, oprot)
  args = read_args(iprot, Fetch_args)
  result = Fetch_result.new()
  begin
    @handler.fetch(args.username, args.password, args.user, args.last_transaction_date)
  rescue ::Radar::Api::ApplicationError => app_error
    result.app_error = app_error
  rescue ::Radar::Api::AuthenticationError => auth_error
    result.auth_error = auth_error
  rescue ::Radar::Api::SystemUnavailableError => system_unavailable
    result.system_unavailable = system_unavailable
  end
  write_result(result, oprot, 'fetch', seqid)
end
process_fetch_portfolio(seqid, iprot, oprot) click to toggle source
# File gen/radar/api/transaction_importer.rb, line 104
def process_fetch_portfolio(seqid, iprot, oprot)
  args = read_args(iprot, Fetch_portfolio_args)
  result = Fetch_portfolio_result.new()
  begin
    result.success = @handler.fetch_portfolio(args.username, args.password, args.date)
  rescue ::Radar::Api::ApplicationError => app_error
    result.app_error = app_error
  rescue ::Radar::Api::AuthenticationError => auth_error
    result.auth_error = auth_error
  rescue ::Radar::Api::SystemUnavailableError => system_unavailable
    result.system_unavailable = system_unavailable
  end
  write_result(result, oprot, 'fetch_portfolio', seqid)
end