Fetch public events for a user. Args: username: GitHub username since: Only fetch events after this time Ret

Fetch news for one watchlist via ``obb.news.company()``.

Return the configured analysis concurrency, clamped to 1 or above.

Return the configured enrichment concurrency, clamped to 1 or above.

Resolve proxy from common env vars (PROXY, http_proxy, all_proxy).

Return the configured inter-item throttle, clamped to zero or above.

Log and display HTTP response status by category. Even 2xx responses may contain platform-specific error codes in the JSON body (e.g.

Return whether platform should use Feishu/Lark card rendering.

Return True when a URL can be emitted as an active Markdown link.

Read browser-exported cookie JSON and convert to Playwright format.

Create sample ContentItems for the test notification.

Case-insensitive substring match against description, name, collections.

Parse publication date from feed entry. Args: entry: Feed entry data Returns: datetime: Parsed publication d

Parse the publication date of an entry into aware UTC.

Parse GitHub event into ContentItem. Args: event: GitHub event data username: GitHub username Returns:

Try multiple strategies to extract a JSON object from an AI response. Returns the parsed dict, or None if all strategies fail.

Parse a GDELT ``seendate`` ("YYYYMMDDTHHMMSSZ") into aware UTC.

Convert raw tweet dict to Horizon ContentItem.

Render one dry-run preview using the same logic as the real sender.

Map one OpenBB news record into a ContentItem. Returns None when the record is too old, has no URL, or fails validation. OpenBB retur

Map one GDELT article record into a ContentItem. Returns None when the record has no URL/title or an unparseable ``seendate`` (publis

Resolve secrets config path via env and common locations.

Convert a raw OSS Insight row into a ContentItem.

Execute the webhook test.

Scrape a single user's tweets via GraphQL interception.

Check if a tag (or any of its aliases) matches the user input.

Build a Feishu plain text object.

Build the Google News time operator from ``since``. Computes the number of whole hours between ``since`` and now (min 1). For windows

Transform horizon-site API response to the internal preset format. The API returns data in horizon-site's format (Category enum IDs like "AI_

Try to import the OpenBB App, returning None if not installed. Importing ``openbb`` is expensive (loads every registered extension),

Validate webhook URL configuration and print warnings for skip scenarios. Raises ValueError when URL is present but invalid. Sets sel

Validate webhook URL has a valid scheme (http/https) and hostname. Raises: ValueError: If the URL is empty, has wrong scheme, no h

Search the web for context via DuckDuckGo. Returns: List of dicts with keys: title, url, body

Adds a new subscriber email.

Step 6: Assemble the final Config object. Args: ai_config: AI configuration. selected_sources: List of selected source dicts.

Step 1: Configure AI provider. Returns: AIConfig if configured, None if user skips.

Deserialize ContentItem list.

Fetch presets from the horizon-site API. Returns: Dict in the internal preset format (with "domains" key), or None if the fetch f

Ask AI to recommend additional sources beyond presets. Args: ai_config: AI configuration for creating the client. interests: User

Synchronous wrapper for get_ai_recommendations.

Return effective config after optional source filtering.

Step 2: Get user's interest description. Returns: Free-form interest string.

Return all aliases for a canonical tag (empty list if unknown).

Return a snapshot of accumulated token usage.

Load presets from API (preferred) or local file (fallback). Args: presets_path: Path to the local presets JSON file for fallback.

Main CLI entry point.

CLI entry point for horizon-webhook.

Run MCP server over stdio.

Add semantic classes to tag lines, source lines, and background paragraphs

Match user interest description against individual sources. Scores each source based on: - Category keyword matches (+1.0 per keyword) -

Merge new config into existing config, deduplicating sources. Rules: - ai / filtering: use new values (full replacement) - sources: dedup

Print the application banner.

Print the setup wizard banner.

Replace ⭐️ N/10 with a colored badge in h2, h3, and li elements

Removes a subscriber email.

Save configuration to config.json, optionally backing up the existing file. Args: config: The Config object to save.

Search HN Algolia. Returns list of {title, url, source, score, num_comments, date}.

Search Reddit JSON API. Returns list of {title, url, source, score, num_comments, subreddit, date}.

Step 5: Interactive source selection with a rich table. Args: preset_sources: Sources matched from presets. ai_sources: Sources r

Send a webhook notification using the configured webhook settings.

Set up EN/中文 language toggle as a page-level control

Initialize orchestrator. Args: config: Application configuration storage: Storage manager