chat

type Channel struct {
	ID   uuid.UUID `ch:"id"`
	Name string    `ch:"name"`
	Time time.Time `ch:"timestamp"`
}

type GetMessageStream func(ctx context.Context, messageTypes []uint8) (<-chan *Message, error)

type Message struct {
	Username    string    `ch:"username"`
	ChannelName string    `ch:"channel"`
	Message     string    `ch:"message"`
	MessageType uint8     `ch:"message_type"`
	Time        time.Time `ch:"timestamp"`
}

type Repository interface {
	SaveMessage(ctx context.Context, message *Message) error
	GetMessages(ctx context.Context, channel, username string, limit, offset int) ([]*Message, error)
	GetChannels(ctx context.Context) ([]*Channel, error)
	GetChannel(ctx context.Context, uuid uuid.UUID) (*Channel, error)
	SaveChannel(ctx context.Context, channel *Channel) error
	DeleteChannel(ctx context.Context, channel *Channel) error
}