From e9eea6fb22bdb5b6521be0c0dd93e265ec0780ee Mon Sep 17 00:00:00 2001
From: aitbc <aitbc@keisanki.net>
Date: Sat, 25 Apr 2026 07:20:21 +0200
Subject: [PATCH] Migrate remaining coordinator-api files to centralized aitbc
 package utilities

- Migrate main.py, main_minimal.py, main_enhanced.py (logging)
- Migrate utils/ files: metrics.py, cache_management.py, circuit_breaker.py, alerting.py, cache.py
- Migrate storage/ files: db_pg.py, db.py
- Migrate settlement/hooks.py
- Migrate sdk/enterprise_client.py
- Migrate reputation/ files: engine.py, aggregator.py
- Migrate agent_identity/ files: wallet_adapter_enhanced.py, wallet_adapter.py, registry.py, core.py, manager.py, sdk/communication.py
- Migrate services/ files: performance_monitoring.py, multi_modal_websocket_fusion.py, multi_modal_fusion.py
- Remove duplicate logging imports
- Add missing aitbc imports for get_logger
---
 apps/coordinator-api/src/app/agent_identity/core.py          | 5 +++--
 apps/coordinator-api/src/app/agent_identity/manager.py       | 5 +++--
 apps/coordinator-api/src/app/agent_identity/registry.py      | 5 +++--
 .../src/app/agent_identity/sdk/communication.py              | 4 ++--
 .../coordinator-api/src/app/agent_identity/wallet_adapter.py | 5 +++--
 .../src/app/agent_identity/wallet_adapter_enhanced.py        | 4 ++--
 apps/coordinator-api/src/app/main.py                         | 4 ++--
 apps/coordinator-api/src/app/main_enhanced.py                | 4 ++--
 apps/coordinator-api/src/app/main_minimal.py                 | 4 ++--
 apps/coordinator-api/src/app/reputation/aggregator.py        | 5 +++--
 apps/coordinator-api/src/app/reputation/engine.py            | 5 +++--
 apps/coordinator-api/src/app/sdk/enterprise_client.py        | 5 +++--
 apps/coordinator-api/src/app/services/multi_modal_fusion.py  | 1 -
 .../src/app/services/multi_modal_websocket_fusion.py         | 1 -
 .../src/app/services/performance_monitoring.py               | 2 +-
 apps/coordinator-api/src/app/settlement/hooks.py             | 5 +++--
 apps/coordinator-api/src/app/storage/db.py                   | 5 +++--
 apps/coordinator-api/src/app/storage/db_pg.py                | 5 +++--
 apps/coordinator-api/src/app/utils/alerting.py               | 5 +++--
 apps/coordinator-api/src/app/utils/cache.py                  | 5 +++--
 apps/coordinator-api/src/app/utils/cache_management.py       | 4 ++--
 apps/coordinator-api/src/app/utils/circuit_breaker.py        | 5 +++--
 apps/coordinator-api/src/app/utils/metrics.py                | 5 +++--
 23 files changed, 55 insertions(+), 43 deletions(-)

diff --git a/apps/coordinator-api/src/app/agent_identity/core.py b/apps/coordinator-api/src/app/agent_identity/core.py
index c1f398b6..4afbf49e 100755
--- a/apps/coordinator-api/src/app/agent_identity/core.py
+++ b/apps/coordinator-api/src/app/agent_identity/core.py
@@ -5,12 +5,13 @@ Provides unified agent identification and cross-chain compatibility
 
 import hashlib
 import json
-import logging
 from datetime import datetime, timedelta
 from typing import Any
 from uuid import uuid4
 
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 from sqlmodel import Session, select
 
