idiolect-indexer 0.2.0

//! The shape of a firehose event once it has been decoded into an
//! idiolect record.
//!
//! `tapped::RecordEvent` gives us metadata (did, rkey, collection,
//! action, live) plus a json slice. The indexer lifts that into
//! [`IndexerEvent`] by decoding the slice through
//! [`idiolect_records::decode_record`]. Handlers consume
//! `IndexerEvent`, not the raw tapped type, so the core crate never
//! imposes the tapped dependency on callers.

use idiolect_records::AnyRecord;

/// Commit action that produced this event.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum IndexerAction {
    /// Record was created in the PDS.
    Create,
    /// Record was updated in place. The appview may or may not have
    /// the prior revision; `tap` does not re-emit it.
    Update,
    /// Record was deleted. No body is present on the event.
    Delete,
}

/// Decoded firehose commit, ready for handler dispatch.
#[derive(Debug, Clone)]
pub struct IndexerEvent {
    /// Sequence id assigned by tap. Monotonic per connection;
    /// suitable for cursor commits on live events.
    pub seq: u64,
    /// True if this event came off the live firehose. False for
    /// backfill / resync replays.
    pub live: bool,
    /// DID of the repo the record belongs to.
    pub did: String,
    /// Repository revision (TID) this commit advanced to.
    pub rev: String,
    /// Record key (usually a TID) within the collection.
    pub rkey: String,
    /// Lexicon nsid of the commit's collection.
    pub collection: String,
    /// Commit action: create / update / delete.
    pub action: IndexerAction,
    /// CID of the record body (`None` on delete).
    pub cid: Option<String>,
    /// Decoded record body. `None` on delete; otherwise the strongly-
    /// typed [`AnyRecord`] variant matching `collection`.
    pub record: Option<AnyRecord>,
}

impl IndexerEvent {
    /// Convenience: the at-uri at which this event's record lives.
    #[must_use]
    pub fn at_uri(&self) -> String {
        format!("at://{}/{}/{}", self.did, self.collection, self.rkey)
    }
}