mock_server

type Client struct {
	ConnectedAtTimestamp string // RFC3339Nano timestamp indicating when the client connected to the server
	// contains filtered or unexported fields
}

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

type EmptyStruct struct {
}

type KeepaliveMessage struct {
	Metadata MessageMetadata         `json:"metadata"`
	Payload  KeepaliveMessagePayload `json:"payload"`
}

type KeepaliveMessagePayload struct{}

type MessageMetadata struct {
	MessageID        string `json:"message_id"`
	MessageType      string `json:"message_type"`
	MessageTimestamp string `json:"message_timestamp"`

	SubscriptionType    string `json:"subscription_type,omitempty"`
	SubscriptionVersion string `json:"subscription_version,omitempty"`
}

type NotificationMessage struct {
	Metadata MessageMetadata         `json:"metadata"`
	Payload  models.EventsubResponse `json:"payload"`
}

type ReconnectMessage struct {
	Metadata MessageMetadata         `json:"metadata"`
	Payload  ReconnectMessagePayload `json:"payload"`
}

type ReconnectMessagePayload struct {
	Session ReconnectMessagePayloadSession `json:"session"`
}

type ReconnectMessagePayloadSession struct {
	ID                      string `json:"id"`
	Status                  string `json:"status"`
	KeepaliveTimeoutSeconds *int   `json:"keepalive_timeout_seconds"`
	ReconnectUrl            string `json:"reconnect_url"`
	ConnectedAt             string `json:"connected_at"`
}

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

type Subscription struct {
	SubscriptionID    string     // Random GUID for the subscription
	ClientID          string     // Client ID included in headers
	Type              string     // EventSub topic
	Version           string     // EventSub topic version
	CreatedAt         string     // Timestamp of when the subscription was created
	DisabledAt        *time.Time // Not public; Timestamp of when the subscription was disabled
	Status            string     // Status of the subscription
	SessionClientName string     // Client name of the session this is associated with.

	ClientConnectedAt    string // Time client connected
	ClientDisconnectedAt string // Time client disconnected

	Conditions models.EventsubCondition // Values of the subscription's condition object
}

type SubscriptionGetSuccessResponse struct {
	Total        int         `json:"total"`
	TotalCost    int         `json:"total_cost"`
	MaxTotalCost int         `json:"max_total_cost"`
	Pagination   EmptyStruct `json:"pagination"`

	Data []SubscriptionPostSuccessResponseBody `json:"data"`
}

type SubscriptionPostErrorResponse struct {
	Error   string `json:"error"`
	Message string `json:"message"`
	Status  int    `json:"status"`
}

type SubscriptionPostRequest struct {
	Type    string `json:"type"`
	Version string `json:"version"`

	Condition models.EventsubCondition         `json:"condition"`
	Transport SubscriptionPostRequestTransport `json:"transport"`
}

type SubscriptionPostRequestTransport struct {
	Method    string `json:"method"`
	SessionID string `json:"session_id"`
}

type SubscriptionPostSuccessResponse struct {
	Data []SubscriptionPostSuccessResponseBody `json:"data"`

	Total        int `json:"total"`
	MaxTotalCost int `json:"max_total_cost"`
	TotalCost    int `json:"total_cost"`
}

type SubscriptionPostSuccessResponseBody struct {
	ID        string `json:"id"`
	Status    string `json:"status"`
	Type      string `json:"type"`
	Version   string `json:"version"`
	CreatedAt string `json:"created_at"`
	Cost      int    `json:"cost"`

	Condition models.EventsubCondition `json:"condition"`
	Transport SubscriptionTransport    `json:"transport"`
}

type SubscriptionTransport struct {
	Method         string `json:"method"`
	SessionID      string `json:"session_id"`
	ConnectedAt    string `json:"connected_at,omitempty"`
	DisconnectedAt string `json:"disconnected_at,omitempty"`
}

type WebSocketServer struct {
	ServerId     string // Int representing the ID of the server
	DebugEnabled bool   // Display debug messages; --debug
	StrictMode   bool   // Force stricter production-like qualities; --strict

	Upgrader websocket.Upgrader

	Clients *util.List[Client] // All connected clients

	Status int // 0 = shut down; 1 = shutting down; 2 = online

	Subscriptions map[string][]Subscription // Active subscriptions on this server -- Accessed via Subscriptions[clientName]

	ReconnectClients *util.List[[]Subscription] // Clients that were part of the last server
	// contains filtered or unexported fields
}

type WelcomeMessage struct {
	Metadata MessageMetadata       `json:"metadata"`
	Payload  WelcomeMessagePayload `json:"payload"`
}

type WelcomeMessagePayload struct {
	Session WelcomeMessagePayloadSession `json:"session"`
}

type WelcomeMessagePayloadSession struct {
	ID                      string  `json:"id"`
	Status                  string  `json:"status"`
	KeepaliveTimeoutSeconds int     `json:"keepalive_timeout_seconds"`
	ReconnectUrl            *string `json:"reconnect_url"`
	ConnectedAt             string  `json:"connected_at"`
}