Struct IntegrationsWriteService 

pub struct IntegrationsWriteService { /* private fields */ }

Implementations

impl IntegrationsWriteService

pub fn new(pool: PgPool) -> Self

pub async fn register_connector( &self, c: NewConnector, ) -> Result<Uuid, IntegrationError>

Register a connector to an external provider.

pub async fn receive_event( &self, e: InboundEvent, mapper: &dyn TargetPort, events: &dyn IntegrationEventSink, ) -> Result<ReceiveOutcome, IntegrationError>

Receive an inbound event: dedup on (connector, external_id), map it to an internal action via the TargetPort, and record the outcome. A retried webhook returns the original with duplicate=true — it never re-maps. Emits IntegrationEventMapped / IntegrationEventFailed / IntegrationEventIgnored.

pub async fn failures( &self, connector_id: Uuid, ) -> Result<Vec<FailedEvent>, IntegrationError>

The failure report for a connector — the failed events with their keys + error — so an operator can see WHICH provider events (e.g. settled payments) failed to book, WITHOUT querying the private ledger (completeness council 2026-07-11).

pub async fn retry_failed( &self, company_id: Uuid, connector_id: Uuid, mapper: &dyn TargetPort, events: &dyn IntegrationEventSink, ) -> Result<usize, IntegrationError>

Re-drive a connector’s FAILED events through the target after the cause is fixed — the recovery path the dedup would otherwise weld shut (a re-delivered webhook dedups and never re-maps). Re-invokes the TargetPort under the SAME business-key idempotency the target enforces, so it can’t double-apply; a still-failed event that now maps transitions failed → mapped. Returns the number newly mapped (completeness council 2026-07-11).

company_id is the legacy tenancy twin (ADR-0029) — the module’s tables carry no company column, but the re-mapped events still route to the TargetPort and the outbox/event payloads, which are company-shaped; the CALLER (the composing host, which knows the tenant) names it, and an unknown value fails closed at those edges, never inside this module.