diff --git a/send-view.py b/send-view.py new file mode 100644 index 0000000..2efd08f --- /dev/null +++ b/send-view.py @@ -0,0 +1,40 @@ +import socket +import json + +GETDHT = '{"request":"getDHT", "keepalive":true}' +GETSWITCHPEERS = '{"request":"getSwitchPeers"}' +SERVER = "y.yakamo.org" + + +def send_view_to_server(tosend): + if tosend: + attempts = 3 + while attempts: + try: + conn = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) + conn.sendto(tosend, (SERVER, 45671)) + break + except: + attempts -= 1 + + +def collect_dht_getswitchpeers(): + try: + ygg = socket.socket(socket.AF_INET, socket.SOCK_STREAM) + ygg.connect(('localhost', 9001)) + + ygg.send(GETDHT) + dhtdata = json.loads(ygg.recv(1024 * 15)) + + ygg.send(GETSWITCHPEERS) + switchdata = json.loads(ygg.recv(1024 * 15)) + + temp_dict = {} + temp_dict["dhtpack"] = dhtdata + temp_dict["switchpack"] = switchdata + + return json.dumps(temp_dict).encode() + except: + return None + +send_view_to_server(collect_dht_getswitchpeers())