pubsub

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

type Event struct {
	Topic  string         `json:"topic"`
	Member string         `json:"member"` // Generic member data (usually outpoint string)
	Score  float64        `json:"score"`
	Source string         `json:"source"`         // "redis", "sse:peerURL", etc.
	Data   map[string]any `json:"data,omitempty"` // Additional event data
}

type EventData struct {
	Outpoint string  `json:"outpoint"`
	Score    float64 `json:"score"`
}

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

type PubSub interface {
	// Publishing functionality
	Publish(ctx context.Context, topic string, data string) error

	// Subscribing functionality
	Subscribe(ctx context.Context, topics []string) (<-chan Event, error)
	Unsubscribe(topics []string) error

	// Connection management
	Start(ctx context.Context) error
	Stop() error
	Close() error
}

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

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

type SSEEvent struct {
	Topic    string
	Outpoint transaction.Outpoint
	PeerURL  string
}

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

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

type Storage interface {
	DoesAppliedTransactionExist(ctx context.Context, tx *overlay.AppliedTransaction) (bool, error)
}

type SubscriberConfig struct {
	// Redis configuration
	RedisURL string

	// SSE peer configuration
	SSEPeers map[string][]string // peer URL -> topics

	// Engine for transaction processing
	Engine interface {
		Submit(ctx context.Context, taggedBEEF any, mode any, onSteakReady any) (any, error)
		GetStorage() Storage
	}
}

type TransactionFetcher interface {
	FetchBEEF(ctx context.Context, peerURL, topic string, outpoint transaction.Outpoint) ([]byte, error)
}