summaryrefslogtreecommitdiff
path: root/testing
diff options
context:
space:
mode:
Diffstat (limited to 'testing')
-rw-r--r--testing/rect.py17
1 files changed, 9 insertions, 8 deletions
diff --git a/testing/rect.py b/testing/rect.py
index 59d6c158..2f9c9256 100644
--- a/testing/rect.py
+++ b/testing/rect.py
@@ -2,6 +2,7 @@
2#for testing only 2#for testing only
3import socket 3import socket
4import random 4import random
5import code
5 6
6UDP_IP = "127.0.0.1" 7UDP_IP = "127.0.0.1"
7UDP_PORT = 5004 8UDP_PORT = 5004
@@ -13,7 +14,7 @@ sock.bind((UDP_IP, UDP_PORT))
13#our client_id 14#our client_id
14client_id = str(''.join(random.choice("abcdefghijklmnopqrstuvwxyz") for x in range(32))) 15client_id = str(''.join(random.choice("abcdefghijklmnopqrstuvwxyz") for x in range(32)))
15 16
16print client_id 17print (client_id)
17a = 1; 18a = 1;
18#send ping request to our DHT on localhost. 19#send ping request to our DHT on localhost.
19sock.sendto("0012345678".decode("hex") + client_id, ('127.0.0.1', 33445)) 20sock.sendto("0012345678".decode("hex") + client_id, ('127.0.0.1', 33445))
@@ -21,25 +22,25 @@ sock.sendto("0012345678".decode("hex") + client_id, ('127.0.0.1', 33445))
21#print all packets recieved and respond to ping requests properly 22#print all packets recieved and respond to ping requests properly
22while True: 23while True:
23 data, addr = sock.recvfrom(1024) # buffer size is 1024 bytes 24 data, addr = sock.recvfrom(1024) # buffer size is 1024 bytes
24 print "received message:", data.encode('hex'), " From:", addr 25 print ("received message:", data.encode('hex'), " From:", addr)
25 #if we recieve a ping request. 26 #if we recieve a ping request.
26 print data[0].encode('hex') 27 print (data[0].encode('hex'))
27 if data[0] == "00".decode('hex'): 28 if data[0] == "00".decode('hex'):
28 print "Sending ping resp" 29 print ("Sending ping resp")
29 sock.sendto("01".decode('hex') + data[1:5] + client_id, addr) 30 sock.sendto("01".decode('hex') + data[1:5] + client_id, addr)
30 31
31 #if we recieve a get_nodes request. 32 #if we recieve a get_nodes request.
32 if data[0] == "02".decode('hex'): 33 if data[0] == "02".decode('hex'):
33 print "Sending getn resp" 34 print ("Sending getn resp")
34 #send send nodes packet with a couple 127.0.0.1 ips and ports. 35 #send send nodes packet with a couple 127.0.0.1 ips and ports.
35 #127.0.0.1:5000, 127.0.0.1:5001, 127.0.0.1:5002 36 #127.0.0.1:5000, 127.0.0.1:5001, 127.0.0.1:5002
36 sock.sendto("03".decode('hex') + data[1:5] + client_id + ("HHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHH" + "7F00000113880000".decode('hex') + "HHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHH" + "7F00000113890000".decode('hex') + "HHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHH" + "7F000001138A0000".decode('hex')), addr) 37 sock.sendto("03".decode('hex') + data[1:5] + client_id + ("HHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHH" + "7F00000113880000".decode('hex') + "HHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHH" + "7F00000113890000".decode('hex') + "HHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHH" + "7F000001138A0000".decode('hex')), addr)
37 38
38 if data[0] == "10".decode('hex'): 39 if data[0] == "10".decode('hex'):
39 print "Sending handshake resp" 40 print ("Sending handshake resp")
40 sock.sendto("10".decode('hex') + data[1:5] + client_id[:4], addr) 41 sock.sendto("10".decode('hex') + data[1:5] + client_id[:4], addr)
41 if data[0] == "11".decode('hex'): 42 if data[0] == "11".decode('hex'):
42 print "Sending SYNC resp" 43 print ("Sending SYNC resp")
43 a+=1 44 a+=1
44 sock.sendto("11".decode('hex') + chr(a) + data[1:9], addr) 45 sock.sendto("11".decode('hex') + chr(a) + data[1:9], addr)
45 46