directus

1
import { createBus, type Bus } from '@directus/memory';
2
import { redisConfigAvailable, useRedis } from '../../redis/index.js';
3

4
export const _cache: { bus: Bus | undefined } = {
5
	bus: undefined,
6
};
7

8
/**
9
 * Returns globally shared message bus. If Redis is available, will use a redis-driven pub/sub bus.
10
 * Otherwise will default to a local-only bus.
11
 */
12
export const useBus = () => {
13
	if (_cache.bus) {
14
		return _cache.bus;
15
	}
16

17
	if (redisConfigAvailable()) {
18
		_cache.bus = createBus({ type: 'redis', redis: useRedis(), namespace: 'directus:bus' });
19
	} else {
20
		_cache.bus = createBus({ type: 'local' });
21
	}
22

23
	return _cache.bus;
24
};
25