hooks

Documentation

Index

• func HeaderCSVToSlice(headers map[string]string) map[string][]string
• func HeaderSliceToCSV(headers map[string][]string) map[string]string
• func HttpRequestToWunderGraphRequestJSON(r *http.Request, withBody bool) ([]byte, error)
• type Client
  • func NewClient(serverUrl string, logger *zap.Logger) *Client
  • func (c *Client) DoAuthenticationRequest(ctx context.Context, hook MiddlewareHook, jsonData []byte) (*MiddlewareHookResponse, error)
  • func (c *Client) DoFunctionRequest(ctx context.Context, operationName string, jsonData []byte) (*MiddlewareHookResponse, error)
  • func (c *Client) DoFunctionSubscriptionRequest(ctx context.Context, operationName string, jsonData []byte, ...) error
  • func (c *Client) DoGlobalRequest(ctx context.Context, hook MiddlewareHook, jsonData []byte) (*MiddlewareHookResponse, error)
  • func (c *Client) DoHealthCheckRequest(ctx context.Context) (status bool)
  • func (c *Client) DoOperationRequest(ctx context.Context, operationName string, hook MiddlewareHook, ...) (*MiddlewareHookResponse, error)
  • func (c *Client) DoUploadRequest(ctx context.Context, providerName string, profileName string, hook UploadHook, ...) (*UploadHookResponse, error)
  • func (c *Client) DoWsTransportRequest(ctx context.Context, hook MiddlewareHook, jsonData []byte) (*MiddlewareHookResponse, error)
• type HookResponse
• type MiddlewareHook
• type MiddlewareHookResponse
  • func (r *MiddlewareHookResponse) ResponseError() string
• type OnRequestHookPayload
• type OnRequestHookResponse
• type OnResponseHookPayload
• type OnResponseHookResponse
• type OnWsConnectionInitHookPayload
• type UploadHook
• type UploadHookResponse
  • func (r *UploadHookResponse) ResponseError() string
• type WunderGraphRequest
• type WunderGraphResponse

Functions

func HeaderCSVToSlice

func HeaderCSVToSlice(headers map[string]string) map[string][]string

func HeaderSliceToCSV

func HeaderSliceToCSV(headers map[string][]string) map[string]string

func HttpRequestToWunderGraphRequestJSON

func HttpRequestToWunderGraphRequestJSON(r *http.Request, withBody bool) ([]byte, error)

Types

type Client

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

func NewClient

func NewClient(serverUrl string, logger *zap.Logger) *Client

func (*Client) DoAuthenticationRequest

func (c *Client) DoAuthenticationRequest(ctx context.Context, hook MiddlewareHook, jsonData []byte) (*MiddlewareHookResponse, error)

func (*Client) DoFunctionRequest

func (c *Client) DoFunctionRequest(ctx context.Context, operationName string, jsonData []byte) (*MiddlewareHookResponse, error)

func (*Client) DoFunctionSubscriptionRequest

func (c *Client) DoFunctionSubscriptionRequest(ctx context.Context, operationName string, jsonData []byte, subscribeOnce, sse bool, out io.Writer) error

func (*Client) DoGlobalRequest

func (c *Client) DoGlobalRequest(ctx context.Context, hook MiddlewareHook, jsonData []byte) (*MiddlewareHookResponse, error)

func (*Client) DoHealthCheckRequest

func (c *Client) DoHealthCheckRequest(ctx context.Context) (status bool)

func (*Client) DoOperationRequest

func (c *Client) DoOperationRequest(ctx context.Context, operationName string, hook MiddlewareHook, jsonData []byte) (*MiddlewareHookResponse, error)

func (*Client) DoUploadRequest

func (c *Client) DoUploadRequest(ctx context.Context, providerName string, profileName string, hook UploadHook, jsonData []byte) (*UploadHookResponse, error)

func (*Client) DoWsTransportRequest

