Upload app.py

app.py

@@ -44,7 +44,6 @@ source_extension_counts: dict[str, dict[str, int]] = {}
 word_index: dict[str, set[int]] = {}
 TOKEN_RE = re.compile(r"[a-z0-9]+|[\u4e00-\u9fff\u3400-\u4dbf]+")
 TOKENIZER_VERSION = "cjk-bigram-boundary-fts5-v6-snippet-anchors"
-APP_BUILD_VERSION = "2026-07-28-search-zip-v2"
 LITERAL_PREFIX = "\0literal:"
 API_CACHE_TTL_SECONDS = 120
 SEARCH_CACHE_TTL_SECONDS = 300
@@ -446,10 +445,7 @@ class FulltextDatabases:
                                 payload["snippet"] += "..."
                             snippets[doc_id_by_number[int(number)]] = payload
                             anchored_numbers.add(int(number))
-                    except sqlite3.OperationalError as exc:
-                        if timings is not None:
-                            timings["snippet_anchor_error"] = 1
-                        print(f"snippet_anchor_sql_failed={type(exc).__name__}:{exc}", flush=True)
+                    except sqlite3.OperationalError:
                         break
             numbers = [number for number in numbers if number not in anchored_numbers]
             for offset in range(0, len(numbers), 500):
@@ -976,16 +972,6 @@ app = FastAPI(title="VOMEBOOK Search", version="1.0", lifespan=lifespan)
 app.add_middleware(GZipMiddleware, minimum_size=500)
 app.add_middleware(CORSMiddleware, allow_origins=["*"], allow_methods=["*"], allow_headers=["*"])
 
-@app.middleware("http")
-async def timing_headers(request: Request, call_next):
-    started = time.perf_counter()
-    response = await call_next(request)
-    app_timing = f'app;dur={(time.perf_counter() - started) * 1000:.2f}'
-    existing = response.headers.get("Server-Timing")
-    response.headers["Server-Timing"] = f"{existing}, {app_timing}" if existing else app_timing
-    response.headers["X-App-Version"] = APP_BUILD_VERSION
-    return response
-
 class SearchRequest(BaseModel):
     q: str = Field(default="", max_length=256)
     sources: Optional[list[str]] = None
@@ -1114,35 +1100,16 @@ def run_search(body: SearchRequest, sources_filter=None, timings=None):
     payload["index_generation"] = fulltext_generation
     return payload
 
-def format_server_timing(timings: dict) -> str:
-    values = [f'cache;desc="{timings.get("cache", "unknown")}";dur={timings.get("cache_lookup", 0):.2f}']
-    for name in ("sqlite", "metadata", "filter", "rank", "sort", "summaries", "snippet_anchor_sql", "snippet_anchor_error", "snippet_fallback_sql", "snippet_payload", "snippets", "decorate", "engine", "json"):
-        if name in timings:
-            values.append(f"{name};dur={timings[name]:.2f}")
-    return ", ".join(values)
-
 @app.post("/api/search")
 
 def api_search(body: SearchRequest):
-    timings = {}
-    payload = run_search(body, timings=timings)
-    json_started = time.perf_counter()
-    response = JSONResponse(payload)
-    timings["json"] = (time.perf_counter() - json_started) * 1000
-    response.headers["Server-Timing"] = format_server_timing(timings)
-    return response
+    return JSONResponse(run_search(body))
 @app.post("/api/search/{source_slug}")
 
 def api_search_source(source_slug: str, body: SearchRequest):
     if source_slug not in source_counts:
         return JSONResponse({"error": "source not found", "results": [], "total": 0}, status_code=404)
-    timings = {}
-    payload = run_search(body, [source_slug], timings)
-    json_started = time.perf_counter()
-    response = JSONResponse(payload)
-    timings["json"] = (time.perf_counter() - json_started) * 1000
-    response.headers["Server-Timing"] = format_server_timing(timings)
-    return response
+    return JSONResponse(run_search(body, [source_slug]))
 
 @app.get("/api/ping")
 def api_ping():