Class SynchronizationManagerRedis

api/src/synchronization.ts:100–148

`;

class SynchronizationManagerRedis implements SynchronizationManager {
	private namespace: string;
	private client: Redis;

	constructor() {
		const env = useEnv();
		const config = getConfigFromEnv('REDIS');

		this.client = new Redis(env['REDIS'] ?? config);
		this.namespace = (env['SYNCHRONIZATION_NAMESPACE'] as string) ?? 'directus-sync';

		this.client.defineCommand('setGreaterThan', {
			numberOfKeys: 1,
			lua: SET_GREATER_THAN_SCRIPT,
		});
	}

	public async set(key: string, value: string | number): Promise<void> {
		await this.client.set(this.getNamespacedKey(key), value);
	}

	public get(key: string): Promise<string | null> {
		return this.client.get(this.getNamespacedKey(key));
	}

	public async delete(key: string): Promise<void> {
		await this.client.del(this.getNamespacedKey(key));
	}

	public async exists(key: string): Promise<boolean> {
		const doesExist = await this.client.exists(this.getNamespacedKey(key));

		return doesExist === 1;
	}

	public async setGreaterThan(key: string, value: number): Promise<boolean> {
		const client = this.client as Redis & {
			setGreaterThan(key: string, value: number): Promise<number>;
		};

		const wasSet = await client.setGreaterThan(this.getNamespacedKey(key), value);

		return wasSet === 1;
	}

	private getNamespacedKey(key: string): string {
		return `${this.namespace}:${key}`;
	}
}

export class SynchronizedClock {
	private key: string;