omnifeed

module
v0.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 20, 2026 License: MIT

README

omnifeed

CI Security Release Go Docker pulls License Stars

MCP server Open WebUI loader REST API Reddit TOON crawl4ai SearXNG

Quick start · Demo · Configuration · API · Architecture · OpenAPI

omnifeed gives an AI agent the full research loop — search → URLs → content — against self-hosted SearXNG + crawl4ai, with a dedicated Reddit engine that returns full comment trees as TOON (~40% fewer tokens than JSON, lossless) and no Reddit API key.

  • web_search queries a SearXNG instance (Google/Bing/DDG, Reddit included) and returns ranked URLs with titles and snippets.
  • fetch_url renders any URL through crawl4ai as clean markdown — and Reddit URLs come back as the full comment tree encoded in TOON.

Why omnifeed

omnifeed Other Reddit MCPs
Web search → crawl in one self-hosted service ✅ SearXNG + crawl4ai ❌ search-only or crawl-only
Full comment tree (/api/morechildren expansion) ✅ up to 40 rounds (~4k comments)
Token-efficient output ✅ TOON, ~40% smaller than JSON ❌ verbose JSON or truncated bodies
Generic crawl fallback for non-Reddit URLs ✅ via crawl4ai
Front-ends MCP + Open WebUI + REST MCP only (most)

Demo

web_search → pick a URL → fetch_url → full Reddit comment tree as TOON. Generate this clip with vhs assets/demo.tape.

Quick start

# No clone needed — fetch the compose file + SearXNG settings, then start:
curl -fsSL https://raw.githubusercontent.com/kinorai/omnifeed/main/docker-compose.yml -o docker-compose.yml
curl -fsSL --create-dirs https://raw.githubusercontent.com/kinorai/omnifeed/main/searxng/settings.yml -o searxng/settings.yml
docker compose up

Starts omnifeed + SearXNG + crawl4ai. Point Open WebUI at http://localhost:8080 with WEB_LOADER_ENGINE=external. (SearXNG is mounted with searxng/settings.yml, which enables the json format the web_search tool needs.)

As an MCP server (Claude Code, Cursor, Windsurf, …)

Stdio — most clients. omnifeed always fetches through crawl4ai (and SearXNG, if you want web_search), so the container your client spawns must be told where they are. The simplest setup joins the network from docker compose up and uses the service names:

{
  "mcpServers": {
    "omnifeed": {
      "command": "docker",
      "args": [
        "run", "--rm", "-i",
        "--network", "omnifeed_default",
        "-e", "OMNIFEED_CRAWL4AI_URL=http://crawl4ai:11235/crawl",
        "-e", "OMNIFEED_SEARXNG_URL=http://searxng:8080",
        "kinorai/omnifeed:latest", "--mcp-stdio"
      ]
    }
  }
}

