@mysten/sui.js - npm Package Compare versions

Comparing version 0.0.0-experimental-20220908212326 to 0.0.0-experimental-20220908214625

dist/providers/json-rpc-provider.d.ts

 import { Provider } from './provider';
 import { JsonRpcClient } from '../rpc/client';
-import { GatewayTxSeqNumber, GetTxnDigestsResponse, GetObjectDataResponse, SuiObjectInfo, SuiMoveFunctionArgTypes, SuiMoveNormalizedModules, SuiMoveNormalizedModule, SuiMoveNormalizedFunction, SuiMoveNormalizedStruct, TransactionDigest, SuiTransactionResponse, SuiObjectRef, ExecuteTransactionRequestType, SuiExecuteTransactionResponse } from '../types';
+import { GatewayTxSeqNumber, GetTxnDigestsResponse, GetObjectDataResponse, SuiObjectInfo, SuiMoveFunctionArgTypes, SuiMoveNormalizedModules, SuiMoveNormalizedModule, SuiMoveNormalizedFunction, SuiMoveNormalizedStruct, TransactionDigest, SuiTransactionResponse, SuiObjectRef, SuiEventFilter, SuiEventEnvelope, SubscriptionId, ExecuteTransactionRequestType, SuiExecuteTransactionResponse } from '../types';
 import { SignatureScheme } from '../cryptography/publickey';
+import { WebsocketClient, WebsocketClientOptions } from '../rpc/websocket-client';
 export declare class JsonRpcProvider extends Provider {
     endpoint: string;
     skipDataValidation: boolean;
+    socketOptions: WebsocketClientOptions;
     protected client: JsonRpcClient;
+    protected wsClient: WebsocketClient;
     /**
@@ -21,3 +24,3 @@ * Establish a connection to a Sui RPC endpoint
      */
-    constructor(endpoint: string, skipDataValidation?: boolean);
+    constructor(endpoint: string, skipDataValidation?: boolean, socketOptions?: WebsocketClientOptions);
     getMoveFunctionArgTypes(objectId: string, moduleName: string, functionName: string): Promise<SuiMoveFunctionArgTypes>;
@@ -44,2 +47,4 @@ getNormalizedMoveModulesByPackage(objectId: string): Promise<SuiMoveNormalizedModules>;
     syncAccountState(address: string): Promise<any>;
+    subscribeEvent(filter: SuiEventFilter, onMessage: (event: SuiEventEnvelope) => void): Promise<SubscriptionId>;
+    unsubscribeEvent(id: SubscriptionId): Promise<boolean>;
 }

dist/providers/provider.d.ts

 import { SignatureScheme } from '../cryptography/publickey';
-import { GetObjectDataResponse, SuiObjectInfo, GatewayTxSeqNumber, GetTxnDigestsResponse, SuiTransactionResponse, SuiObjectRef, SuiMoveFunctionArgTypes, SuiMoveNormalizedFunction, SuiMoveNormalizedStruct, SuiMoveNormalizedModule, SuiMoveNormalizedModules, ExecuteTransactionRequestType, SuiExecuteTransactionResponse } from '../types';
+import { GetObjectDataResponse, SuiObjectInfo, GatewayTxSeqNumber, GetTxnDigestsResponse, SuiTransactionResponse, SuiObjectRef, SuiMoveFunctionArgTypes, SuiMoveNormalizedFunction, SuiMoveNormalizedStruct, SuiMoveNormalizedModule, SuiMoveNormalizedModules, SuiEventFilter, SuiEventEnvelope, SubscriptionId, ExecuteTransactionRequestType, SuiExecuteTransactionResponse } from '../types';
 export declare abstract class Provider {
@@ -67,2 +67,13 @@ /**
     abstract syncAccountState(address: string): Promise<any>;
+    /**
+     * Subscribe to get notifications whenever an event matching the filter occurs
+     * @param filter - filter describing the subset of events to follow
+     * @param onMessage - function to run when we receive a notification of a new event matching the filter
+     */
+    abstract subscribeEvent(filter: SuiEventFilter, onMessage: (event: SuiEventEnvelope) => void): Promise<SubscriptionId>;
+    /**
+     * Unsubscribe from an event subscription
+     * @param id - subscription id to unsubscribe from (previously received from subscribeEvent)
+     */
+    abstract unsubscribeEvent(id: SubscriptionId): Promise<boolean>;
 }

