messaging

type Message struct {
	ID        string    `json:"id"`
	Topic     string    `json:"topic"`
	Payload   string    `json:"payload"`
	Sender    string    `json:"sender,omitempty"`
	SessionID string    `json:"session_id,omitempty"`
	CreatedAt time.Time `json:"created_at"`
}

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

type Store interface {
	// Publish adds a message to multiple topics.
	// Wildcards are expanded before publishing.
	Publish(ctx context.Context, msg Message, topics []string) error

	// Subscribe returns all messages for a topic, optionally filtered by since timestamp.
	// Returns ErrTopicNotFound if the topic doesn't exist.
	Subscribe(ctx context.Context, topic string, since time.Time) ([]Message, error)

	// Acknowledge marks messages as read by a consumer.
	Acknowledge(ctx context.Context, consumerID string, messageIDs []string) error

	// GetUnread returns messages not yet acknowledged by consumer.
	// Supports wildcard topic patterns.
	GetUnread(ctx context.Context, consumerID string, topic string) ([]Message, error)

	// List returns all topic names.
	List(ctx context.Context) ([]string, error)

	// Prune removes messages older than the given duration across all topics.
	// Returns the number of messages removed.
	Prune(ctx context.Context, olderThan time.Duration) (int, error)
}

type Topic struct {
	Name      string    `json:"name"`
	Messages  []Message `json:"messages"`
	UpdatedAt time.Time `json:"updated_at"`
}