fix: address all critical reviewer issues

- Fix missing exports in __init__.py (critical - breaks pull/push commands)
- Fix hardcoded timestamp in converter (use current datetime)
- Fix duplicate Router node names (use unique numbered names)
- Fix resource leaks in CLI commands (proper try/finally blocks)
- Fix ImportError handling in n8n client (allow ImportError to propagate)
- Fix YAML validation in preview.py (validate dict type)
- Add n8n to pyproject.toml extras (all, claw) for complete installation

Co-authored-by: Mervin Praison <MervinPraison@users.noreply.github.com>

Author: praisonai-triage-agent[bot]

src/praisonai/praisonai/cli/commands/n8n.py

@@ -247,9 +247,9 @@ def test_connection(
         praisonai n8n test
         praisonai n8n test --n8n-url http://n8n.example.com
     """
+    client = None
     try:
         from praisonai.n8n import N8nClient
-        
         client = N8nClient(base_url=n8n_url, api_key=api_key)
 
         if client.test_connection():
@@ -267,14 +267,17 @@ def test_connection(
             typer.echo("💡 Make sure n8n is running. Start with: npx n8n start")
             raise typer.Exit(1)
 
-        client.close()
-        
+    except typer.Exit:
+        raise
     except ImportError:
         typer.echo("Error: n8n dependencies not installed. Run: pip install 'praisonai[n8n]'", err=True)
         raise typer.Exit(1)
     except Exception as e:
         typer.echo(f"Error: {e}", err=True)
         raise typer.Exit(1)
+    finally:
+        if client is not None:
+            client.close()
 
 @app.command(name="list")
 def list_workflows(
@@ -286,6 +289,7 @@ def list_workflows(
     Example:
         praisonai n8n list
     """
+    client = None
     try:
         from praisonai.n8n import N8nClient
 
@@ -307,8 +311,6 @@ def list_workflows(
 
                 typer.echo(f"  {workflow_id}: {name} ({status})")
 
-        client.close()
-        
     except ImportError:
         typer.echo("Error: n8n dependencies not installed. Run: pip install 'praisonai[n8n]'", err=True)
         raise typer.Exit(1)
@@ -319,3 +321,6 @@ def list_workflows(
     except Exception as e:
         typer.echo(f"Error: {e}", err=True)
         raise typer.Exit(1)
+    finally:
+        if client is not None:
+            client.close()

src/praisonai/praisonai/n8n/client.py

@@ -210,6 +210,8 @@ def test_connection(self) -> bool:
                 timeout=5.0
             )
             return response.status_code == 200
+        except ImportError:
+            raise
         except Exception as e:
             logger.warning(f"Connection test failed: {e}")
             return False

src/praisonai/praisonai/n8n/converter.py

@@ -6,6 +6,7 @@
 
 from typing import Dict, Any, List, Optional
 from dataclasses import dataclass
+from datetime import datetime, timezone
 import logging
 
 logger = logging.getLogger(__name__)
@@ -84,7 +85,7 @@ def convert(self, yaml_workflow: Dict[str, Any]) -> Dict[str, Any]:
             "staticData": {},
             "tags": ["praisonai", "agents"],
             "triggerCount": 1,
-            "updatedAt": "2026-04-16T12:00:00.000Z",
+            "updatedAt": datetime.now(timezone.utc).strftime("%Y-%m-%dT%H:%M:%S.000Z"),
             "versionId": "1.0.0"
         }
 
@@ -261,7 +262,7 @@ def _create_switch_node(self, route_config: Dict[str, Any]) -> N8nNode:
                 })
 
         return N8nNode(
-            name="Router",
+            name=f"Router {self.node_counter}",
             type="n8n-nodes-base.switch",
             position=[
                 self.position_x_start + (self.node_counter * self.position_x_increment),

src/praisonai/praisonai/n8n/preview.py

@@ -48,6 +48,8 @@ def preview_workflow(
         import yaml as yaml_lib
         with open(yaml_file, 'r') as f:
             yaml_content = yaml_lib.safe_load(f)
+        if not isinstance(yaml_content, dict):
+            raise ValueError("Workflow YAML must deserialize to a mapping")
     except Exception as e:
         raise ValueError(f"Failed to parse YAML workflow: {e}")
 
@@ -175,6 +177,8 @@ def sync_workflow(
         import yaml as yaml_lib
         with open(yaml_file, 'r') as f:
             yaml_content = yaml_lib.safe_load(f)
+        if not isinstance(yaml_content, dict):
+            raise ValueError("Workflow YAML must deserialize to a mapping")
     except Exception as e:
         raise ValueError(f"Failed to parse YAML workflow: {e}")
 

src/praisonai/pyproject.toml

@@ -133,6 +133,8 @@ all = [
     "pymongo>=4.6.0", 
     "psycopg2-binary>=2.9.0",
     "boto3>=1.35.0",
+    # n8n integration
+    "httpx>=0.27.0",
 ]
 bot = [
     # Dependencies for Telegram, Discord, Slack, and WhatsApp bots
@@ -213,6 +215,8 @@ claw = [
     "pymongo>=4.6.0", 
     "psycopg2-binary>=2.9.0",
     "boto3>=1.35.0",
+    # n8n integration
+    "httpx>=0.27.0",
 ]
 n8n = [
     "httpx>=0.27.0",