add all file from old js

dist/callback.js

@@ -0,0 +1,3 @@
+"use strict";
+exports.__esModule = true;
+//# sourceMappingURL=callback.js.map

dist/callback.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"callback.js","sourceRoot":"","sources":["../src/callback.ts"],"names":[],"mappings":""}

dist/index.js

@@ -0,0 +1,283 @@
+"use strict";
+var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    return new (P || (P = Promise))(function (resolve, reject) {
+        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
+        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
+        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        step((generator = generator.apply(thisArg, _arguments || [])).next());
+    });
+};
+var __generator = (this && this.__generator) || function (thisArg, body) {
+    var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
+    return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
+    function verb(n) { return function (v) { return step([n, v]); }; }
+    function step(op) {
+        if (f) throw new TypeError("Generator is already executing.");
+        while (_) try {
+            if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
+            if (y = 0, t) op = [op[0] & 2, t.value];
+            switch (op[0]) {
+                case 0: case 1: t = op; break;
+                case 4: _.label++; return { value: op[1], done: false };
+                case 5: _.label++; y = op[1]; op = [0]; continue;
+                case 7: op = _.ops.pop(); _.trys.pop(); continue;
+                default:
+                    if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
+                    if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
+                    if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
+                    if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
+                    if (t[2]) _.ops.pop();
+                    _.trys.pop(); continue;
+            }
+            op = body.call(thisArg, _);
+        } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
+        if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
+    }
+};
+exports.__esModule = true;
+var constant = require("./constant");
+var packet_1 = require("./packet");
+var utils_1 = require("./utils");
+/**
+ * Client ws client, 单例模式, 负责维护连接
+ */
+var Client = /** @class */ (function () {
+    function Client(url, readyStateCallback) {
+        if (!('WebSocket' in window)) {
+            return;
+        }
+        this.requestHeader = '';
+        this.maxPayload = constant.MAX_PAYLOAD;
+        this.url = url;
+        this.readyStateCallback = readyStateCallback;
+        this.reconnectTimes = 0;
+        this.reconnectLock = false;
+        this.socket = this.connect();
+    }
+    // 向服务端发送ping包保持长连接
+    Client.prototype.ping = function (param, callback) {
+        if (param === void 0) { param = {}; }
+        if (callback === void 0) { callback = {}; }
+        if (typeof callback !== 'object') {
+            throw new Error('callback must be an object');
+        }
+        if (this.socket.readyState !== this.socket.OPEN) {
+            throw new Error('asyncSend: connection refuse');
+        }
+        var _this = this;
+        this.addMessageListener(0, function (data) {
+            var code = _this.getResponseProperty('code');
+            if (typeof code !== 'undefined') {
+                var message = _this.getResponseProperty('message');
+                if (this.callback.onError !== null) {
+                    this.callback.onError(code, message);
+                }
+            }
+            else {
+                this.callback.onSuccess(data);
+            }
+            this.callback.onEnd();
+        });
+        var p = new packet_1.Packet();
+        _this.send(p.pack(0, 0, _this.requestHeader, JSON.stringify(param)));
+    };
+    Client.prototype.send = function (data) {
+        if (this.socket.readyState !== this.socket.OPEN) {
+            console.error('WebSocket is already in CLOSING or CLOSED state.');
+            return;
+        }
+        try {
+            this.socket.send(data);
+        }
+        catch (e) {
+            console.log('send data error', e);
+        }
+    };
+    /**
+     * asyncSend
+     * @param {*} operator
+     * @param {*} param
+     * @param {*} callback 仅此次有效的callback
+     */
+    Client.prototype.asyncSend = function (operator, param, callback) {
+        console.info('websocket send data', operator, this.requestHeader, param);
+        if (typeof callback !== 'object') {
+            throw new Error('callback must be an object');
+        }
+        if (this.socket.readyState !== this.socket.OPEN) {
+            throw new Error('asyncSend: connection refuse');
+        }
+        if (callback.hasOwnProperty('onStart') &&
+            typeof callback.onStart === 'function') {
+            callback.onStart();
+        }
+        var _this = this;
+        var sequence = new Date().getTime();
+        var listener = utils_1.Utils.crc32(operator) + sequence;
+        this.callback[listener] = function (data) {
+            var code = _this.getResponseProperty('code');
+            if (typeof code !== 'undefined') {
+                var message = _this.getResponseProperty('message');
+                if (callback.hasOwnProperty('onError') &&
+                    typeof callback.onError === 'function') {
+                    callback.onError(code, message);
+                }
+            }
+            else {
+                if (callback.hasOwnProperty('onSuccess') &&
+                    typeof callback.onSuccess === 'function') {
+                    callback.onSuccess(data);
+                }
+            }
+            if (callback.hasOwnProperty('onEnd') &&
+                typeof callback.onEnd === 'function') {
+                callback.onEnd();
+            }
+            delete _this.callback[listener];
+        };
+        var p = new packet_1.Packet();
+        this.send(p.pack(utils_1.Utils.crc32(operator), sequence, this.requestHeader, JSON.stringify(param)));
+    };
+    // 同步请求服务端数据
+    Client.prototype.syncSend = function (operator, param, callback) {
+        return __awaiter(this, void 0, void 0, function () {
+            return __generator(this, function (_a) {
+                switch (_a.label) {
+                    case 0: return [4 /*yield*/, this.asyncSend(operator, param, callback)];
+                    case 1:
+                        _a.sent();
+                        return [2 /*return*/];
+                }
+            });
+        });
+    };
+    // 添加消息监听
+    Client.prototype.addMessageListener = function (operator, listener) {
+        this.callback[utils_1.Utils.crc32(operator)] = listener;
+    };
+    // 移除消息监听
+    Client.prototype.removeMessageListener = function (operator) {
+        delete this.callback[utils_1.Utils.crc32(operator)];
+    };
+    // 获取socket的链接状态
+    Client.prototype.getReadyState = function () {
+        return this.socket.readyState;
+    };
+    // 设置单个请求能够处理的最大字节数
+    Client.prototype.setMaxPayload = function (maxPayload) {
+        this.maxPayload = maxPayload;
+    };
+    // 设置请求属性
+    Client.prototype.setRequestProperty = function (key, value) {
+        var v = this.getRequestProperty(key);
+        this.requestHeader = this.requestHeader.replace(key + '=' + v + ';', '');
+        this.requestHeader = this.requestHeader + key + '=' + value + ';';
+    };
+    // 获取请求属性
+    Client.prototype.getRequestProperty = function (key) {
+        var values = this.requestHeader.split(';');
+        for (var index in values) {
+            var kv = values[index].split('=');
+            if (kv[0] === key) {
+                return kv[1];
+            }
+        }
+    };
+    // 设置Response属性
+    Client.prototype.setResponseProperty = function (key, value) {
+        var v = this.getResponseProperty(key);
+        this.responseHeader = this.responseHeader.replace(key + '=' + v + ';', '');
+        this.responseHeader = this.responseHeader + key + '=' + value + ';';
+    };
+    // 获取响应属性
+    Client.prototype.getResponseProperty = function (key) {
+        var values = this.responseHeader.split(';');
+        for (var index in values) {
+            var kv = values[index].split('=');
+            if (kv[0] === key) {
+                return kv[1];
+            }
+        }
+    };
+    // 创建连接
+    Client.prototype.connect = function () {
+        var url = this.url;
+        var readyStateCallback = this.readyStateCallback;
+        var ws = new WebSocket(url);
+        var _this = this;
+        ws.binaryType = 'blob';
+        ws.onopen = function (ev) {
+            console.info('websocket connected');
+            _this.reconnectTimes = 0;
+            if (readyStateCallback.hasOwnProperty('onopen') &&
+                typeof readyStateCallback.onopen === 'function') {
+                readyStateCallback.onopen(ev);
+            }
+        };
+        ws.onclose = function (ev) {
+            console.info('websocket disconnected');
+            _this.reconnect();
+            if (readyStateCallback.hasOwnProperty('onclose') &&
+                typeof readyStateCallback.onclose === 'function') {
+                readyStateCallback.onclose(ev);
+            }
+        };
+        ws.onerror = function (ev) {
+            console.info('websocket error disconnected');
+            _this.reconnect();
+            if (readyStateCallback.hasOwnProperty('onerror') &&
+                typeof readyStateCallback.onerror === 'function') {
+                readyStateCallback.onerror(ev);
+            }
+        };
+        ws.onmessage = function (ev) {
+            if (ev.data instanceof Blob) {
+                var reader = new FileReader();
+                reader.readAsArrayBuffer(ev.data);
+                reader.onload = function () {
+                    try {
+                        var packet = new packet_1.Packet().unPack(this.result);
+                        var packetLength = packet.headerLength + packet.bodyLength + 20;
+                        if (packetLength > constant.MAX_PAYLOAD) {
+                            throw new Error('the packet is big than ' + constant.MAX_PAYLOAD);
+                        }
+                        var operator = Number(packet.operator) + Number(packet.sequence);
+                        if (_this.callback.hasOwnProperty(operator)) {
+                            if (packet.body === '') {
+                                packet.body = '{}';
+                            }
+                            _this.responseHeader = packet.header;
+                            _this.callback[operator](JSON.parse(packet.body));
+                        }
+                        if (operator !== 0 && packet.body !== 'null') {
+                            console.info('receive data', packet.body);
+                        }
+                    }
+                    catch (e) {
+                        console.info(e);
+                        throw new Error(e);
+                    }
+                };
+            }
+            else {
+                throw new Error('websocket unsupported data format');
+            }
+        };
+        return ws;
+    };
+    Client.prototype.reconnect = function () {
+        var _this_1 = this;
+        if (!this.reconnectLock) {
+            this.reconnectLock = true;
+            console.info('websocket reconnect in ' + this.reconnectTimes + 's');
+            // 尝试重连
+            setTimeout(function () {
+                _this_1.reconnectTimes++;
+                _this_1.socket = _this_1.connect();
+                _this_1.reconnectLock = false;
+            }, this.reconnectTimes * 1000);
+        }
+    };
+    return Client;
+}());
+//# sourceMappingURL=index.js.map

