add check_adnl_connection_failed

Author: yungwine

modules/alert_bot.py

@@ -205,6 +205,13 @@ def check_slashed(self):
         if c is not None:
             self.send_alert("validator_slashed", amount=int(c['suggestedFine']))
 
+    def check_adnl_connection_failed(self):
+        from modules.utilities import UtilitiesModule
+        utils_module = UtilitiesModule(self.ton, self.local)
+        ok, error = utils_module.check_adnl_connection()
+        if not ok:
+            self.send_alert("adnl_connection_failed")
+
     def check_status(self):
         if not self.inited:
             self.init()
@@ -216,6 +223,7 @@ def check_status(self):
         self.local.try_function(self.check_zero_blocks_created)
         self.local.try_function(self.check_sync)
         self.local.try_function(self.check_slashed)
+        self.local.try_function(self.check_adnl_connection_failed)
 
     def add_console_commands(self, console):
         ...

modules/utilities.py

@@ -1,9 +1,10 @@
-import base64
 import json
-import os
+import random
 import subprocess
 import time
 
+import requests
+
 from mypylib.mypylib import color_print, print_table, color_text, timeago, bcolors
 from modules.module import MtcModule
 
@@ -335,6 +336,35 @@ def print_validator_list(self, args):
             print_table(table)
     # end define
 
+    def check_adnl_connection(self):
+        telemetry = self.ton.local.db.get("sendTelemetry", False)
+        check_adnl = self.ton.local.db.get("checkAdnl", telemetry)
+        if not check_adnl:
+            return True, ''
+        self.local.add_log('Checking ADNL connection to local node', 'info')
+        hosts = ['45.129.96.53', '5.154.181.153', '2.56.126.137', '91.194.11.68', '45.12.134.214', '138.124.184.27',
+                 '103.106.3.171']
+        hosts = random.sample(hosts, k=3)
+        data = self.ton.get_local_adnl_data()
+        error = ''
+        ok = True
+        for host in hosts:
+            url = f'http://{host}/adnl_check'
+            try:
+                response = requests.post(url, json=data, timeout=5).json()
+            except Exception as e:
+                ok = False
+                error = f'{{red}}Failed to check ADNL connection to local node: {type(e)}: {e}{{endc}}'
+                continue
+            result = response.get("ok")
+            if result:
+                ok = True
+                break
+            if not result:
+                ok = False
+                error = f'{{red}}Failed to check ADNL connection to local node: {response.get("message")}{{endc}}'
+        return ok, error
+
     def add_console_commands(self, console):
         console.AddItem("vas", self.view_account_status, self.local.translate("vas_cmd"))
         console.AddItem("vah", self.view_account_history, self.local.translate("vah_cmd"))

mytonctrl/mytonctrl.py

@@ -492,31 +492,9 @@ def check_slashed(local, ton):
 #end define
 
 def check_adnl(local, ton):
-	telemetry = ton.local.db.get("sendTelemetry", False)
-	check_adnl = ton.local.db.get("checkAdnl", telemetry)
-	local.add_log('Checking ADNL connection to local node', 'info')
-	if not check_adnl:
-		return
-	hosts = ['45.129.96.53', '5.154.181.153', '2.56.126.137', '91.194.11.68', '45.12.134.214', '138.124.184.27', '103.106.3.171']
-	hosts = random.sample(hosts, k=3)
-	data = ton.get_local_adnl_data()
-	error = ''
-	ok = True
-	for host in hosts:
-		url = f'http://{host}/adnl_check'
-		try:
-			response = requests.post(url, json=data, timeout=5).json()
-		except Exception as e:
-			ok = False
-			error = f'{{red}}Failed to check ADNL connection to local node: {type(e)}: {e}{{endc}}'
-			continue
-		result = response.get("ok")
-		if result:
-			ok = True
-			break
-		if not result:
-			ok = False
-			error = f'{{red}}Failed to check ADNL connection to local node: {response.get("message")}{{endc}}'
+	from modules.utilities import UtilitiesModule
+	utils_module = UtilitiesModule(ton, local)
+	ok, error = utils_module.check_adnl_connection()
 	if not ok:
 		print_warning(local, error)
 #end define