apihandler

Documentation

Index

• Constants
• func CreateHooksJWT(secret []byte) (string, error)
• func GenSymmetricKey(bits int) (k []byte, err error)
• func MergeJsonRightIntoLeft(left, right []byte) []byte
• func NewApiTransport(tripper http.RoundTripper, api *Api, hooksClient *hooks.Client, ...) http.RoundTripper
• func NewApiTransportFactory(api *Api, hooksClient *hooks.Client, enableDebugMode bool) func(tripper http.RoundTripper) http.RoundTripper
• func NewRequestFromWunderGraphClientRequest(ctx context.Context, body []byte) (*http.Request, error)
• type Api
  • func (api *Api) HasCookieAuthEnabled() bool
• type ApiTransport
  • func (t *ApiTransport) RoundTrip(request *http.Request) (*http.Response, error)
• type Builder
  • func NewBuilder(pool *pool.Pool, log abstractlogger.Logger, ...) *Builder
  • func (r *Builder) BuildAndMountApiHandler(ctx context.Context, router *mux.Router, api *Api) (streamClosers []chan struct{}, err error)
• type BuilderConfig
• type Claims
• type EndpointUnavailableHandler
  • func (m *EndpointUnavailableHandler) ServeHTTP(w http.ResponseWriter, _ *http.Request)
• type GraphQLHandler
  • func (h *GraphQLHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type GraphQLPlaygroundHandler
  • func (h *GraphQLPlaygroundHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type InternalApiHandler
  • func (h *InternalApiHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type InternalBuilder
  • func NewInternalBuilder(pool *pool.Pool, log abstractlogger.Logger, ...) *InternalBuilder
  • func (i *InternalBuilder) BuildAndMountInternalApiHandler(ctx context.Context, router *mux.Router, api *Api) (streamClosers []chan struct{}, err error)
• type Listener
• type Logging
• type MutationHandler
  • func (h *MutationHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type OpenIDConnectConfiguration
• type OperationMetaData
  • func (o *OperationMetaData) GetOperationTypeString() string
• type Options
• type QueryHandler
  • func (h *QueryHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type QueryResolver
• type SubscriptionHandler
  • func (h *SubscriptionHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

Constants

const (
	WG_PREFIX    = "wg_"
	WG_LIVE      = WG_PREFIX + "live"
	WG_VARIABLES = WG_PREFIX + "variables"
)

Functions

func CreateHooksJWT

func CreateHooksJWT(secret []byte) (string, error)

func GenSymmetricKey

func GenSymmetricKey(bits int) (k []byte, err error)

func MergeJsonRightIntoLeft

func MergeJsonRightIntoLeft(left, right []byte) []byte

MergeJsonRightIntoLeft merges the right JSON into the left JSON while overriding the left side

func NewApiTransport

func NewApiTransport(tripper http.RoundTripper, api *Api, hooksClient *hooks.Client, enableDebugMode bool) http.RoundTripper

func NewApiTransportFactory

func NewApiTransportFactory(api *Api, hooksClient *hooks.Client, enableDebugMode bool) func(tripper http.RoundTripper) http.RoundTripper

func NewRequestFromWunderGraphClientRequest

func NewRequestFromWunderGraphClientRequest(ctx context.Context, body []byte) (*http.Request, error)

Types

type Api

type Api struct {
	PrimaryHost           string
	Hosts                 []string
	PathPrefix            string
	EngineConfiguration   *wgpb.EngineConfiguration
	EnableSingleFlight    bool
	EnableGraphqlEndpoint bool
	Operations            []*wgpb.Operation
	CorsConfiguration     *wgpb.CorsConfiguration
	DeploymentId          string
	CacheConfig           *wgpb.ApiCacheConfig // TODO: extract from proto
	ApiConfigHash         string
	AuthenticationConfig  *wgpb.ApiAuthenticationConfig
	S3UploadConfiguration []*wgpb.S3UploadConfiguration
	Webhooks              []*wgpb.WebhookConfiguration
	Options               *Options
}

func (*Api) HasCookieAuthEnabled

func (api *Api) HasCookieAuthEnabled() bool

type ApiTransport

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

func (*ApiTransport) RoundTrip

func (t *ApiTransport) RoundTrip(request *http.Request) (*http.Response, error)

type Builder

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

func NewBuilder

func NewBuilder(pool *pool.Pool,
	log abstractlogger.Logger,
	loader *engineconfigloader.EngineConfigLoader,
	hooksClient *hooks.Client,
	config BuilderConfig,
) *Builder

func (*Builder) BuildAndMountApiHandler

func (r *Builder) BuildAndMountApiHandler(ctx context.Context, router *mux.Router, api *Api) (streamClosers []chan struct{}, err error)

type BuilderConfig

type BuilderConfig struct {
	InsecureCookies            bool
	ForceHttpsRedirects        bool
	EnableDebugMode            bool
	EnableIntrospection        bool
	GitHubAuthDemoClientID     string
	GitHubAuthDemoClientSecret string
	HookServerURL              string
	DevMode                    bool
}

type Claims

type Claims struct {
	Name string `json:"name"`
	jwt.StandardClaims
}

type EndpointUnavailableHandler

type EndpointUnavailableHandler struct {
	OperationName string
}

func (*EndpointUnavailableHandler) ServeHTTP

func (m *EndpointUnavailableHandler) ServeHTTP(w http.ResponseWriter, _ *http.Request)

type GraphQLHandler

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

func (*GraphQLHandler) ServeHTTP

func (h *GraphQLHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type GraphQLPlaygroundHandler

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

func (*GraphQLPlaygroundHandler) ServeHTTP

func (h *GraphQLPlaygroundHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type InternalApiHandler

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

func (*InternalApiHandler) ServeHTTP

func (h *InternalApiHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type InternalBuilder

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

func NewInternalBuilder

func NewInternalBuilder(pool *pool.Pool, log abstractlogger.Logger, loader *engineconfigloader.EngineConfigLoader) *InternalBuilder

func (*InternalBuilder) BuildAndMountInternalApiHandler

func (i *InternalBuilder) BuildAndMountInternalApiHandler(ctx context.Context, router *mux.Router, api *Api) (streamClosers []chan struct{}, err error)

type Listener

type Listener struct {
	Host string
	Port uint16
}

type Logging

type Logging struct {
	Level wgpb.LogLevel
}

type MutationHandler

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

func (*MutationHandler) ServeHTTP

func (h *MutationHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type OpenIDConnectConfiguration

type OpenIDConnectConfiguration struct {
	Issuer                string `json:"issuer"`
	AuthorizationEndpoint string `json:"authorization_endpoint"`
	TokenEndpoint         string `json:"token_endpoint"`
	UserinfoEndpoint      string `json:"userinfo_endpoint"`
	JwksUri               string `json:"jwks_uri"`
	EndSessionEndpoint    string `json:"end_session_endpoint"`
}

type OperationMetaData

type OperationMetaData struct {
	OperationName string
	OperationType wgpb.OperationType
}

func (*OperationMetaData) GetOperationTypeString

func (o *OperationMetaData) GetOperationTypeString() string

type Options

type Options struct {
	ServerUrl string
	Listener  *Listener
	Logging   Logging
}

type QueryHandler

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

func (*QueryHandler) ServeHTTP

func (h *QueryHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type QueryResolver

type QueryResolver interface {
	ResolveGraphQLResponse(ctx *resolve.Context, response *resolve.GraphQLResponse, data []byte, writer io.Writer) (err error)
}

type SubscriptionHandler

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

func (*SubscriptionHandler) ServeHTTP

func (h *SubscriptionHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)