sharedstate

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

type EventHandler interface {
	HandleEvent(eventType string, data map[string]interface{}) error
}

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

type IntegrationConfig struct {
	EventStream        *eventstream.Stream
	StateManager       *statemanager.StateManager
	SupabaseClient     *supabase.Client
	SharedStateManager *SharedStateManager
}

type MockEvent struct {
	Type      string
	Data      interface{}
	Timestamp time.Time
}

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

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

type MockSupabaseClient struct{}

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

type ServerConfig struct {
	Port               int
	EventStream        *eventstream.Stream
	StateManager       *statemanager.StateManager
	SupabaseClient     *supabase.Client
	SharedStateManager *SharedStateManager
}

type SharedStateConfig struct {
	EventStream  *eventstream.Stream
	StateManager *statemanager.StateManager
}

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

type StateManager interface {
	GetState(stateType StateType, stateID string) (map[string]interface{}, error)

	UpdateState(stateType StateType, stateID string, data map[string]interface{}) error

	RegisterWebSocketHandler(router gin.IRouter)

	Close() error
}

type StateType string

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

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

type WebSocketMessage struct {
	Type      string      `json:"type"`
	Topic     string      `json:"topic"`
	Data      interface{} `json:"data"`
	Timestamp time.Time   `json:"timestamp"`
}

type WebSocketServer interface {
	Start() error

	Stop() error

	PublishToTopic(topic string, data interface{})

	SubscribeToTopic(clientID, topic string)

	UnsubscribeFromTopic(clientID, topic string)

	HandleWebSocket(c *gin.Context)
}