|
15 | 15 |
|
16 | 16 | import uvicorn |
17 | 17 | import argparse |
| 18 | +from contextlib import asynccontextmanager |
18 | 19 | from fastapi import FastAPI, HTTPException |
19 | 20 | from fastapi.responses import StreamingResponse |
20 | 21 | from pydantic import BaseModel, Field |
|
23 | 24 | from src.retriever import VimproveRetriever |
24 | 25 |
|
25 | 26 |
|
| 27 | +@asynccontextmanager |
| 28 | +async def lifespan(app: FastAPI): |
| 29 | + """Lifespan context manager for startup and shutdown events.""" |
| 30 | + # Startup |
| 31 | + global retriever, openrouter_key |
| 32 | + |
| 33 | + cache_dir = Path(os.environ.get("VIMPROVE_CACHE_DIR", "./vimprove-cache")).resolve() |
| 34 | + openrouter_key = os.environ.get("OPENROUTER_API_KEY") |
| 35 | + |
| 36 | + if not openrouter_key: |
| 37 | + print("Warning: OPENROUTER_API_KEY not set. Query endpoint will fail.") |
| 38 | + |
| 39 | + print(f"Loading retriever from {cache_dir}...") |
| 40 | + retriever = VimproveRetriever(cache_dir) |
| 41 | + print(f"✓ Retriever ready ({retriever.collection.count()} chunks)") |
| 42 | + |
| 43 | + yield # App runs here |
| 44 | + |
| 45 | + |
26 | 46 | app = FastAPI( |
27 | 47 | title="Vimprove API", |
28 | 48 | description="RAG-powered Neovim configuration assistant", |
29 | 49 | version="0.1.0", |
| 50 | + lifespan=lifespan, |
30 | 51 | ) |
31 | 52 |
|
32 | 53 |
|
@@ -57,22 +78,6 @@ class QueryResponse(BaseModel): |
57 | 78 | model_used: str |
58 | 79 |
|
59 | 80 |
|
60 | | -@app.on_event("startup") |
61 | | -async def startup_event(): |
62 | | - """Initialize retriever on startup.""" |
63 | | - global retriever, openrouter_key |
64 | | - |
65 | | - cache_dir = Path(os.environ.get("VIMPROVE_CACHE_DIR", "./vimprove-cache")).resolve() |
66 | | - openrouter_key = os.environ.get("OPENROUTER_API_KEY") |
67 | | - |
68 | | - if not openrouter_key: |
69 | | - print("Warning: OPENROUTER_API_KEY not set. Query endpoint will fail.") |
70 | | - |
71 | | - print(f"Loading retriever from {cache_dir}...") |
72 | | - retriever = VimproveRetriever(cache_dir) |
73 | | - print(f"✓ Retriever ready ({retriever.collection.count()} chunks)") |
74 | | - |
75 | | - |
76 | 81 | @app.get("/health") |
77 | 82 | async def health_check(): |
78 | 83 | """Health check endpoint.""" |
|
0 commit comments