@solana/rpc-core - npm Package Compare versions

Comparing version 2.0.0-experimental.ca22964 to 2.0.0-experimental.caf8d51

dist/index.browser.js

@@ -0,3 +1,120 @@
+import bs58 from 'bs58';
 
+// src/blockhash.ts
+function assertIsBlockhash(putativeBlockhash) {
+  try {
+    if (
+      // Lowest value (32 bytes of zeroes)
+      putativeBlockhash.length < 32 || // Highest value (32 bytes of 255)
+      putativeBlockhash.length > 44
+    ) {
+      throw new Error("Expected input string to decode to a byte array of length 32.");
+    }
+    const bytes = bs58.decode(putativeBlockhash);
+    const numBytes = bytes.byteLength;
+    if (numBytes !== 32) {
+      throw new Error(`Expected input string to decode to a byte array of length 32. Actual length: ${numBytes}`);
+    }
+  } catch (e) {
+    throw new Error(`\`${putativeBlockhash}\` is not a blockhash`, {
+      cause: e
+    });
+  }
+}
+
+// src/params-patcher.ts
+function visitNode(value, keyPath, onIntegerOverflow) {
+  if (Array.isArray(value)) {
+    return value.map(
+      (element, ii) => visitNode(element, [...keyPath, ii], onIntegerOverflow)
+    );
+  } else if (typeof value === "object" && value !== null) {
+    const out = {};
+    for (const propName in value) {
+      if (Object.prototype.hasOwnProperty.call(value, propName)) {
+        out[propName] = visitNode(value[propName], [...keyPath, propName], onIntegerOverflow);
+      }
+    }
+    return out;
+  } else if (typeof value === "bigint") {
+    if (onIntegerOverflow && (value > Number.MAX_SAFE_INTEGER || value < -Number.MAX_SAFE_INTEGER)) {
+      onIntegerOverflow(keyPath, value);
+    }
+    return Number(value);
+  } else {
+    return value;
+  }
+}
+function patchParamsForSolanaLabsRpc(params, onIntegerOverflow) {
+  return visitNode(params, [], onIntegerOverflow);
+}
+
+// src/response-patcher-types.ts
+var KEYPATH_WILDCARD = {};
+
+// src/response-patcher-allowed-numeric-values.ts
+var ALLOWED_NUMERIC_KEYPATHS = {
+  getInflationReward: [[KEYPATH_WILDCARD, "commission"]]
+};
+
+// src/response-patcher.ts
+function getNextAllowedKeypaths(keyPaths, property) {
+  return keyPaths.filter((keyPath) => keyPath[0] === KEYPATH_WILDCARD && typeof property === "number" || keyPath[0] === property).map((keyPath) => keyPath.slice(1));
+}
+function visitNode2(value, allowedKeypaths) {
+  if (Array.isArray(value)) {
+    return value.map((element, ii) => {
+      const nextAllowedKeypaths = getNextAllowedKeypaths(allowedKeypaths, ii);
+      return visitNode2(element, nextAllowedKeypaths);
+    });
+  } else if (typeof value === "object" && value !== null) {
+    const out = {};
+    for (const [propName, innerValue] of Object.entries(value)) {
+      const nextAllowedKeypaths = getNextAllowedKeypaths(allowedKeypaths, propName);
+      out[propName] = visitNode2(innerValue, nextAllowedKeypaths);
+    }
+    return out;
+  } else if (typeof value === "number" && // The presence of an allowed keypath on the route to this value implies it's allowlisted;
+  // Upcast the value to `bigint` unless an allowed keypath is present.
+  allowedKeypaths.length === 0) {
+    return BigInt(value);
+  } else {
+    return value;
+  }
+}
+function patchResponseForSolanaLabsRpc(rawResponse, methodName) {
+  const allowedKeypaths = methodName ? ALLOWED_NUMERIC_KEYPATHS[methodName] : void 0;
+  return visitNode2(rawResponse, allowedKeypaths ?? []);
+}
+
+// src/rpc-methods/index.ts
+function createSolanaRpcApi(config) {
+  return new Proxy({}, {
+    defineProperty() {
+      return false;
+    },
+    deleteProperty() {
+      return false;
+    },
+    get(...args) {
+      const [_, p] = args;
+      const methodName = p.toString();
+      return function(...rawParams) {
+        const handleIntegerOverflow = config?.onIntegerOverflow;
+        const params = patchParamsForSolanaLabsRpc(
+          rawParams,
+          handleIntegerOverflow ? (keyPath, value) => handleIntegerOverflow(methodName, keyPath, value) : void 0
+        );
+        return {
+          methodName,
+          params,
+          responseProcessor: (rawResponse) => patchResponseForSolanaLabsRpc(rawResponse, methodName)
+        };
+      };
+    }
+  });
+}
+
+export { assertIsBlockhash, createSolanaRpcApi };
 //# sourceMappingURL=out.js.map
 //# sourceMappingURL=index.browser.js.map