dist/packet.js

@@ -4,10 +4,11 @@ var utils_1 = require("./utils");
 var Int64 = require("node-int64");
 var Packet = /** @class */ (function () {
     function Packet() {
+        this.key = 'b8ca9aa66def05ff3f24919274bb4a66';
     }
-    Packet.pack = function (operator, sequence, header, body) {
-        var header = utils_1.Utils.encrypt(header, Packet.key, Packet.key);
-        var body = utils_1.Utils.encrypt(body, Packet.key, Packet.key);
+    Packet.prototype.pack = function (operator, sequence, header, body) {
+        header = utils_1.Utils.encrypt(header, this.key, this.key);
+        body = utils_1.Utils.encrypt(body, this.key, this.key);
         var headerLength = header.length;
         var bodyLength = body.length;
         var buf = new ArrayBuffer(20 + headerLength + bodyLength);
@@ -28,19 +29,18 @@ var Packet = /** @class */ (function () {
         }
         return buf;
     };
-    Packet.unPack = function (data) {
+    Packet.prototype.unPack = function (data) {
         var dataView = new DataView(data);
-        Packet.operator = dataView.getUint32(0, false);
-        Packet.sequence = new Int64(new Uint8Array(dataView.buffer.slice(4, 12))).toNumber();
-        Packet.headerLength = dataView.getUint32(12, false);
-        Packet.bodyLength = dataView.getUint32(16, false);
-        var header = utils_1.Utils.ab2str(dataView.buffer.slice(20, 20 + Packet.headerLength));
-        var body = utils_1.Utils.ab2str(dataView.buffer.slice(20 + Packet.headerLength));
-        Packet.header = utils_1.Utils.decrypt(header, Packet.key, Packet.key);
-        Packet.body = utils_1.Utils.decrypt(body, Packet.key, Packet.key);
-        return Packet;
+        this.operator = dataView.getUint32(0, false);
+        this.sequence = new Int64(new Uint8Array(dataView.buffer.slice(4, 12))).toNumber();
+        this.headerLength = dataView.getUint32(12, false);
+        this.bodyLength = dataView.getUint32(16, false);
+        var header = utils_1.Utils.ab2str(dataView.buffer.slice(20, 20 + this.headerLength));
+        var body = utils_1.Utils.ab2str(dataView.buffer.slice(20 + this.headerLength));
+        this.header = utils_1.Utils.decrypt(header, this.key, this.key);
+        this.body = utils_1.Utils.decrypt(body, this.key, this.key);
+        return this;
     };
-    Packet.key = 'b8ca9aa66def05ff3f24919274bb4a66';
     return Packet;
 }());
 exports.Packet = Packet;

dist/packet.js.map

@@ -1 +1 @@
-{"version":3,"file":"packet.js","sourceRoot":"","sources":["../src/packet.ts"],"names":[],"mappings":";;AAAA,iCAAgC;AAChC,kCAAoC;AAEpC;IAAA;IAgEA,CAAC;IAvDgB,WAAI,GAAnB,UACE,QAAgB,EAChB,QAAgB,EAChB,MAAc,EACd,IAAY;QAEZ,IAAM,MAAM,GAAG,aAAK,CAAC,OAAO,CAAC,MAAM,EAAE,MAAM,CAAC,GAAG,EAAE,MAAM,CAAC,GAAG,CAAC,CAAC;QAC7D,IAAM,IAAI,GAAG,aAAK,CAAC,OAAO,CAAC,IAAI,EAAE,MAAM,CAAC,GAAG,EAAE,MAAM,CAAC,GAAG,CAAC,CAAC;QAEzD,IAAM,YAAY,GAAG,MAAM,CAAC,MAAM,CAAC;QACnC,IAAM,UAAU,GAAG,IAAI,CAAC,MAAM,CAAC;QAE/B,IAAM,GAAG,GAAG,IAAI,WAAW,CAAC,EAAE,GAAG,YAAY,GAAG,UAAU,CAAC,CAAC;QAC5D,IAAM,QAAQ,GAAG,IAAI,QAAQ,CAAC,GAAG,CAAC,CAAC;QACnC,IAAM,KAAK,GAAG,IAAI,KAAK,CAAC,QAAQ,CAAC,CAAC,QAAQ,EAAE,CAAC;QAE7C,QAAQ,CAAC,SAAS,CAAC,CAAC,EAAE,QAAQ,CAAC,CAAC;QAChC,QAAQ,CAAC,SAAS,CAAC,EAAE,EAAE,YAAY,CAAC,CAAC;QACrC,QAAQ,CAAC,SAAS,CAAC,EAAE,EAAE,UAAU,CAAC,CAAC;QAEnC,IAAI,OAAO,GAAG,IAAI,UAAU,CAAC,GAAG,CAAC,CAAC;QAClC,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,CAAC,EAAE,CAAC,EAAE,EAAE;YAC1B,OAAO,CAAC,CAAC,GAAG,CAAC,CAAC,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC;SAC3B;QACD,KAAK,IAAI,GAAC,GAAG,CAAC,EAAE,GAAC,GAAG,YAAY,EAAE,GAAC,EAAE,EAAE;YACrC,OAAO,CAAC,EAAE,GAAG,GAAC,CAAC,GAAG,MAAM,CAAC,UAAU,CAAC,GAAC,CAAC,CAAC;SACxC;QAED,KAAK,IAAI,GAAC,GAAG,CAAC,EAAE,GAAC,GAAG,UAAU,EAAE,GAAC,EAAE,EAAE;YACnC,OAAO,CAAC,EAAE,GAAG,YAAY,GAAG,GAAC,CAAC,GAAG,IAAI,CAAC,UAAU,CAAC,GAAC,CAAC,CAAC;SACrD;QAED,OAAO,GAAG,CAAC;IACb,CAAC;IAEc,aAAM,GAArB,UAAsB,IAAiB;QACrC,IAAM,QAAQ,GAAG,IAAI,QAAQ,CAAC,IAAI,CAAC,CAAC;QAEpC,MAAM,CAAC,QAAQ,GAAG,QAAQ,CAAC,SAAS,CAAC,CAAC,EAAE,KAAK,CAAC,CAAC;QAC/C,MAAM,CAAC,QAAQ,GAAG,IAAI,KAAK,CACzB,IAAI,UAAU,CAAC,QAAQ,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAC7C,CAAC,QAAQ,EAAE,CAAC;QACb,MAAM,CAAC,YAAY,GAAG,QAAQ,CAAC,SAAS,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC;QACpD,MAAM,CAAC,UAAU,GAAG,QAAQ,CAAC,SAAS,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC;QAElD,IAAM,MAAM,GAAG,aAAK,CAAC,MAAM,CACzB,QAAQ,CAAC,MAAM,CAAC,KAAK,CAAC,EAAE,EAAE,EAAE,GAAG,MAAM,CAAC,YAAY,CAAC,CACpD,CAAC;QACF,IAAM,IAAI,GAAG,aAAK,CAAC,MAAM,CAAC,QAAQ,CAAC,MAAM,CAAC,KAAK,CAAC,EAAE,GAAG,MAAM,CAAC,YAAY,CAAC,CAAC,CAAC;QAE3E,MAAM,CAAC,MAAM,GAAG,aAAK,CAAC,OAAO,CAAC,MAAM,EAAE,MAAM,CAAC,GAAG,EAAE,MAAM,CAAC,GAAG,CAAC,CAAC;QAC9D,MAAM,CAAC,IAAI,GAAG,aAAK,CAAC,OAAO,CAAC,IAAI,EAAE,MAAM,CAAC,GAAG,EAAE,MAAM,CAAC,GAAG,CAAC,CAAC;QAE1D,OAAO,MAAM,CAAC;IAChB,CAAC;IA9Dc,UAAG,GAAG,kCAAkC,CAAC;IA+D1D,aAAC;CAAA,AAhED,IAgEC;AAhEY,wBAAM"}
+{"version":3,"file":"packet.js","sourceRoot":"","sources":["../src/packet.ts"],"names":[],"mappings":";;AAAA,iCAAgC;AAChC,kCAAoC;AAEpC;IAAA;QACU,QAAG,GAAW,kCAAkC,CAAC;IA+D3D,CAAC;IAvDQ,qBAAI,GAAX,UACE,QAAgB,EAChB,QAAgB,EAChB,MAAc,EACd,IAAY;QAEZ,MAAM,GAAG,aAAK,CAAC,OAAO,CAAC,MAAM,EAAE,IAAI,CAAC,GAAG,EAAE,IAAI,CAAC,GAAG,CAAC,CAAC;QACnD,IAAI,GAAG,aAAK,CAAC,OAAO,CAAC,IAAI,EAAE,IAAI,CAAC,GAAG,EAAE,IAAI,CAAC,GAAG,CAAC,CAAC;QAE/C,IAAM,YAAY,GAAG,MAAM,CAAC,MAAM,CAAC;QACnC,IAAM,UAAU,GAAG,IAAI,CAAC,MAAM,CAAC;QAE/B,IAAM,GAAG,GAAG,IAAI,WAAW,CAAC,EAAE,GAAG,YAAY,GAAG,UAAU,CAAC,CAAC;QAC5D,IAAM,QAAQ,GAAG,IAAI,QAAQ,CAAC,GAAG,CAAC,CAAC;QACnC,IAAM,KAAK,GAAG,IAAI,KAAK,CAAC,QAAQ,CAAC,CAAC,QAAQ,EAAE,CAAC;QAE7C,QAAQ,CAAC,SAAS,CAAC,CAAC,EAAE,QAAQ,CAAC,CAAC;QAChC,QAAQ,CAAC,SAAS,CAAC,EAAE,EAAE,YAAY,CAAC,CAAC;QACrC,QAAQ,CAAC,SAAS,CAAC,EAAE,EAAE,UAAU,CAAC,CAAC;QAEnC,IAAI,OAAO,GAAG,IAAI,UAAU,CAAC,GAAG,CAAC,CAAC;QAClC,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,CAAC,EAAE,CAAC,EAAE,EAAE;YAC1B,OAAO,CAAC,CAAC,GAAG,CAAC,CAAC,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC;SAC3B;QACD,KAAK,IAAI,GAAC,GAAG,CAAC,EAAE,GAAC,GAAG,YAAY,EAAE,GAAC,EAAE,EAAE;YACrC,OAAO,CAAC,EAAE,GAAG,GAAC,CAAC,GAAG,MAAM,CAAC,UAAU,CAAC,GAAC,CAAC,CAAC;SACxC;QAED,KAAK,IAAI,GAAC,GAAG,CAAC,EAAE,GAAC,GAAG,UAAU,EAAE,GAAC,EAAE,EAAE;YACnC,OAAO,CAAC,EAAE,GAAG,YAAY,GAAG,GAAC,CAAC,GAAG,IAAI,CAAC,UAAU,CAAC,GAAC,CAAC,CAAC;SACrD;QAED,OAAO,GAAG,CAAC;IACb,CAAC;IAEM,uBAAM,GAAb,UAAc,IAAS;QACrB,IAAM,QAAQ,GAAG,IAAI,QAAQ,CAAC,IAAI,CAAC,CAAC;QAEpC,IAAI,CAAC,QAAQ,GAAG,QAAQ,CAAC,SAAS,CAAC,CAAC,EAAE,KAAK,CAAC,CAAC;QAC7C,IAAI,CAAC,QAAQ,GAAG,IAAI,KAAK,CACvB,IAAI,UAAU,CAAC,QAAQ,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAC7C,CAAC,QAAQ,EAAE,CAAC;QACb,IAAI,CAAC,YAAY,GAAG,QAAQ,CAAC,SAAS,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC;QAClD,IAAI,CAAC,UAAU,GAAG,QAAQ,CAAC,SAAS,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC;QAEhD,IAAM,MAAM,GAAG,aAAK,CAAC,MAAM,CACzB,QAAQ,CAAC,MAAM,CAAC,KAAK,CAAC,EAAE,EAAE,EAAE,GAAG,IAAI,CAAC,YAAY,CAAC,CAClD,CAAC;QACF,IAAM,IAAI,GAAG,aAAK,CAAC,MAAM,CAAC,QAAQ,CAAC,MAAM,CAAC,KAAK,CAAC,EAAE,GAAG,IAAI,CAAC,YAAY,CAAC,CAAC,CAAC;QAEzE,IAAI,CAAC,MAAM,GAAG,aAAK,CAAC,OAAO,CAAC,MAAM,EAAE,IAAI,CAAC,GAAG,EAAE,IAAI,CAAC,GAAG,CAAC,CAAC;QACxD,IAAI,CAAC,IAAI,GAAG,aAAK,CAAC,OAAO,CAAC,IAAI,EAAE,IAAI,CAAC,GAAG,EAAE,IAAI,CAAC,GAAG,CAAC,CAAC;QAEpD,OAAO,IAAI,CAAC;IACd,CAAC;IACH,aAAC;AAAD,CAAC,AAhED,IAgEC;AAhEY,wBAAM"}

dist/types/callback.d.ts

@@ -0,0 +1,11 @@
+export interface readyStateCallback {
+    onopen(ev: Event): any;
+    onerror(ev: Event): any;
+    onclose(ev: Event): any;
+}
+export interface callback {
+    onStart(): any;
+    onSuccess(data: string): any;
+    onError(code: number, message: string): any;
+    onEnd(): any;
+}

dist/types/index.d.ts

@@ -0,0 +1 @@
+export {};

dist/types/packet.d.ts

@@ -1,11 +1,11 @@
 export declare class Packet {
-    private static key;
-    private static operator;
-    private static sequence;
-    private static headerLength;
-    private static bodyLength;
-    private static header;
-    private static body;
-    private static pack;
-    private static unPack;
+    private key;
+    operator: number;
+    sequence: number;
+    headerLength: number;
+    bodyLength: number;
+    header: string;
+    body: string;
+    pack(operator: number, sequence: number, header: string, body: string): ArrayBuffer;
+    unPack(data: any): Packet;
 }

src/callback.ts

@@ -0,0 +1,12 @@
+export interface readyStateCallback {
+  onopen(ev: Event);
+  onerror(ev: Event);
+  onclose(ev: Event);
+}
+
+export interface callback {
+  onStart();
+  onSuccess(data: string);
+  onError(code: number, message: string);
+  onEnd();
+}

src/index.ts

@@ -0,0 +1,297 @@
+import * as constant from './constant';
+import { readyStateCallback, callback } from './callback';
+import { Packet } from './packet';
+import { Utils } from './utils';
+
+/**
+ * Client ws client, 单例模式, 负责维护连接
+ */
+class Client {
+  public callback: callback;
+  public requestHeader: string;
+  public responseHeader: string;
+  public maxPayload: number;
+  public url: string;
+  public reconnectTimes: number;
+  public reconnectLock: boolean;
+  public socket: WebSocket;
+  public readyStateCallback: readyStateCallback;
+
+  constructor(url: string, readyStateCallback: readyStateCallback) {
+    if (!('WebSocket' in window)) {
+      return;
+    }
+
+    this.requestHeader = '';
+    this.maxPayload = constant.MAX_PAYLOAD;
+    this.url = url;
+    this.readyStateCallback = readyStateCallback;
+    this.reconnectTimes = 0;
+    this.reconnectLock = false;
+
+    this.socket = this.connect();
+  }
+
+  // 向服务端发送ping包保持长连接
+  ping(param = {}, callback = {}) {
+    if (typeof callback !== 'object') {
+      throw new Error('callback must be an object');
+    }
+
+    if (this.socket.readyState !== this.socket.OPEN) {
+      throw new Error('asyncSend: connection refuse');
+    }
+
+    let _this = this;
+    this.addMessageListener(0, function(data) {
+      let code = _this.getResponseProperty('code');
+      if (typeof code !== 'undefined') {
+        let message = _this.getResponseProperty('message');
+        if (this.callback.onError !== null) {
+          this.callback.onError(code, message);
+        }
+      } else {
+        this.callback.onSuccess(data);
+      }
+
+      this.callback.onEnd();
+    });
+
+    const p = new Packet();
+    _this.send(p.pack(0, 0, _this.requestHeader, JSON.stringify(param)));
+  }
+
+  send(data) {
+    if (this.socket.readyState !== this.socket.OPEN) {
+      console.error('WebSocket is already in CLOSING or CLOSED state.');
+      return;
+    }
+    try {
+      this.socket.send(data);
+    } catch (e) {
+      console.log('send data error', e);
+    }
+  }
+
+  /**
+   * asyncSend
+   * @param {*} operator
+   * @param {*} param
+   * @param {*} callback 仅此次有效的callback
+   */
+  asyncSend(operator, param, callback) {
+    console.info('websocket send data', operator, this.requestHeader, param);
+
+    if (typeof callback !== 'object') {
+      throw new Error('callback must be an object');
+    }
+
+    if (this.socket.readyState !== this.socket.OPEN) {
+      throw new Error('asyncSend: connection refuse');
+    }
+
+    if (
+      callback.hasOwnProperty('onStart') &&
+      typeof callback.onStart === 'function'
+    ) {
+      callback.onStart();
+    }
+
+    let _this = this;
+    let sequence = new Date().getTime();
+    let listener = Utils.crc32(operator) + sequence;
+    this.callback[listener] = function(data) {
+      let code = _this.getResponseProperty('code');
+      if (typeof code !== 'undefined') {
+        let message = _this.getResponseProperty('message');
+        if (
+          callback.hasOwnProperty('onError') &&
+          typeof callback.onError === 'function'
+        ) {
+          callback.onError(code, message);
+        }
+      } else {
+        if (
+          callback.hasOwnProperty('onSuccess') &&
+          typeof callback.onSuccess === 'function'
+        ) {
+          callback.onSuccess(data);
+        }
+      }
+
+      if (
+        callback.hasOwnProperty('onEnd') &&
+        typeof callback.onEnd === 'function'
+      ) {
+        callback.onEnd();
+      }
+
+      delete _this.callback[listener];
+    };
+
+    const p = new Packet();
+    this.send(
+      p.pack(
+        Utils.crc32(operator),
+        sequence,
+        this.requestHeader,
+        JSON.stringify(param),
+      ),
+    );
+  }
+
+  // 同步请求服务端数据
+  async syncSend(operator, param, callback) {
+    await this.asyncSend(operator, param, callback);
+  }
+
+  // 添加消息监听
+  addMessageListener(operator, listener) {
+    this.callback[Utils.crc32(operator)] = listener;
+  }
+
+  // 移除消息监听
+  removeMessageListener(operator) {
+    delete this.callback[Utils.crc32(operator)];
+  }
+
+  // 获取socket的链接状态
+  getReadyState() {
+    return this.socket.readyState;
+  }
+
+  // 设置单个请求能够处理的最大字节数
+  setMaxPayload(maxPayload) {
+    this.maxPayload = maxPayload;
+  }
+
+  // 设置请求属性
+  setRequestProperty(key, value) {
+    let v = this.getRequestProperty(key);
+
+    this.requestHeader = this.requestHeader.replace(key + '=' + v + ';', '');
+    this.requestHeader = this.requestHeader + key + '=' + value + ';';
+  }
+
+  // 获取请求属性
+  getRequestProperty(key) {
+    let values = this.requestHeader.split(';');
+    for (let index in values) {
+      let kv = values[index].split('=');
+      if (kv[0] === key) {
+        return kv[1];
+      }
+    }
+  }
+
+  // 设置Response属性
+  setResponseProperty(key, value) {
+    let v = this.getResponseProperty(key);
+
+    this.responseHeader = this.responseHeader.replace(key + '=' + v + ';', '');
+    this.responseHeader = this.responseHeader + key + '=' + value + ';';
+  }
+
+  // 获取响应属性
+  getResponseProperty(key) {
+    let values = this.responseHeader.split(';');
+    for (let index in values) {
+      let kv = values[index].split('=');
+      if (kv[0] === key) {
+        return kv[1];
+      }
+    }
+  }
+
+  // 创建连接
+  connect() {
+    const url = this.url;
+    const readyStateCallback = this.readyStateCallback;
+
+    let ws = new WebSocket(url);
+    let _this = this;
+
+    ws.binaryType = 'blob';
+
+    ws.onopen = function(ev) {
+      console.info('websocket connected');
+      _this.reconnectTimes = 0;
+      if (
+        readyStateCallback.hasOwnProperty('onopen') &&
+        typeof readyStateCallback.onopen === 'function'
+      ) {
+        readyStateCallback.onopen(ev);
+      }
+    };
+
+    ws.onclose = function(ev) {
+      console.info('websocket disconnected');
+      _this.reconnect();
+      if (
+        readyStateCallback.hasOwnProperty('onclose') &&
+        typeof readyStateCallback.onclose === 'function'
+      ) {
+        readyStateCallback.onclose(ev);
+      }
+    };
+
+    ws.onerror = function(ev) {
+      console.info('websocket error disconnected');
+      _this.reconnect();
+      if (
+        readyStateCallback.hasOwnProperty('onerror') &&
+        typeof readyStateCallback.onerror === 'function'
+      ) {
+        readyStateCallback.onerror(ev);
+      }
+    };
+
+    ws.onmessage = function(ev) {
+      if (ev.data instanceof Blob) {
+        let reader = new FileReader();
+        reader.readAsArrayBuffer(ev.data);
+        reader.onload = function() {
+          try {
+            let packet = new Packet().unPack(this.result);
+            let packetLength = packet.headerLength + packet.bodyLength + 20;
+            if (packetLength > constant.MAX_PAYLOAD) {
+              throw new Error('the packet is big than ' + constant.MAX_PAYLOAD);
+            }
+
+            let operator = Number(packet.operator) + Number(packet.sequence);
+            if (_this.callback.hasOwnProperty(operator)) {
+              if (packet.body === '') {
+                packet.body = '{}';
+              }
+              _this.responseHeader = packet.header;
+              _this.callback[operator](JSON.parse(packet.body));
+            }
+            if (operator !== 0 && packet.body !== 'null') {
+              console.info('receive data', packet.body);
+            }
+          } catch (e) {
+            console.info(e);
+            throw new Error(e);
+          }
+        };
+      } else {
+        throw new Error('websocket unsupported data format');
+      }
+    };
+
+    return ws;
+  }
+
+  reconnect() {
+    if (!this.reconnectLock) {
+      this.reconnectLock = true;
+      console.info('websocket reconnect in ' + this.reconnectTimes + 's');
+      // 尝试重连
+      setTimeout(() => {
+        this.reconnectTimes++;
+        this.socket = this.connect();
+        this.reconnectLock = false;
+      }, this.reconnectTimes * 1000);
+    }
+  }
+}

src/packet.ts

@@ -2,22 +2,22 @@ import { Utils } from './utils';
 import * as Int64 from 'node-int64';
 
 export class Packet {
-  private static key = 'b8ca9aa66def05ff3f24919274bb4a66';
-  private static operator: number;
-  private static sequence: number;
-  private static headerLength: number;
-  private static bodyLength: number;
-  private static header: string;
-  private static body: string;
+  private key: string = 'b8ca9aa66def05ff3f24919274bb4a66';
+  public operator: number;
+  public sequence: number;
+  public headerLength: number;
+  public bodyLength: number;
+  public header: string;
+  public body: string;
 
-  private static pack(
+  public pack(
     operator: number,
     sequence: number,
     header: string,
     body: string,
   ): ArrayBuffer {
-    const header = Utils.encrypt(header, Packet.key, Packet.key);
-    const body = Utils.encrypt(body, Packet.key, Packet.key);
+    header = Utils.encrypt(header, this.key, this.key);
+    body = Utils.encrypt(body, this.key, this.key);
 
     const headerLength = header.length;
     const bodyLength = body.length;
@@ -45,24 +45,24 @@ export class Packet {
     return buf;
   }
 
-  private static unPack(data: ArrayBuffer): Packet {
+  public unPack(data: any): Packet {
     const dataView = new DataView(data);
 
-    Packet.operator = dataView.getUint32(0, false);
-    Packet.sequence = new Int64(
+    this.operator = dataView.getUint32(0, false);
+    this.sequence = new Int64(
       new Uint8Array(dataView.buffer.slice(4, 12)),
     ).toNumber();
-    Packet.headerLength = dataView.getUint32(12, false);
-    Packet.bodyLength = dataView.getUint32(16, false);
+    this.headerLength = dataView.getUint32(12, false);
+    this.bodyLength = dataView.getUint32(16, false);
 
     const header = Utils.ab2str(
-      dataView.buffer.slice(20, 20 + Packet.headerLength),
+      dataView.buffer.slice(20, 20 + this.headerLength),
     );
-    const body = Utils.ab2str(dataView.buffer.slice(20 + Packet.headerLength));
+    const body = Utils.ab2str(dataView.buffer.slice(20 + this.headerLength));
 
-    Packet.header = Utils.decrypt(header, Packet.key, Packet.key);
-    Packet.body = Utils.decrypt(body, Packet.key, Packet.key);
+    this.header = Utils.decrypt(header, this.key, this.key);
+    this.body = Utils.decrypt(body, this.key, this.key);
 
-    return Packet;
+    return this;
   }
 }