Contents

require_relative './live_events/base_handler.rb'
require_relative './live_events/process_event_job.rb'

module CanvasSync
  module LiveEvents

    @@registered_handlers = []

    class << self
      def listen(event_types = nil, &blk)
        if event_types != nil
          blk = wrap_method(blk) do |inner, event|
            meta = event[:metadata]
            payload = event[:payload]

            if event_types.include?(meta[:event_name])
              inner.call(*args)
            end
          end
        end

        @@registered_handlers << blk
      end

      def registered_handlers
        @@registered_handlers
      end

      private

      def wrap_method(inner, &outer)
        ->(*args) {
          outer.call(inner, *args)
        }
      end
    end
  end
end

Version data entries

25 entries across 25 versions & 1 rubygems

Version	Path
canvas_sync-0.22.9	lib/canvas_sync/live_events.rb
canvas_sync-0.22.8	lib/canvas_sync/live_events.rb
canvas_sync-0.22.6	lib/canvas_sync/live_events.rb
canvas_sync-0.22.5	lib/canvas_sync/live_events.rb
canvas_sync-0.22.4	lib/canvas_sync/live_events.rb
canvas_sync-0.22.3	lib/canvas_sync/live_events.rb
canvas_sync-0.22.2	lib/canvas_sync/live_events.rb
canvas_sync-0.22.1	lib/canvas_sync/live_events.rb
canvas_sync-0.22.0	lib/canvas_sync/live_events.rb
canvas_sync-0.22.0.beta8	lib/canvas_sync/live_events.rb
canvas_sync-0.22.0.beta7	lib/canvas_sync/live_events.rb
canvas_sync-0.22.0.beta6	lib/canvas_sync/live_events.rb
canvas_sync-0.22.0.beta5	lib/canvas_sync/live_events.rb
canvas_sync-0.22.0.beta4	lib/canvas_sync/live_events.rb
canvas_sync-0.22.0.beta3	lib/canvas_sync/live_events.rb
canvas_sync-0.22.0.beta2	lib/canvas_sync/live_events.rb
canvas_sync-0.22.0.beta1	lib/canvas_sync/live_events.rb
canvas_sync-0.21.1	lib/canvas_sync/live_events.rb
canvas_sync-0.21.1.beta1	lib/canvas_sync/live_events.rb
canvas_sync-0.21.0	lib/canvas_sync/live_events.rb