v0.6.0

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

lerna.json

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

package.json

@@ -9,8 +9,9 @@
         "bs": "lerna bootstrap",
         "clean": "lerna run clean",
         "watch": "lerna run watch --parallel",
-        "build": "lerna run build --scope=\"@ms/!(plugins)\"",
-        "build:plugins": "lerna run build --scope=\"@ms/plugins\"",
+        "build": "lerna run build --scope=\"@ccms/!(plugins)\"",
+        "build:plugins": "lerna run build --scope=\"@ccms/plugins\"",
+        "publish": "yarn lerna exec \"npm publish --access=public\" --scope=\"@ccms/!(plugins|client|types)\"",
         "ug": "yarn upgrade-interactive --latest",
         "lp": "lerna publish"
     },

packages/api/package.json

@@ -1,6 +1,6 @@
 {
-    "name": "@ms/api",
-    "version": "0.4.2",
+    "name": "@ccms/api",
+    "version": "0.6.0",
     "description": "MiaoScript api package",
     "keywords": [
         "miaoscript",
@@ -12,9 +12,6 @@
     "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",
@@ -22,11 +19,13 @@
         "test": "echo \"Error: run tests from root\" && exit 1"
     },
     "dependencies": {
-        "@ms/container": "^0.4.0",
-        "@ms/ployfill": "^0.4.2",
+        "@ccms/container": "^0.6.0",
+        "@ccms/ployfill": "^0.6.0",
+        "base64-js": "^1.3.1",
         "source-map-builder": "^0.0.7"
     },
     "devDependencies": {
+        "@types/base64-js": "^1.2.5",
         "reflect-metadata": "^0.1.13",
         "rimraf": "^3.0.2",
         "typescript": "^3.8.3"

packages/api/src/channel.ts

@@ -1,4 +1,4 @@
-import { injectable } from "@ms/container";
+import { injectable } from "@ccms/container";
 
 export namespace channel {
     /**

packages/api/src/command.ts

@@ -1,5 +1,5 @@
-import i18n from '@ms/i18n'
-import { injectable } from "@ms/container";
+import i18n from '@ccms/i18n'
+import { injectable } from "@ccms/container";
 
 export namespace command {
     @injectable()

packages/api/src/console.ts

@@ -1,10 +1,9 @@
-import i18m from '@ms/i18n'
+import i18m from '@ccms/i18n'
 import { SourceMapBuilder } from 'source-map-builder'
+import * as base64 from 'base64-js'
 
 const Arrays = Java.type('java.util.Arrays');
 const Level = Java.type('java.util.logging.Level');
-const JavaString = Java.type('java.lang.String');
-const Files = Java.type('java.nio.file.Files');
 const Paths = Java.type('java.nio.file.Paths');
 const ignoreLogPrefix = ['java.', 'net.minecraft.', 'org.bukkit.', 'jdk.nashorn.', 'io.netty.', 'org.spongepowered.'];
 
@@ -23,6 +22,7 @@ export class MiaoScriptConsole implements Console {
     Console: NodeJS.ConsoleConstructor;
 
     private sourceMaps: { [key: string]: SourceMapBuilder } = {};
+    private sourceFileMaps: { [key: string]: string } = {};
     private _name: string = '';
     private _level: LogLevel = LogLevel.INFO;
 
@@ -83,7 +83,7 @@ export class MiaoScriptConsole implements Console {
         this.console(i18m.translate(name, param))
     }
     object(obj) {
-        for (var i in obj) {
+        for (const i in obj) {
             this.info(i, '=>', obj[i])
         }
     }
@@ -93,23 +93,31 @@ export class MiaoScriptConsole implements Console {
     readSourceMap(fileName: string, lineNumber: number) {
         try {
             if (fileName.endsWith('js')) {
-                var file = Paths.get(fileName + '.map');
                 if (this.sourceMaps[fileName] === undefined) {
-                    if (file.toFile().exists()) {
-                        var sourceMapObj = JSON.parse(new JavaString(Files.readAllBytes(file), "UTF-8"))
-                        this.sourceMaps[fileName] = new SourceMapBuilder(sourceMapObj)
+                    this.sourceMaps[fileName] = null
+                    let sourceLine = base.read(fileName).split('\n');
+                    let lastLine = sourceLine[sourceLine.length - 1]
+                    if (lastLine.startsWith('//# sourceMappingURL=')) {
+                        let sourceContent = null;
+                        let sourceMappingURL = lastLine.split('sourceMappingURL=', 2)[1];
+                        if (sourceMappingURL.startsWith('data:application/json;base64,')) {
+                            sourceContent = String.fromCharCode(...Array.from(base64.toByteArray(sourceMappingURL.split(',', 2)[1])))
+                        } else if (sourceMappingURL.startsWith('http')) {
+                            // TODO
                         } else {
-                        this.sourceMaps[fileName] = null;
+                            let file = Paths.get(Paths.get(fileName, '..', sourceMappingURL).toFile().getCanonicalPath()).toFile();
+                            if (file.exists()) { sourceContent = base.read(file) }
+                        }
+                        if (sourceContent) {
+                            this.sourceMaps[fileName] = new SourceMapBuilder(JSON.parse(sourceContent))
+                            this.sourceFileMaps[fileName] = Paths.get(fileName, '..', this.sourceMaps[fileName].sources[0]).toFile().getCanonicalPath();
+                        }
                     }
                 }
                 if (this.sourceMaps[fileName]) {
-                    var sourceMapping = this.sourceMaps[fileName].getSource(lineNumber, 25, true);
-                    if (sourceMapping) {
-                        if (lineNumber != sourceMapping.mapping.sourceLine) {
-                            fileName = fileName.replace(".js", ".ts");
-                            lineNumber = sourceMapping.mapping.sourceLine;
-                        }
-                    }
+                    let sourceMapping = this.sourceMaps[fileName].getSource(lineNumber, 25, true, true);
+                    fileName = this.sourceFileMaps[fileName]
+                    if (sourceMapping && lineNumber != sourceMapping.mapping.sourceLine) { lineNumber = sourceMapping.mapping.sourceLine; }
                 }
             }
         } catch (error) {
@@ -121,26 +129,26 @@ export class MiaoScriptConsole implements Console {
         }
     }
     stack(ex: Error): string[] {
-        var stack = ex.getStackTrace();
-        var cache = ['§c' + ex];
+        let stack = ex.getStackTrace();
+        let cache = ['§c' + ex];
         //@ts-ignore
         if (stack.class) {
             stack = Arrays.asList(stack)
         }
         stack.forEach(trace => {
             if (trace.className.startsWith('<')) {
-                var { fileName, lineNumber } = this.readSourceMap(trace.fileName, trace.lineNumber)
+                let { fileName, lineNumber } = this.readSourceMap(trace.fileName, trace.lineNumber)
                 if (fileName.startsWith(root)) { fileName = fileName.split(root)[1] }
                 cache.push(`    §e->§c ${fileName} => §4${trace.methodName}:${lineNumber}`)
             } else {
-                var className = trace.className;
+                let className = trace.className;
                 var fileName = trace.fileName as string;
                 if (className.startsWith('jdk.nashorn.internal.scripts')) {
                     className = className.substr(className.lastIndexOf('$') + 1)
                     var { fileName, lineNumber } = this.readSourceMap(trace.fileName, trace.lineNumber)
                     if (fileName.startsWith(root)) { fileName = fileName.split(root)[1] }
                 } else {
-                    for (var prefix in ignoreLogPrefix) {
+                    for (let prefix in ignoreLogPrefix) {
                         if (className.startsWith(ignoreLogPrefix[prefix])) {
                             return;
                         }

packages/api/src/constants.ts

@@ -0,0 +1,16 @@
+export namespace constants {
+    export namespace Reflect {
+        export const Method = {
+            getServerConnection: [/*spigot 1.8.8*/'aq',/*spigot 1.12.2*/ 'an', /*spigot 1.14.4+*/'getServerConnection', /*catserver 1.12.2*/'func_147137_ag']
+        }
+        export const Field = {
+            listeningChannels: [/*spigot 1.8.8-1.12.2*/'g', /*spigot 1.14.4*/'f', /*spigot 1.15.2+*/'listeningChannels', /*catserver 1.12.2*/'field_151274_e']
+        }
+    }
+    export enum ServerType {
+        Bukkit = 'bukkit',
+        Sponge = 'sponge',
+        Nukkit = 'nukkit',
+        Bungee = 'bungee'
+    }
+}

packages/api/src/event.ts

@@ -1,8 +1,8 @@
 /**
  * MiaoScript Event处理类
  */
-import i18n from '@ms/i18n'
-import { injectable, unmanaged } from '@ms/container'
+import i18n from '@ccms/i18n'
+import { injectable, unmanaged } from '@ccms/container'
 
 const Thread = Java.type('java.lang.Thread');
 
@@ -62,8 +62,8 @@ export namespace event {
             return count;
         }
 
