Sha256: ce5e5a1735cef1616ac836fec12de5e8978f7f205a6a050df3bcdbf718a36bb8
Contents?: true
Size: 1.36 KB
Versions: 8
Compression:
Stored size: 1.36 KB
Contents
class IngestLocalFileJob
attr_accessor :directory, :filename, :user_key, :generic_file_id
def queue_name
:ingest
end
def initialize(generic_file_id, directory, filename, user_key)
self.generic_file_id = generic_file_id
self.directory = directory
self.filename = filename
self.user_key = user_key
end
#TODO this should use Actor#create_content
def run
user = User.find_by_user_key(user_key)
raise "Unable to find user for #{user_key}" unless user
generic_file = GenericFile.find(generic_file_id)
path = File.join(directory, filename)
actor = Sufia::GenericFile::Actor.new(generic_file, user)
if actor.create_content(File.open(path), filename, 'content', mime_type(filename))
FileUtils.rm(path)
Sufia.queue.push(ContentDepositEventJob.new(generic_file.id, user_key))
message = "The file (#{File.basename(filename)}) was successfully deposited."
subject = 'Local file ingest'
else
message = "There was a problem depositing #{File.basename(filename)}. Please contact a system admin."
subject = 'Local file ingest error'
end
job_user.send_message(user, message, subject)
end
def job_user
User.batchuser
end
def mime_type(file_name)
mime_types = MIME::Types.of(file_name)
mime_types.empty? ? "application/octet-stream" : mime_types.first.content_type
end
end
Version data entries
8 entries across 8 versions & 2 rubygems