style: fix ruff linting issues

- Apply ruff auto-fixes for 36 code style issues
- Convert datetime.timezone.utc to datetime.UTC alias
- Ensure code quality standards compliance

Author: jaschadub

.gitignore

@@ -77,4 +77,6 @@ site/
 .mkdocs_cache/
 
 PYPI_DISTRIBUTION_PLAN.md
-MockLoop_CLI*
+MockLoop_CLI*
+
+.roo

src/mockloop_mcp/mcp_audit_logger.py

@@ -9,7 +9,7 @@
 import sqlite3
 import time
 import uuid
-from datetime import datetime, timezone
+from datetime import datetime, timezone, UTC
 from pathlib import Path
 from typing import Any, Union
 import hashlib
@@ -312,7 +312,7 @@ def log_tool_execution(
             Unique entry ID for the logged event
         """
         entry_id = str(uuid.uuid4())
-        timestamp = datetime.now(timezone.utc).isoformat()
+        timestamp = datetime.now(UTC).isoformat()
 
         # Generate content hash if enabled
         content_hash = None
@@ -433,7 +433,7 @@ def log_resource_access(
             Unique entry ID for the logged event
         """
         entry_id = str(uuid.uuid4())
-        timestamp = datetime.now(timezone.utc).isoformat()
+        timestamp = datetime.now(UTC).isoformat()
 
         # Generate content hash if enabled
         content_hash = None
@@ -542,7 +542,7 @@ def log_context_operation(
             Unique entry ID for the logged event
         """
         entry_id = str(uuid.uuid4())
-        timestamp = datetime.now(timezone.utc).isoformat()
+        timestamp = datetime.now(UTC).isoformat()
 
         try:
             with sqlite3.connect(self.db_path) as conn:
@@ -624,7 +624,7 @@ def log_prompt_invocation(
             Unique entry ID for the logged event
         """
         entry_id = str(uuid.uuid4())
-        timestamp = datetime.now(timezone.utc).isoformat()
+        timestamp = datetime.now(UTC).isoformat()
 
         # Use generated_output if provided, otherwise use execution_result
         output_data = (
@@ -781,7 +781,7 @@ def cleanup_expired_logs(self) -> int:
             Number of deleted log entries
         """
         try:
-            current_time = datetime.now(timezone.utc).isoformat()
+            current_time = datetime.now(UTC).isoformat()
 
             with sqlite3.connect(self.db_path) as conn:
                 cursor = conn.cursor()

src/mockloop_mcp/mcp_compliance.py

@@ -12,7 +12,7 @@
 import csv
 import json
 import sqlite3
-from datetime import datetime, timezone, timedelta
+from datetime import datetime, timezone, timedelta, UTC
 from pathlib import Path
 from typing import Any, Optional, Union
 from dataclasses import dataclass
@@ -164,9 +164,9 @@ def generate_compliance_report(
 
         # Set default date range if not provided
         if not end_date:
-            end_date = datetime.now(timezone.utc).isoformat()
+            end_date = datetime.now(UTC).isoformat()
         if not start_date:
-            start_date = (datetime.now(timezone.utc) - timedelta(days=30)).isoformat()
+            start_date = (datetime.now(UTC) - timedelta(days=30)).isoformat()
 
         # Query audit logs for the period
         audit_logs = self._query_audit_logs(start_date, end_date)
@@ -179,7 +179,7 @@ def generate_compliance_report(
             report_id=self._generate_report_id(),
             report_type=f"{regulation.value}_compliance",
             regulation=regulation.value,
-            generated_at=datetime.now(timezone.utc).isoformat(),
+            generated_at=datetime.now(UTC).isoformat(),
             period_start=start_date,
             period_end=end_date,
             total_operations=len(audit_logs),
@@ -357,7 +357,7 @@ def generate_data_lineage_report(
                 "source_statistics": source_stats,
                 "total_entries": len(lineage_map),
                 "unique_sources": len(source_stats),
-                "generated_at": datetime.now(timezone.utc).isoformat(),
+                "generated_at": datetime.now(UTC).isoformat(),
             }
 
     def check_retention_compliance(self) -> dict[str, Any]:
@@ -367,7 +367,7 @@ def check_retention_compliance(self) -> dict[str, Any]:
         Returns:
             Retention compliance report
         """
-        current_time = datetime.now(timezone.utc)
+        current_time = datetime.now(UTC)
 
         with sqlite3.connect(str(self.audit_db_path)) as conn:
             conn.row_factory = sqlite3.Row
@@ -434,7 +434,7 @@ def purge_expired_data(self, dry_run: bool = True) -> dict[str, Any]:
         Returns:
             Purge operation results
         """
-        current_time = datetime.now(timezone.utc)
+        current_time = datetime.now(UTC)
 
         with sqlite3.connect(str(self.audit_db_path)) as conn:
             conn.row_factory = sqlite3.Row
@@ -529,7 +529,7 @@ def generate_privacy_impact_assessment(
             "risk_analysis": risk_analysis,
             "recommendations": recommendations,
             "compliance_status": risk_analysis.get("overall_risk_level", "unknown"),
-            "generated_at": datetime.now(timezone.utc).isoformat(),
+            "generated_at": datetime.now(UTC).isoformat(),
         }
 
     def _query_audit_logs(
@@ -634,7 +634,7 @@ def _analyze_compliance(
             "metadata": {
                 "regulation": regulation.value,
                 "total_logs_analyzed": len(audit_logs),
-                "analysis_timestamp": datetime.now(timezone.utc).isoformat(),
+                "analysis_timestamp": datetime.now(UTC).isoformat(),
             },
         }
 

src/mockloop_mcp/mcp_resources.py

@@ -26,7 +26,7 @@
 import hashlib
 from functools import wraps
 from typing import Any, Optional
-from datetime import datetime, timezone
+from datetime import datetime, timezone, UTC
 
 # Handle imports for different execution contexts
 if __package__ is None or __package__ == "":
@@ -43,7 +43,7 @@
 # Resource metadata and versioning
 RESOURCE_VERSION = "1.0.0"
 RESOURCE_SCHEMA_VERSION = "1.0"
-LAST_UPDATED = datetime.now(timezone.utc).isoformat()
+LAST_UPDATED = datetime.now(UTC).isoformat()
 
 # Resource categories and their scenario packs
 SCENARIO_PACK_CATEGORIES = {
@@ -1496,5 +1496,5 @@ def get_resource_integrity_info(pack_data: dict[str, Any]) -> dict[str, Any]:
         "is_valid": is_valid,
         "validation_errors": errors,
         "content_size": len(json.dumps(pack_data)),
-        "last_validated": datetime.now(timezone.utc).isoformat(),
+        "last_validated": datetime.now(UTC).isoformat(),
     }

src/mockloop_mcp/mcp_tools.py

@@ -21,7 +21,7 @@
 import logging
 import time
 import uuid
-from datetime import datetime, timezone
+from datetime import datetime, timezone, UTC
 from functools import wraps
 from pathlib import Path
 from typing import Any, Optional, Union
@@ -874,7 +874,7 @@ async def run_test_iteration(
         # Record start time
         start_time = time.time()
         iteration_result["start_time"] = datetime.fromtimestamp(
-            start_time, tz=timezone.utc
+            start_time, tz=UTC
         ).isoformat()
 
         # Get initial metrics if monitoring is enabled
@@ -891,7 +891,7 @@ async def run_test_iteration(
         # Record end time
         end_time = time.time()
         iteration_result["end_time"] = datetime.fromtimestamp(
-            end_time, tz=timezone.utc
+            end_time, tz=UTC
         ).isoformat()
 
         # Collect final metrics
@@ -1114,7 +1114,7 @@ async def create_mcp_plugin(
             "mode": mode,
             "spec_source": spec_url_or_path,
             "target_url": target_url,
-            "created_at": datetime.now(timezone.utc).isoformat(),
+            "created_at": datetime.now(UTC).isoformat(),
             "plugin_config": {},
             "mcp_config": {},
             "mock_server_path": None,
@@ -1274,7 +1274,7 @@ async def create_mcp_plugin(
             "mode": mode,
             "spec_source": spec_url_or_path,
             "error": f"Plugin creation failed: {e!s}",
-            "created_at": datetime.now(timezone.utc).isoformat(),
+            "created_at": datetime.now(UTC).isoformat(),
             "plugin_config": {},
             "mcp_config": {},
             "mock_server_path": None,
@@ -1778,7 +1778,7 @@ def _generate_session_summary(session_data: dict[str, Any]) -> dict[str, Any]:
 def _calculate_next_execution(schedule_config: dict[str, Any]) -> str:
     """Calculate next execution time."""
     # Simplified implementation
-    return datetime.now(timezone.utc).isoformat()
+    return datetime.now(UTC).isoformat()
 
 
 def _validate_test_suite(test_suite: dict[str, Any]) -> dict[str, bool]:
@@ -2246,7 +2246,7 @@ async def generate_test_report(
             "report_id": str(uuid.uuid4()),
             "report_format": report_format,
             "output_format": output_format,
-            "generated_at": datetime.now(timezone.utc).isoformat(),
+            "generated_at": datetime.now(UTC).isoformat(),
             "report_content": {},
             "chart_data": None,
             "export_data": None,
@@ -2299,7 +2299,7 @@ async def generate_test_report(
             "report_format": report_format,
             "output_format": output_format,
             "error": f"Report generation failed: {e!s}",
-            "generated_at": datetime.now(timezone.utc).isoformat(),
+            "generated_at": datetime.now(UTC).isoformat(),
             "report_content": {},
             "chart_data": None,
             "export_data": None,
@@ -2543,7 +2543,7 @@ async def create_test_session(
             "status": "success",
             "session_id": session_id,
             "session_name": session_name,
-            "created_at": datetime.now(timezone.utc).isoformat(),
+            "created_at": datetime.now(UTC).isoformat(),
             "test_plan": test_plan,
             "session_config": session_config or {},
             "session_state": "created",
@@ -2567,7 +2567,7 @@ async def create_test_session(
             "session_id": None,
             "session_name": session_name,
             "error": f"Test session creation failed: {e!s}",
-            "created_at": datetime.now(timezone.utc).isoformat(),
+            "created_at": datetime.now(UTC).isoformat(),
             "test_plan": {},
             "session_config": {},
             "session_state": "error",
@@ -2595,14 +2595,14 @@ async def end_test_session(
                 "status": "error",
                 "session_id": session_id,
                 "error": "Test session not found",
-                "ended_at": datetime.now(timezone.utc).isoformat(),
+                "ended_at": datetime.now(UTC).isoformat(),
                 "final_report": None,
                 "session_summary": {},
             }
 
         session_data = _active_test_sessions[session_id]
         session_data["session_state"] = "completed"
-        session_data["ended_at"] = datetime.now(timezone.utc).isoformat()
+        session_data["ended_at"] = datetime.now(UTC).isoformat()
 
         end_result = {
             "status": "success",
@@ -2636,7 +2636,7 @@ async def end_test_session(
             "status": "error",
             "session_id": session_id,
             "error": f"Test session completion failed: {e!s}",
-            "ended_at": datetime.now(timezone.utc).isoformat(),
+            "ended_at": datetime.now(UTC).isoformat(),
             "final_report": None,
             "session_summary": {},
         }
@@ -2667,7 +2667,7 @@ async def schedule_test_suite(
             "test_suite": test_suite,
             "schedule_config": schedule_config,
             "notification_config": notification_config or {},
-            "created_at": datetime.now(timezone.utc).isoformat(),
+            "created_at": datetime.now(UTC).isoformat(),
             "next_execution": _calculate_next_execution(schedule_config),
             "schedule_state": "active",
             "validation_result": _validate_test_suite(test_suite),
@@ -2691,7 +2691,7 @@ async def schedule_test_suite(
             "test_suite": {},
             "schedule_config": {},
             "notification_config": {},
-            "created_at": datetime.now(timezone.utc).isoformat(),
+            "created_at": datetime.now(UTC).isoformat(),
             "next_execution": None,
             "schedule_state": "error",
             "validation_result": {"valid": False, "errors": []},
@@ -2722,7 +2722,7 @@ async def monitor_test_progress(
                 "progress": {},
                 "performance_data": {},
                 "alerts": [],
-                "monitoring_timestamp": datetime.now(timezone.utc).isoformat(),
+                "monitoring_timestamp": datetime.now(UTC).isoformat(),
             }
 
         session_data = _active_test_sessions[session_id]
@@ -2736,7 +2736,7 @@ async def monitor_test_progress(
             "progress_percentage": _calculate_progress_percentage(progress),
             "performance_data": {},
             "alerts": [],
-            "monitoring_timestamp": datetime.now(timezone.utc).isoformat(),
+            "monitoring_timestamp": datetime.now(UTC).isoformat(),
         }
 
         # Include performance data if requested
@@ -2773,7 +2773,7 @@ async def monitor_test_progress(
             "progress": {},
             "performance_data": {},
             "alerts": [],
-            "monitoring_timestamp": datetime.now(timezone.utc).isoformat(),
+            "monitoring_timestamp": datetime.now(UTC).isoformat(),
         }
 
 
@@ -3099,7 +3099,7 @@ async def _register_mcp_plugin(plugin_config: PluginConfig) -> dict[str, Any]:
             "status": "success",
             "registered": True,
             "plugin_id": plugin_config.mcp_server_name,
-            "registration_time": datetime.now(timezone.utc).isoformat(),
+            "registration_time": datetime.now(UTC).isoformat(),
             "message": f"Plugin {plugin_config.plugin_name} registered successfully",
         }
 
@@ -3111,7 +3111,7 @@ async def _register_mcp_plugin(plugin_config: PluginConfig) -> dict[str, Any]:
             "status": "error",
             "registered": False,
             "error": str(e),
-            "registration_time": datetime.now(timezone.utc).isoformat(),
+            "registration_time": datetime.now(UTC).isoformat(),
         }
 
 

tests/unit/test_mcp_audit_logging.py

@@ -12,7 +12,7 @@
 import sqlite3
 import tempfile
 import unittest
-from datetime import datetime, timezone
+from datetime import datetime, timezone, UTC
 from pathlib import Path
 from unittest.mock import AsyncMock, MagicMock, patch
 
@@ -287,7 +287,7 @@ def test_cleanup_expired_logs(self):
             cursor = conn.cursor()
 
             # Insert a log entry that's already expired
-            past_time = datetime.now(timezone.utc).replace(year=2020).isoformat()
+            past_time = datetime.now(UTC).replace(year=2020).isoformat()
             cursor.execute(
                 """
                 INSERT INTO mcp_audit_logs (
@@ -490,7 +490,7 @@ def test_purge_expired_data_dry_run(self):
         # First, create an expired entry
         with sqlite3.connect(str(self.db_path)) as conn:
             cursor = conn.cursor()
-            past_time = datetime.now(timezone.utc).replace(year=2020).isoformat()
+            past_time = datetime.now(UTC).replace(year=2020).isoformat()
             cursor.execute(
                 """
                 INSERT INTO mcp_audit_logs (