Class: Punchblock::Client

Inherits:

Object

• Object
• Punchblock::Client

show all

Extended by:

ActiveSupport::Autoload

Includes:

HasGuardedHandlers

Defined in:

lib/punchblock/client.rb,
lib/punchblock/client/component_registry.rb

Defined Under Namespace

Classes: ComponentRegistry

Instance Attribute Summary (collapse)

• - (Object) component_registry readonly

  Returns the value of attribute component_registry.

• - (Object) connection readonly

  Returns the value of attribute connection.

• - (Object) event_queue readonly

  Returns the value of attribute event_queue.

Instance Method Summary (collapse)

• - (Object) execute_command(command, options = {})
• - (Object) find_component_by_id(component_id)
• - (Object) handle_event(event)
• - (Client) initialize(options = {}) constructor

  A new instance of Client.

• - (Object) register_component(component)
• - (Object) register_event_handler(*guards, &block)
• - (Object) register_initial_handlers

18
19
20
21
22
23
24
25

# File 'lib/punchblock/client.rb', line 18

def initialize(options = {})
  @event_queue = Queue.new
  @connection = options[:connection]
  @connection.event_handler = lambda { |event| self.handle_event event } if @connection
  register_initial_handlers
  @component_registry = ComponentRegistry.new
  @write_timeout = options[:write_timeout] || 3
end

11
12
13

# File 'lib/punchblock/client.rb', line 11

def component_registry
  @component_registry
end

11
12
13

# File 'lib/punchblock/client.rb', line 11

def connection
  @connection
end

11
12
13

# File 'lib/punchblock/client.rb', line 11

def event_queue
  @event_queue
end

54
55
56
57
58
59
60
61
62
63
64

# File 'lib/punchblock/client.rb', line 54

def execute_command(command, options = {})
  async = options.has_key?(:async) ? options.delete(:async) : true
  command.client = self
  if command.respond_to?(:register_handler)
    command.register_handler :internal do |event|
      trigger_handler :event, event
    end
  end
  connection.write command, options
  command.response(@write_timeout).tap { |result| raise result if result.is_a? Exception } unless async
end

50
51
52

# File 'lib/punchblock/client.rb', line 50

def find_component_by_id(component_id)
  component_registry.find_by_id component_id
end

27
28
29
30
31
32
33
34

# File 'lib/punchblock/client.rb', line 27

def handle_event(event)
  event.client = self
  if event.source
    event.source.add_event event
  else
    trigger_handler :event, event
  end
end

46
47
48

# File 'lib/punchblock/client.rb', line 46

def register_component(component)
  component_registry << component
end

36
37
38

# File 'lib/punchblock/client.rb', line 36

def register_event_handler(*guards, &block)
  register_handler :event, *guards, &block
end

40
41
42
43
44

# File 'lib/punchblock/client.rb', line 40

def register_initial_handlers
  register_handler_with_priority :event, -10 do |event|
    event_queue.push event
  end
end