dist/index.native.js

@@ -0,3 +1,120 @@
+import bs58 from 'bs58';
 
+// src/blockhash.ts
+function assertIsBlockhash(putativeBlockhash) {
+  try {
+    if (
+      // Lowest value (32 bytes of zeroes)
+      putativeBlockhash.length < 32 || // Highest value (32 bytes of 255)
+      putativeBlockhash.length > 44
+    ) {
+      throw new Error("Expected input string to decode to a byte array of length 32.");
+    }
+    const bytes = bs58.decode(putativeBlockhash);
+    const numBytes = bytes.byteLength;
+    if (numBytes !== 32) {
+      throw new Error(`Expected input string to decode to a byte array of length 32. Actual length: ${numBytes}`);
+    }
+  } catch (e) {
+    throw new Error(`\`${putativeBlockhash}\` is not a blockhash`, {
+      cause: e
+    });
+  }
+}
+
+// src/params-patcher.ts
+function visitNode(value, keyPath, onIntegerOverflow) {
+  if (Array.isArray(value)) {
+    return value.map(
+      (element, ii) => visitNode(element, [...keyPath, ii], onIntegerOverflow)
+    );
+  } else if (typeof value === "object" && value !== null) {
+    const out = {};
+    for (const propName in value) {
+      if (Object.prototype.hasOwnProperty.call(value, propName)) {
+        out[propName] = visitNode(value[propName], [...keyPath, propName], onIntegerOverflow);
+      }
+    }
+    return out;
+  } else if (typeof value === "bigint") {
+    if (onIntegerOverflow && (value > Number.MAX_SAFE_INTEGER || value < -Number.MAX_SAFE_INTEGER)) {
+      onIntegerOverflow(keyPath, value);
+    }
+    return Number(value);
+  } else {
+    return value;
+  }
+}
+function patchParamsForSolanaLabsRpc(params, onIntegerOverflow) {
+  return visitNode(params, [], onIntegerOverflow);
+}
+
+// src/response-patcher-types.ts
+var KEYPATH_WILDCARD = {};
+
+// src/response-patcher-allowed-numeric-values.ts
+var ALLOWED_NUMERIC_KEYPATHS = {
+  getInflationReward: [[KEYPATH_WILDCARD, "commission"]]
+};
+
+// src/response-patcher.ts
+function getNextAllowedKeypaths(keyPaths, property) {
+  return keyPaths.filter((keyPath) => keyPath[0] === KEYPATH_WILDCARD && typeof property === "number" || keyPath[0] === property).map((keyPath) => keyPath.slice(1));
+}
+function visitNode2(value, allowedKeypaths) {
+  if (Array.isArray(value)) {
+    return value.map((element, ii) => {
+      const nextAllowedKeypaths = getNextAllowedKeypaths(allowedKeypaths, ii);
+      return visitNode2(element, nextAllowedKeypaths);
+    });
+  } else if (typeof value === "object" && value !== null) {
+    const out = {};
+    for (const [propName, innerValue] of Object.entries(value)) {
+      const nextAllowedKeypaths = getNextAllowedKeypaths(allowedKeypaths, propName);
+      out[propName] = visitNode2(innerValue, nextAllowedKeypaths);
+    }
+    return out;
+  } else if (typeof value === "number" && // The presence of an allowed keypath on the route to this value implies it's allowlisted;
+  // Upcast the value to `bigint` unless an allowed keypath is present.
+  allowedKeypaths.length === 0) {
+    return BigInt(value);
+  } else {
+    return value;
+  }
+}
+function patchResponseForSolanaLabsRpc(rawResponse, methodName) {
+  const allowedKeypaths = methodName ? ALLOWED_NUMERIC_KEYPATHS[methodName] : void 0;
+  return visitNode2(rawResponse, allowedKeypaths ?? []);
+}
+
+// src/rpc-methods/index.ts
+function createSolanaRpcApi(config) {
+  return new Proxy({}, {
+    defineProperty() {
+      return false;
+    },
+    deleteProperty() {
+      return false;
+    },
+    get(...args) {
+      const [_, p] = args;
+      const methodName = p.toString();
+      return function(...rawParams) {
+        const handleIntegerOverflow = config?.onIntegerOverflow;
+        const params = patchParamsForSolanaLabsRpc(
+          rawParams,
+          handleIntegerOverflow ? (keyPath, value) => handleIntegerOverflow(methodName, keyPath, value) : void 0
+        );
+        return {
+          methodName,
+          params,
+          responseProcessor: (rawResponse) => patchResponseForSolanaLabsRpc(rawResponse, methodName)
+        };
+      };
+    }
+  });
+}
+
+export { assertIsBlockhash, createSolanaRpcApi };
 //# sourceMappingURL=out.js.map
 //# sourceMappingURL=index.native.js.map

