Struct LabelService 

pub struct LabelService { /* private fields */ }

The main label service that creates, signs, and stores labels.

Implementations

impl LabelService

pub fn new(db: SqlitePool, signer: LabelSigner, labeler_did: String) -> Self

Create a new label service.

pub async fn migrate(&self) -> Result<()>

Run migrations to create the labels table.

pub async fn create_label( &self, subject_uri: &str, value: LabelValue, subject_cid: Option<&str>, ) -> Result<SignedLabel>

Create and store a label for a subject.

The label is signed and persisted to the store before being returned.

pub async fn negate_label( &self, subject_uri: &str, value: LabelValue, subject_cid: Option<&str>, ) -> Result<SignedLabel>

Negate (remove) a previously issued label.

Creates a new label entry with neg: true, indicating that the specified label value no longer applies to the subject.

pub async fn query_labels(&self, uri: &str) -> Result<Vec<SignedLabel>>

Query labels for a subject URI.

pub async fn query_since( &self, cursor: i64, limit: i64, ) -> Result<Vec<(i64, SignedLabel)>>

Query labels since a cursor for subscription streaming.

Returns (row_id, signed_label) pairs so callers can track the cursor position for subsequent requests.