diff --git a/.gitea/workflows/api-endpoint-tests.yml b/.gitea/workflows/api-endpoint-tests.yml
new file mode 100644
index 00000000..12b1df65
--- /dev/null
+++ b/.gitea/workflows/api-endpoint-tests.yml
@@ -0,0 +1,501 @@
+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..."
+            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
+          cat > test_coordinator_api.py << 'EOF'
+import requests
+import json
+
+def test_coordinator_health():
+    try:
+        response = requests.get('http://localhost:8000/', timeout=5)
+        print(f"✅ Coordinator health check: {response.status_code}")
+        return response.status_code == 200
+    except Exception as e:
+        print(f"❌ Coordinator health error: {e}")
+        return False
+
+def test_coordinator_endpoints():
+    endpoints = [
+        'http://localhost:8000/',
+        'http://localhost:8000/health',
+        'http://localhost:8000/info'
+    ]
+    
+    results = []
+    for endpoint in endpoints:
+        try:
+            response = requests.get(endpoint, timeout=5)
+            print(f"✅ {endpoint}: {response.status_code}")
+            results.append(response.status_code == 200)
+        except Exception as e:
+            print(f"❌ {endpoint}: {e}")
+            results.append(False)
+    
+    return all(results)
+
+if __name__ == "__main__":
+    print("🧪 Testing Coordinator API...")
+    
+    health_ok = test_coordinator_health()
+    endpoints_ok = test_coordinator_endpoints()
+    
+    if health_ok and endpoints_ok:
+        print("✅ Coordinator API tests passed")
+    else:
+        print("❌ Coordinator API tests failed")
+EOF
+          
+          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
+          cat > test_exchange_api.py << 'EOF'
+import requests
+import json
+
+def test_exchange_health():
+    try:
+        response = requests.get('http://localhost:8001/', timeout=5)
+        print(f"✅ Exchange health check: {response.status_code}")
+        return response.status_code == 200
+    except Exception as e:
+        print(f"❌ Exchange health error: {e}")
+        return False
+
+def test_exchange_endpoints():
+    endpoints = [
+        'http://localhost:8001/',
+        'http://localhost:8001/health',
+        'http://localhost:8001/markets'
+    ]
+    
+    results = []
+    for endpoint in endpoints:
+        try:
+            response = requests.get(endpoint, timeout=5)
+            print(f"✅ {endpoint}: {response.status_code}")
+            results.append(response.status_code == 200)
+        except Exception as e:
+            print(f"❌ {endpoint}: {e}")
+            results.append(False)
+    
+    return all(results)
+
+if __name__ == "__main__":
+    print("🧪 Testing Exchange API...")
+    
+    health_ok = test_exchange_health()
+    endpoints_ok = test_exchange_endpoints()
+    
+    if health_ok and endpoints_ok:
+        print("✅ Exchange API tests passed")
+    else:
+        print("❌ Exchange API tests failed")
+EOF
+          
+          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
+          cat > test_wallet_api.py << 'EOF'
+import requests
+import json
+
+def test_wallet_health():
+    try:
+        response = requests.get('http://localhost:8002/', timeout=5)
+        print(f"✅ Wallet health check: {response.status_code}")
+        return response.status_code == 200
+    except Exception as e:
+        print(f"❌ Wallet health error: {e}")
+        return False
+
+def test_wallet_endpoints():
+    endpoints = [
+        'http://localhost:8002/',
+        'http://localhost:8002/health',
+        'http://localhost:8002/wallets'
+    ]
+    
+    results = []
+    for endpoint in endpoints:
+        try:
+            response = requests.get(endpoint, timeout=5)
+            print(f"✅ {endpoint}: {response.status_code}")
+            results.append(response.status_code == 200)
+        except Exception as e:
+            print(f"❌ {endpoint}: {e}")
+            results.append(False)
+    
+    return all(results)
+
+if __name__ == "__main__":
+    print("🧪 Testing Wallet API...")
+    
+    health_ok = test_wallet_health()
+    endpoints_ok = test_wallet_endpoints()
+    
+    if health_ok and endpoints_ok:
+        print("✅ Wallet API tests passed")
+    else:
+        print("❌ Wallet API tests failed")
+EOF
+          
+          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"
diff --git a/.gitea/workflows/integration-tests.yml b/.gitea/workflows/integration-tests.yml
new file mode 100644
index 00000000..f649a0a8
--- /dev/null
+++ b/.gitea/workflows/integration-tests.yml
@@ -0,0 +1,413 @@
+name: integration-tests
+
+on:
+  push:
+    branches: [ main, develop ]
+    paths:
+      - 'apps/**'
+      - 'packages/**'
+      - '.gitea/workflows/integration-tests.yml'
+  pull_request:
+    branches: [ main, develop ]
+    paths:
+      - 'apps/**'
+      - 'packages/**'
+      - '.gitea/workflows/integration-tests.yml'
+  workflow_dispatch:
+
+# Prevent parallel execution - run workflows serially
+concurrency:
+  group: ci-workflows
+  cancel-in-progress: true
+
+jobs:
+  test-service-integration:
+    runs-on: debian
+    
+    steps:
+      - name: Setup workspace
+        run: |
+          echo "=== INTEGRATION TESTS SETUP ==="
+          echo "Current PWD: $(pwd)"
+          echo "Forcing absolute workspace path..."
+          
+          # Clean and create isolated workspace
+          rm -rf /opt/aitbc/integration-tests-workspace
+          mkdir -p /opt/aitbc/integration-tests-workspace
+          cd /opt/aitbc/integration-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/integration-tests-workspace/repo
+          
+          # Ensure systemd files are synced
+          if [[ -f "scripts/link-systemd.sh" ]]; then
+            echo "🔗 Syncing systemd files..."
+            sudo ./scripts/link-systemd.sh
+          else
+            echo "⚠️  Systemd sync script not found"
+          fi
+
+      - name: Start Required Services
+        run: |
+          echo "=== STARTING REQUIRED SERVICES ==="
+          cd /opt/aitbc/integration-tests-workspace/repo
+          
+          # Check if running as root
+          if [[ $EUID -ne 0 ]]; then
+            echo "❌ This step requires root privileges"
+            exit 1
+          fi
+          
+          echo "🔍 Checking service status..."
+          
+          # Start blockchain node
+          echo "🚀 Starting blockchain node..."
+          systemctl start aitbc-blockchain-node || echo "Blockchain node already running"
+          sleep 5
+          
+          # Start coordinator API
+          echo "🚀 Starting coordinator API..."
+          systemctl start aitbc-coordinator-api || echo "Coordinator API already running"
+          sleep 3
+          
+          # Start marketplace service
+          echo "🚀 Starting marketplace service..."
+          systemctl start aitbc-marketplace || echo "Marketplace already running"
+          sleep 3
+          
+          # Start wallet service
+          echo "🚀 Starting wallet service..."
+          systemctl start aitbc-wallet || echo "Wallet already running"
+          sleep 3
+          
+          echo "📊 Service status:"
+          systemctl status aitbc-blockchain-node --no-pager -l || echo "Blockchain node status unavailable"
+          systemctl status aitbc-coordinator-api --no-pager -l || echo "Coordinator API status unavailable"
+          
+          echo "✅ Services started"
+
+      - name: Wait for Services Ready
+        run: |
+          echo "=== WAITING FOR SERVICES READY ==="
+          cd /opt/aitbc/integration-tests-workspace/repo
+          
+          echo "⏳ Waiting for services to be ready..."
+          
+          # Wait for blockchain node
+          echo "Checking blockchain node..."
+          for i in {1..30}; do
+            if systemctl is-active --quiet aitbc-blockchain-node; then
+              echo "✅ Blockchain node is ready"
+              break
+            fi
+            echo "Waiting for blockchain node... ($i/30)"
+            sleep 2
+          done
+          
+          # Wait for coordinator API
+          echo "Checking coordinator API..."
+          for i in {1..30}; do
+            if systemctl is-active --quiet aitbc-coordinator-api; then
+              echo "✅ Coordinator API is ready"
+              break
+            fi
+            echo "Waiting for coordinator API... ($i/30)"
+            sleep 2
+          done
+          
+          # Wait for API endpoints to respond
+          echo "Checking API endpoints..."
+          for i in {1..30}; do
+            if curl -s http://localhost:8000/health >/dev/null 2>&1 || curl -s http://localhost:8000/ >/dev/null 2>&1; then
+              echo "✅ API endpoint is responding"
+              break
+            fi
+            echo "Waiting for API endpoint... ($i/30)"
+            sleep 2
+          done
+          
+          echo "✅ All services are ready"
+
+      - name: Setup Python Environment
+        run: |
+          echo "=== PYTHON ENVIRONMENT SETUP ==="
+          cd /opt/aitbc/integration-tests-workspace/repo
+          
+          # Create virtual environment
+          python3 -m venv venv
+          source venv/bin/activate
+          
+          echo "Project venv activated"
+          echo "Python in venv: $(python --version)"
+          echo "Pip in venv: $(pip --version)"
+          
+          # Install dependencies
+          echo "Installing dependencies..."
+          pip install requests pytest httpx asyncio-mqtt websockets
+          
+          echo "✅ Python environment ready"
+
+      - name: Run Integration Tests
+        run: |
+          echo "=== RUNNING INTEGRATION TESTS ==="
+          cd /opt/aitbc/integration-tests-workspace/repo
+          source venv/bin/activate
+          
+          echo "🧪 Testing blockchain node integration..."
+          
+          # Test blockchain node RPC
+          echo "Testing blockchain RPC..."
+          if curl -s http://localhost:8545 >/dev/null 2>&1; then
+            echo "✅ Blockchain RPC is accessible"
+          else
+            echo "❌ Blockchain RPC not accessible"
+          fi
+          
+          # Test coordinator API
+          echo "Testing coordinator API..."
+          if curl -s http://localhost:8000/health >/dev/null 2>&1 || curl -s http://localhost:8000/ >/dev/null 2>&1; then
+            echo "✅ Coordinator API is responding"
+          else
+            echo "❌ Coordinator API not responding"
+          fi
+          
+          # Test marketplace service
+          echo "Testing marketplace service..."
+          if curl -s http://localhost:3001 >/dev/null 2>&1; then
+            echo "✅ Marketplace service is responding"
+          else
+            echo "❌ Marketplace service not responding"
+          fi
+          
+          # Test wallet service
+          echo "Testing wallet service..."
+          if curl -s http://localhost:8002 >/dev/null 2>&1; then
+            echo "✅ Wallet service is responding"
+          else
+            echo "❌ Wallet service not responding"
+          fi
+          
+          echo "✅ Integration tests completed"
+
+      - name: Test Cross-Service Communication
+        run: |
+          echo "=== TESTING CROSS-SERVICE COMMUNICATION ==="
+          cd /opt/aitbc/integration-tests-workspace/repo
+          source venv/bin/activate
+          
+          echo "🔗 Testing service-to-service communication..."
+          
+          # Create test script
+          cat > test_integration.py << 'EOF'
+import requests
+import json
+import time
+
+def test_coordinator_api():
+    try:
+        response = requests.get('http://localhost:8000/', timeout=5)
+        print(f"✅ Coordinator API responded: {response.status_code}")
+        return True
+    except Exception as e:
+        print(f"❌ Coordinator API error: {e}")
+        return False
+
+def test_blockchain_rpc():
+    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"✅ Blockchain RPC responded: {result.get('result', 'Unknown')}")
+            return True
+    except Exception as e:
+        print(f"❌ Blockchain RPC error: {e}")
+        return False
+
+def test_marketplace():
+    try:
+        response = requests.get('http://localhost:3001/', timeout=5)
+        print(f"✅ Marketplace responded: {response.status_code}")
+        return True
+    except Exception as e:
+        print(f"❌ Marketplace error: {e}")
+        return False
+
+if __name__ == "__main__":
+    print("🧪 Running cross-service communication tests...")
+    
+    results = []
+    results.append(test_coordinator_api())
+    results.append(test_blockchain_rpc())
+    results.append(test_marketplace())
+    
+    success_count = sum(results)
+    total_count = len(results)
+    
+    print(f"\n📊 Test Results: {success_count}/{total_count} services working")
+    
+    if success_count == total_count:
+        print("✅ All services communicating successfully")
+    else:
+        print("⚠️  Some services not communicating properly")
+EOF
+          
+          # Run integration test
+          python test_integration.py
+          
+          echo "✅ Cross-service communication tests completed"
+
+      - name: Test End-to-End Workflows
+        run: |
+          echo "=== TESTING END-TO-END WORKFLOWS ==="
+          cd /opt/aitbc/integration-tests-workspace/repo
+          source venv/bin/activate
+          
+          echo "🔄 Testing end-to-end workflows..."
+          
+          # Test blockchain operations
+          echo "Testing blockchain operations..."
+          
+          # Create E2E test script
+          cat > test_e2e.py << 'EOF'
+import requests
+import json
+import time
+
+def test_blockchain_operations():
+    try:
+        # Get latest block
+        payload = {
+            "jsonrpc": "2.0",
+            "method": "eth_getBlockByNumber",
+            "params": ["latest", False],
+            "id": 1
+        }
+        response = requests.post('http://localhost:8545', json=payload, timeout=5)
+        if response.status_code == 200:
+            block = response.json().get('result', {})
+            print(f"✅ Latest block: {block.get('number', 'Unknown')}")
+            return True
+    except Exception as e:
+        print(f"❌ Blockchain operations error: {e}")
+        return False
+
+def test_api_endpoints():
+    try:
+        # Test API health
+        response = requests.get('http://localhost:8000/', timeout=5)
+        if response.status_code == 200:
+            print("✅ API health check passed")
+            return True
+    except Exception as e:
+        print(f"❌ API endpoints error: {e}")
+        return False
+
+if __name__ == "__main__":
+    print("🔄 Running end-to-end workflow tests...")
+    
+    results = []
+    results.append(test_blockchain_operations())
+    results.append(test_api_endpoints())
+    
+    success_count = sum(results)
+    total_count = len(results)
+    
+    print(f"\n📊 E2E Results: {success_count}/{total_count} workflows working")
+    
+    if success_count == total_count:
+        print("✅ All end-to-end workflows successful")
+    else:
+        print("⚠️  Some workflows not working properly")
+EOF
+          
+          # Run E2E test
+          python test_e2e.py
+          
+          echo "✅ End-to-end workflow tests completed"
+
+      - name: Collect Service Logs
+        if: always()
+        run: |
+          echo "=== COLLECTING SERVICE LOGS ==="
+          cd /opt/aitbc/integration-tests-workspace/repo
+          
+          mkdir -p service-logs
+          
+          # Collect service logs
+          echo "📋 Collecting service logs..."
+          
+          # Blockchain node logs
+          journalctl -u aitbc-blockchain-node --since "5 minutes ago" --no-pager > service-logs/blockchain-node.log 2>&1 || echo "No blockchain logs available"
+          
+          # Coordinator API logs
+          journalctl -u aitbc-coordinator-api --since "5 minutes ago" --no-pager > service-logs/coordinator-api.log 2>&1 || echo "No coordinator API logs available"
+          
+          # Marketplace logs
+          journalctl -u aitbc-marketplace --since "5 minutes ago" --no-pager > service-logs/marketplace.log 2>&1 || echo "No marketplace logs available"
+          
+          # Wallet logs
+          journalctl -u aitbc-wallet --since "5 minutes ago" --no-pager > service-logs/wallet.log 2>&1 || echo "No wallet logs available"
+          
+          echo "📊 Log files collected:"
+          ls -la service-logs/
+          
+          echo "✅ Service logs collected"
+
+      - name: Cleanup Services
+        if: always()
+        run: |
+          echo "=== CLEANING UP SERVICES ==="
+          cd /opt/aitbc/integration-tests-workspace/repo
+          
+          if [[ $EUID -eq 0 ]]; then
+            echo "🧹 Stopping services..."
+            
+            # Stop services (optional - keep them running for other tests)
+            # systemctl stop aitbc-blockchain-node
+            # systemctl stop aitbc-coordinator-api
+            # systemctl stop aitbc-marketplace
+            # systemctl stop aitbc-wallet
+            
+            echo "✅ Services cleanup completed"
+          else
+            echo "⚠️  Cannot cleanup services without root privileges"
+          fi
+
+      - name: Upload Test Results
+        if: always()
+        run: |
+          echo "=== UPLOADING TEST RESULTS ==="
+          cd /opt/aitbc/integration-tests-workspace/repo
+          
+          # Create results directory
+          mkdir -p integration-test-results
+          
+          # Copy test results
+          cp test_integration.py integration-test-results/ 2>/dev/null || true
+          cp test_e2e.py integration-test-results/ 2>/dev/null || true
+          cp -r service-logs integration-test-results/ 2>/dev/null || true
+          
+          echo "📊 Integration test results saved to integration-test-results/"
+          ls -la integration-test-results/
+          
+          echo "✅ Test results uploaded"