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.tr('/', '_')) do |f|
      path, mime_type = copy_remote_file(generic_file.import_url, f)

      # reload the generic file once the data is copied since this is a long running task
      generic_file.reload

      # 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
    [uri.path, mime_type]
  end

  def job_user
    User.batchuser
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
sufia-models-6.7.0	app/jobs/import_url_job.rb
sufia-models-6.6.1	app/jobs/import_url_job.rb
sufia-models-6.6.0	app/jobs/import_url_job.rb
sufia-models-6.5.0	app/jobs/import_url_job.rb
sufia-models-6.4.0	app/jobs/import_url_job.rb
sufia-models-6.3.0	app/jobs/import_url_job.rb