eventlog

type ActorType string

type AppendOption func(*appendConfig)

type AppendResult struct {
	GroupID  string // surrogate id of the resolved registry row
	Seq      int64  // group-monotonic ordering token of the (existing or new) row
	Inserted bool   // false = an idempotent redelivery collapsed onto an existing row
	Message  sqlc.CtxGroupMessage
}

type GroupMessage struct {
	ActorType      ActorType
	ActorID        string
	Content        string
	Reasoning      string
	AgentSessionID string
}

type Message struct {
	// Physical group identity (D0). The triple resolves to one registry row.
	Platform         string
	PlatformGroupID  string
	PlatformThreadID string // "" when the group has no sub-thread/topic

	SourceChannelID string // observing bot; audit only, never a dedup/route key

	ActorType ActorType
	ActorID   string // platform sender id (human) or agent id (agent)

	PlatformMessageID string // "" when the adapter cannot supply one
	ReplyTo           string // platform message id this replies to; "" if none

	// PlatformTimestamp is the platform-reported send time. Pass a non-zero,
	// dedup-grade (high-precision) time to enable the fallback idempotency key
	// when PlatformMessageID is absent; pass the zero value to skip it. Never
	// pass a local receive time — that would misclassify back-to-back identical
	// messages as redeliveries and drop data.
	PlatformTimestamp time.Time

	Content string
}

type Store struct {
	// contains filtered or unexported fields
}