Merge pull request #774 from nemtech/dev

Dev -> Main

Author: rg911

CHANGELOG.md

@@ -4,6 +4,18 @@ All notable changes to this project will be documented in this file.
 
 The changelog format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
 
+## [1.0.0] - 13-Mar-2021
+
+**Milestone**: Symbol Mainnet
+ Package  | Version  | Link
+---|---|---
+SDK Core| v1.0.0 | [symbol-sdk](https://www.npmjs.com/package/symbol-sdk)
+Catbuffer | v0.1.1 | [catbuffer-typescript](https://www.npmjs.com/package/catbuffer-typescript)
+Client Library | v0.11.1  | [symbol-openapi-typescript-fetch-client](https://www.npmjs.com/package/symbol-openapi-typescript-fetch-client)
+
+- Added callback function in websocket listener for client to handle unsolicited websocket close event.
+- Release for Symbol mainnet.
+
 ## [0.23.3] - 5-Mar-2021
 
 **Milestone**: Catapult-server main(0.10.0.8)

package-lock.json

@@ -1,6 +1,6 @@
 {
     "name": "symbol-sdk",
-    "version": "0.23.4",
+    "version": "1.0.0",
     "description": "Reactive symbol sdk for typescript and javascript",
     "scripts": {
         "pretest": "npm run build",

package.json

@@ -23,6 +23,8 @@ import { CosignatureSignedTransaction } from '../model/transaction/CosignatureSi
 import { Transaction } from '../model/transaction/Transaction';
 import { TransactionStatusError } from '../model/transaction/TransactionStatusError';
 
+export type OnWsCloseCallback = (event: { client: string; code: any; reason: any }) => void;
+
 /**
  * Listener service
  */
@@ -35,7 +37,7 @@ export interface IListener {
      * Open web socket connection.
      * @returns Promise<Void>
      */
-    open(): Promise<void>;
+    open(onUnsolicitedCloseCallback?: OnWsCloseCallback): Promise<void>;
 
     /**
      * returns a boolean that repressents the open state

src/infrastructure/IListener.ts

@@ -29,7 +29,7 @@ import { Deadline } from '../model/transaction/Deadline';
 import { Transaction } from '../model/transaction/Transaction';
 import { TransactionStatusError } from '../model/transaction/TransactionStatusError';
 import { UInt64 } from '../model/UInt64';
-import { IListener } from './IListener';
+import { IListener, OnWsCloseCallback } from './IListener';
 import { MultisigHttp } from './MultisigHttp';
 import { MultisigRepository } from './MultisigRepository';
 import { NamespaceRepository } from './NamespaceRepository';
@@ -109,7 +109,7 @@ export class Listener implements IListener {
      * Open web socket connection.
      * @returns Promise<Void>
      */
-    public open(): Promise<void> {
+    public open(onUnsolicitedCloseCallback?: OnWsCloseCallback): Promise<void> {
         return new Promise((resolve, reject) => {
             if (this.webSocket === undefined || this.webSocket.readyState === this.webSocket.CLOSED) {
                 if (this.websocketInjected) {
@@ -127,11 +127,16 @@ export class Listener implements IListener {
                         return;
                     }
                     if (closeEvent) {
-                        reject({
+                        const event = {
                             client: this.uid,
                             code: closeEvent.code,
                             reason: closeEvent.reason,
-                        });
+                        };
+                        if (onUnsolicitedCloseCallback) {
+                            onUnsolicitedCloseCallback(event);
+                        } else {
+                            reject(event);
+                        }
                     }
                 };
                 this.webSocket.onmessage = (msg: any): void => {