improved formatting etc

Author: chrishayuk

.github/workflows/publish.yml

@@ -0,0 +1,51 @@
+name: Publish to PyPI
+
+on:
+  release:
+    types: [published]
+  workflow_dispatch:
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+    - uses: actions/checkout@v4
+    
+    - name: Install uv
+      uses: astral-sh/setup-uv@v4
+      with:
+        enable-cache: true
+    
+    - name: Set up Python
+      run: uv python install 3.12
+    
+    - name: Build package
+      run: |
+        uv build
+    
+    - name: Upload artifacts
+      uses: actions/upload-artifact@v4
+      with:
+        name: dist
+        path: dist/
+
+  publish:
+    needs: build
+    runs-on: ubuntu-latest
+    environment:
+      name: pypi
+      url: https://pypi.org/p/chuk-tool-processor
+    permissions:
+      id-token: write
+    
+    steps:
+    - name: Download artifacts
+      uses: actions/download-artifact@v4
+      with:
+        name: dist
+        path: dist/
+    
+    - name: Publish to PyPI
+      uses: pypa/gh-action-pypi-publish@release/v1
+      with:
+        verbose: true

.github/workflows/test.yml

@@ -0,0 +1,69 @@
+name: Test
+
+on:
+  push:
+    branches: [ main, develop ]
+  pull_request:
+    branches: [ main ]
+  workflow_dispatch:
+
+jobs:
+  test:
+    runs-on: ${{ matrix.os }}
+    strategy:
+      fail-fast: false
+      matrix:
+        os: [ubuntu-latest, windows-latest, macos-latest]
+        python-version: ["3.11", "3.12", "3.13"]
+    
+    steps:
+    - uses: actions/checkout@v4
+    
+    - name: Install uv
+      uses: astral-sh/setup-uv@v4
+      with:
+        enable-cache: true
+        cache-dependency-glob: "uv.lock"
+    
+    - name: Set up Python ${{ matrix.python-version }}
+      run: uv python install ${{ matrix.python-version }}
+    
+    - name: Install dependencies
+      run: |
+        uv sync --dev
+    
+    - name: Run linting
+      run: |
+        uv run ruff check .
+        uv run ruff format --check .
+    
+    - name: Run type checking
+      run: |
+        uv run mypy src --ignore-missing-imports
+    
+    - name: Run tests with coverage
+      run: |
+        uv run pytest tests/ --cov=src --cov-report=term --cov-report=xml --cov-report=html
+    
+    - name: Upload coverage reports
+      if: matrix.os == 'ubuntu-latest' && matrix.python-version == '3.12'
+      uses: codecov/codecov-action@v4
+      with:
+        file: ./coverage.xml
+        flags: unittests
+        name: codecov-umbrella
+        fail_ci_if_error: false
+    
+    - name: Check coverage threshold
+      if: matrix.os == 'ubuntu-latest' && matrix.python-version == '3.12'
+      run: |
+        uv run python -c "
+        import xml.etree.ElementTree as ET
+        tree = ET.parse('coverage.xml')
+        root = tree.getroot()
+        coverage = float(root.attrib['line-rate']) * 100
+        print(f'Coverage: {coverage:.2f}%')
+        if coverage < 80:
+            print(f'Coverage {coverage:.2f}% is below 80% threshold')
+            exit(1)
+        "

.gitignore

@@ -1,17 +1,82 @@
-# Python-generated files
+# Byte-compiled / optimized / DLL files
 __pycache__/
-*.py[oc]
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
 build/
+develop-eggs/
 dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
 wheels/
-*.egg-info
+share/python-wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+MANIFEST
 
-# Virtual environments
-.venv
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.nox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*.cover
+*.py,cover
+.hypothesis/
+.pytest_cache/
+cover/
 
-# env
+# Environments
 .env
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+
+# mypy
+.mypy_cache/
+.dmypy.json
+dmypy.json
 
-# DS Store
+# IDEs
+.idea/
+.vscode/
+*.swp
+*.swo
+*~
+
+# OS
 .DS_Store
-.pytest_cache
+Thumbs.db
+ehthumbs.db
+
+# uv
+.uv/
+uv.lock.bak
+
+# ruff
+.ruff_cache/
+
+# Local test files
+test.db
+*.db
+scratch/
+temp/
+tmp/

.pre-commit-config.yaml

