Revert "Add zstd encoding support (#533)" (#543)

This reverts commit 692dda6.

package.json

@@ -28,7 +28,6 @@
   },
   "homepage": "https://www.statsig.com",
   "dependencies": {
-    "@mongodb-js/zstd": "^2.0.0",
     "ip3country": "^5.0.0",
     "node-fetch": "^2.6.13",
     "ua-parser-js": "^1.0.2",
@@ -53,11 +52,11 @@
     "eslint-config-prettier": "^9.1.0",
     "eslint-plugin-prettier": "^5.1.2",
     "eslint-plugin-simple-import-sort": "^10.0.0",
+    "sha.js": "^2.4.11",
     "jest": "^29.7.0",
     "jest-environment-jsdom": "^29.7.0",
     "jsdoc-to-markdown": "^7.1.1",
     "prettier": "^3.1.1",
-    "sha.js": "^2.4.11",
     "typescript": "^4.7.4"
   },
   "importSort": {

src/LogEventProcessor.ts

@@ -4,15 +4,10 @@ import ErrorBoundary from './ErrorBoundary';
 import { EvaluationDetails } from './EvaluationDetails';
 import LogEvent, { LogEventData, SecondaryExposure } from './LogEvent';
 import OutputLogger from './OutputLogger';
-import SDKConfigs from './SDKConfigs';
 import SDKFlags from './SDKFlags';
 import { ExplicitStatsigOptions, StatsigOptions } from './StatsigOptions';
 import { StatsigUser } from './StatsigUser';
 import { getStatsigMetadata, poll } from './utils/core';
-import {
-  CompressionType,
-  isValidCompressionType,
-} from './utils/getEncodedBody';
 import { GlobalContext, StatsigContext } from './utils/StatsigContext';
 import StatsigFetcher from './utils/StatsigFetcher';
 
@@ -120,7 +115,9 @@ export default class LogEventProcessor {
         retries: fireAndForget ? 0 : this.explicitOptions.postLogsRetryLimit,
         backoff: this.explicitOptions.postLogsRetryBackoff,
         signal: abortSignal,
-        compression: this.getLogEventCompression(),
+        compress:
+          !GlobalContext.isEdgeEnvironment &&
+          SDKFlags.on('stop_log_event_compression') === false,
         additionalHeaders: {
           'STATSIG-EVENT-COUNT': String(oldQueue.length),
         },
@@ -509,22 +506,4 @@ export default class LogEventProcessor {
     }
     Diagnostics.instance.clearMarker(context);
   }
-
-  private getLogEventCompression(): CompressionType {
-    if (
-      GlobalContext.isEdgeEnvironment ||
-      SDKFlags.on('stop_log_event_compression') === true
-    ) {
-      return 'none';
-    }
-
-    // Validation of dynamic config value
-    const config = SDKConfigs.get('event_content_encoding');
-    if (isValidCompressionType(config)) {
-      return config;
-    }
-
-    // Default value
-    return 'gzip';
-  }
 }

src/SpecStore.ts

@@ -18,7 +18,6 @@ import {
   IDataAdapter,
 } from './interfaces/IDataAdapter';
 import OutputLogger from './OutputLogger';
-import SDKConfigs from './SDKConfigs';
 import SDKFlags from './SDKFlags';
 import {
   ExplicitStatsigOptions,
@@ -571,7 +570,6 @@ export default class SpecStore {
     }
 
     SDKFlags.setFlags(specsJSON?.sdk_flags);
-    SDKConfigs.setConfigs(specsJSON?.sdk_configs);
 
     const updatedExpToLayer: Record<string, string> =
       this._reverseLayerExperimentMapping(layerToExperimentMap);

src/utils/StatsigFetcher.ts

@@ -12,7 +12,7 @@ import {
 } from '../StatsigOptions';
 import { getSDKType, getSDKVersion } from './core';
 import Dispatcher from './Dispatcher';
-import { CompressionType, getEncodedBody } from './getEncodedBody';
+import { getEncodedBody } from './getEncodedBody';
 import { djb2Hash } from './Hashing';
 import safeFetch from './safeFetch';
 import { StatsigContext } from './StatsigContext';
@@ -27,7 +27,7 @@ type RequestOptions = Partial<{
   backoff: number | RetryBackoffFunc;
   isRetrying: boolean;
   signal: AbortSignal;
-  compression?: CompressionType;
+  compress?: boolean;
   additionalHeaders?: Record<string, string>;
 }>;
 
@@ -133,7 +133,7 @@ export default class StatsigFetcher {
       backoff = 1000,
       isRetrying = false,
       signal,
-      compression = 'none',
+      compress = false,
     } = options ?? {};
     const markDiagnostic = this.getDiagnosticFromURL(url);
     if (this.localMode) {
@@ -172,7 +172,7 @@ export default class StatsigFetcher {
 
     const { contents, contentEncoding } = await getEncodedBody(
       body,
-      compression,
+      compress ? 'gzip' : 'none',
       this.errorBoundry,
     );
 

src/utils/getEncodedBody.ts

@@ -1,17 +1,7 @@
 import ErrorBoundary from '../ErrorBoundary';
 import { StatsigContext } from './StatsigContext';
 
-export function isValidCompressionType(
-  input: unknown,
-): input is CompressionType {
-  return (
-    typeof input === 'string' &&
-    (VALID_COMPRESSION_TYPES as ReadonlyArray<string>).includes(input)
-  );
-}
-
-const VALID_COMPRESSION_TYPES = ['gzip', 'zstd', 'none'] as const;
-export type CompressionType = (typeof VALID_COMPRESSION_TYPES)[number];
+export type CompressionType = 'gzip' | 'none';
 
 export async function getEncodedBody(
   body: Record<string, unknown> | undefined,
@@ -34,12 +24,6 @@ export async function getEncodedBody(
       });
       return { contents: compressed, contentEncoding: 'gzip' };
     }
-
-    if (compression === 'zstd') {
-      const { compress } = await import('@mongodb-js/zstd');
-      const compressed = await compress(Buffer.from(bodyString, 'utf8'));
-      return { contents: compressed, contentEncoding: 'zstd' };
-    }
   } catch (e) {
     errorBoundry.logError(
       e,