Module: ObjectsFramework::PubSub

Defined in:
lib/objectsframework/pubsub.rb

Defined Under Namespace

Modules: ClassExtend Classes: Channel

Constant Summary collapse

@@channels = 
{}

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.included(child) ⇒ Object 



8
9
10
11
 
# File 'lib/objectsframework/pubsub.rb', line 8

def self.included(child)
  child.add_hook :filter => "request.capture", :method => "pubsub_capture_request"
  child.extend ClassExtend
end

Instance Method Details

#pubsub_capture_request ⇒ Object 



13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/objectsframework/pubsub.rb', line 13

def pubsub_capture_request
  # TODO: hijack rack request

  if(@env["HTTP_UPGRADE"] == "websocket")
    # Request is websockets hijacking
    tubesock = Tubesock.hijack(@env)

    @@channels[request.path.split("/")[2]].sockets << tubesock

    tubesock.onclose do
        @@channels[request.path.split("/")[2]].sockets.delete(tubesock)
    end

    tubesock.listen

    [-1, {}, []]
  else
    return continue
  end
end