dist/providers/void-provider.d.ts

 import { SignatureScheme } from '../cryptography/publickey';
-import { CertifiedTransaction, TransactionDigest, GetTxnDigestsResponse, GatewayTxSeqNumber, SuiObjectInfo, GetObjectDataResponse, SuiTransactionResponse, SuiObjectRef, SuiMoveFunctionArgTypes, SuiMoveNormalizedFunction, SuiMoveNormalizedStruct, SuiMoveNormalizedModule, SuiMoveNormalizedModules, ExecuteTransactionRequestType, SuiExecuteTransactionResponse } from '../types';
+import { CertifiedTransaction, TransactionDigest, GetTxnDigestsResponse, GatewayTxSeqNumber, SuiObjectInfo, GetObjectDataResponse, SuiTransactionResponse, SuiObjectRef, SuiMoveFunctionArgTypes, SuiMoveNormalizedFunction, SuiMoveNormalizedStruct, SuiMoveNormalizedModule, SuiMoveNormalizedModules, SuiEventFilter, SuiEventEnvelope, SubscriptionId, ExecuteTransactionRequestType, SuiExecuteTransactionResponse } from '../types';
 import { Provider } from './provider';
@@ -21,3 +21,5 @@ export declare class VoidProvider extends Provider {
     syncAccountState(_address: string): Promise<any>;
+    subscribeEvent(_filter: SuiEventFilter, _onMessage: (event: SuiEventEnvelope) => void): Promise<SubscriptionId>;
+    unsubscribeEvent(_id: SubscriptionId): Promise<boolean>;
     private newError;
 }

dist/types/events.d.ts

@@ -1,3 +0,4 @@
-import { SuiAddress, ObjectOwner } from "./common";
+import { SuiAddress, ObjectOwner, TransactionDigest } from "./common";
 import { ObjectId, SequenceNumber } from "./objects";
+import { SuiJsonValue } from "./transactions";
 export declare type MoveEvent = {
@@ -55,1 +56,37 @@ packageId: ObjectId;
 };
+export declare type MoveEventField = {
+    path: string;
+    value: SuiJsonValue;
+};
+export declare type EventType = "MoveEvent" | "Publish" | "TransferObject" | "DeleteObject" | "NewObject" | "EpochChange" | "Checkpoint";
+export declare type SuiEventFilter = {
+    "Package": ObjectId;
+} | {
+    "Module": string;
+} | {
+    "MoveEventType": string;
+} | {
+    "MoveEventField": MoveEventField;
+} | {
+    "SenderAddress": SuiAddress;
+} | {
+    "EventType": EventType;
+} | {
+    "All": SuiEventFilter[];
+} | {
+    "Any": SuiEventFilter[];
+} | {
+    "And": [SuiEventFilter, SuiEventFilter];
+} | {
+    "Or": [SuiEventFilter, SuiEventFilter];
+};
+export declare type SuiEventEnvelope = {
+    timestamp: number;
+    txDigest: TransactionDigest;
+    event: SuiEvent;
+};
+export declare type SubscriptionId = number;
+export declare type SubscriptionEvent = {
+    subscription: SubscriptionId;
+    result: SuiEventEnvelope;
+};

dist/types/index.guard.d.ts

