require 'fog/openstack' class PjsMigrationJob < ApplicationJob queue_as :pj_migration_jobs def perform(blob_id) 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 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