Without OMNIFEED_CRAWL4AI_URL the container exits at startup. If crawl4ai/SearXNG run elsewhere, point the URLs there (e.g. http://host.docker.internal:11235/crawl, adding --add-host=host.docker.internal:host-gateway on Linux).

HTTP — remote clients, or the simplest option when the docker compose up stack is already running (no second container, no networking to wire up):

{ "mcpServers": { "omnifeed": { "url": "http://your-host:8081/mcp" } } }

Tools: fetch_url (always) and web_search (only when OMNIFEED_SEARXNG_URL is set). The intended loop is web_search → pick URLs → fetch_url.

/crawl returns [{"page_content": "...", "metadata": {...}}] — already the shape of a LangChain / LlamaIndex Document, so wrapping it as a custom document loader takes only a few lines.

Authentication

The HTTP transports (/crawl, /search, /mcp) share one bearer token. Set OMNIFEED_API_KEY and send Authorization: Bearer <token>:

# Generate a key and print it — clients send it as the bearer token, so save it somewhere.
export OMNIFEED_API_KEY="$(openssl rand -hex 32)"
echo "OMNIFEED_API_KEY=$OMNIFEED_API_KEY"

# `-e OMNIFEED_API_KEY` (no value) forwards the variable from your shell.
docker run -e OMNIFEED_API_KEY \
  -e OMNIFEED_CRAWL4AI_URL=http://crawl4ai:11235/crawl \
  kinorai/omnifeed

Without a key the proxy refuses to start, so it can't be left open by accident. For a throwaway local run, opt out with OMNIFEED_DEV_NO_AUTH=true (the compose files already do). Stdio MCP needs no token — it inherits the trust of the process that spawned it.

Configuration

Everything is configured with OMNIFEED_-prefixed environment variables. In practice you only ever set threeOMNIFEED_API_KEY, OMNIFEED_CRAWL4AI_URL, and (optionally) OMNIFEED_SEARXNG_URL. The rest have sane defaults.

Variable Default Purpose
OMNIFEED_API_KEY (unset) Bearer token for /crawl, /search, /mcp. If unset, the proxy refuses to start unless OMNIFEED_DEV_NO_AUTH=true. Stdio MCP is unaffected.
OMNIFEED_CRAWL4AI_URL (required) Upstream crawl4ai endpoint. Every engine fetches through it; if empty, the proxy exits at startup.
OMNIFEED_SEARXNG_URL (unset) Upstream SearXNG base URL (e.g. http://searxng:8080). When unset, web_search / /search are not exposed. The instance must enable the json format.
OMNIFEED_DEV_NO_AUTH false Run the HTTP transports with no auth when no key is set (local/dev only). Ignored if a key is set.
OMNIFEED_LISTEN_ADDR :8080 HTTP listen address (/crawl, /search)
OMNIFEED_MCP_LISTEN_ADDR :8081 MCP HTTP/SSE listen address
OMNIFEED_MCP_STDIO false Run MCP over stdio (also via --mcp-stdio)
OMNIFEED_METRICS_ADDR :9090 Prometheus + health listen address
OMNIFEED_CRAWL4AI_TIMEOUT 90s Per-call timeout to crawl4ai
OMNIFEED_SEARXNG_TIMEOUT 15s Per-query timeout to SearXNG
OMNIFEED_SEARCH_MAX_RESULTS 25 Hard cap on the search limit argument (1–100)
OMNIFEED_REDDIT_TIMEOUT 4m Wall-clock cap for a Reddit thread expansion
OMNIFEED_REDDIT_MAX_ROUNDS 3 Default /api/morechildren rounds (max 40 via ?expand=full)
OMNIFEED_REDDIT_FORMAT toon Default Reddit output: toon or json
OMNIFEED_REDDIT_FETCH_LIMIT 500 Reddit limit: max comments fetched in the initial tree
OMNIFEED_REDDIT_DEPTH 20 Reddit depth: max nesting depth of the initial tree
OMNIFEED_REDDIT_SORT top Reddit sort: one of confidence (=best), top, new, controversial, old, random, qa, live
OMNIFEED_REDDIT_MAX_COMMENTS 0 Hard cap on total comments emitted after expansion (0 = unlimited)
OMNIFEED_REDDIT_MAX_TOP_LEVEL 0 Hard cap on top-level comment threads, replies included (0 = unlimited)
OMNIFEED_REDDIT_KEEP_CREATED true Include each comment's created timestamp
OMNIFEED_REDDIT_KEEP_DEPTH false Include each comment's depth field
OMNIFEED_MAX_URLS_PER_REQUEST 30 Cap on urls[] length
OMNIFEED_PER_DOMAIN_CONCURRENCY 2 Max concurrent requests to one domain
OMNIFEED_PER_DOMAIN_DELAY 1500ms Minimum delay between same-domain requests
OMNIFEED_BLOCK_PRIVATE_IPS true SSRF protection (keep on in production)
OMNIFEED_LOG_LEVEL info debug/info/warn/error
OMNIFEED_LOG_FORMAT json json or text
OMNIFEED_ENABLE_PPROF false Expose /debug/pprof/* (opt-in)

Controlling Reddit response size

A Reddit thread's comment tree can be huge. The size knobs come in two kinds — it matters which is which:

  • Upstream Reddit params — forwarded verbatim to Reddit's API, so Reddit owns their behavior: OMNIFEED_REDDIT_FETCH_LIMITlimit, OMNIFEED_REDDIT_DEPTHdepth, OMNIFEED_REDDIT_SORTsort. They shape what Reddit sends back (less latency, fewer tokens) but are approximate, and limit/depth bound only the initial fetch. Semantics are Reddit's, not ours — see https://www.reddit.com/dev/api/GET [/r/subreddit]/comments/article (limit = "maximum number of comments to return", depth = "maximum depth of subtrees").
  • omnifeed engine caps — our own, applied after fetch + expansion, so they're exact and independent of Reddit: OMNIFEED_REDDIT_MAX_COMMENTS (truncate the flat comment list) and OMNIFEED_REDDIT_MAX_TOP_LEVEL (keep the first N top-level threads, in sort order, with their replies).

Rule of thumb: reach for the upstream params to fetch less from Reddit; reach for the engine caps when you need a guaranteed ceiling — OMNIFEED_REDDIT_MAX_ROUNDS expansion adds comments on top of limit, so only the caps bound the final total. All five are also per-request on the fetch_url MCP tool (limit, depth, sort, max_comments, max_top_level); a positive value overrides the env default.

API

Two bearer-authenticated JSON endpoints on the loader port (:8080). The full reference — request/response schemas, query params, and error codes — lives in openapi.yaml (paste it into editor.swagger.io or any OpenAPI viewer).

  • POST /crawl — URL → content (Open WebUI external-loader contract). Body {"urls": [...]}[{"page_content", "metadata"}, ...]. Reddit-only query params: format=toon|json, expand=N|full, depth=1, nocreated=1.
  • POST /search — query → ranked result URLs. Exposed only when OMNIFEED_SEARXNG_URL is set. Body {"query", "limit", "time_range", "language"}.
curl -s http://localhost:8080/crawl \
  -H "Authorization: Bearer $OMNIFEED_API_KEY" \
  -H 'Content-Type: application/json' \
  -d '{"urls": ["https://www.reddit.com/r/golang/comments/.../"]}'

Health & metrics

  • GET /livez — liveness; 200 unless shutting down
  • GET /readyz — checks crawl4ai (and SearXNG, when configured); GET /healthz is an alias
  • GET /metrics — Prometheus (omnifeed_requests_total, omnifeed_request_seconds, omnifeed_reddit_expansion_rounds, omnifeed_search_requests_total, omnifeed_search_request_seconds)

Health and metrics listen on OMNIFEED_METRICS_ADDR (default :9090), separate from the API (:8080) and MCP (:8081) ports.

MCP

JSON-RPC 2.0 at:

  • stdio when OMNIFEED_MCP_STDIO=true or --mcp-stdio
  • Streamable HTTP at /mcp (spec 2025-03-26) on OMNIFEED_MCP_LISTEN_ADDRPOST /mcp for one-shot calls, GET /mcp for the SSE stream
  • GET /mcp/sse is a legacy alias for older dual-endpoint SSE clients; new clients target /mcp

Architecture

Two ports answer two questions. The Searcher port answers query → URLs; the Engine port answers URL → content. MCP tools and REST handlers compose them; transports stay thin.

%%{init: {"theme":"base","themeVariables":{"background":"transparent","mainBkg":"#161b22","primaryColor":"#161b22","primaryTextColor":"#e6edf3","primaryBorderColor":"#F97316","lineColor":"#8b949e","secondaryColor":"#161b22","tertiaryColor":"#161b22","fontFamily":"Inter, system-ui, sans-serif"},"flowchart":{"curve":"basis","htmlLabels":true}}}%%
flowchart TB
  crawl["POST /crawl"] e1@--> owt["Open WebUI<br/>transport"]
  search["POST /search"] e2@--> sat["SearchAPI<br/>transport"]
  mcpStdio["MCP stdio"] e3@--> mcp["MCP server"]
  mcpHTTP["MCP HTTP /mcp"] e4@--> mcp

  owt e5@--> reg["Engine Registry"]
  mcp -- crawl tools --> reg
  sat e6@--> searcher["Searcher<br/>(SearXNG)"]
  mcp -- search tool --> searcher

  reg e7@--> reddit["Reddit engine<br/>(TOON)"]
  reg e8@--> generic["Generic fallback<br/>(markdown)"]
  reddit e9@--> c4["crawl4ai upstream<br/>(headless browser)"]
  generic e10@--> c4
  searcher e11@--> sx["SearXNG upstream<br/>(Google / Bing / DDG)"]

  classDef box fill:#161b22,stroke:#30363d,stroke-width:1px,color:#e6edf3;
  classDef accent fill:#0d1117,stroke:#F97316,stroke-width:2px,color:#ffd9b3;
  classDef animate stroke:#F97316,stroke-width:2px,stroke-dasharray:10 6,stroke-dashoffset:900,animation:dash 14s linear infinite;
  class crawl,search,mcpStdio,mcpHTTP,owt,sat box;
  class mcp,reg,searcher,reddit,generic,c4,sx accent;
  class e1,e2,e3,e4,e5,e6,e7,e8,e9,e10,e11 animate;

Reddit anti-bot handling

Reddit's edge 403-blocks non-browser HTTP clients (it fingerprints the TLS/JA3 handshake), so the Reddit engine never calls Reddit directly. It drives crawl4ai's headless Chromium to a www.reddit.com page (which clears the bot wall), then runs a same-origin fetch() of the .json and /api/morechildren endpoints from inside that page. No Reddit auth, cookies, or API key. A per-thread crawl4ai session_id is reused across expansion rounds to keep one warmed context.

Sustained scraping can raise your source IP's risk score. If fetches start returning the block page, slow down, keep expand modest, or route crawl4ai through a residential proxy.

Extending it

New engines (Hacker News, Stack Overflow, …), searchers (Brave, Tavily, …), MCP tools, and transports each plug into one small port without touching the rest. See AGENTS.md → Adding things for the architecture and a step-by-step.

Development

git clone https://github.com/kinorai/omnifeed.git && cd omnifeed
make check        # vet + lint + test (what CI runs)
go run ./cmd/omnifeed

See CONTRIBUTING.md for the full workflow, SECURITY.md for vulnerability reporting, and AGENTS.md if you're a coding agent working in this repo.

Star history

Star History Chart

Contributing

Star it if it's useful — it helps other AI builders find omnifeed.

Star Open an issue Submit a PR

New engines, searchers, MCP tools, and transports are all welcome — start with AGENTS.md and CONTRIBUTING.md.

License

MIT © kinorai

Directories

Path Synopsis
cmd
omnifeed command
Command omnifeed is the entry point.
Command omnifeed is the entry point.
internal
antibot
Package antibot recognizes bot-wall / CAPTCHA / challenge pages that upstreams (Cloudflare, Reddit's "network security" wall, PerimeterX, …) return in place of real content — frequently with an HTTP 200, so a crawl that "succeeded" can still be a block.
Package antibot recognizes bot-wall / CAPTCHA / challenge pages that upstreams (Cloudflare, Reddit's "network security" wall, PerimeterX, …) return in place of real content — frequently with an HTTP 200, so a crawl that "succeeded" can still be a block.
auth
Package auth defines an Authenticator interface for inbound transports.
Package auth defines an Authenticator interface for inbound transports.
config
Package config loads all runtime configuration from OMNIFEED_-prefixed environment variables.
Package config loads all runtime configuration from OMNIFEED_-prefixed environment variables.
domain
Package domain holds the core types exchanged between transports and engines.
Package domain holds the core types exchanged between transports and engines.
engine
Package engine defines the dispatch mechanism that picks the right per-URL handler.
Package engine defines the dispatch mechanism that picks the right per-URL handler.
engine/crawl4ai
Package crawl4ai implements the fallback engine: dispatches generic URLs to an upstream crawl4ai instance and reshapes the response into the canonical Document.
Package crawl4ai implements the fallback engine: dispatches generic URLs to an upstream crawl4ai instance and reshapes the response into the canonical Document.
engine/reddit
Package reddit implements the Reddit-specific engine: fetches threads via the public JSON API, expands collapsed reply branches with /api/morechildren, strips fields, drops deleted comments, and emits TOON or JSON.
Package reddit implements the Reddit-specific engine: fetches threads via the public JSON API, expands collapsed reply branches with /api/morechildren, strips fields, drops deleted comments, and emits TOON or JSON.
httpx
Package httpx provides HTTP utilities shared across engines: a retrying HTTP client wrapper, per-domain rate limiter, and SSRF guards.
Package httpx provides HTTP utilities shared across engines: a retrying HTTP client wrapper, per-domain rate limiter, and SSRF guards.
observability
Package observability wires structured logging, Prometheus metrics, and Kubernetes-style health endpoints.
Package observability wires structured logging, Prometheus metrics, and Kubernetes-style health endpoints.
search/searxng
Package searxng implements domain.Searcher against a SearXNG instance's JSON API (GET /search?format=json).
Package searxng implements domain.Searcher against a SearXNG instance's JSON API (GET /search?format=json).
transport/mcp
Package mcp implements a minimal Model Context Protocol server.
Package mcp implements a minimal Model Context Protocol server.
transport/mcp/tools
Package tools defines the MCP tools this proxy exposes — fetch_url and web_search.
Package tools defines the MCP tools this proxy exposes — fetch_url and web_search.
transport/openwebui
Package openwebui implements the HTTP transport that speaks Open WebUI's external-loader contract.
Package openwebui implements the HTTP transport that speaks Open WebUI's external-loader contract.
transport/searchapi
Package searchapi exposes the web-search use case over plain HTTP/JSON, so non-MCP clients (scripts, RAG pipelines, n8n, ...) can run the same query → result-URLs search the `web_search` MCP tool provides — no MCP client required.
Package searchapi exposes the web-search use case over plain HTTP/JSON, so non-MCP clients (scripts, RAG pipelines, n8n, ...) can run the same query → result-URLs search the `web_search` MCP tool provides — no MCP client required.
version
Package version exposes build-time version metadata.
Package version exposes build-time version metadata.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL