debug ci

Author: almogdepaz

chia/server/server.py

@@ -425,6 +425,7 @@ async def start_client(
         """
         if self.is_duplicate_or_self_connection(target_node):
             self.log.warning(f"cannot connect to {target_node.host}, duplicate/self connection")
+            print(f"cannot connect to {target_node.host}, duplicate/self connection")
             return False
 
         if target_node.host in self.banned_peers and time.time() < self.banned_peers[target_node.host]:
@@ -452,15 +453,19 @@ async def start_client(
                 )
             except ServerDisconnectedError:
                 self.log.debug(f"Server disconnected error connecting to {url}. Perhaps we are banned by the peer.")
+                print(f"Server disconnected error connecting to {url}. Perhaps we are banned by the peer.")
                 return False
             except ClientResponseError as e:
                 self.log.warning(f"Connection failed to {url}. Error: {e}")
+                print(f"Connection failed to {url}. Error: {e}")
                 return False
             except asyncio.TimeoutError:
                 self.log.debug(f"Timeout error connecting to {url}")
+                print(f"Timeout error connecting to {url}")
                 return False
             if ws is None:
                 self.log.warning(f"Connection failed to {url}. ws was None")
+                print(f"Connection failed to {url}. ws was None")
                 return False
 
             ssl_object = ws.get_extra_info("ssl_object")

chia/server/start_service.py

@@ -149,6 +149,7 @@ def __init__(
     async def _connect_peers_task_handler(self) -> None:
         resolved_peers: dict[UnresolvedPeerInfo, PeerInfo] = {}
         prefer_ipv6 = self.config.get("prefer_ipv6", False)
+        print(f"connect peers task started {self._connect_peers}")
         while True:
             for unresolved in self._connect_peers:
                 print(f"try peer {unresolved}")
@@ -164,15 +165,15 @@ async def _connect_peers_task_handler(self) -> None:
                     resolved_peers[unresolved] = resolved
 
                 if any(connection.peer_info == resolved for connection in self._server.all_connections.values()):
-                    print("step 1")
+                    print(f"step 1. {resolved} {self._server.all_connections.values()}")
                     continue
                 if any(
                     connection.peer_info.host == resolved.host and connection.peer_server_port == resolved.port
                     for connection in self._server.all_connections.values()
                 ):
                     print("step 2")
                     continue
-
+                print(f"connect to {resolved}")
                 if not await self._server.start_client(resolved, None):
                     self._log.info(f"Failed to connect to {resolved}")
                     print(f"Failed to connect to {resolved}")