dist/index.node.js

@@ -0,3 +1,120 @@
+import bs58 from 'bs58';
 
+// src/blockhash.ts
+function assertIsBlockhash(putativeBlockhash) {
+  try {
+    if (
+      // Lowest value (32 bytes of zeroes)
+      putativeBlockhash.length < 32 || // Highest value (32 bytes of 255)
+      putativeBlockhash.length > 44
+    ) {
+      throw new Error("Expected input string to decode to a byte array of length 32.");
+    }
+    const bytes = bs58.decode(putativeBlockhash);
+    const numBytes = bytes.byteLength;
+    if (numBytes !== 32) {
+      throw new Error(`Expected input string to decode to a byte array of length 32. Actual length: ${numBytes}`);
+    }
+  } catch (e) {
+    throw new Error(`\`${putativeBlockhash}\` is not a blockhash`, {
+      cause: e
+    });
+  }
+}
+
+// src/params-patcher.ts
+function visitNode(value, keyPath, onIntegerOverflow) {
+  if (Array.isArray(value)) {
+    return value.map(
+      (element, ii) => visitNode(element, [...keyPath, ii], onIntegerOverflow)
+    );
+  } else if (typeof value === "object" && value !== null) {
+    const out = {};
+    for (const propName in value) {
+      if (Object.prototype.hasOwnProperty.call(value, propName)) {
+        out[propName] = visitNode(value[propName], [...keyPath, propName], onIntegerOverflow);
+      }
+    }
+    return out;
+  } else if (typeof value === "bigint") {
+    if (onIntegerOverflow && (value > Number.MAX_SAFE_INTEGER || value < -Number.MAX_SAFE_INTEGER)) {
+      onIntegerOverflow(keyPath, value);
+    }
+    return Number(value);
+  } else {
+    return value;
+  }
+}
+function patchParamsForSolanaLabsRpc(params, onIntegerOverflow) {
+  return visitNode(params, [], onIntegerOverflow);
+}
+
+// src/response-patcher-types.ts
+var KEYPATH_WILDCARD = {};
+
+// src/response-patcher-allowed-numeric-values.ts
+var ALLOWED_NUMERIC_KEYPATHS = {
+  getInflationReward: [[KEYPATH_WILDCARD, "commission"]]
+};
+
+// src/response-patcher.ts
+function getNextAllowedKeypaths(keyPaths, property) {
+  return keyPaths.filter((keyPath) => keyPath[0] === KEYPATH_WILDCARD && typeof property === "number" || keyPath[0] === property).map((keyPath) => keyPath.slice(1));
+}
+function visitNode2(value, allowedKeypaths) {
+  if (Array.isArray(value)) {
+    return value.map((element, ii) => {
+      const nextAllowedKeypaths = getNextAllowedKeypaths(allowedKeypaths, ii);
+      return visitNode2(element, nextAllowedKeypaths);
+    });
+  } else if (typeof value === "object" && value !== null) {
+    const out = {};
+    for (const [propName, innerValue] of Object.entries(value)) {
+      const nextAllowedKeypaths = getNextAllowedKeypaths(allowedKeypaths, propName);
+      out[propName] = visitNode2(innerValue, nextAllowedKeypaths);
+    }
+    return out;
+  } else if (typeof value === "number" && // The presence of an allowed keypath on the route to this value implies it's allowlisted;
+  // Upcast the value to `bigint` unless an allowed keypath is present.
+  allowedKeypaths.length === 0) {
+    return BigInt(value);
+  } else {
+    return value;
+  }
+}
+function patchResponseForSolanaLabsRpc(rawResponse, methodName) {
+  const allowedKeypaths = methodName ? ALLOWED_NUMERIC_KEYPATHS[methodName] : void 0;
+  return visitNode2(rawResponse, allowedKeypaths ?? []);
+}
+
+// src/rpc-methods/index.ts
+function createSolanaRpcApi(config) {
+  return new Proxy({}, {
+    defineProperty() {
+      return false;
+    },
+    deleteProperty() {
+      return false;
+    },
+    get(...args) {
+      const [_, p] = args;
+      const methodName = p.toString();
+      return function(...rawParams) {
+        const handleIntegerOverflow = config?.onIntegerOverflow;
+        const params = patchParamsForSolanaLabsRpc(
+          rawParams,
+          handleIntegerOverflow ? (keyPath, value) => handleIntegerOverflow(methodName, keyPath, value) : void 0
+        );
+        return {
+          methodName,
+          params,
+          responseProcessor: (rawResponse) => patchResponseForSolanaLabsRpc(rawResponse, methodName)
+        };
+      };
+    }
+  });
+}
+
+export { assertIsBlockhash, createSolanaRpcApi };
 //# sourceMappingURL=out.js.map
 //# sourceMappingURL=index.node.js.map

