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
|
p2p_bind_port=8005
|
||||||
proposer_id=aitbc1genesis
|
proposer_id=aitbc1genesis
|
||||||
proposer_key=changeme_hex_private_key
|
proposer_key=changeme_hex_private_key
|
||||||
keystore_path=/opt/aitbc/keystore
|
keystore_path=/var/lib/aitbc/keystore
|
||||||
keystore_password_file=/opt/aitbc/keystore/.password
|
keystore_password_file=/var/lib/aitbc/keystore/.password
|
||||||
gossip_backend=broadcast
|
gossip_backend=broadcast
|
||||||
gossip_broadcast_url=redis://127.0.0.1:6379
|
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
|
mint_per_unit=0
|
||||||
coordinator_ratio=0.05
|
coordinator_ratio=0.05
|
||||||
block_time_seconds=60
|
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/
|
data/
|
||||||
apps/blockchain-node/data/
|
apps/blockchain-node/data/
|
||||||
|
|
||||||
|
# ===================
|
||||||
|
# Runtime Directories (System Standard)
|
||||||
|
# ===================
|
||||||
|
/var/lib/aitbc/
|
||||||
|
/etc/aitbc/
|
||||||
|
/var/log/aitbc/
|
||||||
|
|
||||||
# ===================
|
# ===================
|
||||||
# Logs & Runtime
|
# Logs & Runtime
|
||||||
# ===================
|
# ===================
|
||||||
|
|||||||
45
SETUP.md
45
SETUP.md
@@ -32,16 +32,43 @@ sudo ./setup.sh
|
|||||||
- Installs dependencies from `requirements.txt` when available
|
- Installs dependencies from `requirements.txt` when available
|
||||||
- Falls back to core dependencies if requirements missing
|
- 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/`
|
- Installs service files to `/etc/systemd/system/`
|
||||||
- Enables auto-start on boot
|
- Enables auto-start on boot
|
||||||
- Provides fallback manual startup
|
- Provides fallback manual startup
|
||||||
|
|
||||||
5. **Service Management**
|
6. **Service Management**
|
||||||
- Creates `/opt/aitbc/start-services.sh` for manual control
|
- Creates `/opt/aitbc/start-services.sh` for manual control
|
||||||
- Creates `/opt/aitbc/health-check.sh` for monitoring
|
- Creates `/opt/aitbc/health-check.sh` for monitoring
|
||||||
- Sets up logging to `/var/log/aitbc-*.log`
|
- 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 Endpoints
|
||||||
|
|
||||||
| Service | Port | Health Endpoint |
|
| Service | Port | Health Endpoint |
|
||||||
@@ -60,10 +87,13 @@ sudo ./setup.sh
|
|||||||
# Restart all services
|
# Restart all services
|
||||||
/opt/aitbc/start-services.sh
|
/opt/aitbc/start-services.sh
|
||||||
|
|
||||||
# View logs
|
# View logs (new standard locations)
|
||||||
tail -f /var/log/aitbc-wallet.log
|
tail -f /var/lib/aitbc/logs/aitbc-wallet.log
|
||||||
tail -f /var/log/aitbc-coordinator.log
|
tail -f /var/lib/aitbc/logs/aitbc-coordinator.log
|
||||||
tail -f /var/log/aitbc-exchange.log
|
tail -f /var/lib/aitbc/logs/aitbc-exchange.log
|
||||||
|
|
||||||
|
# Check keystore
|
||||||
|
ls -la /var/lib/aitbc/keystore/
|
||||||
|
|
||||||
# Systemd control
|
# Systemd control
|
||||||
systemctl status aitbc-wallet
|
systemctl status aitbc-wallet
|
||||||
@@ -74,9 +104,10 @@ systemctl stop aitbc-exchange-api
|
|||||||
## Troubleshooting
|
## Troubleshooting
|
||||||
|
|
||||||
### Services Not Starting
|
### 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'`
|
2. Verify ports: `netstat -tlnp | grep ':800'`
|
||||||
3. Check processes: `ps aux | grep python`
|
3. Check processes: `ps aux | grep python`
|
||||||
|
4. Verify runtime directories: `ls -la /var/lib/aitbc/`
|
||||||
|
|
||||||
### Missing Dependencies
|
### Missing Dependencies
|
||||||
The setup script handles missing `requirements.txt` files by installing core 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():
|
def fix():
|
||||||
try:
|
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 = conn.cursor()
|
||||||
|
|
||||||
cur.execute('PRAGMA table_info("block")')
|
cur.execute('PRAGMA table_info("block")')
|
||||||
|
|||||||
@@ -2,7 +2,7 @@ import sqlite3
|
|||||||
|
|
||||||
def fix():
|
def fix():
|
||||||
try:
|
try:
|
||||||
conn = sqlite3.connect('/opt/aitbc/data/chain.db')
|
conn = sqlite3.connect('/var/lib/aitbc/data/chain.db')
|
||||||
cur = conn.cursor()
|
cur = conn.cursor()
|
||||||
|
|
||||||
cur.execute('PRAGMA table_info("block")')
|
cur.execute('PRAGMA table_info("block")')
|
||||||
|
|||||||
@@ -2,7 +2,7 @@ import sqlite3
|
|||||||
|
|
||||||
def fix():
|
def fix():
|
||||||
try:
|
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 = conn.cursor()
|
||||||
|
|
||||||
cur.execute('PRAGMA table_info("transaction")')
|
cur.execute('PRAGMA table_info("transaction")')
|
||||||
|
|||||||
@@ -3,7 +3,7 @@ import sqlite3
|
|||||||
def fix_db():
|
def fix_db():
|
||||||
print("Fixing transaction table on aitbc node...")
|
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()
|
cursor = conn.cursor()
|
||||||
|
|
||||||
try:
|
try:
|
||||||
|
|||||||
@@ -23,7 +23,7 @@ python-dotenv = "^1.0.1"
|
|||||||
httpx = "^0.27.0"
|
httpx = "^0.27.0"
|
||||||
uvloop = ">=0.22.0"
|
uvloop = ">=0.22.0"
|
||||||
rich = "^13.7.1"
|
rich = "^13.7.1"
|
||||||
cryptography = "^46.0.5"
|
cryptography = "^46.0.6"
|
||||||
asyncpg = ">=0.29.0"
|
asyncpg = ">=0.29.0"
|
||||||
requests = "^2.33.0"
|
requests = "^2.33.0"
|
||||||
# Pin starlette to a version with Broadcast (removed in 0.38)
|
# 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 = ""
|
chain_id: str = ""
|
||||||
supported_chains: str = "ait-devnet" # Comma-separated list of supported chain IDs
|
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_host: str = "127.0.0.1"
|
||||||
rpc_bind_port: int = 8080
|
rpc_bind_port: int = 8080
|
||||||
@@ -62,8 +62,8 @@ class ChainSettings(BaseSettings):
|
|||||||
gossip_broadcast_url: Optional[str] = None
|
gossip_broadcast_url: Optional[str] = None
|
||||||
|
|
||||||
# Keystore for proposer private key (future block signing)
|
# Keystore for proposer private key (future block signing)
|
||||||
keystore_path: Path = Path("/opt/aitbc/data/keystore")
|
keystore_path: Path = Path("/var/lib/aitbc/keystore")
|
||||||
keystore_password_file: Path = Path("/opt/aitbc/data/keystore/.password")
|
keystore_password_file: Path = Path("/var/lib/aitbc/keystore/.password")
|
||||||
|
|
||||||
|
|
||||||
settings = ChainSettings()
|
settings = ChainSettings()
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
APP_ENV=dev
|
APP_ENV=dev
|
||||||
APP_HOST=127.0.0.1
|
APP_HOST=127.0.0.1
|
||||||
APP_PORT=8011
|
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
|
CLIENT_API_KEYS=${CLIENT_API_KEY},client_dev_key_2
|
||||||
MINER_API_KEYS=${MINER_API_KEY},miner_dev_key_2
|
MINER_API_KEYS=${MINER_API_KEY},miner_dev_key_2
|
||||||
ADMIN_API_KEYS=${ADMIN_API_KEY}
|
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
|
from decimal import Decimal
|
||||||
|
|
||||||
# Database configurations
|
# Database configurations
|
||||||
SQLITE_DB = "/opt/aitbc/data/coordinator.db"
|
SQLITE_DB = "/var/lib/aitbc/data/coordinator.db"
|
||||||
PG_CONFIG = {
|
PG_CONFIG = {
|
||||||
"host": "localhost",
|
"host": "localhost",
|
||||||
"database": "aitbc_coordinator",
|
"database": "aitbc_coordinator",
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ from decimal import Decimal
|
|||||||
import json
|
import json
|
||||||
|
|
||||||
# Database configurations
|
# Database configurations
|
||||||
SQLITE_DB = "/opt/aitbc/data/coordinator.db"
|
SQLITE_DB = "/var/lib/aitbc/data/coordinator.db"
|
||||||
PG_CONFIG = {
|
PG_CONFIG = {
|
||||||
"host": "localhost",
|
"host": "localhost",
|
||||||
"database": "aitbc_coordinator",
|
"database": "aitbc_coordinator",
|
||||||
|
|||||||
@@ -9,7 +9,8 @@ from typing import Dict, List, Optional, Any, Tuple
|
|||||||
from uuid import uuid4
|
from uuid import uuid4
|
||||||
import json
|
import json
|
||||||
import hashlib
|
import hashlib
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from sqlmodel import Session, select, update, delete
|
from sqlmodel import Session, select, update, delete
|
||||||
from sqlalchemy.exc import SQLAlchemyError
|
from sqlalchemy.exc import SQLAlchemyError
|
||||||
@@ -21,7 +22,7 @@ from ..domain.agent_identity import (
|
|||||||
CrossChainMappingUpdate, IdentityVerificationCreate
|
CrossChainMappingUpdate, IdentityVerificationCreate
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class AgentIdentityCore:
|
class AgentIdentityCore:
|
||||||
|
|||||||
@@ -8,7 +8,8 @@ from datetime import datetime, timedelta
|
|||||||
from typing import Dict, List, Optional, Any, Tuple
|
from typing import Dict, List, Optional, Any, Tuple
|
||||||
from uuid import uuid4
|
from uuid import uuid4
|
||||||
import json
|
import json
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from sqlmodel import Session, select, update, delete
|
from sqlmodel import Session, select, update, delete
|
||||||
from sqlalchemy.exc import SQLAlchemyError
|
from sqlalchemy.exc import SQLAlchemyError
|
||||||
@@ -25,7 +26,7 @@ from .core import AgentIdentityCore
|
|||||||
from .registry import CrossChainRegistry
|
from .registry import CrossChainRegistry
|
||||||
from .wallet_adapter import MultiChainWalletAdapter
|
from .wallet_adapter import MultiChainWalletAdapter
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class AgentIdentityManager:
|
class AgentIdentityManager:
|
||||||
|
|||||||
@@ -9,7 +9,8 @@ from typing import Dict, List, Optional, Any, Set
|
|||||||
from uuid import uuid4
|
from uuid import uuid4
|
||||||
import json
|
import json
|
||||||
import hashlib
|
import hashlib
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from sqlmodel import Session, select, update, delete
|
from sqlmodel import Session, select, update, delete
|
||||||
from sqlalchemy.exc import SQLAlchemyError
|
from sqlalchemy.exc import SQLAlchemyError
|
||||||
@@ -19,7 +20,7 @@ from ..domain.agent_identity import (
|
|||||||
IdentityStatus, VerificationType, ChainType
|
IdentityStatus, VerificationType, ChainType
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class CrossChainRegistry:
|
class CrossChainRegistry:
|
||||||
|
|||||||
@@ -9,7 +9,8 @@ from datetime import datetime
|
|||||||
from typing import Dict, List, Optional, Any, Union
|
from typing import Dict, List, Optional, Any, Union
|
||||||
from decimal import Decimal
|
from decimal import Decimal
|
||||||
import json
|
import json
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from sqlmodel import Session, select, update
|
from sqlmodel import Session, select, update
|
||||||
from sqlalchemy.exc import SQLAlchemyError
|
from sqlalchemy.exc import SQLAlchemyError
|
||||||
@@ -19,7 +20,7 @@ from ..domain.agent_identity import (
|
|||||||
AgentWalletCreate, AgentWalletUpdate
|
AgentWalletCreate, AgentWalletUpdate
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class WalletAdapter(ABC):
|
class WalletAdapter(ABC):
|
||||||
|
|||||||
@@ -13,7 +13,8 @@ from uuid import uuid4
|
|||||||
from enum import Enum
|
from enum import Enum
|
||||||
import hashlib
|
import hashlib
|
||||||
import secrets
|
import secrets
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from sqlmodel import Session, select, update, delete, func, Field
|
from sqlmodel import Session, select, update, delete, func, Field
|
||||||
from sqlalchemy.exc import SQLAlchemyError
|
from sqlalchemy.exc import SQLAlchemyError
|
||||||
@@ -25,7 +26,7 @@ from ..domain.agent_identity import (
|
|||||||
from ..domain.cross_chain_reputation import CrossChainReputationAggregation
|
from ..domain.cross_chain_reputation import CrossChainReputationAggregation
|
||||||
from ..reputation.engine import CrossChainReputationEngine
|
from ..reputation.engine import CrossChainReputationEngine
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class WalletStatus(str, Enum):
|
class WalletStatus(str, Enum):
|
||||||
|
|||||||
@@ -30,7 +30,7 @@ class DatabaseConfig(BaseSettings):
|
|||||||
|
|
||||||
# Default SQLite path - consistent with blockchain-node pattern
|
# Default SQLite path - consistent with blockchain-node pattern
|
||||||
if self.adapter == "sqlite":
|
if self.adapter == "sqlite":
|
||||||
return "sqlite:////opt/aitbc/data/coordinator.db"
|
return "sqlite:////var/lib/aitbc/data/coordinator.db"
|
||||||
|
|
||||||
# Default PostgreSQL connection string
|
# Default PostgreSQL connection string
|
||||||
return f"{self.adapter}://localhost:5432/coordinator"
|
return f"{self.adapter}://localhost:5432/coordinator"
|
||||||
@@ -187,7 +187,7 @@ class Settings(BaseSettings):
|
|||||||
if self.database.url:
|
if self.database.url:
|
||||||
return self.database.url
|
return self.database.url
|
||||||
# Default SQLite path - consistent with blockchain-node pattern
|
# 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
|
@database_url.setter
|
||||||
def database_url(self, value: str):
|
def database_url(self, value: str):
|
||||||
|
|||||||
@@ -7,7 +7,7 @@ from .marketplace import MarketplaceOffer, MarketplaceBid
|
|||||||
from .user import User, Wallet, Transaction, UserSession
|
from .user import User, Wallet, Transaction, UserSession
|
||||||
from .payment import JobPayment, PaymentEscrow
|
from .payment import JobPayment, PaymentEscrow
|
||||||
from .gpu_marketplace import GPURegistry, ConsumerGPUProfile, EdgeGPUMetrics, GPUBooking, GPUReview
|
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__ = [
|
__all__ = [
|
||||||
"Job",
|
"Job",
|
||||||
@@ -31,4 +31,5 @@ __all__ = [
|
|||||||
"AgentExecution",
|
"AgentExecution",
|
||||||
"AgentStepExecution",
|
"AgentStepExecution",
|
||||||
"AgentMarketplace",
|
"AgentMarketplace",
|
||||||
|
"AgentStatus",
|
||||||
]
|
]
|
||||||
|
|||||||
@@ -80,11 +80,12 @@ except ImportError:
|
|||||||
print("WARNING: ML ZK proofs router not available (missing dependencies)")
|
print("WARNING: ML ZK proofs router not available (missing dependencies)")
|
||||||
from .storage.models_governance import GovernanceProposal, ProposalVote, TreasuryTransaction, GovernanceParameter
|
from .storage.models_governance import GovernanceProposal, ProposalVote, TreasuryTransaction, GovernanceParameter
|
||||||
from .exceptions import AITBCError, ErrorResponse
|
from .exceptions import AITBCError, ErrorResponse
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
from .config import settings
|
from .config import settings
|
||||||
from .storage.db import init_db
|
from .storage.db import init_db
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
from contextlib import asynccontextmanager
|
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 .routers.openclaw_enhanced_simple import router as openclaw_enhanced
|
||||||
from .storage.models_governance import GovernanceProposal, ProposalVote, TreasuryTransaction, GovernanceParameter
|
from .storage.models_governance import GovernanceProposal, ProposalVote, TreasuryTransaction, GovernanceParameter
|
||||||
from .exceptions import AITBCError, ErrorResponse
|
from .exceptions import AITBCError, ErrorResponse
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
from .config import settings
|
from .config import settings
|
||||||
from .storage.db import init_db
|
from .storage.db import init_db
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
def create_app() -> FastAPI:
|
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.marketplace_enhanced_simple import router as marketplace_enhanced
|
||||||
from .routers.openclaw_enhanced_simple import router as openclaw_enhanced
|
from .routers.openclaw_enhanced_simple import router as openclaw_enhanced
|
||||||
from .exceptions import AITBCError, ErrorResponse
|
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:
|
def create_app() -> FastAPI:
|
||||||
|
|||||||
@@ -8,7 +8,8 @@ from datetime import datetime, timedelta
|
|||||||
from typing import Dict, List, Optional, Any, Set
|
from typing import Dict, List, Optional, Any, Set
|
||||||
from uuid import uuid4
|
from uuid import uuid4
|
||||||
import json
|
import json
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from sqlmodel import Session, select, update, delete, func
|
from sqlmodel import Session, select, update, delete, func
|
||||||
from sqlalchemy.exc import SQLAlchemyError
|
from sqlalchemy.exc import SQLAlchemyError
|
||||||
@@ -19,7 +20,7 @@ from ..domain.cross_chain_reputation import (
|
|||||||
CrossChainReputationConfig, ReputationMetrics
|
CrossChainReputationConfig, ReputationMetrics
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class CrossChainReputationAggregator:
|
class CrossChainReputationAggregator:
|
||||||
|
|||||||
@@ -9,7 +9,8 @@ from datetime import datetime, timedelta
|
|||||||
from typing import Dict, List, Optional, Any, Tuple
|
from typing import Dict, List, Optional, Any, Tuple
|
||||||
from uuid import uuid4
|
from uuid import uuid4
|
||||||
import json
|
import json
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from sqlmodel import Session, select, update, delete, func
|
from sqlmodel import Session, select, update, delete, func
|
||||||
from sqlalchemy.exc import SQLAlchemyError
|
from sqlalchemy.exc import SQLAlchemyError
|
||||||
@@ -20,7 +21,7 @@ from ..domain.cross_chain_reputation import (
|
|||||||
CrossChainReputationConfig, ReputationMetrics
|
CrossChainReputationConfig, ReputationMetrics
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class CrossChainReputationEngine:
|
class CrossChainReputationEngine:
|
||||||
|
|||||||
@@ -10,12 +10,15 @@ from datetime import datetime
|
|||||||
import sys
|
import sys
|
||||||
import psutil
|
import psutil
|
||||||
from typing import Dict, Any
|
from typing import Dict, Any
|
||||||
|
import logging
|
||||||
|
|
||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
from ..services.adaptive_learning import AdaptiveLearningService
|
from ..services.adaptive_learning import AdaptiveLearningService
|
||||||
|
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
from ..logging import get_logger
|
from ..logging import get_logger
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -11,9 +11,10 @@ from ..services import JobService, MinerService
|
|||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
from ..utils.cache import cached, get_cache_config
|
from ..utils.cache import cached, get_cache_config
|
||||||
from ..config import settings
|
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)
|
limiter = Limiter(key_func=get_remote_address)
|
||||||
router = APIRouter(prefix="/admin", tags=["admin"])
|
router = APIRouter(prefix="/admin", tags=["admin"])
|
||||||
|
|
||||||
|
|||||||
@@ -9,7 +9,8 @@ from datetime import datetime
|
|||||||
from typing import Dict, List, Optional, Any
|
from typing import Dict, List, Optional, Any
|
||||||
from fastapi import APIRouter, HTTPException, Depends, Query, Body
|
from fastapi import APIRouter, HTTPException, Depends, Query, Body
|
||||||
from pydantic import BaseModel, Field
|
from pydantic import BaseModel, Field
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
from ..services.creative_capabilities_service import (
|
from ..services.creative_capabilities_service import (
|
||||||
@@ -17,7 +18,7 @@ from ..services.creative_capabilities_service import (
|
|||||||
)
|
)
|
||||||
from ..domain.agent_performance import CreativeCapability
|
from ..domain.agent_performance import CreativeCapability
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/v1/agent-creativity", tags=["agent-creativity"])
|
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 fastapi import APIRouter, Depends, HTTPException, BackgroundTasks
|
||||||
from typing import List, Optional
|
from typing import List, Optional
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from ..domain.agent import (
|
from ..domain.agent import (
|
||||||
AIAgentWorkflow, AgentExecution, AgentStatus, VerificationLevel
|
AIAgentWorkflow, AgentExecution, AgentStatus, VerificationLevel
|
||||||
@@ -21,7 +22,7 @@ from ..deps import require_admin_key
|
|||||||
from sqlmodel import Session, select
|
from sqlmodel import Session, select
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/agents/integration", tags=["Agent Integration"])
|
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 typing import Dict, List, Optional, Any
|
||||||
from fastapi import APIRouter, HTTPException, Depends, Query
|
from fastapi import APIRouter, HTTPException, Depends, Query
|
||||||
from pydantic import BaseModel, Field
|
from pydantic import BaseModel, Field
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
from ..services.agent_performance_service import (
|
from ..services.agent_performance_service import (
|
||||||
@@ -23,7 +24,7 @@ from ..domain.agent_performance import (
|
|||||||
OptimizationTarget
|
OptimizationTarget
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/v1/agent-performance", tags=["agent-performance"])
|
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 fastapi import APIRouter, Depends, HTTPException, BackgroundTasks
|
||||||
from typing import List, Optional
|
from typing import List, Optional
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from ..domain.agent import (
|
from ..domain.agent import (
|
||||||
AIAgentWorkflow, AgentWorkflowCreate, AgentWorkflowUpdate,
|
AIAgentWorkflow, AgentWorkflowCreate, AgentWorkflowUpdate,
|
||||||
@@ -20,7 +21,7 @@ from ..storage import get_session
|
|||||||
from ..deps import require_admin_key
|
from ..deps import require_admin_key
|
||||||
from sqlmodel import Session, select
|
from sqlmodel import Session, select
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/agents", tags=["AI Agents"])
|
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 fastapi import APIRouter, Depends, HTTPException, BackgroundTasks
|
||||||
from typing import List, Optional
|
from typing import List, Optional
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from ..domain.agent import (
|
from ..domain.agent import (
|
||||||
AIAgentWorkflow, AgentExecution, AgentStatus, VerificationLevel
|
AIAgentWorkflow, AgentExecution, AgentStatus, VerificationLevel
|
||||||
@@ -21,7 +22,7 @@ from ..storage import get_session
|
|||||||
from ..deps import require_admin_key
|
from ..deps import require_admin_key
|
||||||
from sqlmodel import Session, select
|
from sqlmodel import Session, select
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/agents/security", tags=["Agent Security"])
|
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 typing import Dict, List, Optional, Any
|
||||||
from fastapi import APIRouter, HTTPException, Depends, Query
|
from fastapi import APIRouter, HTTPException, Depends, Query
|
||||||
from pydantic import BaseModel, Field
|
from pydantic import BaseModel, Field
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
from ..services.analytics_service import MarketplaceAnalytics
|
from ..services.analytics_service import MarketplaceAnalytics
|
||||||
@@ -18,7 +19,7 @@ from ..domain.analytics import (
|
|||||||
AnalyticsPeriod, MetricType, InsightType, ReportType
|
AnalyticsPeriod, MetricType, InsightType, ReportType
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/v1/analytics", tags=["analytics"])
|
router = APIRouter(prefix="/v1/analytics", tags=["analytics"])
|
||||||
|
|
||||||
|
|||||||
@@ -1,9 +1,10 @@
|
|||||||
from __future__ import annotations
|
from __future__ import annotations
|
||||||
|
|
||||||
from fastapi import APIRouter, HTTPException
|
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"])
|
router = APIRouter(tags=["blockchain"])
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -20,7 +20,7 @@ from ..services.bounty_service import BountyService
|
|||||||
from ..services.blockchain_service import BlockchainService
|
from ..services.blockchain_service import BlockchainService
|
||||||
from ..auth import get_current_user
|
from ..auth import get_current_user
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
# Pydantic models for request/response
|
# Pydantic models for request/response
|
||||||
|
|||||||
@@ -8,9 +8,10 @@ from slowapi.util import get_remote_address
|
|||||||
from ..deps import require_admin_key
|
from ..deps import require_admin_key
|
||||||
from ..utils.cache_management import get_cache_stats, clear_cache, warm_cache
|
from ..utils.cache_management import get_cache_stats, clear_cache, warm_cache
|
||||||
from ..config import settings
|
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)
|
limiter = Limiter(key_func=get_remote_address)
|
||||||
router = APIRouter(prefix="/cache", tags=["cache-management"])
|
router = APIRouter(prefix="/cache", tags=["cache-management"])
|
||||||
|
|
||||||
|
|||||||
@@ -9,7 +9,8 @@ from datetime import datetime, timedelta
|
|||||||
from typing import Dict, List, Optional, Any
|
from typing import Dict, List, Optional, Any
|
||||||
from fastapi import APIRouter, HTTPException, Depends, Query
|
from fastapi import APIRouter, HTTPException, Depends, Query
|
||||||
from pydantic import BaseModel, Field
|
from pydantic import BaseModel, Field
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
from ..services.certification_service import (
|
from ..services.certification_service import (
|
||||||
@@ -22,7 +23,7 @@ from ..domain.certification import (
|
|||||||
PartnershipType, BadgeType
|
PartnershipType, BadgeType
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/v1/certification", tags=["certification"])
|
router = APIRouter(prefix="/v1/certification", tags=["certification"])
|
||||||
|
|
||||||
|
|||||||
@@ -9,7 +9,8 @@ from datetime import datetime
|
|||||||
from typing import Dict, List, Optional, Any
|
from typing import Dict, List, Optional, Any
|
||||||
from fastapi import APIRouter, HTTPException, Depends, Query, Body
|
from fastapi import APIRouter, HTTPException, Depends, Query, Body
|
||||||
from pydantic import BaseModel, Field
|
from pydantic import BaseModel, Field
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
from ..services.community_service import (
|
from ..services.community_service import (
|
||||||
@@ -21,7 +22,7 @@ from ..domain.community import (
|
|||||||
CommunityPost, Hackathon, DeveloperTier, SolutionStatus, LabStatus
|
CommunityPost, Hackathon, DeveloperTier, SolutionStatus, LabStatus
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/community", tags=["community"])
|
router = APIRouter(prefix="/community", tags=["community"])
|
||||||
|
|
||||||
|
|||||||
@@ -27,7 +27,7 @@ from ..services.access_control import AccessController
|
|||||||
from ..auth import get_api_key
|
from ..auth import get_api_key
|
||||||
from ..logging import get_logger
|
from ..logging import get_logger
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
# Initialize router and security
|
# Initialize router and security
|
||||||
router = APIRouter(prefix="/confidential", tags=["confidential"])
|
router = APIRouter(prefix="/confidential", tags=["confidential"])
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ from ..domain.bounty import EcosystemMetrics, BountyStats, AgentMetrics
|
|||||||
from ..services.ecosystem_service import EcosystemService
|
from ..services.ecosystem_service import EcosystemService
|
||||||
from ..auth import get_current_user
|
from ..auth import get_current_user
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
# Pydantic models for request/response
|
# Pydantic models for request/response
|
||||||
|
|||||||
@@ -11,9 +11,10 @@ import json
|
|||||||
import os
|
import os
|
||||||
from slowapi import Limiter
|
from slowapi import Limiter
|
||||||
from slowapi.util import get_remote_address
|
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)
|
limiter = Limiter(key_func=get_remote_address)
|
||||||
|
|
||||||
from ..schemas import (
|
from ..schemas import (
|
||||||
|
|||||||
@@ -9,7 +9,8 @@ from datetime import datetime
|
|||||||
from typing import Dict, List, Optional, Any
|
from typing import Dict, List, Optional, Any
|
||||||
from fastapi import APIRouter, HTTPException, Depends, Query, Body
|
from fastapi import APIRouter, HTTPException, Depends, Query, Body
|
||||||
from pydantic import BaseModel, Field
|
from pydantic import BaseModel, Field
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
from ..services.governance_service import GovernanceService
|
from ..services.governance_service import GovernanceService
|
||||||
@@ -18,7 +19,7 @@ from ..domain.governance import (
|
|||||||
ProposalStatus, VoteType, GovernanceRole
|
ProposalStatus, VoteType, GovernanceRole
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/governance", tags=["governance"])
|
router = APIRouter(prefix="/governance", tags=["governance"])
|
||||||
|
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ from ..storage import get_session
|
|||||||
from ..services.multimodal_agent import MultiModalAgentService
|
from ..services.multimodal_agent import MultiModalAgentService
|
||||||
from ..logging import get_logger
|
from ..logging import get_logger
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -13,9 +13,10 @@ from ..storage import get_session
|
|||||||
from ..metrics import marketplace_requests_total, marketplace_errors_total
|
from ..metrics import marketplace_requests_total, marketplace_errors_total
|
||||||
from ..utils.cache import cached, get_cache_config
|
from ..utils.cache import cached, get_cache_config
|
||||||
from ..config import settings
|
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)
|
limiter = Limiter(key_func=get_remote_address)
|
||||||
router = APIRouter(tags=["marketplace"])
|
router = APIRouter(tags=["marketplace"])
|
||||||
|
|
||||||
|
|||||||
@@ -6,7 +6,8 @@ REST API endpoints for advanced marketplace features including royalties, licens
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
from typing import List, Optional
|
from typing import List, Optional
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from fastapi import APIRouter, HTTPException, Depends
|
from fastapi import APIRouter, HTTPException, Depends
|
||||||
from pydantic import BaseModel, Field
|
from pydantic import BaseModel, Field
|
||||||
@@ -22,7 +23,7 @@ from ..schemas.marketplace_enhanced import (
|
|||||||
MarketplaceAnalyticsRequest, MarketplaceAnalyticsResponse
|
MarketplaceAnalyticsRequest, MarketplaceAnalyticsResponse
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/marketplace/enhanced", tags=["Enhanced Marketplace"])
|
router = APIRouter(prefix="/marketplace/enhanced", tags=["Enhanced Marketplace"])
|
||||||
|
|
||||||
|
|||||||
@@ -15,7 +15,7 @@ from ..storage import get_session
|
|||||||
from ..services.marketplace_enhanced import EnhancedMarketplaceService
|
from ..services.marketplace_enhanced import EnhancedMarketplaceService
|
||||||
from ..logging import get_logger
|
from ..logging import get_logger
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -6,7 +6,8 @@ REST API endpoints for enhanced marketplace features
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
from typing import List, Optional, Dict, Any
|
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 fastapi import APIRouter, HTTPException, Depends
|
||||||
from pydantic import BaseModel, Field
|
from pydantic import BaseModel, Field
|
||||||
@@ -16,7 +17,7 @@ from ..storage import get_session
|
|||||||
from ..deps import require_admin_key
|
from ..deps import require_admin_key
|
||||||
from sqlmodel import Session
|
from sqlmodel import Session
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/marketplace/enhanced", tags=["Marketplace Enhanced"])
|
router = APIRouter(prefix="/marketplace/enhanced", tags=["Marketplace Enhanced"])
|
||||||
|
|
||||||
|
|||||||
@@ -10,7 +10,8 @@ from datetime import datetime
|
|||||||
from typing import Dict, List, Optional, Any
|
from typing import Dict, List, Optional, Any
|
||||||
from fastapi import APIRouter, HTTPException, Depends, Query, BackgroundTasks
|
from fastapi import APIRouter, HTTPException, Depends, Query, BackgroundTasks
|
||||||
from pydantic import BaseModel, Field
|
from pydantic import BaseModel, Field
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
import sys
|
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_monitor import monitor as marketplace_monitor
|
||||||
from aitbc.gpu_acceleration.parallel_processing.marketplace_scaler import ResourceScaler, ScalingPolicy
|
from aitbc.gpu_acceleration.parallel_processing.marketplace_scaler import ResourceScaler, ScalingPolicy
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/v1/marketplace/performance", tags=["marketplace-performance"])
|
router = APIRouter(prefix="/v1/marketplace/performance", tags=["marketplace-performance"])
|
||||||
|
|
||||||
|
|||||||
@@ -13,9 +13,10 @@ from ..services import JobService, MinerService
|
|||||||
from ..services.receipts import ReceiptService
|
from ..services.receipts import ReceiptService
|
||||||
from ..config import settings
|
from ..config import settings
|
||||||
from ..storage import get_session
|
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)
|
limiter = Limiter(key_func=get_remote_address)
|
||||||
router = APIRouter(tags=["miner"])
|
router = APIRouter(tags=["miner"])
|
||||||
|
|
||||||
|
|||||||
@@ -15,7 +15,7 @@ from ..storage import get_session
|
|||||||
from ..services.multimodal_agent import MultiModalAgentService
|
from ..services.multimodal_agent import MultiModalAgentService
|
||||||
from ..logging import get_logger
|
from ..logging import get_logger
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -15,7 +15,7 @@ from typing import Dict, Any, List
|
|||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
from ..logging import get_logger
|
from ..logging import get_logger
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
# Templates would be stored in a templates directory in production
|
# 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 typing import Dict, List, Optional, Any
|
||||||
from fastapi import APIRouter, Depends, HTTPException, Query, BackgroundTasks, WebSocket, WebSocketDisconnect
|
from fastapi import APIRouter, Depends, HTTPException, Query, BackgroundTasks, WebSocket, WebSocketDisconnect
|
||||||
from pydantic import BaseModel, Field
|
from pydantic import BaseModel, Field
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
from ..services.multi_modal_fusion import MultiModalFusionEngine
|
from ..services.multi_modal_fusion import MultiModalFusionEngine
|
||||||
@@ -19,7 +20,7 @@ from ..domain.agent_performance import (
|
|||||||
CreativeCapability
|
CreativeCapability
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/multi-modal-rl", tags=["multi-modal-rl"])
|
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 ..services.multimodal_agent import MultiModalAgentService
|
||||||
from ..logging import get_logger
|
from ..logging import get_logger
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -6,7 +6,8 @@ REST API endpoints for advanced agent orchestration, edge computing integration,
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
from typing import List, Optional
|
from typing import List, Optional
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from fastapi import APIRouter, HTTPException, Depends
|
from fastapi import APIRouter, HTTPException, Depends
|
||||||
from pydantic import BaseModel, Field
|
from pydantic import BaseModel, Field
|
||||||
@@ -25,7 +26,7 @@ from ..schemas.openclaw_enhanced import (
|
|||||||
EcosystemDevelopmentRequest, EcosystemDevelopmentResponse
|
EcosystemDevelopmentRequest, EcosystemDevelopmentResponse
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/openclaw/enhanced", tags=["OpenClaw Enhanced"])
|
router = APIRouter(prefix="/openclaw/enhanced", tags=["OpenClaw Enhanced"])
|
||||||
|
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ from ..storage import get_session
|
|||||||
from ..services.openclaw_enhanced import OpenClawEnhancedService
|
from ..services.openclaw_enhanced import OpenClawEnhancedService
|
||||||
from ..logging import get_logger
|
from ..logging import get_logger
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -6,7 +6,8 @@ REST API endpoints for OpenClaw integration features
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
from typing import List, Optional, Dict, Any
|
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 fastapi import APIRouter, HTTPException, Depends
|
||||||
from pydantic import BaseModel, Field
|
from pydantic import BaseModel, Field
|
||||||
@@ -16,7 +17,7 @@ from ..storage import get_session
|
|||||||
from ..deps import require_admin_key
|
from ..deps import require_admin_key
|
||||||
from sqlmodel import Session
|
from sqlmodel import Session
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/openclaw/enhanced", tags=["OpenClaw Enhanced"])
|
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 typing import Dict, List, Optional, Any
|
||||||
from fastapi import APIRouter, HTTPException, Depends, Query
|
from fastapi import APIRouter, HTTPException, Depends, Query
|
||||||
from pydantic import BaseModel, Field
|
from pydantic import BaseModel, Field
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
from ..services.reputation_service import ReputationService
|
from ..services.reputation_service import ReputationService
|
||||||
@@ -19,7 +20,7 @@ from ..domain.reputation import (
|
|||||||
)
|
)
|
||||||
from sqlmodel import select, func, Field
|
from sqlmodel import select, func, Field
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/v1/reputation", tags=["reputation"])
|
router = APIRouter(prefix="/v1/reputation", tags=["reputation"])
|
||||||
|
|
||||||
|
|||||||
@@ -9,7 +9,8 @@ from datetime import datetime, timedelta
|
|||||||
from typing import Dict, List, Optional, Any
|
from typing import Dict, List, Optional, Any
|
||||||
from fastapi import APIRouter, HTTPException, Depends, Query
|
from fastapi import APIRouter, HTTPException, Depends, Query
|
||||||
from pydantic import BaseModel, Field
|
from pydantic import BaseModel, Field
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
from ..services.reward_service import RewardEngine
|
from ..services.reward_service import RewardEngine
|
||||||
@@ -17,7 +18,7 @@ from ..domain.rewards import (
|
|||||||
AgentRewardProfile, RewardTier, RewardType, RewardStatus
|
AgentRewardProfile, RewardTier, RewardType, RewardStatus
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/v1/rewards", tags=["rewards"])
|
router = APIRouter(prefix="/v1/rewards", tags=["rewards"])
|
||||||
|
|
||||||
|
|||||||
@@ -20,7 +20,7 @@ from ..services.staking_service import StakingService
|
|||||||
from ..services.blockchain_service import BlockchainService
|
from ..services.blockchain_service import BlockchainService
|
||||||
from ..auth import get_current_user
|
from ..auth import get_current_user
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
# Pydantic models for request/response
|
# Pydantic models for request/response
|
||||||
|
|||||||
@@ -9,7 +9,8 @@ from datetime import datetime, timedelta
|
|||||||
from typing import Dict, List, Optional, Any
|
from typing import Dict, List, Optional, Any
|
||||||
from fastapi import APIRouter, HTTPException, Depends, Query
|
from fastapi import APIRouter, HTTPException, Depends, Query
|
||||||
from pydantic import BaseModel, Field
|
from pydantic import BaseModel, Field
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
from ..services.trading_service import P2PTradingProtocol
|
from ..services.trading_service import P2PTradingProtocol
|
||||||
@@ -18,7 +19,7 @@ from ..domain.trading import (
|
|||||||
TradeStatus, TradeType, NegotiationStatus, SettlementType
|
TradeStatus, TradeType, NegotiationStatus, SettlementType
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/v1/trading", tags=["trading"])
|
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 fastapi import APIRouter, HTTPException
|
||||||
from pydantic import BaseModel
|
from pydantic import BaseModel
|
||||||
from typing import List, Dict, Any, Optional
|
from typing import List, Dict, Any, Optional
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
|
|||||||
@@ -16,9 +16,10 @@ import jwt
|
|||||||
import hashlib
|
import hashlib
|
||||||
import secrets
|
import secrets
|
||||||
from pydantic import BaseModel, Field, validator
|
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):
|
class SDKVersion(str, Enum):
|
||||||
"""SDK version"""
|
"""SDK version"""
|
||||||
|
|||||||
@@ -12,7 +12,7 @@ from ..schemas import ConfidentialAccessRequest, ConfidentialAccessLog
|
|||||||
from ..config import settings
|
from ..config import settings
|
||||||
from ..logging import get_logger
|
from ..logging import get_logger
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class AccessPurpose(str, Enum):
|
class AccessPurpose(str, Enum):
|
||||||
|
|||||||
@@ -7,7 +7,8 @@ Reinforcement learning frameworks for agent self-improvement
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
import asyncio
|
import asyncio
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
from typing import Dict, List, Any, Optional, Tuple, Union
|
from typing import Dict, List, Any, Optional, Tuple, Union
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
from enum import Enum
|
from enum import Enum
|
||||||
@@ -17,7 +18,7 @@ import json
|
|||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
from ..domain import AIAgentWorkflow, AgentExecution, AgentStatus
|
from ..domain import AIAgentWorkflow, AgentExecution, AgentStatus
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class LearningAlgorithm(str, Enum):
|
class LearningAlgorithm(str, Enum):
|
||||||
|
|||||||
@@ -17,7 +17,8 @@ import numpy as np
|
|||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
import uuid
|
import uuid
|
||||||
import json
|
import json
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from .advanced_reinforcement_learning import AdvancedReinforcementLearningEngine
|
from .advanced_reinforcement_learning import AdvancedReinforcementLearningEngine
|
||||||
from .multi_modal_fusion import MultiModalFusionEngine
|
from .multi_modal_fusion import MultiModalFusionEngine
|
||||||
@@ -25,7 +26,7 @@ from .gpu_multimodal import GPUAcceleratedMultiModal
|
|||||||
from .advanced_learning import AdvancedLearningService
|
from .advanced_learning import AdvancedLearningService
|
||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
# Pydantic models for API
|
# Pydantic models for API
|
||||||
class RLTrainingRequest(BaseModel):
|
class RLTrainingRequest(BaseModel):
|
||||||
|
|||||||
@@ -4,7 +4,8 @@ Implements meta-learning, federated learning, and continuous model improvement
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
import asyncio
|
import asyncio
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
from typing import Dict, List, Any, Optional, Tuple, Union
|
from typing import Dict, List, Any, Optional, Tuple, Union
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
from enum import Enum
|
from enum import Enum
|
||||||
@@ -12,7 +13,7 @@ import json
|
|||||||
import numpy as np
|
import numpy as np
|
||||||
from dataclasses import dataclass, asdict, field
|
from dataclasses import dataclass, asdict, field
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class LearningType(str, Enum):
|
class LearningType(str, Enum):
|
||||||
|
|||||||
@@ -12,7 +12,8 @@ import torch.optim as optim
|
|||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
from typing import Dict, List, Optional, Any, Tuple, Union
|
from typing import Dict, List, Optional, Any, Tuple, Union
|
||||||
from uuid import uuid4
|
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 sqlmodel import Session, select, update, delete, and_, or_, func
|
||||||
from sqlalchemy.exc import SQLAlchemyError
|
from sqlalchemy.exc import SQLAlchemyError
|
||||||
@@ -22,7 +23,7 @@ from ..domain.agent_performance import (
|
|||||||
AgentCapability, FusionModel
|
AgentCapability, FusionModel
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class PPOAgent(nn.Module):
|
class PPOAgent(nn.Module):
|
||||||
|
|||||||
@@ -4,7 +4,8 @@ Implements secure agent-to-agent messaging with reputation-based access control
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
import asyncio
|
import asyncio
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
from typing import Dict, List, Any, Optional, Tuple
|
from typing import Dict, List, Any, Optional, Tuple
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
from enum import Enum
|
from enum import Enum
|
||||||
@@ -15,7 +16,7 @@ from dataclasses import dataclass, asdict, field
|
|||||||
|
|
||||||
from .cross_chain_reputation import CrossChainReputationService, ReputationTier
|
from .cross_chain_reputation import CrossChainReputationService, ReputationTier
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class MessageType(str, Enum):
|
class MessageType(str, Enum):
|
||||||
|
|||||||
@@ -5,7 +5,8 @@ Integrates agent orchestration with existing ML ZK proof system and provides dep
|
|||||||
|
|
||||||
import asyncio
|
import asyncio
|
||||||
import json
|
import json
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
from typing import Dict, List, Optional, Any
|
from typing import Dict, List, Optional, Any
|
||||||
from uuid import uuid4
|
from uuid import uuid4
|
||||||
@@ -44,7 +45,7 @@ class ZKProofService:
|
|||||||
"details": {"mock": True}
|
"details": {"mock": True}
|
||||||
}
|
}
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class DeploymentStatus(str, Enum):
|
class DeploymentStatus(str, Enum):
|
||||||
|
|||||||
@@ -4,7 +4,8 @@ Implements multi-agent coordination and sub-task management
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
import asyncio
|
import asyncio
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
from typing import Dict, List, Any, Optional, Tuple, Set
|
from typing import Dict, List, Any, Optional, Tuple, Set
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
from enum import Enum
|
from enum import Enum
|
||||||
@@ -14,7 +15,7 @@ from dataclasses import dataclass, asdict, field
|
|||||||
from .task_decomposition import TaskDecomposition, SubTask, SubTaskStatus, GPU_Tier
|
from .task_decomposition import TaskDecomposition, SubTask, SubTaskStatus, GPU_Tier
|
||||||
from .bid_strategy_engine import BidResult, BidStrategy, UrgencyLevel
|
from .bid_strategy_engine import BidResult, BidStrategy, UrgencyLevel
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class OrchestratorStatus(str, Enum):
|
class OrchestratorStatus(str, Enum):
|
||||||
|
|||||||
@@ -8,7 +8,8 @@ import numpy as np
|
|||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
from typing import Dict, List, Optional, Any, Tuple
|
from typing import Dict, List, Optional, Any, Tuple
|
||||||
from uuid import uuid4
|
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 sqlmodel import Session, select, update, delete, and_, or_, func
|
||||||
from sqlalchemy.exc import SQLAlchemyError
|
from sqlalchemy.exc import SQLAlchemyError
|
||||||
@@ -21,7 +22,7 @@ from ..domain.agent_performance import (
|
|||||||
OptimizationTarget
|
OptimizationTarget
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class MetaLearningEngine:
|
class MetaLearningEngine:
|
||||||
|
|||||||
@@ -6,7 +6,8 @@ Implements comprehensive security, auditing, and trust establishment for agent e
|
|||||||
import asyncio
|
import asyncio
|
||||||
import hashlib
|
import hashlib
|
||||||
import json
|
import json
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
from typing import Dict, List, Optional, Any, Set
|
from typing import Dict, List, Optional, Any, Set
|
||||||
from uuid import uuid4
|
from uuid import uuid4
|
||||||
@@ -20,7 +21,7 @@ from ..domain.agent import (
|
|||||||
AgentStatus, VerificationLevel
|
AgentStatus, VerificationLevel
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class SecurityLevel(str, Enum):
|
class SecurityLevel(str, Enum):
|
||||||
|
|||||||
@@ -8,7 +8,8 @@ from datetime import datetime, timedelta
|
|||||||
from typing import Dict, List, Optional, Any
|
from typing import Dict, List, Optional, Any
|
||||||
from uuid import uuid4
|
from uuid import uuid4
|
||||||
import json
|
import json
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from sqlmodel import Session, select, update, delete
|
from sqlmodel import Session, select, update, delete
|
||||||
from sqlalchemy.exc import SQLAlchemyError
|
from sqlalchemy.exc import SQLAlchemyError
|
||||||
@@ -24,7 +25,7 @@ class CoordinatorClient:
|
|||||||
"""Mock coordinator client for agent orchestration"""
|
"""Mock coordinator client for agent orchestration"""
|
||||||
pass
|
pass
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class AgentStateManager:
|
class AgentStateManager:
|
||||||
|
|||||||
@@ -4,7 +4,8 @@ Implements a sophisticated marketplace where agents can offer specialized servic
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
import asyncio
|
import asyncio
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
from typing import Dict, List, Any, Optional, Tuple
|
from typing import Dict, List, Any, Optional, Tuple
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
from enum import Enum
|
from enum import Enum
|
||||||
@@ -12,7 +13,7 @@ import json
|
|||||||
import hashlib
|
import hashlib
|
||||||
from dataclasses import dataclass, asdict, field
|
from dataclasses import dataclass, asdict, field
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class ServiceStatus(str, Enum):
|
class ServiceStatus(str, Enum):
|
||||||
|
|||||||
@@ -9,7 +9,8 @@ from datetime import datetime, timedelta
|
|||||||
from typing import Dict, List, Optional, Any, Tuple
|
from typing import Dict, List, Optional, Any, Tuple
|
||||||
from uuid import uuid4
|
from uuid import uuid4
|
||||||
import json
|
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 sqlmodel import Session, select, update, delete, and_, or_, func
|
||||||
from sqlalchemy.exc import SQLAlchemyError
|
from sqlalchemy.exc import SQLAlchemyError
|
||||||
@@ -23,7 +24,7 @@ from ..domain.trading import TradingAnalytics
|
|||||||
from ..domain.rewards import RewardAnalytics
|
from ..domain.rewards import RewardAnalytics
|
||||||
from ..domain.reputation import AgentReputation
|
from ..domain.reputation import AgentReputation
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class DataCollector:
|
class DataCollector:
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ from ..schemas import ConfidentialAccessLog
|
|||||||
from ..config import settings
|
from ..config import settings
|
||||||
from ..logging import get_logger
|
from ..logging import get_logger
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
@dataclass
|
@dataclass
|
||||||
|
|||||||
@@ -4,7 +4,8 @@ Implements intelligent bidding algorithms for GPU rental negotiations
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
import asyncio
|
import asyncio
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
from typing import Dict, List, Any, Optional, Tuple
|
from typing import Dict, List, Any, Optional, Tuple
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
from enum import Enum
|
from enum import Enum
|
||||||
@@ -12,7 +13,7 @@ import numpy as np
|
|||||||
import json
|
import json
|
||||||
from dataclasses import dataclass, asdict
|
from dataclasses import dataclass, asdict
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class BidStrategy(str, Enum):
|
class BidStrategy(str, Enum):
|
||||||
|
|||||||
@@ -6,7 +6,8 @@ Uses RPC to connect to Bitcoin Core (or alternative like Block.io)
|
|||||||
|
|
||||||
import os
|
import os
|
||||||
import json
|
import json
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
from typing import Dict, Optional
|
from typing import Dict, Optional
|
||||||
|
|
||||||
try:
|
try:
|
||||||
@@ -16,7 +17,7 @@ except ImportError:
|
|||||||
HTTP_CLIENT_AVAILABLE = False
|
HTTP_CLIENT_AVAILABLE = False
|
||||||
logging.warning("httpx not available, bitcoin wallet functions will be disabled")
|
logging.warning("httpx not available, bitcoin wallet functions will be disabled")
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
# Bitcoin wallet configuration (credentials from environment)
|
# Bitcoin wallet configuration (credentials from environment)
|
||||||
WALLET_CONFIG = {
|
WALLET_CONFIG = {
|
||||||
|
|||||||
@@ -4,12 +4,13 @@ Blockchain service for AITBC token operations
|
|||||||
|
|
||||||
import httpx
|
import httpx
|
||||||
import asyncio
|
import asyncio
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
from typing import Optional
|
from typing import Optional
|
||||||
|
|
||||||
from ..config import settings
|
from ..config import settings
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
BLOCKCHAIN_RPC = f"http://127.0.0.1:9080/rpc"
|
BLOCKCHAIN_RPC = f"http://127.0.0.1:9080/rpc"
|
||||||
|
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ from ..domain.bounty import (
|
|||||||
from ..storage import get_session
|
from ..storage import get_session
|
||||||
from ..logging import get_logger
|
from ..logging import get_logger
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
class BountyService:
|
class BountyService:
|
||||||
"""Service for managing AI agent bounties"""
|
"""Service for managing AI agent bounties"""
|
||||||
|
|||||||
@@ -9,7 +9,8 @@ import json
|
|||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
from typing import Dict, List, Optional, Any, Tuple
|
from typing import Dict, List, Optional, Any, Tuple
|
||||||
from uuid import uuid4
|
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 sqlmodel import Session, select, update, delete, and_, or_, func
|
||||||
from sqlalchemy.exc import SQLAlchemyError
|
from sqlalchemy.exc import SQLAlchemyError
|
||||||
@@ -23,7 +24,7 @@ from ..domain.certification import (
|
|||||||
from ..domain.reputation import AgentReputation
|
from ..domain.reputation import AgentReputation
|
||||||
from ..domain.rewards import AgentRewardProfile
|
from ..domain.rewards import AgentRewardProfile
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class CertificationSystem:
|
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 typing import Optional, List, Dict, Any
|
||||||
from sqlmodel import Session, select
|
from sqlmodel import Session, select
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
from uuid import uuid4
|
from uuid import uuid4
|
||||||
|
|
||||||
from ..domain.community import (
|
from ..domain.community import (
|
||||||
@@ -14,7 +15,7 @@ from ..domain.community import (
|
|||||||
CommunityPost, Hackathon, DeveloperTier, SolutionStatus, LabStatus
|
CommunityPost, Hackathon, DeveloperTier, SolutionStatus, LabStatus
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
class DeveloperEcosystemService:
|
class DeveloperEcosystemService:
|
||||||
"""Service for managing the developer ecosystem and SDKs"""
|
"""Service for managing the developer ecosystem and SDKs"""
|
||||||
|
|||||||
@@ -14,9 +14,10 @@ from enum import Enum
|
|||||||
from dataclasses import dataclass, field
|
from dataclasses import dataclass, field
|
||||||
import re
|
import re
|
||||||
from pydantic import BaseModel, Field, validator
|
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):
|
class ComplianceFramework(str, Enum):
|
||||||
"""Compliance frameworks"""
|
"""Compliance frameworks"""
|
||||||
|
|||||||
@@ -8,7 +8,8 @@ import numpy as np
|
|||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
from typing import Dict, List, Optional, Any, Tuple
|
from typing import Dict, List, Optional, Any, Tuple
|
||||||
from uuid import uuid4
|
from uuid import uuid4
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
import random
|
import random
|
||||||
|
|
||||||
from sqlmodel import Session, select, update, delete, and_, or_, func
|
from sqlmodel import Session, select, update, delete, and_, or_, func
|
||||||
@@ -18,7 +19,7 @@ from ..domain.agent_performance import (
|
|||||||
CreativeCapability, AgentCapability, AgentPerformanceProfile
|
CreativeCapability, AgentCapability, AgentPerformanceProfile
|
||||||
)
|
)
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class CreativityEnhancementEngine:
|
class CreativityEnhancementEngine:
|
||||||
|
|||||||
@@ -12,7 +12,8 @@ from decimal import Decimal
|
|||||||
from enum import Enum
|
from enum import Enum
|
||||||
import secrets
|
import secrets
|
||||||
import hashlib
|
import hashlib
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
from sqlmodel import Session, select, update, delete, func, Field
|
from sqlmodel import Session, select, update, delete, func, Field
|
||||||
from sqlalchemy.exc import SQLAlchemyError
|
from sqlalchemy.exc import SQLAlchemyError
|
||||||
@@ -28,7 +29,7 @@ from ..agent_identity.wallet_adapter_enhanced import (
|
|||||||
)
|
)
|
||||||
from ..reputation.engine import CrossChainReputationEngine
|
from ..reputation.engine import CrossChainReputationEngine
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class BridgeProtocol(str, Enum):
|
class BridgeProtocol(str, Enum):
|
||||||
|
|||||||
@@ -4,14 +4,15 @@ Implements portable reputation scores across multiple blockchain networks
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
import asyncio
|
import asyncio
|
||||||
from aitbc.logging import get_logger
|
import logging
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
from typing import Dict, List, Any, Optional, Tuple
|
from typing import Dict, List, Any, Optional, Tuple
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
from enum import Enum
|
from enum import Enum
|
||||||
import json
|
import json
|
||||||
from dataclasses import dataclass, asdict, field
|
from dataclasses import dataclass, asdict, field
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class ReputationTier(str, Enum):
|
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