v0.4.0

Signed-off-by: MiaoWoo <admin@yumc.pw>

lerna.json

@@ -1,5 +1,5 @@
 {
-    "version": "0.3.2",
+    "version": "0.4.0",
     "useWorkspaces": true,
     "npmClient": "yarn",
     "packages": [

package.json

@@ -8,8 +8,8 @@
     "scripts": {
         "bs": "lerna bootstrap",
         "clean": "lerna run clean",
-        "watch": "lerna run watch --parallel --scope=\"@ms/!(manager)\"",
-        "build": "lerna run build --scope=\"@ms/!(plugins|manager)\"",
+        "watch": "lerna run watch --parallel",
+        "build": "lerna run build --scope=\"@ms/!(plugins)\"",
         "build:plugins": "lerna run build --scope=\"@ms/plugins\"",
         "ug": "yarn upgrade-interactive --latest",
         "lp": "lerna publish"

packages/api/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ms/api",
-    "version": "0.3.2",
+    "version": "0.4.0",
     "description": "MiaoScript api package",
     "keywords": [
         "miaoscript",
@@ -22,8 +22,8 @@
         "test": "echo \"Error: run tests from root\" && exit 1"
     },
     "dependencies": {
-        "@ms/container": "^0.3.2",
-        "@ms/ployfill": "^0.3.1",
+        "@ms/container": "^0.4.0",
+        "@ms/ployfill": "^0.4.0",
         "source-map-builder": "^0.0.7"
     },
     "devDependencies": {

packages/api/src/channel.ts

@@ -10,7 +10,12 @@ export namespace channel {
     @injectable()
     export abstract class Channel {
         private listenerMap = [];
-
+        /**
+         * 注册通道
+         * @param plugin 插件
+         * @param channel 通道
+         * @param exec 执行器
+         */
         listen(plugin: any, channel: string, exec: ChannelListener) {
             if (!plugin || !plugin.description || !plugin.description.name) throw new TypeError('Plugin can\'t be undefiend!');
             let name = plugin.description.name;
@@ -29,6 +34,10 @@ export namespace channel {
             console.debug(`[${name}] register channel ${channel} => ${exec.name || '[anonymous]'}`);
             return off;
         }
+        /**
+         * 关闭插件注册的通道
+         * @param plugin 插件
+         */
         disable(plugin: any) {
             var channelCache = this.listenerMap[plugin.description.name];
             if (channelCache) {
@@ -36,7 +45,6 @@ export namespace channel {
                 delete this.listenerMap[plugin.description.name];
             }
         }
-
         /**
          * Send Channel Message
          * @param player recover target

packages/api/src/command.ts

@@ -4,6 +4,12 @@ import { injectable } from "@ms/container";
 export namespace command {
     @injectable()
     export abstract class Command {
+        /**
+         * 注册插件命令
+         * @param plugin 插件
+         * @param name 命令
+         * @param exec 执行器
+         */
         on(plugin: any, name: string, exec: { cmd: Function, tab?: Function }) {
             var cmd = this.create(plugin, name);
             console.debug(i18n.translate("ms.api.command.register", { plugin: plugin.description.name, name, cmd }))
@@ -16,18 +22,20 @@ export namespace command {
                 this.onTabComplete(plugin, cmd, exec.tab);
             }
         }
+        /**
+         * 取消命令注册
+         * @param plugin 插件
+         * @param name 命令
+         */
         off(plugin: any, name: string) {
             console.debug(i18n.translate("ms.api.command.unregister", { plugin: plugin.description.name, name }))
             this.remove(plugin, name);
         }
-        /**
-         * Create Server Command Object
-         */
+
         protected abstract create(plugin: any, command: string);
         protected abstract remove(plugin: any, command: string);
         protected abstract onCommand(plugin: any, command: any, executor: Function);
         protected abstract onTabComplete(plugin: any, command: any, tabCompleter: Function);
-
         protected setExecutor(plugin: any, command: any, executor: Function) {
             return (sender: any, _: any, command: string, args: string[]) => {
                 try {
@@ -40,7 +48,6 @@ export namespace command {
                 }
             }
         }
-
         protected setTabCompleter(plugin: any, command: any, tabCompleter: Function) {
             return (sender: any, _: any, command: string, args: string[]) => {
                 try {
@@ -55,10 +62,9 @@ export namespace command {
                 }
             }
         }
-
         protected copyPartialMatches(complete: string[], token: string, array: string[] = []): string[] {
             if (!token) { return complete }
-            complete.forEach(function(e) {
+            complete.forEach(function (e) {
                 if (typeof e === "string" && e.toLowerCase().startsWith(token.toLowerCase())) {
                     array.push(e)
                 }

packages/api/src/console.ts

@@ -103,7 +103,7 @@ export class MiaoScriptConsole implements Console {
                     }
                 }
                 if (this.sourceMaps[fileName]) {
-                    var sourceMapping = this.sourceMaps[fileName].getSource(lineNumber, lineNumber);
+                    var sourceMapping = this.sourceMaps[fileName].getSource(lineNumber, 25, true);
                     if (sourceMapping) {
                         if (lineNumber != sourceMapping.mapping.sourceLine) {
                             fileName = fileName.replace(".js", ".ts");
@@ -122,7 +122,7 @@ export class MiaoScriptConsole implements Console {
     }
     stack(ex: Error): string[] {
         var stack = ex.getStackTrace();
-        var cache = ['§4' + ex];
+        var cache = ['§c' + ex];
         //@ts-ignore
         if (stack.class) {
             stack = Arrays.asList(stack)

packages/api/src/event.ts

@@ -7,6 +7,9 @@ import { injectable, unmanaged } from '@ms/container'
 const Thread = Java.type('java.lang.Thread');
 
 export namespace event {
+    /**
+     * 事件监听优先级
+     */
     export enum EventPriority {
         LOWEST = "LOWEST",
         LOW = "LOW",
@@ -144,6 +147,10 @@ export namespace event {
             return off;
         }
 
+        /**
+         * 关闭插件监听任务
+         * @param plugin 插件
+         */
         disable(plugin: any) {
             var eventCache = this.listenerMap[plugin.description.name];
             if (eventCache) {
@@ -152,8 +159,24 @@ export namespace event {
             }
         }
 
+        /**
+         * 判断
+         * @param clazz 事件类
+         */
         abstract isValidEvent(clazz: any): boolean;
+        /**
+         * 注册事件
+         * @param eventCls 事件类
+         * @param exec 执行器
+         * @param priority 优先级
+         * @param ignoreCancel 是否忽略已取消的事件
+         */
         abstract register(eventCls: any, exec: Function, priority: any, ignoreCancel: boolean): any;
+        /**
+         * 取消监听事件
+         * @param event 事件
+         * @param listener 监听器
+         */
         abstract unregister(event: any, listener: any): void;
     }
 }

packages/api/src/task.ts

@@ -1,7 +1,15 @@
 export namespace task {
     export const TaskManager = Symbol('TaskManager')
     export interface TaskManager {
+        /**
+         * 创建任务
+         * @param func 任务内容
+         */
         create(func: Function): task.Task;
+        /**
+         * 在主线程执行代码
+         * @param func 执行内容
+         */
         callSyncMethod(func: Function): any;
     }
     /**
@@ -19,16 +27,28 @@ export namespace task {
             this.func = func;
         }
 
+        /**
+         * 设置任务异步执行
+         * @param isAsync 是否异步
+         */
         async(isAsync: boolean = true): task.Task {
             this.isAsync = isAsync;
             return this;
         }
 
+        /**
+         * 设置任务延时执行
+         * @param tick 延时 Tick
+         */
         later(tick: number): task.Task {
             this.laterTime = tick;
             return this;
         }
 
+        /**
+         * 设置任务循环执行
+         * @param tick 循环时间 Tick
+         */
         timer(tick: number): task.Task {
             this.interval = tick;
             return this;
@@ -43,6 +63,9 @@ export namespace task {
             }
         }
 
+        /**
+         * 提交任务
+         */
         abstract submit(): Cancelable;
     }
     /**

packages/bukkit/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ms/bukkit",
-    "version": "0.3.2",
+    "version": "0.4.0",
     "description": "MiaoScript bukkit package",
     "keywords": [
         "miaoscript",
@@ -27,8 +27,8 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/api": "^0.3.2",
-        "@ms/common": "^0.3.1",
-        "@ms/container": "^0.3.2"
+        "@ms/api": "^0.4.0",
+        "@ms/common": "^0.4.0",
+        "@ms/container": "^0.4.0"
     }
 }

packages/bungee/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ms/bungee",
-    "version": "0.3.2",
+    "version": "0.4.0",
     "description": "MiaoScript bungee package",
     "keywords": [
         "miaoscript",
@@ -27,8 +27,8 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/api": "^0.3.2",
-        "@ms/common": "^0.3.1",
-        "@ms/container": "^0.3.2"
+        "@ms/api": "^0.4.0",
+        "@ms/common": "^0.4.0",
+        "@ms/container": "^0.4.0"
     }
 }

packages/client/package.json

@@ -1,7 +1,7 @@
 {
     "private": true,
     "name": "@ms/client",
-    "version": "0.3.1",
+    "version": "0.4.0",
     "description": "MiaoScript client package",
     "keywords": [
         "miaoscript",

packages/common/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ms/common",
-    "version": "0.3.1",
+    "version": "0.4.0",
     "description": "MiaoScript api package",
     "keywords": [
         "miaoscript",
@@ -27,7 +27,7 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/nashorn": "^0.3.1"
+        "@ms/nashorn": "^0.4.0"
     },
     "gitHead": "562e2d00175c9d3a99c8b672aa07e6d92706a027"
 }

packages/compile/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ms/compile",
-    "version": "0.3.1",
+    "version": "0.4.0",
     "description": "MiaoScript compile package",
     "keywords": [
         "miaoscript",

packages/container/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ms/container",
-    "version": "0.3.2",
+    "version": "0.4.0",
     "description": "MiaoScript container package",
     "keywords": [
         "miaoscript",

packages/core/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ms/core",
-    "version": "0.3.2",
+    "version": "0.4.0",
     "description": "MiaoScript api package",
     "keywords": [
         "miaoscript",
@@ -27,8 +27,8 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/api": "^0.3.2",
-        "@ms/container": "^0.3.2"
+        "@ms/api": "^0.4.0",
+        "@ms/container": "^0.4.0"
     },
     "gitHead": "781524f83e52cad26d7c480513e3c525df867121"
 }

packages/i18n/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ms/i18n",
-    "version": "0.3.1",
+    "version": "0.4.0",
     "description": "MiaoScript i18n package",
     "keywords": [
         "miaoscript",
@@ -28,7 +28,7 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/nashorn": "^0.3.1",
+        "@ms/nashorn": "^0.4.0",
         "js-yaml": "^3.13.1"
     },
     "gitHead": "781524f83e52cad26d7c480513e3c525df867121"

packages/nashorn/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ms/nashorn",
-    "version": "0.3.1",
+    "version": "0.4.0",
     "description": "MiaoScript api package",
     "keywords": [
         "miaoscript",

packages/nodejs/package.json

@@ -0,0 +1,33 @@
+{
+    "name": "@ms/nodejs",
+    "version": "0.4.0",
+    "description": "MiaoScript nodejs package",
+    "keywords": [
+        "miaoscript",
+        "minecraft",
+        "bukkit",
+        "sponge"
+    ],
+    "author": "MiaoWoo <admin@yumc.pw>",
+    "homepage": "https://github.com/circlecloud/ms.git",
+    "license": "ISC",
+    "main": "dist/index.js",
+    "publishConfig": {
+        "registry": "https://repo.yumc.pw/repository/npm-hosted/"
+    },
+    "scripts": {
+        "clean": "rimraf dist",
+        "watch": "tsc --watch",
+        "build": "yarn clean && tsc",
+        "test": "echo \"Error: run tests from root\" && exit 1"
+    },
+    "devDependencies": {
+        "reflect-metadata": "^0.1.13",
+        "rimraf": "^3.0.2",
+        "typescript": "^3.8.3"
+    },
+    "dependencies": {
+        "@ms/nashorn": "^0.4.0"
+    },
+    "gitHead": "781524f83e52cad26d7c480513e3c525df867121"
+}

packages/nodejs/src/events/index.ts

@@ -0,0 +1,455 @@
+// Copyright Joyent, Inc. and other Node contributors.
+//
+// Permission is hereby granted, free of charge, to any person obtaining a
+// copy of this software and associated documentation files (the
+// "Software"), to deal in the Software without restriction, including
+// without limitation the rights to use, copy, modify, merge, publish,
+// distribute, sublicense, and/or sell copies of the Software, and to permit
+// persons to whom the Software is furnished to do so, subject to the
+// following conditions:
+//
+// The above copyright notice and this permission notice shall be included
+// in all copies or substantial portions of the Software.
+//
+// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
+// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
+// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
+// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
+// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
+// USE OR OTHER DEALINGS IN THE SOFTWARE.
+
+'use strict';
+var R = typeof Reflect === 'object' ? Reflect : null
+var ReflectApply = R && typeof R.apply === 'function'
+    ? R.apply
+    : function ReflectApply(target, receiver, args) {
+        return Function.prototype.apply.call(target, receiver, args);
+    }
+
+var ReflectOwnKeys
+if (R && typeof R.ownKeys === 'function') {
+    ReflectOwnKeys = R.ownKeys
+} else if (Object.getOwnPropertySymbols) {
+    ReflectOwnKeys = function ReflectOwnKeys(target) {
+        return Object.getOwnPropertyNames(target)
+            // @ts-ignore
+            .concat(Object.getOwnPropertySymbols(target));
+    };
+} else {
+    ReflectOwnKeys = function ReflectOwnKeys(target) {
+        return Object.getOwnPropertyNames(target);
+    };
+}
+
+function ProcessEmitWarning(warning) {
+    if (console && console.warn) console.warn(warning);
+}
+
+var NumberIsNaN = Number.isNaN || function NumberIsNaN(value) {
+    return value !== value;
+}
+
+function EventEmitter(this: any) {
+    EventEmitter.init.call(this);
+}
+module.exports = EventEmitter;
+
+// Backwards-compat with node 0.10.x
+EventEmitter.EventEmitter = EventEmitter;
+
+EventEmitter.prototype._events = undefined;
+EventEmitter.prototype._eventsCount = 0;
+EventEmitter.prototype._maxListeners = undefined;
+
+// By default EventEmitters will print a warning if more than 10 listeners are
+// added to it. This is a useful default which helps finding memory leaks.
+var defaultMaxListeners = 10;
+
+function checkListener(listener) {
+    if (typeof listener !== 'function') {
+        throw new TypeError('The "listener" argument must be of type Function. Received type ' + typeof listener);
+    }
+}
+
+Object.defineProperty(EventEmitter, 'defaultMaxListeners', {
+    enumerable: true,
+    get: function () {
+        return defaultMaxListeners;
+    },
+    set: function (arg) {
+        if (typeof arg !== 'number' || arg < 0 || NumberIsNaN(arg)) {
+            throw new RangeError('The value of "defaultMaxListeners" is out of range. It must be a non-negative number. Received ' + arg + '.');
+        }
+        defaultMaxListeners = arg;
+    }
+});
+
+EventEmitter.init = function () {
+    // @ts-ignore
+    if (this._events === undefined ||
+        // @ts-ignore
+        this._events === Object.getPrototypeOf(this)._events) {
+        // @ts-ignore
+        this._events = Object.create(null);
+        // @ts-ignore
+        this._eventsCount = 0;
+    }
+    // @ts-ignore
+    this._maxListeners = this._maxListeners || undefined;
+};
+
+// Obviously not all Emitters should be limited to 10. This function allows
+// that to be increased. Set to zero for unlimited.
+EventEmitter.prototype.setMaxListeners = function setMaxListeners(n) {
+    if (typeof n !== 'number' || n < 0 || NumberIsNaN(n)) {
+        throw new RangeError('The value of "n" is out of range. It must be a non-negative number. Received ' + n + '.');
+    }
+    this._maxListeners = n;
+    return this;
+};
+
+function _getMaxListeners(that) {
+    if (that._maxListeners === undefined)
+        // @ts-ignore
+        return EventEmitter.defaultMaxListeners;
+    return that._maxListeners;
+}
+
+EventEmitter.prototype.getMaxListeners = function getMaxListeners() {
+    return _getMaxListeners(this);
+};
+
+EventEmitter.prototype.emit = function emit(type) {
+    var args = [];
+    for (var i = 1; i < arguments.length; i++) args.push(arguments[i]);
+    var doError = (type === 'error');
+
+    var events = this._events;
+    if (events !== undefined)
+        doError = (doError && events.error === undefined);
+    else if (!doError)
+        return false;
+
+    // If there is no 'error' event listener then throw.
+    if (doError) {
+        var er;
+        if (args.length > 0)
+            er = args[0];
+        if (er instanceof Error) {
+            // Note: The comments on the `throw` lines are intentional, they show
+            // up in Node's output if this results in an unhandled exception.
+            throw er; // Unhandled 'error' event
+        }
+        // At least give some kind of context to the user
+        var err = new Error('Unhandled error.' + (er ? ' (' + er.message + ')' : ''));
+        // @ts-ignore
+        err.context = er;
+        throw err; // Unhandled 'error' event
+    }
+
+    var handler = events[type];
+
+    if (handler === undefined)
+        return false;
+
+    if (typeof handler === 'function') {
+        ReflectApply(handler, this, args);
+    } else {
+        var len = handler.length;
+        var listeners = arrayClone(handler, len);
+        for (var i = 0; i < len; ++i)
+            ReflectApply(listeners[i], this, args);
+    }
+
+    return true;
+};
+
+function _addListener(target, type, listener, prepend) {
+    var m;
+    var events;
+    var existing;
+
+    checkListener(listener);
+
+    events = target._events;
+    if (events === undefined) {
+        events = target._events = Object.create(null);
+        target._eventsCount = 0;
+    } else {
+        // To avoid recursion in the case that type === "newListener"! Before
+        // adding it to the listeners, first emit "newListener".
+        if (events.newListener !== undefined) {
+            target.emit('newListener', type,
+                listener.listener ? listener.listener : listener);
+
+            // Re-assign `events` because a newListener handler could have caused the
+            // this._events to be assigned to a new object
+            events = target._events;
+        }
+        existing = events[type];
+    }
+
+    if (existing === undefined) {
+        // Optimize the case of one listener. Don't need the extra array object.
+        existing = events[type] = listener;
+        ++target._eventsCount;
+    } else {
+        if (typeof existing === 'function') {
+            // Adding the second element, need to change to array.
+            existing = events[type] =
+                prepend ? [listener, existing] : [existing, listener];
+            // If we've already got an array, just append.
+        } else if (prepend) {
+            existing.unshift(listener);
+        } else {
+            existing.push(listener);
+        }
+
+        // Check for listener leak
+        m = _getMaxListeners(target);
+        if (m > 0 && existing.length > m && !existing.warned) {
+            existing.warned = true;
+            // No error code for this since it is a Warning
+            // eslint-disable-next-line no-restricted-syntax
+            var w = new Error('Possible EventEmitter memory leak detected. ' +
+                existing.length + ' ' + String(type) + ' listeners ' +
+                'added. Use emitter.setMaxListeners() to ' +
+                'increase limit');
+            w.name = 'MaxListenersExceededWarning';
+            // @ts-ignore
+            w.emitter = target;
+            // @ts-ignore
+            w.type = type;
+            // @ts-ignore
+            w.count = existing.length;
+            ProcessEmitWarning(w);
+        }
+    }
+
+    return target;
+}
+
+EventEmitter.prototype.addListener = function addListener(type, listener) {
+    return _addListener(this, type, listener, false);
+};
+
+EventEmitter.prototype.on = EventEmitter.prototype.addListener;
+
+EventEmitter.prototype.prependListener =
+    function prependListener(type, listener) {
+        return _addListener(this, type, listener, true);
+    };
+
+function onceWrapper(this: any) {
+    if (!this.fired) {
+        this.target.removeListener(this.type, this.wrapFn);
+        this.fired = true;
+        if (arguments.length === 0)
+            return this.listener.call(this.target);
+        return this.listener.apply(this.target, arguments);
+    }
+}
+
+function _onceWrap(target, type, listener) {
+    var state = { fired: false, wrapFn: undefined, target: target, type: type, listener: listener };
+    var wrapped = onceWrapper.bind(state);
+    // @ts-ignore
+    wrapped.listener = listener;
+    state.wrapFn = wrapped;
+    return wrapped;
+}
+
+EventEmitter.prototype.once = function once(type, listener) {
+    checkListener(listener);
+    this.on(type, _onceWrap(this, type, listener));
+    return this;
+};
+
+EventEmitter.prototype.prependOnceListener =
+    function prependOnceListener(type, listener) {
+        checkListener(listener);
+        this.prependListener(type, _onceWrap(this, type, listener));
+        return this;
+    };
+
+// Emits a 'removeListener' event if and only if the listener was removed.
+EventEmitter.prototype.removeListener =
+    function removeListener(type, listener) {
+        var list, events, position, i, originalListener;
+
+        checkListener(listener);
+
+        events = this._events;
+        if (events === undefined)
+            return this;
+
+        list = events[type];
+        if (list === undefined)
+            return this;
+
+        if (list === listener || list.listener === listener) {
+            if (--this._eventsCount === 0)
+                this._events = Object.create(null);
+            else {
+                delete events[type];
+                if (events.removeListener)
+                    this.emit('removeListener', type, list.listener || listener);
+            }
+        } else if (typeof list !== 'function') {
+            position = -1;
+
+            for (i = list.length - 1; i >= 0; i--) {
+                if (list[i] === listener || list[i].listener === listener) {
+                    originalListener = list[i].listener;
+                    position = i;
+                    break;
+                }
+            }
+
+            if (position < 0)
+                return this;
+
+            if (position === 0)
+                list.shift();
+            else {
+                spliceOne(list, position);
+            }
+
+            if (list.length === 1)
+                events[type] = list[0];
+
+            if (events.removeListener !== undefined)
+                this.emit('removeListener', type, originalListener || listener);
+        }
+
+        return this;
+    };
+
+EventEmitter.prototype.off = EventEmitter.prototype.removeListener;
+
+EventEmitter.prototype.removeAllListeners =
+    function removeAllListeners(type) {
+        var listeners, events, i;
+
+        events = this._events;
+        if (events === undefined)
+            return this;
+
+        // not listening for removeListener, no need to emit
+        if (events.removeListener === undefined) {
+            if (arguments.length === 0) {
+                this._events = Object.create(null);
+                this._eventsCount = 0;
+            } else if (events[type] !== undefined) {
+                if (--this._eventsCount === 0)
+                    this._events = Object.create(null);
+                else
+                    delete events[type];
+            }
+            return this;
+        }
+
+        // emit removeListener for all listeners on all events
+        if (arguments.length === 0) {
+            var keys = Object.keys(events);
+            var key;
+            for (i = 0; i < keys.length; ++i) {
+                key = keys[i];
+                if (key === 'removeListener') continue;
+                this.removeAllListeners(key);
+            }
+            this.removeAllListeners('removeListener');
+            this._events = Object.create(null);
+            this._eventsCount = 0;
+            return this;
+        }
+
+        listeners = events[type];
+
+        if (typeof listeners === 'function') {
+            this.removeListener(type, listeners);
+        } else if (listeners !== undefined) {
+            // LIFO order
+            for (i = listeners.length - 1; i >= 0; i--) {
+                this.removeListener(type, listeners[i]);
+            }
+        }
+
+        return this;
+    };
+
+function _listeners(target, type, unwrap) {
+    var events = target._events;
+
+    if (events === undefined)
+        return [];
+
+    var evlistener = events[type];
+    if (evlistener === undefined)
+        return [];
+
+    if (typeof evlistener === 'function')
+        return unwrap ? [evlistener.listener || evlistener] : [evlistener];
+
+    return unwrap ?
+        unwrapListeners(evlistener) : arrayClone(evlistener, evlistener.length);
+}
+
+EventEmitter.prototype.listeners = function listeners(type) {
+    return _listeners(this, type, true);
+};
+
+EventEmitter.prototype.rawListeners = function rawListeners(type) {
+    return _listeners(this, type, false);
+};
+
+EventEmitter.listenerCount = function (emitter, type) {
+    if (typeof emitter.listenerCount === 'function') {
+        return emitter.listenerCount(type);
+    } else {
+        return listenerCount.call(emitter, type);
+    }
+};
+
+EventEmitter.prototype.listenerCount = listenerCount;
+function listenerCount(this: any, type) {
+    var events = this._events;
+
+    if (events !== undefined) {
+        var evlistener = events[type];
+
+        if (typeof evlistener === 'function') {
+            return 1;
+        } else if (evlistener !== undefined) {
+            return evlistener.length;
+        }
+    }
+
+    return 0;
+}
+
+EventEmitter.prototype.eventNames = function eventNames() {
+    return this._eventsCount > 0 ? ReflectOwnKeys(this._events) : [];
+};
+
+function arrayClone(arr, n) {
+    var copy = new Array(n);
+    for (var i = 0; i < n; ++i)
+        copy[i] = arr[i];
+    return copy;
+}
+
+function spliceOne(list, index) {
+    for (; index + 1 < list.length; index++)
+        list[index] = list[index + 1];
+    list.pop();
+}
+
+function unwrapListeners(arr) {
+    var ret = new Array(arr.length);
+    for (var i = 0; i < ret.length; ++i) {
+        ret[i] = arr[i].listener || arr[i];
+    }
+    return ret;
+}

packages/nodejs/src/index.ts

@@ -0,0 +1,51 @@
+/// <reference types="@ms/nashorn" />
+import * as yaml from 'js-yaml'
+
+const File = Java.type("java.io.File");
+const separatorChar = File.separatorChar;
+
+let langMap = {};
+let fallbackMap = {};
+
+type TranslateParam = { [key: string]: any }
+
+function translate(name: string, param?: TranslateParam) {
+    let langText: string = langMap[name] || fallbackMap[name];
+    if (!langText) { return '[WARN] @ms/i18n miss lang translate: ' + name }
+    for (const key in param) {
+        langText = langText.replace("{" + key + "}", param[key])
+    }
+    return langText;
+}
+
+function initialize(lang: string = 'zh_cn', fallback: string = 'zh_cn') {
+    langMap = readYamlFile(root, lang) || readYamlFile(concat(__dirname, '..'), lang)
+    fallbackMap = readYamlFile(root, fallback) || readYamlFile(concat(__dirname, '..'), fallback)
+    console.i18n = function i18n(name: string, param?: TranslateParam) {
+        console.log(translate(name, param))
+    }
+}
+
+function readYamlFile(dir: string, name: string) {
+    let langFile = concat(dir, 'languages', name + '.yml');
+    return exists(langFile) && yaml.safeLoad(base.read(langFile))
+}
+
+function concat(...args: string[]) {
+    return args.join(separatorChar)
+}
+
+function exists(path: string) {
+    return new File(path).exists()
+}
+
+declare global {
+    interface Console {
+        i18n(name: string, param?: TranslateParam);
+    }
+}
+
+export default {
+    initialize,
+    translate
+};

packages/nodejs/tsconfig.json

@@ -0,0 +1,7 @@
+{
+    "extends": "../../tsconfig.json",
+    "compilerOptions": {
+        "baseUrl": "src",
+        "outDir": "dist"
+    }
+}

packages/nukkit/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ms/nukkit",
-    "version": "0.3.2",
+    "version": "0.4.0",
     "description": "MiaoScript nukkit package",
     "keywords": [
         "miaoscript",
@@ -27,8 +27,8 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/api": "^0.3.2",
-        "@ms/common": "^0.3.1",
-        "@ms/container": "^0.3.2"
+        "@ms/api": "^0.4.0",
+        "@ms/common": "^0.4.0",
+        "@ms/container": "^0.4.0"
     }
 }

packages/ployfill/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ms/ployfill",
-    "version": "0.3.1",
+    "version": "0.4.0",
     "description": "MiaoScript ployfill package",
     "author": "MiaoWoo <admin@yumc.pw>",
     "homepage": "https://github.com/circlecloud/ms.git",
@@ -17,8 +17,8 @@
         "test": "echo \"Error: run tests from root\" && exit 1"
     },
     "dependencies": {
-        "@ms/i18n": "^0.3.1",
-        "@ms/nashorn": "^0.3.1",
+        "@ms/i18n": "^0.4.0",
+        "@ms/nashorn": "^0.4.0",
         "core-js": "^3.6.4"
     },
     "devDependencies": {

packages/plugin/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ms/plugin",
-    "version": "0.3.2",
+    "version": "0.4.0",
     "description": "MiaoScript api package",
     "keywords": [
         "miaoscript",
@@ -28,10 +28,10 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/api": "^0.3.2",
-        "@ms/common": "^0.3.1",
-        "@ms/container": "^0.3.2",
-        "@ms/i18n": "^0.3.1",
+        "@ms/api": "^0.4.0",
+        "@ms/common": "^0.4.0",
+        "@ms/container": "^0.4.0",
+        "@ms/i18n": "^0.4.0",
         "js-yaml": "^3.13.1"
     }
 }

packages/plugin/src/manager.ts

@@ -186,14 +186,19 @@ export class PluginManagerImpl implements plugin.PluginManager {
     }
 
     private buildPlugin(metadata: interfaces.PluginMetadata) {
-        this.bindPlugin(metadata)
-        let pluginInstance = this.container.getNamed<interfaces.Plugin>(plugin.Plugin, metadata.name)
-        if (!(pluginInstance instanceof interfaces.Plugin)) {
-            console.i18n('ms.plugin.manager.build.not.extends', { source: metadata.source })
-            return
+        try {
+            this.bindPlugin(metadata)
+            let pluginInstance = this.container.getNamed<interfaces.Plugin>(plugin.Plugin, metadata.name)
+            if (!(pluginInstance instanceof interfaces.Plugin)) {
+                console.i18n('ms.plugin.manager.build.not.extends', { source: metadata.source })
+                return
+            }
+            this.pluginMap.set(metadata.name, pluginInstance)
+            return pluginInstance;
+        } catch (ex) {
+            console.i18n("ms.plugin.manager.initialize.error", { name: metadata.name, ex })
+            console.ex(ex)
         }
-        this.pluginMap.set(metadata.name, pluginInstance)
-        return pluginInstance
     }
 
     private bindPlugin(metadata: interfaces.PluginMetadata) {

packages/plugins/package.json

@@ -1,7 +1,7 @@
 {
     "private": true,
     "name": "@ms/plugins",
-    "version": "0.3.2",
+    "version": "0.4.0",
     "description": "MiaoScript plugins package",
     "keywords": [
         "miaoscript",
@@ -28,8 +28,8 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/api": "^0.3.2",
-        "@ms/container": "^0.3.2",
-        "@ms/plugin": "^0.3.2"
+        "@ms/api": "^0.4.0",
+        "@ms/container": "^0.4.0",
+        "@ms/plugin": "^0.4.0"
     }
 }

packages/sponge/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ms/sponge",
-    "version": "0.3.2",
+    "version": "0.4.0",
     "description": "MiaoScript api package",
     "keywords": [
         "miaoscript",
@@ -27,8 +27,8 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/api": "^0.3.2",
-        "@ms/common": "^0.3.1",
-        "@ms/container": "^0.3.2"
+        "@ms/api": "^0.4.0",
+        "@ms/common": "^0.4.0",
+        "@ms/container": "^0.4.0"
     }
 }

packages/types/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ms/types",
-    "version": "0.3.1",
+    "version": "0.4.0",
     "description": "MiaoScript types package",
     "keywords": [
         "miaoscript",

packages/websocket/package.json

@@ -1,7 +1,7 @@
 {
     "name": "@ms/websocket",
-    "version": "0.3.1",
-    "description": "MiaoScript api package",
+    "version": "0.4.0",
+    "description": "MiaoScript websocket package",
     "keywords": [
         "miaoscript",
         "minecraft",
@@ -27,7 +27,6 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/nashorn": "^0.3.1"
-    },
-    "gitHead": "781524f83e52cad26d7c480513e3c525df867121"
+        "@ms/nashorn": "^0.4.0"
+    }
 }

packages/websocket/src/index.ts

@@ -1 +1,3 @@
 /// <reference types="@ms/nashorn" />
+
+export * from './socket-io'

packages/websocket/src/netty/httprequest.ts

@@ -2,18 +2,19 @@ const TypeParameterMatcher = Java.type('io.netty.util.internal.TypeParameterMatc
 const SimpleChannelInboundHandler = Java.type('io.netty.channel.SimpleChannelInboundHandler')
 const FullHttpRequestMatcher = TypeParameterMatcher.get(base.getClass('io.netty.handler.codec.http.FullHttpRequest'))
 
-export default abstract class HttpRequestHandlerAdapter {
+export abstract class HttpRequestHandlerAdapter {
     private _Handler;
     constructor() {
-        this._Handler == Java.extend(SimpleChannelInboundHandler, {
+        let HttpRequestHandlerAdapterImpl = Java.extend(SimpleChannelInboundHandler, {
             acceptInboundMessage: (msg: any) => {
                 return FullHttpRequestMatcher.match(msg)
             },
-            channelRead0: this.channelRead0
+            channelRead0: this.channelRead0.bind(this)
         })
+        this._Handler = new HttpRequestHandlerAdapterImpl();
     }
-    abstract channelRead0(ctx: any, msg: any);
+    abstract channelRead0(ctx: any, request: any);
     getHandler() {
         return this._Handler;
     }
-}
+}

packages/websocket/src/netty/index.ts

@@ -0,0 +1,3 @@
+export * from './text_websocket_frame'
+export * from './websocket'
+export * from './httprequest'

packages/websocket/src/netty/text_websocket_frame.ts

@@ -2,19 +2,22 @@ const TypeParameterMatcher = Java.type('io.netty.util.internal.TypeParameterMatc
 const TextWebSocketFrameMatcher = TypeParameterMatcher.get(base.getClass('io.netty.handler.codec.http.websocketx.TextWebSocketFrame'))
 const SimpleChannelInboundHandler = Java.type('io.netty.channel.SimpleChannelInboundHandler')
 
-export default abstract class TextWebSocketFrameHandlerAdapter {
+export abstract class TextWebSocketFrameHandlerAdapter {
     private _Handler;
     constructor() {
-        this._Handler == Java.extend(SimpleChannelInboundHandler, {
-            userEventTriggered: this.userEventTriggered,
+        let TextWebSocketFrameHandlerAdapterImpl = Java.extend(SimpleChannelInboundHandler, {
+            userEventTriggered: this.userEventTriggered.bind(this),
             acceptInboundMessage: (msg: any) => {
                 return TextWebSocketFrameMatcher.match(msg)
             },
-            channelRead0: this.channelRead0
+            channelRead0: this.channelRead0.bind(this),
+            exceptionCaught: this.exceptionCaught.bind(this)
         })
+        this._Handler = new TextWebSocketFrameHandlerAdapterImpl();
     }
     abstract userEventTriggered(ctx: any, evt: any);
     abstract channelRead0(ctx: any, msg: any);
+    abstract exceptionCaught(ctx: any, cause: Error);
     getHandler() {
         return this._Handler;
     }

packages/websocket/src/netty/websocket.ts

@@ -1,15 +1,14 @@
-const MiaoWebSocket = 'miaowebsocket'
-const CharsetUtil = Java.type('io.netty.util.CharsetUtil')
 const ChannelInboundHandlerAdapter = Java.type('io.netty.channel.ChannelInboundHandlerAdapter')
 
-export default abstract class WebSocketHandlerAdapter {
+export abstract class WebSocketHandlerAdapter {
     private _Handler;
     constructor() {
-        this._Handler = Java.extend(ChannelInboundHandlerAdapter, {
-            channelRead: this.channelRead
+        let ChannelInboundHandlerAdapterImpl = Java.extend(ChannelInboundHandlerAdapter, {
+            channelRead: this.channelRead.bind(this)
         })
+        this._Handler = new ChannelInboundHandlerAdapterImpl()
     }
-    abstract channelRead(ctx: any, msg: any);
+    abstract channelRead(ctx: any, channel: any);
     getHandler() {
         return this._Handler;
     }

packages/websocket/src/server/client.ts

@@ -0,0 +1,40 @@
+import { EventEmitter } from 'events'
+import { SocketIO } from 'socket-io/interfaces';
+import { Keys, AttributeKeys } from './constants';
+
+const TextWebSocketFrame = Java.type('io.netty.handler.codec.http.websocketx.TextWebSocketFrame')
+
+export class NettyClient extends EventEmitter implements SocketIO.EngineSocket {
+    private _id: string;
+    private channel: any
+
+    server: any;
+    readyState: string;
+    remoteAddress: string;
+    upgraded: boolean;
+    request: any;
+    transport: any;
+
+    constructor(server: any, channel: any) {
+        super();
+        this.server = server;
+        this.readyState = 'open';
+        this.remoteAddress = channel.remoteAddress() + ''
+        this.upgraded = true;
+        this.request = channel.attr(AttributeKeys.Request).get();
+        this.transport = null;
+
+        this.channel = channel;
+        this._id = channel.id();
+    }
+
+    get id() {
+        return this._id;
+    }
+    send(text: string) {
+        this.channel.writeAndFlush(new TextWebSocketFrame(text))
+    }
+    close() {
+        this.channel.close();
+    }
+}

packages/websocket/src/server/constants.ts

@@ -0,0 +1,20 @@
+export enum ServerEvent {
+    detect = 'detect',
+    connect = 'connect',
+    connection = 'connection',
+    message = 'message',
+    error = 'error',
+    disconnect = 'disconnect'
+}
+
+const AttributeKey = Java.type('io.netty.util.AttributeKey');
+
+export enum Keys {
+    Detect = "miao_detect",
+    Handler = "miaowebsocket",
+    Default = "DefaultChannelPipeline"
+}
+
+export enum AttributeKeys {
+    Request = AttributeKey.valueOf('request')
+}

packages/websocket/src/server/httprequest.ts

@@ -0,0 +1,61 @@
+import { HttpRequestHandlerAdapter } from '../netty'
+import { AttributeKeys } from './constants'
+import { ServerOptions } from 'socket-io'
+
+const DefaultHttpResponse = Java.type('io.netty.handler.codec.http.DefaultHttpResponse')
+const DefaultFullHttpResponse = Java.type('io.netty.handler.codec.http.DefaultFullHttpResponse')
+const HttpHeaders = Java.type('io.netty.handler.codec.http.HttpHeaders')
+const HttpVersion = Java.type('io.netty.handler.codec.http.HttpVersion')
+const HttpResponseStatus = Java.type('io.netty.handler.codec.http.HttpResponseStatus')
+const LastHttpContent = Java.type('io.netty.handler.codec.http.LastHttpContent')
+
+const File = Java.type('java.io.File')
+const Runnable = Java.type('java.lang.Runnable')
+const RandomAccessFile = Java.type('java.io.RandomAccessFile')
+const DefaultFileRegion = Java.type('io.netty.channel.DefaultFileRegion')
+const ChannelFutureListener = Java.type('io.netty.channel.ChannelFutureListener')
+
+export class HttpRequestHandler extends HttpRequestHandlerAdapter {
+    private ws: string;
+    private root: string;
+    constructor(options: ServerOptions) {
+        super()
+        this.root = options.root;
+        this.ws = options.path;
+    }
+    channelRead0(ctx: any, request: any) {
+        if (request.getUri().startsWith(this.ws)) {
+            ctx.channel().attr(AttributeKeys.Request).set(request);
+            ctx.fireChannelRead(request.retain())
+        } else {
+            ctx.executor().execute(new Runnable({
+                run: () => {
+                    if (HttpHeaders.is100ContinueExpected(request)) {
+                        ctx.writeAndFlush(new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.CONTINUE))
+                    }
+                    let filename = request.getUri().split('?')[0].substr(1)
+                    let file = new File(this.root, filename || 'index.html')
+                    if (!file.exists() || !file.isFile()) {
+                        ctx.write(new DefaultHttpResponse(request.getProtocolVersion(), HttpResponseStatus.NOT_FOUND))
+                        ctx.writeAndFlush(LastHttpContent.EMPTY_LAST_CONTENT).addListener(ChannelFutureListener.CLOSE)
+                        return
+                    }
+                    let response = new DefaultHttpResponse(request.getProtocolVersion(), HttpResponseStatus.OK)
+                    response.headers().set(HttpHeaders.Names.CONTENT_TYPE, "text/html charset=UTF-8")
+                    let raf = new RandomAccessFile(file, 'r')
+                    let keepAlive = HttpHeaders.isKeepAlive(request)
+                    if (keepAlive) {
+                        response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, file.length())
+                        response.headers().set(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE)
+                    }
+                    ctx.write(response)
+                    ctx.write(new DefaultFileRegion(raf.getChannel(), 0, raf.length()))
+                    let future = ctx.writeAndFlush(LastHttpContent.EMPTY_LAST_CONTENT)
+                    if (!keepAlive) {
+                        future.addListener(ChannelFutureListener.CLOSE)
+                    }
+                }
+            }))
+        }
+    }
+}

packages/websocket/src/server/index.ts

@@ -0,0 +1,48 @@
+import { EventEmitter } from 'events'
+
+import { ServerEvent, Keys } from './constants'
+import { WebSocketDetect } from './websocket_detect'
+import { WebSocketHandler } from './websocket_handler'
+import { NettyClient } from './client'
+import { ServerOptions, Server } from '../socket-io'
+
+class NettyWebSocketServer extends EventEmitter {
+    private pipeline: any;
+    private allClients: { [key: string]: NettyClient };
+
+    constructor(pipeline: any, options: ServerOptions) {
+        super()
+        this.allClients = {};
+        this.pipeline = pipeline;
+        let connectEvent = options.event;
+        try { this.pipeline.remove(Keys.Detect) } catch (error) { }
+        this.pipeline.addFirst(Keys.Detect, new WebSocketDetect(connectEvent).getHandler())
+        connectEvent.on(ServerEvent.detect, (ctx, channel) => {
+            channel.pipeline().addFirst(Keys.Handler, new WebSocketHandler(options).getHandler())
+            ctx.fireChannelRead(channel)
+        })
+        connectEvent.on(ServerEvent.connect, (ctx) => {
+            let nettyClient = new NettyClient(this, ctx.channel());
+            this.allClients[nettyClient.id] = nettyClient;
+            this.emit(ServerEvent.connect, nettyClient);
+        })
+        connectEvent.on(ServerEvent.message, (ctx, msg) => {
+            this.emit(ServerEvent.message, this.allClients[ctx.channel().id()], msg.text())
+        })
+        connectEvent.on(ServerEvent.error, (ctx, cause) => {
+            this.emit(ServerEvent.error, this.allClients[ctx.channel().id()], cause)
+        })
+    }
+    close() {
+        if (this.pipeline.names().contains(Keys.Detect)) {
+            this.pipeline.remove(Keys.Detect)
+        }
+        Object.values(this.allClients).forEach(client => client.close())
+    }
+}
+
+export {
+    NettyWebSocketServer,
+    ServerEvent,
+    NettyClient
+};

packages/websocket/src/server/text_websocket_frame.ts

@@ -0,0 +1,23 @@
+import { TextWebSocketFrameHandlerAdapter } from '../netty'
+import { EventEmitter } from 'events'
+import { ServerEvent } from './constants'
+import { ServerOptions } from '../socket-io';
+
+export class TextWebSocketFrameHandler extends TextWebSocketFrameHandlerAdapter {
+    private event: EventEmitter;
+    constructor(options: ServerOptions) {
+        super()
+        this.event = options.event;
+    }
+    userEventTriggered(ctx: any, evt: any) {
+        if (evt == 'HANDSHAKE_COMPLETE') {
+            this.event.emit(ServerEvent.connect, ctx)
+        }
+    }
+    channelRead0(ctx: any, msg: any) {
+        this.event.emit(ServerEvent.message, ctx, msg)
+    }
+    exceptionCaught(ctx: any, cause: Error) {
+        this.event.emit(ServerEvent.error, ctx, cause)
+    }
+}

packages/websocket/src/server/websocket_detect.ts

@@ -0,0 +1,14 @@
+import { EventEmitter } from 'events'
+import { WebSocketHandlerAdapter } from "../netty"
+import { ServerEvent } from './constants'
+
+export class WebSocketDetect extends WebSocketHandlerAdapter {
+    private event: EventEmitter;
+    constructor(event: EventEmitter) {
+        super()
+        this.event = event;
+    }
+    channelRead(ctx: any, channel: any) {
+        this.event.emit(ServerEvent.detect, ctx, channel);
+    }
+}

packages/websocket/src/server/websocket_handler.ts

@@ -0,0 +1,43 @@
+import { EventEmitter } from 'events'
+
+import { Keys } from './constants'
+import { WebSocketHandlerAdapter } from "../netty"
+import { HttpRequestHandler } from './httprequest'
+import { TextWebSocketFrameHandler } from './text_websocket_frame'
+import { ServerOptions } from '../socket-io'
+
+const CharsetUtil = Java.type('io.netty.util.CharsetUtil')
+
+const HttpServerCodec = Java.type('io.netty.handler.codec.http.HttpServerCodec')
+const ChunkedWriteHandler = Java.type('io.netty.handler.stream.ChunkedWriteHandler')
+const HttpObjectAggregator = Java.type('io.netty.handler.codec.http.HttpObjectAggregator')
+const WebSocketServerProtocolHandler = Java.type('io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler')
+
+export class WebSocketHandler extends WebSocketHandlerAdapter {
+    private options: ServerOptions;
+    constructor(options: ServerOptions) {
+        super()
+        this.options = options;
+    }
+    channelRead(ctx: any, msg: any) {
+        msg.markReaderIndex()
+        let message: string = msg.toString(CharsetUtil.UTF_8)
+        let channel = ctx.channel()
+        let pipeline = channel.pipeline()
+        if (message.indexOf('HTTP/1.1') > 0) {
+            pipeline.names().forEach(f => {
+                if (f == Keys.Handler || f.indexOf(Keys.Default) > -1) { return }
+                pipeline.remove(f)
+            })
+            pipeline.addLast('http', new HttpServerCodec())
+            pipeline.addLast('chunk', new ChunkedWriteHandler())
+            pipeline.addLast('httpobj', new HttpObjectAggregator(64 * 1024))
+            pipeline.addLast('http_request', new HttpRequestHandler(this.options).getHandler())
+            pipeline.addLast('websocket', new WebSocketServerProtocolHandler(this.options.path, true))
+            pipeline.addLast('websocket_handler', new TextWebSocketFrameHandler(this.options).getHandler())
+        }
+        pipeline.remove(Keys.Handler)
+        msg.resetReaderIndex()
+        ctx.fireChannelRead(msg)
+    }
+}

packages/websocket/src/socket-io/adapter.ts

@@ -0,0 +1,127 @@
+import { EventEmitter } from 'events'
+import { SocketIO } from './interfaces';
+import { Namespace } from './namespace';
+import { Parser } from './parser';
+import { Socket } from './socket';
+
+export class Adapter extends EventEmitter implements SocketIO.Adapter {
+    nsp: Namespace;
+    rooms: Rooms;
+    sids: { [id: string]: { [room: string]: boolean; }; };
+    parser: Parser
+    constructor(nsp: Namespace) {
+        super()
+        this.nsp = nsp;
+        this.rooms = new Rooms();
+        this.sids = {};
+        this.parser = nsp.server.parser;
+    }
+    add(id: string, room: string, callback?: (err?: any) => void): void {
+        return this.addAll(id, [room], callback);
+    }
+    /**
+     * Adds a socket to a list of room.
+     *
+     * @param {String} socket id
+     * @param {String} rooms
+     * @param {Function} callback
+     * @api public
+     */
+    addAll(id: string, rooms: string | any[], fn: { (err?: any): void; bind?: any; }) {
+        for (var i = 0; i < rooms.length; i++) {
+            var room = rooms[i];
+            this.sids[id] = this.sids[id] || {};
+            this.sids[id][room] = true;
+            this.rooms[room] = this.rooms[room] || new Room();
+            this.rooms[room].add(id);
+        }
+        fn && fn.bind(null, null)
+    };
+    del(id: string, room: string, callback?: (err?: any) => void): void {
+        if (this.sids[id]) delete this.sids[id][room];
+
+        if (this.rooms.hasOwnProperty(room)) {
+            this.rooms[room].del(id);
+            if (this.rooms[room].length === 0) delete this.rooms[room];
+        }
+        callback && callback.bind(null, null)
+    }
+    delAll(id: string): void {
+        var rooms = this.sids[id];
+        if (rooms) {
+            for (var room in rooms) {
+                if (this.rooms.hasOwnProperty(room)) {
+                    this.rooms[room].del(id);
+                    if (this.rooms[room].length === 0) delete this.rooms[room];
+                }
+            }
+        }
+        delete this.sids[id];
+    }
+    broadcast(packet: any, opts: { rooms?: string[]; except?: string[]; flags?: { [flag: string]: boolean; }; }): void {
+        var rooms = opts.rooms || [];
+        var except = opts.except || [];
+        var flags = opts.flags || {};
+        var packetOpts = {
+            preEncoded: true,
+            volatile: flags.volatile,
+            compress: flags.compress
+        };
+        var ids = {};
+        var self = this;
+        var socket: Socket;
+
+        packet.nsp = this.nsp.name;
+        // let encodedPackets = this.parser.encode(packet)
+        if (rooms.length) {
+            for (var i = 0; i < rooms.length; i++) {
+                var room = self.rooms[rooms[i]];
+                if (!room) continue;
+                var sockets = room.sockets;
+                for (var id in sockets) {
+                    if (sockets.hasOwnProperty(id)) {
+                        if (ids[id] || ~except.indexOf(id)) continue;
+                        socket = self.nsp.connected[id];
+                        if (socket) {
+                            socket.packet(packet, packetOpts);
+                            ids[id] = true;
+                        }
+                    }
+                }
+            }
+        } else {
+            for (var id in self.sids) {
+                if (self.sids.hasOwnProperty(id)) {
+                    if (~except.indexOf(id)) continue;
+                    socket = self.nsp.connected[id];
+                    if (socket) socket.packet(packet, packetOpts);
+                }
+            }
+        }
+    }
+}
+
+class Rooms implements SocketIO.Rooms {
+    [room: string]: Room;
+}
+
+class Room implements SocketIO.Room {
+    sockets: { [id: string]: boolean; };
+    length: number;
+    constructor() {
+        this.sockets = {};
+        this.length = 0;
+    }
+    add(id) {
+        if (!this.sockets.hasOwnProperty(id)) {
+            this.sockets[id] = true;
+            this.length++;
+        }
+    }
+    del(id) {
+        if (this.sockets.hasOwnProperty(id)) {
+            delete this.sockets[id];
+            this.length--;
+        }
+    }
+}

packages/websocket/src/socket-io/client.ts

@@ -0,0 +1,103 @@
+import { EventEmitter } from 'events'
+import { Parser } from './parser'
+import { Packet } from './packet';
+import { NettyClient } from '../server';
+import { SocketIO } from './interfaces'
+import { Server, Socket } from './index';
+import { PacketTypes, SubPacketTypes } from './types';
+
+const parser = new Parser();
+
+export class Client extends EventEmitter implements SocketIO.Client {
+    id: string;
+    server: Server;
+    conn: NettyClient;
+    request: any;
+    sockets: { [id: string]: Socket; };
+    nsps: { [nsp: string]: SocketIO.Socket; };
+    connectBuffer: any;
+
+    constructor(server: Server, nettyClient: NettyClient) {
+        super();
+        this.server = server;
+        this.conn = nettyClient;
+        this.id = this.conn.id + '';
+        this.request = nettyClient.request;
+        this.sockets = {};
+        this.nsps = {};
+    }
+    connect(name, query) {
+        if (this.server.nsps[name]) {
+            // console.debug(`connecting to namespace ${name}`);
+            return this.doConnect(name, query);
+        }
+        this.server.checkNamespace(name, query, (dynamicNsp) => {
+            if (dynamicNsp) {
+                // console.debug('dynamic namespace %s was created', dynamicNsp.name);
+                this.doConnect(name, query);
+            } else {
+                // console.debug('creation of namespace %s was denied', name);
+                this.packet({
+                    type: PacketTypes.MESSAGE,
+                    sub_type: SubPacketTypes.ERROR,
+                    nsp: name,
+                    data: 'Invalid namespace'
+                });
+            }
+        })
+    }
+    doConnect(name, query) {
+        var nsp = this.server.of(name);
+        if ('/' != name && !this.nsps['/']) {
+            this.connectBuffer.push(name);
+            return;
+        }
+        var socket = nsp.add(this, query, () => {
+            this.sockets[socket.id] = socket;
+            this.nsps[nsp.name] = socket;
+
+            if ('/' == nsp.name && this.connectBuffer.length > 0) {
+                this.connectBuffer.forEach(this.connect, this);
+                this.connectBuffer = [];
+            }
+        });
+    }
+    packet(packet: Packet, opts?: any) {
+        this.conn.send(parser.encode(packet))
+    }
+    onclose(reason?: string) {
+        // debug('client close with reason %s', reason);
+        // ignore a potential subsequent `close` event
+        this.destroy();
+        // `nsps` and `sockets` are cleaned up seamlessly
+        for (var id in this.sockets) {
+            if (this.sockets.hasOwnProperty(id)) {
+                this.sockets[id].onclose(reason);
+            }
+        }
+        this.sockets = {};
+        // this.decoder.destroy(); // clean up decoder
+    }
+    disconnect() {
+        // if ('open' == this.conn.readyState) {
+        // debug('forcing transport close');
+        this.conn.close();
+        this.onclose('forced server close');
+        // }
+    }
+    remove(socket: Socket) {
+        if (this.sockets.hasOwnProperty(socket.id)) {
+            var nsp = this.sockets[socket.id].nsp.name;
+            delete this.sockets[socket.id];
+            delete this.nsps[nsp];
+        } else {
+            // debug('ignoring remove for %s', socket.id);
+        }
+    }
+    destroy() {
+        // this.conn.removeListener('data', this.ondata);
+        // this.conn.removeListener('error', this.onerror);
+        // this.conn.removeListener('close', this.onclose);
+        // this.decoder.removeListener('decoded', this.ondecoded);
+    };
+}

packages/websocket/src/socket-io/index.ts

@@ -0,0 +1,210 @@
+import { EventEmitter } from 'events'
+
+import { NettyWebSocketServer, NettyClient } from '../server'
+import { ServerEvent } from '../server/constants';
+
+import { Namespace } from './namespace';
+import { Client } from './client';
+import { SocketIO } from './interfaces'
+import { Parser } from './parser'
+import { PacketTypes, SubPacketTypes } from './types';
+import { Packet } from './packet';
+import { Socket } from './socket';
+import { Adapter } from './adapter';
+
+interface ServerOptions extends SocketIO.ServerOptions {
+    event?: EventEmitter;
+    root?: string;
+}
+
+const defaultOptions: ServerOptions = {
+    event: new EventEmitter(),
+    path: '/socket.io',
+    root: root + '/wwwroot'
+}
+
+class Server implements SocketIO.Server {
+    private nettyServer: NettyWebSocketServer;
+    private allClients: { [key: string]: Client };
+
+    engine: { ws: any; };
+    nsps: { [namespace: string]: Namespace; };
+    sockets: Namespace;
+    json: SocketIO.Server;
+    volatile: SocketIO.Server;
+    local: SocketIO.Server;
+    parser = new Parser();
+    _adapter: Adapter;
+    options: ServerOptions;
+
+    constructor(pipeline: any, options: ServerOptions) {
+        if (!pipeline) { throw new Error('Netty Pipeline can\'t be undefiend!') }
+        this.allClients = {};
+        this.nsps = {};
+        this.sockets = new Namespace('/', this);
+        this.nsps['/'] = this.sockets;
+        this.initNettyServer(pipeline, Object.assign(defaultOptions, options));
+    }
+
+    checkRequest(req: any, fn: (err: any, success: boolean) => void): void {
+        throw new Error("Method not implemented.");
+    }
+    serveClient(): boolean;
+    serveClient(v: boolean): SocketIO.Server;
+    serveClient(v?: any): boolean | SocketIO.Server {
+        throw new Error("Method not implemented.");
+    }
+    path(): string;
+    path(v: string): SocketIO.Server;
+    path(v?: any): string | SocketIO.Server {
+        if (!arguments.length) return this.options.path;
+        this.options.path = v.replace(/\/$/, '');
+        return this;
+    }
+    adapter(): Adapter;
+    adapter(v: any): SocketIO.Server;
+    adapter(v?: any): Adapter | SocketIO.Server {
+        if (!arguments.length) return this._adapter;
+        this._adapter = v;
+        for (var i in this.nsps) {
+            if (this.nsps.hasOwnProperty(i)) {
+                this.nsps[i].initAdapter();
+            }
+        }
+        return this;
+    }
+    origins(): string | string[];
+    origins(v: string | string[]): SocketIO.Server;
+    origins(fn: (origin: string, callback: (error: string, success: boolean) => void) => void): SocketIO.Server;
+    origins(fn?: any): string | string[] | SocketIO.Server {
+        throw new Error("Method not implemented.");
+    }
+    attach(srv: any, opts?: SocketIO.ServerOptions): SocketIO.Server;
+    attach(port: number, opts?: SocketIO.ServerOptions): SocketIO.Server;
+    attach(port: any, opts?: any): SocketIO.Server {
+        throw new Error("Method not implemented.");
+    }
+    listen(srv: any, opts?: SocketIO.ServerOptions): SocketIO.Server;
+    listen(port: number, opts?: SocketIO.ServerOptions): SocketIO.Server;
+    listen(port: any, opts?: any): SocketIO.Server {
+        throw new Error("Method not implemented.");
+    }
+    bind(srv: any): SocketIO.Server {
+        throw new Error("Method not implemented.");
+    }
+    onconnection(socket: Client): SocketIO.Server {
+        this.allClients[socket.id] = socket;
+        socket.packet({
+            type: PacketTypes.OPEN,
+            data: {
+                sid: socket.id,
+                upgrades: [],
+                pingInterval: 25000,
+                pingTimeout: 5000
+            }
+        })
+        this.sockets.add(socket);
+        return this;
+    }
+    of(nsp: string): Namespace {
+        if (!this.nsps[nsp]) {
+            this.nsps[nsp] = new Namespace(nsp, this);
+        }
+        return this.nsps[nsp];
+    }
+    close(fn?: () => void): void {
+        for (let socket in this.sockets.sockets) {
+            this.sockets.sockets[socket].onclose()
+        }
+        this.nettyServer.close();
+    }
+    on(event: "connection", listener: (socket: SocketIO.Socket) => void): SocketIO.Namespace;
+    on(event: "connect", listener: (socket: SocketIO.Socket) => void): SocketIO.Namespace;
+    on(event: string, listener: Function): SocketIO.Namespace;
+    on(event: any, listener: any): SocketIO.Namespace {
+        return this.sockets.on(event, listener);
+    }
+    to(room: string): SocketIO.Namespace {
+        return this.sockets.to(room);
+    }
+    in(room: string): SocketIO.Namespace {
+        return this.sockets.in(room);
+    }
+    use(fn: (socket: SocketIO.Socket, fn: (err?: any) => void) => void): SocketIO.Namespace {
+        return this.sockets.use(fn);
+    }
+    emit(event: string, ...args: any[]): SocketIO.Namespace {
+        // @ts-ignore
+        return this.sockets.emit(event, ...args);
+    }
+    send(...args: any[]): SocketIO.Namespace {
+        return this.sockets.send(...args);
+    }
+    write(...args: any[]): SocketIO.Namespace {
+        return this.sockets.write(...args);
+    }
+    clients(...args: any[]): SocketIO.Namespace {
+        return this.sockets.clients(args[0]);
+    }
+    compress(...args: any[]): SocketIO.Namespace {
+        return this.sockets.compress(args[0])
+    }
+    // ===============================
+    checkNamespace(name, query, fn) {
+        fn(false);
+    };
+
+    private initNettyServer(pipeline, options) {
+        this.nettyServer = new NettyWebSocketServer(pipeline, options);
+        this.nettyServer.on(ServerEvent.connect, (nettyClient: NettyClient) => {
+            let client = new Client(this, nettyClient);
+            this.onconnection(client);
+        })
+        this.nettyServer.on(ServerEvent.message, (nettyClient: NettyClient, text) => {
+            this.processPacket(this.parser.decode(text), this.allClients[nettyClient.id]);
+        })
+        this.nettyServer.on(ServerEvent.error, (nettyClient: NettyClient, cause) => {
+            console.error(`Client ${nettyClient.id} cause error: ` + cause)
+            console.ex(cause)
+        })
+    }
+
+    private processPacket(packet: Packet, client: Client) {
+        switch (packet.type) {
+            case PacketTypes.PING:
+                client.packet({
+                    type: PacketTypes.PONG,
+                    data: packet.data
+                })
+                break;
+            case PacketTypes.UPGRADE:
+                break;
+            case PacketTypes.MESSAGE:
+                this.processSubPacket(packet, client);
+                break;
+            case PacketTypes.CLOSE:
+                client.onclose()
+                break;
+        }
+    }
+
+    private processSubPacket(packet: Packet, client: Client) {
+        let namespace = this.nsps[packet.nsp]
+        if (!namespace) {
+            client.packet({
+                type: PacketTypes.MESSAGE,
+                sub_type: SubPacketTypes.ERROR,
+                data: 'not support dynamic namespace: ' + packet.nsp
+            });
+            client.disconnect();
+            return;
+        }
+        namespace.process(packet, client);
+    }
+}
+export {
+    Server,
+    Socket,
+    Client,
+    ServerOptions
+}

packages/websocket/src/socket-io/interfaces.ts

@@ -0,0 +1,824 @@
+export declare namespace SocketIO {
+    interface Server {
+        engine: { ws: any };
+
+		/**
+		 * A dictionary of all the namespaces currently on this Server
+		 */
+        nsps: { [namespace: string]: Namespace };
+
+		/**
+		 * The default '/' Namespace
+		 */
+        sockets: Namespace;
+
+		/**
+		 * Sets the 'json' flag when emitting an event
+		 */
+        json: Server;
+
+		/**
+		 * Sets a modifier for a subsequent event emission that the event data may be lost if the clients are not ready to receive messages
+		 */
+        volatile: Server;
+
+		/**
+		 * Sets a modifier for a subsequent event emission that the event data will only be broadcast to the current node
+		 */
+        local: Server;
+
+		/**
+		 * Server request verification function, that checks for allowed origins
+		 * @param req The http.IncomingMessage request
+		 * @param fn The callback to be called. It should take one parameter, err,
+		 * which will be null if there was no problem, and one parameter, success,
+		 * of type boolean
+		 */
+        checkRequest(req: any, fn: (err: any, success: boolean) => void): void;
+
+		/**
+		 * Gets whether we're serving the client.js file or not
+		 * @default true
+		 */
+        serveClient(): boolean;
+
+		/**
+		 * Sets whether we're serving the client.js file or not
+		 * @param v True if we want to serve the file, false otherwise
+		 * @default true
+		 * @return This Server
+		 */
+        serveClient(v: boolean): Server;
+
+		/**
+		 * Gets the client serving path
+		 * @default '/socket.io'
+		 */
+        path(): string;
+
+		/**
+		 * Sets the client serving path
+		 * @param v The path to serve the client file on
+		 * @default '/socket.io'
+		 * @return This Server
+		 */
+        path(v: string): Server;
+
+		/**
+		 * Gets the adapter that we're going to use for handling rooms
+		 * @default typeof Adapter
+		 */
+        adapter(): any;
+
+		/**
+		 * Sets the adapter (class) that we're going to use for handling rooms
+		 * @param v The class for the adapter to create
+		 * @default typeof Adapter
+		 * @return This Server
+		 */
+        adapter(v: any): Server;
+
+		/**
+		 * Gets the allowed origins for requests
+		 * @default "*:*"
+		 */
+        origins(): string | string[];
+
+		/**
+		 * Sets the allowed origins for requests
+		 * @param v The allowed origins, in host:port form
+		 * @default "*:*"
+		 * return This Server
+		 */
+        origins(v: string | string[]): Server;
+
+		/**
+		 * Provides a function taking two arguments origin:String
+		 * and callback(error, success), where success is a boolean
+		 * value indicating whether origin is allowed or not. If
+		 * success is set to false, error must be provided as a string
+		 * value that will be appended to the server response, e.g. “Origin not allowed”.
+		 * @param fn The function that will be called to check the origin
+		 * return This Server
+		 */
+        origins(fn: (origin: string, callback: (error: string | null, success: boolean) => void) => void): Server;
+
+		/**
+		 * Attaches socket.io to a server
+		 * @param srv The http.Server that we want to attach to
+		 * @param opts An optional parameters object
+		 * @return This Server
+		 */
+        attach(srv: any, opts?: ServerOptions): Server;
+
+		/**
+		 * Attaches socket.io to a port
+		 * @param port The port that we want to attach to
+		 * @param opts An optional parameters object
+		 * @return This Server
+		 */
+        attach(port: number, opts?: ServerOptions): Server;
+
+		/**
+		 * @see attach( srv, opts )
+		 */
+        listen(srv: any, opts?: ServerOptions): Server;
+
+		/**
+		 * @see attach( port, opts )
+		 */
+        listen(port: number, opts?: ServerOptions): Server;
+
+		/**
+		 * Binds socket.io to an engine.io instance
+		 * @param src The Engine.io (or compatible) server to bind to
+		 * @return This Server
+		 */
+        bind(srv: any): Server;
+
+		/**
+		 * Called with each incoming connection
+		 * @param socket The Engine.io Socket
+		 * @return This Server
+		 */
+        onconnection(socket: any): Server;
+
+		/**
+		 * Looks up/creates a Namespace
+		 * @param nsp The name of the NameSpace to look up/create. Should start
+		 * with a '/'
+		 * @return The Namespace
+		 */
+        of(nsp: string | RegExp | Function): Namespace;
+
+		/**
+		 * Closes the server connection
+		 */
+        close(fn?: () => void): void;
+
+		/**
+		 * The event fired when we get a new connection
+		 * @param event The event being fired: 'connection'
+		 * @param listener A listener that should take one parameter of type Socket
+		 * @return The default '/' Namespace
+		 */
+        on(event: 'connection', listener: (socket: Socket) => void): Namespace;
+
+		/**
+		 * @see on( 'connection', listener )
+		 */
+        on(event: 'connect', listener: (socket: Socket) => void): Namespace;
+
+		/**
+		 * Base 'on' method to add a listener for an event
+		 * @param event The event that we want to add a listener for
+		 * @param listener The callback to call when we get the event. The parameters
+		 * for the callback depend on the event
+		 * @return The default '/' Namespace
+		 */
+        on(event: string, listener: Function): Namespace;
+
+		/**
+		 * Targets a room when emitting to the default '/' Namespace
+		 * @param room The name of the room that we're targeting
+		 * @return The default '/' Namespace
+		 */
+        to(room: string): Namespace;
+
+		/**
+		 * @see to( room )
+		 */
+        in(room: string): Namespace;
+
+		/**
+		 * Registers a middleware function, which is a function that gets executed
+		 * for every incoming Socket, on the default '/' Namespace
+		 * @param fn The function to call when we get a new incoming socket. It should
+		 * take one parameter of type Socket, and one callback function to call to
+		 * execute the next middleware function. The callback can take one optional
+		 * parameter, err, if there was an error. Errors passed to middleware callbacks
+		 * are sent as special 'error' packets to clients
+		 * @return The default '/' Namespace
+		 */
+        use(fn: (socket: Socket, fn: (err?: any) => void) => void): Namespace;
+
+		/**
+		 * Emits an event to the default Namespace
+		 * @param event The event that we want to emit
+		 * @param args Any number of optional arguments to pass with the event. If the
+		 * last argument is a function, it will be called as an ack. The ack should
+		 * take whatever data was sent with the packet
+		 * @return The default '/' Namespace
+		 */
+        emit(event: string, ...args: any[]): Namespace;
+
+		/**
+		 * Sends a 'message' event
+		 * @see emit( event, ...args )
+		 * @return The default '/' Namespace
+		 */
+        send(...args: any[]): Namespace;
+
+		/**
+		 * @see send( ...args )
+		 */
+        write(...args: any[]): Namespace;
+
+		/**
+		 * Gets a list of clients
+		 * @return The default '/' Namespace
+		 */
+        clients(...args: any[]): Namespace;
+
+		/**
+		 * Sets the compress flag
+		 * @return The default '/' Namespace
+		 */
+        compress(...args: any[]): Namespace;
+    }
+
+	/**
+	 * Options to pass to our server when creating it
+	 */
+    interface ServerOptions {
+
+		/**
+		 * The path to server the client file to
+		 * @default '/socket.io'
+		 */
+        path?: string;
+
+		/**
+		 * Should we serve the client file?
+		 * @default true
+		 */
+        serveClient?: boolean;
+
+		/**
+		 * The adapter to use for handling rooms. NOTE: this should be a class,
+		 * not an object
+		 * @default typeof Adapter
+		 */
+        adapter?: Adapter;
+
+		/**
+		 * Accepted origins
+		 * @default '*:*'
+		 */
+        origins?: string | string[];
+
+		/**
+		 * How many milliseconds without a pong packed to consider the connection closed (engine.io)
+		 * @default 60000
+		 */
+        pingTimeout?: number;
+
+		/**
+		 * How many milliseconds before sending a new ping packet (keep-alive) (engine.io)
+		 * @default 25000
+		 */
+        pingInterval?: number;
+
+		/**
+		 * How many bytes or characters a message can be when polling, before closing the session
+		 * (to avoid Dos) (engine.io)
+		 * @default 10E7
+		 */
+        maxHttpBufferSize?: number;
+
+		/**
+		 * A function that receives a given handshake or upgrade request as its first parameter,
+		 * and can decide whether to continue or not. The second argument is a function that needs
+		 * to be called with the decided information: fn( err, success ), where success is a boolean
+		 * value where false means that the request is rejected, and err is an error code (engine.io)
+		 * @default null
+		 */
+        allowRequest?: (request: any, callback: (err: number, success: boolean) => void) => void;
+
+		/**
+		 * Transports to allow connections to (engine.io)
+		 * @default ['polling','websocket']
+		 */
+        transports?: string[];
+
+		/**
+		 * Whether to allow transport upgrades (engine.io)
+		 * @default true
+		 */
+        allowUpgrades?: boolean;
+
+		/**
+		 * parameters of the WebSocket permessage-deflate extension (see ws module).
+		 * Set to false to disable (engine.io)
+		 * @default true
+		 */
+        perMessageDeflate?: Object | boolean;
+
+		/**
+		 * Parameters of the http compression for the polling transports (see zlib).
+		 * Set to false to disable, or set an object with parameter "threshold:number"
+		 * to only compress data if the byte size is above this value (1024) (engine.io)
+		 * @default true|1024
+		 */
+        httpCompression?: Object | boolean;
+
+		/**
+		 * Name of the HTTP cookie that contains the client sid to send as part of
+		 * handshake response headers. Set to false to not send one (engine.io)
+		 * @default "io"
+		 */
+        cookie?: string | boolean;
+
+        /**
+         * Whether to let engine.io handle the OPTIONS requests.
+         * You can also pass a custom function to handle the requests
+         * @default true
+         */
+        handlePreflightRequest?: ((req: any, res: any) => void) | boolean;
+    }
+
+	/**
+	 * The Namespace, sandboxed environments for sockets, each connection
+	 * to a Namespace requires a new Socket
+	 */
+    interface Namespace extends NodeJS.EventEmitter {
+
+		/**
+		 * The name of the NameSpace
+		 */
+        name: string;
+
+		/**
+		 * The controller Server for this Namespace
+		 */
+        server: Server;
+
+		/**
+		 * A dictionary of all the Sockets connected to this Namespace, where
+		 * the Socket ID is the key
+		 */
+        sockets: { [id: string]: Socket };
+
+		/**
+		 * A dictionary of all the Sockets connected to this Namespace, where
+		 * the Socket ID is the key
+		 */
+        connected: { [id: string]: Socket };
+
+		/**
+		 * The Adapter that we're using to handle dealing with rooms etc
+		 */
+        adapter: Adapter;
+
+		/**
+		 * Sets the 'json' flag when emitting an event
+		 */
+        json: Namespace;
+
+		/**
+		 * Registers a middleware function, which is a function that gets executed
+		 * for every incoming Socket
+		 * @param fn The function to call when we get a new incoming socket. It should
+		 * take one parameter of type Socket, and one callback function to call to
+		 * execute the next middleware function. The callback can take one optional
+		 * parameter, err, if there was an error. Errors passed to middleware callbacks
+		 * are sent as special 'error' packets to clients
+		 * @return This Namespace
+		 */
+        use(fn: (socket: Socket, fn: (err?: any) => void) => void): Namespace;
+
+		/**
+		 * Targets a room when emitting
+		 * @param room The name of the room that we're targeting
+		 * @return This Namespace
+		 */
+        to(room: string): Namespace;
+
+		/**
+		 * @see to( room )
+		 */
+        in(room: string): Namespace;
+
+		/**
+		 * Sends a 'message' event
+		 * @see emit( event, ...args )
+		 * @return This Namespace
+		 */
+        send(...args: any[]): Namespace;
+
+		/**
+		 * @see send( ...args )
+		 */
+        write(...args: any[]): Namespace;
+
+		/**
+		 * The event fired when we get a new connection
+		 * @param event The event being fired: 'connection'
+		 * @param listener A listener that should take one parameter of type Socket
+		 * @return This Namespace
+		 */
+        on(event: 'connection', listener: (socket: Socket) => void): this;
+
+		/**
+		 * @see on( 'connection', listener )
+		 */
+        on(event: 'connect', listener: (socket: Socket) => void): this;
+
+		/**
+		 * Base 'on' method to add a listener for an event
+		 * @param event The event that we want to add a listener for
+		 * @param listener The callback to call when we get the event. The parameters
+		 * for the callback depend on the event
+		 * @ This Namespace
+		 */
+        on(event: string, listener: Function): this;
+
+		/**
+		 * Gets a list of clients.
+		 * @return This Namespace
+		 */
+        clients(fn: Function): Namespace;
+
+		/**
+		 * Sets the compress flag.
+		 * @param compress If `true`, compresses the sending data
+		 * @return This Namespace
+		 */
+        compress(compress: boolean): Namespace;
+    }
+
+    interface Packet extends Array<any> {
+		/**
+		 * Event name
+		 */
+        [0]: string;
+		/**
+		 * Packet data
+		 */
+        [1]: any;
+		/**
+		 * Ack function
+		 */
+        [2]: (...args: any[]) => void;
+    }
+
+	/**
+	 * The socket, which handles our connection for a namespace. NOTE: while
+	 * we technically extend NodeJS.EventEmitter, we're not putting it here
+	 * as we have a problem with the emit() event (as it's overridden with a
+	 * different return)
+	 */
+    interface Socket extends NodeJS.EventEmitter {
+
+		/**
+		 * The namespace that this socket is for
+		 */
+        nsp: Namespace;
+
+		/**
+		 * The Server that our namespace is in
+		 */
+        server: Server;
+
+		/**
+		 * The Adapter that we use to handle our rooms
+		 */
+        adapter: Adapter;
+
+		/**
+		 * The unique ID for this Socket. Regenerated at every connection. This is
+		 * also the name of the room that the Socket automatically joins on connection
+		 */
+        id: string;
+
+		/**
+		 * The http.IncomingMessage request sent with the connection. Useful
+		 * for recovering headers etc
+		 */
+        request: any;
+
+		/**
+		 * The Client associated with this Socket
+		 */
+        client: Client;
+
+		/**
+		 * The underlying Engine.io Socket instance
+		 */
+        conn: EngineSocket;
+
+		/**
+		 * The list of rooms that this Socket is currently in, where
+		 * the ID the the room ID
+		 */
+        rooms: { [id: string]: string };
+
+		/**
+		 * Is the Socket currently connected?
+		 */
+        connected: boolean;
+
+		/**
+		 * Is the Socket currently disconnected?
+		 */
+        disconnected: boolean;
+
+		/**
+		 * The object used when negociating the handshake
+		 */
+        handshake: Handshake;
+		/**
+		 * Sets the 'json' flag when emitting an event
+		 */
+        json: Socket;
+
+		/**
+		 * Sets the 'volatile' flag when emitting an event. Volatile messages are
+		 * messages that can be dropped because of network issues and the like. Use
+		 * for high-volume/real-time messages where you don't need to receive *all*
+		 * of them
+		 */
+        volatile: Socket;
+
+		/**
+		 * Sets the 'broadcast' flag when emitting an event. Broadcasting an event
+		 * will send it to all the other sockets in the namespace except for yourself
+		 */
+        broadcast: Socket;
+
+		/**
+		 * Targets a room when broadcasting
+		 * @param room The name of the room that we're targeting
+		 * @return This Socket
+		 */
+        to(room: string): Socket;
+
+		/**
+		 * @see to( room )
+		 */
+        in(room: string): Socket;
+
+		/**
+		 * Registers a middleware, which is a function that gets executed for every incoming Packet and receives as parameter the packet and a function to optionally defer execution to the next registered middleware.
+		 *
+		 * Errors passed to middleware callbacks are sent as special error packets to clients.
+		 */
+        use(fn: (packet: Packet, next: (err?: any) => void) => void): Socket;
+
+		/**
+		 * Sends a 'message' event
+		 * @see emit( event, ...args )
+		 */
+        send(...args: any[]): Socket;
+
+		/**
+		 * @see send( ...args )
+		 */
+        write(...args: any[]): Socket;
+
+		/**
+		 * Joins a room. You can join multiple rooms, and by default, on connection,
+		 * you join a room with the same name as your ID
+		 * @param name The name of the room that we want to join
+		 * @param fn An optional callback to call when we've joined the room. It should
+		 * take an optional parameter, err, of a possible error
+		 * @return This Socket
+		 */
+        join(name: string | string[], fn?: (err?: any) => void): Socket;
+
+		/**
+		 * Leaves a room
+		 * @param name The name of the room to leave
+		 * @param fn An optional callback to call when we've left the room. It should
+		 * take on optional parameter, err, of a possible error
+		 */
+        leave(name: string, fn?: Function): Socket;
+
+		/**
+		 * Leaves all the rooms that we've joined
+		 */
+        leaveAll(): void;
+
+		/**
+		 * Disconnects this Socket
+		 * @param close If true, also closes the underlying connection
+		 * @return This Socket
+		 */
+        disconnect(close?: boolean): Socket;
+
+		/**
+		 * Returns all the callbacks for a particular event
+		 * @param event The event that we're looking for the callbacks of
+		 * @return An array of callback Functions, or an empty array if we don't have any
+		 */
+        listeners(event: string): Function[];
+
+		/**
+		 * Sets the compress flag
+		 * @param compress If `true`, compresses the sending data
+		 * @return This Socket
+		 */
+        compress(compress: boolean): Socket;
+
+        /**
+         * Emits the error
+         * @param err Error message=
+         */
+        error(err: any): void;
+    }
+
+    interface Handshake {
+		/**
+		 * The headers passed along with the request. e.g. 'host',
+		 * 'connection', 'accept', 'referer', 'cookie'
+		 */
+        headers: any;
+
+		/**
+		 * The current time, as a string
+		 */
+        time: string;
+
+		/**
+		 * The remote address of the connection request
+		 */
+        address: string;
+
+		/**
+		 * Is this a cross-domain request?
+		 */
+        xdomain: boolean;
+
+		/**
+		 * Is this a secure request?
+		 */
+        secure: boolean;
+
+		/**
+		 * The timestamp for when this was issued
+		 */
+        issued: number;
+
+		/**
+		 * The request url
+		 */
+        url: string;
+
+		/**
+		 * Any query string parameters in the request url
+		 */
+        query: any;
+    }
+
+	/**
+	 * The interface describing a room
+	 */
+    interface Room {
+        sockets: { [id: string]: boolean };
+        length: number;
+    }
+
+	/**
+	 * The interface describing a dictionary of rooms
+	 * Where room is the name of the room
+	 */
+
+    interface Rooms {
+        [room: string]: Room;
+    }
+
+	/**
+	 * The interface used when dealing with rooms etc
+	 */
+    interface Adapter extends NodeJS.EventEmitter {
+
+		/**
+		 * The namespace that this adapter is for
+		 */
+        nsp: Namespace;
+
+		/**
+		 * A dictionary of all the rooms that we have in this namespace
+		 */
+        rooms: Rooms;
+
+		/**
+		 * A dictionary of all the socket ids that we're dealing with, and all
+		 * the rooms that the socket is currently in
+		 */
+        sids: { [id: string]: { [room: string]: boolean } };
+
+		/**
+		 * Adds a socket to a room. If the room doesn't exist, it's created
+		 * @param id The ID of the socket to add
+		 * @param room The name of the room to add the socket to
+		 * @param callback An optional callback to call when the socket has been
+		 * added. It should take an optional parameter, error, if there was a problem
+		 */
+        add(id: string, room: string, callback?: (err?: any) => void): void;
+
+		/**
+		 * Removes a socket from a room. If there are no more sockets in the room,
+		 * the room is deleted
+		 * @param id The ID of the socket that we're removing
+		 * @param room The name of the room to remove the socket from
+		 * @param callback An optional callback to call when the socket has been
+		 * removed. It should take on optional parameter, error, if there was a problem
+		 */
+        del(id: string, room: string, callback?: (err?: any) => void): void;
+
+		/**
+		 * Removes a socket from all the rooms that it's joined
+		 * @param id The ID of the socket that we're removing
+		 */
+        delAll(id: string): void;
+
+		/**
+		 * Broadcasts a packet
+		 * @param packet The packet to broadcast
+		 * @param opts Any options to send along:
+		 * 	- rooms: An optional list of rooms to broadcast to. If empty, the packet is broadcast to all sockets
+		 * 	- except: A list of Socket IDs to exclude
+		 * 	- flags: Any flags that we want to send along ('json', 'volatile', 'broadcast')
+		 */
+        broadcast(packet: any, opts: { rooms?: string[]; except?: string[]; flags?: { [flag: string]: boolean } }): void;
+    }
+
+	/**
+	 * The client behind each socket (can have multiple sockets)
+	 */
+    interface Client {
+		/**
+		 * The Server that this client belongs to
+		 */
+        server: Server;
+
+		/**
+		 * The underlying Engine.io Socket instance
+		 */
+        conn: EngineSocket;
+
+		/**
+		 * The ID for this client. Regenerated at every connection
+		 */
+        id: string;
+
+		/**
+		 * The http.IncomingMessage request sent with the connection. Useful
+		 * for recovering headers etc
+		 */
+        request: any;
+
+		/**
+		 * The dictionary of sockets currently connect via this client (i.e. to different
+		 * namespaces) where the Socket ID is the key
+		 */
+        sockets: { [id: string]: Socket };
+
+		/**
+		 * A dictionary of all the namespaces for this client, with the Socket that
+		 * deals with that namespace
+		 */
+        nsps: { [nsp: string]: Socket };
+    }
+
+	/**
+	 * A reference to the underlying engine.io Socket connection.
+	 */
+    interface EngineSocket extends NodeJS.EventEmitter {
+		/**
+		 * The ID for this socket - matches Client.id
+		 */
+        id: string;
+
+		/**
+		 * The Engine.io Server for this socket
+		 */
+        server: any;
+
+		/**
+		 * The ready state for the client. Either 'opening', 'open', 'closing', or 'closed'
+		 */
+        readyState: string;
+
+		/**
+		 * The remote IP for this connection
+		 */
+        remoteAddress: string;
+
+		/**
+		 * whether the transport has been upgraded
+		 */
+        upgraded: boolean;
+
+		/**
+		 * (http.IncomingMessage): request that originated the Socket
+		 */
+        request: any;
+
+		/**
+		 * (Transport): transport reference
+		 */
+        transport: any;
+    }
+}

packages/websocket/src/socket-io/namespace.ts

@@ -0,0 +1,136 @@
+import { EventEmitter } from 'events'
+
+import { Client } from './client'
+import { SocketIO } from './interfaces';
+import { ServerEvent } from '../server';
+import { Socket } from './socket';
+import { Adapter } from './adapter';
+import { Server } from './index'
+import { Packet } from './packet';
+import { SubPacketTypes } from './types';
+
+export class Namespace extends EventEmitter implements SocketIO.Namespace {
+    name: string;
+    server: Server;
+    sockets: { [id: string]: Socket; };
+    connected: { [id: string]: Socket; };
+    adapter: SocketIO.Adapter;
+    json: SocketIO.Namespace;
+
+    fns: any[];
+    ids: number;
+    rooms: string[];
+    flags: { [key: string]: boolean };
+
+    private events = ['connect', 'connection', 'newListener']
+
+    constructor(name: string, server: Server) {
+        super();
+        this.name = name;
+        this.server = server;
+        this.sockets = {};
+        this.connected = {};
+        this.fns = [];
+        this.ids = 0;
+        this.rooms = [];
+        this.flags = {};
+        this.adapter = new Adapter(this);
+    }
+    initAdapter() {
+        // @ts-ignore
+        this.adapter = new (this.server.adapter())()
+    }
+    add(client: Client, query?: any, callback?: () => void) {
+        // client.conn.request.url();
+        let socket = new Socket(this, client, {});
+        this.sockets[client.id] = socket;
+        client.nsps[this.name] = socket;
+        this.onconnection(socket);
+        return socket;
+    }
+    del(client: Client) {
+        let socket = this.sockets[client.id];
+        socket.disconnect();
+        delete this.sockets[client.id];
+    }
+    use(fn: (socket: SocketIO.Socket, fn: (err?: any) => void) => void): SocketIO.Namespace {
+        throw new Error("Method not implemented.");
+    }
+    to(room: string): SocketIO.Namespace {
+        if (!~this.rooms.indexOf(room)) this.rooms.push(room);
+        return this;
+    }
+    in(room: string): SocketIO.Namespace {
+        return this.to(room);
+    }
+    send(...args: any[]): SocketIO.Namespace {
+        super.emit('message', ...args)
+        return this;
+    }
+    write(...args: any[]): SocketIO.Namespace {
+        return this.send(...args);
+    }
+    emit(event: string, ...args: any[]): boolean {
+        if (~this.events.indexOf(event)) {
+            super.emit(event, ...args);
+            // @ts-ignore
+            return this;
+        }
+        // set up packet object
+        var packet = {
+            type: (this.flags.binary !== undefined ? this.flags.binary : this.hasBin(args)) ? SubPacketTypes.BINARY_EVENT : SubPacketTypes.EVENT,
+            data: args
+        }
+
+        if ('function' == typeof args[args.length - 1]) {
+            throw new Error('Callbacks are not supported when broadcasting');
+        }
+
+        var rooms = this.rooms.slice(0);
+        var flags = Object.assign({}, this.flags);
+
+        // reset flags
+        this.rooms = [];
+        this.flags = {};
+
+        this.adapter.broadcast(packet, {
+            rooms: rooms,
+            flags: flags
+        });
+        // @ts-ignore
+        return this;
+    }
+    hasBin(args: any[]) {
+        return false;
+    }
+    clients(fn: Function): SocketIO.Namespace {
+        return fn(Object.values(this.sockets))
+    }
+    compress(compress: boolean): SocketIO.Namespace {
+        throw new Error("Method not implemented.");
+    }
+    process(packet: Packet, client: Client) {
+        switch (packet.sub_type) {
+            case SubPacketTypes.CONNECT:
+                this.add(client);
+                break;
+            default:
+                this.sockets[client.id].onpacket(packet);
+                break;
+        }
+    }
+    remove(socket: Socket) {
+        if (this.sockets.hasOwnProperty(socket.id)) {
+            delete this.sockets[socket.id];
+        } else {
+            // debug('ignoring remove for %s', socket.id);
+        }
+    }
+    private onconnection(socket: any) {
+        let client = socket as Socket;
+        this.sockets[client.id] = client;
+        client.onconnect()
+        this.emit(ServerEvent.connect, socket);
+        this.emit(ServerEvent.connection, socket);
+    }
+}

packages/websocket/src/socket-io/packet.ts

@@ -0,0 +1,11 @@
+import { PacketTypes, SubPacketTypes } from './types'
+
+export interface Packet {
+    type: PacketTypes;
+    sub_type?: SubPacketTypes;
+    nsp?: string;
+    id?: number;
+    name?: string;
+    data?: any;
+    attachments?: any;
+}

packages/websocket/src/socket-io/parser.ts

@@ -0,0 +1,158 @@
+import { Packet } from "./packet";
+import { PacketTypes, SubPacketTypes } from "./types";
+
+export class Parser {
+    encode(packet: Packet): string {
+        let origin = JSON.stringify(packet)
+        // first is type
+        let str = '' + packet.type;
+        if (packet.type == PacketTypes.PONG) {
+            if (packet.data) { str += packet.data };
+            return str;
+        }
+        if (packet.sub_type != undefined) {
+            str += packet.sub_type;
+        }
+        // attachments if we have them
+        if ([SubPacketTypes.BINARY_EVENT, SubPacketTypes.BINARY_ACK].includes(packet.sub_type)) {
+            str += packet.attachments + '-';
+        }
+        // if we have a namespace other than `/`
+        // we append it followed by a comma `,`
+        if (packet.nsp && '/' !== packet.nsp) {
+            str += packet.nsp + ',';
+        }
+        // immediately followed by the id
+        if (null != packet.id) {
+            str += packet.id;
+        }
+        if (packet.sub_type == SubPacketTypes.EVENT) {
+            if (packet.name == undefined) { throw new Error(`SubPacketTypes.EVENT name can't be empty!`) }
+            packet.data = [packet.name, ...packet.data]
+        }
+        // json data
+        if (null != packet.data) {
+            let payload = this.tryStringify(packet.data);
+            if (payload !== false) {
+                str += payload;
+            } else {
+                return '4"encode error"'
+            }
+        }
+        console.debug(`encoded ${origin} as ${str}`);
+        return str;
+    }
+    tryStringify(str) {
+        try {
+            return JSON.stringify(str);
+        } catch (e) {
+            return false;
+        }
+    }
+    decode(str: string): Packet {
+        let i = 0;
+        // ignore parse binary
+        // if ((frame.getByte(0) == 'b' && frame.getByte(1) == '4')
+        //     || frame.getByte(0) == 4 || frame.getByte(0) == 1) {
+        //     return parseBinary(head, frame);
+        // }
+        // look up type
+        let p: Packet = {
+            type: Number(str.charAt(i))
+        };
+        if (null == PacketTypes[p.type]) {
+            return this.error('unknown packet type ' + p.type);
+        }
+        // if str empty return
+        if (str.length == i + 1) {
+            return p;
+        }
+        // if is ping packet read data and return
+        if (PacketTypes.PING == p.type) {
+            p.data = str.substr(++i);
+            return p;
+        }
+        // look up sub type
+        p.sub_type = Number(str.charAt(++i));
+        if (null == PacketTypes[p.sub_type]) {
+            return this.error('unknown sub packet type ' + p.type);
+        }
+        // look up attachments if type binary
+        if ([SubPacketTypes.BINARY_ACK, SubPacketTypes.BINARY_EVENT].includes(p.sub_type)) {
+            let buf = '';
+            while (str.charAt(++i) !== '-') {
+                buf += str.charAt(i);
+                if (i == str.length) break;
+            }
+            if (buf != `${Number(buf)}` || str.charAt(i) !== '-') {
+                return this.error('Illegal attachments');
+            }
+            p.attachments = Number(buf);
+        }
+
+        // look up namespace (if any)
+        if ('/' === str.charAt(i + 1)) {
+            p.nsp = '';
+            while (++i) {
+                let c = str.charAt(i);
+                if (',' === c) break;
+                p.nsp += c;
+                if (i === str.length) break;
+            }
+        } else {
+            p.nsp = '/';
+        }
+
+        // look up id
+        let next = str.charAt(i + 1);
+        if ('' !== next && !isNaN(Number(next))) {
+            let id = ''
+            while (++i) {
+                let c = str.charAt(i);
+                if (null == c || isNaN(Number(c))) {
+                    --i;
+                    break;
+                }
+                id += str.charAt(i);
+                if (i === str.length) break;
+            }
+            p.id = Number(id);
+        }
+
+        // ignore binary packet
+        if (p.sub_type == SubPacketTypes.BINARY_EVENT) {
+            return this.error('not support binary parse...')
+        }
+
+        // look up json data
+        if (str.charAt(++i)) {
+            let payload = this.tryParse(str.substr(i));
+            let isPayloadValid = payload !== false && (p.sub_type == SubPacketTypes.ERROR || Array.isArray(payload));
+            if (isPayloadValid) {
+                p.name = payload[0];
+                p.data = payload.slice(1);
+            } else {
+                return this.error('invalid payload ' + str.substr(i));
+            }
+        }
+
+        console.debug(`decoded ${str} as ${JSON.stringify(p)}`);
+        return p;
+    }
+
+    tryParse(str) {
+        try {
+            return JSON.parse(str);
+        } catch (e) {
+            return false;
+        }
+    }
+
+    error(error: string): Packet {
+        return {
+            type: PacketTypes.MESSAGE,
+            sub_type: SubPacketTypes.ERROR,
+            data: 'parser error: ' + error
+        };
+    }
+}

packages/websocket/src/socket-io/socket.ts

@@ -0,0 +1,294 @@
+import { EventEmitter } from 'events'
+
+import { SocketIO } from "./interfaces";
+import { Packet } from './packet';
+import { PacketTypes, SubPacketTypes } from './types';
+import { Client } from './client';
+import { Namespace } from './namespace';
+
+export class Socket extends EventEmitter implements SocketIO.Socket {
+    nsp: Namespace;
+    server: SocketIO.Server;
+    adapter: SocketIO.Adapter;
+    id: string;
+    request: any;
+    client: Client;
+    conn: SocketIO.EngineSocket;
+    rooms: { [id: string]: string; };
+    acks: { [id: string]: Function; };
+    connected: boolean;
+    disconnected: boolean;
+    handshake: SocketIO.Handshake;
+    fns: any[];
+    flags: { [key: string]: boolean };
+    _rooms: string[];
+
+    private events = [
+        'error',
+        'connect',
+        'disconnect',
+        'disconnecting',
+        'newListener',
+        'removeListener'
+    ]
+
+    constructor(nsp: Namespace, client: Client, query = {}) {
+        super();
+        this.nsp = nsp;
+        this.server = nsp.server;
+        this.adapter = this.nsp.adapter;
+        this.id = nsp.name !== '/' ? nsp.name + '#' + client.id : client.id;
+        this.client = client;
+        this.request = client.request;
+        this.conn = client.conn;
+        this.rooms = {};
+        this.acks = {};
+        this.connected = true;
+        this.disconnected = false;
+        // this.handshake = this.buildHandshake(query);
+        this.fns = [];
+        this.flags = {};
+        this._rooms = [];
+    }
+
+    get json() {
+        this.flags.json = true;
+        return this
+    }
+
+    get volatile() {
+        this.flags.volatile = true;
+        return this
+    }
+    get broadcast() {
+        this.flags.broadcast = true;
+        return this
+    }
+    get local() {
+        this.flags.local = true;
+        return this
+    }
+
+    to(room: string): SocketIO.Socket {
+        if (!~this._rooms.indexOf(room)) this._rooms.push(room);
+        return this;
+    }
+    in(room: string): SocketIO.Socket {
+        return this.to(room);
+    }
+    use(fn: (packet: SocketIO.Packet, next: (err?: any) => void) => void): SocketIO.Socket {
+        throw new Error("Method not implemented.");
+    }
+    send(...args: any[]): SocketIO.Socket {
+        this.emit("message", ...args)
+        return this;
+    }
+    write(...args: any[]): SocketIO.Socket {
+        return this.send(...args);
+    }
+    join(rooms: string | string[], fn?: (err?: any) => void): SocketIO.Socket {
+        if (!Array.isArray(rooms)) {
+            rooms = [rooms];
+        }
+        rooms = rooms.filter((room) => {
+            return !this.rooms.hasOwnProperty(room);
+        });
+        if (!rooms.length) {
+            fn && fn(null);
+            return this;
+        }
+        return this;
+    }
+    leave(name: string, fn?: Function): SocketIO.Socket {
+        delete this.rooms[name];
+        fn && fn(null)
+        return this;
+    }
+    leaveAll(): void {
+        this.adapter.delAll(this.id);
+        this.rooms = {};
+    }
+    disconnect(close?: boolean): SocketIO.Socket {
+        if (!this.connected) return this;
+        if (close) {
+            this.client.disconnect();
+        } else {
+            this.packet({ type: PacketTypes.MESSAGE, sub_type: SubPacketTypes.DISCONNECT });
+            this.onclose('server namespace disconnect');
+        }
+        return this;
+    }
+    compress(compress: boolean): SocketIO.Socket {
+        throw new Error("Method not implemented.");
+    }
+    error(err: any): void {
+        this.packet({ type: PacketTypes.MESSAGE, sub_type: SubPacketTypes.ERROR, data: err });
+    }
+
+    // ==========================================
+    buildHandshake(query): SocketIO.Handshake {
+        let requestQuery = this.request.uri();
+        return {
+            headers: this.request.headers(),
+            time: (new Date) + '',
+            address: this.conn.remoteAddress,
+            xdomain: !!this.request.headers.origin,
+            secure: !!this.request.connection.encrypted,
+            issued: +(new Date),
+            url: this.request.url,
+            query: Object.assign(query, requestQuery)
+        }
+    }
+    emit(event: string, ...args: any[]): boolean {
+        if (~this.events.indexOf(event)) {
+            super.emit(event, ...args);
+            // @ts-ignore
+            return this;
+        }
+
+        let packet: Packet = {
+            type: PacketTypes.MESSAGE,
+            sub_type: (this.flags.binary !== undefined ? this.flags.binary : this.hasBin(args)) ? SubPacketTypes.BINARY_EVENT : SubPacketTypes.EVENT,
+            name: event,
+            data: args
+        }
+
+        // access last argument to see if it's an ACK callback
+        if (typeof args[args.length - 1] === 'function') {
+            if (this._rooms.length || this.flags.broadcast) {
+                throw new Error('Callbacks are not supported when broadcasting');
+            }
+            // debug('emitting packet with ack id %d', this.nsp.ids);
+            this.acks[this.nsp.ids] = args.pop();
+            packet.id = this.nsp.ids++;
+        }
+
+        let rooms = this._rooms.slice(0);
+        let flags = Object.assign({}, this.flags);
+
+        // reset flags
+        this._rooms = [];
+        this.flags = {};
+
+        if (rooms.length || flags.broadcast) {
+            this.adapter.broadcast(packet, {
+                except: [this.id],
+                rooms: rooms,
+                flags: flags
+            });
+        } else {
+            // dispatch packet
+            this.packet(packet, flags);
+        }
+        // @ts-ignore
+        return this;
+    }
+    packet(packet: Packet, opts?: any) {
+        packet.nsp = this.nsp.name;
+        opts = opts || {};
+        opts.compress = false !== opts.compress;
+        this.client.packet(packet, opts);
+    }
+    onconnect() {
+        this.nsp.connected[this.id] = this;
+        this.client.sockets[this.id] = this;
+        this.join(this.id);
+        // let skip = this.nsp.name === '/' && this.nsp.fns.length === 0;
+        // if (skip) {
+        // debug('packet already sent in initial handshake');
+        // } else {
+        this.packet({
+            type: PacketTypes.MESSAGE,
+            sub_type: SubPacketTypes.CONNECT
+        });
+        // }
+    }
+    onclose(reason?: string) {
+        if (!this.connected) return this;
+        // debug('closing socket - reason %s', reason);
+        this.emit('disconnecting', reason);
+        this.leaveAll();
+        this.nsp.remove(this);
+        this.client.remove(this);
+        this.connected = false;
+        this.disconnected = true;
+        delete this.nsp.connected[this.id];
+        this.emit('disconnect', reason);
+    }
+    onpacket(packet: Packet) {
+        switch (packet.sub_type) {
+            // 2
+            case SubPacketTypes.EVENT:
+                this.onevent(packet);
+                break;
+            // 5
+            case SubPacketTypes.BINARY_EVENT:
+                this.onevent(packet);
+                break;
+            // 3
+            case SubPacketTypes.ACK:
+                this.onack(packet);
+                break;
+            // 6
+            case SubPacketTypes.BINARY_ACK:
+                this.onack(packet);
+                break;
+            // 1
+            case SubPacketTypes.DISCONNECT:
+                this.ondisconnect();
+                break;
+            // 4
+            case SubPacketTypes.ERROR:
+                this.onerror(new Error(packet.data));
+        }
+    }
+    onerror(err: Error) {
+        if (this.listeners('error').length) {
+            this.emit('error', err);
+        } else {
+            console.error('Missing error handler on `socket`.');
+            console.error(err.stack);
+        }
+    }
+    ondisconnect() {
+        this.onclose('client namespace disconnect')
+    }
+    onevent(packet: Packet) {
+        if (null != packet.id) {
+            // debug('attaching ack callback to event');
+            this.dispatch(packet, this.ack(packet.id));
+        } else {
+            this.dispatch(packet);
+        }
+    }
+    ack(id: number) {
+        let sent = false;
+        return (...args: any[]) => {
+            if (sent) return;
+            this.packet({
+                id: id,
+                type: PacketTypes.MESSAGE,
+                sub_type: this.hasBin(args) ? SubPacketTypes.BINARY_ACK : SubPacketTypes.ACK,
+                data: args
+            });
+            sent = true;
+        }
+    }
+    onack(packet: Packet) {
+        let ack = this.acks[packet.id];
+        if ('function' == typeof ack) {
+            // debug('calling ack %s with %j', packet.id, packet.data);
+            ack.apply(this, packet.data);
+            delete this.acks[packet.id];
+        } else {
+            // debug('bad ack %s', packet.id);
+        }
+    }
+    dispatch(packet: Packet, ack?: Function) {
+        if (ack) { this.acks[packet.id] = ack; }
+        super.emit(packet.name, ...packet.data, ack)
+    }
+    private hasBin(obj: any) {
+        return false;
+    }
+}

packages/websocket/src/socket-io/types.ts

@@ -0,0 +1,18 @@
+export enum PacketTypes {
+    OPEN,
+    CLOSE,
+    PING,
+    PONG,
+    MESSAGE,
+    UPGRADE,
+    NOOP,
+}
+export enum SubPacketTypes {
+    CONNECT,
+    DISCONNECT,
+    EVENT,
+    ACK,
+    ERROR,
+    BINARY_EVENT,
+    BINARY_ACK
+}