Connectors

from open_index.connectors import Connector, EntitySpec


class LinearConnector(Connector):
    name = "linear-issues"

    # Where the source MCP server lives. ${ENV} refs are resolved at run time,
    # so the URL and token stay out of git.
    mcp_url = "${LINEAR_MCP_URL}"
    mcp_auth_headers = {"Authorization": "Bearer ${LINEAR_TOKEN}"}

    schedule = "daily"          # manual | hourly | daily | weekly | 6h | 30m | 1w

    def extract_issues(self):
        for item in self.paginate("list_issues", result_key="issues"):
            yield EntitySpec(
                doc_type="issue",
                id=f"issue:{item['id']}",
                name=item["title"],
                fields={"status": item["state"]},
                related_to=[(f"product:{item['project']}", "belongs to product")],
            )

export LINEAR_MCP_URL=https://mcp.linear.app/mcp
export LINEAR_TOKEN=...

open-index list-connectors                  # what's discovered, and its URL
open-index ingest linear-issues             # run it now
open-index run                              # run everything whose schedule is due
open-index run --loop 3600                  # or wire `open-index run` into cron/CI