pubsub

type BulkHandler func(ctx context.Context, msgs []*NewMessage) error

type BulkMessageEntry struct {
	EntryId     string            `json:"entryId"` //nolint:stylecheck
	Event       []byte            `json:"event"`
	ContentType string            `json:"contentType,omitempty"`
	Metadata    map[string]string `json:"metadata"`
}

type BulkPublishRequest struct {
	Entries    []BulkMessageEntry `json:"entries"`
	PubsubName string             `json:"pubsubname"`
	Topic      string             `json:"topic"`
	Metadata   map[string]string  `json:"metadata"`
}

type BulkPublishResponse struct {
	FailedEntry []FailedEntry
}

type BulkPublisher interface {
	BulkPublish(ctx context.Context, req *BulkPublishRequest) (*BulkPublishResponse, error)
}

type BulkSubscribeConfig struct {
	MaxMessagesCount   int `json:"maxMessagesCount,omitempty"`
	MaxAwaitDurationMs int `json:"maxAwaitDurationMs,omitempty"`
}

type BulkSubscriber interface {
	BulkSubscribe(ctx context.Context, req *SubscribeRequest, handler BulkHandler) error
}

type FailedEntry struct {
	EntryId string
	Err     error
}

type Feature string

type Handler func(ctx context.Context, msg *NewMessage) error

type Metadata struct {
	metadata.Base `json:",inline"`
}

type NewMessage struct {
	Data        []byte            `json:"data"`
	Topic       string            `json:"topic"`
	Metadata    map[string]string `json:"metadata"`
	ContentType *string           `json:"contentType,omitempty"`
}

type PubSub interface {
	io.Closer
	Init(ctx context.Context, metadata Metadata) error
	Publish(ctx context.Context, req *PublishRequest) error
	Subscribe(ctx context.Context, req *SubscribeRequest, handler Handler) error
}

type PublishRequest struct {
	Data       []byte            `json:"data"`
	PubsubName string            `json:"pubsubName"`
	Topic      string            `json:"topic"`
	Metadata   map[string]string `json:"metadata"`
}

type SubscribeRequest struct {
	Topic               string              `json:"topic"`
	Metadata            map[string]string   `json:"metadata"`
	BulkSubscribeConfig BulkSubscribeConfig `json:"bulkSubscribe,omitempty"`
}