diff --git a/apps/coordinator-api/src/app/agent_identity/manager.py b/apps/coordinator-api/src/app/agent_identity/manager.py
index 22adad40..712a1ae9 100755
--- a/apps/coordinator-api/src/app/agent_identity/manager.py
+++ b/apps/coordinator-api/src/app/agent_identity/manager.py
@@ -3,12 +3,13 @@ Agent Identity Manager Implementation
 High-level manager for agent identity operations and cross-chain management
 """
 
-import logging
 from datetime import datetime
 from typing import Any
 from uuid import uuid4
 
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 from sqlmodel import Session
 
diff --git a/apps/coordinator-api/src/app/agent_identity/registry.py b/apps/coordinator-api/src/app/agent_identity/registry.py
index ec7d33ac..ce2bf60b 100755
--- a/apps/coordinator-api/src/app/agent_identity/registry.py
+++ b/apps/coordinator-api/src/app/agent_identity/registry.py
@@ -5,12 +5,13 @@ Registry for cross-chain agent identity mapping and synchronization
 
 import hashlib
 import json
-import logging
 from datetime import datetime, timedelta
 from typing import Any
 from uuid import uuid4
 
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 from sqlmodel import Session, select
 
diff --git a/apps/coordinator-api/src/app/agent_identity/sdk/communication.py b/apps/coordinator-api/src/app/agent_identity/sdk/communication.py
index e7905818..6207bf9e 100644
--- a/apps/coordinator-api/src/app/agent_identity/sdk/communication.py
+++ b/apps/coordinator-api/src/app/agent_identity/sdk/communication.py
@@ -8,15 +8,15 @@ for forum-like agent interactions using the blockchain messaging contract.
 import asyncio
 import hashlib
 import json
-import logging
 from dataclasses import dataclass
 from datetime import datetime
 from typing import Any, Dict, List, Optional, Union
 
+from aitbc import get_logger
 from .client import AgentIdentityClient
 from .models import AgentIdentity, AgentWallet
 
-logger = logging.getLogger(__name__)
+logger = get_logger(__name__)
 
 @dataclass
 class ForumTopic:
diff --git a/apps/coordinator-api/src/app/agent_identity/wallet_adapter.py b/apps/coordinator-api/src/app/agent_identity/wallet_adapter.py
index 8b34a3c9..eb5fe918 100755
--- a/apps/coordinator-api/src/app/agent_identity/wallet_adapter.py
+++ b/apps/coordinator-api/src/app/agent_identity/wallet_adapter.py
@@ -3,13 +3,14 @@ Multi-Chain Wallet Adapter Implementation
 Provides blockchain-agnostic wallet interface for agents
 """
 
-import logging
 from abc import ABC, abstractmethod
 from datetime import datetime
 from decimal import Decimal
 from typing import Any
 
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 from sqlmodel import Session, select
 
diff --git a/apps/coordinator-api/src/app/agent_identity/wallet_adapter_enhanced.py b/apps/coordinator-api/src/app/agent_identity/wallet_adapter_enhanced.py
index 412fc30f..5a1db7bd 100755
--- a/apps/coordinator-api/src/app/agent_identity/wallet_adapter_enhanced.py
+++ b/apps/coordinator-api/src/app/agent_identity/wallet_adapter_enhanced.py
@@ -5,7 +5,6 @@ Production-ready wallet adapter for cross-chain operations with advanced securit
 
 import hashlib
 import json
-import logging
 import secrets
 from abc import ABC, abstractmethod
 from datetime import datetime
@@ -13,8 +12,9 @@ from decimal import Decimal
 from enum import StrEnum
 from typing import Any
 
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
 
+logger = get_logger(__name__)
 
 from ..domain.agent_identity import ChainType
 
diff --git a/apps/coordinator-api/src/app/main.py b/apps/coordinator-api/src/app/main.py
index cb3d25d4..6120ffa3 100755
--- a/apps/coordinator-api/src/app/main.py
+++ b/apps/coordinator-api/src/app/main.py
@@ -87,11 +87,11 @@ try:
 except ImportError:
     ml_zk_proofs = None
     print("WARNING: ML ZK proofs router not available (missing dependencies)")
-import logging
+from aitbc import get_logger
 
 from .exceptions import AITBCError, ErrorResponse
 
-logger = logging.getLogger(__name__)
+logger = get_logger(__name__)
 from contextlib import asynccontextmanager
 
 from .storage.db import init_db
diff --git a/apps/coordinator-api/src/app/main_enhanced.py b/apps/coordinator-api/src/app/main_enhanced.py
index a810aef2..4777cb93 100755
--- a/apps/coordinator-api/src/app/main_enhanced.py
+++ b/apps/coordinator-api/src/app/main_enhanced.py
@@ -2,7 +2,7 @@
 Enhanced Main Application - Adds new enhanced routers to existing AITBC Coordinator API
 """
 
-import logging
+from aitbc import get_logger
 
 from fastapi import FastAPI
 from fastapi.middleware.cors import CORSMiddleware
@@ -31,7 +31,7 @@ from .routers.openclaw_enhanced_simple import router as openclaw_enhanced
 from .routers.partners import router as partners
 from .storage import init_db
 
-logger = logging.getLogger(__name__)
+logger = get_logger(__name__)
 from .storage.db import init_db
 
 
diff --git a/apps/coordinator-api/src/app/main_minimal.py b/apps/coordinator-api/src/app/main_minimal.py
index cd9c55b4..1abad480 100755
--- a/apps/coordinator-api/src/app/main_minimal.py
+++ b/apps/coordinator-api/src/app/main_minimal.py
@@ -2,7 +2,7 @@
 Minimal Main Application - Only includes existing routers plus enhanced ones
 """
 
