notificationstore

type Delivery struct {
	Key            string
	NotificationID model.ID[Envelope]
	Channel        string
	Kind           string
	State          string
	Payload        value.JSON[json.RawMessage]
	Claim          model.ID[Delivery]
	Attempts       uint32
	UpdatedAt      temporal.DateTime
}

type DeliveryTable struct {
	// Table provides model queries and writes. Example: orm.First(ctx, tx, Deliveries.Query()).
	orm.Table[Delivery, string]
	// KeyColumn binds Delivery.Key.
	// Example: orm.TextSet(Deliveries.KeyColumn, key).
	KeyColumn orm.TextLookupKey[Delivery, string]
	// NotificationID binds Delivery.NotificationID.
	// Example: orm.ColumnSet(Deliveries.NotificationID, notificationID).
	NotificationID orm.Column[Delivery, model.ID[Envelope]]
	// Channel binds Delivery.Channel.
	// Example: orm.TextSet(Deliveries.Channel, channel).
	Channel orm.Text[Delivery, string]
	// Kind binds Delivery.Kind.
	// Example: orm.TextSet(Deliveries.Kind, kind).
	Kind orm.Text[Delivery, string]
	// State binds Delivery.State.
	// Example: orm.TextSet(Deliveries.State, state).
	State orm.Text[Delivery, string]
	// Payload binds Delivery.Payload.
	// Example: encoded, err := value.NewJSON(payload); if err == nil { _ = orm.JSONSet(Deliveries.Payload, encoded) }.
	Payload orm.JSON[Delivery, json.RawMessage]
	// Claim binds Delivery.Claim.
	// Example: orm.ColumnSet(Deliveries.Claim, claim).
	Claim orm.Column[Delivery, model.ID[Delivery]]
	// Attempts binds Delivery.Attempts.
	// Example: orm.NumberSet(Deliveries.Attempts, attempts).
	Attempts orm.Number[Delivery, uint32]
	// UpdatedAt is caller-managed; the ORM does not refresh it.
	// Example: orm.TimeSet(Deliveries.UpdatedAt, updatedAt).
	UpdatedAt orm.Time[Delivery, temporal.DateTime]
}

type Envelope struct {
	ID          model.ID[Envelope]
	Recipient   string
	Scope       string
	SubjectKey  string
	Identity    value.JSON[model.Identity]
	Origin      value.JSON[attribution.Origin]
	Name        string
	Version     uint32
	Payload     value.JSON[json.RawMessage]
	Fingerprint string
	CreatedAt   temporal.DateTime
}

type EnvelopeTable struct {
	// Table provides model queries and writes. Example: orm.First(ctx, tx, Envelopes.Query()).
	orm.Table[Envelope, model.ID[Envelope]]
	// ID binds Envelope.ID.
	// Example: orm.KeySet(Envelopes.ID, id).
	ID orm.Key[Envelope, model.ID[Envelope]]
	// Recipient binds Envelope.Recipient.
	// Example: orm.TextSet(Envelopes.Recipient, recipient).
	Recipient orm.Text[Envelope, string]
	// Scope binds Envelope.Scope.
	// Example: orm.TextSet(Envelopes.Scope, scope).
	Scope orm.Text[Envelope, string]
	// SubjectKey binds Envelope.SubjectKey.
	// Example: orm.TextSet(Envelopes.SubjectKey, subjectKey).
	SubjectKey orm.Text[Envelope, string]
	// Identity binds Envelope.Identity.
	// Example: encoded, err := value.NewJSON(identity); if err == nil { _ = orm.JSONSet(Envelopes.Identity, encoded) }.
	Identity orm.JSON[Envelope, model.Identity]
	// Origin binds Envelope.Origin.
	// Example: encoded, err := value.NewJSON(origin); if err == nil { _ = orm.JSONSet(Envelopes.Origin, encoded) }.
	Origin orm.JSON[Envelope, attribution.Origin]
	// Name binds Envelope.Name.
	// Example: orm.TextSet(Envelopes.Name, name).
	Name orm.Text[Envelope, string]
	// Version binds Envelope.Version.
	// Example: orm.NumberSet(Envelopes.Version, version).
	Version orm.Number[Envelope, uint32]
	// Payload binds Envelope.Payload.
	// Example: encoded, err := value.NewJSON(payload); if err == nil { _ = orm.JSONSet(Envelopes.Payload, encoded) }.
	Payload orm.JSON[Envelope, json.RawMessage]
	// Fingerprint binds Envelope.Fingerprint.
	// Example: orm.TextSet(Envelopes.Fingerprint, fingerprint).
	Fingerprint orm.Text[Envelope, string]
	// CreatedAt preserves an explicit creation time; callers supply this timestamp.
	// Example: orm.TimeSet(Envelopes.CreatedAt, createdAt).
	CreatedAt orm.Time[Envelope, temporal.DateTime]
}

type Inbox struct {
	ID         model.ID[Inbox]
	Scope      string
	SubjectKey string
	Name       string
	Version    uint32
	Data       value.JSON[json.RawMessage]
	CreatedAt  temporal.DateTime
	ReadAt     value.Nullable[temporal.DateTime]
}

type InboxTable struct {
	// Table provides model queries and writes. Example: orm.First(ctx, tx, Inboxes.Query()).
	orm.Table[Inbox, model.ID[Inbox]]
	// ID binds Inbox.ID.
	// Example: orm.KeySet(Inboxes.ID, id).
	ID orm.Key[Inbox, model.ID[Inbox]]
	// Scope binds Inbox.Scope.
	// Example: orm.TextSet(Inboxes.Scope, scope).
	Scope orm.Text[Inbox, string]
	// SubjectKey binds Inbox.SubjectKey.
	// Example: orm.TextSet(Inboxes.SubjectKey, subjectKey).
	SubjectKey orm.Text[Inbox, string]
	// Name binds Inbox.Name.
	// Example: orm.TextSet(Inboxes.Name, name).
	Name orm.Text[Inbox, string]
	// Version binds Inbox.Version.
	// Example: orm.NumberSet(Inboxes.Version, version).
	Version orm.Number[Inbox, uint32]
	// Data binds Inbox.Data.
	// Example: encoded, err := value.NewJSON(data); if err == nil { _ = orm.JSONSet(Inboxes.Data, encoded) }.
	Data orm.JSON[Inbox, json.RawMessage]
	// CreatedAt preserves an explicit creation time; callers supply this timestamp.
	// Example: orm.TimeSet(Inboxes.CreatedAt, createdAt).
	CreatedAt orm.Time[Inbox, temporal.DateTime]
	// ReadAt binds Inbox.ReadAt.
	// Example: orm.NullableTimeSetNull(Inboxes.ReadAt).
	ReadAt orm.NullableTime[Inbox, temporal.DateTime]
}