feat(node): Add /nodes/reconnect endpoint

Author: ImMohammad20000

app/operation/node.py

@@ -78,8 +78,8 @@ async def update_node_status(
 
     @staticmethod
     async def connect_node(node_id: int) -> None:
-        gozargah_node: PasarGuardNode | None = await node_manager.get_node(node_id)
-        if gozargah_node is None:
+        pg_node: PasarGuardNode | None = await node_manager.get_node(node_id)
+        if pg_node is None:
             return
 
         async with GetDB() as db:
@@ -96,7 +96,7 @@ async def connect_node(node_id: int) -> None:
             core = await core_manager.get_core(db_node.core_config_id if db_node.core_config_id else 1)
 
             try:
-                info = await gozargah_node.start(
+                info = await pg_node.start(
                     config=core.to_str(),
                     backend_type=0,
                     users=await core_users(db=db),
@@ -325,12 +325,12 @@ async def sync_node_users(self, db: AsyncSession, node_id: int, flush_users: boo
         if db_node.status != NodeStatus.connected:
             await self.raise_error(message="Node is not connected", code=406)
 
-        gozargah_node = await node_manager.get_node(node_id)
-        if gozargah_node is None:
+        pg_node = await node_manager.get_node(node_id)
+        if pg_node is None:
             await self.raise_error(message="Node is not connected", code=409)
 
         try:
-            await gozargah_node.sync_users(await core_users(db=db), flush_queue=flush_users)
+            await pg_node.sync_users(await core_users(db=db), flush_queue=flush_users)
         except NodeAPIError as e:
             await update_node_status(db=db, db_node=db_node, status=NodeStatus.error, message=e.detail)
             await self.raise_error(message=e.detail, code=e.code)

app/routers/node.py

@@ -53,6 +53,19 @@ async def get_nodes(
     return await node_operator.get_db_nodes(db=db, core_id=backend_id, offset=offset, limit=limit)
 
 
+@router.post("s/reconnect")
+async def reconnect_all_node(
+    core_id: int | None = None,
+    db: AsyncSession = Depends(get_db),
+    admin: AdminDetails = Depends(check_sudo_admin),
+):
+    """
+    Trigger reconnection for all nodes or a specific core.
+    """
+    await node_operator.restart_all_node(db=db, admin=admin, core_id=core_id)
+    return {}
+
+
 @router.post(
     "",
     response_model=NodeResponse,