@@ -1,2 +0,2 @@
-import { TransactionDigest, SuiAddress, ObjectOwner, SuiObjectRef, SuiObjectInfo, ObjectContentFields, MovePackageContent, SuiData, SuiMoveObject, SuiMovePackage, SuiMoveFunctionArgTypesResponse, SuiMoveFunctionArgType, SuiMoveFunctionArgTypes, SuiMoveNormalizedModules, SuiMoveNormalizedModule, SuiMoveModuleId, SuiMoveNormalizedStruct, SuiMoveStructTypeParameter, SuiMoveNormalizedField, SuiMoveNormalizedFunction, SuiMoveVisibility, SuiMoveTypeParameterIndex, SuiMoveAbilitySet, SuiMoveNormalizedType, SuiMoveNormalizedTypeParameterType, SuiMoveNormalizedStructType, SuiObject, ObjectStatus, ObjectType, GetOwnedObjectsResponse, GetObjectDataResponse, ObjectDigest, ObjectId, SequenceNumber, MoveEvent, PublishEvent, TransferObjectEvent, DeleteObjectEvent, NewObjectEvent, SuiEvent, TransferObject, SuiTransferSui, SuiChangeEpoch, ExecuteTransactionRequestType, TransactionKindName, SuiTransactionKind, SuiTransactionData, EpochId, AuthorityQuorumSignInfo, CertifiedTransaction, GasCostSummary, ExecutionStatusType, ExecutionStatus, OwnedObjectRef, TransactionEffects, SuiTransactionResponse, SuiCertifiedTransactionEffects, SuiExecuteTransactionResponse, GatewayTxSeqNumber, GetTxnDigestsResponse, MoveCall, SuiJsonValue, EmptySignInfo, AuthorityName, AuthoritySignature, TransactionBytes, SuiParsedMergeCoinResponse, SuiParsedSplitCoinResponse, SuiParsedPublishResponse, SuiPackage, SuiParsedTransactionResponse, DelegationData, DelegationSuiObject, TransferObjectTx, TransferSuiTx, PublishTx, ObjectArg, CallArg, StructTag, TypeTag, MoveCallTx, Transaction, TransactionKind, TransactionData } from "./index";
+import { TransactionDigest, SuiAddress, ObjectOwner, SuiObjectRef, SuiObjectInfo, ObjectContentFields, MovePackageContent, SuiData, SuiMoveObject, SuiMovePackage, SuiMoveFunctionArgTypesResponse, SuiMoveFunctionArgType, SuiMoveFunctionArgTypes, SuiMoveNormalizedModules, SuiMoveNormalizedModule, SuiMoveModuleId, SuiMoveNormalizedStruct, SuiMoveStructTypeParameter, SuiMoveNormalizedField, SuiMoveNormalizedFunction, SuiMoveVisibility, SuiMoveTypeParameterIndex, SuiMoveAbilitySet, SuiMoveNormalizedType, SuiMoveNormalizedTypeParameterType, SuiMoveNormalizedStructType, SuiObject, ObjectStatus, ObjectType, GetOwnedObjectsResponse, GetObjectDataResponse, ObjectDigest, ObjectId, SequenceNumber, MoveEvent, PublishEvent, TransferObjectEvent, DeleteObjectEvent, NewObjectEvent, SuiEvent, MoveEventField, EventType, SuiEventFilter, SuiEventEnvelope, SubscriptionId, SubscriptionEvent, TransferObject, SuiTransferSui, SuiChangeEpoch, ExecuteTransactionRequestType, TransactionKindName, SuiTransactionKind, SuiTransactionData, EpochId, AuthorityQuorumSignInfo, CertifiedTransaction, GasCostSummary, ExecutionStatusType, ExecutionStatus, OwnedObjectRef, TransactionEffects, SuiTransactionResponse, SuiCertifiedTransactionEffects, SuiExecuteTransactionResponse, GatewayTxSeqNumber, GetTxnDigestsResponse, MoveCall, SuiJsonValue, EmptySignInfo, AuthorityName, AuthoritySignature, TransactionBytes, SuiParsedMergeCoinResponse, SuiParsedSplitCoinResponse, SuiParsedPublishResponse, SuiPackage, SuiParsedTransactionResponse, DelegationData, DelegationSuiObject, TransferObjectTx, TransferSuiTx, PublishTx, ObjectArg, CallArg, StructTag, TypeTag, MoveCallTx, Transaction, TransactionKind, TransactionData } from "./index";
 export declare function isTransactionDigest(obj: any, _argumentName?: string): obj is TransactionDigest;
@@ -42,2 +42,8 @@ export declare function isSuiAddress(obj: any, _argumentName?: string): obj is SuiAddress;
 export declare function isSuiEvent(obj: any, _argumentName?: string): obj is SuiEvent;
