aitbc1
27510ebf2c
API ENDPOINT TESTS YAML FIX: Continue fixing YAML syntax errors Issues Fixed: ❌ Additional heredoc causing YAML parsing issues ❌ Wallet API test script creation failing ❌ Multi-line Python content being parsed as YAML Root Cause: - Remaining heredoc syntax in wallet API section - YAML parser still failing on multi-line content - Need to convert all heredocs to echo commands Solution Applied: ✅ Replaced wallet API heredoc with echo commands ✅ Line-by-line Python script creation for wallet tests ✅ Proper YAML syntax for wallet API section ✅ Maintained complete wallet API functionality Implementation Changes: - Removed wallet API heredoc syntax completely - Used echo commands for each Python line - Proper shell escaping for quotes and strings - Line-by-line file construction Generated Content: - Complete wallet API test script - Wallet health check functions - Wallet endpoint testing logic - Error handling and validation Impact: - YAML file now validates for wallet section - Wallet API test creation works properly - Progress toward complete YAML syntax validation - Need to fix remaining 2 heredocs for complete solution This continues the fix - 2 more heredocs (blockchain RPC and performance) need to be addressed for complete YAML syntax validation.
498 lines
20 KiB
YAML
498 lines
20 KiB
YAML
name: api-endpoint-tests
|
|
|
|
on:
|
|
push:
|
|
branches: [ main, develop ]
|
|
paths:
|
|
- 'apps/coordinator-api/**'
|
|
- 'apps/exchange-api/**'
|
|
- 'apps/wallet-daemon/**'
|
|
- '.gitea/workflows/api-endpoint-tests.yml'
|
|
pull_request:
|
|
branches: [ main, develop ]
|
|
paths:
|
|
- 'apps/coordinator-api/**'
|
|
- 'apps/exchange-api/**'
|
|
- 'apps/wallet-daemon/**'
|
|
- '.gitea/workflows/api-endpoint-tests.yml'
|
|
workflow_dispatch:
|
|
|
|
# Prevent parallel execution - run workflows serially
|
|
concurrency:
|
|
group: ci-workflows
|
|
cancel-in-progress: true
|
|
|
|
jobs:
|
|
test-api-endpoints:
|
|
runs-on: debian
|
|
|
|
steps:
|
|
- name: Setup workspace
|
|
run: |
|
|
echo "=== API ENDPOINT TESTS SETUP ==="
|
|
echo "Current PWD: $(pwd)"
|
|
echo "Forcing absolute workspace path..."
|
|
|
|
# Clean and create isolated workspace
|
|
rm -rf /opt/aitbc/api-tests-workspace
|
|
mkdir -p /opt/aitbc/api-tests-workspace
|
|
cd /opt/aitbc/api-tests-workspace
|
|
|
|
# Ensure no git lock files exist
|
|
find . -name "*.lock" -delete 2>/dev/null || true
|
|
|
|
echo "Workspace PWD: $(pwd)"
|
|
echo "Cloning repository..."
|
|
git clone https://gitea.bubuit.net/oib/aitbc.git repo
|
|
|
|
cd repo
|
|
echo "Repo PWD: $(pwd)"
|
|
echo "Files in repo:"
|
|
ls -la
|
|
|
|
- name: Sync Systemd Files
|
|
run: |
|
|
echo "=== SYNCING SYSTEMD FILES ==="
|
|
cd /opt/aitbc/api-tests-workspace/repo
|
|
|
|
# Ensure systemd files are synced
|
|
if [[ -f "scripts/link-systemd.sh" ]]; then
|
|
echo "🔗 Syncing systemd files..."
|
|
# Update script with correct repository path
|
|
sed -i "s|REPO_SYSTEMD_DIR=\"/opt/aitbc/systemd\"|REPO_SYSTEMD_DIR=\"/opt/aitbc/api-tests-workspace/repo/systemd\"|g" scripts/link-systemd.sh
|
|
sudo ./scripts/link-systemd.sh
|
|
else
|
|
echo "⚠️ Systemd sync script not found"
|
|
fi
|
|
|
|
- name: Start API Services
|
|
run: |
|
|
echo "=== STARTING API SERVICES ==="
|
|
cd /opt/aitbc/api-tests-workspace/repo
|
|
|
|
# Check if running as root
|
|
if [[ $EUID -ne 0 ]]; then
|
|
echo "❌ This step requires root privileges"
|
|
exit 1
|
|
fi
|
|
|
|
echo "🚀 Starting API services..."
|
|
|
|
# Start coordinator API
|
|
echo "🚀 Starting coordinator API..."
|
|
systemctl start aitbc-coordinator-api || echo "Coordinator API already running"
|
|
sleep 3
|
|
|
|
# Start exchange API
|
|
echo "🚀 Starting exchange API..."
|
|
systemctl start aitbc-exchange-api || echo "Exchange API already running"
|
|
sleep 3
|
|
|
|
# Start wallet service
|
|
echo "🚀 Starting wallet service..."
|
|
systemctl start aitbc-wallet || echo "Wallet already running"
|
|
sleep 3
|
|
|
|
# Start blockchain RPC
|
|
echo "🚀 Starting blockchain RPC..."
|
|
systemctl start aitbc-blockchain-rpc || echo "Blockchain RPC already running"
|
|
sleep 3
|
|
|
|
echo "✅ API services started"
|
|
|
|
- name: Wait for APIs Ready
|
|
run: |
|
|
echo "=== WAITING FOR APIS READY ==="
|
|
cd /opt/aitbc/api-tests-workspace/repo
|
|
|
|
echo "⏳ Waiting for APIs to be ready..."
|
|
|
|
# Wait for coordinator API
|
|
for i in {1..30}; do
|
|
if curl -s http://localhost:8000/ >/dev/null 2>&1 || curl -s http://localhost:8000/health >/dev/null 2>&1; then
|
|
echo "✅ Coordinator API is ready"
|
|
break
|
|
fi
|
|
echo "Waiting for coordinator API... ($i/30)"
|
|
sleep 2
|
|
done
|
|
|
|
# Wait for exchange API
|
|
for i in {1..30}; do
|
|
if curl -s http://localhost:8001/ >/dev/null 2>&1; then
|
|
echo "✅ Exchange API is ready"
|
|
break
|
|
fi
|
|
echo "Waiting for exchange API... ($i/30)"
|
|
sleep 2
|
|
done
|
|
|
|
# Wait for wallet API
|
|
for i in {1..30}; do
|
|
if curl -s http://localhost:8002/ >/dev/null 2>&1; then
|
|
echo "✅ Wallet API is ready"
|
|
break
|
|
fi
|
|
echo "Waiting for wallet API... ($i/30)"
|
|
sleep 2
|
|
done
|
|
|
|
# Wait for blockchain RPC
|
|
for i in {1..30}; do
|
|
if curl -s http://localhost:8545 >/dev/null 2>&1; then
|
|
echo "✅ Blockchain RPC is ready"
|
|
break
|
|
fi
|
|
echo "Waiting for blockchain RPC... ($i/30)"
|
|
sleep 2
|
|
done
|
|
|
|
echo "✅ All APIs are ready"
|
|
|
|
- name: Setup Test Environment
|
|
run: |
|
|
echo "=== SETUP TEST ENVIRONMENT ==="
|
|
cd /opt/aitbc/api-tests-workspace/repo
|
|
|
|
# Create virtual environment
|
|
python3 -m venv venv
|
|
source venv/bin/activate
|
|
|
|
# Install test dependencies
|
|
pip install requests pytest httpx websockets pytest-asyncio
|
|
|
|
echo "✅ Test environment ready"
|
|
|
|
- name: Test Coordinator API
|
|
run: |
|
|
echo "=== TESTING COORDINATOR API ==="
|
|
cd /opt/aitbc/api-tests-workspace/repo
|
|
source venv/bin/activate
|
|
|
|
echo "🧪 Testing Coordinator API endpoints..."
|
|
|
|
# Create coordinator API test
|
|
echo 'import requests' > test_coordinator_api.py
|
|
echo 'import json' >> test_coordinator_api.py
|
|
echo '' >> test_coordinator_api.py
|
|
echo 'def test_coordinator_health():' >> test_coordinator_api.py
|
|
echo ' try:' >> test_coordinator_api.py
|
|
echo ' response = requests.get('"'"'http://localhost:8000/'"'"', timeout=5)' >> test_coordinator_api.py
|
|
echo ' print(f"✅ Coordinator health check: {response.status_code}")' >> test_coordinator_api.py
|
|
echo ' return response.status_code == 200' >> test_coordinator_api.py
|
|
echo ' except Exception as e:' >> test_coordinator_api.py
|
|
echo ' print(f"❌ Coordinator health error: {e}")' >> test_coordinator_api.py
|
|
echo ' return False' >> test_coordinator_api.py
|
|
echo '' >> test_coordinator_api.py
|
|
echo 'def test_coordinator_endpoints():' >> test_coordinator_api.py
|
|
echo ' endpoints = [' >> test_coordinator_api.py
|
|
echo ' '"'"'http://localhost:8000/'"'"',' >> test_coordinator_api.py
|
|
echo ' '"'"'http://localhost:8000/health'"'"',' >> test_coordinator_api.py
|
|
echo ' '"'"'http://localhost:8000/info'"'"'' >> test_coordinator_api.py
|
|
echo ' ]' >> test_coordinator_api.py
|
|
echo ' ' >> test_coordinator_api.py
|
|
echo ' results = []' >> test_coordinator_api.py
|
|
echo ' for endpoint in endpoints:' >> test_coordinator_api.py
|
|
echo ' try:' >> test_coordinator_api.py
|
|
echo ' response = requests.get(endpoint, timeout=5)' >> test_coordinator_api.py
|
|
echo ' print(f"✅ {endpoint}: {response.status_code}")' >> test_coordinator_api.py
|
|
echo ' results.append(response.status_code == 200)' >> test_coordinator_api.py
|
|
echo ' except Exception as e:' >> test_coordinator_api.py
|
|
echo ' print(f"❌ {endpoint}: {e}")' >> test_coordinator_api.py
|
|
echo ' results.append(False)' >> test_coordinator_api.py
|
|
echo ' ' >> test_coordinator_api.py
|
|
echo ' return all(results)' >> test_coordinator_api.py
|
|
echo '' >> test_coordinator_api.py
|
|
echo 'if __name__ == "__main__":' >> test_coordinator_api.py
|
|
echo ' print("🧪 Testing Coordinator API...")' >> test_coordinator_api.py
|
|
echo ' ' >> test_coordinator_api.py
|
|
echo ' health_ok = test_coordinator_health()' >> test_coordinator_api.py
|
|
echo ' endpoints_ok = test_coordinator_endpoints()' >> test_coordinator_api.py
|
|
echo ' ' >> test_coordinator_api.py
|
|
echo ' if health_ok and endpoints_ok:' >> test_coordinator_api.py
|
|
echo ' print("✅ Coordinator API tests passed")' >> test_coordinator_api.py
|
|
echo ' else:' >> test_coordinator_api.py
|
|
echo ' print("❌ Coordinator API tests failed")' >> test_coordinator_api.py
|
|
|
|
python test_coordinator_api.py
|
|
|
|
echo "✅ Coordinator API tests completed"
|
|
|
|
- name: Test Exchange API
|
|
run: |
|
|
echo "=== TESTING EXCHANGE API ==="
|
|
cd /opt/aitbc/api-tests-workspace/repo
|
|
source venv/bin/activate
|
|
|
|
echo "🧪 Testing Exchange API endpoints..."
|
|
|
|
# Create exchange API test
|
|
echo 'import requests' > test_exchange_api.py
|
|
echo 'import json' >> test_exchange_api.py
|
|
echo '' >> test_exchange_api.py
|
|
echo 'def test_exchange_health():' >> test_exchange_api.py
|
|
echo ' try:' >> test_exchange_api.py
|
|
echo ' response = requests.get('"'"'http://localhost:8001/'"'"', timeout=5)' >> test_exchange_api.py
|
|
echo ' print(f"✅ Exchange health check: {response.status_code}")' >> test_exchange_api.py
|
|
echo ' return response.status_code == 200' >> test_exchange_api.py
|
|
echo ' except Exception as e:' >> test_exchange_api.py
|
|
echo ' print(f"❌ Exchange health error: {e}")' >> test_exchange_api.py
|
|
echo ' return False' >> test_exchange_api.py
|
|
echo '' >> test_exchange_api.py
|
|
echo 'def test_exchange_endpoints():' >> test_exchange_api.py
|
|
echo ' endpoints = [' >> test_exchange_api.py
|
|
echo ' '"'"'http://localhost:8001/'"'"',' >> test_exchange_api.py
|
|
echo ' '"'"'http://localhost:8001/health'"'"',' >> test_exchange_api.py
|
|
echo ' '"'"'http://localhost:8001/info'"'"'' >> test_exchange_api.py
|
|
echo ' ]' >> test_exchange_api.py
|
|
echo ' ' >> test_exchange_api.py
|
|
echo ' results = []' >> test_exchange_api.py
|
|
echo ' for endpoint in endpoints:' >> test_exchange_api.py
|
|
echo ' try:' >> test_exchange_api.py
|
|
echo ' response = requests.get(endpoint, timeout=5)' >> test_exchange_api.py
|
|
echo ' print(f"✅ {endpoint}: {response.status_code}")' >> test_exchange_api.py
|
|
echo ' results.append(response.status_code == 200)' >> test_exchange_api.py
|
|
echo ' except Exception as e:' >> test_exchange_api.py
|
|
echo ' print(f"❌ {endpoint}: {e}")' >> test_exchange_api.py
|
|
echo ' results.append(False)' >> test_exchange_api.py
|
|
echo ' ' >> test_exchange_api.py
|
|
echo ' return all(results)' >> test_exchange_api.py
|
|
echo '' >> test_exchange_api.py
|
|
echo 'if __name__ == "__main__":' >> test_exchange_api.py
|
|
echo ' print("🧪 Testing Exchange API...")' >> test_exchange_api.py
|
|
echo ' ' >> test_exchange_api.py
|
|
echo ' health_ok = test_exchange_health()' >> test_exchange_api.py
|
|
echo ' endpoints_ok = test_exchange_endpoints()' >> test_exchange_api.py
|
|
echo ' ' >> test_exchange_api.py
|
|
echo ' if health_ok and endpoints_ok:' >> test_exchange_api.py
|
|
echo ' print("✅ Exchange API tests passed")' >> test_exchange_api.py
|
|
echo ' else:' >> test_exchange_api.py
|
|
echo ' print("❌ Exchange API tests failed")' >> test_exchange_api.py
|
|
|
|
python test_exchange_api.py
|
|
|
|
echo "✅ Exchange API tests completed"
|
|
|
|
- name: Test Wallet API
|
|
run: |
|
|
echo "=== TESTING WALLET API ==="
|
|
cd /opt/aitbc/api-tests-workspace/repo
|
|
source venv/bin/activate
|
|
|
|
echo "🧪 Testing Wallet API endpoints..."
|
|
|
|
# Create wallet API test
|
|
echo 'import requests' > test_wallet_api.py
|
|
echo 'import json' >> test_wallet_api.py
|
|
echo '' >> test_wallet_api.py
|
|
echo 'def test_wallet_health():' >> test_wallet_api.py
|
|
echo ' try:' >> test_wallet_api.py
|
|
echo ' response = requests.get('"'"'http://localhost:8002/'"'"', timeout=5)' >> test_wallet_api.py
|
|
echo ' print(f"✅ Wallet health check: {response.status_code}")' >> test_wallet_api.py
|
|
echo ' return response.status_code == 200' >> test_wallet_api.py
|
|
echo ' except Exception as e:' >> test_wallet_api.py
|
|
echo ' print(f"❌ Wallet health error: {e}")' >> test_wallet_api.py
|
|
echo ' return False' >> test_wallet_api.py
|
|
echo '' >> test_wallet_api.py
|
|
echo 'def test_wallet_endpoints():' >> test_wallet_api.py
|
|
echo ' endpoints = [' >> test_wallet_api.py
|
|
echo ' '"'"'http://localhost:8002/'"'"',' >> test_wallet_api.py
|
|
echo ' '"'"'http://localhost:8002/health'"'"',' >> test_wallet_api.py
|
|
echo ' '"'"'http://localhost:8002/wallets'"'"'' >> test_wallet_api.py
|
|
echo ' ]' >> test_wallet_api.py
|
|
echo ' ' >> test_wallet_api.py
|
|
echo ' results = []' >> test_wallet_api.py
|
|
echo ' for endpoint in endpoints:' >> test_wallet_api.py
|
|
echo ' try:' >> test_wallet_api.py
|
|
echo ' response = requests.get(endpoint, timeout=5)' >> test_wallet_api.py
|
|
echo ' print(f"✅ {endpoint}: {response.status_code}")' >> test_wallet_api.py
|
|
echo ' results.append(response.status_code == 200)' >> test_wallet_api.py
|
|
echo ' except Exception as e:' >> test_wallet_api.py
|
|
echo ' print(f"❌ {endpoint}: {e}")' >> test_wallet_api.py
|
|
echo ' results.append(False)' >> test_wallet_api.py
|
|
echo ' ' >> test_wallet_api.py
|
|
echo ' return all(results)' >> test_wallet_api.py
|
|
echo '' >> test_wallet_api.py
|
|
echo 'if __name__ == "__main__":' >> test_wallet_api.py
|
|
echo ' print("🧪 Testing Wallet API...")' >> test_wallet_api.py
|
|
echo ' ' >> test_wallet_api.py
|
|
echo ' health_ok = test_wallet_health()' >> test_wallet_api.py
|
|
echo ' endpoints_ok = test_wallet_endpoints()' >> test_wallet_api.py
|
|
echo ' ' >> test_wallet_api.py
|
|
echo ' if health_ok and endpoints_ok:' >> test_wallet_api.py
|
|
echo ' print("✅ Wallet API tests passed")' >> test_wallet_api.py
|
|
echo ' else:' >> test_wallet_api.py
|
|
echo ' print("❌ Wallet API tests failed")' >> test_wallet_api.py
|
|
|
|
python test_wallet_api.py
|
|
|
|
echo "✅ Wallet API tests completed"
|
|
|
|
- name: Test Blockchain RPC
|
|
run: |
|
|
echo "=== TESTING BLOCKCHAIN RPC ==="
|
|
cd /opt/aitbc/api-tests-workspace/repo
|
|
source venv/bin/activate
|
|
|
|
echo "🧪 Testing Blockchain RPC endpoints..."
|
|
|
|
# Create blockchain RPC test
|
|
cat > test_blockchain_rpc.py << 'EOF'
|
|
import requests
|
|
import json
|
|
|
|
def test_rpc_connection():
|
|
try:
|
|
payload = {
|
|
"jsonrpc": "2.0",
|
|
"method": "eth_blockNumber",
|
|
"params": [],
|
|
"id": 1
|
|
}
|
|
response = requests.post('http://localhost:8545', json=payload, timeout=5)
|
|
if response.status_code == 200:
|
|
result = response.json()
|
|
print(f"✅ RPC connection: {result.get('result', 'Unknown block number')}")
|
|
return True
|
|
else:
|
|
print(f"❌ RPC connection failed: {response.status_code}")
|
|
return False
|
|
except Exception as e:
|
|
print(f"❌ RPC connection error: {e}")
|
|
return False
|
|
|
|
def test_rpc_methods():
|
|
methods = [
|
|
{"method": "eth_chainId", "params": []},
|
|
{"method": "eth_getBlockByNumber", "params": ["latest", False]},
|
|
{"method": "net_version", "params": []}
|
|
]
|
|
|
|
results = []
|
|
for method in methods:
|
|
try:
|
|
payload = {
|
|
"jsonrpc": "2.0",
|
|
"method": method["method"],
|
|
"params": method["params"],
|
|
"id": 1
|
|
}
|
|
response = requests.post('http://localhost:8545', json=payload, timeout=5)
|
|
if response.status_code == 200:
|
|
result = response.json()
|
|
print(f"✅ {method['method']}: {result.get('result', 'Success')}")
|
|
results.append(True)
|
|
else:
|
|
print(f"❌ {method['method']}: {response.status_code}")
|
|
results.append(False)
|
|
except Exception as e:
|
|
print(f"❌ {method['method']}: {e}")
|
|
results.append(False)
|
|
|
|
return all(results)
|
|
|
|
if __name__ == "__main__":
|
|
print("🧪 Testing Blockchain RPC...")
|
|
|
|
connection_ok = test_rpc_connection()
|
|
methods_ok = test_rpc_methods()
|
|
|
|
if connection_ok and methods_ok:
|
|
print("✅ Blockchain RPC tests passed")
|
|
else:
|
|
print("❌ Blockchain RPC tests failed")
|
|
EOF
|
|
|
|
python test_blockchain_rpc.py
|
|
|
|
echo "✅ Blockchain RPC tests completed"
|
|
|
|
- name: Test API Performance
|
|
run: |
|
|
echo "=== TESTING API PERFORMANCE ==="
|
|
cd /opt/aitbc/api-tests-workspace/repo
|
|
source venv/bin/activate
|
|
|
|
echo "⚡ Testing API performance..."
|
|
|
|
# Create performance test
|
|
cat > test_api_performance.py << 'EOF'
|
|
import requests
|
|
import time
|
|
import statistics
|
|
|
|
def measure_response_time(url, timeout=5):
|
|
try:
|
|
start_time = time.time()
|
|
response = requests.get(url, timeout=timeout)
|
|
end_time = time.time()
|
|
return end_time - start_time, response.status_code
|
|
except Exception as e:
|
|
return None, str(e)
|
|
|
|
def test_api_performance():
|
|
apis = [
|
|
("Coordinator API", "http://localhost:8000/"),
|
|
("Exchange API", "http://localhost:8001/"),
|
|
("Wallet API", "http://localhost:8002/"),
|
|
("Blockchain RPC", "http://localhost:8545")
|
|
]
|
|
|
|
for name, url in apis:
|
|
print(f"\n📊 Testing {name} performance...")
|
|
|
|
times = []
|
|
success_count = 0
|
|
|
|
for i in range(10):
|
|
response_time, status = measure_response_time(url)
|
|
if response_time is not None:
|
|
times.append(response_time)
|
|
if status == 200:
|
|
success_count += 1
|
|
print(f" Request {i+1}: {response_time:.3f}s (status: {status})")
|
|
else:
|
|
print(f" Request {i+1}: Failed ({status})")
|
|
|
|
if times:
|
|
avg_time = statistics.mean(times)
|
|
min_time = min(times)
|
|
max_time = max(times)
|
|
|
|
print(f" 📈 Average: {avg_time:.3f}s")
|
|
print(f" 📉 Min: {min_time:.3f}s")
|
|
print(f" 📈 Max: {max_time:.3f}s")
|
|
print(f" ✅ Success rate: {success_count}/10")
|
|
else:
|
|
print(f" ❌ All requests failed")
|
|
|
|
if __name__ == "__main__":
|
|
print("⚡ Testing API performance...")
|
|
test_api_performance()
|
|
EOF
|
|
|
|
python test_api_performance.py
|
|
|
|
echo "✅ API performance tests completed"
|
|
|
|
- name: Upload Test Results
|
|
if: always()
|
|
run: |
|
|
echo "=== UPLOADING TEST RESULTS ==="
|
|
cd /opt/aitbc/api-tests-workspace/repo
|
|
|
|
# Create results directory
|
|
mkdir -p api-test-results
|
|
|
|
# Copy test results
|
|
cp test_coordinator_api.py api-test-results/ 2>/dev/null || true
|
|
cp test_exchange_api.py api-test-results/ 2>/dev/null || true
|
|
cp test_wallet_api.py api-test-results/ 2>/dev/null || true
|
|
cp test_blockchain_rpc.py api-test-results/ 2>/dev/null || true
|
|
cp test_api_performance.py api-test-results/ 2>/dev/null || true
|
|
|
|
echo "📊 API test results saved to api-test-results/"
|
|
ls -la api-test-results/
|
|
|
|
echo "✅ Test results uploaded"
|