Sha256: cd81ed09a0a84188aab7de8cef80e9f76df1cb7bfc854c6e0049a48791a94187
Contents?: true
Size: 1.03 KB
Versions: 32
Compression:
Stored size: 1.03 KB
Contents
# encoding: UTF-8
module Vines
class Stream
class Http
class BindRestart < State
def initialize(stream, success=Bind)
super
end
def node(node)
raise StreamErrors::NotAuthorized unless restart?(node)
doc = Document.new
body = doc.create_element('body') do |el|
el.add_namespace(nil, NAMESPACES[:http_bind])
el.add_namespace('stream', NAMESPACES[:stream])
el << doc.create_element('stream:features') do |features|
features << doc.create_element('bind', 'xmlns' => NAMESPACES[:bind])
end
end
stream.reply(body)
advance
end
private
def restart?(node)
session = stream.valid_session?(node['sid'])
restart = node.attribute_with_ns('restart', NAMESPACES[:bosh]).value rescue nil
domain = node['to'] == stream.domain
session && body?(node) && domain && restart == 'true' && node['rid']
end
end
end
end
end
Version data entries
32 entries across 32 versions & 4 rubygems