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

#__reactive_dependency_get, 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 



108
109
110
111
112
113
 
# File 'lib/volt/page/channel.rb', line 108

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

#closed(error) ⇒ Object 



69
70
71
72
73
74
75
 
# File 'lib/volt/page/channel.rb', line 69

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
46
47
48
49
50
51
52
53
54
55
56
57
 
# File 'lib/volt/page/channel.rb', line 29

def connect!
  %x{
    if (document.location.protocol == 'https:') {
      var wsProto = 'wss';
    } else {
      var wsProto = 'ws';
    }

    this.socket = new WebSocket(wsProto + '://' + document.location.host + '/socket');

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

    // Log errors
    this.socket.onerror = function (error) {
      console.log('WebSocket Error ', error);
    };

    // Log messages from the server
    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 



90
91
92
93
94
 
# File 'lib/volt/page/channel.rb', line 90

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

  trigger!('message', *message)
end

#opened ⇒ Object 



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

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

#reconnect! ⇒ Object 



77
78
79
80
81
82
83
84
85
86
87
88
 
# File 'lib/volt/page/channel.rb', line 77

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

  interval = self.reconnect_interval

  self.reconnect_in = interval

  reconnect_tick
end

#send_message(message) ⇒ Object 



96
97
98
99
100
101
102
103
104
105
106
 
# File 'lib/volt/page/channel.rb', line 96

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