Contents

require 'net/https'
require 'uri'
require 'tempfile'

class ImportUrlJob < ActiveFedoraIdBasedJob

  def queue_name
    :import_url
  end

  def run
    user = User.find_by_user_key(generic_file.depositor)

    Tempfile.open(id.gsub('/', '_')) do |f|
      path, mime_type = copy_remote_file(generic_file.import_url, f)
      # attach downloaded file to generic file stubbed out
      if Sufia::GenericFile::Actor.new(generic_file, user).create_content(f, path, 'content', mime_type)
        # add message to user for downloaded file
        message = "The file (#{generic_file.label}) was successfully imported."
        job_user.send_message(user, message, 'File Import')
      else
        job_user.send_message(user, generic_file.errors.full_messages.join(', '), 'File Import Error')
      end
    end
  end

  def copy_remote_file(import_url, f)
    f.binmode
    # download file from url
    uri = URI(generic_file.import_url)
    http = Net::HTTP.new(uri.host, uri.port)
    http.use_ssl = uri.scheme == "https"  # enable SSL/TLS
    http.verify_mode = OpenSSL::SSL::VERIFY_NONE
    mime_type = nil

    http.start do
      http.request_get(uri.request_uri) do |resp|
        mime_type = resp.content_type
        resp.read_body do |segment|
          f.write(segment)
        end
      end
    end

    f.rewind
    return uri.path, mime_type
  end

  def job_user
    User.batchuser
  end
end

Version data entries

4 entries across 4 versions & 2 rubygems

Version	Path
sufia-models-6.2.0	app/jobs/import_url_job.rb
sufia-models-6.1.0	app/jobs/import_url_job.rb
sufia-models-6.0.0	app/jobs/import_url_job.rb
sufia-6.0.0	sufia-models/app/jobs/import_url_job.rb