def __init__(self, spoof_hostname, spoof_port):
"""Create a new spoof TCP proxy.
:param str spoof_hostname: the hostname of the spoof server
:param int spoof_port: the port of the spoof server
"""
# how many bytes have been sent by the spoof server?
self.spoof_messages_length = 0
# for the actual server connection
self.server_queue = DeferredQueue()
self.client_queue = DeferredQueue()
# for the spoofed connection
self.spoof_client_queue = DeferredQueue()
self.spoof_server_queue = DeferredQueue()
self._connectServer(spoof_hostname, spoof_port,
self.spoof_server_queue, self.spoof_client_queue)
# add callbacks
self.server_queue.get().addCallback(self.serverQueueCallback)
self.spoof_server_queue.get().addCallback(self.spoofServerQueueCallback)
评论列表
文章目录