Sha256: e05a6ab4d67b4a816407c2759cca032ac2541bc4175dd449ed10c98ecd86f306
Contents?: true
Size: 1.91 KB
Versions: 15
Compression:
Stored size: 1.91 KB
Contents
# =XMPP4R - XMPP Library for Ruby
# License:: Ruby's license (see the LICENSE file) or GNU GPL, at your option.
# Website::http://home.gna.org/xmpp4r/
module Jabber
module Bytestreams
##
# SOCKS5 Bytestreams implementation of the target site
class SOCKS5BytestreamsTarget < SOCKS5Bytestreams
##
# Wait until the stream has been established
#
# May raise various exceptions
def accept
error = nil
connect_sem = Semaphore.new
@stream.add_iq_callback(200, self) { |iq|
if iq.type == :set and iq.from == @initiator_jid and iq.to == @target_jid and iq.query.kind_of?(IqQueryBytestreams)
begin
@stream.delete_iq_callback(self)
iq.query.each_element('streamhost') { |streamhost|
if streamhost.host and streamhost.port and not @socks
begin
@socks = connect_socks(streamhost)
@streamhost_used = streamhost
rescue Exception => e
Jabber::debuglog("SOCKS5 Bytestreams: #{e.class}: #{e}\n#{e.backtrace.join("\n")}")
@streamhost_cbs.process(streamhost, :failure, e)
end
end
}
reply = iq.answer(false)
if @streamhost_used
reply.type = :result
reply.add(IqQueryBytestreams.new)
reply.query.add(StreamHostUsed.new(@streamhost_used.jid))
else
reply.type = :error
reply.add(ErrorResponse.new('item-not-found'))
end
@stream.send(reply)
rescue Exception => e
error = e
end
connect_sem.run
true
else
false
end
}
connect_sem.wait
raise error if error
(@socks != nil)
end
end
end
end
Version data entries
15 entries across 15 versions & 6 rubygems