events

type ConnectorSyncCompletedEvent struct {
	// EventMetadata contains the common event fields.
	EventMetadata

	// ConnectorID is the identifier of the connector that completed syncing.
	ConnectorID string `json:"connector_id"`

	// WorkspaceID is the workspace the connector synced into.
	WorkspaceID string `json:"workspace_id"`

	// DocumentsNew is the count of newly created documents.
	DocumentsNew int `json:"documents_new"`

	// DocumentsUpd is the count of updated documents.
	DocumentsUpd int `json:"documents_updated"`

	// DocumentsDel is the count of deleted documents.
	DocumentsDel int `json:"documents_deleted"`

	// Errors is the count of errors encountered during the sync.
	Errors int `json:"errors"`
}

type DocumentDeletedEvent struct {
	// EventMetadata contains the common event fields.
	EventMetadata

	// DocumentID is the identifier of the deleted document.
	DocumentID string `json:"document_id"`

	// WorkspaceID is the workspace the document belonged to.
	WorkspaceID string `json:"workspace_id"`

	// Title is the deleted document's name (its value in the "name" list-query field).
	// It is carried on the event so the value-suggestion facet's refcount DEC
	// recovers the value without re-reading the soft-deleted row.
	Title string `json:"title,omitempty"`

	// Classification is the deleted document's sensitivity — the facet partition key the
	// DEC decrements, carried alongside Title so the delete needs no second read.
	Classification string `json:"classification,omitempty"`
}

type DocumentReclassifiedEvent struct {
	// EventMetadata contains the common event fields.
	EventMetadata

	// DocumentID is the identifier of the reclassified document.
	DocumentID string `json:"document_id"`

	// WorkspaceID is the workspace the document belongs to (the KB tenant-isolation filter).
	WorkspaceID string `json:"workspace_id"`

	// StorageKey is the document's object-store key; the sidecar lives at
	// <storage_key>.metadata.json, so the consumer needs it to re-stamp the metadata.
	StorageKey string `json:"storage_key"`

	// TrustLevel is the document's NEW provenance trust to write into the sidecar.
	TrustLevel string `json:"trust_level"`

	// Classification is the document's NEW sensitivity to write into the sidecar (the
	// value retrieval's clearance filter compares against).
	Classification string `json:"classification"`
}

type DocumentStatusChangedEvent struct {
	// EventMetadata contains the common event fields.
	EventMetadata

	// DocumentID is the identifier of the document whose status changed.
	DocumentID string `json:"document_id"`

	// WorkspaceID is the workspace the document belongs to.
	WorkspaceID string `json:"workspace_id"`

	// OldStatus is the previous status of the document.
	OldStatus string `json:"old_status"`

	// NewStatus is the new status of the document.
	NewStatus string `json:"new_status"`
}

type DocumentUploadedEvent struct {
	// EventMetadata contains the common event fields.
	EventMetadata

	// DocumentID is the identifier of the uploaded document.
	DocumentID string `json:"document_id"`

	// WorkspaceID is the workspace the document was uploaded to.
	WorkspaceID string `json:"workspace_id"`

	// FileName is the original name of the uploaded file.
	FileName string `json:"file_name"`

	// ContentType is the MIME type of the uploaded file.
	ContentType string `json:"content_type"`

	// StorageKey is the object storage key where the file is stored.
	StorageKey string `json:"storage_key"`

	// TrustLevel is the document's provenance trust; ingestion writes it into the
	// Bedrock KB sidecar for retrieval weighting.
	TrustLevel string `json:"trust_level"`

	// Classification is the document's sensitivity; ingestion writes it into the
	// Bedrock KB sidecar for clearance-based retrieval filtering.
	Classification string `json:"classification"`

	// SizeBytes is the size of the uploaded file in bytes.
	SizeBytes int64 `json:"size_bytes"`
}

type Event interface {
	// Type returns the event's type discriminator.
	Type() EventType

	// Metadata returns the common metadata shared by all events.
	Metadata() EventMetadata
}

type EventMetadata struct {
	// EventID is the unique identifier of the event.
	EventID string `json:"event_id"`

	// EventType is the type discriminator for the event.
	EventType EventType `json:"event_type"`

	// OccurredAt is the timestamp when the event occurred.
	OccurredAt time.Time `json:"occurred_at"`

	// OrgID is the organization that the event belongs to.
	OrgID string `json:"org_id"`

	// UserID is the user who triggered the event, if applicable.
	UserID string `json:"user_id,omitempty"`

	// CorrelationID links related events across services.
	CorrelationID string `json:"correlation_id,omitempty"`

	// TraceParent carries the W3C trace context (traceparent header) captured when
	// the event was produced, so a consumer can continue the originating trace —
	// e.g. HTTP upload → outbox → relay publish → ingestion — as one distributed
	// trace. Empty when no active trace context was present.
	TraceParent string `json:"traceparent,omitempty"`
}

type EventType string

type TeamCreatedEvent struct {
	// EventMetadata contains the common event fields.
	EventMetadata

	// TeamID is the identifier of the newly created team.
	TeamID string `json:"team_id"`

	// TeamName is the display name of the newly created team.
	TeamName string `json:"team_name"`
}