Method: Taps::Cli#clientresumexfer

Defined in:

lib/taps/cli.rb

#clientresumexfer(method, opts) ⇒ Object

# File 'lib/taps/cli.rb', line 173

def clientresumexfer(method, opts)
  session = ::OkJson.decode(File.read(opts.delete(:resume_filename)))
  session.symbolize_recursively!

  database_url = opts.delete(:database_url)
  remote_url = opts.delete(:remote_url) || session.delete(:remote_url)

  Taps::Config.verify_database_url(database_url)

  require 'taps/operation'

  newsession = session.merge(default_chunksize: opts[:default_chunksize],
                             disable_compression: opts[:disable_compression],
                             resume: true)

  Taps::Operation.factory(method, database_url, remote_url, newsession).run
end