From 32c32b46c458f8cd157d8c7f0b2961d8facdd12d Mon Sep 17 00:00:00 2001
From: none <none>
Date: Sun, 25 Feb 2024 19:38:13 +0300
Subject: [PATCH] =?UTF-8?q?=D0=98=D1=81=D0=BF=D1=80=D0=B0=D0=B2=D0=BB?=
 =?UTF-8?q?=D0=B5=D0=BD=D0=B8=D0=B5=20=D0=BF=D1=80=D0=BE=D1=88=D0=BB=D0=BE?=
 =?UTF-8?q?=D0=B3=D0=BE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 network.py | 38 +++++++++++++++++++++++++++++++-------
 1 file changed, 31 insertions(+), 7 deletions(-)

diff --git a/network.py b/network.py
index f664649..568fc57 100644
--- a/network.py
+++ b/network.py
@@ -88,7 +88,12 @@ def server(http_port):
 		except:
 			print("SERVER FALLED")
 
-def recv(data):
+
+from time import time
+from threading import Thread
+from queue import Queue
+
+def recv(s, data_out):
 	okay = False
 	while not okay:
 		try:
@@ -96,9 +101,8 @@ def recv(data):
 			okay = True
 		except:
 			pass
+	data_out.put(data)
 
-from time import time
-from threading import Thread
 # op = operation
 def client(port, op = "ping"):
 	host = 'jetwork.404.mn'
@@ -116,17 +120,22 @@ def client(port, op = "ping"):
 
 		s.send(op.encode())
 
-		data = None
-		ping = Thread(target = recv, args=(data,))
+
+		data = Queue()
+
+		ping = Thread(target = recv, args=(s, data,))
 		ping.daemon = True
 		# Стартуем пинг
 		ping.start()
 
 		# Ждём 8 секунд
-		ping.join(8)
+		ping.join(6)
 
+		if not data.empty():
+			return data.get()
+		else:
+			return None
 
-		return data
 	elif op[:4] == "get_":
 		site = op[4:]
 
@@ -214,7 +223,14 @@ def client(port, op = "ping"):
 			os.remove(f"verify/{site}.sig")
 
 
+def check_current(ports, cur_port):
+	if client(cur_port, "ping"):
+		ports.append(cur_port)
+		print("CATHCED: ", cur_port)
+	return
+
 from tqdm import tqdm
+from time import sleep
 def port_check(your_port):
 	ports = []
 
@@ -223,6 +239,14 @@ def port_check(your_port):
 	for port in tqdm(checks):
 		if client(port, "ping"):
 			ports.append(port)
+			print("CATHCED: ", port)
+#		ping = Thread(target = check_current, args=(ports, port,))
+#		ping.start()
+
+#	sleep(10)
 
 	return ports
 
+
+#print( port_check(4001) )
+#print( client(4184, "ping") )