Contents

module PusherClient
  class Subscription
    attr_accessor :global, :subscribed
    attr_reader :channel, :user_data, :callbacks, :global_callbacks

    def initialize(channel_name, user_data)
      @channel = channel_name
      @user_data = user_data
      @global = false
      @callbacks = {}
      @global_callbacks = {}
      @subscribed = false
    end

    def bind(event_name, &callback)
      @callbacks[event_name] = callbacks[event_name] || []
      @callbacks[event_name] << callback
      return self
    end

    def dispatch_with_all(event_name, data)
      dispatch(event_name, data)
      dispatch_global_callbacks(event_name, data)
    end

    def dispatch(event_name, data)
      PusherClient.logger.debug "Dispatching callbacks for #{event_name}"
      if @callbacks[event_name]
        @callbacks[event_name].each do |callback|
          callback.call(data)
        end
      else
        PusherClient.logger.debug "No callbacks to dispatch for #{event_name}"
      end
    end

    def dispatch_global_callbacks(event_name, data)
      if @global_callbacks[event_name]
        PusherClient.logger.debug "Dispatching global callbacks for #{event_name}"
        @global_callbacks[event_name].each do |callback|
          callback.call(data)
        end
      else
        PusherClient.logger.debug "No global callbacks to dispatch for #{event_name}"
      end
    end

    def acknowledge_subscription(data)
      @subscribed = true
    end

  end

end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
pusher-client-nc-0.2.1	lib/pusher-client/subscription.rb