@solana/rpc-subscriptions - npm Package Compare versions

Comparing version 2.0.0-experimental.c32f08b to 2.0.0-experimental.c732fad

dist/index.browser.js

@@ -1,2 +0,2 @@
-import { createSolanaRpcSubscriptionsApi, createSolanaRpcSubscriptionsApi_UNSTABLE } from '@solana/rpc-subscriptions-api';
+import { createSolanaRpcSubscriptionsApi } from '@solana/rpc-subscriptions-api';
 export * from '@solana/rpc-subscriptions-api';
@@ -7,3 +7,3 @@ import { createSubscriptionRpc } from '@solana/rpc-subscriptions-spec';
 import fastStableStringify from 'fast-stable-stringify';
-import { SolanaError, SOLANA_ERROR__RPC_INTEGER_OVERFLOW } from '@solana/errors';
+import { SolanaError, SOLANA_ERROR__RPC__INTEGER_OVERFLOW, SOLANA_ERROR__INVARIANT_VIOLATION__CACHED_ABORTABLE_ITERABLE_CACHE_ENTRY_MISSING } from '@solana/errors';
 import { createWebSocketTransport } from '@solana/rpc-subscriptions-transport-websocket';
@@ -32,3 +32,3 @@
   const path = keyPath.length > 1 ? keyPath.slice(1).map((pathPart) => typeof pathPart === "number" ? `[${pathPart}]` : pathPart).join(".") : void 0;
