Class: Volt::Channel

Inherits:
Object show all
Includes:
Eventable, ReactiveAccessors
Defined in:
lib/volt/page/channel.rb

Instance Method Summary collapse

Methods included from Eventable

#on, #remove_listener, #trigger!

Methods included from ReactiveAccessors

included

Constructor Details

#initialize ⇒ Channel

Returns a new instance of Channel.



14
15
16
17
18
19
20
21
22
23
 
# File 'lib/volt/page/channel.rb', line 14

def initialize
  @socket          = nil
  self.status      = :opening
  self.connected   = false
  self.error       = nil
  self.retry_count = 0
  @queue           = []

  connect!
end

Instance Method Details

#close! ⇒ Object 



99
100
101
102
103
104
 
# File 'lib/volt/page/channel.rb', line 99

def close!
  self.status = :closed
  `
    this.socket.close();
  `
end

#closed(error) ⇒ Object 



58
59
60
61
62
63
64
 
# File 'lib/volt/page/channel.rb', line 58

def closed(error)
  self.status    = :closed
  self.connected = false
  self.error     = `error.reason`

  reconnect!
end

#connect! ⇒ Object 



29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
 
# File 'lib/volt/page/channel.rb', line 29

def connect!
  `
    this.socket = new SockJS('/channel');

    this.socket.onopen = function() {
      self.$opened();
    };

    this.socket.onmessage = function(message) {
      self['$message_received'](message.data);
    };

    this.socket.onclose = function(error) {
      self.$closed(error);
    };
  `
end

#connected? ⇒ Boolean

Returns:



25
26
27
 
# File 'lib/volt/page/channel.rb', line 25

def connected?
  connected
end

#message_received(message) ⇒ Object 



81
82
83
84
85
 
# File 'lib/volt/page/channel.rb', line 81

def message_received(message)
  message = JSON.parse(message)

  trigger!('message', *message)
end

#opened ⇒ Object 



47
48
49
50
51
52
53
54
55
56
 
# File 'lib/volt/page/channel.rb', line 47

def opened
  old_status          = @status
  @status             = :open
  @connected          = true
  @reconnect_interval = nil
  @retry_count        = 0
  @queue.each do |message|
    send_message(message)
  end
end

#reconnect! ⇒ Object 



66
67
68
69
70
71
72
73
74
75
76
77
78
79
 
# File 'lib/volt/page/channel.rb', line 66

def reconnect!
  self.status             = :reconnecting
  self.reconnect_interval ||= 0
  self.reconnect_interval += (2000 + rand(5000))
  self.retry_count        += 1

  interval = self.reconnect_interval

  `
    setTimeout(function() {
      self['$connect!']();
    }, interval);
  `
end

#send_message(message) ⇒ Object 



87
88
89
90
91
92
93
94
95
96
97
 
# File 'lib/volt/page/channel.rb', line 87

def send_message(message)
  if status != :open
    @queue << message
  else
    # TODO: Temp: wrap message in an array, so we're sure its valid JSON
    message = JSON.dump([message])
    `
      this.socket.send(message);
    `
  end
end