Sha256: 456908d711026c061150604920c3602fd3217a44e9d710033b7e947f9378dc84

Contents?: true

Size: 1.21 KB

Versions: 1

Compression:

Stored size: 1.21 KB

Contents

require 'open-uri'

module BagIt
  module Fetch
    def fetch_txt_file
      File.join @bag_dir, 'fetch.txt'
    end

    def add_remote_file(url, path, size, sha1, md5)
      open(fetch_txt_file, 'a') { |io| io.puts "#{url} #{size || '-'} #{path}" }
      open(manifest_file('sha1'), 'a') { |io| io.puts "#{sha1} #{File.join 'data', path}" }
      open(manifest_file('md5'), 'a') { |io| io.puts "#{md5} #{File.join 'data', path}" }
    end

    # feth all remote files
    def fetch!
      open(fetch_txt_file) do |io|
        io.readlines.each do |line|
          (url, _length, path) = line.chomp.split(/\s+/, 3)

          add_file(path) do |file_io|
            file_io.write open(url)
          end
        end
      end

      rename_old_fetch_txt(fetch_txt_file)
      move_current_fetch_txt(fetch_txt_file)
    end

    def rename_old_fetch_txt(fetch_txt_file)
      Dir["#{fetch_txt_file}.?*"].sort.reverse.each do |f|
        if f =~ /fetch.txt.(\d+)$/
          new_f = File.join File.dirname(f), "fetch.txt.#{Regexp.last_match(1).to_i + 1}"
          FileUtils.mv f, new_f
        end
      end
    end

    def move_current_fetch_txt(fetch_txt_file)
      FileUtils.mv fetch_txt_file, "#{fetch_txt_file}.0"
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
bagit-0.4.3 lib/bagit/fetch.rb