dist/types/index.d.ts

@@ -1,2 +0,3 @@
-export * from './types/jsonRpcApi';
+export * from './blockhash';
+export * from './rpc-methods';
 //# sourceMappingURL=index.d.ts.map

package.json

 {
   "name": "@solana/rpc-core",
-  "version": "2.0.0-experimental.ca22964",
+  "version": "2.0.0-experimental.caf8d51",
   "description": "A library for making calls to the Solana JSON RPC API",
@@ -49,3 +49,4 @@ "exports": {
   "dependencies": {
-    "@solana/keys": "2.0.0-experimental.ca22964"
+    "bs58": "^5.0.0",
+    "@solana/keys": "2.0.0-experimental.caf8d51"
   },
@@ -66,2 +67,3 @@ "devDependencies": {
     "jest-environment-jsdom": "^29.5.0",
+    "jest-fetch-mock-fork": "^3.0.4",
     "jest-runner-eslint": "^2.0.0",
@@ -73,5 +75,5 @@ "jest-runner-prettier": "^1.0.0",
     "tsup": "6.7.0",
-    "turbo": "^1.6.3",
     "typescript": "^5.0.3",
     "version-from-git": "^1.1.1",
+    "@solana/rpc-transport": "2.0.0-experimental.caf8d51",
     "build-scripts": "0.0.0",
@@ -92,3 +94,3 @@ "test-config": "0.0.0",
     "compile:typedefs": "tsc -p ./tsconfig.declarations.json",
-    "dev": "jest -c node_modules/test-config/jest-dev.config.ts --rootDir . --watch",
+    "dev": "jest -c node_modules/test-config/jest-dev.config.ts --globalSetup test-config/test-validator-setup.js --globalTeardown test-config/test-validator-teardown.js --rootDir . --watch",
     "publish-packages": "pnpm publish --tag experimental --access public --no-git-checks",
@@ -100,4 +102,6 @@ "test:lint": "jest -c node_modules/test-config/jest-lint.config.ts --rootDir . --silent",
     "test:treeshakability:node": "agadoo dist/index.native.js",
-    "test:typecheck": "tsc --noEmit"
+    "test:typecheck": "tsc --noEmit",
+    "test:unit:browser": "jest -c node_modules/test-config/jest-unit.config.browser.ts --globalSetup test-config/test-validator-setup.js --globalTeardown test-config/test-validator-teardown.js --rootDir . --silent",
+    "test:unit:node": "jest -c node_modules/test-config/jest-unit.config.node.ts --globalSetup test-config/test-validator-setup.js --globalTeardown test-config/test-validator-teardown.js --rootDir . --silent"
   }
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

No README

Quality

Package does not have a README. This may indicate a failed publish or a low quality package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

119728

increased by657.87%

Number of package files

60

increased by122.22%

Lines of code

1039

increased by606.8%

Number of medium quality alerts

1

decreased by-50%

Number of lines in readme file

24

increased byInfinity%

Worsened metrics

Dependency count

2

increased by100%

Dev dependency count

26

increased by4%

Number of medium supply chain risk alerts

1

increased byInfinity%

Dependency changes

• + Addedbs58@^5.0.0

• + Added@solana/[e-mail]8d51(transitive)

• - Removed@solana/[e-mail]22964(transitive)

• Updated@solana/[e-mail]8d51