-import logging
+from aitbc import get_logger
 
 from fastapi import FastAPI
 from fastapi.middleware.cors import CORSMiddleware
@@ -22,7 +22,7 @@ from .routers.marketplace_offers import router as marketplace_offers
 from .routers.openclaw_enhanced_simple import router as openclaw_enhanced
 from .storage import init_db
 
-logger = logging.getLogger(__name__)
+logger = get_logger(__name__)
 
 
 def create_app() -> FastAPI:
diff --git a/apps/coordinator-api/src/app/reputation/aggregator.py b/apps/coordinator-api/src/app/reputation/aggregator.py
index 8ffefb8d..0c1a2424 100755
--- a/apps/coordinator-api/src/app/reputation/aggregator.py
+++ b/apps/coordinator-api/src/app/reputation/aggregator.py
@@ -3,11 +3,12 @@ Cross-Chain Reputation Aggregator
 Aggregates reputation data from multiple blockchains and normalizes scores
 """
 
-import logging
 from datetime import datetime
 from typing import Any
 
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 from sqlmodel import Session, select
 
diff --git a/apps/coordinator-api/src/app/reputation/engine.py b/apps/coordinator-api/src/app/reputation/engine.py
index 295bbc23..69333e4e 100755
--- a/apps/coordinator-api/src/app/reputation/engine.py
+++ b/apps/coordinator-api/src/app/reputation/engine.py
@@ -3,11 +3,12 @@ Cross-Chain Reputation Engine
 Core reputation calculation and aggregation engine for multi-chain agent reputation
 """
 
-import logging
 from datetime import datetime, timedelta
 from typing import Any
 
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 from sqlmodel import Session, select
 
diff --git a/apps/coordinator-api/src/app/sdk/enterprise_client.py b/apps/coordinator-api/src/app/sdk/enterprise_client.py
index 15d30174..bba58e2e 100755
--- a/apps/coordinator-api/src/app/sdk/enterprise_client.py
+++ b/apps/coordinator-api/src/app/sdk/enterprise_client.py
@@ -4,7 +4,6 @@ Python SDK for enterprise clients to integrate with AITBC platform
 """
 
 import hashlib
-import logging
 import secrets
 from dataclasses import dataclass, field
 from datetime import datetime, timedelta
@@ -14,7 +13,9 @@ from typing import Any
 import aiohttp
 from pydantic import BaseModel
 
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 
 class SDKVersion(StrEnum):
diff --git a/apps/coordinator-api/src/app/services/multi_modal_fusion.py b/apps/coordinator-api/src/app/services/multi_modal_fusion.py
index 332e987d..1f935c88 100755
--- a/apps/coordinator-api/src/app/services/multi_modal_fusion.py
+++ b/apps/coordinator-api/src/app/services/multi_modal_fusion.py
@@ -5,7 +5,6 @@ Phase 5.1: Advanced AI Capabilities Enhancement
 """
 
 import asyncio
-import logging
 from datetime import datetime
 from typing import Any
 from uuid import uuid4
diff --git a/apps/coordinator-api/src/app/services/multi_modal_websocket_fusion.py b/apps/coordinator-api/src/app/services/multi_modal_websocket_fusion.py
index b43fca7a..b013bdc2 100755
--- a/apps/coordinator-api/src/app/services/multi_modal_websocket_fusion.py
+++ b/apps/coordinator-api/src/app/services/multi_modal_websocket_fusion.py
@@ -7,7 +7,6 @@ per-stream backpressure handling and GPU provider flow control.
 
 import asyncio
 import json
-import logging
 import time
 from dataclasses import dataclass, field
 from enum import Enum
diff --git a/apps/coordinator-api/src/app/services/performance_monitoring.py b/apps/coordinator-api/src/app/services/performance_monitoring.py
index 6e83176a..1d1ae92a 100755
--- a/apps/coordinator-api/src/app/services/performance_monitoring.py
+++ b/apps/coordinator-api/src/app/services/performance_monitoring.py
@@ -4,7 +4,6 @@ Real-time performance tracking and optimization recommendations
 """
 
 import json
-import logging
 from collections import defaultdict, deque
 from dataclasses import dataclass
 from datetime import datetime, timedelta
@@ -12,6 +11,7 @@ from typing import Any
 
 import psutil
 import torch
+
 from aitbc import get_logger
 
 logger = get_logger(__name__)
diff --git a/apps/coordinator-api/src/app/settlement/hooks.py b/apps/coordinator-api/src/app/settlement/hooks.py
index 9c857104..f3192e65 100755
--- a/apps/coordinator-api/src/app/settlement/hooks.py
+++ b/apps/coordinator-api/src/app/settlement/hooks.py
@@ -3,11 +3,12 @@ Settlement hooks for coordinator API integration
 """
 
 import asyncio
