a567f49df3
- Migrate scripts/blockchain_simple.py from logging to aitbc.get_logger - Migrate hardcoded paths in blockchain_simple.py to use DATA_DIR, CONFIG_DIR, LOG_DIR - Migrate scripts/blockchain_http_launcher.py from logging to aitbc.get_logger - Remove logging.basicConfig() calls
136 lines
4.7 KiB
Python
Executable File
136 lines
4.7 KiB
Python
Executable File
#!/usr/bin/env python3
|
|
"""
|
|
Blockchain Node Service for AITBC Production
|
|
"""
|
|
|
|
import os
|
|
import sys
|
|
from pathlib import Path
|
|
|
|
from aitbc import get_logger, DATA_DIR, CONFIG_DIR
|
|
|
|
# Add the blockchain app to Python path
|
|
sys.path.insert(0, '/opt/aitbc/apps/blockchain-node/src')
|
|
sys.path.insert(0, '/opt/aitbc/apps/blockchain-node/scripts')
|
|
|
|
logger = get_logger(__name__)
|
|
|
|
def main():
|
|
"""Main blockchain service function"""
|
|
logger.info("Starting AITBC Blockchain Node Service")
|
|
|
|
try:
|
|
# Set environment variables
|
|
os.environ.setdefault('PYTHONPATH', '/opt/aitbc/apps/blockchain-node/src')
|
|
os.environ.setdefault('BLOCKCHAIN_DATA_DIR', str(DATA_DIR / 'data/blockchain'))
|
|
os.environ.setdefault('BLOCKCHAIN_CONFIG_DIR', str(CONFIG_DIR))
|
|
os.environ.setdefault('BLOCKCHAIN_LOG_DIR', str(LOG_DIR / 'production/blockchain'))
|
|
|
|
# Try to import and run the actual blockchain node
|
|
logger.info("Attempting to start blockchain node...")
|
|
|
|
# Check if we can import the blockchain app
|
|
try:
|
|
from aitbc_chain.app import app
|
|
logger.info("Successfully imported blockchain app")
|
|
|
|
# Run the blockchain FastAPI app
|
|
import uvicorn
|
|
logger.info("Starting blockchain FastAPI app on port 8545")
|
|
uvicorn.run(app, host="0.0.0.0", port=int(os.environ.get("BLOCKCHAIN_PORT", 8545)))
|
|
|
|
except ImportError as e:
|
|
logger.error(f"Failed to import blockchain app: {e}")
|
|
|
|
# Try to run the main blockchain function
|
|
try:
|
|
from aitbc_chain.main import main as blockchain_main
|
|
logger.info("Successfully imported blockchain main")
|
|
blockchain_main()
|
|
|
|
except ImportError as e2:
|
|
logger.error(f"Failed to import blockchain main: {e2}")
|
|
logger.info("Starting blockchain node with basic functionality")
|
|
basic_blockchain_node()
|
|
|
|
except Exception as e:
|
|
logger.error(f"Error starting blockchain service: {e}")
|
|
logger.info("Starting fallback blockchain node")
|
|
basic_blockchain_node()
|
|
|
|
def basic_blockchain_node():
|
|
"""Basic blockchain node functionality"""
|
|
logger.info("Starting basic blockchain node")
|
|
|
|
try:
|
|
# Create a simple FastAPI app for blockchain node
|
|
from fastapi import FastAPI
|
|
import uvicorn
|
|
import time
|
|
import threading
|
|
|
|
app = FastAPI(title="AITBC Blockchain Node")
|
|
|
|
# Blockchain state
|
|
blockchain_state = {
|
|
"status": "running",
|
|
"block_height": 0,
|
|
"last_block": None,
|
|
"peers": [],
|
|
"start_time": time.time()
|
|
}
|
|
|
|
@app.get("/health")
|
|
async def health():
|
|
return {
|
|
"status": "healthy",
|
|
"service": "blockchain-node",
|
|
"block_height": blockchain_state["block_height"],
|
|
"uptime": time.time() - blockchain_state["start_time"]
|
|
}
|
|
|
|
@app.get("/")
|
|
async def root():
|
|
return {
|
|
"service": "blockchain-node",
|
|
"status": "running",
|
|
"endpoints": ["/health", "/", "/blocks", "/status"]
|
|
}
|
|
|
|
@app.get("/blocks")
|
|
async def get_blocks():
|
|
return {
|
|
"blocks": [],
|
|
"count": 0,
|
|
"latest_height": blockchain_state["block_height"]
|
|
}
|
|
|
|
@app.get("/status")
|
|
async def get_status():
|
|
return blockchain_state
|
|
|
|
# Simulate blockchain activity
|
|
def blockchain_activity():
|
|
while True:
|
|
time.sleep(30) # Simulate block generation every 30 seconds
|
|
blockchain_state["block_height"] += 1
|
|
blockchain_state["last_block"] = f"block_{blockchain_state['block_height']}"
|
|
logger.info(f"Generated block {blockchain_state['block_height']}")
|
|
|
|
# Start blockchain activity in background
|
|
activity_thread = threading.Thread(target=blockchain_activity, daemon=True)
|
|
activity_thread.start()
|
|
|
|
logger.info("Starting basic blockchain API on port 8545")
|
|
uvicorn.run(app, host="0.0.0.0", port=int(os.environ.get("BLOCKCHAIN_PORT", 8545)))
|
|
|
|
except ImportError:
|
|
# Fallback to simple heartbeat
|
|
logger.info("FastAPI not available, using simple blockchain node")
|
|
while True:
|
|
logger.info("Blockchain node heartbeat - active")
|
|
time.sleep(30)
|
|
|
|
if __name__ == "__main__":
|
|
main()
|