Contents

class CreateFile
  def initialize(n)
    @n = n
  end

  def output_to_file
    path = "/tmp/transfer_test_#{@n.to_s}.txt"
    open(path, 'w') { |f| f.puts "file#{@n.to_s}" }
    path
  end

  def create
    path = output_to_file
    DRbQS::Transfer.enqueue(path)
    File.basename(path)
  end

  def create_compress
    path = output_to_file
    DRbQS::Transfer.compress_enqueue(path)
    File.basename(path)
  end
end

class CreateDirectory
  def initialize(n)
    @n = n
  end

  def output_to_directory
    path = "/tmp/transfer_test_#{@n.to_s}/"
    FileUtils.mkdir_p(path)
    open(File.join(path, 'tmp.txt'), 'w') { |f| f.puts "file#{@n.to_s}" }
    path
  end

  def create
    dir = output_to_directory
    DRbQS::Transfer.enqueue(dir)
    File.basename(dir)
  end

  def create_compress
    dir = output_to_directory
    DRbQS::Transfer.compress_enqueue(dir)
    File.basename(dir)
  end
end

class ReceiveFile
  def initialize(file_list)
    @file_list = file_list
  end

  def read_file
    ret = ''
    @file_list.path.each do |path|
      if File.directory?(path)
        raise "Receive directory, not file."
      end
      ret << path << "\t" << File.read(path).strip << "\n"
    end
    ret
  end

  def read_directory
    ret = ''
    @file_list.path.each do |dir|
      unless File.directory?(dir)
        raise "Receive file, not directory."
      end
      Dir.glob("#{dir}/**/*.txt").each do |path|
        ret << path << "\t" << File.read(path).strip << "\n"
      end
    end
    ret
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
drbqs-0.1.1	examples/transfer/file.rb
drbqs-0.1.0	examples/transfer/file.rb
drbqs-0.0.19	example/transfer/file.rb
drbqs-0.0.18	example/transfer/file.rb
drbqs-0.0.17	example/transfer/file.rb
drbqs-0.0.16	example/transfer/file.rb