-import logging
 from datetime import datetime
 from typing import Any
 
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 from ..models.job import Job
 from .bridges.base import BridgeStatus, SettlementMessage, SettlementResult
diff --git a/apps/coordinator-api/src/app/storage/db.py b/apps/coordinator-api/src/app/storage/db.py
index 98a569bb..d4faab00 100755
--- a/apps/coordinator-api/src/app/storage/db.py
+++ b/apps/coordinator-api/src/app/storage/db.py
@@ -6,7 +6,6 @@ Provides SQLite and PostgreSQL support with connection pooling.
 
 from __future__ import annotations
 
-import logging
 from collections.abc import AsyncGenerator, Generator
 from contextlib import asynccontextmanager, contextmanager
 
@@ -17,7 +16,9 @@ from sqlalchemy.orm import Session
 from sqlalchemy.pool import QueuePool
 from sqlmodel import SQLModel
 
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 from ..config import settings
 
diff --git a/apps/coordinator-api/src/app/storage/db_pg.py b/apps/coordinator-api/src/app/storage/db_pg.py
index 4b03322a..d6f41f4b 100755
--- a/apps/coordinator-api/src/app/storage/db_pg.py
+++ b/apps/coordinator-api/src/app/storage/db_pg.py
@@ -1,7 +1,6 @@
 """PostgreSQL database module for Coordinator API"""
 
 import json
-import logging
 from collections.abc import Generator
 from typing import Any
 
@@ -11,7 +10,9 @@ from sqlalchemy import create_engine
 from sqlalchemy.ext.declarative import declarative_base
 from sqlalchemy.orm import Session, sessionmaker
 
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 from datetime import datetime
 
 from .config_pg import settings
diff --git a/apps/coordinator-api/src/app/utils/alerting.py b/apps/coordinator-api/src/app/utils/alerting.py
index 21d2192f..e6d7eb60 100644
--- a/apps/coordinator-api/src/app/utils/alerting.py
+++ b/apps/coordinator-api/src/app/utils/alerting.py
@@ -1,12 +1,13 @@
 import json
-import logging
 import os
 from collections import deque
 from datetime import datetime, timedelta
 from typing import Any
 from urllib import error, request
 
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 
 class AlertDispatcher:
diff --git a/apps/coordinator-api/src/app/utils/cache.py b/apps/coordinator-api/src/app/utils/cache.py
index 0bf693fc..1ec3c4fd 100755
--- a/apps/coordinator-api/src/app/utils/cache.py
+++ b/apps/coordinator-api/src/app/utils/cache.py
@@ -3,12 +3,13 @@ Caching strategy for expensive queries
 """
 
 import hashlib
-import logging
 from datetime import datetime, timedelta
 from functools import wraps
 from typing import Any
 
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 
 class CacheManager:
diff --git a/apps/coordinator-api/src/app/utils/cache_management.py b/apps/coordinator-api/src/app/utils/cache_management.py
index a92dd3ea..18027a40 100755
--- a/apps/coordinator-api/src/app/utils/cache_management.py
+++ b/apps/coordinator-api/src/app/utils/cache_management.py
@@ -2,11 +2,11 @@
 Cache management utilities for endpoints
 """
 
-import logging
+from aitbc import get_logger
 
 from ..utils.cache import cache_manager, cleanup_expired_cache
 
-logger = logging.getLogger(__name__)
+logger = get_logger(__name__)
 
 
 def invalidate_cache_pattern(pattern: str):
diff --git a/apps/coordinator-api/src/app/utils/circuit_breaker.py b/apps/coordinator-api/src/app/utils/circuit_breaker.py
index 6014bef9..6e5c01a4 100755
--- a/apps/coordinator-api/src/app/utils/circuit_breaker.py
+++ b/apps/coordinator-api/src/app/utils/circuit_breaker.py
@@ -3,14 +3,15 @@ Circuit breaker pattern for external services
 """
 
 import asyncio
-import logging
 from collections.abc import Callable
 from datetime import datetime, timedelta
 from enum import Enum
 from functools import wraps
 from typing import Any
 
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 
 class CircuitState(Enum):
diff --git a/apps/coordinator-api/src/app/utils/metrics.py b/apps/coordinator-api/src/app/utils/metrics.py
index e7a68621..bf250b1e 100644
--- a/apps/coordinator-api/src/app/utils/metrics.py
+++ b/apps/coordinator-api/src/app/utils/metrics.py
@@ -3,13 +3,14 @@ Basic Metrics Collection Module
 Collects and tracks system and application metrics for monitoring
 """
 
-import logging
 import os
 import resource
 from datetime import datetime
 from typing import Any
 
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 
 class MetricsCollector: