summaryrefslogtreecommitdiff
path: root/testing/rect.py
diff options
context:
space:
mode:
authorirungentoo <irungentoo@gmail.com>2013-06-25 12:11:11 -0400
committerirungentoo <irungentoo@gmail.com>2013-06-25 12:11:11 -0400
commit3396d8e495598c2b8ee1cdb2dd5f748647971c26 (patch)
treede7d07e18488976db5687454ba8c1929cef1a2c8 /testing/rect.py
parent338bfc151023474bd09030cbededa49d0816efc6 (diff)
DHT implementation finished. Currently testing it.
Diffstat (limited to 'testing/rect.py')
-rw-r--r--testing/rect.py24
1 files changed, 21 insertions, 3 deletions
diff --git a/testing/rect.py b/testing/rect.py
index 94baeaec..816e6e8c 100644
--- a/testing/rect.py
+++ b/testing/rect.py
@@ -1,6 +1,7 @@
1#basic python UDP script 1#basic python UDP script
2#for testing only 2#for testing only
3import socket 3import socket
4import random
4 5
5UDP_IP = "127.0.0.1" 6UDP_IP = "127.0.0.1"
6UDP_PORT = 5004 7UDP_PORT = 5004
@@ -9,11 +10,28 @@ sock = socket.socket(socket.AF_INET, # Internet
9 socket.SOCK_DGRAM) # UDP 10 socket.SOCK_DGRAM) # UDP
10sock.bind((UDP_IP, UDP_PORT)) 11sock.bind((UDP_IP, UDP_PORT))
11 12
13#our client_id
14client_id = str(''.join(random.choice("abcdefghijklmnopqrstuvwxyz") for x in range(32)))
15
16print client_id
17
12#send ping request to our DHT on localhost. 18#send ping request to our DHT on localhost.
13sock.sendto("0012345678".decode("hex") + "HHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHH", ('127.0.0.1', 33445)) 19sock.sendto("0012345678".decode("hex") + client_id, ('127.0.0.1', 33445))
14 20
15#print all packets recieved and respond to ping requests properly 21#print all packets recieved and respond to ping requests properly
16while True: 22while True:
17 data, addr = sock.recvfrom(1024) # buffer size is 1024 bytes 23 data, addr = sock.recvfrom(1024) # buffer size is 1024 bytes
18 print "received message:", data, " From:", addr 24 print "received message:", data.encode('hex'), " From:", addr
19 sock.sendto("01".decode('hex') + data[1:5] + "HHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHH", addr) 25 #if we recieve a ping request.
26 print data[0].encode('hex')
27 if data[0] == "00".decode('hex'):
28 print "Sending ping resp"
29 sock.sendto("01".decode('hex') + data[1:5] + client_id, addr)
30
31 #if we recieve a get_nodes request.
32 if data[0] == "02".decode('hex'):
33 print "Sending getn resp"
34 #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 sock.sendto("03".decode('hex') + data[1:5] + client_id + ("HHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHH" + "7F00000113880000".decode('hex') + "HHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHH" + "7F00000113890000".decode('hex') + "HHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHH" + "7F000001138A0000".decode('hex')), addr)
37