Compare commits
2 Commits
67f26070f0
...
3352d63f36
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
3352d63f36 | ||
|
|
848162ae21 |
@@ -13,11 +13,11 @@ p2p_bind_host=0.0.0.0
|
||||
p2p_bind_port=8005
|
||||
proposer_id=aitbc1genesis
|
||||
proposer_key=changeme_hex_private_key
|
||||
keystore_path=/opt/aitbc/keystore
|
||||
keystore_password_file=/opt/aitbc/keystore/.password
|
||||
keystore_path=/var/lib/aitbc/keystore
|
||||
keystore_password_file=/var/lib/aitbc/keystore/.password
|
||||
gossip_backend=broadcast
|
||||
gossip_broadcast_url=redis://127.0.0.1:6379
|
||||
db_path=/opt/aitbc/data/ait-mainnet/chain.db
|
||||
db_path=/var/lib/aitbc/data/ait-mainnet/chain.db
|
||||
mint_per_unit=0
|
||||
coordinator_ratio=0.05
|
||||
block_time_seconds=60
|
||||
|
||||
8
.gitea/workflows/aitbc.code-workspace
Normal file
8
.gitea/workflows/aitbc.code-workspace
Normal file
@@ -0,0 +1,8 @@
|
||||
{
|
||||
"folders": [
|
||||
{
|
||||
"path": "../.."
|
||||
}
|
||||
],
|
||||
"settings": {}
|
||||
}
|
||||
7
.gitignore
vendored
7
.gitignore
vendored
@@ -45,6 +45,13 @@ htmlcov/
|
||||
data/
|
||||
apps/blockchain-node/data/
|
||||
|
||||
# ===================
|
||||
# Runtime Directories (System Standard)
|
||||
# ===================
|
||||
/var/lib/aitbc/
|
||||
/etc/aitbc/
|
||||
/var/log/aitbc/
|
||||
|
||||
# ===================
|
||||
# Logs & Runtime
|
||||
# ===================
|
||||
|
||||
45
SETUP.md
45
SETUP.md
@@ -32,16 +32,43 @@ sudo ./setup.sh
|
||||
- Installs dependencies from `requirements.txt` when available
|
||||
- Falls back to core dependencies if requirements missing
|
||||
|
||||
4. **Systemd Services**
|
||||
4. **Runtime Directories**
|
||||
- Creates standard Linux directories:
|
||||
- `/var/lib/aitbc/keystore/` - Blockchain keys
|
||||
- `/var/lib/aitbc/data/` - Database files
|
||||
- `/var/lib/aitbc/logs/` - Application logs
|
||||
- `/etc/aitbc/` - Configuration files
|
||||
- Sets proper permissions and ownership
|
||||
|
||||
5. **Systemd Services**
|
||||
- Installs service files to `/etc/systemd/system/`
|
||||
- Enables auto-start on boot
|
||||
- Provides fallback manual startup
|
||||
|
||||
5. **Service Management**
|
||||
6. **Service Management**
|
||||
- Creates `/opt/aitbc/start-services.sh` for manual control
|
||||
- Creates `/opt/aitbc/health-check.sh` for monitoring
|
||||
- Sets up logging to `/var/log/aitbc-*.log`
|
||||
|
||||
## Runtime Directories
|
||||
|
||||
AITBC uses standard Linux system directories for runtime data:
|
||||
|
||||
```
|
||||
/var/lib/aitbc/
|
||||
├── keystore/ # Blockchain private keys (700 permissions)
|
||||
├── data/ # Database files (.db, .sqlite)
|
||||
└── logs/ # Application logs
|
||||
|
||||
/etc/aitbc/ # Configuration files
|
||||
/var/log/aitbc/ # System logging (symlink)
|
||||
```
|
||||
|
||||
### Security Notes
|
||||
- **Keystore**: Restricted to root/aitbc user only
|
||||
- **Data**: Writable by services, readable by admin
|
||||
- **Logs**: Rotated automatically by logrotate
|
||||
|
||||
## Service Endpoints
|
||||
|
||||
| Service | Port | Health Endpoint |
|
||||
@@ -60,10 +87,13 @@ sudo ./setup.sh
|
||||
# Restart all services
|
||||
/opt/aitbc/start-services.sh
|
||||
|
||||
# View logs
|
||||
tail -f /var/log/aitbc-wallet.log
|
||||
tail -f /var/log/aitbc-coordinator.log
|
||||
tail -f /var/log/aitbc-exchange.log
|
||||
# View logs (new standard locations)
|
||||
tail -f /var/lib/aitbc/logs/aitbc-wallet.log
|
||||
tail -f /var/lib/aitbc/logs/aitbc-coordinator.log
|
||||
tail -f /var/lib/aitbc/logs/aitbc-exchange.log
|
||||
|
||||
# Check keystore
|
||||
ls -la /var/lib/aitbc/keystore/
|
||||
|
||||
# Systemd control
|
||||
systemctl status aitbc-wallet
|
||||
@@ -74,9 +104,10 @@ systemctl stop aitbc-exchange-api
|
||||
## Troubleshooting
|
||||
|
||||
### Services Not Starting
|
||||
1. Check logs: `tail -f /var/log/aitbc-*.log`
|
||||
1. Check logs: `tail -f /var/lib/aitbc/logs/aitbc-*.log`
|
||||
2. Verify ports: `netstat -tlnp | grep ':800'`
|
||||
3. Check processes: `ps aux | grep python`
|
||||
4. Verify runtime directories: `ls -la /var/lib/aitbc/`
|
||||
|
||||
### Missing Dependencies
|
||||
The setup script handles missing `requirements.txt` files by installing core dependencies:
|
||||
|
||||
53
aitbc-env
Executable file
53
aitbc-env
Executable file
@@ -0,0 +1,53 @@
|
||||
#!/bin/bash
|
||||
# AITBC Virtual Environment Wrapper
|
||||
# This script activates the central AITBC virtual environment
|
||||
|
||||
# Check if venv exists
|
||||
if [ ! -d "/opt/aitbc/venv" ]; then
|
||||
echo "❌ AITBC virtual environment not found at /opt/aitbc/venv"
|
||||
echo "Run: sudo python3 -m venv /opt/aitbc/venv && pip install -r /opt/aitbc/requirements.txt"
|
||||
exit 1
|
||||
fi
|
||||
|
||||
# Activate the virtual environment
|
||||
source /opt/aitbc/venv/bin/activate
|
||||
|
||||
# Set up environment (avoid aitbc-core logging conflict)
|
||||
export PYTHONPATH="/opt/aitbc/packages/py/aitbc-sdk/src:/opt/aitbc/packages/py/aitbc-crypto/src:$PYTHONPATH"
|
||||
export AITBC_VENV="/opt/aitbc/venv"
|
||||
export PATH="/opt/aitbc/venv/bin:$PATH"
|
||||
|
||||
# Show status
|
||||
echo "✅ AITBC Virtual Environment Activated"
|
||||
echo "📍 Python: $(which python)"
|
||||
echo "📍 Pip: $(which pip)"
|
||||
echo "📦 Packages: $(pip list | wc -l) installed"
|
||||
|
||||
# CLI alias function
|
||||
aitbc() {
|
||||
if [ -f "/opt/aitbc/cli/core/main.py" ]; then
|
||||
cd /opt/aitbc/cli
|
||||
PYTHONPATH=/opt/aitbc/cli:/opt/aitbc/packages/py/aitbc-sdk/src:/opt/aitbc/packages/py/aitbc-crypto/src python -m core.main "$@"
|
||||
cd - > /dev/null
|
||||
else
|
||||
echo "❌ AITBC CLI not found at /opt/aitbc/cli/core/main.py"
|
||||
return 1
|
||||
fi
|
||||
}
|
||||
|
||||
# Execute command or start shell
|
||||
if [ $# -eq 0 ]; then
|
||||
echo "🚀 Starting interactive shell..."
|
||||
echo "💡 Use 'aitbc <command>' for CLI operations"
|
||||
exec bash
|
||||
else
|
||||
echo "🔧 Executing: $@"
|
||||
if [ "$1" = "aitbc" ]; then
|
||||
shift
|
||||
cd /opt/aitbc/cli
|
||||
PYTHONPATH=/opt/aitbc/cli:/opt/aitbc/packages/py/aitbc-sdk/src:/opt/aitbc/packages/py/aitbc-crypto/src python -m core.main "$@"
|
||||
cd - > /dev/null
|
||||
else
|
||||
exec "$@"
|
||||
fi
|
||||
fi
|
||||
@@ -1,8 +0,0 @@
|
||||
# AITBC Blockchain Explorer Requirements - Enhanced Version
|
||||
# Compatible with Python 3.13+
|
||||
|
||||
fastapi>=0.111.0
|
||||
uvicorn[standard]>=0.30.0
|
||||
httpx>=0.27.0
|
||||
pydantic>=2.0.0
|
||||
python-multipart>=0.0.6
|
||||
@@ -2,7 +2,7 @@ import sqlite3
|
||||
|
||||
def fix():
|
||||
try:
|
||||
conn = sqlite3.connect('/opt/aitbc/data/ait-mainnet/chain.db')
|
||||
conn = sqlite3.connect('/var/lib/aitbc/data/ait-mainnet/chain.db')
|
||||
cur = conn.cursor()
|
||||
|
||||
cur.execute('PRAGMA table_info("block")')
|
||||
|
||||
@@ -2,7 +2,7 @@ import sqlite3
|
||||
|
||||
def fix():
|
||||
try:
|
||||
conn = sqlite3.connect('/opt/aitbc/data/chain.db')
|
||||
conn = sqlite3.connect('/var/lib/aitbc/data/chain.db')
|
||||
cur = conn.cursor()
|
||||
|
||||
cur.execute('PRAGMA table_info("block")')
|
||||
|
||||
@@ -2,7 +2,7 @@ import sqlite3
|
||||
|
||||
def fix():
|
||||
try:
|
||||
conn = sqlite3.connect('/opt/aitbc/data/ait-mainnet/chain.db')
|
||||
conn = sqlite3.connect('/var/lib/aitbc/data/ait-mainnet/chain.db')
|
||||
cur = conn.cursor()
|
||||
|
||||
cur.execute('PRAGMA table_info("transaction")')
|
||||
|
||||
@@ -3,7 +3,7 @@ import sqlite3
|
||||
def fix_db():
|
||||
print("Fixing transaction table on aitbc node...")
|
||||
|
||||
conn = sqlite3.connect('/opt/aitbc/data/ait-mainnet/chain.db')
|
||||
conn = sqlite3.connect('/var/lib/aitbc/data/ait-mainnet/chain.db')
|
||||
cursor = conn.cursor()
|
||||
|
||||
try:
|
||||
|
||||
@@ -23,7 +23,7 @@ python-dotenv = "^1.0.1"
|
||||
httpx = "^0.27.0"
|
||||
uvloop = ">=0.22.0"
|
||||
rich = "^13.7.1"
|
||||
cryptography = "^46.0.5"
|
||||
cryptography = "^46.0.6"
|
||||
asyncpg = ">=0.29.0"
|
||||
requests = "^2.33.0"
|
||||
# Pin starlette to a version with Broadcast (removed in 0.38)
|
||||
|
||||
@@ -1,27 +0,0 @@
|
||||
# AITBC Blockchain Node Requirements
|
||||
# Generated from pyproject.toml dependencies
|
||||
|
||||
# Core Framework
|
||||
fastapi>=0.111.0
|
||||
uvicorn[standard]>=0.30.0
|
||||
|
||||
# Data & Database
|
||||
sqlmodel>=0.0.16
|
||||
sqlalchemy>=2.0.30
|
||||
alembic>=1.13.1
|
||||
aiosqlite>=0.20.0
|
||||
|
||||
# WebSocket Support
|
||||
websockets>=12.0
|
||||
|
||||
# Validation & Configuration
|
||||
pydantic>=2.7.0
|
||||
pydantic-settings>=2.2.1
|
||||
|
||||
# Performance
|
||||
orjson>=3.10.0
|
||||
|
||||
# Local Dependencies
|
||||
# Note: These should be installed in development mode with:
|
||||
# pip install -e ../../packages/py/aitbc-crypto
|
||||
# pip install -e ../../packages/py/aitbc-sdk
|
||||
@@ -20,7 +20,7 @@ class ChainSettings(BaseSettings):
|
||||
|
||||
chain_id: str = ""
|
||||
supported_chains: str = "ait-devnet" # Comma-separated list of supported chain IDs
|
||||
db_path: Path = Path("/opt/aitbc/data/chain.db")
|
||||
db_path: Path = Path("/var/lib/aitbc/data/chain.db")
|
||||
|
||||
rpc_bind_host: str = "127.0.0.1"
|
||||
rpc_bind_port: int = 8080
|
||||
@@ -62,8 +62,8 @@ class ChainSettings(BaseSettings):
|
||||
gossip_broadcast_url: Optional[str] = None
|
||||
|
||||
# Keystore for proposer private key (future block signing)
|
||||
keystore_path: Path = Path("/opt/aitbc/data/keystore")
|
||||
keystore_password_file: Path = Path("/opt/aitbc/data/keystore/.password")
|
||||
keystore_path: Path = Path("/var/lib/aitbc/keystore")
|
||||
keystore_password_file: Path = Path("/var/lib/aitbc/keystore/.password")
|
||||
|
||||
|
||||
settings = ChainSettings()
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
APP_ENV=dev
|
||||
APP_HOST=127.0.0.1
|
||||
APP_PORT=8011
|
||||
DATABASE_URL=sqlite:////opt/aitbc/data/coordinator.db
|
||||
DATABASE_URL=sqlite:////var/lib/aitbc/data/coordinator.db
|
||||
CLIENT_API_KEYS=${CLIENT_API_KEY},client_dev_key_2
|
||||
MINER_API_KEYS=${MINER_API_KEY},miner_dev_key_2
|
||||
ADMIN_API_KEYS=${ADMIN_API_KEY}
|
||||
|
||||
@@ -1,40 +0,0 @@
|
||||
# AITBC Coordinator API Requirements
|
||||
# Generated from pyproject.toml dependencies
|
||||
|
||||
# Core Framework
|
||||
fastapi>=0.111.0
|
||||
uvicorn[standard]>=0.30.0
|
||||
gunicorn>=22.0.0
|
||||
|
||||
# Data & Validation
|
||||
pydantic>=2.7.0
|
||||
pydantic-settings>=2.2.1
|
||||
sqlalchemy>=2.0.30
|
||||
aiosqlite>=0.20.0
|
||||
sqlmodel>=0.0.16
|
||||
numpy>=1.26.0
|
||||
tenseal
|
||||
# concrete-ml # Optional - requires Python <3.13, currently incompatible
|
||||
|
||||
# HTTP & Networking
|
||||
httpx>=0.27.0
|
||||
|
||||
# Configuration & Environment
|
||||
python-dotenv>=1.0.1
|
||||
|
||||
# Rate Limiting & Performance
|
||||
slowapi>=0.1.8
|
||||
orjson>=3.10.0
|
||||
|
||||
# Monitoring
|
||||
prometheus-client>=0.19.0
|
||||
|
||||
# Local Dependencies
|
||||
# Note: These should be installed in development mode with:
|
||||
# pip install -e ../../packages/py/aitbc-crypto
|
||||
# pip install -e ../../packages/py/aitbc-sdk
|
||||
|
||||
# Development Dependencies (optional)
|
||||
# pytest>=8.2.0
|
||||
# pytest-asyncio>=0.23.0
|
||||
# httpx[cli]>=0.27.0
|
||||
@@ -8,7 +8,7 @@ import json
|
||||
from decimal import Decimal
|
||||
|
||||
# Database configurations
|
||||
SQLITE_DB = "/opt/aitbc/data/coordinator.db"
|
||||
SQLITE_DB = "/var/lib/aitbc/data/coordinator.db"
|
||||
PG_CONFIG = {
|
||||
"host": "localhost",
|
||||
"database": "aitbc_coordinator",
|
||||
|
||||
@@ -16,7 +16,7 @@ from decimal import Decimal
|
||||
import json
|
||||
|
||||
# Database configurations
|
||||
SQLITE_DB = "/opt/aitbc/data/coordinator.db"
|
||||
SQLITE_DB = "/var/lib/aitbc/data/coordinator.db"
|
||||
PG_CONFIG = {
|
||||
"host": "localhost",
|
||||
"database": "aitbc_coordinator",
|
||||
|
||||
@@ -9,7 +9,8 @@ from typing import Dict, List, Optional, Any, Tuple
|
||||
from uuid import uuid4
|
||||
import json
|
||||
import hashlib
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from sqlmodel import Session, select, update, delete
|
||||
from sqlalchemy.exc import SQLAlchemyError
|
||||
@@ -21,7 +22,7 @@ from ..domain.agent_identity import (
|
||||
CrossChainMappingUpdate, IdentityVerificationCreate
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class AgentIdentityCore:
|
||||
|
||||
@@ -8,7 +8,8 @@ from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any, Tuple
|
||||
from uuid import uuid4
|
||||
import json
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from sqlmodel import Session, select, update, delete
|
||||
from sqlalchemy.exc import SQLAlchemyError
|
||||
@@ -25,7 +26,7 @@ from .core import AgentIdentityCore
|
||||
from .registry import CrossChainRegistry
|
||||
from .wallet_adapter import MultiChainWalletAdapter
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class AgentIdentityManager:
|
||||
|
||||
@@ -9,7 +9,8 @@ from typing import Dict, List, Optional, Any, Set
|
||||
from uuid import uuid4
|
||||
import json
|
||||
import hashlib
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from sqlmodel import Session, select, update, delete
|
||||
from sqlalchemy.exc import SQLAlchemyError
|
||||
@@ -19,7 +20,7 @@ from ..domain.agent_identity import (
|
||||
IdentityStatus, VerificationType, ChainType
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class CrossChainRegistry:
|
||||
|
||||
@@ -9,7 +9,8 @@ from datetime import datetime
|
||||
from typing import Dict, List, Optional, Any, Union
|
||||
from decimal import Decimal
|
||||
import json
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from sqlmodel import Session, select, update
|
||||
from sqlalchemy.exc import SQLAlchemyError
|
||||
@@ -19,7 +20,7 @@ from ..domain.agent_identity import (
|
||||
AgentWalletCreate, AgentWalletUpdate
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class WalletAdapter(ABC):
|
||||
|
||||
@@ -13,7 +13,8 @@ from uuid import uuid4
|
||||
from enum import Enum
|
||||
import hashlib
|
||||
import secrets
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from sqlmodel import Session, select, update, delete, func, Field
|
||||
from sqlalchemy.exc import SQLAlchemyError
|
||||
@@ -25,7 +26,7 @@ from ..domain.agent_identity import (
|
||||
from ..domain.cross_chain_reputation import CrossChainReputationAggregation
|
||||
from ..reputation.engine import CrossChainReputationEngine
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class WalletStatus(str, Enum):
|
||||
|
||||
@@ -30,7 +30,7 @@ class DatabaseConfig(BaseSettings):
|
||||
|
||||
# Default SQLite path - consistent with blockchain-node pattern
|
||||
if self.adapter == "sqlite":
|
||||
return "sqlite:////opt/aitbc/data/coordinator.db"
|
||||
return "sqlite:////var/lib/aitbc/data/coordinator.db"
|
||||
|
||||
# Default PostgreSQL connection string
|
||||
return f"{self.adapter}://localhost:5432/coordinator"
|
||||
@@ -187,7 +187,7 @@ class Settings(BaseSettings):
|
||||
if self.database.url:
|
||||
return self.database.url
|
||||
# Default SQLite path - consistent with blockchain-node pattern
|
||||
return "sqlite:////opt/aitbc/data/coordinator.db"
|
||||
return "sqlite:////var/lib/aitbc/data/coordinator.db"
|
||||
|
||||
@database_url.setter
|
||||
def database_url(self, value: str):
|
||||
|
||||
@@ -7,7 +7,7 @@ from .marketplace import MarketplaceOffer, MarketplaceBid
|
||||
from .user import User, Wallet, Transaction, UserSession
|
||||
from .payment import JobPayment, PaymentEscrow
|
||||
from .gpu_marketplace import GPURegistry, ConsumerGPUProfile, EdgeGPUMetrics, GPUBooking, GPUReview
|
||||
from .agent import AIAgentWorkflow, AgentStep, AgentExecution, AgentStepExecution, AgentMarketplace
|
||||
from .agent import AIAgentWorkflow, AgentStep, AgentExecution, AgentStepExecution, AgentMarketplace, AgentStatus
|
||||
|
||||
__all__ = [
|
||||
"Job",
|
||||
@@ -31,4 +31,5 @@ __all__ = [
|
||||
"AgentExecution",
|
||||
"AgentStepExecution",
|
||||
"AgentMarketplace",
|
||||
"AgentStatus",
|
||||
]
|
||||
|
||||
@@ -80,11 +80,12 @@ except ImportError:
|
||||
print("WARNING: ML ZK proofs router not available (missing dependencies)")
|
||||
from .storage.models_governance import GovernanceProposal, ProposalVote, TreasuryTransaction, GovernanceParameter
|
||||
from .exceptions import AITBCError, ErrorResponse
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
from .config import settings
|
||||
from .storage.db import init_db
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
from contextlib import asynccontextmanager
|
||||
|
||||
|
||||
@@ -30,11 +30,12 @@ from .routers.marketplace_enhanced_simple import router as marketplace_enhanced
|
||||
from .routers.openclaw_enhanced_simple import router as openclaw_enhanced
|
||||
from .storage.models_governance import GovernanceProposal, ProposalVote, TreasuryTransaction, GovernanceParameter
|
||||
from .exceptions import AITBCError, ErrorResponse
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
from .config import settings
|
||||
from .storage.db import init_db
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
def create_app() -> FastAPI:
|
||||
|
||||
@@ -20,9 +20,10 @@ from .routers.marketplace_offers import router as marketplace_offers
|
||||
from .routers.marketplace_enhanced_simple import router as marketplace_enhanced
|
||||
from .routers.openclaw_enhanced_simple import router as openclaw_enhanced
|
||||
from .exceptions import AITBCError, ErrorResponse
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
def create_app() -> FastAPI:
|
||||
|
||||
@@ -8,7 +8,8 @@ from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any, Set
|
||||
from uuid import uuid4
|
||||
import json
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from sqlmodel import Session, select, update, delete, func
|
||||
from sqlalchemy.exc import SQLAlchemyError
|
||||
@@ -19,7 +20,7 @@ from ..domain.cross_chain_reputation import (
|
||||
CrossChainReputationConfig, ReputationMetrics
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class CrossChainReputationAggregator:
|
||||
|
||||
@@ -9,7 +9,8 @@ from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any, Tuple
|
||||
from uuid import uuid4
|
||||
import json
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from sqlmodel import Session, select, update, delete, func
|
||||
from sqlalchemy.exc import SQLAlchemyError
|
||||
@@ -20,7 +21,7 @@ from ..domain.cross_chain_reputation import (
|
||||
CrossChainReputationConfig, ReputationMetrics
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class CrossChainReputationEngine:
|
||||
|
||||
@@ -10,12 +10,15 @@ from datetime import datetime
|
||||
import sys
|
||||
import psutil
|
||||
from typing import Dict, Any
|
||||
import logging
|
||||
|
||||
from ..storage import get_session
|
||||
from ..services.adaptive_learning import AdaptiveLearningService
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
from ..logging import get_logger
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
|
||||
|
||||
@@ -11,9 +11,10 @@ from ..services import JobService, MinerService
|
||||
from ..storage import get_session
|
||||
from ..utils.cache import cached, get_cache_config
|
||||
from ..config import settings
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
logger = get_logger(__name__)
|
||||
limiter = Limiter(key_func=get_remote_address)
|
||||
router = APIRouter(prefix="/admin", tags=["admin"])
|
||||
|
||||
|
||||
@@ -9,7 +9,8 @@ from datetime import datetime
|
||||
from typing import Dict, List, Optional, Any
|
||||
from fastapi import APIRouter, HTTPException, Depends, Query, Body
|
||||
from pydantic import BaseModel, Field
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from ..storage import get_session
|
||||
from ..services.creative_capabilities_service import (
|
||||
@@ -17,7 +18,7 @@ from ..services.creative_capabilities_service import (
|
||||
)
|
||||
from ..domain.agent_performance import CreativeCapability
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/v1/agent-creativity", tags=["agent-creativity"])
|
||||
|
||||
|
||||
@@ -7,7 +7,8 @@ Provides REST API endpoints for production deployment and integration management
|
||||
|
||||
from fastapi import APIRouter, Depends, HTTPException, BackgroundTasks
|
||||
from typing import List, Optional
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from ..domain.agent import (
|
||||
AIAgentWorkflow, AgentExecution, AgentStatus, VerificationLevel
|
||||
@@ -21,7 +22,7 @@ from ..deps import require_admin_key
|
||||
from sqlmodel import Session, select
|
||||
from datetime import datetime
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/agents/integration", tags=["Agent Integration"])
|
||||
|
||||
|
||||
@@ -9,7 +9,8 @@ from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any
|
||||
from fastapi import APIRouter, HTTPException, Depends, Query
|
||||
from pydantic import BaseModel, Field
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from ..storage import get_session
|
||||
from ..services.agent_performance_service import (
|
||||
@@ -23,7 +24,7 @@ from ..domain.agent_performance import (
|
||||
OptimizationTarget
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/v1/agent-performance", tags=["agent-performance"])
|
||||
|
||||
|
||||
@@ -8,7 +8,8 @@ Provides REST API endpoints for agent workflow management and execution
|
||||
from fastapi import APIRouter, Depends, HTTPException, BackgroundTasks
|
||||
from typing import List, Optional
|
||||
from datetime import datetime
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from ..domain.agent import (
|
||||
AIAgentWorkflow, AgentWorkflowCreate, AgentWorkflowUpdate,
|
||||
@@ -20,7 +21,7 @@ from ..storage import get_session
|
||||
from ..deps import require_admin_key
|
||||
from sqlmodel import Session, select
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/agents", tags=["AI Agents"])
|
||||
|
||||
|
||||
@@ -7,7 +7,8 @@ Provides REST API endpoints for security management and auditing
|
||||
|
||||
from fastapi import APIRouter, Depends, HTTPException, BackgroundTasks
|
||||
from typing import List, Optional
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from ..domain.agent import (
|
||||
AIAgentWorkflow, AgentExecution, AgentStatus, VerificationLevel
|
||||
@@ -21,7 +22,7 @@ from ..storage import get_session
|
||||
from ..deps import require_admin_key
|
||||
from sqlmodel import Session, select
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/agents/security", tags=["Agent Security"])
|
||||
|
||||
|
||||
@@ -9,7 +9,8 @@ from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any
|
||||
from fastapi import APIRouter, HTTPException, Depends, Query
|
||||
from pydantic import BaseModel, Field
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from ..storage import get_session
|
||||
from ..services.analytics_service import MarketplaceAnalytics
|
||||
@@ -18,7 +19,7 @@ from ..domain.analytics import (
|
||||
AnalyticsPeriod, MetricType, InsightType, ReportType
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/v1/analytics", tags=["analytics"])
|
||||
|
||||
|
||||
@@ -1,9 +1,10 @@
|
||||
from __future__ import annotations
|
||||
|
||||
from fastapi import APIRouter, HTTPException
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
logger = get_logger(__name__)
|
||||
router = APIRouter(tags=["blockchain"])
|
||||
|
||||
|
||||
|
||||
@@ -20,7 +20,7 @@ from ..services.bounty_service import BountyService
|
||||
from ..services.blockchain_service import BlockchainService
|
||||
from ..auth import get_current_user
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
# Pydantic models for request/response
|
||||
|
||||
@@ -8,9 +8,10 @@ from slowapi.util import get_remote_address
|
||||
from ..deps import require_admin_key
|
||||
from ..utils.cache_management import get_cache_stats, clear_cache, warm_cache
|
||||
from ..config import settings
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
logger = get_logger(__name__)
|
||||
limiter = Limiter(key_func=get_remote_address)
|
||||
router = APIRouter(prefix="/cache", tags=["cache-management"])
|
||||
|
||||
|
||||
@@ -9,7 +9,8 @@ from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any
|
||||
from fastapi import APIRouter, HTTPException, Depends, Query
|
||||
from pydantic import BaseModel, Field
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from ..storage import get_session
|
||||
from ..services.certification_service import (
|
||||
@@ -22,7 +23,7 @@ from ..domain.certification import (
|
||||
PartnershipType, BadgeType
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/v1/certification", tags=["certification"])
|
||||
|
||||
|
||||
@@ -9,7 +9,8 @@ from datetime import datetime
|
||||
from typing import Dict, List, Optional, Any
|
||||
from fastapi import APIRouter, HTTPException, Depends, Query, Body
|
||||
from pydantic import BaseModel, Field
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from ..storage import get_session
|
||||
from ..services.community_service import (
|
||||
@@ -21,7 +22,7 @@ from ..domain.community import (
|
||||
CommunityPost, Hackathon, DeveloperTier, SolutionStatus, LabStatus
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/community", tags=["community"])
|
||||
|
||||
|
||||
@@ -27,7 +27,7 @@ from ..services.access_control import AccessController
|
||||
from ..auth import get_api_key
|
||||
from ..logging import get_logger
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
# Initialize router and security
|
||||
router = APIRouter(prefix="/confidential", tags=["confidential"])
|
||||
|
||||
@@ -16,7 +16,7 @@ from ..domain.bounty import EcosystemMetrics, BountyStats, AgentMetrics
|
||||
from ..services.ecosystem_service import EcosystemService
|
||||
from ..auth import get_current_user
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
# Pydantic models for request/response
|
||||
|
||||
@@ -11,9 +11,10 @@ import json
|
||||
import os
|
||||
from slowapi import Limiter
|
||||
from slowapi.util import get_remote_address
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
logger = get_logger(__name__)
|
||||
limiter = Limiter(key_func=get_remote_address)
|
||||
|
||||
from ..schemas import (
|
||||
|
||||
@@ -9,7 +9,8 @@ from datetime import datetime
|
||||
from typing import Dict, List, Optional, Any
|
||||
from fastapi import APIRouter, HTTPException, Depends, Query, Body
|
||||
from pydantic import BaseModel, Field
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from ..storage import get_session
|
||||
from ..services.governance_service import GovernanceService
|
||||
@@ -18,7 +19,7 @@ from ..domain.governance import (
|
||||
ProposalStatus, VoteType, GovernanceRole
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/governance", tags=["governance"])
|
||||
|
||||
|
||||
@@ -16,7 +16,7 @@ from ..storage import get_session
|
||||
from ..services.multimodal_agent import MultiModalAgentService
|
||||
from ..logging import get_logger
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
|
||||
|
||||
@@ -13,9 +13,10 @@ from ..storage import get_session
|
||||
from ..metrics import marketplace_requests_total, marketplace_errors_total
|
||||
from ..utils.cache import cached, get_cache_config
|
||||
from ..config import settings
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
logger = get_logger(__name__)
|
||||
limiter = Limiter(key_func=get_remote_address)
|
||||
router = APIRouter(tags=["marketplace"])
|
||||
|
||||
|
||||
@@ -6,7 +6,8 @@ REST API endpoints for advanced marketplace features including royalties, licens
|
||||
"""
|
||||
|
||||
from typing import List, Optional
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from fastapi import APIRouter, HTTPException, Depends
|
||||
from pydantic import BaseModel, Field
|
||||
@@ -22,7 +23,7 @@ from ..schemas.marketplace_enhanced import (
|
||||
MarketplaceAnalyticsRequest, MarketplaceAnalyticsResponse
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/marketplace/enhanced", tags=["Enhanced Marketplace"])
|
||||
|
||||
|
||||
@@ -15,7 +15,7 @@ from ..storage import get_session
|
||||
from ..services.marketplace_enhanced import EnhancedMarketplaceService
|
||||
from ..logging import get_logger
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
|
||||
|
||||
@@ -6,7 +6,8 @@ REST API endpoints for enhanced marketplace features
|
||||
"""
|
||||
|
||||
from typing import List, Optional, Dict, Any
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from fastapi import APIRouter, HTTPException, Depends
|
||||
from pydantic import BaseModel, Field
|
||||
@@ -16,7 +17,7 @@ from ..storage import get_session
|
||||
from ..deps import require_admin_key
|
||||
from sqlmodel import Session
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/marketplace/enhanced", tags=["Marketplace Enhanced"])
|
||||
|
||||
|
||||
@@ -10,7 +10,8 @@ from datetime import datetime
|
||||
from typing import Dict, List, Optional, Any
|
||||
from fastapi import APIRouter, HTTPException, Depends, Query, BackgroundTasks
|
||||
from pydantic import BaseModel, Field
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from ..storage import get_session
|
||||
import sys
|
||||
@@ -22,7 +23,7 @@ from aitbc.gpu_acceleration.parallel_processing.marketplace_cache_optimizer impo
|
||||
from aitbc.gpu_acceleration.parallel_processing.marketplace_monitor import monitor as marketplace_monitor
|
||||
from aitbc.gpu_acceleration.parallel_processing.marketplace_scaler import ResourceScaler, ScalingPolicy
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/v1/marketplace/performance", tags=["marketplace-performance"])
|
||||
|
||||
|
||||
@@ -13,9 +13,10 @@ from ..services import JobService, MinerService
|
||||
from ..services.receipts import ReceiptService
|
||||
from ..config import settings
|
||||
from ..storage import get_session
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
logger = get_logger(__name__)
|
||||
limiter = Limiter(key_func=get_remote_address)
|
||||
router = APIRouter(tags=["miner"])
|
||||
|
||||
|
||||
@@ -15,7 +15,7 @@ from ..storage import get_session
|
||||
from ..services.multimodal_agent import MultiModalAgentService
|
||||
from ..logging import get_logger
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
|
||||
|
||||
@@ -15,7 +15,7 @@ from typing import Dict, Any, List
|
||||
from ..storage import get_session
|
||||
from ..logging import get_logger
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
# Templates would be stored in a templates directory in production
|
||||
|
||||
@@ -9,7 +9,8 @@ from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any
|
||||
from fastapi import APIRouter, Depends, HTTPException, Query, BackgroundTasks, WebSocket, WebSocketDisconnect
|
||||
from pydantic import BaseModel, Field
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from ..storage import get_session
|
||||
from ..services.multi_modal_fusion import MultiModalFusionEngine
|
||||
@@ -19,7 +20,7 @@ from ..domain.agent_performance import (
|
||||
CreativeCapability
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/multi-modal-rl", tags=["multi-modal-rl"])
|
||||
|
||||
|
||||
@@ -15,7 +15,7 @@ from ..storage import get_session
|
||||
from ..services.multimodal_agent import MultiModalAgentService
|
||||
from ..logging import get_logger
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
|
||||
|
||||
@@ -6,7 +6,8 @@ REST API endpoints for advanced agent orchestration, edge computing integration,
|
||||
"""
|
||||
|
||||
from typing import List, Optional
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from fastapi import APIRouter, HTTPException, Depends
|
||||
from pydantic import BaseModel, Field
|
||||
@@ -25,7 +26,7 @@ from ..schemas.openclaw_enhanced import (
|
||||
EcosystemDevelopmentRequest, EcosystemDevelopmentResponse
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/openclaw/enhanced", tags=["OpenClaw Enhanced"])
|
||||
|
||||
|
||||
@@ -16,7 +16,7 @@ from ..storage import get_session
|
||||
from ..services.openclaw_enhanced import OpenClawEnhancedService
|
||||
from ..logging import get_logger
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
|
||||
|
||||
@@ -6,7 +6,8 @@ REST API endpoints for OpenClaw integration features
|
||||
"""
|
||||
|
||||
from typing import List, Optional, Dict, Any
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from fastapi import APIRouter, HTTPException, Depends
|
||||
from pydantic import BaseModel, Field
|
||||
@@ -16,7 +17,7 @@ from ..storage import get_session
|
||||
from ..deps import require_admin_key
|
||||
from sqlmodel import Session
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/openclaw/enhanced", tags=["OpenClaw Enhanced"])
|
||||
|
||||
|
||||
@@ -9,7 +9,8 @@ from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any
|
||||
from fastapi import APIRouter, HTTPException, Depends, Query
|
||||
from pydantic import BaseModel, Field
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from ..storage import get_session
|
||||
from ..services.reputation_service import ReputationService
|
||||
@@ -19,7 +20,7 @@ from ..domain.reputation import (
|
||||
)
|
||||
from sqlmodel import select, func, Field
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/v1/reputation", tags=["reputation"])
|
||||
|
||||
|
||||
@@ -9,7 +9,8 @@ from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any
|
||||
from fastapi import APIRouter, HTTPException, Depends, Query
|
||||
from pydantic import BaseModel, Field
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from ..storage import get_session
|
||||
from ..services.reward_service import RewardEngine
|
||||
@@ -17,7 +18,7 @@ from ..domain.rewards import (
|
||||
AgentRewardProfile, RewardTier, RewardType, RewardStatus
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/v1/rewards", tags=["rewards"])
|
||||
|
||||
|
||||
@@ -20,7 +20,7 @@ from ..services.staking_service import StakingService
|
||||
from ..services.blockchain_service import BlockchainService
|
||||
from ..auth import get_current_user
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
# Pydantic models for request/response
|
||||
|
||||
@@ -9,7 +9,8 @@ from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any
|
||||
from fastapi import APIRouter, HTTPException, Depends, Query
|
||||
from pydantic import BaseModel, Field
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from ..storage import get_session
|
||||
from ..services.trading_service import P2PTradingProtocol
|
||||
@@ -18,7 +19,7 @@ from ..domain.trading import (
|
||||
TradeStatus, TradeType, NegotiationStatus, SettlementType
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/v1/trading", tags=["trading"])
|
||||
|
||||
|
||||
@@ -6,7 +6,8 @@ Web Vitals API endpoint for collecting performance metrics
|
||||
from fastapi import APIRouter, HTTPException
|
||||
from pydantic import BaseModel
|
||||
from typing import List, Dict, Any, Optional
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
|
||||
@@ -16,9 +16,10 @@ import jwt
|
||||
import hashlib
|
||||
import secrets
|
||||
from pydantic import BaseModel, Field, validator
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
class SDKVersion(str, Enum):
|
||||
"""SDK version"""
|
||||
|
||||
@@ -12,7 +12,7 @@ from ..schemas import ConfidentialAccessRequest, ConfidentialAccessLog
|
||||
from ..config import settings
|
||||
from ..logging import get_logger
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class AccessPurpose(str, Enum):
|
||||
|
||||
@@ -7,7 +7,8 @@ Reinforcement learning frameworks for agent self-improvement
|
||||
"""
|
||||
|
||||
import asyncio
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
from typing import Dict, List, Any, Optional, Tuple, Union
|
||||
from datetime import datetime, timedelta
|
||||
from enum import Enum
|
||||
@@ -17,7 +18,7 @@ import json
|
||||
from ..storage import get_session
|
||||
from ..domain import AIAgentWorkflow, AgentExecution, AgentStatus
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class LearningAlgorithm(str, Enum):
|
||||
|
||||
@@ -17,7 +17,8 @@ import numpy as np
|
||||
from datetime import datetime
|
||||
import uuid
|
||||
import json
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from .advanced_reinforcement_learning import AdvancedReinforcementLearningEngine
|
||||
from .multi_modal_fusion import MultiModalFusionEngine
|
||||
@@ -25,7 +26,7 @@ from .gpu_multimodal import GPUAcceleratedMultiModal
|
||||
from .advanced_learning import AdvancedLearningService
|
||||
from ..storage import get_session
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
# Pydantic models for API
|
||||
class RLTrainingRequest(BaseModel):
|
||||
|
||||
@@ -4,7 +4,8 @@ Implements meta-learning, federated learning, and continuous model improvement
|
||||
"""
|
||||
|
||||
import asyncio
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
from typing import Dict, List, Any, Optional, Tuple, Union
|
||||
from datetime import datetime, timedelta
|
||||
from enum import Enum
|
||||
@@ -12,7 +13,7 @@ import json
|
||||
import numpy as np
|
||||
from dataclasses import dataclass, asdict, field
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class LearningType(str, Enum):
|
||||
|
||||
@@ -12,7 +12,8 @@ import torch.optim as optim
|
||||
from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any, Tuple, Union
|
||||
from uuid import uuid4
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from sqlmodel import Session, select, update, delete, and_, or_, func
|
||||
from sqlalchemy.exc import SQLAlchemyError
|
||||
@@ -22,7 +23,7 @@ from ..domain.agent_performance import (
|
||||
AgentCapability, FusionModel
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class PPOAgent(nn.Module):
|
||||
|
||||
@@ -4,7 +4,8 @@ Implements secure agent-to-agent messaging with reputation-based access control
|
||||
"""
|
||||
|
||||
import asyncio
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
from typing import Dict, List, Any, Optional, Tuple
|
||||
from datetime import datetime, timedelta
|
||||
from enum import Enum
|
||||
@@ -15,7 +16,7 @@ from dataclasses import dataclass, asdict, field
|
||||
|
||||
from .cross_chain_reputation import CrossChainReputationService, ReputationTier
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class MessageType(str, Enum):
|
||||
|
||||
@@ -5,7 +5,8 @@ Integrates agent orchestration with existing ML ZK proof system and provides dep
|
||||
|
||||
import asyncio
|
||||
import json
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any
|
||||
from uuid import uuid4
|
||||
@@ -44,7 +45,7 @@ class ZKProofService:
|
||||
"details": {"mock": True}
|
||||
}
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class DeploymentStatus(str, Enum):
|
||||
|
||||
@@ -4,7 +4,8 @@ Implements multi-agent coordination and sub-task management
|
||||
"""
|
||||
|
||||
import asyncio
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
from typing import Dict, List, Any, Optional, Tuple, Set
|
||||
from datetime import datetime, timedelta
|
||||
from enum import Enum
|
||||
@@ -14,7 +15,7 @@ from dataclasses import dataclass, asdict, field
|
||||
from .task_decomposition import TaskDecomposition, SubTask, SubTaskStatus, GPU_Tier
|
||||
from .bid_strategy_engine import BidResult, BidStrategy, UrgencyLevel
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class OrchestratorStatus(str, Enum):
|
||||
|
||||
@@ -8,7 +8,8 @@ import numpy as np
|
||||
from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any, Tuple
|
||||
from uuid import uuid4
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from sqlmodel import Session, select, update, delete, and_, or_, func
|
||||
from sqlalchemy.exc import SQLAlchemyError
|
||||
@@ -21,7 +22,7 @@ from ..domain.agent_performance import (
|
||||
OptimizationTarget
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class MetaLearningEngine:
|
||||
|
||||
@@ -6,7 +6,8 @@ Implements comprehensive security, auditing, and trust establishment for agent e
|
||||
import asyncio
|
||||
import hashlib
|
||||
import json
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any, Set
|
||||
from uuid import uuid4
|
||||
@@ -20,7 +21,7 @@ from ..domain.agent import (
|
||||
AgentStatus, VerificationLevel
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class SecurityLevel(str, Enum):
|
||||
|
||||
@@ -8,7 +8,8 @@ from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any
|
||||
from uuid import uuid4
|
||||
import json
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from sqlmodel import Session, select, update, delete
|
||||
from sqlalchemy.exc import SQLAlchemyError
|
||||
@@ -24,7 +25,7 @@ class CoordinatorClient:
|
||||
"""Mock coordinator client for agent orchestration"""
|
||||
pass
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class AgentStateManager:
|
||||
|
||||
@@ -4,7 +4,8 @@ Implements a sophisticated marketplace where agents can offer specialized servic
|
||||
"""
|
||||
|
||||
import asyncio
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
from typing import Dict, List, Any, Optional, Tuple
|
||||
from datetime import datetime, timedelta
|
||||
from enum import Enum
|
||||
@@ -12,7 +13,7 @@ import json
|
||||
import hashlib
|
||||
from dataclasses import dataclass, asdict, field
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class ServiceStatus(str, Enum):
|
||||
|
||||
@@ -9,7 +9,8 @@ from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any, Tuple
|
||||
from uuid import uuid4
|
||||
import json
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from sqlmodel import Session, select, update, delete, and_, or_, func
|
||||
from sqlalchemy.exc import SQLAlchemyError
|
||||
@@ -23,7 +24,7 @@ from ..domain.trading import TradingAnalytics
|
||||
from ..domain.rewards import RewardAnalytics
|
||||
from ..domain.reputation import AgentReputation
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class DataCollector:
|
||||
|
||||
@@ -16,7 +16,7 @@ from ..schemas import ConfidentialAccessLog
|
||||
from ..config import settings
|
||||
from ..logging import get_logger
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
@dataclass
|
||||
|
||||
@@ -4,7 +4,8 @@ Implements intelligent bidding algorithms for GPU rental negotiations
|
||||
"""
|
||||
|
||||
import asyncio
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
from typing import Dict, List, Any, Optional, Tuple
|
||||
from datetime import datetime, timedelta
|
||||
from enum import Enum
|
||||
@@ -12,7 +13,7 @@ import numpy as np
|
||||
import json
|
||||
from dataclasses import dataclass, asdict
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class BidStrategy(str, Enum):
|
||||
|
||||
@@ -6,7 +6,8 @@ Uses RPC to connect to Bitcoin Core (or alternative like Block.io)
|
||||
|
||||
import os
|
||||
import json
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
from typing import Dict, Optional
|
||||
|
||||
try:
|
||||
@@ -16,7 +17,7 @@ except ImportError:
|
||||
HTTP_CLIENT_AVAILABLE = False
|
||||
logging.warning("httpx not available, bitcoin wallet functions will be disabled")
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
# Bitcoin wallet configuration (credentials from environment)
|
||||
WALLET_CONFIG = {
|
||||
|
||||
@@ -4,12 +4,13 @@ Blockchain service for AITBC token operations
|
||||
|
||||
import httpx
|
||||
import asyncio
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
from typing import Optional
|
||||
|
||||
from ..config import settings
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
BLOCKCHAIN_RPC = f"http://127.0.0.1:9080/rpc"
|
||||
|
||||
|
||||
@@ -16,7 +16,7 @@ from ..domain.bounty import (
|
||||
from ..storage import get_session
|
||||
from ..logging import get_logger
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
class BountyService:
|
||||
"""Service for managing AI agent bounties"""
|
||||
|
||||
@@ -9,7 +9,8 @@ import json
|
||||
from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any, Tuple
|
||||
from uuid import uuid4
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from sqlmodel import Session, select, update, delete, and_, or_, func
|
||||
from sqlalchemy.exc import SQLAlchemyError
|
||||
@@ -23,7 +24,7 @@ from ..domain.certification import (
|
||||
from ..domain.reputation import AgentReputation
|
||||
from ..domain.rewards import AgentRewardProfile
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class CertificationSystem:
|
||||
|
||||
@@ -6,7 +6,8 @@ Services for managing OpenClaw developer tools, SDKs, and third-party solutions
|
||||
from typing import Optional, List, Dict, Any
|
||||
from sqlmodel import Session, select
|
||||
from datetime import datetime
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
from uuid import uuid4
|
||||
|
||||
from ..domain.community import (
|
||||
@@ -14,7 +15,7 @@ from ..domain.community import (
|
||||
CommunityPost, Hackathon, DeveloperTier, SolutionStatus, LabStatus
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
class DeveloperEcosystemService:
|
||||
"""Service for managing the developer ecosystem and SDKs"""
|
||||
|
||||
@@ -14,9 +14,10 @@ from enum import Enum
|
||||
from dataclasses import dataclass, field
|
||||
import re
|
||||
from pydantic import BaseModel, Field, validator
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
class ComplianceFramework(str, Enum):
|
||||
"""Compliance frameworks"""
|
||||
|
||||
@@ -8,7 +8,8 @@ import numpy as np
|
||||
from datetime import datetime, timedelta
|
||||
from typing import Dict, List, Optional, Any, Tuple
|
||||
from uuid import uuid4
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
import random
|
||||
|
||||
from sqlmodel import Session, select, update, delete, and_, or_, func
|
||||
@@ -18,7 +19,7 @@ from ..domain.agent_performance import (
|
||||
CreativeCapability, AgentCapability, AgentPerformanceProfile
|
||||
)
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class CreativityEnhancementEngine:
|
||||
|
||||
@@ -12,7 +12,8 @@ from decimal import Decimal
|
||||
from enum import Enum
|
||||
import secrets
|
||||
import hashlib
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
from sqlmodel import Session, select, update, delete, func, Field
|
||||
from sqlalchemy.exc import SQLAlchemyError
|
||||
@@ -28,7 +29,7 @@ from ..agent_identity.wallet_adapter_enhanced import (
|
||||
)
|
||||
from ..reputation.engine import CrossChainReputationEngine
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class BridgeProtocol(str, Enum):
|
||||
|
||||
@@ -4,14 +4,15 @@ Implements portable reputation scores across multiple blockchain networks
|
||||
"""
|
||||
|
||||
import asyncio
|
||||
from aitbc.logging import get_logger
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
from typing import Dict, List, Any, Optional, Tuple
|
||||
from datetime import datetime, timedelta
|
||||
from enum import Enum
|
||||
import json
|
||||
from dataclasses import dataclass, asdict, field
|
||||
|
||||
logger = get_logger(__name__)
|
||||
|
||||
|
||||
|
||||
class ReputationTier(str, Enum):
|
||||
|
||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user