add more file

dist/constant.js

@@ -0,0 +1,7 @@
+"use strict";
+exports.__esModule = true;
+// 单个数据包能够传输的最大数据量
+exports.MAX_PAYLOAD = 1024 * 1024;
+// 版本
+exports.VERSION = '1.0';
+//# sourceMappingURL=constant.js.map

dist/constant.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"constant.js","sourceRoot":"","sources":["../src/constant.ts"],"names":[],"mappings":";;AAAA,kBAAkB;AACL,QAAA,WAAW,GAAG,IAAI,GAAG,IAAI,CAAC;AAEvC,KAAK;AACQ,QAAA,OAAO,GAAG,KAAK,CAAC"}

dist/packet.js

@@ -0,0 +1,47 @@
+"use strict";
+exports.__esModule = true;
+var utils_1 = require("./utils");
+var Int64 = require("node-int64");
+var Packet = /** @class */ (function () {
+    function Packet() {
+    }
+    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);
+        var headerLength = header.length;
+        var bodyLength = body.length;
+        var buf = new ArrayBuffer(20 + headerLength + bodyLength);
+        var dataView = new DataView(buf);
+        var nsBuf = new Int64(sequence).toBuffer();
+        dataView.setUint32(0, operator);
+        dataView.setUint32(12, headerLength);
+        dataView.setUint32(16, bodyLength);
+        var bufView = new Uint8Array(buf);
+        for (var i = 0; i < 8; i++) {
+            bufView[4 + i] = nsBuf[i];
+        }
+        for (var i_1 = 0; i_1 < headerLength; i_1++) {
+            bufView[20 + i_1] = header.charCodeAt(i_1);
+        }
+        for (var i_2 = 0; i_2 < bodyLength; i_2++) {
+            bufView[20 + headerLength + i_2] = body.charCodeAt(i_2);
+        }
+        return buf;
+    };
+    Packet.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;
+    };
+    Packet.key = 'b8ca9aa66def05ff3f24919274bb4a66';
+    return Packet;
+}());
+exports.Packet = Packet;
+//# sourceMappingURL=packet.js.map

dist/packet.js.map

@@ -0,0 +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"}

dist/types/constant.d.ts

@@ -0,0 +1,2 @@
+export declare const MAX_PAYLOAD: number;
+export declare const VERSION = "1.0";

dist/types/packet.d.ts

@@ -0,0 +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;
+}

package.json

@@ -9,7 +9,8 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
-    "crypto-js": "^3.1.9-1"
+    "crypto-js": "^3.1.9-1",
+    "node-int64": "^0.4.0"
   },
   "devDependencies": {
     "@types/jest": "^24.0.11",

src/constant.ts

@@ -0,0 +1,5 @@
+// 单个数据包能够传输的最大数据量
+export const MAX_PAYLOAD = 1024 * 1024;
+
+// 版本
+export const VERSION = '1.0';

src/packet.ts

@@ -0,0 +1,68 @@
+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 static 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);
+
+    const headerLength = header.length;
+    const bodyLength = body.length;
+
+    const buf = new ArrayBuffer(20 + headerLength + bodyLength);
+    const dataView = new DataView(buf);
+    const nsBuf = new Int64(sequence).toBuffer();
+
+    dataView.setUint32(0, operator);
+    dataView.setUint32(12, headerLength);
+    dataView.setUint32(16, bodyLength);
+
+    let bufView = new Uint8Array(buf);
+    for (var i = 0; i < 8; i++) {
+      bufView[4 + i] = nsBuf[i];
+    }
+    for (let i = 0; i < headerLength; i++) {
+      bufView[20 + i] = header.charCodeAt(i);
+    }
+
+    for (let i = 0; i < bodyLength; i++) {
+      bufView[20 + headerLength + i] = body.charCodeAt(i);
+    }
+
+    return buf;
+  }
+
+  private static unPack(data: ArrayBuffer): Packet {
+    const 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);
+
+    const header = Utils.ab2str(
+      dataView.buffer.slice(20, 20 + Packet.headerLength),
+    );
+    const body = Utils.ab2str(dataView.buffer.slice(20 + Packet.headerLength));
+
+    Packet.header = Utils.decrypt(header, Packet.key, Packet.key);
+    Packet.body = Utils.decrypt(body, Packet.key, Packet.key);
+
+    return Packet;
+  }
+}