wsgraphql

type Callbacks struct {
	// OnRequest called once HTTP request is received, before attempting to do websocket upgrade or plain request
	// execution, consequently before OnConnect as well.
	OnRequest func(reqctx mutable.Context, r *http.Request, w http.ResponseWriter) error

	// OnRequestDone called once HTTP request is finished, regardless of request type, with error occurred during
	// request execution (if any).
	// By default, if error is present, will write error text and return 400 code.
	OnRequestDone func(reqctx mutable.Context, r *http.Request, w http.ResponseWriter, origerr error)

	// OnConnect is called once per HTTP request, after websocket upgrade and init message received in case of
	// websocket request, or before execution in case of plain request
	OnConnect func(reqctx mutable.Context, init apollows.PayloadInit) error

	// OnDisconnect is called once per HTTP request, before OnRequestDone, without responsibility to handle errors
	OnDisconnect func(reqctx mutable.Context, origerr error) error

	// OnOperation is called before each operation with original payload, allowing to modify it or terminate
	// the operation by returning an error.
	OnOperation func(opctx mutable.Context, payload *apollows.PayloadOperation) error

	// OnOperationValidation is called after parsing an operation payload with any immediate validation result, if
	// available. AST will be available in context with ContextAST if parsing succeeded.
	OnOperationValidation func(opctx mutable.Context, payload *apollows.PayloadOperation, result *graphql.Result) error

	// OnOperationResult is called after operation result is received, allowing to postprocess it or terminate the
	// operation before returning the result with error. AST is available in context with ContextAST.
	OnOperationResult func(opctx mutable.Context, payload *apollows.PayloadOperation, result *graphql.Result) error

	// OnOperationDone is called once operation is finished, with error occurred during the execution (if any)
	// error returned from this handler will close the websocket / terminate HTTP request with error response.
	// By default, will pass through any error occurred. AST will be available in context with ContextAST if can be
	// parsed.
	OnOperationDone func(opctx mutable.Context, payload *apollows.PayloadOperation, origerr error) error
}

type Conn interface {
	ReadJSON(v interface{}) error
	WriteJSON(v interface{}) error
	Close(code int, message string) error
	Subprotocol() string
}

type HandlerHTTPRequest func(ctx context.Context, w http.ResponseWriter, r *http.Request) error

type HandlerInit func(ctx context.Context, init apollows.PayloadInit) error

type HandlerOperation func(ctx context.Context, payload *apollows.PayloadOperation) error

type HandlerOperationExecute func(ctx context.Context, payload *apollows.PayloadOperation) (chan *graphql.Result, error)

type HandlerOperationParse func(ctx context.Context, payload *apollows.PayloadOperation) error

type InterceptorHTTPRequest func(
	ctx context.Context,
	w http.ResponseWriter,
	r *http.Request,
	handler HandlerHTTPRequest,
) error

type InterceptorInit func(
	ctx context.Context,
	init apollows.PayloadInit,
	handler HandlerInit,
) error

type InterceptorOperation func(
	ctx context.Context,
	payload *apollows.PayloadOperation,
	handler HandlerOperation,
) error

type InterceptorOperationExecute func(
	ctx context.Context,
	payload *apollows.PayloadOperation,
	handler HandlerOperationExecute,
) (chan *graphql.Result, error)

type InterceptorOperationParse func(
	ctx context.Context,
	payload *apollows.PayloadOperation,
	handler HandlerOperationParse,
) error

type Interceptors struct {
	HTTPRequest      InterceptorHTTPRequest
	Init             InterceptorInit
	Operation        InterceptorOperation
	OperationParse   InterceptorOperationParse
	OperationExecute InterceptorOperationExecute
}

type ResultError struct {
	*graphql.Result
}

type ResultProcessor func(
	ctx context.Context,
	payload *apollows.PayloadOperation,
	result *graphql.Result,
) *graphql.Result

type Server interface {
	http.Handler
}

type ServerOption func(config *serverConfig) error

type Upgrader interface {
	Upgrade(w http.ResponseWriter, r *http.Request, responseHeader http.Header) (Conn, error)
}