Merge pull request #1380 from starknet-io/ws-rpc-0.8.1

feat: update to rpc 0.8.1

Author: tabaktoni

package-lock.json

@@ -106,8 +106,8 @@
     "isows": "^1.0.6",
     "lossless-json": "^4.0.1",
     "pako": "^2.0.4",
-    "starknet-types-07": "npm:@starknet-io/types-js@^0.7.10",
-    "starknet-types-08": "npm:@starknet-io/[email protected].0-beta.10",
+    "starknet-types-07": "npm:@starknet-io/types-js@~0.7.10",
+    "starknet-types-08": "npm:@starknet-io/types-js@~0.8.1",
     "ts-mixer": "^6.0.3",
     "ws": "^8.18.0"
   },

package.json

@@ -157,9 +157,11 @@ export class WebSocketChannel {
   /**
    * Assign implementation to this method to listen unsubscription
    */
-  public onUnsubscribe: (this: WebSocketChannel, _subscriptionId: number) => any = () => {};
+  public onUnsubscribe: (this: WebSocketChannel, _subscriptionId: SUBSCRIPTION_ID) => any =
+    () => {};
 
-  private onUnsubscribeLocal: (this: WebSocketChannel, _subscriptionId: number) => any = () => {};
+  private onUnsubscribeLocal: (this: WebSocketChannel, _subscriptionId: SUBSCRIPTION_ID) => any =
+    () => {};
 
   /**
    * JSON RPC latest sent message id
@@ -171,7 +173,7 @@ export class WebSocketChannel {
    * subscriptions ids
    * mapped by keys WSSubscriptions
    */
-  readonly subscriptions: Map<string, number> = new Map();
+  readonly subscriptions: Map<string, SUBSCRIPTION_ID> = new Map();
 
   /**
    * Construct class and event listeners
@@ -323,7 +325,7 @@ export class WebSocketChannel {
    * @param subscriptionId
    * @param ref internal usage, only for managed subscriptions
    */
-  public async unsubscribe(subscriptionId: number, ref?: string) {
+  public async unsubscribe(subscriptionId: SUBSCRIPTION_ID, ref?: string) {
     const status = (await this.sendReceive('starknet_unsubscribe', {
       subscription_id: subscriptionId,
     })) as boolean;
@@ -346,7 +348,7 @@ export class WebSocketChannel {
    * const subscriptionId = await webSocketChannel.waitForUnsubscription();
    * ```
    */
-  public async waitForUnsubscription(forSubscriptionId?: number) {
+  public async waitForUnsubscription(forSubscriptionId?: SUBSCRIPTION_ID) {
     // unsubscribe
     return new Promise((resolve, reject) => {
       if (!this.websocket) return;