broadcasting

type AuthConfig struct {
	Enabled    bool
	Path       string
	Middleware []contractshttp.Middleware
}

type AuthResponse struct {
	Auth        string `json:"auth"`
	ChannelData string `json:"channel_data,omitempty"`
}

type Broadcast interface {
	Channel(pattern string, callback ChannelAuthFunc)
	Dispatch(ctx context.Context, event ShouldBroadcast) error
}

type ChannelAuthFunc func(ctx context.Context, userID any, channelName string, params map[string]string) (bool, any)

type ConnectionConfig struct {
	Driver  string
	Key     string
	Secret  string
	AppID   string `json:"app_id"`
	Options map[string]any
}

type Driver interface {
	Broadcast(ctx context.Context, channels []string, event string, payload map[string]any) error
}

type PusherOptions struct {
	Cluster string
	Host    string
	Port    int
	Scheme  string
}

type ShouldBroadcast interface {
	BroadcastOn() []string
	BroadcastAs() string
	BroadcastWith() map[string]any
	BroadcastWhen() bool
}

type ShouldBroadcastNow interface {
	BroadcastNow() bool
}

type ShouldBroadcastWithBackoff interface {
	// BroadcastBackoff returns the delay before each retry attempt, in
	// order; the last value repeats for subsequent attempts. It applies
	// to every retry, whether capped by the event's own BroadcastTries
	// or the queue worker's Tries config; the last value repeats.
	BroadcastBackoff() []time.Duration
}

type ShouldBroadcastWithConnections interface {
	BroadcastConnections() []string
}

type ShouldBroadcastWithDelay interface {
	BroadcastDelay() time.Time
}

type ShouldBroadcastWithQueue interface {
	BroadcastQueue() string
}

type ShouldBroadcastWithQueueConnection interface {
	BroadcastQueueConnection() string
}

type ShouldBroadcastWithTimeout interface {
	BroadcastTimeout() time.Duration
}

type ShouldBroadcastWithTries interface {
	// BroadcastTries returns the maximum number of attempts for the
	// queued broadcast. 0 / not implementing the interface means no
	// retry policy is declared and the queue worker's Tries config
	// applies.
	BroadcastTries() int
}