Contents

module CableReady
  module Updatable
    class ModelUpdatableCallbacks
      def initialize(operation, enabled_operations = %i[create update destroy])
        @operation = operation
        @enabled_operations = enabled_operations
      end

      def after_commit(model)
        return unless @enabled_operations.include?(@operation)

        send("broadcast_#{@operation}", model)
      end

      private

      def broadcast_create(model)
        ActionCable.server.broadcast(model.class, {})
      end
      alias_method :broadcast_destroy, :broadcast_create

      def broadcast_update(model)
        ActionCable.server.broadcast(model.class, {})
        ActionCable.server.broadcast(model.to_global_id, {})
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
cable_ready-5.0.0.pre7	app/models/concerns/cable_ready/updatable/model_updatable_callbacks.rb
cable_ready-5.0.0.pre6	app/models/concerns/cable_ready/updatable/model_updatable_callbacks.rb
cable_ready-5.0.0.pre5	app/models/concerns/cable_ready/updatable/model_updatable_callbacks.rb
cable_ready-5.0.0.pre4	app/models/concerns/cable_ready/updatable/model_updatable_callbacks.rb