-        getJarFile(resource: string) {
-            let dirs = Thread.currentThread().getContextClassLoader().getResources(resource);
+        getJarFile(resource: string, loader?: any) {
+            let dirs = (loader || Thread.currentThread().getContextClassLoader()).getResources(resource);
             if (dirs.hasMoreElements()) {
                 let url = dirs.nextElement();
                 if (url.protocol === "jar") { return url.openConnection().jarFile; }

packages/api/src/index.ts

@@ -1,7 +1,8 @@
-import "@ms/nashorn"
+import "@ccms/nashorn"
 export * from './task'
 export * from './event'
 export * from './console'
 export * from './channel'
 export * from './command'
+export * from './constants'
 export * from './interfaces'

packages/bukkit/package.json

@@ -1,6 +1,6 @@
 {
-    "name": "@ms/bukkit",
-    "version": "0.4.2",
+    "name": "@ccms/bukkit",
+    "version": "0.6.0",
     "description": "MiaoScript bukkit package",
     "keywords": [
         "miaoscript",
@@ -12,9 +12,6 @@
     "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",
@@ -27,8 +24,8 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/api": "^0.4.2",
-        "@ms/common": "^0.4.2",
-        "@ms/container": "^0.4.0"
+        "@ccms/api": "^0.6.0",
+        "@ccms/common": "^0.6.0",
+        "@ccms/container": "^0.6.0"
     }
 }

packages/bukkit/src/channel.ts

@@ -1,5 +1,5 @@
-import { channel, plugin } from '@ms/api'
-import { inject, provideSingleton } from '@ms/container'
+import { channel, plugin } from '@ccms/api'
+import { inject, provideSingleton } from '@ccms/container'
 
 const Bukkit = org.bukkit.Bukkit
 const PluginMessageListener = Java.type("org.bukkit.plugin.messaging.PluginMessageListener")

packages/bukkit/src/command.ts

@@ -1,8 +1,8 @@
-import '@ms/nashorn'
+import '@ccms/nashorn'
 
-import { command, plugin } from '@ms/api'
-import * as reflect from '@ms/common/dist/reflect'
-import { provideSingleton, postConstruct, inject } from '@ms/container'
+import { command, plugin } from '@ccms/api'
+import * as reflect from '@ccms/common/dist/reflect'
+import { provideSingleton, postConstruct, inject } from '@ccms/container'
 
 let Bukkit = org.bukkit.Bukkit;
 let TabCompleter = Java.type('org.bukkit.command.TabCompleter');

packages/bukkit/src/console.ts

@@ -1,4 +1,4 @@
-import { MiaoScriptConsole } from '@ms/api'
+import { MiaoScriptConsole } from '@ccms/api'
 
 let Bukkit = org.bukkit.Bukkit;
 

packages/bukkit/src/event.ts

@@ -1,6 +1,6 @@
-import { event, plugin } from '@ms/api'
-import { inject, provideSingleton } from '@ms/container';
-import * as reflect from '@ms/common/dist/reflect'
+import { event, plugin } from '@ccms/api'
+import { inject, provideSingleton } from '@ccms/container';
+import * as reflect from '@ccms/common/dist/reflect'
 
 const Bukkit = Java.type("org.bukkit.Bukkit");
 const Event = Java.type("org.bukkit.event.Event");
@@ -19,7 +19,7 @@ export class BukkitEvent extends event.Event {
     }
 
     getJarFile(resource: string) {
-        return super.getJarFile('org/bukkit/Bukkit.class')
+        return super.getJarFile('org/bukkit/Bukkit.class', Bukkit.class.classLoader)
     }
     isValidEvent(clazz: any): boolean {
         // 继承于 org.bukkit.event.Event

packages/bukkit/src/index.ts

@@ -1,7 +1,7 @@
-/// <reference types="@ms/types/dist/typings/bukkit" />
+/// <reference types="@ccms/types/dist/typings/bukkit" />
 
-import { server } from '@ms/api'
-import { Container } from '@ms/container'
+import { server } from '@ccms/api'
+import { Container } from '@ccms/container'
 
 import { BukkitConsole } from './console';
 import './event';

packages/bukkit/src/server.ts

@@ -1,16 +1,9 @@
-import { server } from '@ms/api'
-import { provideSingleton } from '@ms/container';
+import { server, constants } from '@ccms/api'
+import { provideSingleton } from '@ccms/container';
 
-import * as reflect from '@ms/common/dist/reflect'
+import * as reflect from '@ccms/common/dist/reflect'
 import chat from './enhance/chat'
 
-const refList: Array<{ server: string, future: string }> = [
-    { server: 'aq', future: 'g' },//spigot 1.8.8
-    { server: 'an', future: 'g' },//spigot 1.12.2
-    { server: 'getServerConnection', future: 'f' },//after spigot 1.14.4
-    { server: 'func_147137_ag', future: 'field_151274_e' }//catserver 1.12.2
-]
-
 let Bukkit = org.bukkit.Bukkit;
 
 @provideSingleton(server.Server)
@@ -68,14 +61,24 @@ export class BukkitServer implements server.Server {
 
     private reflectPipeline() {
         let consoleServer = reflect.on(Bukkit.getServer()).get('console').get()
+        let connection: any;
         let promise: any;
-        for (const ref of refList) {
+        for (const method of constants.Reflect.Method.getServerConnection) {
             try {
-                promise = reflect.on(consoleServer).call(ref.server).get(ref.future).get().get(0); break;
-            } catch (error) {
+                connection = reflect.on(consoleServer).call(method).get()
+                if (connection.class.name.indexOf('ServerConnection') !== -1) { break; }
+                connection = undefined;
+            } catch (error) { }
         }
+        if (!connection) { console.error("Can't found ServerConnection!"); return }
+        for (const field of constants.Reflect.Field.listeningChannels) {
+            try {
+                promise = reflect.on(connection).get(field).get().get(0);
+                if (promise.class.name.indexOf('Promise') !== -1) { break; }
+                promise = undefined;
+            } catch (error) { }
         }
-        if (!promise) { console.error("Can't found ServerConnection or ChannelFuture !"); return }
+        if (!promise) { console.error("Can't found listeningChannels!"); return }
         this.pipeline = reflect.on(promise).get('channel').get().pipeline()
     }
 }

packages/bukkit/src/task.ts

@@ -1,5 +1,5 @@
-import { task, plugin } from '@ms/api'
-import { inject, provideSingleton } from '@ms/container';
+import { task, plugin } from '@ccms/api'
+import { inject, provideSingleton } from '@ccms/container';
 
 const Bukkit = Java.type('org.bukkit.Bukkit');
 const BukkitRunnable = Java.type('org.bukkit.scheduler.BukkitRunnable');

packages/bungee/package.json

@@ -1,6 +1,6 @@
 {
-    "name": "@ms/bungee",
-    "version": "0.4.2",
+    "name": "@ccms/bungee",
+    "version": "0.6.0",
     "description": "MiaoScript bungee package",
     "keywords": [
         "miaoscript",
@@ -12,9 +12,6 @@
     "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",
@@ -27,8 +24,8 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/api": "^0.4.2",
-        "@ms/common": "^0.4.2",
-        "@ms/container": "^0.4.0"
+        "@ccms/api": "^0.6.0",
+        "@ccms/common": "^0.6.0",
+        "@ccms/container": "^0.6.0"
     }
 }

packages/bungee/src/channel.ts

@@ -1,5 +1,5 @@
-import { channel, event } from '@ms/api'
-import { provideSingleton, inject } from '@ms/container'
+import { channel, event } from '@ccms/api'
+import { provideSingleton, inject } from '@ccms/container'
 
 const Bungee: net.md_5.bungee.api.ProxyServer = base.getInstance().getProxy()
 

packages/bungee/src/command.ts

@@ -1,5 +1,5 @@
-import { command, plugin } from "@ms/api";
-import { inject, provideSingleton } from "@ms/container";
+import { command, plugin } from "@ccms/api";
+import { inject, provideSingleton } from "@ccms/container";
 
 const Arrays = Java.type('java.util.Arrays')
 const Command = Java.extend(Java.type('net.md_5.bungee.api.plugin.Command'), Java.type('net.md_5.bungee.api.plugin.TabExecutor'));

packages/bungee/src/console.ts

@@ -1,6 +1,6 @@
-import '@ms/nashorn'
-import { plugin, MiaoScriptConsole } from '@ms/api'
-import { inject, injectable } from "@ms/container";
+import '@ccms/nashorn'
+import { plugin, MiaoScriptConsole } from '@ccms/api'
+import { inject, injectable } from "@ccms/container";
 
 let CommandSender = Java.type("net.md_5.bungee.api.CommandSender")
 

packages/bungee/src/event.ts

@@ -1,6 +1,6 @@
-import { event } from '@ms/api'
-import { provideSingleton, postConstruct } from '@ms/container'
-import * as reflect from '@ms/common/dist/reflect'
+import { event } from '@ccms/api'
+import { provideSingleton, postConstruct } from '@ccms/container'
+import * as reflect from '@ccms/common/dist/reflect'
 
 const Bungee: net.md_5.bungee.api.ProxyServer = base.getInstance().getProxy();
 const Event = Java.type("net.md_5.bungee.api.plugin.Event");

packages/bungee/src/index.ts

@@ -1,7 +1,7 @@
-/// <reference types="@ms/types/dist/typings/bungee" />
+/// <reference types="@ccms/types/dist/typings/bungee" />
 
-import { server } from '@ms/api'
-import { Container } from '@ms/container'
+import { server } from '@ccms/api'
+import { Container } from '@ccms/container'
 
 import { BungeeConsole } from './console';
 import './event';

packages/bungee/src/server.ts

@@ -1,7 +1,7 @@
-import { server, task } from '@ms/api'
-import { provideSingleton, inject, postConstruct } from '@ms/container'
+import { server, task } from '@ccms/api'
+import { provideSingleton, inject, postConstruct } from '@ccms/container'
 
-import * as reflect from '@ms/common/dist/reflect'
+import * as reflect from '@ccms/common/dist/reflect'
 
 let Bungee: net.md_5.bungee.api.ProxyServer = base.getInstance().getProxy();
 

packages/bungee/src/task.ts

@@ -1,5 +1,5 @@
-import { task, plugin } from '@ms/api'
-import { inject, provideSingleton } from '@ms/container';
+import { task, plugin } from '@ccms/api'
+import { inject, provideSingleton } from '@ccms/container';
 
 var Runnable = Java.type('java.lang.Runnable')
 let TimeUnit = Java.type('java.util.concurrent.TimeUnit')

packages/client/package.json

@@ -1,7 +1,7 @@
 {
     "private": true,
-    "name": "@ms/client",
-    "version": "0.4.2",
+    "name": "@ccms/client",
+    "version": "0.6.0",
     "description": "MiaoScript client package",
     "keywords": [
         "miaoscript",
@@ -13,9 +13,6 @@
     "homepage": "https://github.com/circlecloud/ms.git",
     "license": "ISC",
     "main": "dist/index.js",
-    "publishConfig": {
-        "registry": "https://repo.yumc.pw/repository/npm-hosted/"
-    },
     "scripts": {
         "dev": "ts-node-dev --respawn --debounce=1500 src/index.ts",
         "clean": "rimraf dist",

packages/common/package.json

@@ -1,6 +1,6 @@
 {
-    "name": "@ms/common",
-    "version": "0.4.2",
+    "name": "@ccms/common",
+    "version": "0.6.0",
     "description": "MiaoScript api package",
     "keywords": [
         "miaoscript",
@@ -12,9 +12,6 @@
     "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",
@@ -27,7 +24,7 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/nashorn": "^0.4.0"
+        "@ccms/nashorn": "^0.6.0"
     },
     "gitHead": "562e2d00175c9d3a99c8b672aa07e6d92706a027"
 }

packages/common/src/fs.ts

@@ -1,4 +1,4 @@
-import '@ms/nashorn'
+import '@ccms/nashorn'
 
 /*global Java, base, module, exports, require, __FILE__*/
 const Path = Java.type("java.nio.file.Path");

packages/common/src/tgz.ts

@@ -1,4 +1,4 @@
-import '@ms/nashorn'
+import '@ccms/nashorn'
 
 let Files = Java.type("java.nio.file.Files");
 let Paths = Java.type("java.nio.file.Paths");

packages/compile/package.json

@@ -1,6 +1,6 @@
 {
-    "name": "@ms/compile",
-    "version": "0.4.0",
+    "name": "@ccms/compile",
+    "version": "0.6.0",
     "description": "MiaoScript compile package",
     "keywords": [
         "miaoscript",
@@ -12,9 +12,6 @@
     "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",

packages/container/package.json

@@ -1,6 +1,6 @@
 {
-    "name": "@ms/container",
-    "version": "0.4.0",
+    "name": "@ccms/container",
+    "version": "0.6.0",
     "description": "MiaoScript container package",
     "keywords": [
         "miaoscript",
@@ -12,9 +12,6 @@
     "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",

packages/container/src/decorators.ts

@@ -2,7 +2,7 @@ import { interfaces, Container } from "inversify";
 
 let _container: Container;
 
-const ContainerInstance = Symbol.for("@ms/ioc:Container");
+const ContainerInstance = Symbol.for("@ccms/ioc:Container");
 const INJECTION = Symbol.for("INJECTION");
 
 function _proxyGetter(

packages/core/package.json

@@ -1,6 +1,6 @@
 {
-    "name": "@ms/core",
-    "version": "0.4.2",
+    "name": "@ccms/core",
+    "version": "0.6.0",
     "description": "MiaoScript api package",
     "keywords": [
         "miaoscript",
@@ -12,9 +12,6 @@
     "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",
@@ -27,8 +24,8 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/api": "^0.4.2",
-        "@ms/container": "^0.4.0"
+        "@ccms/api": "^0.6.0",
+        "@ccms/container": "^0.6.0"
     },
     "gitHead": "781524f83e52cad26d7c480513e3c525df867121"
 }

packages/core/src/index.ts

@@ -1,8 +1,8 @@
 let containerStartTime = Date.now();
-console.i18n("ms.core.ioc.initialize");
-import { plugin, server, task } from '@ms/api'
-import { DefaultContainer as container, inject, provideSingleton, ContainerInstance, buildProviderModule } from '@ms/container'
-console.i18n("ms.core.ioc.completed", { time: (Date.now() - containerStartTime) / 1000 })
+console.i18n("ms.core.ioc.initialize", { scope: global.scope });
+import { plugin, server, task, constants } from '@ccms/api'
+import { DefaultContainer as container, inject, provideSingleton, ContainerInstance, buildProviderModule } from '@ccms/container'
+console.i18n("ms.core.ioc.completed", { scope: global.scope, time: (Date.now() - containerStartTime) / 1000 })
 
 @provideSingleton(MiaoScriptCore)
 class MiaoScriptCore {
@@ -25,14 +25,12 @@ class MiaoScriptCore {
 
     loadServerConsole() {
         //@ts-ignore
-        console = new this.Console();
+        global.setGlobal('console', new this.Console())
     }
 
     loadTaskFunction() {
-        //@ts-ignore
-        global.setTimeout = (func: Function, tick: number, async: boolean = false) => this.taskManager.create(func).later(tick).async(async).submit()
-        //@ts-ignore
-        global.setInterval = (func: Function, tick: number, async: boolean = false) => this.taskManager.create(func).timer(tick).async(async).submit()
+        global.setGlobal('setTimeout', (func: Function, tick: number, async: boolean = false) => this.taskManager.create(func).later(tick).async(async).submit())
+        global.setGlobal('setInterval', (func: Function, tick: number, async: boolean = false) => this.taskManager.create(func).timer(tick).async(async).submit())
     }
 
     loadPlugins() {
@@ -49,49 +47,57 @@ class MiaoScriptCore {
         console.i18n("ms.core.engine.disable")
         this.pluginManager.disable();
         this.taskManager.disable();
+        //@ts-ignore
+        require.disable()
     }
 }
 
-function detectServer() {
+function detectServer(): constants.ServerType {
     try {
         Java.type("org.bukkit.Bukkit");
-        return 'bukkit'
+        return constants.ServerType.Bukkit
     } catch (ex) {
     }
     try {
         Java.type("org.spongepowered.api.Sponge");
-        return 'sponge'
+        return constants.ServerType.Sponge
     } catch (ex) {
     }
     try {
         Java.type("cn.nukkit.Nukkit");
-        return 'nukkit'
+        return constants.ServerType.Nukkit
     } catch (ex) {
     }
     try {
         Java.type("net.md_5.bungee.api.ProxyServer");
-        return 'bungee'
+        return constants.ServerType.Bungee
     } catch (ex) {
     }
     throw Error('Unknow Server Type...')
 }
 
 function initialize() {
+    try {
         let corePackageStartTime = new Date().getTime()
         container.bind(ContainerInstance).toConstantValue(container);
         container.bind(plugin.PluginInstance).toConstantValue(base.getInstance());
         container.bind(plugin.PluginFolder).toConstantValue('plugins');
         let type = detectServer();
-    console.i18n("ms.core.initialize.detect", { type });
+        console.i18n("ms.core.initialize.detect", { scope: global.scope, type });
         container.bind(server.ServerType).toConstantValue(type);
-    console.i18n("ms.core.package.initialize", { type });
-    require(`@ms/${type}`).default(container);
-    require('@ms/plugin')
+        console.i18n("ms.core.package.initialize", { scope: global.scope, type });
+        require(`${global.scope}/${type}`).default(container);
+        require(`${global.scope}/plugin`)
         container.load(buildProviderModule());
-    console.i18n("ms.core.package.completed", { type, time: (Date.now() - corePackageStartTime) / 1000 });
+        console.i18n("ms.core.package.completed", { scope: global.scope, type, time: (Date.now() - corePackageStartTime) / 1000 });
         let disable = container.get<MiaoScriptCore>(MiaoScriptCore).enable()
         console.i18n("ms.core.engine.completed", { time: (Date.now() - global.NashornEngineStartTime) / 1000 });
         return disable;
+    } catch (error) {
+        console.i18n("ms.core.initialize.error", { error });
+        console.ex(error)
+        return () => console.i18n('ms.core.engine.disable.abnormal')
+    }
 }
 
 export default initialize();

packages/i18n/languages/en.yml

@@ -1,15 +1,17 @@
 ms.ployfill.initialize: "Initialization Java Nashorn ployfill. Please wait..."
 ms.ployfill.completed: "Java Nashorn ployfill loading completed... Cost ({time}s)!"
 
-ms.core.ioc.initialize: "Initialization MiaoScript IOC Container @ms/container. Please wait..."
-ms.core.ioc.completed: "MiaoScript IOC Container @ms/container loading completed({time}s)!"
+ms.core.ioc.initialize: "Initialization MiaoScript IOC Container {scope}/container. Please wait..."
+ms.core.ioc.completed: "MiaoScript IOC Container {scope}/container loading completed({time}s)!"
 ms.core.initialize.detect: "Detect Compatible Server set ServerType to {type} ..."
-ms.core.package.initialize: "Initialization MiaoScript Package @ms/core @ms/{type} @ms/plugin. Please wait..."
-ms.core.package.completed: "MiaoScript Package @ms/core @ms/{type} @ms/plugin loading completed({time}s)!"
+ms.core.initialize.error: "MiaoScript Engine Initialization Error: {error} ..."
+ms.core.package.initialize: "Initialization MiaoScript Package {scope}/core {scope}/{type} {scope}/plugin. Please wait..."
+ms.core.package.completed: "MiaoScript Package {scope}/core {scope}/{type} {scope}/plugin loading completed({time}s)!"
 ms.core.plugin.initialize: "Initialization MiaoScript Plugin System. Please wait..."
 ms.core.plugin.completed: "MiaoScript Plugin System loading completed({time}s)!"
 ms.core.engine.completed: "MiaoScript ScriptEngine loading completed... Done({time}s)!"
 ms.core.engine.disable: "Disable MiaoScript Engine..."
+ms.core.engine.disable.abnormal: "abnormal Initialization MiaoScript Engine. Skip disable step..."
 
 ms.api.event.resource.not.found: "Can't Mapping Event Because not found Resources {resource}!"
 ms.api.event.empty.event.dir: "base event dir is empty, can't map event name !"
@@ -26,11 +28,13 @@ ms.api.command.unregister: "[{plugin}] unregister command {name}..."
 ms.api.command.execute.error: "§6Player {player} §6exec §b{plugin} §6Plugin Command §d{command} {args} §6error §4{ex}"
 ms.api.command.tab.completer.error: "§6Player {player} §6exec §b{plugin} §6Plugin TabComplete §d{command} {args} §6error §4{ex}"
 
-ms.plugin.initialize: "Initialization MiaoScript Plugin System: {plugin} ..."
+ms.plugin.initialize: "Initialization MiaoScript Plugin System: Plugin: {plugin} Loader: {loader}..."
 ms.plugin.event.map: "Total {count} {type} Event Mapping Complate..."
 ms.plugin.manager.scan: "Scanning Plugins in {folder} ..."
 ms.plugin.manager.initialize.error: "§6Plugin §b{name} §6initialize error §4{ex}"
 ms.plugin.manager.stage: "{stage} {plugin} version {version} by {author}"
+ms.plugin.manager.stage.exec: "[{plugin}] Exec {name} Stage {stage} When servers is {servers}..."
+ms.plugin.manager.stage.exec.error: "§6Plugin §b{plugin} §6exec §d{executor} §6function error §4{error}"
 ms.plugin.manager.stage.load: "Loading"
 ms.plugin.manager.stage.enable: "Enabling"
 ms.plugin.manager.stage.disable: "Disabling"

packages/i18n/languages/zh_cn.yml

@@ -1,15 +1,17 @@
 ms.ployfill.initialize: "加载 Java Nashorn 补丁. 请稍候..."
 ms.ployfill.completed: "Java Nashorn 补丁 加载完成... 耗时 ({time}s)!"
 
-ms.core.ioc.initialize: "初始化 MiaoScript IOC 容器 @ms/container. 请稍候..."
-ms.core.ioc.completed: "MiaoScript IOC 容器 @ms/container 加载完成 耗时({time}s)"
+ms.core.ioc.initialize: "初始化 MiaoScript IOC 容器 {scope}/container. 请稍候..."
+ms.core.ioc.completed: "MiaoScript IOC 容器 {scope}/container 加载完成 耗时({time}s)"
 ms.core.initialize.detect: "检测到兼容的服务器类型. 设置 ServerType 值 {type} ..."
-ms.core.package.initialize: "初始化 MiaoScript 扩展 @ms/core @ms/{type} @ms/plugin. 请稍候..."
-ms.core.package.completed: "MiaoScript 扩展 @ms/core @ms/{type} @ms/plugin 加载完成 耗时({time}s)"
+ms.core.initialize.error: "§4MiaoScript 系统初始化失败 §c{error} ..."
+ms.core.package.initialize: "初始化 MiaoScript 扩展 {scope}/core {scope}/{type} {scope}/plugin. 请稍候..."
+ms.core.package.completed: "MiaoScript 扩展 {scope}/core {scope}/{type} {scope}/plugin 加载完成 耗时({time}s)"
 ms.core.plugin.initialize: "MiaoScript 开始引导插件系统. 请稍候..."
 ms.core.plugin.completed: "MiaoScript 插件加载完毕 耗时({time}s)!"
 ms.core.engine.completed: "MiaoScript 脚本引擎 加载完毕... 耗时({time}s)!"
 ms.core.engine.disable: "关闭 MiaoScript 引擎..."
+ms.core.engine.disable.abnormal: "引擎异常启动或初始化未完成 跳过关闭流程..."
 
 ms.api.event.resource.not.found: "无法映射事件 未找到资源文件 {resource}!"
 ms.api.event.empty.event.dir: "事件基础目录为空, 无法映射事件!"
@@ -26,11 +28,13 @@ ms.api.command.unregister: "[{plugin}] 注销命令 {name}..."
 ms.api.command.execute.error: "§6玩家 §a{player} §6执行 §b{plugin} §6插件 §d{command} {args} §6命令时发生异常 §4{ex}"
 ms.api.command.tab.completer.error: "§6玩家 §a{player} §6执行 §b{plugin} §6插件 §d{command} {args} §6补全时发生异常 §4{ex}"
 
-ms.plugin.initialize: "初始化 MiaoScript 插件系统: {plugin} ..."
+ms.plugin.initialize: "初始化 MiaoScript 插件系统: 实例: {plugin} 加载器: {loader}..."
 ms.plugin.event.map: "总计 {count} 个 {type} 事件 映射完成..."
 ms.plugin.manager.scan: "扫描 {folder} 文件夹中插件..."
 ms.plugin.manager.initialize.error: "§6插件 §b{name} §6初始化错误 §4{ex}"
 ms.plugin.manager.stage: "{stage} {plugin} 版本 {version} 作者 {author}"
+ms.plugin.manager.stage.exec: "[{plugin}] 执行 {stage} 阶段函数 {name} 匹配类型 {servers}..."
+ms.plugin.manager.stage.exec.error: "§6插件 §b{plugin} §6执行 §d{executor} §6函数发生异常 错误: §4{error}"
 ms.plugin.manager.stage.load: "加载"
 ms.plugin.manager.stage.enable: "启用"
 ms.plugin.manager.stage.disable: "关闭"

packages/i18n/package.json

@@ -1,6 +1,6 @@
 {
-    "name": "@ms/i18n",
-    "version": "0.4.2",
+    "name": "@ccms/i18n",
+    "version": "0.6.0",
     "description": "MiaoScript i18n package",
     "keywords": [
         "miaoscript",
@@ -12,9 +12,6 @@
     "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",
@@ -28,7 +25,7 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/nashorn": "^0.4.0",
+        "@ccms/nashorn": "^0.6.0",
         "js-yaml": "^3.13.1"
     },
     "gitHead": "781524f83e52cad26d7c480513e3c525df867121"

packages/i18n/src/index.ts

@@ -1,4 +1,4 @@
-/// <reference types="@ms/nashorn" />
+/// <reference types="@ccms/nashorn" />
 import * as yaml from 'js-yaml'
 
 const File = Java.type("java.io.File");
@@ -32,9 +32,9 @@ export class Translate {
 
     translate(name: string, param?: TranslateParam) {
         let langText: string = this.langMap[name] || this.fallbackMap[name];
-        if (!langText) { return '[WARN] @ms/i18n miss lang translate: ' + name }
+        if (!langText) { return '[WARN] @ccms/i18n miss lang translate: ' + name }
         for (const key in param) {
-            langText = langText.replace("{" + key + "}", param[key])
+            langText = langText.replace(new RegExp("{" + key + "}", 'gm'), param[key])
         }
         return langText;
     }

packages/nashorn/package.json

@@ -1,6 +1,6 @@
 {
-    "name": "@ms/nashorn",
-    "version": "0.4.0",
+    "name": "@ccms/nashorn",
+    "version": "0.6.0",
     "description": "MiaoScript api package",
     "keywords": [
         "miaoscript",
@@ -13,9 +13,6 @@
     "license": "ISC",
     "main": "dist/index.js",
     "types": "dist/index.d.ts",
-    "publishConfig": {
-        "registry": "https://repo.yumc.pw/repository/npm-hosted/"
-    },
     "scripts": {
         "clean": "rimraf dist",
         "watch": "tsc --watch",

packages/nashorn/src/index.ts

@@ -41,6 +41,7 @@ declare global {
 
     namespace NodeJS {
         interface Global {
+            scope: string;
             logger: any;
             debug: boolean;
             level: string;

packages/nodejs/package.json

@@ -1,6 +1,6 @@
 {
-    "name": "@ms/nodejs",
-    "version": "0.4.2",
+    "name": "@ccms/nodejs",
+    "version": "0.6.0",
     "description": "MiaoScript nodejs package",
     "keywords": [
         "miaoscript",
@@ -12,9 +12,6 @@
     "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",
@@ -27,7 +24,7 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/nashorn": "^0.4.0"
+        "@ccms/nashorn": "^0.6.0"
     },
     "gitHead": "781524f83e52cad26d7c480513e3c525df867121"
 }

packages/nodejs/src/fs/index.ts

@@ -1,4 +1,4 @@
-import '@ms/nashorn'
+import '@ccms/nashorn'
 import { URL } from "url";
 
 const Path = Java.type("java.nio.file.Path");

packages/nukkit/package.json

@@ -1,6 +1,6 @@
 {
-    "name": "@ms/nukkit",
-    "version": "0.4.2",
+    "name": "@ccms/nukkit",
+    "version": "0.6.0",
     "description": "MiaoScript nukkit package",
     "keywords": [
         "miaoscript",
@@ -12,9 +12,6 @@
     "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",
@@ -27,8 +24,8 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/api": "^0.4.2",
-        "@ms/common": "^0.4.2",
-        "@ms/container": "^0.4.0"
+        "@ccms/api": "^0.6.0",
+        "@ccms/common": "^0.6.0",
+        "@ccms/container": "^0.6.0"
     }
 }

packages/nukkit/src/command.ts

@@ -1,7 +1,7 @@
-import '@ms/nashorn'
+import '@ccms/nashorn'
 
-import { command, plugin } from '@ms/api'
-import { inject, provideSingleton, postConstruct } from '@ms/container'
+import { command, plugin } from '@ccms/api'
+import { inject, provideSingleton, postConstruct } from '@ccms/container'
 
 let PluginCommand = Java.type('cn.nukkit.command.PluginCommand');
 let CommandExecutor = Java.type('cn.nukkit.command.CommandExecutor');

packages/nukkit/src/console.ts

@@ -1,4 +1,4 @@
-import { MiaoScriptConsole } from '@ms/api'
+import { MiaoScriptConsole } from '@ccms/api'
 
 let Nukkit = base.getInstance().getServer();
 let CommandSender = Java.type('cn.nukkit.command.CommandSender')

packages/nukkit/src/event.ts

@@ -1,5 +1,5 @@
-import { event, plugin } from '@ms/api'
-import { inject, provideSingleton } from '@ms/container'
+import { event, plugin } from '@ccms/api'
+import { inject, provideSingleton } from '@ccms/container'
 
 const Nukkit: cn.nukkit.Server = base.getInstance().getServer();
 const Event = Java.type("cn.nukkit.event.Event");

packages/nukkit/src/index.ts

@@ -1,7 +1,7 @@
-/// <reference types="@ms/types/dist/typings/nukkit" />
+/// <reference types="@ccms/types/dist/typings/nukkit" />
 
-import { server } from '@ms/api'
-import { Container } from '@ms/container'
+import { server } from '@ccms/api'
+import { Container } from '@ccms/container'
 
 import { NukkitConsole } from './console';
 import './event';

packages/nukkit/src/server.ts

@@ -1,5 +1,5 @@
-import { server } from '@ms/api'
-import { provideSingleton } from '@ms/container';
+import { server } from '@ccms/api'
+import { provideSingleton } from '@ccms/container';
 
 let Nukkit: cn.nukkit.Server = base.getInstance().getServer();
 const File = Java.type("java.io.File");

packages/nukkit/src/task.ts

@@ -1,5 +1,5 @@
-import { task, plugin } from '@ms/api'
-import { inject, provideSingleton } from '@ms/container';
+import { task, plugin } from '@ccms/api'
+import { inject, provideSingleton } from '@ccms/container';
 
 const NukkitRunnable = Java.type('cn.nukkit.scheduler.NukkitRunnable');
 

packages/ployfill/package.json

@@ -1,15 +1,12 @@
 {
-    "name": "@ms/ployfill",
-    "version": "0.4.2",
+    "name": "@ccms/ployfill",
+    "version": "0.6.0",
     "description": "MiaoScript ployfill package",
     "author": "MiaoWoo <admin@yumc.pw>",
     "homepage": "https://github.com/circlecloud/ms.git",
     "license": "ISC",
     "main": "dist/index.js",
     "types": "dist/index.d.ts",
-    "publishConfig": {
-        "registry": "https://repo.yumc.pw/repository/npm-hosted/"
-    },
     "scripts": {
         "clean": "rimraf dist",
         "watch": "tsc --watch",
@@ -17,8 +14,8 @@
         "test": "echo \"Error: run tests from root\" && exit 1"
     },
     "dependencies": {
-        "@ms/i18n": "^0.4.2",
-        "@ms/nashorn": "^0.4.0",
+        "@ccms/i18n": "^0.6.0",
+        "@ccms/nashorn": "^0.6.0",
         "core-js": "^3.6.4"
     },
     "devDependencies": {

packages/ployfill/src/index.ts

@@ -1,6 +1,6 @@
-/// <reference types="@ms/nashorn" />
+/// <reference types="@ccms/nashorn" />
 
-import i18n from '@ms/i18n'
+import i18n from '@ccms/i18n'
 let ployfillStartTime = new Date().getTime();
 i18n.initialize();
 console.i18n("ms.ployfill.initialize");

packages/ployfill/src/xml-http-request.ts

@@ -1,4 +1,4 @@
-import '@ms/nashorn'
+import '@ccms/nashorn'
 
 const URL = Java.type("java.net.URL");
 const Files = Java.type("java.nio.file.Files");

packages/plugin/package.json

@@ -1,6 +1,6 @@
 {
-    "name": "@ms/plugin",
-    "version": "0.4.2",
+    "name": "@ccms/plugin",
+    "version": "0.6.0",
     "description": "MiaoScript api package",
     "keywords": [
         "miaoscript",
@@ -12,9 +12,6 @@
     "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",
@@ -28,10 +25,10 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/api": "^0.4.2",
-        "@ms/common": "^0.4.2",
-        "@ms/container": "^0.4.0",
-        "@ms/i18n": "^0.4.2",
+        "@ccms/api": "^0.6.0",
+        "@ccms/common": "^0.6.0",
+        "@ccms/container": "^0.6.0",
+        "@ccms/i18n": "^0.6.0",
         "js-yaml": "^3.13.1"
     }
 }

packages/plugin/src/constants.ts

@@ -1,7 +1,12 @@
 export const METADATA_KEY = {
-    plugin: "@ms/plugin:plugin",
-    cmd: "@ms/plugin:cmd",
-    tab: "@ms/plugin:tab",
-    listener: "@ms/plugin:listener",
-    config: "@ms/plugin:config",
+    plugin: "@ccms/plugin:plugin",
+    cmd: "@ccms/plugin:cmd",
+    tab: "@ccms/plugin:tab",
+    listener: "@ccms/plugin:listener",
+    config: "@ccms/plugin:config",
+    stage: {
+        load: "@ccms/plugin:stage:load",
+        enable: "@ccms/plugin:stage:enable",
+        disable: "@ccms/plugin:stage:disable"
+    }
 };

packages/plugin/src/decorators.ts

@@ -1,7 +1,7 @@
-import { injectable, decorate } from "@ms/container";
+import { injectable, decorate } from "@ccms/container";
 import { interfaces } from './interfaces'
 import { METADATA_KEY } from './constants'
-import { getPluginMetadatas, getPluginCommandMetadata, getPluginListenerMetadata, getPluginTabCompleterMetadata, getPluginConfigMetadata } from './utils'
+import { getPluginMetadatas, getPluginCommandMetadata, getPluginListenerMetadata, getPluginTabCompleterMetadata, getPluginConfigMetadata, getPluginStageMetadata } from './utils'
 
 /**
  * MiaoScript plugin
@@ -71,3 +71,24 @@ export function config(metadata: interfaces.ConfigMetadata = { version: 1, forma
         Reflect.defineMetadata(METADATA_KEY.config, previousMetadata, target.constructor);
     }
 }
+
+function stage(metadata: interfaces.ExecMetadata = {}, stage: string) {
+    return function (target: any, key: string, value: any) {
+        metadata.name = metadata.name || key;
+        metadata.executor = key;
+        const previousMetadata: interfaces.ExecMetadata[] = getPluginStageMetadata(target, stage)
+        Reflect.defineMetadata(METADATA_KEY.stage[stage], [metadata, ...previousMetadata], target.constructor);
+    };
+}
+
+export function load(metadata: interfaces.ExecMetadata = {}) {
+    return stage(metadata, 'load')
+}
+
+export function enable(metadata: interfaces.ExecMetadata = {}) {
+    return stage(metadata, 'enable')
+}
+
+export function disable(metadata: interfaces.ExecMetadata = {}) {
+    return stage(metadata, 'disable')
+}

packages/plugin/src/interfaces.ts

@@ -1,6 +1,6 @@
-import { server, MiaoScriptConsole } from "@ms/api";
+import { server, MiaoScriptConsole, event } from "@ccms/api";
 import { METADATA_KEY } from './constants'
-import { injectable, inject, postConstruct } from "@ms/container";
+import { injectable, inject, postConstruct } from "@ccms/container";
 import { getPluginMetadata } from "./utils";
 
 export namespace interfaces {
@@ -55,7 +55,7 @@ export namespace interfaces {
          */
         target?: any;
     }
-    interface ExecMetadata extends BaseMetadata {
+    export interface ExecMetadata extends BaseMetadata {
         /**
          * 执行器
          */
@@ -68,6 +68,15 @@ export namespace interfaces {
         paramtypes?: string[];
     }
     export interface ListenerMetadata extends ExecMetadata {
+        /**
+         * 监听优先级
+         */
+        priority?: event.EventPriority;
+        /**
+         * 是否忽略已取消的事件
+         */
+        ignoreCancel?: boolean;
+
     }
     export interface ConfigMetadata extends BaseMetadata {
         /**

packages/plugin/src/manager.ts

@@ -1,12 +1,14 @@
-import i18n from '@ms/i18n'
-import { plugin, server, command, event } from '@ms/api'
-import { inject, provideSingleton, postConstruct, Container, ContainerInstance } from '@ms/container'
-import * as fs from '@ms/common/dist/fs'
+import i18n from '@ccms/i18n'
+import { plugin, server, command, event } from '@ccms/api'
+import { inject, provideSingleton, Container, ContainerInstance } from '@ccms/container'
+import * as fs from '@ccms/common/dist/fs'
 
-import { getPluginMetadatas, getPluginCommandMetadata, getPluginListenerMetadata, getPlugin, getPluginTabCompleterMetadata, getPluginConfigMetadata } from './utils'
+import { getPluginMetadatas, getPluginCommandMetadata, getPluginListenerMetadata, getPlugin, getPluginTabCompleterMetadata, getPluginConfigMetadata, getPluginStageMetadata } from './utils'
 import { interfaces } from './interfaces'
 import { getConfigLoader } from './config'
 
+const Thread = Java.type('java.lang.Thread')
+
 @provideSingleton(plugin.PluginManager)
 export class PluginManagerImpl implements plugin.PluginManager {
     @inject(ContainerInstance)
@@ -22,25 +24,23 @@ export class PluginManagerImpl implements plugin.PluginManager {
     @inject(event.Event)
     private EventManager: event.Event
 
+    private initialized: boolean = false
     private pluginMap: Map<string, interfaces.Plugin>
 
-    @postConstruct()
     initialize() {
-        if (this.pluginInstance !== null) {
+        if (this.pluginInstance !== null && this.initialized !== true) {
             // 如果plugin不等于null 则代表是正式环境
-            console.i18n('ms.plugin.initialize', { plugin: this.pluginInstance })
+            console.i18n('ms.plugin.initialize', { plugin: this.pluginInstance, loader: Thread.currentThread().contextClassLoader })
             this.pluginMap = new Map()
             console.i18n('ms.plugin.event.map', { count: this.EventManager.mapEventName().toFixed(0), type: this.serverType });
+            this.initialized = true;
         }
     }
 
     scan(folder: string): void {
+        this.initialize()
         var plugin = fs.file(root, folder)
-        var files = []
-            // load common plugin
-            .concat(this.scanFolder(plugin))
-            // load space plugin
-            .concat(this.scanFolder(fs.file(plugin, this.serverType)))
+        var files = this.scanFolder(plugin)
         this.loadPlugins(files)
     }
 
@@ -52,32 +52,37 @@ export class PluginManagerImpl implements plugin.PluginManager {
         console.i18n("ms.plugin.manager.stage", { stage, plugin: plugin.description.name, version: plugin.description.version, author: plugin.description.author })
     }
 
+    private runPluginStage(plugin: interfaces.Plugin, stage: string, ext: Function) {
+        this.logStage(plugin, i18n.translate(`ms.plugin.manager.stage.${stage}`))
+        ext()
+        this.runCatch(plugin, stage)
+        this.runCatch(plugin, `${this.serverType}${stage}`)
+        this.execPluginStage(plugin, stage)
+    }
+
     load(...args: any[]): void {
         this.checkAndGet(args[0]).forEach((plugin: interfaces.Plugin) => {
-            this.logStage(plugin, i18n.translate("ms.plugin.manager.stage.load"))
+            this.runPluginStage(plugin, 'load', () => {
                 this.loadConfig(plugin)
-            this.runCatch(plugin, 'load')
-            this.runCatch(plugin, `${this.serverType}load`)
+            })
         })
     }
 
     enable(...args: any[]): void {
         this.checkAndGet(args[0]).forEach((plugin: interfaces.Plugin) => {
-            this.logStage(plugin, i18n.translate("ms.plugin.manager.stage.enable"))
+            this.runPluginStage(plugin, 'enable', () => {
                 this.registryCommand(plugin)
                 this.registryListener(plugin)
-            this.runCatch(plugin, 'enable')
-            this.runCatch(plugin, `${this.serverType}enable`)
+            })
         })
     }
 
     disable(...args: any[]): void {
         this.checkAndGet(args[0]).forEach((plugin: interfaces.Plugin) => {
-            this.logStage(plugin, i18n.translate("ms.plugin.manager.stage.disable"))
+            this.runPluginStage(plugin, 'disable', () => {
                 this.unregistryCommand(plugin)
                 this.unregistryListener(plugin)
-            this.runCatch(plugin, 'disable')
-            this.runCatch(plugin, `${this.serverType}disable`)
+            })
         })
     }
 
@@ -99,7 +104,7 @@ export class PluginManagerImpl implements plugin.PluginManager {
         try {
             if (pl[func]) pl[func].call(pl)
         } catch (ex) {
-            console.console(`§6Plugin §b${pl.description.name} §6exec §d${func} §6function error §4${ex}`)
+            console.i18n("ms.plugin.manager.stage.exec.error", { plugin: pl.description.name, executor: func, error: ex })
             console.ex(ex)
         }
     }
@@ -162,7 +167,7 @@ export class PluginManagerImpl implements plugin.PluginManager {
 
     private allowProcess(servers: string[]) {
         // Not set servers allow
-        if (!servers) return true
+        if (!servers || !servers.length) return true
         // include !type deny
         let denyServers = servers.filter(svr => svr.startsWith("!"))
         if (denyServers.length !== 0) {
@@ -174,7 +179,7 @@ export class PluginManagerImpl implements plugin.PluginManager {
 
     private createPlugin(file: string) {
         //@ts-ignore
-        require(file, { cache: false })
+        require(file + '', { cache: false })
     }
 
     private buildPlugins() {
@@ -260,4 +265,18 @@ export class PluginManagerImpl implements plugin.PluginManager {
     private unregistryListener(pluginInstance: interfaces.Plugin) {
         this.EventManager.disable(pluginInstance)
     }
+
+    private execPluginStage(pluginInstance: interfaces.Plugin, stageName: string) {
+        let stages = getPluginStageMetadata(pluginInstance, stageName);
+        for (const stage of stages) {
+            if (!this.allowProcess(stage.servers)) { continue }
+            console.i18n("ms.plugin.manager.stage.exec", { plugin: pluginInstance.description.name, name: stage.executor, stage: stageName, servers: stage.servers })
+            try {
+                pluginInstance[stage.executor].apply(pluginInstance)
+            } catch (error) {
+                console.i18n("ms.plugin.manager.stage.exec.error", { plugin: pluginInstance.description.name, executor: stage.executor, error })
+                console.ex(error)
+            }
+        }
+    }
 }

packages/plugin/src/utils.ts

@@ -57,6 +57,14 @@ function getPluginConfigMetadata(target: any) {
     return configMetadata;
 }
 
+function getPluginStageMetadata(target: any, stage: string) {
+    let stageMetadata: interfaces.ExecMetadata[] = Reflect.getMetadata(
+        METADATA_KEY.stage[stage],
+        target.constructor
+    ) || [];
+    return stageMetadata;
+}
+
 export {
     getPlugin,
     getPlugins,
@@ -65,5 +73,6 @@ export {
     getPluginCommandMetadata,
     getPluginTabCompleterMetadata,
     getPluginListenerMetadata,
-    getPluginConfigMetadata
+    getPluginConfigMetadata,
+    getPluginStageMetadata
 }

packages/plugins/package.json

@@ -1,7 +1,7 @@
 {
     "private": true,
-    "name": "@ms/plugins",
-    "version": "0.4.2",
+    "name": "@ccms/plugins",
+    "version": "0.6.0",
     "description": "MiaoScript plugins package",
     "keywords": [
         "miaoscript",
@@ -13,9 +13,6 @@
     "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",
@@ -28,8 +25,8 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/api": "^0.4.2",
-        "@ms/container": "^0.4.0",
-        "@ms/plugin": "^0.4.2"
+        "@ccms/api": "^0.6.0",
+        "@ccms/container": "^0.6.0",
+        "@ccms/plugin": "^0.6.0"
     }
 }

packages/plugins/src/HelloWorld.ts

@@ -1,11 +1,11 @@
-/// <reference types="@ms/types/dist/typings/bukkit" />
-/// <reference types="@ms/types/dist/typings/sponge" />
-/// <reference types="@ms/types/dist/typings/bungee" />
-/// <reference types="@ms/types/dist/typings/nukkit" />
+/// <reference types="@ccms/types/dist/typings/bukkit" />
+/// <reference types="@ccms/types/dist/typings/sponge" />
+/// <reference types="@ccms/types/dist/typings/bungee" />
+/// <reference types="@ccms/types/dist/typings/nukkit" />
 
-import { server } from '@ms/api';
-import { inject } from '@ms/container';
-import { plugin, interfaces, cmd, listener, tab } from '@ms/plugin'
+import { server } from '@ccms/api';
+import { inject } from '@ccms/container';
+import { plugin, interfaces, cmd, listener, tab } from '@ccms/plugin'
 
 @plugin({ name: 'HelloWorld', version: '1.0.0', author: 'MiaoWoo', source: __filename })
 export class HelloWorld extends interfaces.Plugin {

packages/plugins/src/MiaoChat.ts

@@ -1,21 +1,19 @@
-/// <reference types="@ms/types/dist/typings/bukkit" />
-/// <reference types="@ms/types/dist/typings/sponge" />
-/// <reference types="@ms/types/dist/typings/bungee" />
+/// <reference types="@ccms/types/dist/typings/bukkit" />
+/// <reference types="@ccms/types/dist/typings/sponge" />
+/// <reference types="@ccms/types/dist/typings/bungee" />
 
-import { server, plugin as pluginApi, channel } from '@ms/api'
-import { inject, optional } from '@ms/container';
-import { plugin, interfaces, cmd, listener, tab, config } from '@ms/plugin'
-import Tellraw from '@ms/common/dist/tellraw'
+import { server, plugin as pluginApi, channel, constants } from '@ccms/api'
+import { inject, optional } from '@ccms/container';
+import { plugin, interfaces, cmd, listener, tab, config, enable } from '@ccms/plugin'
+import Tellraw from '@ccms/common/dist/tellraw'
 
 const ByteArrayInputStream = Java.type("java.io.ByteArrayInputStream");
 const ByteArrayOutputStream = Java.type("java.io.ByteArrayOutputStream");
 const StandardCharsets = Java.type("java.nio.charset.StandardCharsets");
 const GZIPInputStream = Java.type("java.util.zip.GZIPInputStream");
 const GZIPOutputStream = Java.type("java.util.zip.GZIPOutputStream");
-const Consumer = Java.type("java.util.function.Consumer");
-const ByteArray = Java.type("byte[]")
-
 const BiConsumer = Java.type('java.util.function.BiConsumer')
+const ByteArray = Java.type("byte[]")
 
 class MiaoMessage {
     // public static final String CHANNEL = "MiaoChat:Default".toLowerCase();
@@ -184,9 +182,6 @@ export class MiaoChat extends interfaces.Plugin {
         } catch (ex) {
             this.logger.console("§cCan't found me.clip.placeholderapi.PlaceholderAPI variable will not be replaced! Err: " + ex)
         }
-        this.channelOff = this.Channel?.listen(this, MiaoMessage.CHANNEL, (data) => {
-            this.sendChatAll(MiaoMessage.decode(data).json)
-        })
     }
 
     spongeenable() {
@@ -205,6 +200,10 @@ export class MiaoChat extends interfaces.Plugin {
         } catch (ex) {
             this.logger.console("§cCan't found me.rojo8399.placeholderapi.PlaceholderService variable will not be replaced! Err: " + ex)
         }
+    }
+
+    @enable({ servers: [constants.ServerType.Bukkit, constants.ServerType.Sponge] })
+    serverEnbale() {
         this.channelOff = this.Channel?.listen(this, MiaoMessage.CHANNEL, (data) => {
             this.sendChatAll(MiaoMessage.decode(data).json)
         })

packages/plugins/src/MiaoConsole.ts

@@ -1,104 +1,114 @@
-/// <reference types="@ms/types/dist/typings/bukkit" />
-/// <reference types="@ms/types/dist/typings/sponge" />
-/// <reference types="@ms/types/dist/typings/bungee" />
+/// <reference types="@ccms/types/dist/typings/bukkit" />
+/// <reference types="@ccms/types/dist/typings/sponge" />
+/// <reference types="@ccms/types/dist/typings/bungee" />
 
-import { plugin as pluginApi, server, task } from '@ms/api'
-import { plugin, interfaces, cmd } from '@ms/plugin'
-import { inject, Container } from '@ms/container'
-import * as reflect from '@ms/common/dist/reflect'
-import { Server as SocketIOServer, Socket as SocketIOSocket } from '@ms/websocket'
+import { plugin as pluginApi, server, task } from '@ccms/api'
+import { plugin, interfaces, cmd } from '@ccms/plugin'
+import { inject, ContainerInstance, Container } from '@ccms/container'
+import io, { Server as SocketIOServer, Socket as SocketIOSocket } from '@ccms/websocket'
 
-const refList: Array<{ server: string, future: string }> = [
-    { server: 'an', future: 'g' },//spigot 1.12.2
-    { server: 'getServerConnection', future: 'f' },//after spigot 1.14.4
-    { server: 'func_147137_ag', future: 'field_151274_e' }//catserver 1.12.2
-]
+const suffixMap = {
+    ts: 'typescript',
+    js: 'javascript',
+    yml: 'yaml'
+}
 
 @plugin({ name: 'MiaoConsole', version: '1.0.0', author: 'MiaoWoo', servers: ['!nukkit'], source: __filename })
 export class MiaoConsole extends interfaces.Plugin {
+    @inject(ContainerInstance)
+    private container: Container
     @inject(server.ServerType)
-    private ServerType: string
+    private serverType: string
     @inject(server.Server)
-    private Server: server.Server
+    private server: server.Server
     @inject(task.TaskManager)
-    private Task: task.TaskManager
+    private task: task.TaskManager
+    @inject(pluginApi.PluginManager)
+    private pluginManager: pluginApi.PluginManager
 
     private pipeline: any;
     private socketIOServer: SocketIOServer;
 
     @cmd()
     mconsole(sender: any, command: string, args: string[]) {
+        if (args[0] == 'reload') {
+            // @ts-ignore
+            require.clear('websocket');
+            this.pluginManager.reload(this);
+            return
+        }
+        let tfunc = new Function('pipeline', args.join(' '))
+        tfunc.apply(this, [this.pipeline])
+    }
+
+    enable() {
+        let count = 0;
+        let wait = this.task.create(() => {
+            this.pipeline = this.server.getNettyPipeline()
+            if (this.pipeline) {
+                wait.cancel()
+                this.createSocketIOServer()
+                this.startSocketIOServer()
+            }
+            if (count > 30) { wait.cancel() }
+            count++
+        }).later(20).timer(40).submit()
     }
 
     disable() {
         this.socketIOServer?.close()
-    }
-
-    bukkitenable() {
-        let Bukkit = Java.type('org.bukkit.Bukkit')
-        let consoleServer = reflect.on(Bukkit.getServer()).get('console').get()
-        this.reflectChannel(this.reflectPromise(consoleServer))
-        this.injectMiaoDetect()
-    }
-
-    spongeenable() {
-        let Sponge = Java.type('org.spongepowered.api.Sponge')
-        let consoleServer = reflect.on(Sponge.getServer()).get()
-        this.reflectChannel(this.reflectPromise(consoleServer))
-        this.injectMiaoDetect()
-    }
-
-    bungeeenable() {
-        let wait = this.Task.create(() => {
-            try {
-                // @ts-ignore
-                this.pipeline = reflect.on(base.getInstance().getProxy()).get('listeners').get().toArray()[0].pipeline()
-                this.injectMiaoDetect()
-                wait.cancel();
-            } catch (ex) {
-                this.logger.warn('Wait BungeeCord start ready to get netty channel pipeline. Err: ' + ex)
-            }
-        }).later(300).timer(500).submit()
-    }
-
-    reflectPromise(consoleServer: any) {
-        for (const ref of refList) {
-            try { return reflect.on(consoleServer).call(ref.server).get(ref.future).get().get(0) } catch (error) { }
+        if (this.container.isBound(io.Instance)) {
+            this.container.unbind(io.Instance)
         }
     }
 
-    reflectChannel(promise: any) {
-        if (!promise) { throw Error(`Can't found ServerConnection or ChannelFuture !`) }
-        this.pipeline = reflect.on(promise).get('channel').get().pipeline()
-    }
-
-    injectMiaoDetect() {
-        this.socketIOServer = new SocketIOServer(this.pipeline, {
-            path: '/ws'
+    createSocketIOServer() {
+        this.socketIOServer = io(this.pipeline, {
+            path: '/ws',
+            root: '/home/project/TSWorkSpace/ms/packages/plugins/public'
         });
+        this.container.bind(io.Instance).toConstantValue(this.socketIOServer)
+    }
+
+    startSocketIOServer() {
         let namespace = this.socketIOServer.of('/MiaoConsole')
         namespace.on('connect', (client: SocketIOSocket) => {
-            global.setGlobal('client', client);
-            client.on('type', (fn) => {
             this.logger.console(`§6客户端 §b${client.id} §a新建连接...`)
-                fn && fn(this.ServerType)
-                client.emit('log', `Currect Server Version is ${this.Server.getVersion()}`)
+            client.on('type', (fn) => {
+                fn && fn(this.serverType)
+                client.emit('log', `Currect Server Version is ${this.server.getVersion()}`)
             })
             client.on('command', (cmd) => {
-                setTimeout(() => this.Server.dispatchConsoleCommand(cmd), 0)
+                setTimeout(() => this.server.dispatchConsoleCommand(cmd), 0)
                 client.emit('log', `§6命令: §b${cmd} §a执行成功!`)
             })
             client.on('exec', (code) => {
                 try {
-                    client.emit('log', this.Task.callSyncMethod(() => eval(code)) + '')
+                    client.emit('log', this.runCode(code, namespace, client))
                 } catch (ex) {
                     client.emit('log', '§4代码执行异常\n' + console.stack(ex).join('\n'))
                 }
             })
+            client.on('edit', (file: string, fn) => {
+                fn && fn(base.read(file), suffixMap[file.split('.', 2)[1]])
+            })
             client.on('disconnect', () => {
                 this.logger.console(`§6客户端 §b${client.id} §c断开连接...`)
             })
         })
         this.logger.info('Netty Channel Pipeline Inject MiaoDetectHandler Successful!')
     }
+
+    private runCode(code: string, namespace: any, client: any) {
+        let tfunc = new Function('namespace', 'client', `
+        var reflect = require('@ccms/common/dist/reflect');
+        var tempconcent = '';
+        function print(text) {
+            tempconcent += text + "\\n"
+        }
+        var result = eval(${JSON.stringify(code)});
+        return tempconcent + result
+        `)
+        return this.task.callSyncMethod(() => tfunc.apply(this, [namespace, client])) + ''
+    }
 }

packages/plugins/src/MiaoPluginManager.ts

@@ -1,11 +1,11 @@
-/// <reference types="@ms/types" />
+/// <reference types="@ccms/types" />
 
-import { task, server } from "@ms/api";
-import { inject } from "@ms/container";
-import { plugin, interfaces, cmd } from "@ms/plugin";
+import { task, server } from "@ccms/api";
+import { inject } from "@ccms/container";
+import { plugin, interfaces, cmd } from "@ccms/plugin";
 
-import http from '@ms/common/dist/http'
-import * as fs from '@ms/common/dist/fs'
+import http from '@ccms/common/dist/http'
+import * as fs from '@ccms/common/dist/fs'
 
 @plugin({ name: 'MiaoPluginManager', prefix: 'MPM', version: '1.0.0', author: 'MiaoWoo', source: __filename })
 export class MiaoPluginManager extends interfaces.Plugin {

packages/plugins/src/MiaoScriptPackageManager.ts

@@ -1,11 +1,11 @@
-import { plugin as pluginApi, task, server } from '@ms/api'
+import { plugin as pluginApi, task, server } from '@ccms/api'
 
-import { Translate } from '@ms/i18n'
-import { inject } from '@ms/container';
-import { interfaces, plugin, cmd, tab } from '@ms/plugin'
+import { Translate } from '@ccms/i18n'
+import { inject } from '@ccms/container';
+import { interfaces, plugin, cmd, tab } from '@ccms/plugin'
 
-import * as fs from '@ms/common/dist/fs'
-import http from '@ms/common/dist/http'
+import * as fs from '@ccms/common/dist/fs'
+import http from '@ccms/common/dist/http'
 
 let help = [
     '§6========= §6[§aMiaoScriptPackageManager§6] 帮助 §aBy §b喵♂呜 §6=========',

packages/plugins/src/Test.ts

@@ -1,9 +1,9 @@
-import { plugin as pluginApi } from '@ms/api'
-import { plugin, interfaces, cmd, listener, tab } from '@ms/plugin'
-import { inject } from '@ms/container';
+import { plugin as pluginApi } from '@ccms/api'
+import { plugin, interfaces, cmd, listener, tab } from '@ccms/plugin'
+import { inject } from '@ccms/container';
 
-import * as reflect from '@ms/common/dist/reflect';
-import http from '@ms/common/dist/http';
+import * as reflect from '@ccms/common/dist/reflect';
+import http from '@ccms/common/dist/http';
 
 @plugin({ name: 'Test', version: '1.0.0', author: 'MiaoWoo', source: __filename })
 export class Test extends interfaces.Plugin {

packages/plugins/tsconfig.json

@@ -3,7 +3,9 @@
     "compilerOptions": {
         "baseUrl": "src",
         "outDir": "dist",
-        "skipLibCheck": true
+        "skipLibCheck": true,
+        "sourceMap": false,
+        "inlineSourceMap": true
     },
     "exclude": [
         "dist",

packages/sponge/package.json

@@ -1,6 +1,6 @@
 {
-    "name": "@ms/sponge",
-    "version": "0.4.2",
+    "name": "@ccms/sponge",
+    "version": "0.6.0",
     "description": "MiaoScript api package",
     "keywords": [
         "miaoscript",
@@ -12,9 +12,6 @@
     "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",
@@ -27,8 +24,8 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/api": "^0.4.2",
-        "@ms/common": "^0.4.2",
-        "@ms/container": "^0.4.0"
+        "@ccms/api": "^0.6.0",
+        "@ccms/common": "^0.6.0",
+        "@ccms/container": "^0.6.0"
     }
 }

packages/sponge/src/channel.ts

@@ -1,5 +1,5 @@
-import { channel, plugin } from '@ms/api'
-import { inject, provideSingleton } from '@ms/container'
+import { channel, plugin } from '@ccms/api'
+import { inject, provideSingleton } from '@ccms/container'
 
 const Sponge = org.spongepowered.api.Sponge
 const RawDataListener = Java.type("org.spongepowered.api.network.RawDataListener")

packages/sponge/src/command.ts

@@ -1,5 +1,5 @@
-import { command, plugin } from "@ms/api";
-import { inject, provideSingleton } from "@ms/container";
+import { command, plugin } from "@ccms/api";
+import { inject, provideSingleton } from "@ccms/container";
 
 let Sponge = Java.type('org.spongepowered.api.Sponge');
 let Text = Java.type('org.spongepowered.api.text.Text');

packages/sponge/src/console.ts

@@ -1,5 +1,5 @@
-import '@ms/nashorn'
-import { MiaoScriptConsole } from '@ms/api'
+import '@ccms/nashorn'
+import { MiaoScriptConsole } from '@ccms/api'
 
 let Sponge = Java.type('org.spongepowered.api.Sponge');
 var Text = Java.type('org.spongepowered.api.text.Text');

packages/sponge/src/event.ts

@@ -1,5 +1,5 @@
-import { event, plugin } from '@ms/api'
-import { inject, provideSingleton } from '@ms/container';
+import { event, plugin } from '@ccms/api'
+import { inject, provideSingleton } from '@ccms/container';
 
 let Modifier = Java.type("java.lang.reflect.Modifier");
 let Order = Java.type("org.spongepowered.api.event.Order");

packages/sponge/src/index.ts

@@ -1,7 +1,7 @@
-/// <reference types="@ms/types/dist/typings/sponge" />
+/// <reference types="@ccms/types/dist/typings/sponge" />
 
-import { server } from '@ms/api'
-import { Container } from '@ms/container'
+import { server } from '@ccms/api'
+import { Container } from '@ccms/container'
 
 import { SpongeConsole } from './console';
 import './event';

packages/sponge/src/server.ts

@@ -1,13 +1,7 @@
-import { server } from '@ms/api'
-import { provideSingleton } from '@ms/container';
+import { server, constants } from '@ccms/api'
+import { provideSingleton } from '@ccms/container';
 
-import * as reflect from '@ms/common/dist/reflect'
-
-const refList: Array<{ server: string, future: string }> = [
-    { server: 'an', future: 'g' },//spigot 1.12.2
-    { server: 'getServerConnection', future: 'f' },//after spigot 1.14.4
-    { server: 'func_147137_ag', future: 'field_151274_e' }//catserver 1.12.2
-]
+import * as reflect from '@ccms/common/dist/reflect'
 
 const Sponge = org.spongepowered.api.Sponge;
 const TextSerializers = org.spongepowered.api.text.serializer.TextSerializers;
@@ -64,14 +58,24 @@ export class SpongeServer implements server.Server {
     }
     private reflectPipeline() {
         let consoleServer = reflect.on(Sponge.getServer()).get()
+        let connection: any;
         let promise: any;
-        for (const ref of refList) {
+        for (const method of constants.Reflect.Method.getServerConnection) {
             try {
-                promise = reflect.on(consoleServer).call(ref.server).get(ref.future).get().get(0); break;
-            } catch (error) {
+                connection = reflect.on(consoleServer).call(method).get()
+                if (connection.class.name.indexOf('ServerConnection') !== -1) { break; }
+                connection = undefined;
+            } catch (error) { }
         }
+        if (!connection) { console.error("Can't found ServerConnection!"); return }
+        for (const field of constants.Reflect.Field.listeningChannels) {
+            try {
+                promise = reflect.on(connection).get(field).get().get(0);
+                if (promise.class.name.indexOf('Promise') !== -1) { break; }
+                promise = undefined;
+            } catch (error) { }
         }
-        if (!promise) { throw Error(`Can't found ServerConnection or ChannelFuture !`) }
+        if (!promise) { console.error("Can't found listeningChannels!"); return }
         this.pipeline = reflect.on(promise).get('channel').get().pipeline()
     }
 }

packages/sponge/src/task.ts

@@ -1,5 +1,5 @@
-import { task, plugin } from '@ms/api'
-import { inject, provideSingleton, postConstruct } from '@ms/container';
+import { task, plugin } from '@ccms/api'
+import { inject, provideSingleton, postConstruct } from '@ccms/container';
 
 const Sponge = Java.type("org.spongepowered.api.Sponge");
 const Task = Java.type("org.spongepowered.api.scheduler.Task");

packages/types/package.json

@@ -1,6 +1,6 @@
 {
-    "name": "@ms/types",
-    "version": "0.4.0",
+    "name": "@ccms/types",
+    "version": "0.6.0",
     "description": "MiaoScript types package",
     "keywords": [
         "miaoscript",
@@ -12,8 +12,5 @@
     "homepage": "https://github.com/circlecloud/ms.git",
     "license": "ISC",
     "main": "dist/index.js",
-    "types": "dist/index.d.ts",
-    "publishConfig": {
-        "registry": "https://repo.yumc.pw/repository/npm-hosted/"
-    }
+    "types": "dist/index.d.ts"
 }

packages/websocket/package.json

@@ -1,6 +1,6 @@
 {
-    "name": "@ms/websocket",
-    "version": "0.4.2",
+    "name": "@ccms/websocket",
+    "version": "0.6.0",
     "description": "MiaoScript websocket package",
     "keywords": [
         "miaoscript",
@@ -12,9 +12,6 @@
     "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",
@@ -27,6 +24,6 @@
         "typescript": "^3.8.3"
     },
     "dependencies": {
-        "@ms/nashorn": "^0.4.0"
+        "@ccms/nashorn": "^0.6.0"
     }
 }

packages/websocket/src/index.ts

@@ -1,4 +1,4 @@
-/// <reference types="@ms/nashorn" />
+/// <reference types="@ccms/nashorn" />
 
 import { Server, ServerOptions } from './socket-io'
 
@@ -41,6 +41,6 @@ type SocketStatic = SocketIOStatic & { Instance?: symbol }
 let io: SocketStatic = function (pipeline: any, options: ServerOptions) {
     return new Server(pipeline, options)
 }
-io.Instance = Symbol("@ms/websocket")
+io.Instance = Symbol("@ccms/websocket")
 export default io
 export * from './socket-io'

packages/websocket/src/server/index.ts

@@ -1,10 +1,10 @@
 import { EventEmitter } from 'events'
 
+import { NettyClient } from './client'
+import { ServerOptions } from '../socket-io'
 import { ServerEvent, Keys } from './constants'
 import { WebSocketDetect } from './websocket_detect'
 import { WebSocketHandler } from './websocket_handler'
-import { NettyClient } from './client'
-import { ServerOptions } from '../socket-io'
 
 class NettyWebSocketServer extends EventEmitter {
     private pipeline: any;
@@ -22,10 +22,9 @@ class NettyWebSocketServer extends EventEmitter {
             ctx.fireChannelRead(channel)
         })
         connectEvent.on(ServerEvent.connect, (ctx) => {
-            console.log('NettyWebSocketServer ServerEvent.connect', ctx, ctx.channel().id(), ctx.channel().class.name)
-            let nettyClient = new NettyClient(this, ctx.channel());
-            this.allClients[nettyClient.id] = nettyClient;
-            this.emit(ServerEvent.connect, nettyClient);
+            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())
@@ -46,4 +45,4 @@ export {
     NettyWebSocketServer,
     ServerEvent,
     NettyClient
-};
+}

packages/websocket/src/server/text_websocket_frame.ts

@@ -1,7 +1,7 @@
-import { TextWebSocketFrameHandlerAdapter } from '../netty'
 import { EventEmitter } from 'events'
 import { ServerEvent } from './constants'
 import { ServerOptions } from '../socket-io';
+import { TextWebSocketFrameHandlerAdapter } from '../netty'
 
 export class TextWebSocketFrameHandler extends TextWebSocketFrameHandlerAdapter {
     private event: EventEmitter;