Class: Pubnub::Event

Inherits:

Object

• Object
• Pubnub::Event

show all

Defined in:

lib/pubnub/event.rb

Overview

Instance Attribute Summary (collapse)

• - (Object) callback readonly

  Returns the value of attribute callback.

• - (Object) channel (also: #channels) readonly

  Returns the value of attribute channel.

• - (Object) error_callback readonly

  Returns the value of attribute error_callback.

• - (Object) group readonly

  Returns the value of attribute group.

• - (Object) idle_timeout readonly

  Returns the value of attribute idle_timeout.

• - (Object) open_timeout readonly

  Returns the value of attribute open_timeout.

• - (Object) origin readonly

  Returns the value of attribute origin.

• - (Object) presence_callback readonly

  Returns the value of attribute presence_callback.

• - (Object) read_timeout readonly

  Returns the value of attribute read_timeout.

Instance Method Summary (collapse)

• - (Boolean) finalized?
• - (Object) fire
• - (Event) initialize(options, app) constructor

  A new instance of Event.

• - (Boolean) sync?
• - (Object) uri

12
13
14
15
16
17
18
19
20

# File 'lib/pubnub/event.rb', line 12

def initialize(options, app)
  @app = app
  create_variables_from_options(app.env.merge(options))
  @origin = @app.current_origin
  format_channels
  format_group
  set_timestamp
  Pubnub.logger.debug('Pubnub::Event') { "Initialized #{self.class}" }
end

6
7
8

# File 'lib/pubnub/event.rb', line 6

def callback
  @callback
end

6
7
8

# File 'lib/pubnub/event.rb', line 6

def channel
  @channel
end

6
7
8

# File 'lib/pubnub/event.rb', line 6

def error_callback
  @error_callback
end

6
7
8

# File 'lib/pubnub/event.rb', line 6

def group
  @group
end

6
7
8

# File 'lib/pubnub/event.rb', line 6

def idle_timeout
  @idle_timeout
end

6
7
8

# File 'lib/pubnub/event.rb', line 6

def open_timeout
  @open_timeout
end

6
7
8

# File 'lib/pubnub/event.rb', line 6

def origin
  @origin
end

6
7
8

# File 'lib/pubnub/event.rb', line 6

def presence_callback
  @presence_callback
end

6
7
8

# File 'lib/pubnub/event.rb', line 6

def read_timeout
  @read_timeout
end

46
47
48

# File 'lib/pubnub/event.rb', line 46

def finalized?
  @finalized || @stop
end

22
23
24
25
26
27
28
29
30
31
32
33
34
35

# File 'lib/pubnub/event.rb', line 22

def fire
  Pubnub.logger.debug('Pubnub::Event') { "Fired event #{self.class}" }

  sender = request_dispatcher

  message = sender.send_request(Celluloid::Actor.current)

  envelopes = fire_callbacks(handle(message))
  finalize_event(envelopes)
  envelopes
ensure
  sender.terminate if @http_sync
  terminate unless @stay_alive
end

50
51
52

# File 'lib/pubnub/event.rb', line 50

def sync?
  @http_sync ? true : false
end

37
38
39
40
41
42
43
44

# File 'lib/pubnub/event.rb', line 37

def uri
  uri = @ssl ? 'https://' : 'http://'
  uri += @origin
  uri += path
  uri += '?' + Formatter.params_hash_to_url_params(parameters)
  Pubnub.logger.debug('Pubnub::Event') { "Requested URI: #{uri}" }
  URI uri
end