autoflake8 isort pylint fixes

Signed-off-by: Mihai Criveti <[email protected]>

Author: crivetimihai

.env.example

@@ -289,4 +289,4 @@ DEBUG=false
 
 # Gateway tool name separator
 GATEWAY_TOOL_NAME_SEPARATOR=-
-VALID_SLUG_SEPARATOR_REGEXP= r"^(-{1,2}|[_.])$"
+VALID_SLUG_SEPARATOR_REGEXP= r"^(-{1,2}|[_.])$"

.github/workflows/check-headers.yml.inactive

@@ -36,14 +36,14 @@ on:
       - '**.py'
       - '.github/workflows/check-headers.yml'
       - '.github/tools/fix_file_headers.py'
-  
+
   push:
-    branches: 
+    branches:
       - main
       - master
     paths:
       - '**.py'
-  
+
   workflow_dispatch:
     inputs:
       debug_mode:
@@ -75,7 +75,7 @@ jobs:
   check-headers:
     name: 🔍 Validate Python Headers
     runs-on: ubuntu-latest
-    
+
     steps:
       # -----------------------------------------------------------
       # 0️⃣  Checkout repository
@@ -115,32 +115,32 @@ jobs:
         id: check
         run: |
           echo "🔍 Checking Python file headers..."
-          
+
           # Build command based on inputs
           CHECK_CMD="python3 .github/tools/fix_file_headers.py"
-          
+
           # Add flags based on workflow inputs
           if [[ "${{ inputs.show_diff }}" == "true" ]] || [[ "${{ github.event_name }}" == "pull_request" ]]; then
             CHECK_CMD="$CHECK_CMD --show-diff"
           fi
-          
+
           if [[ "${{ inputs.debug_mode }}" == "true" ]]; then
             CHECK_CMD="$CHECK_CMD --debug"
           fi
-          
+
           echo "🏃 Running: $CHECK_CMD"
-          
+
           # Run check and capture output
           if $CHECK_CMD > header-check-output.txt 2>&1; then
             echo "✅ All Python file headers are correct!"
             echo "check_passed=true" >> $GITHUB_OUTPUT
           else
             echo "❌ Some files have incorrect headers"
             echo "check_passed=false" >> $GITHUB_OUTPUT
-            
+
             # Show the output
             cat header-check-output.txt
-            
+
             # Save summary for PR comment
             echo '```' > header-check-summary.md
             cat header-check-output.txt >> header-check-summary.md
@@ -157,35 +157,35 @@ jobs:
           script: |
             const fs = require('fs');
             const summary = fs.readFileSync('header-check-summary.md', 'utf8');
-            
+
             const body = `## ❌ Python Header Check Failed
-            
+
             Some Python files have incorrect or missing headers. Please fix them before merging.
-            
+
             ### 🔧 How to fix:
-            
+
             1. **Fix all files automatically:**
                \`\`\`bash
                make fix-all-headers
                \`\`\`
-            
+
             2. **Fix specific files:**
                \`\`\`bash
                make fix-header path=path/to/file.py
                \`\`\`
-            
+
             3. **Review changes interactively:**
                \`\`\`bash
                make interactive-fix-headers
                \`\`\`
-            
+
             ### 📋 Check Results:
-            
+
             ${summary}
-            
+
             ---
             🤖 *This check ensures all Python files have proper copyright, license, and author information.*`;
