add conditional decoding

Author: lowkeynicc

sdk/bun.lock

@@ -60,24 +60,15 @@
     },
   },
   "overrides": {
+    "debug": "<4.4.2",
+    "supports-color": "7.2.0",
     "ansi-regex": "5.0.1",
+    "color-convert": "<3.1.1",
     "ansi-styles": "4.3.0",
-    "backslash": "<0.2.1",
+    "wrap-ansi": "7.0.0",
     "chalk": "4.1.2",
-    "chalk-template": "<1.1.1",
-    "color-convert": "<3.1.1",
-    "color-name": "<2.0.1",
-    "color-string": "<2.1.1",
-    "debug": "<4.4.2",
-    "error-ex": "<1.3.3",
-    "has-ansi": "<6.0.1",
-    "is-arrayish": "<0.3.3",
-    "simple-swizzle": "<0.2.3",
-    "slice-ansi": "3.0.0",
     "strip-ansi": "6.0.1",
-    "supports-color": "7.2.0",
-    "supports-hyperlinks": "<4.1.1",
-    "wrap-ansi": "7.0.0",
+    "color-name": "<2.0.1",
   },
   "packages": {
     "@babel/code-frame": ["@babel/[email protected]", "", { "dependencies": { "@babel/helper-validator-identifier": "^7.25.9", "js-tokens": "^4.0.0", "picocolors": "^1.0.0" } }, "sha512-RJlIHRueQgwWitWgF8OdFYGZX328Ax5BCemNGlqHfplnRT9ESi8JkFlvaVYbS+UubVY6dpv87Fs2u5M29iNFVQ=="],

sdk/src/constituentMap/constituentMap.ts

@@ -124,12 +124,17 @@ export class ConstituentMap implements ConstituentMapInterface {
 
 	public async sync(): Promise<void> {
 		try {
+			// Check if zstddec is available (it's disabled in browser environments)
+			const canUseZstd =
+				typeof ZSTDDecoder !== 'undefined' && (ZSTDDecoder as any) !== false;
+			const encoding = canUseZstd ? 'base64+zstd' : 'base64';
+
 			const rpcRequestArgs = [
 				this.driftClient.program.programId.toBase58(),
 				{
 					commitment: this.commitment,
 					filters: this.getFilters(),
-					encoding: 'base64+zstd',
+					encoding,
 					withContext: true,
 				},
 			];
@@ -146,15 +151,32 @@ export class ConstituentMap implements ConstituentMapInterface {
 
 			const promises = rpcResponseAndContext.value.map(
 				async (programAccount) => {
-					const compressedUserData = Buffer.from(
-						programAccount.account.data[0],
-						'base64'
-					);
-					const decoder = new ZSTDDecoder();
-					await decoder.init();
-					const buffer = Buffer.from(
-						decoder.decode(compressedUserData, MAX_CONSTITUENT_SIZE_BYTES)
-					);
+					let buffer: Buffer;
+
+					if (canUseZstd) {
+						// Decompress zstd data
+						const compressedData = Buffer.from(
+							programAccount.account.data[0],
+							'base64'
+						);
+						// Handle both default and named exports for browser/webpack compatibility
+						let DecoderClass = ZSTDDecoder;
+						if (
+							typeof ZSTDDecoder === 'object' &&
+							(ZSTDDecoder as any).default
+						) {
+							DecoderClass = (ZSTDDecoder as any).default;
+						}
+						const decoder = new (DecoderClass as any)();
+						await decoder.init();
+						buffer = Buffer.from(
+							decoder.decode(compressedData, MAX_CONSTITUENT_SIZE_BYTES)
+						);
+					} else {
+						// Use regular base64 data (not compressed)
+						buffer = Buffer.from(programAccount.account.data[0], 'base64');
+					}
+
 					const key = programAccount.pubkey.toString();
 					const currAccountWithSlot = this.getWithSlot(key);
 

sdk/src/userMap/userMap.ts

@@ -434,12 +434,17 @@ export class UserMap implements UserMapInterface {
 		});
 
 		try {
+			// Check if zstddec is available (it's disabled in browser environments)
+			const canUseZstd =
+				typeof ZSTDDecoder !== 'undefined' && (ZSTDDecoder as any) !== false;
+			const encoding = canUseZstd ? 'base64+zstd' : 'base64';
+
 			const rpcRequestArgs = [
 				this.driftClient.program.programId.toBase58(),
 				{
 					commitment: this.commitment,
 					filters: this.getFilters(),
-					encoding: 'base64+zstd',
+					encoding,
 					withContext: true,
 				},
 			];
@@ -459,19 +464,35 @@ export class UserMap implements UserMapInterface {
 			const programAccountBufferMap = new Map<string, Buffer>();
 			const decodingPromises = rpcResponseAndContext.value.map(
 				async (programAccount) => {
-					const compressedUserData = Buffer.from(
-						programAccount.account.data[0],
-						'base64'
-					);
-					const decoder = new ZSTDDecoder();
-					await decoder.init();
-					const userBuffer = decoder.decode(
-						compressedUserData,
-						MAX_USER_ACCOUNT_SIZE_BYTES
-					);
+					let userBuffer: Buffer;
+
+					if (canUseZstd) {
+						// Decompress zstd data
+						const compressedUserData = Buffer.from(
+							programAccount.account.data[0],
+							'base64'
+						);
+						// Handle both default and named exports for browser/webpack compatibility
+						let DecoderClass = ZSTDDecoder;
+						if (
+							typeof ZSTDDecoder === 'object' &&
+							(ZSTDDecoder as any).default
+						) {
+							DecoderClass = (ZSTDDecoder as any).default;
+						}
+						const decoder = new (DecoderClass as any)();
+						await decoder.init();
+						userBuffer = Buffer.from(
+							decoder.decode(compressedUserData, MAX_USER_ACCOUNT_SIZE_BYTES)
+						);
+					} else {
+						// Use regular base64 data (not compressed)
+						userBuffer = Buffer.from(programAccount.account.data[0], 'base64');
+					}
+
 					programAccountBufferMap.set(
 						programAccount.pubkey.toString(),
-						Buffer.from(userBuffer)
+						userBuffer
 					);
 				}
 			);