chore: update

packages/cts-api/dist/cjs/api/WsApi.js

@@ -0,0 +1,157 @@
+"use strict";
+var __assign = (this && this.__assign) || function () {
+    __assign = Object.assign || function(t) {
+        for (var s, i = 1, n = arguments.length; i < n; i++) {
+            s = arguments[i];
+            for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
+                t[p] = s[p];
+        }
+        return t;
+    };
+    return __assign.apply(this, arguments);
+};
+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 };
+    }
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+var CmdMsg_1 = require("../protocol/CmdMsg");
+var WsApi = (function () {
+    function WsApi() {
+    }
+    WsApi.prototype.sendMsg = function (msg) {
+        return __awaiter(this, void 0, void 0, function () {
+            return __generator(this, function (_a) {
+                console.log(msg);
+                return [2];
+            });
+        });
+    };
+    WsApi.prototype.sendGetCmdMsg = function (action, extra) {
+        if (extra === void 0) { extra = {}; }
+        return __awaiter(this, void 0, void 0, function () {
+            var msg;
+            return __generator(this, function (_a) {
+                msg = CmdMsg_1.CmdMsg.createMsg(__assign({ from: this.from, action: action }, extra));
+                return [2, this.sendMsg(msg)];
+            });
+        });
+    };
+    WsApi.prototype.sendPostCmdMsg = function (action, userIds, extra) {
+        if (extra === void 0) { extra = {}; }
+        return __awaiter(this, void 0, void 0, function () {
+            var msg;
+            return __generator(this, function (_a) {
+                msg = CmdMsg_1.CmdMsg.createMsg(__assign({ from: this.from, to: (userIds || []).join(','), action: action }, extra));
+                return [2, this.sendMsg(msg)];
+            });
+        });
+    };
+    WsApi.prototype.getRoster = function () {
+        return this.sendGetCmdMsg('getRoster');
+    };
+    WsApi.prototype.addFriends = function (userIds) {
+        return this.sendPostCmdMsg('addFriends', userIds);
+    };
+    WsApi.prototype.agreeFriends = function (userIds) {
+        return this.sendPostCmdMsg('agreeFriends', userIds);
+    };
+    WsApi.prototype.rejectFriends = function (userIds) {
+        return this.sendPostCmdMsg('rejectFriends', userIds);
+    };
+    WsApi.prototype.removeFriends = function (userIds) {
+        return this.sendPostCmdMsg('removeFriends', userIds);
+    };
+    WsApi.prototype.getBlacklist = function () {
+        return this.sendGetCmdMsg('getBlacklist');
+    };
+    WsApi.prototype.addToBlackList = function (userIds) {
+        return this.sendPostCmdMsg('addToBlackList', userIds);
+    };
+    WsApi.prototype.removeBlackList = function (userIds) {
+        return this.sendPostCmdMsg('removeBlackList', userIds);
+    };
+    WsApi.prototype.listGroups = function () {
+        return this.sendGetCmdMsg('listGroups');
+    };
+    WsApi.prototype.queryGroupInfo = function (roomId) {
+        return this.sendGetCmdMsg('queryGroupInfo', { to: roomId });
+    };
+    WsApi.prototype.queryRoomMember = function (roomId) {
+        return this.sendGetCmdMsg('queryRoomMember', { to: roomId });
+    };
+    WsApi.prototype.getGroupBlackList = function (roomId) {
+        return this.sendGetCmdMsg('getGroupBlackList', { to: roomId });
+    };
+    WsApi.prototype.createGroup = function (groupOption) {
+        return this.sendPostCmdMsg('createGroup', null, { ext: groupOption });
+    };
+    WsApi.prototype.changeGroupInfo = function (groupOption) {
+        return this.sendPostCmdMsg('changeGroupInfo', null, { ext: groupOption });
+    };
+    WsApi.prototype.addGroupMembers = function (roomId, userIds) {
+        return this.sendPostCmdMsg('addGroupMembers', [roomId], {
+            ext: {
+                members: userIds
+            }
+        });
+    };
+    WsApi.prototype.addToGroupBlackList = function (roomId, userIds) {
+        return this.sendPostCmdMsg('addToGroupBlackList', [roomId], {
+            ext: {
+                members: userIds
+            }
+        });
+    };
+    WsApi.prototype.destroyGroup = function (roomId) {
+        return this.sendPostCmdMsg('destroyGroup', [roomId]);
+    };
+    WsApi.prototype.leaveGroup = function (roomId) {
+        return this.sendPostCmdMsg('leaveGroup', [roomId]);
+    };
+    WsApi.prototype.createRoom = function (groupOption) {
+        return this.sendPostCmdMsg('createGroup', null, { ext: groupOption });
+    };
+    WsApi.prototype.listRooms = function () {
+        return this.sendGetCmdMsg('listRooms');
+    };
+    WsApi.prototype.joinRoom = function (roomId) {
+        return this.sendPostCmdMsg('joinRoom', [roomId]);
+    };
+    WsApi.prototype.quitRoom = function (roomId) {
+        return this.sendPostCmdMsg('quitRoom', [roomId]);
+    };
+    return WsApi;
+}());
+exports.WsApi = WsApi;

