88 lines
2.2 KiB
Ruby
88 lines
2.2 KiB
Ruby
require 'fog/openstack'
|
|
|
|
class ActiveStorage::DownloadableFile
|
|
def self.create_list_from_dossiers(dossiers:, user_profile:, export_template: nil)
|
|
pj_service = PiecesJustificativesService.new(user_profile:, export_template:)
|
|
|
|
files = []
|
|
DossierPreloader.new(dossiers).in_batches_with_block do |loaded_dossiers|
|
|
files += pj_service.generate_dossiers_export(loaded_dossiers) + pj_service.liste_documents(loaded_dossiers)
|
|
end
|
|
|
|
files
|
|
end
|
|
|
|
def self.cleanup_list_from_dossier(files)
|
|
if Rails.application.config.active_storage.service != :openstack
|
|
return files
|
|
end
|
|
|
|
files.filter do |file, _filename|
|
|
if file.is_a?(ActiveStorage::FakeAttachment)
|
|
true
|
|
else
|
|
service = file.blob.service
|
|
begin
|
|
client.head_object(service.container, file.blob.key)
|
|
true
|
|
rescue Fog::OpenStack::Storage::NotFound
|
|
false
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
def self.client
|
|
credentials = Rails.application.config.active_storage
|
|
.service_configurations['openstack']['credentials']
|
|
|
|
Fog::OpenStack::Storage.new(credentials)
|
|
end
|
|
|
|
def self.bill_and_path(bill)
|
|
[
|
|
bill,
|
|
"bills/#{self.timestamped_filename(bill)}"
|
|
]
|
|
end
|
|
|
|
def self.pj_and_path(dossier_id, pj)
|
|
[
|
|
pj,
|
|
"dossier-#{dossier_id}/#{self.timestamped_filename(pj)}"
|
|
]
|
|
end
|
|
|
|
def self.timestamped_filename(attachment)
|
|
# we pad the original file name with a timestamp
|
|
# and a short id in order to help identify multiple versions and avoid name collisions
|
|
folder = self.folder(attachment)
|
|
extension = File.extname(attachment.filename.to_s)
|
|
basename = File.basename(attachment.filename.to_s, extension)
|
|
timestamp = attachment.created_at.strftime("%d-%m-%Y-%H-%M")
|
|
id = attachment.id % 10000
|
|
|
|
[folder, "#{basename}-#{timestamp}-#{id}#{extension}"].join
|
|
end
|
|
|
|
def self.folder(attachment)
|
|
if attachment.name == 'pdf_export_for_instructeur'
|
|
return ''
|
|
end
|
|
|
|
case attachment.record_type
|
|
when 'Dossier'
|
|
'dossier/'
|
|
when 'DossierOperationLog', 'BillSignature'
|
|
'horodatage/'
|
|
when 'Commentaire'
|
|
'messagerie/'
|
|
when 'Avis'
|
|
'avis/'
|
|
else
|
|
'pieces_justificatives/'
|
|
end
|
|
end
|
|
end
|