diff --git a/app/models/account/data_transfer/active_storage_blob_record_set.rb b/app/models/account/data_transfer/active_storage_blob_record_set.rb index 5b9390710..10ee326ad 100644 --- a/app/models/account/data_transfer/active_storage_blob_record_set.rb +++ b/app/models/account/data_transfer/active_storage_blob_record_set.rb @@ -6,4 +6,17 @@ class Account::DataTransfer::ActiveStorageBlobRecordSet < Account::DataTransfer: attributes: ActiveStorage::Blob.column_names - %w[service_name] ) end + + private + def import_batch(files) + batch_data = files.map do |file| + data = load(file) + data.slice(*attributes).merge( + "account_id" => account.id, + "service_name" => ActiveStorage::Blob.service.name + ) + end + + model.insert_all!(batch_data) + end end