-  const error = new SolanaError(SOLANA_ERROR__RPC_INTEGER_OVERFLOW, {
+  const error = new SolanaError(SOLANA_ERROR__RPC__INTEGER_OVERFLOW, {
     argumentLabel,
@@ -54,4 +54,2 @@ keyPath,
 };
-
-// src/cached-abortable-iterable.ts
 function registerIterableCleanup(iterable, cleanupFn) {
@@ -70,3 +68,2 @@ (async () => {
   getAbortSignalFromInputArgs,
-  getCacheEntryMissingError,
   getCacheKeyFromInputArgs,
@@ -80,3 +77,5 @@ onCacheHit,
     if (!currentCacheEntry) {
-      throw getCacheEntryMissingError(cacheKey);
+      throw new SolanaError(SOLANA_ERROR__INVARIANT_VIOLATION__CACHED_ABORTABLE_ITERABLE_CACHE_ENTRY_MISSING, {
+        cacheKey: cacheKey.toString()
+      });
     }
@@ -182,7 +181,2 @@ return currentCacheEntry;
           getAbortSignalFromInputArgs: ({ abortSignal }) => abortSignal,
-          getCacheEntryMissingError(deduplicationKey2) {
-            return new Error(
-              `Found no cache entry for subscription with deduplication key \`${deduplicationKey2?.toString()}\``
-            );
-          },
           getCacheKeyFromInputArgs: () => deduplicationKey,
@@ -246,22 +240,2 @@ async onCacheHit(_iterable, _config) {
 
-// src/rpc-subscriptions.ts
-function createSolanaRpcSubscriptions(config) {
-  return pipe(
-    createSubscriptionRpc({
-      ...config,
-      api: createSolanaRpcSubscriptionsApi(DEFAULT_RPC_CONFIG)
-    }),
-    (rpcSubscriptions) => getRpcSubscriptionsWithSubscriptionCoalescing({
-      getDeduplicationKey: (...args) => fastStableStringify(args),
-      rpcSubscriptions
-    })
-  );
-}
-function createSolanaRpcSubscriptions_UNSTABLE(config) {
-  return createSubscriptionRpc({
-    ...config,
-    api: createSolanaRpcSubscriptionsApi_UNSTABLE(DEFAULT_RPC_CONFIG)
-  });
-}
-
 // src/rpc-subscriptions-autopinger.ts
@@ -343,5 +317,2 @@ var PING_PAYLOAD = {
     getAbortSignalFromInputArgs: ({ signal }) => signal,
-    getCacheEntryMissingError(shardKey) {
-      return new Error(`Found no cache entry for connection with shard key \`${shardKey?.toString()}\``);
-    },
     getCacheKeyFromInputArgs: ({ payload }) => getShard ? getShard(payload) : NULL_SHARD_CACHE_KEY,
@@ -376,4 +347,31 @@ onCacheHit: (connection, { payload }) => connection.send_DO_NOT_USE_OR_YOU_WILL_BE_FIRED(payload),
 
-export { createDefaultRpcSubscriptionsTransport, createSolanaRpcSubscriptions, createSolanaRpcSubscriptions_UNSTABLE };
+// src/rpc-subscriptions.ts
+function createSolanaRpcSubscriptions(clusterUrl, config) {
+  const transport = createDefaultRpcSubscriptionsTransport({ url: clusterUrl, ...config });
+  return createSolanaRpcSubscriptionsFromTransport(transport);
+}
+function createSolanaRpcSubscriptions_UNSTABLE(clusterUrl, config) {
+  return createSolanaRpcSubscriptions(
+    clusterUrl,
+    config
+  );
+}
+function createSolanaRpcSubscriptionsFromTransport(transport) {
+  return pipe(
+    createSubscriptionRpc({
+      api: createSolanaRpcSubscriptionsApi(DEFAULT_RPC_CONFIG),
+      transport
+    }),
+    (rpcSubscriptions) => getRpcSubscriptionsWithSubscriptionCoalescing({
+      getDeduplicationKey: (...args) => fastStableStringify(args),
+      rpcSubscriptions
+    })
+  );
+}
+function createSolanaRpcSubscriptionsFromTransport_UNSTABLE(transport) {
+  return createSolanaRpcSubscriptionsFromTransport(transport);
+}
+
+export { createDefaultRpcSubscriptionsTransport, createSolanaRpcSubscriptions, createSolanaRpcSubscriptionsFromTransport, createSolanaRpcSubscriptionsFromTransport_UNSTABLE, createSolanaRpcSubscriptions_UNSTABLE };
 //# sourceMappingURL=out.js.map
 //# sourceMappingURL=index.browser.js.map

dist/index.native.js

@@ -1,2 +0,2 @@
-import { createSolanaRpcSubscriptionsApi, createSolanaRpcSubscriptionsApi_UNSTABLE } from '@solana/rpc-subscriptions-api';
+import { createSolanaRpcSubscriptionsApi } from '@solana/rpc-subscriptions-api';
 export * from '@solana/rpc-subscriptions-api';
@@ -7,3 +7,3 @@ import { createSubscriptionRpc } from '@solana/rpc-subscriptions-spec';
 import fastStableStringify from 'fast-stable-stringify';
-import { SolanaError, SOLANA_ERROR__RPC_INTEGER_OVERFLOW } from '@solana/errors';
+import { SolanaError, SOLANA_ERROR__RPC__INTEGER_OVERFLOW, SOLANA_ERROR__INVARIANT_VIOLATION__CACHED_ABORTABLE_ITERABLE_CACHE_ENTRY_MISSING } from '@solana/errors';
 import { createWebSocketTransport } from '@solana/rpc-subscriptions-transport-websocket';
@@ -32,3 +32,3 @@
   const path = keyPath.length > 1 ? keyPath.slice(1).map((pathPart) => typeof pathPart === "number" ? `[${pathPart}]` : pathPart).join(".") : void 0;
-  const error = new SolanaError(SOLANA_ERROR__RPC_INTEGER_OVERFLOW, {
+  const error = new SolanaError(SOLANA_ERROR__RPC__INTEGER_OVERFLOW, {
     argumentLabel,
@@ -54,4 +54,2 @@ keyPath,
 };
-
-// src/cached-abortable-iterable.ts
 function registerIterableCleanup(iterable, cleanupFn) {
@@ -70,3 +68,2 @@ (async () => {
   getAbortSignalFromInputArgs,
-  getCacheEntryMissingError,
   getCacheKeyFromInputArgs,
@@ -80,3 +77,5 @@ onCacheHit,
     if (!currentCacheEntry) {
-      throw getCacheEntryMissingError(cacheKey);
+      throw new SolanaError(SOLANA_ERROR__INVARIANT_VIOLATION__CACHED_ABORTABLE_ITERABLE_CACHE_ENTRY_MISSING, {
+        cacheKey: cacheKey.toString()
+      });
     }
@@ -182,7 +181,2 @@ return currentCacheEntry;
           getAbortSignalFromInputArgs: ({ abortSignal }) => abortSignal,
-          getCacheEntryMissingError(deduplicationKey2) {
-            return new Error(
-              `Found no cache entry for subscription with deduplication key \`${deduplicationKey2?.toString()}\``
-            );
-          },
           getCacheKeyFromInputArgs: () => deduplicationKey,
@@ -246,22 +240,2 @@ async onCacheHit(_iterable, _config) {
 
-// src/rpc-subscriptions.ts
-function createSolanaRpcSubscriptions(config) {
-  return pipe(
-    createSubscriptionRpc({
-      ...config,
-      api: createSolanaRpcSubscriptionsApi(DEFAULT_RPC_CONFIG)
-    }),
-    (rpcSubscriptions) => getRpcSubscriptionsWithSubscriptionCoalescing({
-      getDeduplicationKey: (...args) => fastStableStringify(args),
-      rpcSubscriptions
-    })
-  );
-}
-function createSolanaRpcSubscriptions_UNSTABLE(config) {
-  return createSubscriptionRpc({
-    ...config,
-    api: createSolanaRpcSubscriptionsApi_UNSTABLE(DEFAULT_RPC_CONFIG)
-  });
-}
-
 // src/rpc-subscriptions-autopinger.ts
@@ -332,5 +306,2 @@ var PING_PAYLOAD = {
     getAbortSignalFromInputArgs: ({ signal }) => signal,
-    getCacheEntryMissingError(shardKey) {
-      return new Error(`Found no cache entry for connection with shard key \`${shardKey?.toString()}\``);
-    },
     getCacheKeyFromInputArgs: ({ payload }) => getShard ? getShard(payload) : NULL_SHARD_CACHE_KEY,
@@ -365,4 +336,31 @@ onCacheHit: (connection, { payload }) => connection.send_DO_NOT_USE_OR_YOU_WILL_BE_FIRED(payload),
 
-export { createDefaultRpcSubscriptionsTransport, createSolanaRpcSubscriptions, createSolanaRpcSubscriptions_UNSTABLE };
+// src/rpc-subscriptions.ts
+function createSolanaRpcSubscriptions(clusterUrl, config) {
+  const transport = createDefaultRpcSubscriptionsTransport({ url: clusterUrl, ...config });
+  return createSolanaRpcSubscriptionsFromTransport(transport);
+}
+function createSolanaRpcSubscriptions_UNSTABLE(clusterUrl, config) {
+  return createSolanaRpcSubscriptions(
+    clusterUrl,
+    config
+  );
+}
+function createSolanaRpcSubscriptionsFromTransport(transport) {
+  return pipe(
+    createSubscriptionRpc({
+      api: createSolanaRpcSubscriptionsApi(DEFAULT_RPC_CONFIG),
+      transport
+    }),
+    (rpcSubscriptions) => getRpcSubscriptionsWithSubscriptionCoalescing({
+      getDeduplicationKey: (...args) => fastStableStringify(args),
+      rpcSubscriptions
+    })
+  );
+}
+function createSolanaRpcSubscriptionsFromTransport_UNSTABLE(transport) {
+  return createSolanaRpcSubscriptionsFromTransport(transport);
+}
+
+export { createDefaultRpcSubscriptionsTransport, createSolanaRpcSubscriptions, createSolanaRpcSubscriptionsFromTransport, createSolanaRpcSubscriptionsFromTransport_UNSTABLE, createSolanaRpcSubscriptions_UNSTABLE };
 //# sourceMappingURL=out.js.map
 //# sourceMappingURL=index.native.js.map

dist/index.node.js

@@ -1,2 +0,2 @@
-import { createSolanaRpcSubscriptionsApi, createSolanaRpcSubscriptionsApi_UNSTABLE } from '@solana/rpc-subscriptions-api';
+import { createSolanaRpcSubscriptionsApi } from '@solana/rpc-subscriptions-api';
 export * from '@solana/rpc-subscriptions-api';
@@ -7,3 +7,3 @@ import { createSubscriptionRpc } from '@solana/rpc-subscriptions-spec';
 import fastStableStringify from 'fast-stable-stringify';
-import { SolanaError, SOLANA_ERROR__RPC_INTEGER_OVERFLOW } from '@solana/errors';
+import { SolanaError, SOLANA_ERROR__RPC__INTEGER_OVERFLOW, SOLANA_ERROR__INVARIANT_VIOLATION__CACHED_ABORTABLE_ITERABLE_CACHE_ENTRY_MISSING } from '@solana/errors';
 import { createWebSocketTransport } from '@solana/rpc-subscriptions-transport-websocket';
@@ -32,3 +32,3 @@
   const path = keyPath.length > 1 ? keyPath.slice(1).map((pathPart) => typeof pathPart === "number" ? `[${pathPart}]` : pathPart).join(".") : void 0;
-  const error = new SolanaError(SOLANA_ERROR__RPC_INTEGER_OVERFLOW, {
+  const error = new SolanaError(SOLANA_ERROR__RPC__INTEGER_OVERFLOW, {
     argumentLabel,
@@ -54,4 +54,2 @@ keyPath,
 };
-
-// src/cached-abortable-iterable.ts
 function registerIterableCleanup(iterable, cleanupFn) {
@@ -70,3 +68,2 @@ (async () => {
   getAbortSignalFromInputArgs,
-  getCacheEntryMissingError,
   getCacheKeyFromInputArgs,
@@ -80,3 +77,5 @@ onCacheHit,
     if (!currentCacheEntry) {
-      throw getCacheEntryMissingError(cacheKey);
+      throw new SolanaError(SOLANA_ERROR__INVARIANT_VIOLATION__CACHED_ABORTABLE_ITERABLE_CACHE_ENTRY_MISSING, {
+        cacheKey: cacheKey.toString()
+      });
     }
@@ -182,7 +181,2 @@ return currentCacheEntry;
           getAbortSignalFromInputArgs: ({ abortSignal }) => abortSignal,
-          getCacheEntryMissingError(deduplicationKey2) {
-            return new Error(
-              `Found no cache entry for subscription with deduplication key \`${deduplicationKey2?.toString()}\``
-            );
-          },
           getCacheKeyFromInputArgs: () => deduplicationKey,
@@ -246,22 +240,2 @@ async onCacheHit(_iterable, _config) {
 
-// src/rpc-subscriptions.ts
-function createSolanaRpcSubscriptions(config) {
-  return pipe(
-    createSubscriptionRpc({
-      ...config,
-      api: createSolanaRpcSubscriptionsApi(DEFAULT_RPC_CONFIG)
-    }),
-    (rpcSubscriptions) => getRpcSubscriptionsWithSubscriptionCoalescing({
-      getDeduplicationKey: (...args) => fastStableStringify(args),
-      rpcSubscriptions
-    })
-  );
-}
-function createSolanaRpcSubscriptions_UNSTABLE(config) {
-  return createSubscriptionRpc({
-    ...config,
-    api: createSolanaRpcSubscriptionsApi_UNSTABLE(DEFAULT_RPC_CONFIG)
-  });
-}
-
 // src/rpc-subscriptions-autopinger.ts
@@ -332,5 +306,2 @@ var PING_PAYLOAD = {
     getAbortSignalFromInputArgs: ({ signal }) => signal,
-    getCacheEntryMissingError(shardKey) {
-      return new Error(`Found no cache entry for connection with shard key \`${shardKey?.toString()}\``);
-    },
     getCacheKeyFromInputArgs: ({ payload }) => getShard ? getShard(payload) : NULL_SHARD_CACHE_KEY,
@@ -365,4 +336,31 @@ onCacheHit: (connection, { payload }) => connection.send_DO_NOT_USE_OR_YOU_WILL_BE_FIRED(payload),
 
-export { createDefaultRpcSubscriptionsTransport, createSolanaRpcSubscriptions, createSolanaRpcSubscriptions_UNSTABLE };
+// src/rpc-subscriptions.ts
+function createSolanaRpcSubscriptions(clusterUrl, config) {
+  const transport = createDefaultRpcSubscriptionsTransport({ url: clusterUrl, ...config });
+  return createSolanaRpcSubscriptionsFromTransport(transport);
+}
+function createSolanaRpcSubscriptions_UNSTABLE(clusterUrl, config) {
+  return createSolanaRpcSubscriptions(
+    clusterUrl,
+    config
+  );
+}
+function createSolanaRpcSubscriptionsFromTransport(transport) {
+  return pipe(
+    createSubscriptionRpc({
+      api: createSolanaRpcSubscriptionsApi(DEFAULT_RPC_CONFIG),
+      transport
+    }),
+    (rpcSubscriptions) => getRpcSubscriptionsWithSubscriptionCoalescing({
+      getDeduplicationKey: (...args) => fastStableStringify(args),
+      rpcSubscriptions
+    })
+  );
+}
+function createSolanaRpcSubscriptionsFromTransport_UNSTABLE(transport) {
+  return createSolanaRpcSubscriptionsFromTransport(transport);
+}
+
+export { createDefaultRpcSubscriptionsTransport, createSolanaRpcSubscriptions, createSolanaRpcSubscriptionsFromTransport, createSolanaRpcSubscriptionsFromTransport_UNSTABLE, createSolanaRpcSubscriptions_UNSTABLE };
 //# sourceMappingURL=out.js.map
 //# sourceMappingURL=index.node.js.map

dist/types/cached-abortable-iterable.d.ts

 type CacheKey = string | symbol;
 type Config<TInput extends unknown[], TIterable extends AsyncIterable<unknown>> = Readonly<{
     getAbortSignalFromInputArgs: (...args: TInput) => AbortSignal;
-    getCacheEntryMissingError: (cacheKey: CacheKey) => Error;
     getCacheKeyFromInputArgs: (...args: TInput) => CacheKey | undefined;
@@ -9,4 +8,4 @@ onCacheHit: (iterable: TIterable, ...args: TInput) => Promise<void>;
 }>;
-export declare function getCachedAbortableIterableFactory<TInput extends unknown[], TIterable extends AsyncIterable<unknown>>({ getAbortSignalFromInputArgs, getCacheEntryMissingError, getCacheKeyFromInputArgs, onCacheHit, onCreateIterable, }: Config<TInput, TIterable>): (...args: TInput) => Promise<TIterable>;
+export declare function getCachedAbortableIterableFactory<TInput extends unknown[], TIterable extends AsyncIterable<unknown>>({ getAbortSignalFromInputArgs, getCacheKeyFromInputArgs, onCacheHit, onCreateIterable, }: Config<TInput, TIterable>): (...args: TInput) => Promise<TIterable>;
 export {};
 //# sourceMappingURL=cached-abortable-iterable.d.ts.map

dist/types/rpc-integer-overflow-error.d.ts

@@ -1,4 +0,4 @@
-import { SOLANA_ERROR__RPC_INTEGER_OVERFLOW, SolanaError } from '@solana/errors';
+import { SOLANA_ERROR__RPC__INTEGER_OVERFLOW, SolanaError } from '@solana/errors';
 import type { KeyPath } from '@solana/rpc-transformers';
-export declare function createSolanaJsonRpcIntegerOverflowError(methodName: string, keyPath: KeyPath, value: bigint): SolanaError<typeof SOLANA_ERROR__RPC_INTEGER_OVERFLOW>;
+export declare function createSolanaJsonRpcIntegerOverflowError(methodName: string, keyPath: KeyPath, value: bigint): SolanaError<typeof SOLANA_ERROR__RPC__INTEGER_OVERFLOW>;
 //# sourceMappingURL=rpc-integer-overflow-error.d.ts.map

dist/types/rpc-subscriptions-clusters.d.ts

@@ -12,3 +12,3 @@ import type { RpcSubscriptions, RpcSubscriptionsTransport } from '@solana/rpc-subscriptions-spec';
 };
-export type RpcSubscriptionsTransportWithCluster = RpcSubscriptionsTransportDevnet | RpcSubscriptionsTransportTestnet | RpcSubscriptionsTransportMainnet;
+export type RpcSubscriptionsTransportWithCluster = RpcSubscriptionsTransportDevnet | RpcSubscriptionsTransportMainnet | RpcSubscriptionsTransportTestnet;
 export type RpcSubscriptionsTransportFromClusterUrl<TClusterUrl extends ClusterUrl> = TClusterUrl extends DevnetUrl ? RpcSubscriptionsTransportDevnet : TClusterUrl extends TestnetUrl ? RpcSubscriptionsTransportTestnet : TClusterUrl extends MainnetUrl ? RpcSubscriptionsTransportMainnet : RpcSubscriptionsTransport;
@@ -15,0 +15,0 @@ export type RpcSubscriptionsDevnet<TRpcMethods> = RpcSubscriptions<TRpcMethods> & {

dist/types/rpc-subscriptions-transport.d.ts

 import type { ClusterUrl } from '@solana/rpc-types';
 import { RpcSubscriptionsTransportFromClusterUrl } from './rpc-subscriptions-clusters.js';
-type Config<TClusterUrl extends ClusterUrl> = Readonly<{
-    url: TClusterUrl;
-}>;
-export declare function createDefaultRpcSubscriptionsTransport<TClusterUrl extends ClusterUrl>(config: Config<TClusterUrl> & {
+export type DefaultRpcSubscriptionsTransportConfig<TClusterUrl extends ClusterUrl> = Readonly<{
     /**
@@ -15,4 +12,5 @@ * You might like to open more subscriptions per connection than your RPC provider allows
     sendBufferHighWatermark?: number;
-}): RpcSubscriptionsTransportFromClusterUrl<TClusterUrl>;
-export {};
+    url: TClusterUrl;
+}>;
+export declare function createDefaultRpcSubscriptionsTransport<TClusterUrl extends ClusterUrl>(config: DefaultRpcSubscriptionsTransportConfig<TClusterUrl>): RpcSubscriptionsTransportFromClusterUrl<TClusterUrl>;
 //# sourceMappingURL=rpc-subscriptions-transport.d.ts.map

dist/types/rpc-subscriptions.d.ts

@@ -1,10 +0,10 @@
-import type { SolanaRpcSubscriptionsApi, SolanaRpcSubscriptionsApiUnstable } from '@solana/rpc-subscriptions-api';
-import { type RpcSubscriptionsTransport } from '@solana/rpc-subscriptions-spec';
+import type { SolanaRpcSubscriptionsApi } from '@solana/rpc-subscriptions-api';
+import { RpcSubscriptionsApiMethods, type RpcSubscriptionsTransport } from '@solana/rpc-subscriptions-spec';
+import { ClusterUrl } from '@solana/rpc-types';
 import type { RpcSubscriptionsFromTransport } from './rpc-subscriptions-clusters.js';
-type RpcSubscriptionsConfig<TTransport extends RpcSubscriptionsTransport> = Readonly<{
-    transport: TTransport;
-}>;
-export declare function createSolanaRpcSubscriptions<TTransport extends RpcSubscriptionsTransport>(config: RpcSubscriptionsConfig<TTransport>): RpcSubscriptionsFromTransport<SolanaRpcSubscriptionsApi, TTransport>;
-export declare function createSolanaRpcSubscriptions_UNSTABLE<TTransport extends RpcSubscriptionsTransport>(config: RpcSubscriptionsConfig<TTransport>): RpcSubscriptionsFromTransport<SolanaRpcSubscriptionsApi & SolanaRpcSubscriptionsApiUnstable, TTransport>;
-export {};
+import { DefaultRpcSubscriptionsTransportConfig } from './rpc-subscriptions-transport.js';
+export declare function createSolanaRpcSubscriptions<TClusterUrl extends ClusterUrl, TApi extends RpcSubscriptionsApiMethods = SolanaRpcSubscriptionsApi>(clusterUrl: TClusterUrl, config?: Omit<DefaultRpcSubscriptionsTransportConfig<TClusterUrl>, 'url'>): RpcSubscriptionsFromTransport<TApi, import("./rpc-subscriptions-clusters").RpcSubscriptionsTransportFromClusterUrl<TClusterUrl>>;
+export declare function createSolanaRpcSubscriptions_UNSTABLE<TClusterUrl extends ClusterUrl>(clusterUrl: TClusterUrl, config?: Omit<DefaultRpcSubscriptionsTransportConfig<TClusterUrl>, 'url'>): RpcSubscriptionsFromTransport<import("@solana/rpc-subscriptions-api").AccountNotificationsApi & import("@solana/rpc-subscriptions-api").LogsNotificationsApi & import("@solana/rpc-subscriptions-api").ProgramNotificationsApi & import("@solana/rpc-subscriptions-api").RootNotificationsApi & import("@solana/rpc-subscriptions-api").SignatureNotificationsApi & import("@solana/rpc-subscriptions-api").SlotNotificationsApi & import("@solana/rpc-subscriptions-api").BlockNotificationsApi & import("@solana/rpc-subscriptions-api").SlotsUpdatesNotificationsApi & import("@solana/rpc-subscriptions-api").VoteNotificationsApi, import("./rpc-subscriptions-clusters").RpcSubscriptionsTransportFromClusterUrl<TClusterUrl>>;
+export declare function createSolanaRpcSubscriptionsFromTransport<TTransport extends RpcSubscriptionsTransport, TApi extends RpcSubscriptionsApiMethods = SolanaRpcSubscriptionsApi>(transport: TTransport): RpcSubscriptionsFromTransport<TApi, TTransport>;
+export declare function createSolanaRpcSubscriptionsFromTransport_UNSTABLE<TTransport extends RpcSubscriptionsTransport>(transport: TTransport): RpcSubscriptionsFromTransport<import("@solana/rpc-subscriptions-api").AccountNotificationsApi & import("@solana/rpc-subscriptions-api").LogsNotificationsApi & import("@solana/rpc-subscriptions-api").ProgramNotificationsApi & import("@solana/rpc-subscriptions-api").RootNotificationsApi & import("@solana/rpc-subscriptions-api").SignatureNotificationsApi & import("@solana/rpc-subscriptions-api").SlotNotificationsApi & import("@solana/rpc-subscriptions-api").BlockNotificationsApi & import("@solana/rpc-subscriptions-api").SlotsUpdatesNotificationsApi & import("@solana/rpc-subscriptions-api").VoteNotificationsApi, TTransport>;
 //# sourceMappingURL=rpc-subscriptions.d.ts.map

package.json

 {
   "name": "@solana/rpc-subscriptions",
-  "version": "2.0.0-experimental.c32f08b",
+  "version": "2.0.0-experimental.c732fad",
   "description": "A library for subscribing to Solana RPC notifications",
@@ -50,9 +50,9 @@ "exports": {
     "fast-stable-stringify": "^1.0.0",
-    "@solana/errors": "2.0.0-experimental.c32f08b",
-    "@solana/functional": "2.0.0-experimental.c32f08b",
-    "@solana/rpc-subscriptions-api": "2.0.0-experimental.c32f08b",
-    "@solana/rpc-subscriptions-spec": "2.0.0-experimental.c32f08b",
-    "@solana/rpc-subscriptions-transport-websocket": "2.0.0-experimental.c32f08b",
-    "@solana/rpc-transformers": "2.0.0-experimental.c32f08b",
-    "@solana/rpc-types": "2.0.0-experimental.c32f08b"
+    "@solana/errors": "2.0.0-experimental.c732fad",
+    "@solana/functional": "2.0.0-experimental.c732fad",
+    "@solana/rpc-subscriptions-api": "2.0.0-experimental.c732fad",
+    "@solana/rpc-subscriptions-spec": "2.0.0-experimental.c732fad",
+    "@solana/rpc-subscriptions-transport-websocket": "2.0.0-experimental.c732fad",
+    "@solana/rpc-transformers": "2.0.0-experimental.c732fad",
+    "@solana/rpc-types": "2.0.0-experimental.c732fad"
   },
@@ -69,9 +69,9 @@ "bundlewatch": {
     "compile:js": "tsup --config build-scripts/tsup.config.package.ts",
-    "compile:typedefs": "tsc -p ./tsconfig.declarations.json && node node_modules/@solana/build-scripts/add-js-extension-to-types.mjs",
-    "dev": "jest -c node_modules/@solana/test-config/jest-dev.config.ts --rootDir . --watch",
+    "compile:typedefs": "tsc -p ./tsconfig.declarations.json && node ../../node_modules/@solana/build-scripts/add-js-extension-to-types.mjs",
+    "dev": "jest -c ../../node_modules/@solana/test-config/jest-dev.config.ts --rootDir . --watch",
     "publish-impl": "npm view $npm_package_name@$npm_package_version > /dev/null 2>&1 || pnpm publish --tag experimental --access public --no-git-checks",
     "publish-packages": "pnpm prepublishOnly && pnpm publish-impl",
     "style:fix": "pnpm eslint --fix src/* && pnpm prettier -w src/* package.json",
-    "test:lint": "jest -c node_modules/@solana/test-config/jest-lint.config.ts --rootDir . --silent",
-    "test:prettier": "jest -c node_modules/@solana/test-config/jest-prettier.config.ts --rootDir . --silent",
+    "test:lint": "jest -c ../../node_modules/@solana/test-config/jest-lint.config.ts --rootDir . --silent",
+    "test:prettier": "jest -c ../../node_modules/@solana/test-config/jest-prettier.config.ts --rootDir . --silent",
     "test:treeshakability:browser": "agadoo dist/index.browser.js",
@@ -81,5 +81,5 @@ "test:treeshakability:native": "agadoo dist/index.native.js",
     "test:typecheck": "tsc --noEmit",
-    "test:unit:browser": "jest -c node_modules/@solana/test-config/jest-unit.config.browser.ts --rootDir . --silent",
-    "test:unit:node": "jest -c node_modules/@solana/test-config/jest-unit.config.node.ts --rootDir . --silent"
+    "test:unit:browser": "jest -c ../../node_modules/@solana/test-config/jest-unit.config.browser.ts --rootDir . --silent",
+    "test:unit:node": "jest -c ../../node_modules/@solana/test-config/jest-unit.config.node.ts --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

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

Improved metrics

Total package byte prevSize

245211

increased by1.88%

Lines of code

2263

increased by0.13%

Worsened metrics

Number of downloads

14996

decreased by-20.2%

Published versions last months

18

decreased by-45.45%

Dependency changes

• + Added@solana/addresses@2.0.0-experimental.c732fad(transitive)

• + Added@solana/assertions@2.0.0-experimental.c732fad(transitive)

• + Added@solana/codecs-core@2.0.0-experimental.c732fad(transitive)

• + Added@solana/codecs-data-structures@2.0.0-experimental.c732fad(transitive)

• + Added@solana/codecs-numbers@2.0.0-experimental.c732fad(transitive)

• + Added@solana/codecs-strings@2.0.0-experimental.c732fad(transitive)

• + Added@solana/errors@2.0.0-experimental.c732fad(transitive)

• + Added@solana/functional@2.0.0-experimental.c732fad(transitive)

• + Added@solana/keys@2.0.0-experimental.c732fad(transitive)

• + Added@solana/rpc-spec@2.0.0-experimental.c732fad(transitive)

• + Added@solana/rpc-spec-types@2.0.0-experimental.c732fad(transitive)

• + Added@solana/rpc-subscriptions-api@2.0.0-experimental.c732fad(transitive)

• + Added@solana/rpc-subscriptions-spec@2.0.0-experimental.c732fad(transitive)

• + Added@solana/rpc-subscriptions-transport-websocket@2.0.0-experimental.c732fad(transitive)

• + Added@solana/rpc-transformers@2.0.0-experimental.c732fad(transitive)

• + Added@solana/rpc-types@2.0.0-experimental.c732fad(transitive)

• + Added@solana/transactions@2.0.0-experimental.c732fad(transitive)

• + Addedcommander@12.1.0(transitive)

• - Removed@solana/addresses@2.0.0-experimental.c32f08b(transitive)

• - Removed@solana/assertions@2.0.0-experimental.c32f08b(transitive)

• - Removed@solana/codecs-core@2.0.0-experimental.c32f08b(transitive)

• - Removed@solana/codecs-data-structures@2.0.0-experimental.c32f08b(transitive)

• - Removed@solana/codecs-numbers@2.0.0-experimental.c32f08b(transitive)

• - Removed@solana/codecs-strings@2.0.0-experimental.c32f08b(transitive)

• - Removed@solana/errors@2.0.0-experimental.c32f08b(transitive)

• - Removed@solana/functional@2.0.0-experimental.c32f08b(transitive)

• - Removed@solana/keys@2.0.0-experimental.c32f08b(transitive)

• - Removed@solana/rpc-spec@2.0.0-experimental.c32f08b(transitive)

• - Removed@solana/rpc-spec-types@2.0.0-experimental.c32f08b(transitive)

• - Removed@solana/rpc-subscriptions-api@2.0.0-experimental.c32f08b(transitive)

• - Removed@solana/rpc-subscriptions-spec@2.0.0-experimental.c32f08b(transitive)

• - Removed@solana/rpc-subscriptions-transport-websocket@2.0.0-experimental.c32f08b(transitive)

• - Removed@solana/rpc-transformers@2.0.0-experimental.c32f08b(transitive)

• - Removed@solana/rpc-types@2.0.0-experimental.c32f08b(transitive)

• - Removed@solana/transactions@2.0.0-experimental.c32f08b(transitive)

• - Removedcommander@11.1.0(transitive)

• Updated@solana/errors@2.0.0-experimental.c732fad

• Updated@solana/functional@2.0.0-experimental.c732fad

• Updated@solana/rpc-subscriptions-api@2.0.0-experimental.c732fad

• Updated@solana/rpc-subscriptions-spec@2.0.0-experimental.c732fad

• Updated@solana/rpc-subscriptions-transport-websocket@2.0.0-experimental.c732fad

• Updated@solana/rpc-transformers@2.0.0-experimental.c732fad

• Updated@solana/rpc-types@2.0.0-experimental.c732fad