Hooks are registered with the fastify.graphql.addHook
method and allow you to listen to specific events in the GraphQL request/response lifecycle. You have to register a hook before the event is triggered, otherwise the event is lost.
By using hooks you can interact directly with the GraphQL lifecycle of Mercurius. There are GraphQL Request and Subscription hooks:
Notice: these hooks are only supported with async
/await
or returning a Promise
.
It is pretty easy to understand where each hook is executed by looking at the lifecycle page.
There are five different hooks that you can use in a GraphQL Request (in order of execution):
When registering hooks, you must wait for Mercurius to be registered in Fastify.
await fastify.ready()
If you are using the preParsing
hook, you can access the GraphQL query string before it is parsed. It receives the schema and context objects as other hooks.
For instance, you can register some tracing events:
fastify.graphql.addHook('preParsing', async (schema, source, context) => {
await registerTraceEvent()
})
By the time the preValidation
hook triggers, the query string has been parsed into a GraphQL Document AST. The hook will not be triggered for cached queries, as they are not validated.
fastify.graphql.addHook('preValidation', async (schema, document, context) => {
await asyncMethod()
})
In the preExecution
hook, you can modify the following items by returning them in the hook definition:
document
schema
variables
errors
Note that if you modify the schema
or the document
object, the jit compilation will be disabled for the request.
fastify.graphql.addHook('preExecution', async (schema, document, context, variables) => {
const {
modifiedSchema,
modifiedDocument,
modifiedVariables,
errors
} = await asyncMethod(document)
return {
schema: modifiedSchema, // ⚠️ changing the schema may break the query execution. Use it carefully.
document: modifiedDocument,
variables: modifiedVariables,
errors
}
})
The onResolution
hooks run after the GraphQL query execution and you can access the result via the execution
argument.
fastify.graphql.addHook('onResolution', async (execution, context) => {
await asyncMethod()
})
If you get an error during the execution of your hook, you can just throw an error and Mercurius will automatically close the GraphQL request and send the appropriate errors to the user.`
fastify.graphql.addHook('preParsing', async (schema, source, context) => {
throw new Error('Some error')
})
The following hooks support adding errors to the GraphQL response. These are:
preExecution
fastify.graphql.addHook('preExecution', async (schema, document, context) => {
return {
errors: [new Error('foo')]
}
})
Note, the original query will still execute. Adding the above will result in the following response:
{
"data": {
"foo": "bar"
},
"errors": [
{
"message": "foo"
},
{
"message": "bar"
}
]
}
It is pretty easy to understand where each hook is executed by looking at the lifecycle page.
There are five different hooks that you can use in GraphQL Subscriptions (in order of execution):
When registering hooks, you must make sure that subscriptions are enabled and you must wait for Mercurius to be registered in Fastify.
await fastify.ready()
If you are using the preSubscriptionParsing
hook, you can access the GraphQL subscription query string before it is parsed. It receives the schema and context objects as other hooks.
For instance, you can register some tracing events:
fastify.graphql.addHook('preSubscriptionParsing', async (schema, source, context) => {
await registerTraceEvent()
})
By the time the preSubscriptionExecution
hook triggers, the subscription query string has been parsed into a GraphQL Document AST.
fastify.graphql.addHook('preSubscriptionExecution', async (schema, document, context) => {
await asyncMethod()
})
fastify.graphql.addHook('onSubscriptionResolution', async (execution, context) => {
await asyncMethod()
})
This hook will be triggered when a subscription ends.
fastify.graphql.addHook('onSubscriptionEnd', async (context, id) => {
await asyncMethod()
})
If you get an error during the execution of your subscription hook, you can just throw an error and Mercurius will send the appropriate errors to the user along the websocket.`
Notice: there are exceptions to this with the onSubscriptionResolution
and onSubscriptionEnd
hooks, which will close the subscription connection if an error occurs.
fastify.graphql.addHook('preSubscriptionParsing', async (schema, source, context) => {
throw new Error('Some error')
})
When registering hooks, you must wait for Mercurius to be registered in Fastify.
await fastify.ready()
This hook will be triggered when extendSchema
is called. It receives the new schema and context object.
app.graphql.addHook('onExtendSchema', async (schema, context) => {
await asyncMethod()
})