|
|
|
@ -98,20 +98,20 @@ def contrib_entry(ipv6):
@@ -98,20 +98,20 @@ def contrib_entry(ipv6):
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def error_check_insert_into_db(dht, switchpeers, ipv6): |
|
|
|
|
# try: |
|
|
|
|
if dht.get("status") == "success": |
|
|
|
|
for x, y in dht["response"]["dht"].iteritems(): |
|
|
|
|
if valid_ipv6_check(x) and check_coords(y["coords"]): |
|
|
|
|
insert_new_entry(x, y["coords"]) |
|
|
|
|
|
|
|
|
|
if dht.get("status") == "success": |
|
|
|
|
for x in switchpeers["response"]["switchpeers"].iteritems(): |
|
|
|
|
if valid_ipv6_check(x[1]["ip"]) and check_coords(x[1]["coords"]): |
|
|
|
|
insert_new_entry(x[1]["ip"], x[1]["coords"]) |
|
|
|
|
|
|
|
|
|
contrib_entry(ipv6) |
|
|
|
|
# except: |
|
|
|
|
# print"error in json file, aborting" |
|
|
|
|
try: |
|
|
|
|
if dht.get("status") == "success": |
|
|
|
|
for x, y in dht["response"]["dht"].iteritems(): |
|
|
|
|
if valid_ipv6_check(x) and check_coords(y["coords"]): |
|
|
|
|
insert_new_entry(x, y["coords"]) |
|
|
|
|
|
|
|
|
|
if dht.get("status") == "success": |
|
|
|
|
for x in switchpeers["response"]["switchpeers"].iteritems(): |
|
|
|
|
if valid_ipv6_check(x[1]["ip"]) and check_coords(x[1]["coords"]): |
|
|
|
|
insert_new_entry(x[1]["ip"], x[1]["coords"]) |
|
|
|
|
|
|
|
|
|
contrib_entry(ipv6) |
|
|
|
|
except: |
|
|
|
|
print"error in json file, aborting" |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def proccess_incoming_data(datty, ipv6): |
|
|
|
|