@@ -0,0 +1,50 @@
+repos:
+  - repo: https://github.com/pre-commit/pre-commit-hooks
+    rev: v4.6.0
+    hooks:
+      - id: trailing-whitespace
+      - id: end-of-file-fixer
+      - id: check-yaml
+      - id: check-added-large-files
+      - id: check-json
+      - id: check-toml
+      - id: check-merge-conflict
+      - id: check-case-conflict
+      - id: detect-private-key
+
+  - repo: https://github.com/astral-sh/ruff-pre-commit
+    rev: v0.7.1
+    hooks:
+      - id: ruff
+        args: [--fix]
+      - id: ruff-format
+
+  - repo: https://github.com/pre-commit/mirrors-mypy
+    rev: v1.13.0
+    hooks:
+      - id: mypy
+        additional_dependencies: [types-all]
+        files: ^src/
+        args: [--ignore-missing-imports]
+
+  - repo: https://github.com/pycqa/isort
+    rev: 5.13.2
+    hooks:
+      - id: isort
+        args: ["--profile", "black"]
+
+  - repo: https://github.com/asottile/pyupgrade
+    rev: v3.19.0
+    hooks:
+      - id: pyupgrade
+        args: [--py311-plus]
+
+  - repo: local
+    hooks:
+      - id: pytest-check
+        name: pytest-check
+        entry: uv run pytest
+        language: system
+        pass_filenames: false
+        always_run: true
+        stages: [push]

debug/debug_sse_connection.py

@@ -8,41 +8,41 @@
 """
 
 import asyncio
-import httpx
 import json
 from datetime import datetime
 
+import httpx
+
+
 async def test_sse_connection():
     """Test the SSE connection manually."""
     print("🔍 Testing SSE connection manually...")
-    
+
     url = "http://localhost:8000/sse"
-    
+
     try:
-        async with httpx.AsyncClient() as client:
-            async with client.stream("GET", url) as response:
-                print(f"📡 Connected to: {url}")
-                print(f"📊 Status: {response.status_code}")
-                print(f"📋 Headers: {dict(response.headers)}")
-                print("🔄 Receiving events...\n")
-                
-                event_count = 0
-                timeout_seconds = 10
-                
-                async for line in response.aiter_lines():
-                    if line.strip():
-                        event_count += 1
-                        timestamp = datetime.now().strftime("%H:%M:%S.%f")[:-3]
-                        print(f"[{timestamp}] Event {event_count}: {line}")
-                        
-                        # Stop after getting a few events or timeout
-                        if event_count > 20:
-                            print("📊 Received enough events, stopping...")
-                            break
-                
-                print(f"\n✅ Received {event_count} events total")
-                
-    except asyncio.TimeoutError:
+        async with httpx.AsyncClient() as client, client.stream("GET", url) as response:
+            print(f"📡 Connected to: {url}")
+            print(f"📊 Status: {response.status_code}")
+            print(f"📋 Headers: {dict(response.headers)}")
+            print("🔄 Receiving events...\n")
+
+            event_count = 0
+
+            async for line in response.aiter_lines():
+                if line.strip():
+                    event_count += 1
+                    timestamp = datetime.now().strftime("%H:%M:%S.%f")[:-3]
+                    print(f"[{timestamp}] Event {event_count}: {line}")
+
+                    # Stop after getting a few events or timeout
+                    if event_count > 20:
+                        print("📊 Received enough events, stopping...")
+                        break
+
+            print(f"\n✅ Received {event_count} events total")
+
+    except TimeoutError:
         print("⏰ Connection timed out")
     except httpx.RequestError as e:
         print(f"❌ Connection error: {e}")
@@ -53,13 +53,9 @@ async def test_sse_connection():
 async def test_basic_endpoints():
     """Test basic HTTP endpoints."""
     print("🔍 Testing basic endpoints...")
-    
-    endpoints = [
-        "http://localhost:8000/",
-        "http://localhost:8000/health", 
-        "http://localhost:8000/tools"
-    ]
-    
+
+    endpoints = ["http://localhost:8000/", "http://localhost:8000/health", "http://localhost:8000/tools"]
+
     async with httpx.AsyncClient() as client:
         for url in endpoints:
             try:
@@ -75,15 +71,15 @@ async def main():
     """Run all debug tests."""
     print("🎯 SSE Connection Debug Tool")
     print("=" * 40)
-    
+
     # Test basic endpoints first
     await test_basic_endpoints()
-    
+
     print("\n" + "=" * 40)
-    
+
     # Test SSE connection
     await test_sse_connection()
-    
+
     print("\n🎉 Debug complete!")
 
 
@@ -93,4 +89,4 @@ async def main():
     except KeyboardInterrupt:
         print("\n👋 Debug interrupted")
     except Exception as e:
-        print(f"❌ Debug error: {e}")
+        print(f"❌ Debug error: {e}")