+export declare function isMoveEventField(obj: any, _argumentName?: string): obj is MoveEventField;
+export declare function isEventType(obj: any, _argumentName?: string): obj is EventType;
+export declare function isSuiEventFilter(obj: any, _argumentName?: string): obj is SuiEventFilter;
+export declare function isSuiEventEnvelope(obj: any, _argumentName?: string): obj is SuiEventEnvelope;
+export declare function isSubscriptionId(obj: any, _argumentName?: string): obj is SubscriptionId;
+export declare function isSubscriptionEvent(obj: any, _argumentName?: string): obj is SubscriptionEvent;
 export declare function isTransferObject(obj: any, _argumentName?: string): obj is TransferObject;
@@ -44,0 +50,0 @@ export declare function isSuiTransferSui(obj: any, _argumentName?: string): obj is SuiTransferSui;

package.json

@@ -5,3 +5,3 @@ {
   "description": "Sui TypeScript API(Work in Progress)",
-  "version": "0.0.0-experimental-20220908212326",
+  "version": "0.0.0-experimental-20220908214625",
   "license": "Apache-2.0",
@@ -73,3 +73,3 @@ "files": [
   "dependencies": {
-    "@mysten/bcs": "0.0.0-experimental-20220908212326",
+    "@mysten/bcs": "0.0.0-experimental-20220908214625",
     "@noble/hashes": "^1.1.2",
@@ -81,2 +81,3 @@ "@noble/secp256k1": "^1.6.3",
     "jayson": "^3.6.6",
+    "rpc-websockets": "^7.5.0",
     "js-sha3": "^0.8.0",
@@ -83,0 +84,0 @@ "lossless-json": "^1.0.5",

src/providers/json-rpc-provider.ts

@@ -33,2 +33,5 @@ // Copyright (c) 2022, Mysten Labs, Inc.
   Coin,
+  SuiEventFilter,
+  SuiEventEnvelope,
+  SubscriptionId,
   ExecuteTransactionRequestType,
@@ -38,2 +41,3 @@ SuiExecuteTransactionResponse,
 import { SignatureScheme } from '../cryptography/publickey';
+import { DEFAULT_CLIENT_OPTIONS, WebsocketClient, WebsocketClientOptions } from '../rpc/websocket-client';
 
@@ -43,4 +47,6 @@ const isNumber = (val: any): val is number => typeof val === 'number';
 
+
 export class JsonRpcProvider extends Provider {
   protected client: JsonRpcClient;
+  protected wsClient: WebsocketClient;
   /**
@@ -60,6 +66,9 @@ * Establish a connection to a Sui RPC endpoint
     public endpoint: string,
-    public skipDataValidation: boolean = false
+    public skipDataValidation: boolean = false,
+    public socketOptions: WebsocketClientOptions = DEFAULT_CLIENT_OPTIONS
   ) {
     super();
+
     this.client = new JsonRpcClient(endpoint);
+    this.wsClient = new WebsocketClient(endpoint, skipDataValidation, socketOptions);
   }
@@ -428,2 +437,13 @@
   }
+
+  async subscribeEvent(
+    filter: SuiEventFilter,
+    onMessage: (event: SuiEventEnvelope) => void
+  ): Promise<SubscriptionId> {
+    return this.wsClient.subscribeEvent(filter, onMessage);
+  }
+
+  async unsubscribeEvent(id: SubscriptionId): Promise<boolean> {
+    return this.wsClient.unsubscribeEvent(id);
+  }
 }

src/providers/provider.ts

@@ -17,2 +17,5 @@ // Copyright (c) 2022, Mysten Labs, Inc.
   SuiMoveNormalizedModules,
+  SuiEventFilter,
+  SuiEventEnvelope,
+  SubscriptionId,
   ExecuteTransactionRequestType,
@@ -140,3 +143,19 @@ SuiExecuteTransactionResponse,
   abstract syncAccountState(address: string): Promise<any>;
+
+  /**
+   * Subscribe to get notifications whenever an event matching the filter occurs
+   * @param filter - filter describing the subset of events to follow
+   * @param onMessage - function to run when we receive a notification of a new event matching the filter
+   */
+  abstract subscribeEvent(
+    filter: SuiEventFilter,
+    onMessage: (event: SuiEventEnvelope) => void
+  ): Promise<SubscriptionId>;
+
+  /**
+   * Unsubscribe from an event subscription
+   * @param id - subscription id to unsubscribe from (previously received from subscribeEvent)
+   */
+  abstract unsubscribeEvent(id: SubscriptionId): Promise<boolean>;
   // TODO: add more interface methods
 }

src/providers/void-provider.ts

@@ -19,2 +19,5 @@ // Copyright (c) 2022, Mysten Labs, Inc.
   SuiMoveNormalizedModules,
+  SuiEventFilter,
+  SuiEventEnvelope,
+  SubscriptionId,
   ExecuteTransactionRequestType,
@@ -127,2 +130,13 @@ SuiExecuteTransactionResponse,
 
+  async subscribeEvent(
+    _filter: SuiEventFilter,
+    _onMessage: (event: SuiEventEnvelope) => void
+  ): Promise<SubscriptionId> {
+      throw this.newError('subscribeEvent');
+  }
+
+  async unsubscribeEvent(_id: SubscriptionId): Promise<boolean> {
+    throw this.newError('unsubscribeEvent');
+  }
+
   private newError(operation: string): Error {
@@ -129,0 +143,0 @@ return new Error(`Please use a valid provider for ${operation}`);

src/types/events.ts

 // Copyright (c) 2022, Mysten Labs, Inc.
 // SPDX-License-Identifier: Apache-2.0
 
-import { SuiAddress, ObjectOwner } from "./common";
+import { SuiAddress, ObjectOwner, TransactionDigest } from "./common";
 import { ObjectId, SequenceNumber } from "./objects";
+import { SuiJsonValue } from "./transactions";
 
@@ -14,3 +15,3 @@
     type: string;
-    fields: { [key: string]: any; }; // TODO - better type
+    fields: { [key: string]: any; };
     bcs: string;
@@ -58,1 +59,38 @@ };
     | { checkpoint: bigint };
+
+export type MoveEventField = {
+    path: string,
+    value: SuiJsonValue
+}
+
+export type EventType =
+    | "MoveEvent"
+    | "Publish"
+    | "TransferObject"
+    | "DeleteObject"
+    | "NewObject"
+    | "EpochChange"
+    | "Checkpoint";
+
+// mirrors sui_json_rpc_types::SuiEventFilter
+export type SuiEventFilter =
+    | { "Package" : ObjectId }
+    | { "Module" : string }
+    | { "MoveEventType" : string }
+    | { "MoveEventField" : MoveEventField }
+    | { "SenderAddress" : SuiAddress }
+    | { "EventType" : EventType }
+    | { "All" : SuiEventFilter[] }
+    | { "Any" : SuiEventFilter[] }
+    | { "And" : [SuiEventFilter, SuiEventFilter] }
+    | { "Or" : [SuiEventFilter, SuiEventFilter] };
+
+export type SuiEventEnvelope = {
+    timestamp:  number,
+    txDigest: TransactionDigest,
+    event: SuiEvent
+}
+
+export type SubscriptionId = number;
+
+export type SubscriptionEvent = { subscription: SubscriptionId, result: SuiEventEnvelope };

src/types/index.guard.ts

@@ -10,3 +10,3 @@ // Copyright (c) 2022, Mysten Labs, Inc.
  */
-import { TransactionDigest, SuiAddress, ObjectOwner, SuiObjectRef, SuiObjectInfo, ObjectContentFields, MovePackageContent, SuiData, SuiMoveObject, SuiMovePackage, SuiMoveFunctionArgTypesResponse, SuiMoveFunctionArgType, SuiMoveFunctionArgTypes, SuiMoveNormalizedModules, SuiMoveNormalizedModule, SuiMoveModuleId, SuiMoveNormalizedStruct, SuiMoveStructTypeParameter, SuiMoveNormalizedField, SuiMoveNormalizedFunction, SuiMoveVisibility, SuiMoveTypeParameterIndex, SuiMoveAbilitySet, SuiMoveNormalizedType, SuiMoveNormalizedTypeParameterType, SuiMoveNormalizedStructType, SuiObject, ObjectStatus, ObjectType, GetOwnedObjectsResponse, GetObjectDataResponse, ObjectDigest, ObjectId, SequenceNumber, MoveEvent, PublishEvent, TransferObjectEvent, DeleteObjectEvent, NewObjectEvent, SuiEvent, TransferObject, SuiTransferSui, SuiChangeEpoch, ExecuteTransactionRequestType, TransactionKindName, SuiTransactionKind, SuiTransactionData, EpochId, AuthorityQuorumSignInfo, CertifiedTransaction, GasCostSummary, ExecutionStatusType, ExecutionStatus, OwnedObjectRef, TransactionEffects, SuiTransactionResponse, SuiCertifiedTransactionEffects, SuiExecuteTransactionResponse, GatewayTxSeqNumber, GetTxnDigestsResponse, MoveCall, SuiJsonValue, EmptySignInfo, AuthorityName, AuthoritySignature, TransactionBytes, SuiParsedMergeCoinResponse, SuiParsedSplitCoinResponse, SuiParsedPublishResponse, SuiPackage, SuiParsedTransactionResponse, DelegationData, DelegationSuiObject, TransferObjectTx, TransferSuiTx, PublishTx, ObjectArg, CallArg, StructTag, TypeTag, MoveCallTx, Transaction, TransactionKind, TransactionData } from "./index";
+import { TransactionDigest, SuiAddress, ObjectOwner, SuiObjectRef, SuiObjectInfo, ObjectContentFields, MovePackageContent, SuiData, SuiMoveObject, SuiMovePackage, SuiMoveFunctionArgTypesResponse, SuiMoveFunctionArgType, SuiMoveFunctionArgTypes, SuiMoveNormalizedModules, SuiMoveNormalizedModule, SuiMoveModuleId, SuiMoveNormalizedStruct, SuiMoveStructTypeParameter, SuiMoveNormalizedField, SuiMoveNormalizedFunction, SuiMoveVisibility, SuiMoveTypeParameterIndex, SuiMoveAbilitySet, SuiMoveNormalizedType, SuiMoveNormalizedTypeParameterType, SuiMoveNormalizedStructType, SuiObject, ObjectStatus, ObjectType, GetOwnedObjectsResponse, GetObjectDataResponse, ObjectDigest, ObjectId, SequenceNumber, MoveEvent, PublishEvent, TransferObjectEvent, DeleteObjectEvent, NewObjectEvent, SuiEvent, MoveEventField, EventType, SuiEventFilter, SuiEventEnvelope, SubscriptionId, SubscriptionEvent, TransferObject, SuiTransferSui, SuiChangeEpoch, ExecuteTransactionRequestType, TransactionKindName, SuiTransactionKind, SuiTransactionData, EpochId, AuthorityQuorumSignInfo, CertifiedTransaction, GasCostSummary, ExecutionStatusType, ExecutionStatus, OwnedObjectRef, TransactionEffects, SuiTransactionResponse, SuiCertifiedTransactionEffects, SuiExecuteTransactionResponse, GatewayTxSeqNumber, GetTxnDigestsResponse, MoveCall, SuiJsonValue, EmptySignInfo, AuthorityName, AuthoritySignature, TransactionBytes, SuiParsedMergeCoinResponse, SuiParsedSplitCoinResponse, SuiParsedPublishResponse, SuiPackage, SuiParsedTransactionResponse, DelegationData, DelegationSuiObject, TransferObjectTx, TransferSuiTx, PublishTx, ObjectArg, CallArg, StructTag, TypeTag, MoveCallTx, Transaction, TransactionKind, TransactionData } from "./index";
 
@@ -501,2 +501,106 @@ export function isTransactionDigest(obj: any, _argumentName?: string): obj is TransactionDigest {
 
+export function isMoveEventField(obj: any, _argumentName?: string): obj is MoveEventField {
+    return (
+        (obj !== null &&
+            typeof obj === "object" ||
+            typeof obj === "function") &&
+        isTransactionDigest(obj.path) as boolean &&
+        isSuiJsonValue(obj.value) as boolean
+    )
+}
+
+export function isEventType(obj: any, _argumentName?: string): obj is EventType {
+    return (
+        (obj === "MoveEvent" ||
+            obj === "Publish" ||
+            obj === "TransferObject" ||
+            obj === "DeleteObject" ||
+            obj === "NewObject" ||
+            obj === "EpochChange" ||
+            obj === "Checkpoint")
+    )
+}
+
+export function isSuiEventFilter(obj: any, _argumentName?: string): obj is SuiEventFilter {
+    return (
+        ((obj !== null &&
+            typeof obj === "object" ||
+            typeof obj === "function") &&
+            isTransactionDigest(obj.Package) as boolean ||
+            (obj !== null &&
+                typeof obj === "object" ||
+                typeof obj === "function") &&
+            isTransactionDigest(obj.Module) as boolean ||
+            (obj !== null &&
+                typeof obj === "object" ||
+                typeof obj === "function") &&
+            isTransactionDigest(obj.MoveEventType) as boolean ||
+            (obj !== null &&
+                typeof obj === "object" ||
+                typeof obj === "function") &&
+            isMoveEventField(obj.MoveEventField) as boolean ||
+            (obj !== null &&
+                typeof obj === "object" ||
+                typeof obj === "function") &&
+            isTransactionDigest(obj.SenderAddress) as boolean ||
+            (obj !== null &&
+                typeof obj === "object" ||
+                typeof obj === "function") &&
+            isEventType(obj.EventType) as boolean ||
+            (obj !== null &&
+                typeof obj === "object" ||
+                typeof obj === "function") &&
+            Array.isArray(obj.All) &&
+            obj.All.every((e: any) =>
+                isSuiEventFilter(e) as boolean
+            ) ||
+            (obj !== null &&
+                typeof obj === "object" ||
+                typeof obj === "function") &&
+            Array.isArray(obj.Any) &&
+            obj.Any.every((e: any) =>
+                isSuiEventFilter(e) as boolean
+            ) ||
+            (obj !== null &&
+                typeof obj === "object" ||
+                typeof obj === "function") &&
+            Array.isArray(obj.And) &&
+            isSuiEventFilter(obj.And[0]) as boolean &&
+            isSuiEventFilter(obj.And[1]) as boolean ||
+            (obj !== null &&
+                typeof obj === "object" ||
+                typeof obj === "function") &&
+            Array.isArray(obj.Or) &&
+            isSuiEventFilter(obj.Or[0]) as boolean &&
+            isSuiEventFilter(obj.Or[1]) as boolean)
+    )
+}
+
+export function isSuiEventEnvelope(obj: any, _argumentName?: string): obj is SuiEventEnvelope {
+    return (
+        (obj !== null &&
+            typeof obj === "object" ||
+            typeof obj === "function") &&
+        isSuiMoveTypeParameterIndex(obj.timestamp) as boolean &&
+        isTransactionDigest(obj.txDigest) as boolean &&
+        isSuiEvent(obj.event) as boolean
+    )
+}
+
+export function isSubscriptionId(obj: any, _argumentName?: string): obj is SubscriptionId {
+    return (
+        typeof obj === "number"
+    )
+}
+
+export function isSubscriptionEvent(obj: any, _argumentName?: string): obj is SubscriptionEvent {
+    return (
+        (obj !== null &&
+            typeof obj === "object" ||
+            typeof obj === "function") &&
+        isSuiMoveTypeParameterIndex(obj.subscription) as boolean &&
+        isSuiEventEnvelope(obj.result) as boolean
+    )
+}
+
 export function isTransferObject(obj: any, _argumentName?: string): obj is TransferObject {
@@ -544,4 +648,4 @@ return (
     return (
-        (obj === "TransferObject" ||
-            obj === "Publish" ||
+        (obj === "Publish" ||
+            obj === "TransferObject" ||
             obj === "Call" ||
@@ -548,0 +652,0 @@ obj === "TransferSui" ||

No alert changes

Improved metrics

Total package byte prevSize

928776

increased by9.06%

Number of package files

73

increased by2.82%

Lines of code

11934

increased by8.66%

Worsened metrics

Dependency count

11

increased by10%

Dependency changes

• + Addedrpc-websockets@^7.5.0

• + Added@mysten/bcs@0.0.0-experimental-20220908214625(transitive)

• + Addedbufferutil@4.0.9(transitive)

• + Addedeventemitter3@4.0.7(transitive)

• + Addednode-gyp-build@4.8.4(transitive)

• + Addedrpc-websockets@7.11.2(transitive)

• + Addedutf-8-validate@5.0.10(transitive)

• + Addedws@8.18.1(transitive)

• - Removed@mysten/bcs@0.0.0-experimental-20220908212326(transitive)

• Updated@mysten/bcs@0.0.0-experimental-20220908214625