func (c *Client) DoWsTransportRequest(ctx context.Context, hook MiddlewareHook, jsonData []byte) (*MiddlewareHookResponse, error)

type HookResponse

type HookResponse interface {
	ResponseError() string
}

type MiddlewareHook

type MiddlewareHook string

const (
	MockResolve                MiddlewareHook = "mockResolve"
	PreResolve                 MiddlewareHook = "preResolve"
	PostResolve                MiddlewareHook = "postResolve"
	CustomResolve              MiddlewareHook = "customResolve"
	MutatingPreResolve         MiddlewareHook = "mutatingPreResolve"
	MutatingPostResolve        MiddlewareHook = "mutatingPostResolve"
	PostAuthentication         MiddlewareHook = "postAuthentication"
	PostLogout                 MiddlewareHook = "postLogout"
	MutatingPostAuthentication MiddlewareHook = "mutatingPostAuthentication"
	RevalidateAuthentication   MiddlewareHook = "revalidateAuthentication"

	// HttpTransportOnRequest to the origin
	HttpTransportOnRequest MiddlewareHook = "onOriginRequest"
	// HttpTransportOnResponse from the origin
	HttpTransportOnResponse MiddlewareHook = "onOriginResponse"

	WsTransportOnConnectionInit MiddlewareHook = "onConnectionInit"
)

type MiddlewareHookResponse

type MiddlewareHookResponse struct {
	Error                   string            `json:"error,omitempty"`
	Op                      string            `json:"op"`
	Hook                    string            `json:"hook"`
	Response                json.RawMessage   `json:"response"`
	Input                   json.RawMessage   `json:"input"`
	SetClientRequestHeaders map[string]string `json:"setClientRequestHeaders"`
	// ClientResponseStatusCode is the status code that should be returned to the client
	ClientResponseStatusCode int
}

func (*MiddlewareHookResponse) ResponseError

func (r *MiddlewareHookResponse) ResponseError() string

type OnRequestHookPayload

type OnRequestHookPayload struct {
	Request       WunderGraphRequest `json:"request"`
	OperationName string             `json:"operationName"`
	OperationType string             `json:"operationType"`
}

type OnRequestHookResponse

type OnRequestHookResponse struct {
	Skip    bool                `json:"skip"`
	Cancel  bool                `json:"cancel"`
	Request *WunderGraphRequest `json:"request"`
}

type OnResponseHookPayload

type OnResponseHookPayload struct {
	Response      WunderGraphResponse `json:"response"`
	OperationName string              `json:"operationName"`
	OperationType string              `json:"operationType"`
}

type OnResponseHookResponse

type OnResponseHookResponse struct {
	Skip     bool                 `json:"skip"`
	Cancel   bool                 `json:"cancel"`
	Response *WunderGraphResponse `json:"response"`
}

type OnWsConnectionInitHookPayload

type OnWsConnectionInitHookPayload struct {
	DataSourceID string             `json:"dataSourceId"`
	Request      WunderGraphRequest `json:"request"`
}

type UploadHook

type UploadHook string

const (
	PreUpload  UploadHook = "preUpload"
	PostUpload UploadHook = "postUpload"
)

type UploadHookResponse

type UploadHookResponse struct {
	Error   string `json:"error"`
	FileKey string `json:"fileKey"`
}

func (*UploadHookResponse) ResponseError

func (r *UploadHookResponse) ResponseError() string

type WunderGraphRequest

type WunderGraphRequest struct {
	Method     string            `json:"method"`
	RequestURI string            `json:"requestURI"`
	Headers    map[string]string `json:"headers"`
	Body       json.RawMessage   `json:"body,omitempty"`
}

type WunderGraphResponse

type WunderGraphResponse struct {
	StatusCode int               `json:"statusCode"`
	Status     string            `json:"status"`
	Method     string            `json:"method"`
	RequestURI string            `json:"requestURI"`
	Headers    map[string]string `json:"headers"`
	Body       json.RawMessage   `json:"body,omitempty"`
}