made scripts for ping

RTT.py

+"""
+Module to calculate RTT
+:author: gurnoorsingh (20221024)
+"""
+
+import time
+import requests
+import numpy as np
+ 
+def RTT(url):
+    times = []
+    num_iterations = 10
+
+    for _ in range(num_iterations):
+        t1 = time.time()
+        _ = requests.get(url)
+        t2 = time.time()
+        times.append((t2 - t1))
+ 
+    return int(np.mean(times) * 1e9)
+ 
+def main():
+    # url address
+    url = "http://oregong-algorand-test-1.algorand-testnet.network:4161"
+    print(RTT(url))
+
+if __name__ == '__main__':
+    main()
\ No newline at end of file

get_relays.py

+"""
+Module to get list of all relay nodes present in the network
+:author; gurnoorsingh (20221110)
+"""
+import re
+import json
+
+LOG_FILE = "/home/azureuser/node/data/node.archive.log"
+
+relay_nodes = set()
+relay_node_endpoints = set()
+
+with open(LOG_FILE) as fh:
+    for line in fh.readlines():
+        if re.match(".*OutgoingPeers", line):
+            dict_obj = json.loads(line)
+            for peer in dict_obj['details']['OutgoingPeers']:
+                relay_nodes.add(peer['Address'])
+                relay_node_endpoints.add(peer['Endpoint'])
+
+print(len(relay_nodes))
+print(relay_nodes)
+
+print(len(relay_node_endpoints))
+print(relay_node_endpoints)
\ No newline at end of file

results/endpoints.txt

+{'r19.algorand-testnet.network:4161', 'relay-virginia-testnet-algorand.algorand-testnet.network:4161', 'oregong-algorand-test-1.algorand-testnet.network:4161', 'singaporeg-algorand-test-1.algorand-testnet.network:4161', 'londong-algorand-test-2.algorand-testnet.network:4161', 'singaporeg-algorand-test-2.algorand-testnet.network:4161', 'relay-switzerland1-testnet-algorand.algorand-testnet.network:80', 'londong-algorand-test-1.algorand-testnet.network:4161'}
\ No newline at end of file

scripts/create_txn.sh

 #!/usr/bin/bash
 
-python3 ../create_txn.py -r "IWINPM7ICBCVWJW3N3UQTNSNDPR277W5F32PWMDXEAP5AJ54XNTZ6NOCRA" \
--s "ADFxzTweuf7G7l2jahLl6mtTzUFqPBkCgLps0sOUN2kj5y0ylv6aGsNENp++U1ybcj4ObnIW60E4hCLJZvUU2A==" \
--a "EPTS2MUW72NBVQ2EG2P34U24TNZD4DTOOILOWQJYQQRMSZXVCTMDLS2MZY" \
--t "dea261c48442980a8b2ef64440b3f052e270d33ea77abc83f082bf5997e01912"
+RECEIVER_ADDR=MADR6ILGZJOMAMGWOR7MRMQP35QQO6CVFBX27Z7ILR4U4WIDKMO7G3477E
+SENDER_ADDR=RO7RK3WNLEJPYSK7AP3OX75LCN3NNH7VV7OQE7HFNWBPTQ3FOBW74NUC3I
+SENDER_SECRET_KEY=dpvglDQSyHCmncqwcqQjji0uhZXt8eWCvGlDBL88r9CLvxVuzVkS/ElfA/br/6sTdtaf9a/dAnzlbYL5w2VwbQ==
+ALGOD_ADDR=http://127.0.0.1:33391
+ALGOD_TOKEN=19fe428d54999193ab72951ba00ab20d8d32b5d02c291a5bf5d061944d0cd922
+
+python3 /home/azureuser/algorand-topology/create_txn.py -r $RECEIVER_ADDR \
+-s $SENDER_SECRET_KEY \
+-a $SENDER_ADDR \
+-t $ALGOD_TOKEN \
+-d $ALGOD_ADDR

scripts/mnemonic_to_key.sh

 #!/usr/bin/bash
 
-python3 ../mnemonic_to_key.py --kmd-token "3b968216d17a510c66dd8b3b42e80b09e5b67590e7c94980535656da613cd237" \
+python3 ../mnemonic_to_key.py --kmd-token "a013a0434018a2656acf7d554c87f426c69e098862f2d64d3853749e9ebafc3b" \
 -w "testwallet" \
--p "123456" \
--a "EPTS2MUW72NBVQ2EG2P34U24TNZD4DTOOILOWQJYQQRMSZXVCTMDLS2MZY" 
+-p "1234567" \
+-a "RO7RK3WNLEJPYSK7AP3OX75LCN3NNH7VV7OQE7HFNWBPTQ3FOBW74NUC3I" 

txn_to_sender_map.py

+"""
+Module to process log file for received messages from relays
+:author: gurnoorsingh (20221024)
+"""
+import os
+import re
+import json
+from collections import defaultdict
+from RTT import RTT
+
+BASE_DIR = "/home/azureuser/node/data"
+FILENAME = "node.log"
+
+MSG_RECEIVED_IDENTIFIER = "got a tx group with IDs"
+
+tx_senders_map = defaultdict(lambda: [])
+relay_set = set()
+
+with open(os.path.join(BASE_DIR, FILENAME)) as fh:
+    for line in fh.readlines():
+        try:
+            row = json.loads(line)
+        except:
+            continue
+        if row["msg"].startswith(MSG_RECEIVED_IDENTIFIER):
+            txn_ids_str = re.findall(f".*{MSG_RECEIVED_IDENTIFIER} \[(.*?)\].*", row["msg"])[0]
+            txn_ids = [x.strip() for x in txn_ids_str.split()]
+            sender = re.findall(".*rootURL:(.*?)\s.*", row["msg"])[0]
+            recv_time = int(re.findall(".*at.*?([0-9]+).*", row["msg"])[0])
+            txn_size = len(re.findall(".*uint8=\[(.*?)\]", row["msg"])[0].split())
+
+            # add sender and received time to txn sender map
+            for txn in txn_ids:
+                tx_senders_map[txn].append((sender, recv_time, txn_size))
+
+            # add sender address to set of relays
+            relay_set.add(sender)            
+
+
+TXN_ID = "UCPRQGVTATHIFUEUX3ZVJC3FK2W4YLTDOFXEW563ZCAGNLMBZ5HQ"
+send_times = []
+for k, v in tx_senders_map.items():
+    if k == TXN_ID:
+        for sender, recv_time in v:
+            send_time = recv_time - RTT(f"http://{sender}")//2
+            print(f"Received time: {recv_time}\nSend time: {send_time}")
+            send_times.append((sender, send_time))
+
+send_times.sort(key=lambda x: x[1])
+print(send_times)