Skip to content

Commit

Permalink
Add documentation for Graphile Config middleware (#2239)
Browse files Browse the repository at this point in the history
  • Loading branch information
benjie authored Nov 19, 2024
2 parents caac82b + 4cac754 commit db05daa
Showing 1 changed file with 263 additions and 0 deletions.
263 changes: 263 additions & 0 deletions utils/website/graphile-config/middleware.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,263 @@
---
sidebar_position: 3
title: "Middleware"
---

# Middleware

## For plugin authors

You should probably see the documentation for the relevant project that you
want to add a middleware for.

Generally middleware works by registering a handler function for a given action
in a plugin, scoped within an entry named after the library (e.g.
`plugin.libraryName.middleware.someAction`).

Your handler function will be passed a `next` callback that calls the next
handler, or performs the underlying action if there is no next handler, and any
additional arguments. Normally there is exactly one additional argument,
`event`, which describes the event that is being wrapped in middleware.

Your function should:

1. Take any actions that it needs to take before the underlying code is called
(including mutating `event` if necessary)
2. Then, either:
1. `return next()` (and you're done); or:
2. Call, await, and store the result of `next()`, then return a derivative
thereof (after taking any necessary cleanup actions); or:
3. Use `return next.callback(cb)` where `cb` is a callback you define in
traditional (non-promises!) Node.js style which receives the error (if
any) as the first parameter, and the result (if no error) as the second, and
must return the value to resolve as (or throw an error)

:::warning Some middleware are synchronous!

Some libraries enable middleware around synchronous methods, and expect the
result of the middleware to be synchronous too. Internally, these libraries run
this middleware with `middleware.runSync()` rather than `middleware.run()`;
returning a promise from your middleware will throw an error in these cases.

You should be able to tell a synchronous middleware from its TypeScript types:
if the middleware's return type does not incorporate Promise or PromiseLike
then it probably does not support promises.

Unless you are certain a given middleware supports promises, you should not use
`async`/`await` and should instead use `next.callback(...)` if you need to
perform an action once the action is complete.

:::

Here's a simple example that just multiplies one of the parameters by two, and
logs that this action has been called:

```ts
export const MySomeActionDoubleParameterPlugin: GraphileConfig.Plugin = {
name: "MySomeActionDoubleParameterPlugin",
libraryName: {
middleware: {
someAction(next, event) {
console.log(`someAction(someParameter=${event.someParameter}) called`);
event.someParameter = event.someParameter * 2;
return next();
},
},
},
};
```

Here's an example that retries on error (but always forces promises):

:::danger `next()` should be called exactly once unless otherwise stated

In general libraries may assume that `next()` will be called once, so it might
not be safe to retry `next()`. Libraries that support `next()` being called
more than once should note this in the documentation for the relevant action.

:::

```ts
export const MySomeActionRetryPlugin: GraphileConfig.Plugin = {
name: "MySomeActionRetryPlugin",
libraryName: {
middleware: {
async someAction(next, event) {
let error!: Error;
for (let attempts = 0; attempts < 3; attempts++) {
if (attempts > 0) {
// Wait a few milliseconds before trying again
await sleep(attempts * 5);
}
try {
return await next();
} catch (e) {
error = e;
}
}
throw error;
},
},
},
};
```

Here's an example that does not introduce a promise unless one was already
present (complex, right? Don't do this - see next example instead):

```ts
export const MySomeActionLogPlugin: GraphileConfig.Plugin = {
name: "MySomeActionLogPlugin",
libraryName: {
middleware: {
someAction(next, event) {
console.log(`someAction(someParameter=${event.someParameter}) called`);
// Optionally mutate event
event.someParameter = event.someParameter * 2;

const onSuccess = (result) => {
console.log(`someAction() returned ${result}`);
// Return `result` or a derivative thereof
return result / 2;
};

const onError = (error) => {
console.error(`someAction() threw ${error}`);
// Handle the error somehow... Or just rethrow it.
throw error;
};

const promiseOrValue = next();
try {
if (isPromiseLike(promiseOrValue)) {
return promiseOrValue.then(onSuccess, onError);
} else {
// Optionally perform any additional actions here
return onSuccess(promiseOrValue);
}
} catch (e) {
return onError(e);
}
},
},
},
};
```

Here's the above example again, but using `next.callback()` to handle the
promises (if any) for us; this is the generally recommended approach:

```ts
export const MySomeActionLogPlugin: GraphileConfig.Plugin = {
name: "MySomeActionLogPlugin",
libraryName: {
middleware: {
someAction(next, event) {
console.log(`someAction(someParameter=${event.someParameter}) called`);
// Optionally mutate event
event.someParameter = event.someParameter * 2;

return next.callback((error, result) => {
if (error) {
console.error(`someAction() threw ${error}`);
// Handle the error somehow... Or just rethrow it.
throw error;
} else {
console.log(`someAction() returned ${result}`);
// Return `result` or a derivative thereof
return result / 2;
}
});
},
},
},
};
```

## For a library author

(This section was primarily written by Benjie for Benjie... so you may want to
skip it.)

If you need to create a middleware system for your library, you might follow
something along these lines (replacing `libraryName` with the name of your
library):

```ts
/***** interfaces.ts *****/

// Define the middlewares that you support, their event type and their return type
export interface MyMiddleware {
someAction(event: SomeActionEvent): PromiseOrDirect<SomeActionResult>;
}
interface SomeActionEvent {
someParameter: number;
/*
* Use a per-middleware-method interface to define the various pieces of
* data relevant to this event. **ALWAYS** use the event as an abstraction
* so that new information can be added in future without causing any
* knock-on consequences. Note that these parameters of the event may be
* mutated. The values here can be anything, they don't need to be simple
* values.
*/
}
// Middleware wraps a function call; this represents whatever the function returns
type SomeActionResult = number;

export type PromiseOrDirect<T> = Promise<T> | T;

/***** getMiddleware.ts *****/

import { Middleware, orderedApply, resolvePresets } from "graphile-config";

export function getMiddleware(resolvedPreset: GraphileConfig.ResolvedPreset) {
// Create your middleware instance. The generic describes the events supported
const middleware = new Middleware<MyMiddleware>();
// Now apply the relevant middlewares registered by each plugin (if any) to the
// Middleware instance
orderedApply(
resolvedPreset.plugins,
(plugin) => plugin.libraryName?.middleware,
(name, fn, _plugin) => {
middleware.register(name, fn as any);
},
);
}

/***** main.ts *****/

// Get the user's Graphile Config from somewhere, e.g.
import config from "./graphile.config.js";

// Resolve the above config, recursively applying all the presets it extends from
const resolvedPreset = resolvePresets([config]);

// Get the middleware for this preset
const middleware = getMiddleware(resolvedPreset);

// Then in the relevant place in your code, call the middleware around the
// relevant functionality
const result = await middleware.run(
"someAction",
{ someParameter: 42 }, // < `event` object
async (event) => {
// Call the underlying method to perform the action.
// Note: `event` will be the same object as above, but its contents may
// have been modified by middlewares.
return await someAction(event.someParameter);
},
);
// The value of `result` should match the return value of `someAction(...)`
// (unless a middleware tweaked or replaced it, of course!)

// This is the thing that your middleware wraps. It can do anything, it's just
// an arbitrary JavaScript function.
function someAction(someParameter: number): PromiseOrDirect<SomeActionResult> {
// Do something here...
if (Math.random() < 0.5) {
return someParameter;
} else {
return sleep(200).then(() => someParameter);
}
}
```

0 comments on commit db05daa

Please sign in to comment.