directus

1
import { compress as compressSnappy, uncompress as uncompressSnappy } from 'snappy';
2
import { compress as compressJSON, decompress as decompressJSON } from '@directus/utils';
3

4
export async function compress(raw: Record<string, any> | Record<string, any>[]): Promise<Buffer> {
5
	if (!raw) return raw;
6
	return await compressSnappy(compressJSON(raw));
7
}
8

9
export async function decompress(compressed: Buffer): Promise<any> {
10
	if (!compressed) return compressed;
11
	return decompressJSON((await uncompressSnappy(compressed, { asBuffer: false })) as string);
12
}
13