Files
directus/docs/guides/extensions/creating-a-custom-api-hook.md
Ben Haynes e7489abfa6 Hooks docs
2020-09-24 11:21:12 -04:00

5.0 KiB

Creating a Custom API Hook

Hooks allow running custom logic when specificed events occur within your project.

1. Create a Hook File

Custom hooks are dynamically loaded from within your extensions folder. By default this directory is located at /extensions, but it can be configured within your project's env file to be located anywhere. Hooks can be added standalone or via an extension bundle.

Default Standalone Hook Location

/extensions/hooks/<hook-id>.js

Default Bundled Hook Location

/extensions/bundles/<bundle-id>/hooks/<hook-id>.js

2. Define the Event

Next, you will want to define your event. You can trigger your custom hook with any of the platform's many API events. Each event is referenced with the following format:

<scope>.<action>(.<before>)
// eg: items.create
// eg: files.update.before

Scope

The scope determines the API endpoint that is triggered. The * wildcard can also be used to include all scopes.

:::tip System Scope Currently all system tables are available as event scopes except for directus_migrations and directus_sessions, which don't have relevant endpoints or services. :::

Action

Defines the triggering operation within the specified context (see chart below). The * wildcard can also be used to include all actions available to the scope.

Before

Many scopes (see chart below) support an optional .before suffix for running a blocking hook prior to the event being fired. This allows you to check and/or modify the event's payload before it is processed.

  • items.create.<collection> (Non Blocking)
  • items.create.<collection>.before (Blocking)

Event Scope Options

Scope Actions Before
items create, update and delete Optional
activity create, update and delete Optional
collections create, update and delete Optional
fields create, update and delete Optional
files create, update and delete Optional
folders create, update and delete Optional
permissions create, update and delete Optional
presets create, update and delete Optional
relations create, update and delete Optional
revisions create, update and delete Optional
roles create, update and delete Optional
settings create, update and delete Optional
users create, update and delete Optional
webhooks create, update and delete Optional
server start and error No
auth success, fail and refresh No
request get, patch post and delete No

3. Register your Hook

Each custom hook is registered to its event scope using a function with the following format:

module.exports = function registerHook() {
	return {
		'item.create.articles': function() {
			axios.post('http://example.com/webhook');
		}
	}
}

Register Function

The register function (eg: module.exports = function registerHook()) must return an object where the key is the event, and the value is the handler function itself.

The registerHook function receives a context parameter with the following properties:

  • services — All API interal services Learn More
  • exceptions — API exception objects that can be used for throwing "proper" errors Learn More
  • database — Knex instance that is connected to the current database Learn More
  • env — Parsed environment variables Learn More

Event Handler Function

The event handler function (eg: 'item.create.articles': function()) recieves a context parameter with the following properties:

  • event — Full event string Learn More
  • accountability — Information about the current user Learn More
  • collection — Collection that is being modified Learn More
  • item — Primary key(s) of the item(s) being modified Learn More
  • action — Action that is performed Learn More
  • payload — Payload of the request Learn More

Full example:

// extensions/hooks/sync-with-external/index.js

module.exports = function registerHook({ services, exceptions }) {
	const { ServiceUnavailableException, ForbiddenException } = exceptions;

	return {
		// Force everything to be admin-only at all times
		'item.*.*': async function({ item, accountability }) {
			if (accountability.admin !== true) throw new ForbiddenException();
		},
		// Sync with external recipes service, cancel creation on failure
		'item.recipes.create.before': async function(input) {
			try {
				await axios.post('https://example.com/recipes', input);
			} catch (error) {
				throw new ServiceUnavailableException(error);
			}

			input[0].syncedWithExample = true;

			return input;
		}
	}
}