High Priority Issues - EventStreamMonitor (6 issues)

[Ricky512227]

HIGH Priority Bug Report for EventStreamMonitor

Date: 2025-12-23T23:00:09.278Z

Priority: P0
Severity: HIGH
Total Issues: 6

1. scripts/dry_run_tests.py:150

Category: error_handling

Bare except or except: pass - should catch specific exceptions

        response = requests.get(SERVICES['notification']['url'], timeout=5)
        print(f" Notification service is reachable (status: {response.status_code})")
        results.append(("API Endpoint", "notification", True))
    except:
        print(" Notification service connection refused")
        results.append(("API Endpoint", "notification", False))
    

2. tests/integration/test_all_services.py:31

Category: error_handling

Bare except or except: pass - should catch specific exceptions

    try:
        response = requests.get(f"{url}/health", timeout=5)
        return response.status_code == 200
    except:
        return False

3. tests/integration/test_all_services.py:106

Category: security

Use of eval() is dangerous and can lead to code injection

        return None


def test_task_retrieval(task_id):
    """Test task retrieval"""
    print("\n" + "="*60)
    print("TEST: Task Retrieval")

4. tests/integration/test_all_services.py:189

Category: security

Use of eval() is dangerous and can lead to code injection

        results["task_creation"] = task_id is not None
        
        if task_id:
            results["task_retrieval"] = test_task_retrieval(task_id)
        else:
            print("\n  Task test skipped")
            results["task_retrieval"] = None

5. tests/integration/test_register_user.py:68

Category: error_handling

Bare except or except: pass - should catch specific exceptions

        try:
            response_json = response.json()
            print(f"Response Body: {json.dumps(response_json, indent=2)}")
        except:
            print(f"Response Body (text): {response.text}")
        
        return response.status_code, response.json() if response.headers.get('content-type', '').startswith('application/json') else response.text

6. tests/integration/test_register_user.py:91

Category: error_handling

Bare except or except: pass - should catch specific exceptions

    try:
        health_check = requests.get(f"{BASE_URL}/health", timeout=5)
        print(f"Service health check: {health_check.status_code}")
    except:
        print("WARNING: Service health check failed, but continuing with tests...")
    
    results = []

Full report available in workflow artifacts.