Get cached results if not expired.

Add an item to the cache. Register an occurrence of `item`. First time we see its key, we store the item; every time we bump the coun

Expand "tb" to a full proxy URL if applicable.

Create a DDGS instance with proxy configuration from environment.

Async wrapper for start() for backwards compatibility. Args: timeout: Maximum time to wait for service to start. Returns

Async wrapper for stop() for backwards compatibility. Args: timeout: Maximum time to wait for service to stop.

Get the global DHT service instance. Returns: DhtService singleton.

Store results with TTL and enforce max size.

Compute a normalized hash for a query. Normalization: - Strip whitespace - Lowercase - Sort words alphabetically for deterministic ke

Store results in the DHT. Args: key: The cache key (query hash). results: The search results to cache. tt

Fetch a URL and extract its content. Args: url: The URL to fetch and extract content from. fmt: Output format: "text_

Make a request to the search engine.

Start the DHT client. Returns: True if DHT connection successful.

Perform a text search.

Perform an image search.

Perform a search across engines in the given category. Args: category: The category of search engines (e.g., 'text', 'images', et

Perform a book search.

Get total number of cached entries.

Get cached results for a query. Checks local cache first, then DHT DHT (or REST API). Args: query: The search query.

Perform a news search.

Normalize query for display/storage. Args: query: The search query. Returns: Normalized query string.

Perform a video search.

Override setattr to apply normalization functions to certain attributes.

Run an async function in the Trio event loop from another thread.

Async wrapper for get() for backwards compatibility. Args: key: The cache key (query hash). timeout: Timeout in secon

Async wrapper for set() for backwards compatibility. Args: key: The cache key (query hash). results: The search resul

Cache search results locally and on DHT. Args: query: The search query. results: The search results. cate

Get cached results from the DHT. Args: key: The cache key (query hash). timeout: Timeout in seconds for DHT query.

Extract vqd from html bytes.

Run an async function in the Trio event loop from another thread.

Async wrapper for connect_peer() for backwards compatibility. Args: peer_addr: The multiaddress of the peer to connect to.

Add an entry to the negative cache (no results found).

Async wrapper for find_peers() for backwards compatibility. Returns: List of peer addresses.

Delete a cached result.

Add a list of items to the cache.

Extract html tree from html text.

Get database size in bytes.

Stop the DHT client.

Get or create shared async loop running in dedicated thread.

Get or create the shared primp HTTP client.

Get the network client for caching. Returns: DhtClient instance if available, None otherwise.

Check if any token is a substring of the lower-cased text.

Generate hash positions for a key using SHA-256 for consistency.

Add a key to the filter.

Get all peers from routing table with complete metadata. Returns: List of peer dictionaries with metadata.

Get DHT service status. Returns: Dict with status information.

Make a request to the HTTP client.

Make a request to the HTTP client.

Search the engine.

Cache search results asynchronously.

Connect to bootstrap nodes.

Create a host with Mplex muxer (default security includes Noise).

Ensure the network service is running. If not running, spawn a new ddgs api process only if spawn_api is True.

Split on non-word characters & filter out short tokens.

Get shared thread pool executor for background cache operations.

Retrieve a list of search engine instances for a given category and backend. Args: category: The category of search engines (e.g.

Get cached results from API.

Get vqd value for a search query using DuckDuckGo.

Get vqd value for a search query using DuckDuckGo.

Get vqd value for a search query using DuckDuckGo.

Parse JSON results safely.

Resolve /dnsaddr/ multiaddrs into concrete addresses using DNS TXT records. Follows libp2p dnsaddr specification: - Queries TXT records at _d

Run main DHT event loop.

Set up DHT instance with validator.

Set up Circuit Relay v2 for NAT traversal.

Build a payload for the search request.

Cache search results synchronously (for use from FastAPI). Args: query: The search query. results: The search results

DDGS CLI tool.

Extract date from string.

Extract date from string.

Return a list of items, sorted by descending frequency. Each item is returned as a dict.

Sanitize image url.

Extract search results from html text.

Remove ' via Yahoo' from string.

Sanitize url.

Sanitize url.

Find other peers in the network. Returns: List of peer addresses.

Make a GET request to the HTTP client.

Get cached results synchronously (for use from FastAPI). Args: query: The search query. category: The search category

Get list of connected peers. Returns: List of peer IDs.

Get sc param.

Return one random Android Google App User-Agent string.

Invalidate cached results for a query. Args: query: The search query. category: The search category.

Check if the client is running.

Make a POST request to the HTTP client.

Post-process search results.

Pre-process html_text before extracting results.

Pre-process the HTML text before parsing it.

Rank a list of docs based on a query string.

Get result type based on category.