mirror of
https://github.com/kemko/paperclip.git
synced 2026-01-04 01:15:41 +03:00
Merge pull request #18 from insales/remove_old_upload_worker
Remove old upload worker
This commit is contained in:
@@ -1,6 +1,7 @@
|
||||
module Paperclip
|
||||
module Storage
|
||||
autoload :Filesystem, 'paperclip/storage/filesystem'
|
||||
autoload :DelayedUpload, 'paperclip/storage/delayed_upload'
|
||||
autoload :Delayeds3, 'paperclip/storage/delayeds3'
|
||||
autoload :Cached, 'paperclip/storage/cached'
|
||||
end
|
||||
|
||||
@@ -1,5 +1,3 @@
|
||||
require_relative './delayed_upload'
|
||||
|
||||
module Paperclip
|
||||
module Storage
|
||||
# Saves file to `:cache` store, and run jobs to copy files to one ore more `:store` store.
|
||||
|
||||
@@ -5,8 +5,6 @@ rescue LoadError => e
|
||||
raise e
|
||||
end
|
||||
|
||||
require_relative './delayed_upload'
|
||||
|
||||
module Paperclip
|
||||
module Storage
|
||||
# Need to create boolean field synced_to_s3
|
||||
@@ -76,24 +74,6 @@ module Paperclip
|
||||
end
|
||||
end
|
||||
|
||||
# TODO: Remove legacy workers after migrating to DelayedUpload worker.
|
||||
class UploadWorker
|
||||
include ::Sidekiq::Worker
|
||||
sidekiq_options queue: :paperclip
|
||||
|
||||
def perform(class_name, name, id)
|
||||
DelayedUpload.new.perform(class_name, id, name, self.class::STORE_ID)
|
||||
end
|
||||
end
|
||||
|
||||
class WriteToS3Worker < UploadWorker
|
||||
STORE_ID = :s3
|
||||
end
|
||||
|
||||
class WriteToFogWorker < UploadWorker
|
||||
STORE_ID = :fog
|
||||
end
|
||||
|
||||
delegate :synced_to_s3_field, :synced_to_fog_field, to: :class
|
||||
|
||||
def initialize(*)
|
||||
|
||||
Reference in New Issue
Block a user