api-common/gropius.graphql/GropiusFunctionDataFetcher

GropiusFunctionDataFetcher

class GropiusFunctionDataFetcher(val target: Any?, val function: KFunction<*>, applicationContext: ApplicationContext) : SpringDataFetcher

FunctionDataFetcher which handles files parameter mapping for parameters of GraphQL type JSON correctly Allows input classes to have lateinit properties which are correctly deserialized. Also handles wrapping the result of a mutation when using AutoPayloadType Extends SpringDataFetcher

Parameters

target

if present, the object on which the function is invoked

function

the function the data fetcher calls

applicationContext

used to obtain Spring beans

Constructors

GropiusFunctionDataFetcher

constructor(target: Any?, function: KFunction<*>, applicationContext: ApplicationContext)

Properties

applicationContext

private val applicationContext: ApplicationContext

private val fn: KFunction<*>

private val function: KFunction<*>

private val target: Any?

private val target: Any?

Functions

open operator override fun get(environment: DataFetchingEnvironment): Any?

protected open fun getParameters(fn: KFunction<*>, environment: DataFetchingEnvironment): Map<KParameter, Any?>

handleAutoPayloadType

private fun handleAutoPayloadType(res: CompletableFuture<Any?>): CompletableFuture<Any?>

Handles the AutoPayloadType annotation if present

mapParameterToValue

protected open override fun mapParameterToValue(param: KParameter, environment: DataFetchingEnvironment): Pair<KParameter, Any?>?

runBlockingFunction

protected open fun runBlockingFunction(parameterValues: Map<KParameter, Any?>): Any?

runMutationFunction

private fun runMutationFunction(environment: DataFetchingEnvironment): CompletableFuture<Any?>

Invokes the mutation function and handles transient exceptions

runMutationFunctionWithRetries

private fun runMutationFunctionWithRetries(environment: DataFetchingEnvironment): CompletableFuture<Any?>

Invokes the mutation function and handles transient exceptions

runSuspendingFunction

protected open fun runSuspendingFunction(environment: DataFetchingEnvironment, parameterValues: Map<KParameter, Any?>): CompletableFuture<Any?>