packages/cts-api/dist/cjs/protocol/CmdMsg.js

@@ -0,0 +1,31 @@
+"use strict";
+var __extends = (this && this.__extends) || (function () {
+    var extendStatics = function (d, b) {
+        extendStatics = Object.setPrototypeOf ||
+            ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+        return extendStatics(d, b);
+    };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
+Object.defineProperty(exports, "__esModule", { value: true });
+var MsgBase_1 = require("./MsgBase");
+var CmdMsg = (function (_super) {
+    __extends(CmdMsg, _super);
+    function CmdMsg() {
+        var _this = _super !== null && _super.apply(this, arguments) || this;
+        _this.type = 'cmd';
+        return _this;
+    }
+    CmdMsg.createMsg = function (baseMsg) {
+        var msg = new CmdMsg();
+        Object.assign(msg, baseMsg);
+        return msg;
+    };
+    return CmdMsg;
+}(MsgBase_1.MsgBase));
+exports.CmdMsg = CmdMsg;

packages/cts-api/dist/cjs/protocol/MediaMsg.js

@@ -0,0 +1,55 @@
+"use strict";
+var __extends = (this && this.__extends) || (function () {
+    var extendStatics = function (d, b) {
+        extendStatics = Object.setPrototypeOf ||
+            ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+        return extendStatics(d, b);
+    };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
+var __assign = (this && this.__assign) || function () {
+    __assign = Object.assign || function(t) {
+        for (var s, i = 1, n = arguments.length; i < n; i++) {
+            s = arguments[i];
+            for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
+                t[p] = s[p];
+        }
+        return t;
+    };
+    return __assign.apply(this, arguments);
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+var MsgBase_1 = require("./MsgBase");
+var MediaMsg = (function (_super) {
+    __extends(MediaMsg, _super);
+    function MediaMsg() {
+        var _this = _super !== null && _super.apply(this, arguments) || this;
+        _this.type = 'media';
+        return _this;
+    }
+    MediaMsg.createMsg = function (baseMsg) {
+        var msg = new MediaMsg();
+        Object.assign(msg, baseMsg);
+        return msg;
+    };
+    MediaMsg.createFromClipboard = function (baseMsg, clipboardData) {
+        if (clipboardData && clipboardData.types) {
+            if (clipboardData.items.length > 0) {
+                var blob = clipboardData.items[0].getAsFile();
+                var url = window.URL.createObjectURL(blob);
+                return MediaMsg.createMsg(__assign({}, baseMsg, { file: {
+                        data: blob,
+                        url: url
+                    } }));
+            }
+        }
+        return null;
+    };
+    return MediaMsg;
+}(MsgBase_1.MsgBase));
+exports.MediaMsg = MediaMsg;

packages/cts-api/dist/cjs/protocol/MsgBase.js

@@ -0,0 +1,21 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+var uuid_1 = require("../utils/uuid");
+var MsgBase = (function () {
+    function MsgBase() {
+        this.id = uuid_1.uuid();
+    }
+    MsgBase.prototype.isValid = function () {
+        if (!this.from || !this.to) {
+            return false;
+        }
+        return true;
+    };
+    MsgBase.createMsg = function (baseMsg) {
+        var msg = new MsgBase();
+        Object.assign(msg, baseMsg);
+        return msg;
+    };
+    return MsgBase;
+}());
+exports.MsgBase = MsgBase;

packages/cts-api/dist/cjs/protocol/TextMsg.js

@@ -0,0 +1,31 @@
+"use strict";
+var __extends = (this && this.__extends) || (function () {
+    var extendStatics = function (d, b) {
+        extendStatics = Object.setPrototypeOf ||
+            ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+        return extendStatics(d, b);
+    };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
+Object.defineProperty(exports, "__esModule", { value: true });
+var MsgBase_1 = require("./MsgBase");
+var TextMsg = (function (_super) {
+    __extends(TextMsg, _super);
+    function TextMsg() {
+        var _this = _super !== null && _super.apply(this, arguments) || this;
+        _this.type = 'text';
+        return _this;
+    }
+    TextMsg.createMsg = function (baseMsg) {
+        var msg = new TextMsg();
+        Object.assign(msg, baseMsg);
+        return msg;
+    };
+    return TextMsg;
+}(MsgBase_1.MsgBase));
+exports.TextMsg = TextMsg;

packages/cts-api/dist/cjs/utils/uuid.js

@@ -0,0 +1,4 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+var uuidV1 = require("uuid/v1");
+exports.uuid = uuidV1;

packages/cts-api/dist/types/api/WsApi.d.ts

@@ -0,0 +1,30 @@
+import { MsgBase, GroupOption } from '../protocol/MsgBase';
+export declare class WsApi {
+    token: string;
+    from: string;
+    sendMsg(msg: Partial<MsgBase>): Promise<void>;
+    sendGetCmdMsg(action: string, extra?: {}): Promise<void>;
+    sendPostCmdMsg(action: string, userIds: string[] | null, extra?: {}): Promise<void>;
+    getRoster(): Promise<void>;
+    addFriends(userIds: string[]): Promise<void>;
+    agreeFriends(userIds: string[]): Promise<void>;
+    rejectFriends(userIds: string[]): Promise<void>;
+    removeFriends(userIds: string[]): Promise<void>;
+    getBlacklist(): Promise<void>;
+    addToBlackList(userIds: string[]): Promise<void>;
+    removeBlackList(userIds: string[]): Promise<void>;
+    listGroups(): Promise<void>;
+    queryGroupInfo(roomId: string): Promise<void>;
+    queryRoomMember(roomId: string): Promise<void>;
+    getGroupBlackList(roomId: string): Promise<void>;
+    createGroup(groupOption: GroupOption): Promise<void>;
+    changeGroupInfo(groupOption: GroupOption): Promise<void>;
+    addGroupMembers(roomId: string, userIds: string[]): Promise<void>;
+    addToGroupBlackList(roomId: string, userIds: string[]): Promise<void>;
+    destroyGroup(roomId: string): Promise<void>;
+    leaveGroup(roomId: string): Promise<void>;
+    createRoom(groupOption: GroupOption): Promise<void>;
+    listRooms(): Promise<void>;
+    joinRoom(roomId: string): Promise<void>;
+    quitRoom(roomId: string): Promise<void>;
+}

packages/cts-api/dist/types/protocol/CmdMsg.d.ts

@@ -0,0 +1,7 @@
+import { MsgBase, MsgType } from './MsgBase';
+export declare class CmdMsg extends MsgBase {
+    type: MsgType;
+    msg: string;
+    action: string;
+    static createMsg(baseMsg: Partial<CmdMsg>): CmdMsg;
+}

packages/cts-api/dist/types/protocol/MediaMsg.d.ts

@@ -0,0 +1,10 @@
+import { MsgBase, MsgType } from './MsgBase';
+export declare class MediaMsg extends MsgBase {
+    type: MsgType;
+    file: {
+        data: Blob | null;
+        url: string;
+    };
+    static createMsg(baseMsg: Partial<MediaMsg>): MediaMsg;
+    static createFromClipboard(baseMsg: Partial<MediaMsg>, clipboardData: DataTransfer): MediaMsg | null;
+}

packages/cts-api/dist/types/protocol/MsgBase.d.ts

@@ -0,0 +1,21 @@
+export declare type MsgType = 'text' | 'media' | 'cmd' | 'attachment';
+export declare type RoomType = 'single' | 'room';
+export declare type GroupOption = {
+    subject: string;
+    description: string;
+    members: string[];
+    optionsPublic: boolean;
+    optionsModerate: boolean;
+    optionsMembersOnly: boolean;
+    optionsAllowInvites: boolean;
+};
+export declare class MsgBase {
+    id: string;
+    from: string;
+    to: string;
+    type: MsgType;
+    roomType: RoomType;
+    ext: Record<string, string>;
+    isValid(): boolean;
+    static createMsg(baseMsg: Partial<MsgBase>): MsgBase;
+}

packages/cts-api/dist/types/protocol/TextMsg.d.ts

@@ -0,0 +1,6 @@
+import { MsgBase, MsgType } from './MsgBase';
+export declare class TextMsg extends MsgBase {
+    type: MsgType;
+    msg: string;
+    static createMsg(baseMsg: Partial<TextMsg>): TextMsg;
+}

packages/cts-api/dist/types/utils/uuid.d.ts

@@ -0,0 +1 @@
+export declare const uuid: import("uuid/interfaces").v1;

packages/cts-api/src/api/WsApi.ts

@@ -0,0 +1,158 @@
+import { MsgBase, GroupOption } from '../protocol/MsgBase';
+import { CmdMsg } from '../protocol/CmdMsg';
+
+/** WebSocket Api */
+export class WsApi {
+  // 保存公共的状态信息
+  token: string;
+  from: string;
+
+  async sendMsg(msg: Partial<MsgBase>) {
+    console.log(msg);
+  }
+
+  /** @start 好友管理 */
+  // 通用查询
+  async sendGetCmdMsg(action: string, extra: {} = {}) {
+    const msg = CmdMsg.createMsg({ from: this.from, action, ...extra });
+
+    return this.sendMsg(msg);
+  }
+
+  // 通用操作
+  async sendPostCmdMsg(action: string, userIds: string[] | null, extra: {} = {}) {
+    const msg = CmdMsg.createMsg({
+      from: this.from,
+      to: (userIds || []).join(','),
+      action,
+      ...extra
+    });
+
+    return this.sendMsg(msg);
+  }
+
+  // 查询好友列表
+  getRoster() {
+    return this.sendGetCmdMsg('getRoster');
+  }
+
+  // 添加好友
+  addFriends(userIds: string[]) {
+    return this.sendPostCmdMsg('addFriends', userIds);
+  }
+
+  // 同意好友请求
+  agreeFriends(userIds: string[]) {
+    return this.sendPostCmdMsg('agreeFriends', userIds);
+  }
+
+  // 拒绝好友请求
+  rejectFriends(userIds: string[]) {
+    return this.sendPostCmdMsg('rejectFriends', userIds);
+  }
+
+  // 移除
+  removeFriends(userIds: string[]) {
+    return this.sendPostCmdMsg('removeFriends', userIds);
+  }
+
+  // 获取黑名单列表
+  getBlacklist() {
+    return this.sendGetCmdMsg('getBlacklist');
+  }
+
+  // 加入黑名单
+  addToBlackList(userIds: string[]) {
+    return this.sendPostCmdMsg('addToBlackList', userIds);
+  }
+
+  // 移出黑名单
+  removeBlackList(userIds: string[]) {
+    return this.sendPostCmdMsg('removeBlackList', userIds);
+  }
+
+  /** @end 好友管理 */
+
+  /** @start 群组管理 */
+  // 列出所有的群组
+  listGroups() {
+    return this.sendGetCmdMsg('listGroups');
+  }
+
+  // 获取群组信息
+  queryGroupInfo(roomId: string) {
+    return this.sendGetCmdMsg('queryGroupInfo', { to: roomId });
+  }
+
+  // 查询群组的成员
+  queryRoomMember(roomId: string) {
+    return this.sendGetCmdMsg('queryRoomMember', { to: roomId });
+  }
+
+  // 获取群组黑名单
+  getGroupBlackList(roomId: string) {
+    return this.sendGetCmdMsg('getGroupBlackList', { to: roomId });
+  }
+
+  // 建立群组
+  createGroup(groupOption: GroupOption) {
+    return this.sendPostCmdMsg('createGroup', null, { ext: groupOption });
+  }
+
+  // 更新群组
+  changeGroupInfo(groupOption: GroupOption) {
+    return this.sendPostCmdMsg('changeGroupInfo', null, { ext: groupOption });
+  }
+
+  // 将好友加入群组
+  addGroupMembers(roomId: string, userIds: string[]) {
+    return this.sendPostCmdMsg('addGroupMembers', [roomId], {
+      ext: {
+        members: userIds
+      }
+    });
+  }
+
+  // 将成员踢出群组
+  addToGroupBlackList(roomId: string, userIds: string[]) {
+    return this.sendPostCmdMsg('addToGroupBlackList', [roomId], {
+      ext: {
+        members: userIds
+      }
+    });
+  }
+
+  // 解散群组
+  destroyGroup(roomId: string) {
+    return this.sendPostCmdMsg('destroyGroup', [roomId]);
+  }
+
+  // 退出群组
+  leaveGroup(roomId: string) {
+    return this.sendPostCmdMsg('leaveGroup', [roomId]);
+  }
+
+  /** @end 群组管理 */
+  // 创建聊天室群组
+  createRoom(groupOption: GroupOption) {
+    return this.sendPostCmdMsg('createGroup', null, { ext: groupOption });
+  }
+
+  // 列出所有的聊天室
+  listRooms() {
+    return this.sendGetCmdMsg('listRooms');
+  }
+
+  // 退出聊天室
+  joinRoom(roomId: string) {
+    return this.sendPostCmdMsg('joinRoom', [roomId]);
+  }
+
+  // 退出聊天室
+  quitRoom(roomId: string) {
+    return this.sendPostCmdMsg('quitRoom', [roomId]);
+  }
+
+  /** @start 聊天室管理 */
+  /** @end 聊天室管理 */
+}

packages/cts-api/src/protocol/CmdMsg.ts

@@ -0,0 +1,16 @@
+import { MsgBase, MsgType } from './MsgBase';
+
+export class CmdMsg extends MsgBase {
+  type: MsgType = 'cmd';
+
+  // 消息内容
+  msg: string;
+  // 命令
+  action: string;
+
+  static createMsg(baseMsg: Partial<CmdMsg>): CmdMsg {
+    const msg = new CmdMsg();
+    Object.assign(msg, baseMsg);
+    return msg;
+  }
+}

packages/cts-api/src/protocol/MediaMsg.ts

@@ -0,0 +1,35 @@
+import { MsgBase, MsgType } from './MsgBase';
+
+export class MediaMsg extends MsgBase {
+  type: MsgType = 'media';
+
+  // 消息内容
+  file: { data: Blob | null; url: string };
+
+  // 创建消息
+  static createMsg(baseMsg: Partial<MediaMsg>): MediaMsg {
+    const msg = new MediaMsg();
+    Object.assign(msg, baseMsg);
+    return msg;
+  }
+
+  // 从剪贴板中创建
+  static createFromClipboard(baseMsg: Partial<MediaMsg>, clipboardData: DataTransfer) {
+    if (clipboardData && clipboardData.types) {
+      if (clipboardData.items.length > 0) {
+        const blob = clipboardData.items[0].getAsFile();
+        const url = window.URL.createObjectURL(blob);
+
+        return MediaMsg.createMsg({
+          ...baseMsg,
+          file: {
+            data: blob,
+            url
+          }
+        });
+      }
+    }
+
+    return null;
+  }
+}

packages/cts-api/src/protocol/MsgBase.ts

@@ -0,0 +1,50 @@
+import { uuid } from '../utils/uuid';
+
+export type MsgType = 'text' | 'media' | 'cmd' | 'attachment';
+
+export type RoomType = 'single' | 'room';
+
+export type GroupOption = {
+  subject: string; // 群名称
+  description: string; // 群简介
+  members: string[]; // 成员列表
+  optionsPublic: boolean; // 允许任何人加入
+  optionsModerate: boolean; // 加入需审批
+  optionsMembersOnly: boolean; // 不允许任何人主动加入
+  optionsAllowInvites: boolean; // 允许群人员邀请
+};
+
+export class MsgBase {
+  // 消息编号
+  id: string = uuid();
+
+  // 消息发送方，如果是从多个人发出，则用 , 逗号分隔
+  from: string;
+
+  // 消息接收方/目标方，如果是发送给多个人，则用 , 逗号分隔
+  to: string;
+
+  // 消息类型
+  type: MsgType;
+
+  // 聊天室类型
+  roomType: RoomType;
+
+  // 扩展消息
+  ext: Record<string, string>;
+
+  /** 校验当前消息是否有效 */
+  isValid() {
+    if (!this.from || !this.to) {
+      return false;
+    }
+
+    return true;
+  }
+
+  static createMsg(baseMsg: Partial<MsgBase>): MsgBase {
+    const msg = new MsgBase();
+    Object.assign(msg, baseMsg);
+    return msg;
+  }
+}

packages/cts-api/src/protocol/TextMsg.ts

@@ -0,0 +1,14 @@
+import { MsgBase, MsgType } from './MsgBase';
+
+export class TextMsg extends MsgBase {
+  type: MsgType = 'text';
+
+  // 消息内容
+  msg: string;
+
+  static createMsg(baseMsg: Partial<TextMsg>): TextMsg {
+    const msg = new TextMsg();
+    Object.assign(msg, baseMsg);
+    return msg;
+  }
+}

packages/cts-api/src/utils/uuid.ts

@@ -0,0 +1,3 @@
+import * as uuidV1 from 'uuid/v1';
+
+export const uuid = uuidV1;