streaming

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

type ClientInfo struct {
	ClientID string
	Scopes   []string
}

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

type DataItem struct {
	Service   string          `json:"service"`
	Timestamp int64           `json:"timestamp"`
	Command   string          `json:"command"`
	Content   json.RawMessage `json:"content"`
}

type Metadata struct {
	CorrelID    string    `json:"correl_id"`
	CustomerID  string    `json:"customer_id"`
	Channel     string    `json:"channel"`
	FunctionID  string    `json:"function_id"`
	WSEndpoint  string    `json:"ws_endpoint"`
	ExtractedAt time.Time `json:"extracted_at"`

	TTL time.Duration
}

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

type NotifyItem struct {
	Service   string          `json:"service,omitempty"`
	Timestamp int64           `json:"timestamp,omitempty"`
	Content   json.RawMessage `json:"content,omitempty"`
	Heartbeat string          `json:"heartbeat,omitempty"`
}

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

type Request struct {
	Service    string         `json:"service"`
	Command    string         `json:"command"`
	RequestID  string         `json:"requestid"`
	Parameters map[string]any `json:"parameters,omitempty"`

	//nolint:tagliatelle // Required by Schwab API
	SchwabClientCustomerID string `json:"SchwabClientCustomerId,omitempty"`

	//nolint:tagliatelle // Required by Schwab API
	SchwabClientCorrelID string `json:"SchwabClientCorrelId,omitempty"`
}

type RequestBatch struct {
	Requests []Request `json:"requests"`
}

type Response struct {
	Response []ResponseItem `json:"response,omitempty"`
	Data     []DataItem     `json:"data,omitempty"`
	Notify   []NotifyItem   `json:"notify,omitempty"`
}

type ResponseContent struct {
	Code int    `json:"code"`
	Msg  string `json:"msg,omitempty"`
}

type ResponseItem struct {
	Service   string          `json:"service"`
	RequestID string          `json:"requestid"`
	Command   string          `json:"command"`
	Timestamp int64           `json:"timestamp"`
	Content   ResponseContent `json:"content"`

	//nolint:tagliatelle // Required by Schwab API
	SchwabClientCorrelID string `json:"SchwabClientCorrelId,omitempty"`
}

type StreamerInfo struct {
	//nolint:tagliatelle // Schwab API response structure
	StreamerSocketURL string `json:"streamerSocketUrl"`

	//nolint:tagliatelle // Schwab API response structure
	SchwabClientCustomerID string `json:"schwabClientCustomerId"`

	//nolint:tagliatelle // Schwab API response structure
	SchwabClientCorrelID string `json:"schwabClientCorrelId"`

	//nolint:tagliatelle // Schwab API response structure
	SchwabClientChannel string `json:"schwabClientChannel"`

	//nolint:tagliatelle // Schwab API response structure
	SchwabClientFunctionID string `json:"schwabClientFunctionId"`
}

type UserPreferencesResponse struct {
	//nolint:tagliatelle // Schwab API response structure
	StreamerInfo []StreamerInfo `json:"streamerInfo"`

	// Extras stores any additional fields returned by the Schwab API so they
	// are preserved when the response is re-encoded and forwarded.
	Extras map[string]json.RawMessage `json:"-"`
}