graphqlws

type AuthenticateFunc func(data map[string]any, conn Connection) (context.Context, error)

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

type Connection interface {
	// ID returns the unique ID of the connection.
	ID() string

	// Context returns the context for the connection
	Context() context.Context

	// WS the websocket
	WS() *websocket.Conn

	// SendData sends results of executing an operation (typically a
	// subscription) to the client.
	SendData(string, *DataMessagePayload)

	// SendError sends an error to the client.
	SendError(error)
}

type ConnectionConfig struct {
	Logger        Logger
	Authenticate  AuthenticateFunc
	EventHandlers ConnectionEventHandlers
}

type ConnectionEventHandlers struct {
	// Close is called whenever the connection is closed, regardless of
	// whether this happens because of an error or a deliberate termination
	// by the client.
	Close func(Connection)

	// StartOperation is called whenever the client demands that a GraphQL
	// operation be started (typically a subscription). Event handlers
	// are expected to take the necessary steps to register the operation
	// and send data back to the client with the results eventually.
	StartOperation func(Connection, string, *StartMessagePayload) []error

	// StopOperation is called whenever the client stops a previously
	// started GraphQL operation (typically a subscription). Event handlers
	// are expected to unregister the operation and stop sending result
	// data to the client.
	StopOperation func(Connection, string)
}

type DataMessagePayload struct {
	Data   any     `json:"data"`
	Errors []error `json:"errors"`
}

type HandlerConfig struct {
	Logger       Logger
	Authenticate AuthenticateFunc
	Schema       graphql.Schema
	RootValue    map[string]any
}

type InitMessagePayload struct {
	AuthToken     string `json:"authToken"`
	Authorization string `json:"Authorization"`
}

type Logger interface {
	Infof(format string, data ...any)
	Debugf(format string, data ...any)
	Errorf(format string, data ...any)
	Warnf(format string, data ...any)
}

type OperationMessage struct {
	ID      string `json:"id"`
	Type    string `json:"type"`
	Payload any    `json:"payload"`
}

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

type StartMessagePayload struct {
	Query         string         `json:"query"`
	Variables     map[string]any `json:"variables"`
	OperationName string         `json:"operationName"`
}