oib/aitbc
1
0
Fork 0
Code Issues Pull Requests Actions 7 Packages Projects Releases Wiki Activity
Files
101e3c4fb38d395ef232a92f6b2f5715cdda5d8a
aitbc/.gitea/workflows/api-endpoint-tests.yml
Workflow config file is invalid. Please check your config file: yaml: line 418: could not find expected ':'
aitbc1 101e3c4fb3 fix: replace blockchain RPC heredoc with echo commands in api-endpoint-tests.yml 
API ENDPOINT TESTS YAML FIX: Continue fixing YAML syntax errors

Issues Fixed:
❌ Blockchain RPC heredoc causing YAML parsing issues
❌ Complex RPC test script creation failing
❌ Multi-line Python content with JSON being parsed as YAML

Root Cause:
- Remaining heredoc syntax in blockchain RPC section
- YAML parser still failing on complex multi-line content
- Need to convert all heredocs to echo commands

Solution Applied:
✅ Replaced blockchain RPC heredoc with echo commands
✅ Line-by-line Python script creation for RPC tests
✅ Proper YAML syntax for blockchain RPC section
✅ Maintained complete RPC functionality

Implementation Changes:
- Removed blockchain RPC heredoc syntax completely
- Used echo commands for each Python line
- Proper shell escaping for quotes and JSON structures
- Line-by-line file construction

Generated Content:
- Complete blockchain RPC test script
- RPC connection testing functions
- Multiple RPC method testing
- JSON-RPC payload handling
- Error handling and validation

Impact:
- YAML file now validates for blockchain RPC section
- RPC test creation works properly
- Progress toward complete YAML syntax validation
- Need to fix final performance test heredoc for complete solution

This continues the fix - 1 more heredoc (performance test)
needs to be addressed for complete YAML syntax validation.
2026-03-27 23:55:42 +01:00

496 lines
23 KiB
YAML
Raw Blame History

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
echo 'import requests' > test_blockchain_rpc.py
echo 'import json' >> test_blockchain_rpc.py
echo '' >> test_blockchain_rpc.py
echo 'def test_rpc_connection():' >> test_blockchain_rpc.py
echo ' try:' >> test_blockchain_rpc.py
echo ' payload = {' >> test_blockchain_rpc.py
echo ' "jsonrpc": "2.0",' >> test_blockchain_rpc.py
echo ' "method": "eth_blockNumber",' >> test_blockchain_rpc.py
echo ' "params": [],' >> test_blockchain_rpc.py
echo ' "id": 1' >> test_blockchain_rpc.py
echo ' }' >> test_blockchain_rpc.py
echo ' response = requests.post('"'"'http://localhost:8545'"'"', json=payload, timeout=5)' >> test_blockchain_rpc.py
echo ' if response.status_code == 200:' >> test_blockchain_rpc.py
echo ' result = response.json()' >> test_blockchain_rpc.py
echo ' print(f"✅ RPC connection: {result.get('"'"'result'"'"', '"'"'Unknown block number'"'"')}")' >> test_blockchain_rpc.py
echo ' return True' >> test_blockchain_rpc.py
echo ' else:' >> test_blockchain_rpc.py
echo ' print(f"❌ RPC connection failed: {response.status_code}")' >> test_blockchain_rpc.py
echo ' return False' >> test_blockchain_rpc.py
echo ' except Exception as e:' >> test_blockchain_rpc.py
echo ' print(f"❌ RPC connection error: {e}")' >> test_blockchain_rpc.py
echo ' return False' >> test_blockchain_rpc.py
echo '' >> test_blockchain_rpc.py
echo 'def test_rpc_methods():' >> test_blockchain_rpc.py
echo ' methods = [' >> test_blockchain_rpc.py
echo ' {"method": "eth_getBalance", "params": ["0x0000000000000000000000000000000000000000", "latest"]},' >> test_blockchain_rpc.py
echo ' {"method": "eth_chainId", "params": []},' >> test_blockchain_rpc.py
echo ' {"method": "eth_gasPrice", "params": []}' >> test_blockchain_rpc.py
echo ' ]' >> test_blockchain_rpc.py
echo ' ' >> test_blockchain_rpc.py
echo ' results = []' >> test_blockchain_rpc.py
echo ' for method in methods:' >> test_blockchain_rpc.py
echo ' try:' >> test_blockchain_rpc.py
echo ' payload = {' >> test_blockchain_rpc.py
echo ' "jsonrpc": "2.0",' >> test_blockchain_rpc.py
echo ' "method": method["method"],' >> test_blockchain_rpc.py
echo ' "params": method["params"],' >> test_blockchain_rpc.py
echo ' "id": 1' >> test_blockchain_rpc.py
echo ' }' >> test_blockchain_rpc.py
echo ' response = requests.post('"'"'http://localhost:8545'"'"', json=payload, timeout=5)' >> test_blockchain_rpc.py
echo ' if response.status_code == 200:' >> test_blockchain_rpc.py
echo ' result = response.json()' >> test_blockchain_rpc.py
echo ' print(f"✅ {method['"'"'method'"'"']}: {result.get('"'"'result'"'"', '"'"'Success'"'"')}")' >> test_blockchain_rpc.py
echo ' results.append(True)' >> test_blockchain_rpc.py
echo ' else:' >> test_blockchain_rpc.py
echo ' print(f"❌ {method['"'"'method'"'"']}: {response.status_code}")' >> test_blockchain_rpc.py
echo ' results.append(False)' >> test_blockchain_rpc.py
echo ' except Exception as e:' >> test_blockchain_rpc.py
echo ' print(f"❌ {method['"'"'method'"'"']}: {e}")' >> test_blockchain_rpc.py
echo ' results.append(False)' >> test_blockchain_rpc.py
echo ' ' >> test_blockchain_rpc.py
echo ' return all(results)' >> test_blockchain_rpc.py
echo '' >> test_blockchain_rpc.py
echo 'if __name__ == "__main__":' >> test_blockchain_rpc.py
echo ' print("🧪 Testing Blockchain RPC...")' >> test_blockchain_rpc.py
echo ' ' >> test_blockchain_rpc.py
echo ' connection_ok = test_rpc_connection()' >> test_blockchain_rpc.py
echo ' methods_ok = test_rpc_methods()' >> test_blockchain_rpc.py
echo ' ' >> test_blockchain_rpc.py
echo ' if connection_ok and methods_ok:' >> test_blockchain_rpc.py
echo ' print("✅ Blockchain RPC tests passed")' >> test_blockchain_rpc.py
echo ' else:' >> test_blockchain_rpc.py
echo ' print("❌ Blockchain RPC tests failed")' >> test_blockchain_rpc.py
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"
Reference in New Issue View Git Blame Copy Permalink