corvix.enrichment

Notification enrichment package.

Submodules

• corvix.enrichment.base
• corvix.enrichment.engine
• corvix.enrichment.providers

Classes

EnrichmentContext	Per-cycle provider context with request budget and URL cache.
EnrichmentProvider	Protocol implemented by enrichment providers.
JsonFetchClient	Client capability required by enrichment providers.
EnrichmentEngine	Runs configured enrichment providers over notifications.
EnrichmentRunResult	Result of enriching one poll cycle.
GitHubLatestCommentProvider	Enriches comment notifications with the latest comment metadata.
GitHubPRStateProvider	Enriches pull-request notifications with state metadata.

Package Contents

class corvix.enrichment.EnrichmentContext

Per-cycle provider context with request budget and URL cache.

max_requests_per_cycle: int

url_cache: dict[str, corvix.types.JsonValue]

request_count: int = 0

get_json(client: JsonFetchClient, url: str, timeout_seconds: float) → corvix.types.JsonValue

Fetch and cache a JSON payload for this cycle.

class corvix.enrichment.EnrichmentProvider

Bases: Protocol

Protocol implemented by enrichment providers.

name: str

enrich(notification: corvix.domain.Notification, client: JsonFetchClient, ctx: EnrichmentContext) → dict[str, object]

class corvix.enrichment.JsonFetchClient

Bases: Protocol

Client capability required by enrichment providers.

fetch_json_url(url: str, timeout_seconds: float = 30.0) → corvix.types.JsonValue

Fetch JSON from a fully-qualified API URL.

class corvix.enrichment.EnrichmentEngine

Runs configured enrichment providers over notifications.

config: corvix.config.EnrichmentConfig

providers: list[corvix.enrichment.base.EnrichmentProvider]

run(notifications: list[corvix.domain.Notification], client: corvix.enrichment.base.JsonFetchClient, clients_by_account: dict[str, corvix.enrichment.base.JsonFetchClient] | None = None) → EnrichmentRunResult

Run enabled providers for all notifications in one cycle.

class corvix.enrichment.EnrichmentRunResult

Result of enriching one poll cycle.

contexts_by_notification_key: dict[str, dict[str, object]]

errors: list[str] = []

property contexts_by_thread_id: dict[str, dict[str, object]]

Backward-compatible thread-keyed view of contexts.

class corvix.enrichment.GitHubLatestCommentProvider

Enriches comment notifications with the latest comment metadata.

timeout_seconds: float = 10.0

name: str = 'github.latest_comment'

enrich(notification: corvix.domain.Notification, client: corvix.enrichment.base.JsonFetchClient, ctx: corvix.enrichment.base.EnrichmentContext) → dict[str, object]

Return latest comment metadata under the provider namespace.

class corvix.enrichment.GitHubPRStateProvider

Enriches pull-request notifications with state metadata.

timeout_seconds: float = 10.0

name: str = 'github.pr_state'

enrich(notification: corvix.domain.Notification, client: corvix.enrichment.base.JsonFetchClient, ctx: corvix.enrichment.base.EnrichmentContext) → dict[str, object]

Return pull-request state metadata under the provider namespace.