watermillchat

type Broadcast struct {
	Message
	RoomName string
}

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

type Configuration struct {
	Watermill WatermillConfiguration
	History   HistoryConfiguration
	Logger    *slog.Logger
}

type HistoryConfiguration struct {
	// Defaults to [VoidHistoryRepository].
	Repository HistoryRepository

	// Retention constraints the life time of messages before their deletion.
	// Defaults to [DefaultHistoryRetention].
	Retention time.Duration

	// CleanUpFrequency is the pause between message purge
	// cycles based on retention. Defaults to [DefaultHistoryCleanupFrequency].
	CleanUpFrequency time.Duration

	// MostMessagesPerRoom constraints the maximum number of
	// returned messages per room when history is loaded using. More messages may still
	// be present in the database, if they retention duration
	// has not yet run out. Defaults to [DefaultHistoryMostMessagesPerRoom].
	MostMessagesPerRoom int
}

type HistoryRepository interface {
	Listen(broadcasts <-chan *message.Message)
	GetRoomMessages(context.Context, string) ([]Message, error)
}

type Identity struct {
	ID   string
	Name string
}

type Message struct {
	ID string

	// Author is the creator of the message. System messages
	// do not contain any author information.
	Author    *Identity
	Content   string
	CreatedAt int64
	UpdatedAt int64
}

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

type VoidHistoryRepository struct{}

type WatermillConfiguration struct {
	// Topic where the messages are published to and read from.
	// Defaults to [DefaultWatermillTopic].
	Topic      string
	Publisher  message.Publisher
	Subscriber message.Subscriber
}