Commit 3f34a834

@@ -17,16 +17,7 @@ module My
     private
 
     def publish(image)
-      @bus.publish(:upload_avatar, create_message_from(image))
-    end
-
-    def create_message_from(image)
-      {
-        user_id: current_user.id,
-        file_path: move_to_temporary_storage(image),
-        original_filename: image.original_filename,
-        content_type: image.content_type,
-      }
+      ProcessAvatarJob.perform_later(current_user, move_to_temporary_storage(image))
     end
 
     def move_to_temporary_storage(image)

@@ -1,16 +0,0 @@
-class ProcessAvatar
-  def initialize(blob_storage)
-    @blob_storage = blob_storage
-  end
-
-  def handles?(event)
-    :upload_avatar == event
-  end
-
-  def handle(message)
-    user = User.find(message[:user_id])
-    user.avatar = Photo.create!
-    user.avatar.upload(message[:file_path], @blob_storage)
-    user.avatar.save!
-  end
-end

@@ -2,7 +2,6 @@ class ConfigureContainerCommand
   def configure(container)
     container.register(:configuration) { EnvironmentVariables.new }
     container.register(:message_handler) { |builder| builder.build(ProcessPhoto) }
-    container.register(:message_handler) { |builder| builder.build(ProcessAvatar) }
     container.register(:queue) { |c| Delayed::Job }
     container.register(:command_bus) { |c| c.build(CommandBus) }.as_singleton
     container.register(:exif_parser) { |builder| ExifParser.new }