diff options
author | Astonex <softukitu@gmail.com> | 2013-07-23 16:17:33 +0100 |
---|---|---|
committer | Astonex <softukitu@gmail.com> | 2013-07-23 16:17:33 +0100 |
commit | 4aeded2d0eb735c1b8c7529c7ca9edf924208769 (patch) | |
tree | 3d06b548a53591aa4ed7e413b6e986fa2d5b7dad /testing | |
parent | 0019fe05e5c5eb81caefb6e7d9743ef500985d7c (diff) |
Disregard
Diffstat (limited to 'testing')
-rw-r--r-- | testing/rect.py | 17 |
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 |
3 | import socket | 3 | import socket |
4 | import random | 4 | import random |
5 | import code | ||
5 | 6 | ||
6 | UDP_IP = "127.0.0.1" | 7 | UDP_IP = "127.0.0.1" |
7 | UDP_PORT = 5004 | 8 | UDP_PORT = 5004 |
@@ -13,7 +14,7 @@ sock.bind((UDP_IP, UDP_PORT)) | |||
13 | #our client_id | 14 | #our client_id |
14 | client_id = str(''.join(random.choice("abcdefghijklmnopqrstuvwxyz") for x in range(32))) | 15 | client_id = str(''.join(random.choice("abcdefghijklmnopqrstuvwxyz") for x in range(32))) |
15 | 16 | ||
16 | print client_id | 17 | print (client_id) |
17 | a = 1; | 18 | a = 1; |
18 | #send ping request to our DHT on localhost. | 19 | #send ping request to our DHT on localhost. |
19 | sock.sendto("0012345678".decode("hex") + client_id, ('127.0.0.1', 33445)) | 20 | sock.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 |
22 | while True: | 23 | while 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 | ||