move photo extraction to a class
style improvements new line applied changes applied changes
This commit is contained in:
parent
59fb227d95
commit
2a2b604a60
2 changed files with 45 additions and 28 deletions
|
|
@ -324,34 +324,7 @@ class User < ActiveRecord::Base
|
||||||
end
|
end
|
||||||
|
|
||||||
def perform_export_photos!
|
def perform_export_photos!
|
||||||
temp_zip = Tempfile.new([username, '_photos.zip'])
|
PhotoExporter.new(self).perform
|
||||||
begin
|
|
||||||
Zip::OutputStream.open(temp_zip.path) do |zos|
|
|
||||||
photos.each do |photo|
|
|
||||||
begin
|
|
||||||
photo_file = photo.unprocessed_image.file
|
|
||||||
if photo_file
|
|
||||||
photo_data = photo_file.read
|
|
||||||
zos.put_next_entry(photo.remote_photo_name)
|
|
||||||
zos.print(photo_data)
|
|
||||||
else
|
|
||||||
logger.info "Export photos error: No file for #{photo.remote_photo_name} not found"
|
|
||||||
end
|
|
||||||
rescue Errno::ENOENT
|
|
||||||
logger.info "Export photos error: #{photo.unprocessed_image.file.path} not found"
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
ensure
|
|
||||||
temp_zip.close
|
|
||||||
end
|
|
||||||
|
|
||||||
begin
|
|
||||||
update exported_photos_file: temp_zip, exported_photos_at: Time.zone.now if temp_zip.present?
|
|
||||||
ensure
|
|
||||||
restore_attributes if invalid? || temp_zip.present?
|
|
||||||
update exporting_photos: false
|
|
||||||
end
|
|
||||||
end
|
end
|
||||||
|
|
||||||
######### Mailer #######################
|
######### Mailer #######################
|
||||||
|
|
|
||||||
44
lib/photo_exporter.rb
Normal file
44
lib/photo_exporter.rb
Normal file
|
|
@ -0,0 +1,44 @@
|
||||||
|
class PhotoExporter
|
||||||
|
attr_reader :user
|
||||||
|
|
||||||
|
def initialize(user)
|
||||||
|
@user = user
|
||||||
|
end
|
||||||
|
|
||||||
|
def perform
|
||||||
|
temp_zip = Tempfile.new([user.username, "_photos.zip"])
|
||||||
|
begin
|
||||||
|
Zip::OutputStream.open(temp_zip.path) do |zip_output_stream|
|
||||||
|
user.photos.each do |photo|
|
||||||
|
export_photo(zip_output_stream, photo)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
ensure
|
||||||
|
temp_zip.close
|
||||||
|
end
|
||||||
|
|
||||||
|
update_exported_photos_at(temp_zip)
|
||||||
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
|
def export_photo(zip_output_stream, photo)
|
||||||
|
photo_file = photo.unprocessed_image.file
|
||||||
|
if photo_file
|
||||||
|
photo_data = photo_file.read
|
||||||
|
zip_output_stream.put_next_entry(photo.remote_photo_name)
|
||||||
|
zip_output_stream.print(photo_data)
|
||||||
|
else
|
||||||
|
user.logger.info "Export photos error: No file for #{photo.remote_photo_name} not found"
|
||||||
|
end
|
||||||
|
rescue Errno::ENOENT
|
||||||
|
user.logger.info "Export photos error: #{photo.unprocessed_image.file.path} not found"
|
||||||
|
end
|
||||||
|
|
||||||
|
def update_exported_photos_at(temp_zip)
|
||||||
|
user.update exported_photos_file: temp_zip, exported_photos_at: Time.zone.now
|
||||||
|
ensure
|
||||||
|
user.restore_attributes if user.invalid?
|
||||||
|
user.update exporting_photos: false
|
||||||
|
end
|
||||||
|
end
|
||||||
Loading…
Reference in a new issue