sync: 167 file da Baida98/AI@a9c5b8e5 (2026-08-22 07:53 UTC)

benchmarks/model_watch_adapter.py

@@ -230,7 +230,7 @@ class ObserveOnlyModelsAdapter:
         params: dict[str, str] = {}
         if profile.auth_mode == "query_key":
             params["key"] = profile.api_key
-        else:
+        elif profile.auth_mode != "none":
             headers["Authorization"] = f"Bearer {profile.api_key}"
 
         owns_client = self._client is None
@@ -292,7 +292,7 @@ class GeminiModelsAdapter(ObserveOnlyModelsAdapter):
     async def list_models(self, profile: ProviderProfile) -> CatalogResult:
         url = models_url(profile.base_url)
         headers = {"Accept": "application/json"}
-        params = {"key": profile.api_key}
+        params = {"key": profile.api_key} if profile.auth_mode != "none" else {}
         owns_client = self._client is None
         client = self._client or httpx.AsyncClient(timeout=self.timeout_seconds)
         try:

memory/sync.py

@@ -58,6 +58,12 @@ class MemorySyncStatus(BaseModel):
     stats: dict[str, Any]
 
 
+class MemoryImportRequest(BaseModel):
+    """Payload di import definito a livello modulo per lo schema OpenAPI."""
+    records: list[dict[str, Any]] = Field(default_factory=list)
+    overwrite: bool = False
+
+
 # ── GAP-VAULT-AUTH: autenticazione Bearer ─────────────────────────────────────
 _SYNC_ADMIN_TOKEN = os.getenv('VAULT_ADMIN_TOKEN', '')  # stessa variabile del vault
 
@@ -218,13 +224,9 @@ def create_memory_sync_router(memory: Any) -> APIRouter:
             "server_time": _now_ms(),
         }
 
-    class _MemoryImportRequest(BaseModel):
-        records: list[dict[str, Any]] = Field(default_factory=list)
-        overwrite: bool = False
-
     @router.post("/import")
     async def memory_import(
-        req: _MemoryImportRequest,
+        req: MemoryImportRequest,
         _auth: None = Depends(_require_sync_auth),
     ) -> dict[str, Any]:
         """Importa records nella semantic memory. Richiede Bearer VAULT_ADMIN_TOKEN."""

tests/test_model_catalog_scan.py

@@ -0,0 +1,48 @@
+import unittest
+
+from scripts.model_catalog_scan import diff_catalogs
+from scripts.model_catalog_notify import build_body
+
+
+class ModelCatalogDiffTests(unittest.TestCase):
+    def test_reports_exact_added_removed_and_unavailable_models(self):
+        previous = {"state": {"groq/A": {"provider": "groq", "profile": "A", "status": "available", "models": ["old-model", "stable-model"]}}}
+        current = {"state": {"groq/A": {"provider": "groq", "profile": "A", "status": "available", "models": ["new-model", "stable-model"], "default_model": "old-model", "default_available": False}}}
+        result = diff_catalogs(previous, current)
+        self.assertEqual(result["added_models"][0]["model"], "new-model")
+        self.assertEqual(result["removed_models"][0]["model"], "old-model")
+        self.assertEqual(result["unavailable_defaults"][0]["model"], "old-model")
+        self.assertTrue(result["has_changes"])
+
+    def test_reports_provider_errors_with_exact_status(self):
+        current = {"state": {"gemini/default": {"provider": "gemini", "profile": "default", "status": "rate_limited", "models": [], "detail": "retry after 60"}}}
+        result = diff_catalogs({}, current)
+        self.assertEqual(result["provider_errors"][0]["status"], "rate_limited")
+        self.assertIn("gemini", result["provider_errors"][0]["provider"])
+
+    def test_empty_profile_configuration_is_reported(self):
+        from scripts.model_catalog_scan import audit_payload
+        from benchmarks.model_watch_adapter import ModelWatchConfig, ObserveOnlyModelsAdapter
+        from types import SimpleNamespace
+        payload = audit_payload(SimpleNamespace(results=(), skipped_rate_limited=()), ObserveOnlyModelsAdapter(config=ModelWatchConfig()), [], {})
+        self.assertEqual(payload["profile_count"], 0)
+        self.assertTrue(payload["diff"]["has_changes"])
+        self.assertEqual(payload["diff"]["provider_errors"][0]["status"], "missing_profiles")
+
+    def test_notification_contains_exact_names_and_closed_gate(self):
+        body = build_body({
+            "auto_apply_gate_open": False,
+            "diff": {
+                "added_models": [{"provider": "groq", "profile": "A", "model": "new-model"}],
+                "removed_models": [{"provider": "groq", "profile": "A", "model": "old-model"}],
+                "unavailable_defaults": [],
+                "provider_errors": [],
+            },
+        })
+        self.assertIn("new-model", body)
+        self.assertIn("old-model", body)
+        self.assertIn("CHIUSA", body)
+
+
+if __name__ == "__main__":
+    unittest.main()