92686159d1
Prepare dependency generations before selecting them. Keep shipped tool bytes separate from writable additions, and store facts beside their entries. Validate proposed plugin sets before config publication. Restore the previous config if the facts write fails. Consolidate duplicate updater, backup, setup, and voice helpers. Repair launcher selection, dependency consumers, download ownership, update feeds, and native Windows process and file handling. Verification: 206 changed/prior-failing Python files reported 4630 passed, one failed, and 330 skipped. Fix the remaining Hindsight fixture boundary. The final targeted rerun reported 234 passed and two skipped. The store review regression batch reported 83 passed and one skipped. Desktop TypeScript checks, 56 selected Electron tests, 24 release tests, and the removed-import/compatibility guards passed. This is an integration checkpoint, not full audit acceptance. The complete Python suite has not run on this fixed tree. Crash-atomic plugin publication, generation cleanup, receipt correlation, and packaged lifecycle acceptance remain open in docs/pm-audit-status.md.
93 lines
3.7 KiB
Python
93 lines
3.7 KiB
Python
"""Exa web search + content extraction via the ``exa-py`` SDK (lazy-installed).
|
|
|
|
Env: ``EXA_API_KEY`` (https://exa.ai). Both methods are sync — Exa's SDK is
|
|
sync-only; the dispatcher threads extract when the caller is async.
|
|
"""
|
|
|
|
from __future__ import annotations
|
|
|
|
import logging
|
|
from typing import Any, Dict, List
|
|
|
|
from plugins.web._common import (
|
|
BaseWebSearchProvider, cached_sdk_client, document, keyless_extract, keyless_search, keyless_variant_schema,
|
|
provider_env, run_extract, run_search, search_ok, use_keyless, web_hit,
|
|
)
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
_MISSING_KEY = "EXA_API_KEY environment variable not set. Get your API key at https://exa.ai"
|
|
|
|
|
|
def _get_exa_client() -> Any:
|
|
def _factory(api_key: str) -> Any:
|
|
from exa_py import Exa # deliberately lazy
|
|
client = Exa(api_key=api_key)
|
|
client.headers["x-exa-integration"] = "hermes-agent"
|
|
return client
|
|
|
|
return cached_sdk_client("_exa_client", "EXA_API_KEY", _MISSING_KEY, "exa", _factory)
|
|
|
|
|
|
class ExaWebSearchProvider(BaseWebSearchProvider):
|
|
"""Exa search + extract provider."""
|
|
|
|
NAME = "exa"
|
|
DISPLAY_NAME = "Exa"
|
|
KEY_ENV = "EXA_API_KEY"
|
|
EXTRACT = True
|
|
KEYLESS = True
|
|
|
|
def search(self, query: str, limit: int = 5) -> Dict[str, Any]:
|
|
def _body() -> Dict[str, Any]:
|
|
if use_keyless("exa", provider_env("EXA_API_KEY")):
|
|
return keyless_search("Exa", "exa", query, limit, logger)
|
|
logger.info("Exa search: '%s' (limit=%d)", query, limit)
|
|
response = _get_exa_client().search(query, num_results=limit, contents={"highlights": True})
|
|
return search_ok([
|
|
web_hit(r.url or "", r.title or "", " ".join(r.highlights or []), i + 1)
|
|
for i, r in enumerate(response.results or [])
|
|
])
|
|
|
|
return run_search("Exa", logger, _body, sdk=True)
|
|
|
|
def extract(self, urls: List[str], **kwargs: Any) -> List[Dict[str, Any]]:
|
|
def _body() -> List[Dict[str, Any]]:
|
|
if use_keyless("exa", provider_env("EXA_API_KEY")):
|
|
return keyless_extract("Exa", "exa", urls, logger)
|
|
logger.info("Exa extract: %d URL(s)", len(urls))
|
|
response = _get_exa_client().get_contents(urls, text=True)
|
|
return [document(r.url or "", r.title or "", r.text or "") for r in response.results or []]
|
|
|
|
return run_extract("Exa", logger, urls, _body, sdk=True)
|
|
|
|
def get_setup_schema(self) -> Dict[str, Any]:
|
|
return keyless_variant_schema(
|
|
"Exa", "EXA_API_KEY", "https://exa.ai",
|
|
free_tag="Semantic + neural web search with content extraction on Exa's anonymous free tier. Rate-limited under burst load.",
|
|
paid_tag="Semantic + neural web search with content extraction via the Exa SDK. Unthrottled, guaranteed service.",
|
|
)
|
|
|
|
|
|
# ---- BEGIN PLUGIN-COMPAT (revert-scheduled; see COMPAT_MANIFEST.md) ----
|
|
# Names external plugins imported from this module before the Sep 2026 decomposition.
|
|
# Internal code MUST NOT use these (scripts/check_compat_pointers.py fails CI if it does).
|
|
# The whole block is removed by reverting the commit that added it.
|
|
import os # noqa: F401,E402
|
|
|
|
|
|
_PLUGIN_COMPAT_LAZY = {
|
|
'WebSearchProvider': ('agent.web_search_provider', 'WebSearchProvider'),
|
|
}
|
|
|
|
|
|
def __getattr__(name): # PEP 562 — lazy so no import cycles
|
|
target = _PLUGIN_COMPAT_LAZY.get(name)
|
|
if target is None:
|
|
raise AttributeError(f"module {__name__!r} has no attribute {name!r}")
|
|
import importlib
|
|
from hermes_cli.plugin_compat import warn_once
|
|
warn_once(__name__, name, *target)
|
|
return getattr(importlib.import_module(target[0]), target[1])
|
|
# ---- END PLUGIN-COMPAT ----
|