domain

type Channel struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}

type ChannelRepository interface {
	Get(ctx context.Context) ([]Channel, error)
}

type ChannelUsecase interface {
	Get(ctx context.Context) ([]Channel, error)
}

type Chat struct {
	ChannelID string `json:"channel_id"`
	Sender    string `json:"sender"`
	Message   string `json:"message"`
	CreatedAt int64  `json:"created_at"`
}

type ChatRepository interface {
	Get(ctx context.Context, channelID string, createdAt int64, limit int) ([]Chat, error)
	Create(ctx context.Context, chat Chat) error
	Publish(ctx context.Context, chat Chat) error
}

type ChatUsecase interface {
	NewClient(ctx context.Context, r http.ResponseWriter, groupID string)
	CloseClient(ctx context.Context, r http.ResponseWriter, groupID string)
	Post(ctx context.Context, chat Chat) error
	Get(ctx context.Context, channelID string, createdAt int64, limit int) ([]Chat, error)
	Broadcast(ctx context.Context, chat Chat)
}