Class: Flammarion::Server Private

Inherits:
Object
  • Object
show all
Defined in:
lib/flammarion/server.rb

This class is part of a private API. You should avoid using this class if possible, as it may be removed or be changed in the future.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Server

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns a new instance of Server.



5
6
7
8
9
10
11
12
13
14
15
16
17
18
 
# File 'lib/flammarion/server.rb', line 5

def initialize
  @windows = {}
  @socket_paths = {}
  @started = false
  @launch_thread = Thread.current
  @server_thread = Thread.new do
    begin
      start_server_internal
    rescue StandardError
      handle_exception($!)
    end
  end
  sleep 0.01 while not @started
end

Instance Attribute Details

#port ⇒ Object (readonly)

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



4
5
6
 
# File 'lib/flammarion/server.rb', line 4

def port
  @port
end

#server_thread ⇒ Object (readonly)

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



4
5
6
 
# File 'lib/flammarion/server.rb', line 4

def server_thread
  @server_thread
end

Instance Method Details

#handle_exception(e) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



73
74
75
 
# File 'lib/flammarion/server.rb', line 73

def handle_exception(e)
  @launch_thread.raise(e)
end

#log(str) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



69
70
71
 
# File 'lib/flammarion/server.rb', line 69

def log(str)
  # Kernel.puts str
end

#register_window(window) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



77
78
79
80
81
82
 
# File 'lib/flammarion/server.rb', line 77

def register_window(window)
  @new_path ||= 0
  @new_path += 1
  @windows["/w#{@new_path}"] = window
  return "w#{@new_path}"
end

#start_server_internal ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



20
21
22
23
24
25
26
27
28
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
58
59
60
61
62
63
64
 
# File 'lib/flammarion/server.rb', line 20

def start_server_internal
  @port = 7870
  @port = rand(65000 - 1024) + 1024 if Gem.win_platform?
  begin
    @server = Rubame::Server.new("0.0.0.0", @port)
    while true do
      @started = true
      @server.run do |ws|
        ws.onopen {
          log "WebSocket connection open"
          if @windows.include?(ws.handshake.path)
            @windows[ws.handshake.path].sockets << ws
            @windows[ws.handshake.path].on_connect.call() if @windows[ws.handshake.path].on_connect
            @socket_paths[ws] = ws.handshake.path
          else
            log "No such window: #{handshake.path}"
          end
        }

        ws.onclose do
          log "Connection closed";
          @windows[@socket_paths[ws]].disconnect(ws) if @windows[@socket_paths[ws]]
        end

        ws.onmessage { |msg|
          Thread.new do
            begin
              @windows[@socket_paths[ws]].process_message(msg)
            rescue Exception
              handle_exception($!)
            end
          end
        }
      end
    end
  rescue RuntimeError, Errno::EADDRINUSE
    if $!.message == "no acceptor (port is in use or requires root privileges)" or $!.is_a? Errno::EADDRINUSE
      @port = rand(65000 - 1024) + 1024
      retry
    else
      raise
    end
  end
  @started = true
end

#stop ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



66
67
 
# File 'lib/flammarion/server.rb', line 66

def stop
end