demarches-normaliennes/app/jobs/pjs_migration_job.rb

44 lines
1.1 KiB
Ruby
Raw Normal View History

require 'fog/openstack'
class PjsMigrationJob < ApplicationJob
queue_as :pj_migration_jobs
def perform(blob_id)
2023-06-26 21:32:07 +02:00
blob = ActiveStorage::Blob.find(blob_id)
return if already_moved?(blob)
service = blob.service
container = service.container
old_key = blob.key
new_key = "#{blob.created_at.strftime('%Y/%m/%d')}/#{old_key[0..1]}/#{old_key}"
excon_response = client.copy_object(container,
old_key,
container,
new_key,
{ "Content-Type" => blob.content_type })
if excon_response.status == 201
blob.update_columns(key: new_key)
client.delete_object(container, old_key)
end
rescue Fog::OpenStack::Storage::NotFound
blob.attachments.destroy_all
end
def already_moved?(blob)
blob.key.include?('/')
end
private
def client
@client ||= begin
credentials = Rails.application.config.active_storage
.service_configurations['openstack']['credentials']
Fog::OpenStack::Storage.new(credentials)
end
end
end