use xxh3 in query-orchestrator package

Author: KSDaemon

packages/cubejs-query-orchestrator/package.json

@@ -32,6 +32,7 @@
     "@cubejs-backend/base-driver": "1.2.27",
     "@cubejs-backend/cubestore-driver": "1.2.27",
     "@cubejs-backend/shared": "1.2.27",
+    "@node-rs/xxhash": "^1.7.6",
     "csv-write-stream": "^2.0.0",
     "generic-pool": "^3.8.2",
     "lru-cache": "^5.1.1",

packages/cubejs-query-orchestrator/src/orchestrator/PreAggregations.ts

@@ -1,5 +1,5 @@
 import R from 'ramda';
-import crypto from 'crypto';
+import { xxh3 } from '@node-rs/xxhash';
 import { getEnv, } from '@cubejs-backend/shared';
 
 import { BaseDriver, InlineTable, } from '@cubejs-backend/base-driver';
@@ -29,7 +29,7 @@ export function version(cacheKey) {
   let result = '';
 
   const hashCharset = 'abcdefghijklmnopqrstuvwxyz012345';
-  const digestBuffer = crypto.createHash('md5').update(JSON.stringify(cacheKey)).digest();
+  const digestBuffer = Buffer.from(xxh3.xxh64(JSON.stringify(cacheKey)).toString(16), 'hex');
 
   let residue = 0;
   let shiftCounter = 0;

packages/cubejs-query-orchestrator/src/orchestrator/utils.ts

@@ -1,4 +1,4 @@
-import crypto from 'crypto';
+import { xxh3 } from '@node-rs/xxhash';
 
 import { getProcessUid } from '@cubejs-backend/shared';
 import { QueryKey, QueryKeyHash } from '@cubejs-backend/base-driver';
@@ -18,16 +18,11 @@ export function getCacheHash(queryKey: QueryKey | CacheKey, processUid?: string)
     return queryKey as any;
   }
 
+  const hash = xxh3.xxh128(JSON.stringify(queryKey)).toString(16);
+
   if (typeof queryKey === 'object' && 'persistent' in queryKey && queryKey.persistent) {
-    return `${crypto
-      .createHash('md5')
-      .update(JSON.stringify(queryKey))
-      .digest('hex')
-    }@${processUid}` as any;
+    return `${hash}@${processUid}` as any;
   } else {
-    return crypto
-      .createHash('md5')
-      .update(JSON.stringify(queryKey))
-      .digest('hex') as any;
+    return hash as any;
   }
 }