🎨 Run autopep8 to reformat code

Author: agmangas

api/routes.py

@@ -20,7 +20,8 @@ def validate_non_empty_string(cls, v: str) -> str:
 
 
 @router.post("/connector/initiate")
-async def initiate_negotiation_and_transfer(request: NegotiationRequest = Body(...)):
+async def initiate_negotiation_and_transfer(
+        request: NegotiationRequest = Body(...)):
     try:
         return await run_edcpy_negotiation_and_transfer(
             request.asset_id,

config.py

@@ -1,16 +1,22 @@
 import os
 
 # Configuration
-DASHBOARD_BACKEND_URL = os.environ.get("DASHBOARD_BACKEND_URL", "http://dashboard_backend:28000")
+DASHBOARD_BACKEND_URL = os.environ.get(
+    "DASHBOARD_BACKEND_URL",
+    "http://dashboard_backend:28000")
 
 # API Keys
 DASHBOARD_API_KEY = os.environ.get("DASHBOARD_API_KEY", "dashboard-api-key")
 
 # Connector Ports
-DASHBOARD_CONNECTOR_MANAGEMENT_PORT = int(os.environ.get("DASHBOARD_CONNECTOR_MANAGEMENT_PORT", 29193))
-DASHBOARD_CONNECTOR_CONTROL_PORT = int(os.environ.get("DASHBOARD_CONNECTOR_CONTROL_PORT", 29192))
-DASHBOARD_CONNECTOR_PUBLIC_PORT = int(os.environ.get("DASHBOARD_CONNECTOR_PUBLIC_PORT", 29291))
-DASHBOARD_CONNECTOR_PROTOCOL_PORT = int(os.environ.get("DASHBOARD_CONNECTOR_PROTOCOL_PORT", 29194))
+DASHBOARD_CONNECTOR_MANAGEMENT_PORT = int(
+    os.environ.get("DASHBOARD_CONNECTOR_MANAGEMENT_PORT", 29193))
+DASHBOARD_CONNECTOR_CONTROL_PORT = int(
+    os.environ.get("DASHBOARD_CONNECTOR_CONTROL_PORT", 29192))
+DASHBOARD_CONNECTOR_PUBLIC_PORT = int(
+    os.environ.get("DASHBOARD_CONNECTOR_PUBLIC_PORT", 29291))
+DASHBOARD_CONNECTOR_PROTOCOL_PORT = int(
+    os.environ.get("DASHBOARD_CONNECTOR_PROTOCOL_PORT", 29194))
 
 
 # SSE Data Prefix Length

edc_connector/edc_config.py

@@ -41,4 +41,4 @@ def create_edc_config() -> AppConfig:
     connector.api_key_header = API_KEY_HEADER
 
     config.connector = connector
-    return config
+    return config

edc_connector/sse_receiver.py

@@ -59,7 +59,8 @@ async def _process_sse_line(self, line: str):
 
                 if transfer_id:
                     self.credentials[transfer_id] = data
-                    logger.info(f"Received credentials for transfer {transfer_id}:")
+                    logger.info(
+                        f"Received credentials for transfer {transfer_id}:")
 
                     logger.debug(
                         f"SSE message for transfer '{transfer_id}':\n{pprint.pformat(data)}"
@@ -78,12 +79,13 @@ async def get_credentials(
 
             await asyncio.sleep(SSE_POLL_INTERVAL_SECONDS)
 
-        raise TimeoutError(f"Credentials not received for transfer {transfer_id}")
+        raise TimeoutError(
+            f"Credentials not received for transfer {transfer_id}")
 
     async def stop_listening(self):
         """Stop listening for SSE messages"""
 
         self._listening = False
 
         if self._client:
-            await self._client.aclose()
+            await self._client.aclose()

logger_config.py

@@ -21,4 +21,5 @@ def setup_logging(level: str = "DEBUG") -> logging.Logger:
 
     return logger
 
-logger = setup_logging(level="DEBUG")
+
+logger = setup_logging(level="DEBUG")

main.py

@@ -2,7 +2,6 @@
 from api.routes import router
 
 
-
 app = FastAPI(
     title="Dashboard Backend API",
     description="Dashboard backend that orchestrates connector negotiation and transfer via connectors",
@@ -12,10 +11,11 @@
 
 app.include_router(router=router, prefix="/api")
 
+
 @app.get("/health")
 async def health_check():
     """Health check endpoint"""
     return {
         "status": "healthy",
         "service": "Dashboard Orchestrator"
-    }
+    }

poetry.lock

@@ -19,3 +19,7 @@ dependencies = [
 [build-system]
 requires = ["poetry-core>=2.0.0,<3.0.0"]
 build-backend = "poetry.core.masonry.api"
+
+[tool.poetry.group.dev.dependencies]
+autopep8 = "^2.3.2"
+

pyproject.toml

@@ -6,27 +6,32 @@
 from config import DASHBOARD_BACKEND_URL, DASHBOARD_API_KEY
 
 
-
-async def run_edcpy_negotiation_and_transfer(asset_id: str, provider_connector_protocol_url: str, provider_connector_id: str, provider_host: str) -> dict:
+async def run_edcpy_negotiation_and_transfer(
+        asset_id: str,
+        provider_connector_protocol_url: str,
+        provider_connector_id: str,
+        provider_host: str) -> dict:
     """Use edcpy to handle contract negotiation and transfer process"""
     try:
         # Initialize EDC controller with custom config
         edc_config = create_edc_config()
         controller = ConnectorController(config=edc_config)
 
         # Start SSE listener for credentials
-        sse_receiver = SSEPullCredentialsReceiver(DASHBOARD_BACKEND_URL, DASHBOARD_API_KEY)
+        sse_receiver = SSEPullCredentialsReceiver(
+            DASHBOARD_BACKEND_URL, DASHBOARD_API_KEY)
 
         # Start listening in the background
-        listen_task = asyncio.create_task(sse_receiver.start_listening(provider_host))
+        listen_task = asyncio.create_task(
+            sse_receiver.start_listening(provider_host))
 
         try:
             # Run negotiation flow
             logger.info(f"Starting negotiation for asset {asset_id}")
 
             transfer_details = await controller.run_negotiation_flow(
                 counter_party_protocol_url=provider_connector_protocol_url,
-                counter_party_connector_id= provider_connector_id,
+                counter_party_connector_id=provider_connector_id,
                 asset_query=asset_id
             )
 
@@ -49,15 +54,18 @@ async def run_edcpy_negotiation_and_transfer(asset_id: str, provider_connector_p
             endpoint_url = credentials.get("endpoint")
 
             if not bearer_token:
-                logger.error(f"No access token in received credentials for transfer {transfer_id}")
-                raise Exception("No auth_code (access token) in received credentials")
-            
+                logger.error(
+                    f"No access token in received credentials for transfer {transfer_id}")
+                raise Exception(
+                    "No auth_code (access token) in received credentials")
+
             if not endpoint_url:
-                logger.error(f"No endpoint URL in received credentials for transfer {transfer_id}")
+                logger.error(
+                    f"No endpoint URL in received credentials for transfer {transfer_id}")
                 raise Exception("No endpoint in received credentials")
-            
+
             return {"bearer_token": bearer_token, "endpoint_url": endpoint_url}
-        
+
         finally:
             # Stop SSE listener
             await sse_receiver.stop_listening()
@@ -70,4 +78,4 @@ async def run_edcpy_negotiation_and_transfer(asset_id: str, provider_connector_p
 
     except Exception as e:
         logger.error(f"EDC negotiation and transfer failed: {e}")
-        raise
+        raise

services/edcpy_service.py

@@ -1,5 +1,7 @@
+from urllib.parse import urlparse
 from config import AUTHORIZATION_HEADER, CONTENT_TYPE_HEADER, ACCEPT_HEADER, JSON_CONTENT_TYPE, SSE_CONTENT_TYPE
 
+
 def build_headers(token: str, sse: bool = False, bearer: bool = True) -> dict:
     """
     Construct headers for API requests.
@@ -23,7 +25,6 @@ def build_headers(token: str, sse: bool = False, bearer: bool = True) -> dict:
 
     return headers
 
-from urllib.parse import urlparse
 
 def _extract_hostname(host: str) -> str:
     """
@@ -68,4 +69,4 @@ def _extract_hostname(host: str) -> str:
     if ":" in netloc:
         netloc = netloc.split(":", 1)[0]
 
-    return netloc
+    return netloc