-            
+
             github.rest.issues.createComment({
               issue_number: context.issue.number,
               owner: context.repo.owner,
@@ -223,4 +223,4 @@ jobs:
         if: steps.check.outputs.check_passed == 'true'
         run: |
           echo "✅ All Python file headers are properly formatted!"
-          echo "🎉 No action needed."
+          echo "🎉 No action needed."

README.md

@@ -2131,4 +2131,4 @@ Special thanks to our contributors for helping us improve ContextForge MCP Gatew
 [![Forks](https://img.shields.io/github/forks/ibm/mcp-context-forge?style=social)](https://github.com/ibm/mcp-context-forge/network/members) 
 [![Contributors](https://img.shields.io/github/contributors/ibm/mcp-context-forge)](https://github.com/ibm/mcp-context-forge/graphs/contributors) 
 [![Last Commit](https://img.shields.io/github/last-commit/ibm/mcp-context-forge)](https://github.com/ibm/mcp-context-forge/commits) 
-[![Open Issues](https://img.shields.io/github/issues/ibm/mcp-context-forge)](https://github.com/ibm/mcp-context-forge/issues) 
+[![Open Issues](https://img.shields.io/github/issues/ibm/mcp-context-forge)](https://github.com/ibm/mcp-context-forge/issues) 

docs/docs/using/plugins/index.md

@@ -9,7 +9,7 @@ The MCP Gateway Plugin Framework provides a standardized way to extend gateway f
 
 - **Content Filtering** - PII detection and masking
 - **AI Safety** - Integration with LLMGuard, OpenAI Moderation
-- **Security** - Input validation and output sanitization  
+- **Security** - Input validation and output sanitization
 - **Policy Enforcement** - Business rules and compliance
 - **Transformation** - Request/response modification
 - **Auditing** - Logging and monitoring
@@ -97,13 +97,13 @@ Plugins execute in priority order (ascending):
 plugins:
   - name: "Authentication"
     priority: 10      # Runs first
-    
-  - name: "RateLimiter"  
+
+  - name: "RateLimiter"
     priority: 50      # Runs second
-    
+
   - name: "ContentFilter"
     priority: 100     # Runs third
-    
+
   - name: "Logger"
     priority: 200     # Runs last
 ```
@@ -144,23 +144,23 @@ from mcpgateway.plugins.framework.types import (
 
 class MyPlugin(Plugin):
     """Example plugin implementation."""
-    
+
     def __init__(self, config: PluginConfig):
         super().__init__(config)
         # Initialize plugin-specific configuration
         self.my_setting = config.config.get("my_setting", "default")
-    
+
     async def prompt_pre_fetch(
-        self, 
-        payload: PromptPrehookPayload, 
+        self,
+        payload: PromptPrehookPayload,
         context: PluginContext
     ) -> PromptPrehookResult:
         """Process prompt before retrieval."""
-        
+
         # Access prompt name and arguments
         prompt_name = payload.name
         args = payload.args
-        
+
         # Example: Block requests with forbidden words
         if "forbidden" in str(args.values()).lower():
             return PromptPrehookResult(
@@ -172,40 +172,40 @@ class MyPlugin(Plugin):
                     details={"found_in": "arguments"}
                 )
             )
-        
+
         # Example: Modify arguments
         if "transform_me" in args:
             args["transform_me"] = args["transform_me"].upper()
             return PromptPrehookResult(
                 modified_payload=PromptPrehookPayload(prompt_name, args)
             )
-        
+
         # Allow request to continue unchanged
         return PromptPrehookResult()
-    
+
     async def prompt_post_fetch(
         self,
         payload: PromptPosthookPayload,
         context: PluginContext
     ) -> PromptPosthookResult:
         """Process prompt after rendering."""
-        
+
         # Access rendered prompt
         prompt_result = payload.result
-        
+
         # Example: Add metadata to context
         context.metadata["processed_by"] = self.name
-        
+
         # Example: Modify response
         for message in prompt_result.messages:
             message.content.text = message.content.text.replace(
                 "old_text", "new_text"
             )
-        
+
         return PromptPosthookResult(
             modified_payload=payload
         )
-    
+
     async def shutdown(self):
         """Cleanup when plugin shuts down."""
         # Close connections, save state, etc.
@@ -221,17 +221,17 @@ async def prompt_pre_fetch(self, payload, context):
     # Store state for later use
     context.set_state("request_time", time.time())
     context.set_state("original_args", payload.args.copy())
-    
+
     return PromptPrehookResult()
 
 async def prompt_post_fetch(self, payload, context):
     # Retrieve state from pre-hook
     elapsed = time.time() - context.get_state("request_time", 0)
     original = context.get_state("original_args", {})
-    
+
     # Add timing metadata
     context.metadata["processing_time_ms"] = elapsed * 1000
-    
+
     return PromptPosthookResult()
 ```
 
@@ -240,13 +240,13 @@ async def prompt_post_fetch(self, payload, context):
 ```python
 class LLMGuardPlugin(Plugin):
     """Example external service integration."""
-    
+
     def __init__(self, config: PluginConfig):
         super().__init__(config)
         self.service_url = config.config.get("service_url")
         self.api_key = config.config.get("api_key")
         self.timeout = config.config.get("timeout", 30)
-    
+
     async def prompt_pre_fetch(self, payload, context):
         # Call external service
         async with httpx.AsyncClient() as client:
@@ -262,9 +262,9 @@ class LLMGuardPlugin(Plugin):
                     },
                     timeout=self.timeout
                 )
-                
+
                 result = response.json()
-                
+
                 if result.get("blocked", False):
                     return PromptPrehookResult(
                         continue_processing=False,
@@ -275,7 +275,7 @@ class LLMGuardPlugin(Plugin):
                             details=result
                         )
                     )
-                    
+
             except Exception as e:
                 # Handle errors based on plugin settings
                 if self.config.mode == PluginMode.ENFORCE:
@@ -288,7 +288,7 @@ class LLMGuardPlugin(Plugin):
                             details={"error": str(e)}
                         )
                     )
-        
+
         return PromptPrehookResult()
 ```
 
@@ -357,9 +357,9 @@ async def test_my_plugin():
         hooks=["prompt_pre_fetch"],
         config={"setting_one": "test_value"}
     )
-    
+
     plugin = MyPlugin(config)
-    
+
     # Test your plugin logic
     result = await plugin.prompt_pre_fetch(payload, context)
     assert result.continue_processing
@@ -378,11 +378,11 @@ async def prompt_pre_fetch(self, payload, context):
         pass
     except Exception as e:
         logger.error(f"Plugin {self.name} error: {e}")
-        
+
         # In permissive mode, log and continue
         if self.mode == PluginMode.PERMISSIVE:
             return PromptPrehookResult()
-        
+
         # In enforce mode, block the request
         return PromptPrehookResult(
             continue_processing=False,
@@ -408,17 +408,17 @@ class CachedPlugin(Plugin):
         super().__init__(config)
         self._cache = {}
         self._cache_ttl = config.config.get("cache_ttl", 300)
-    
+
     async def expensive_operation(self, key):
         # Check cache first
         if key in self._cache:
             cached_value, timestamp = self._cache[key]
             if time.time() - timestamp < self._cache_ttl:
                 return cached_value
-        
+
         # Perform expensive operation
         result = await self._do_expensive_work(key)
-        
+
         # Cache result
         self._cache[key] = (result, time.time())
         return result

tests/e2e/test_main_apis.py

@@ -639,7 +639,7 @@ async def test_resource_uri_conflict(self, client: AsyncClient, mock_auth):
             assert "already exists" in resp_json["message"]
         else:
             # Accept any error format as long as status is correct
-            assert response.status_code == 409 
+            assert response.status_code == 409
 
     """Test resource management endpoints."""