removed client side connection host determination

[quix0rs-apt-p2p.git] / knode.py

diff --git a/knode.py b/knode.py
index 52abbed41f81d217b029e578579868274faade69..3e32ce83409aebffe04eec98f17b5dec1533e508 100644 (file)
--- a/knode.py
+++ b/knode.py
@@ -2,9 +2,10 @@ from node import Node
 from twisted.internet.defer import Deferred
 from xmlrpcclient import XMLRPCClientFactory as factory
 from const import reactor
-from base64 import encodestring as encode
+from xmlrpclib import Binary
 
-class KNode(Node):
+
+class KNode(Node):     
     def ping(self, sender):
        df = Deferred()
        f = factory('ping', (sender,), df.callback, df.errback)
@@ -12,16 +13,16 @@ class KNode(Node):
        return df
     def findNode(self, target, sender):
        df = Deferred()
-       f = factory('find_node', (target, sender), df.callback, df.errback)
+       f = factory('find_node', (Binary(target), sender), df.callback, df.errback)
        reactor.connectTCP(self.host, self.port, f)
        return df
     def storeValue(self, key, value, sender):
        df = Deferred()
-       f = factory('store_value', (encode(key), encode(value), sender), df.callback, df.errback)
+       f = factory('store_value', (Binary(key), Binary(value), sender), df.callback, df.errback)
        reactor.connectTCP(self.host, self.port, f)
        return df
     def findValue(self, key, sender):
        df = Deferred()
-       f = factory('find_value', (encode(key), sender), df.callback, df.errback)
+       f = factory('find_value', (Binary(key), sender), df.callback, df.errback)
        reactor.connectTCP(self.host, self.port, f)
        return df