v0.24.2

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

lerna.json

@@ -1,5 +1,5 @@
 {
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "useWorkspaces": true,
     "npmClient": "yarn",
     "packages": [

package.json

@@ -12,9 +12,11 @@
         "build": "lerna run build",
         "ug": "yarn upgrade-interactive --latest",
         "np": "./script/push.sh",
-        "lsp": "npm login --registry=https://registry.npmjs.org --scope=@ccms",
-        "lp": "lerna publish --registry https://registry.npmjs.org",
-        "lpb": "lerna publish --registry https://registry.npmjs.org --canary --preid beta --pre-dist-tag beta"
+        "lsp": "npm login -scope=@ccms",
+        "lp": "lerna publish",
+        "lpb": "lerna publish --dist-tag beta",
+        "lpc": "lerna publish --canary --preid beta --pre-dist-tag beta",
+        "lpf": "lerna publish from-package --yes"
     },
     "workspaces": [
         "packages/*"

packages/amqp/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/amqp",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript amqp package",
     "keywords": [
         "miaoscript",
@@ -19,12 +19,12 @@
         "test": "echo \"Error: run tests from root\" && exit 1"
     },
     "dependencies": {
-        "@ccms/api": "^0.23.0-beta.0",
-        "@ccms/common": "^0.23.0-beta.0",
-        "@ccms/container": "^0.23.0-beta.0"
+        "@ccms/api": "^0.24.2",
+        "@ccms/common": "^0.24.2",
+        "@ccms/container": "^0.24.2"
     },
     "devDependencies": {
-        "@ccms/nashorn": "^0.23.0-beta.0",
+        "@ccms/nashorn": "^0.24.2",
         "@javatypes/amqp-client": "^0.0.3",
         "@javatypes/spring-amqp": "^0.0.3",
         "@javatypes/spring-rabbit": "^0.0.3",

packages/api/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/api",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript api package",
     "keywords": [
         "miaoscript",
@@ -19,9 +19,9 @@
         "test": "echo \"Error: run tests from root\" && exit 1"
     },
     "dependencies": {
-        "@ccms/common": "^0.23.0-beta.0",
-        "@ccms/container": "^0.23.0-beta.0",
-        "@ccms/polyfill": "^0.23.0-beta.0",
+        "@ccms/common": "^0.24.2",
+        "@ccms/container": "^0.24.2",
+        "@ccms/polyfill": "^0.24.2",
         "base64-js": "^1.5.1",
         "source-map-builder": "^0.0.7"
     },

packages/api/src/console.ts

@@ -44,13 +44,13 @@ export namespace jsconsole {
                             let file = Paths.get(Paths.get(fileName, '..', sourceMappingURL).toFile().getCanonicalPath()).toFile()
                             if (file.exists()) {
                                 sourceContent = base.read(file)
+                                sourceFileMaps[fileName] = file.getCanonicalPath()
                             } else if (global.debug) {
                                 console.debug('readSourceMap can\'t found', fileName, 'source map file', sourceMappingURL)
                             }
                         }
                         if (sourceContent) {
                             sourceMaps[fileName] = new SourceMapBuilder(JSON.parse(sourceContent))
-                            sourceFileMaps[fileName] = Paths.get(fileName, '..', sourceMaps[fileName].sources[0]).toFile().getCanonicalPath()
                         }
                     }
                 }
@@ -88,9 +88,9 @@ export namespace jsconsole {
                 let { fileName, lineNumber } = readSourceMap(trace.fileName, trace.lineNumber)
                 if (fileName.startsWith(root)) { fileName = fileName.split(root)[1] }
                 if (color) {
-                    cache.push(`    §e->§c ${fileName}:${lineNumber} => §4${trace.methodName}`)
+                    cache.push(`    §e->§c ${fileName}:${lineNumber}(${trace.lineNumber}) => §4${trace.methodName}`)
                 } else {
-                    cache.push(`    -> ${fileName}:${lineNumber} => ${trace.methodName}`)
+                    cache.push(`    -> ${fileName}:${lineNumber}(${trace.lineNumber}) => ${trace.methodName}`)
                 }
             } else {
                 let className = trace.className

packages/api/src/item.ts

@@ -5,7 +5,7 @@ export namespace item {
     export abstract class Item {
         abstract builder(): ItemBuilder
         abstract toJson(item: any): string
-        abstract fromJSON(json: string): any
+        abstract fromJson(json: string): any
     }
     export interface ItemBuilder {
         from(item: any): ItemBuilder

packages/api/src/plugin.ts

@@ -155,7 +155,11 @@ export namespace plugin {
          */
         cname?: string
         /**
-         * 插件等级 付费插件自动注入
+         * 付费插件ID
+         */
+        pid?: number
+        /**
+         * 付费插件等级 付费插件自动注入
          */
         level?: number
         /**

packages/api/src/server.ts

@@ -172,13 +172,13 @@ export namespace server {
         }
         protected reflectRootLogger(consoleServer: any) {
             try {
-                this.rootLogger = reflect.on(consoleServer).get('LOGGER').get().parent
+                this.rootLogger = reflect.on(consoleServer).get('LOGGER').get()
             } catch (error: any) {
                 if (global.debug) {
                     console.ex(error)
                 }
                 try {
-                    this.rootLogger = reflect.on(consoleServer).get(0).get().parent
+                    this.rootLogger = reflect.on(consoleServer).get(0).get()
                 } catch (error: any) {
                     if (global.debug) {
                         console.ex(error)

packages/bukkit/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/bukkit",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript bukkit package",
     "keywords": [
         "miaoscript",
@@ -25,8 +25,8 @@
         "typescript": "^4.6.3"
     },
     "dependencies": {
-        "@ccms/api": "^0.23.0-beta.0",
-        "@ccms/common": "^0.23.0-beta.0",
-        "@ccms/container": "^0.23.0-beta.0"
+        "@ccms/api": "^0.24.2",
+        "@ccms/common": "^0.24.2",
+        "@ccms/container": "^0.24.2"
     }
 }

packages/bukkit/src/internal/chat.ts

@@ -6,7 +6,7 @@ let bukkitChatInvoke: BukkitChatInvoke
 abstract class BukkitChatInvoke {
     private downgrade: boolean = false
     protected RemapUtils: any
-    protected ComponentSerializer:any
+    protected ComponentSerializer: any
 
     protected ChatSerializer: any
     protected nmsChatSerializerMethodName: string
@@ -39,6 +39,8 @@ abstract class BukkitChatInvoke {
                     if (nmsChatMessageTypeClass.isEnum()) {
                         this.chatMessageTypes = nmsChatMessageTypeClass.getEnumConstants()
                         break
+                    } else if (nmsChatMessageTypeClass.getName() == 'int') {
+                        break
                     }
                 }
             }

packages/bukkit/src/item.ts

@@ -12,6 +12,7 @@ export class BukkitItem extends item.Item {
     private NBTTagCompound: any
     private nmsSaveNBTMethodName: any
     private MojangsonParser: any
+    private nmsItemStack: any
     private mpParseMethodName: any
     private nmsVersion: any
     constructor() {
@@ -25,8 +26,8 @@ export class BukkitItem extends item.Item {
         let nbt = new this.NBTTagCompound()
         return this.CraftItemStack.asNMSCopy(item)[this.nmsSaveNBTMethodName](nbt).toString()
     }
-    fromJSON(json: string) {
-        return this.CraftItemStack.asBukkitCopy(this.MojangsonParser[this.mpParseMethodName](json))
+    fromJson(json: string) {
+        return this.CraftItemStack.asBukkitCopy(new this.nmsItemStack(this.MojangsonParser[this.mpParseMethodName](json)))
     }
     private obcCls(name: string) {
         return base.getClass(['org.bukkit.craftbukkit', this.nmsVersion, name].join('.'))
@@ -44,6 +45,7 @@ export class BukkitItem extends item.Item {
             // @ts-ignore
             let asNMSCopyMethod = CraftItemStackClass.getMethod('asNMSCopy', ItemStack.class)
             let nmsItemStackClass = asNMSCopyMethod.getReturnType()
+            this.nmsItemStack = Java.type(nmsItemStackClass.getName())
             let nmsNBTTagCompoundClass = undefined
             for (let method of Java.from(nmsItemStackClass.getMethods())) {
                 let rt = method.getReturnType()
@@ -61,7 +63,7 @@ export class BukkitItem extends item.Item {
                 }
             }
             try {
-                this.MojangsonParser = this.nmsCls('MojangsonParser')
+                this.MojangsonParser = this.nmsCls('MojangsonParser').static
             } catch (error) {
                 this.MojangsonParser = Java.type('net.minecraft.nbt.MojangsonParser')
             }

packages/bungee/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/bungee",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript bungee package",
     "keywords": [
         "miaoscript",
@@ -25,8 +25,8 @@
         "typescript": "^4.6.3"
     },
     "dependencies": {
-        "@ccms/api": "^0.23.0-beta.0",
-        "@ccms/common": "^0.23.0-beta.0",
-        "@ccms/container": "^0.23.0-beta.0"
+        "@ccms/api": "^0.24.2",
+        "@ccms/common": "^0.24.2",
+        "@ccms/container": "^0.24.2"
     }
 }

packages/client/package.json

@@ -1,7 +1,7 @@
 {
     "private": true,
     "name": "@ccms/client",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript client package",
     "keywords": [
         "miaoscript",

packages/common/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/common",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript common package",
     "keywords": [
         "miaoscript",
@@ -19,7 +19,7 @@
         "test": "echo \"Error: run tests from root\" && exit 1"
     },
     "devDependencies": {
-        "@ccms/nashorn": "^0.23.0-beta.0",
+        "@ccms/nashorn": "^0.24.2",
         "@javatypes/jdk": "^0.0.3",
         "reflect-metadata": "^0.1.13",
         "rimraf": "^3.0.2",

packages/common/src/reflect.ts

@@ -54,6 +54,7 @@ class Reflect {
             }
         }
         if (!field) throw new Error(`can't reflect field ${typeof nameOrIndex == "number" ? 'index' : 'name'} ${nameOrIndex} from ${this.class.getName()}!`)
+        fieldCache.set(key, field)
         return accessible(field)
     }
 

packages/compile/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/compile",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript compile package",
     "keywords": [
         "miaoscript",

packages/container/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/container",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript container package",
     "keywords": [
         "miaoscript",
@@ -19,7 +19,7 @@
         "test": "echo \"Error: run tests from root\" && exit 1"
     },
     "devDependencies": {
-        "@ccms/nashorn": "^0.23.0-beta.0",
+        "@ccms/nashorn": "^0.24.2",
         "reflect-metadata": "^0.1.13",
         "rimraf": "^3.0.2",
         "typescript": "^4.6.3"

packages/core/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/core",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript core package",
     "keywords": [
         "miaoscript",
@@ -24,8 +24,8 @@
         "typescript": "^4.6.3"
     },
     "dependencies": {
-        "@ccms/api": "^0.23.0-beta.0",
-        "@ccms/container": "^0.23.0-beta.0"
+        "@ccms/api": "^0.24.2",
+        "@ccms/container": "^0.24.2"
     },
     "gitHead": "781524f83e52cad26d7c480513e3c525df867121"
 }

packages/database/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/database",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript database package",
     "keywords": [
         "miaoscript",
@@ -25,7 +25,7 @@
         "typescript": "^4.6.3"
     },
     "dependencies": {
-        "@ccms/api": "^0.23.0-beta.0",
-        "@ccms/container": "^0.23.0-beta.0"
+        "@ccms/api": "^0.24.2",
+        "@ccms/container": "^0.24.2"
     }
 }

packages/i18n/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/i18n",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript i18n package",
     "keywords": [
         "miaoscript",
@@ -19,7 +19,7 @@
         "test": "echo \"Error: run tests from root\" && exit 1"
     },
     "devDependencies": {
-        "@ccms/nashorn": "^0.23.0-beta.0",
+        "@ccms/nashorn": "^0.24.2",
         "@types/js-yaml": "^4.0.5",
         "reflect-metadata": "^0.1.13",
         "rimraf": "^3.0.2",

packages/keyvalue/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/keyvalue",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript keyvalue package",
     "keywords": [
         "miaoscript",
@@ -19,12 +19,12 @@
         "test": "echo \"Error: run tests from root\" && exit 1"
     },
     "dependencies": {
-        "@ccms/api": "^0.23.0-beta.0",
-        "@ccms/common": "^0.23.0-beta.0",
-        "@ccms/container": "^0.23.0-beta.0"
+        "@ccms/api": "^0.24.2",
+        "@ccms/common": "^0.24.2",
+        "@ccms/container": "^0.24.2"
     },
     "devDependencies": {
-        "@ccms/nashorn": "^0.23.0-beta.0",
+        "@ccms/nashorn": "^0.24.2",
         "@javatypes/amqp-client": "^0.0.3",
         "@javatypes/spring-amqp": "^0.0.3",
         "@javatypes/spring-rabbit": "^0.0.3",

packages/molang/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/molang",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "A fast parser for Minecraft's MoLang",
     "main": "dist/index.js",
     "types": "dist/index.d.ts",

packages/nashorn/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/nashorn",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript nashorn package",
     "keywords": [
         "miaoscript",

packages/nodejs/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/nodejs",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript nodejs package",
     "keywords": [
         "miaoscript",
@@ -19,7 +19,7 @@
         "test": "echo \"Error: run tests from root\" && exit 1"
     },
     "devDependencies": {
-        "@ccms/nashorn": "^0.23.0-beta.0",
+        "@ccms/nashorn": "^0.24.2",
         "reflect-metadata": "^0.1.13",
         "rimraf": "^3.0.2",
         "tslib": "^2.3.1",

packages/nukkit/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/nukkit",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript nukkit package",
     "keywords": [
         "miaoscript",
@@ -25,8 +25,8 @@
         "typescript": "^4.6.3"
     },
     "dependencies": {
-        "@ccms/api": "^0.23.0-beta.0",
-        "@ccms/common": "^0.23.0-beta.0",
-        "@ccms/container": "^0.23.0-beta.0"
+        "@ccms/api": "^0.24.2",
+        "@ccms/common": "^0.24.2",
+        "@ccms/container": "^0.24.2"
     }
 }

packages/plugin/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/plugin",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript plugin package",
     "keywords": [
         "miaoscript",
@@ -26,10 +26,10 @@
         "typescript": "^4.6.3"
     },
     "dependencies": {
-        "@ccms/api": "^0.23.0-beta.0",
-        "@ccms/common": "^0.23.0-beta.0",
-        "@ccms/container": "^0.23.0-beta.0",
-        "@ccms/i18n": "^0.23.0-beta.0",
+        "@ccms/api": "^0.24.2",
+        "@ccms/common": "^0.24.2",
+        "@ccms/container": "^0.24.2",
+        "@ccms/i18n": "^0.24.2",
         "@ccms/verify": "^0.21.1",
         "crypto-js": "^4.1.1",
         "js-yaml": "^4.1.0"

packages/plugin/src/config.ts

@@ -68,30 +68,25 @@ export class PluginConfigManager {
     private loadConfig0(plugin: plugin.Plugin, metadata: interfaces.ConfigMetadata) {
         try {
             let defaultValue = metadata.default ?? plugin[metadata.variable]
-            let configValue = defaultValue || {}
-            if (defaultValue) {
-                metadata.file = fs.concat(
-                    fs.file(plugin.description.loadMetadata.file).parent,
-                    plugin.description.name,
-                    metadata.filename
-                )
-                let configLoader = this.getConfigLoader(metadata.format)
-                if (!fs.exists(metadata.file)) {
-                    base.save(metadata.file, configLoader.dump(defaultValue))
-                    console.i18n("ms.plugin.manager.config.save.default", {
-                        plugin: plugin.description.name,
-                        name: metadata.name,
-                        format: metadata.format
-                    })
-                } else if (metadata.migrate) {
-                    configValue = configLoader.load(base.read(metadata.file)) || {}
-                    if (defaultValue && this.setDefaultValue(configValue, defaultValue, !!metadata.default)) {
-                        base.save(metadata.file, configLoader.dump(configValue))
-                    }
-                    console.debug(`[${plugin.description.name}] Load Config ${metadata.variable} from file ${metadata.file} =>
-${JSON.stringify(configValue, undefined, 4).substring(0, 500)}`)
-                }
+            metadata.file = fs.concat(
+                fs.file(plugin.description.loadMetadata.file).parent,
+                plugin.description.name,
+                metadata.filename
+            )
+            let configLoader = this.getConfigLoader(metadata.format)
+            if (!fs.exists(metadata.file) && defaultValue) {
+                base.save(metadata.file, configLoader.dump(defaultValue))
+                console.i18n("ms.plugin.manager.config.save.default", {
+                    plugin: plugin.description.name,
+                    name: metadata.name,
+                    format: metadata.format
+                })
             }
+            let configValue = configLoader.load(base.read(metadata.file)) || {}
+            if (metadata.migrate && defaultValue && this.setDefaultValue(configValue, defaultValue, !!metadata.default)) {
+                base.save(metadata.file, configLoader.dump(configValue))
+            }
+            console.debug(`[${plugin.description.name}] Load Config ${metadata.variable} from file ${metadata.file}`)
             this.defienConfigProp(plugin, metadata, configValue)
         } catch (error: any) {
             console.i18n("ms.plugin.manager.config.load.error", {

packages/polyfill/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/polyfill",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript polyfill package",
     "author": "MiaoWoo <admin@yumc.pw>",
     "homepage": "https://github.com/circlecloud/ms.git",
@@ -14,12 +14,12 @@
         "test": "echo \"Error: run tests from root\" && exit 1"
     },
     "dependencies": {
-        "@ccms/i18n": "^0.23.0-beta.0",
-        "@ccms/nodejs": "^0.23.0-beta.0",
+        "@ccms/i18n": "^0.24.2",
+        "@ccms/nodejs": "^0.24.2",
         "core-js": "^3.22.1"
     },
     "devDependencies": {
-        "@ccms/nashorn": "^0.23.0-beta.0",
+        "@ccms/nashorn": "^0.24.2",
         "reflect-metadata": "^0.1.13",
         "rimraf": "^3.0.2",
         "typescript": "^4.6.3"

packages/protocol/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/protocol",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript protocol package",
     "keywords": [
         "miaoscript",

packages/sponge/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/sponge",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript sponge package",
     "keywords": [
         "miaoscript",
@@ -25,8 +25,8 @@
         "typescript": "^4.6.3"
     },
     "dependencies": {
-        "@ccms/api": "^0.23.0-beta.0",
-        "@ccms/common": "^0.23.0-beta.0",
-        "@ccms/container": "^0.23.0-beta.0"
+        "@ccms/api": "^0.24.2",
+        "@ccms/common": "^0.24.2",
+        "@ccms/container": "^0.24.2"
     }
 }

packages/spring/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/spring",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript spring package",
     "keywords": [
         "miaoscript",
@@ -24,9 +24,9 @@
         "typescript": "^4.6.3"
     },
     "dependencies": {
-        "@ccms/api": "^0.23.0-beta.0",
-        "@ccms/common": "^0.23.0-beta.0",
-        "@ccms/container": "^0.23.0-beta.0",
-        "@ccms/database": "^0.23.0-beta.0"
+        "@ccms/api": "^0.24.2",
+        "@ccms/common": "^0.24.2",
+        "@ccms/container": "^0.24.2",
+        "@ccms/database": "^0.24.2"
     }
 }

packages/web/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/web",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript web package",
     "keywords": [
         "miaoscript",
@@ -29,7 +29,7 @@
         "typescript": "^4.6.3"
     },
     "dependencies": {
-        "@ccms/api": "^0.23.0-beta.0",
-        "@ccms/container": "^0.23.0-beta.0"
+        "@ccms/api": "^0.24.2",
+        "@ccms/container": "^0.24.2"
     }
 }

packages/websocket/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ccms/websocket",
-    "version": "0.23.0-beta.0",
+    "version": "0.24.2",
     "description": "MiaoScript websocket package",
     "keywords": [
         "miaoscript",
@@ -23,7 +23,7 @@
         "parseuri": "^0.0.6"
     },
     "devDependencies": {
-        "@ccms/nashorn": "^0.23.0-beta.0",
+        "@ccms/nashorn": "^0.24.2",
         "@javatypes/tomcat-websocket-api": "^0.0.3",
         "reflect-metadata": "^0.1.13",
         "rimraf": "^3.0.2",

packages/websocket/src/client/netty/index.ts

@@ -58,7 +58,7 @@ export class NettyWebSocket extends Transport {
     private _host: string
     private _port: number
     private channel: any
-    private b = new Bootstrap();
+    private b: any
 
     constructor(url: string, subProtocol: string = '', headers: WebSocketHeader = {}) {
         super(url, subProtocol, headers)
@@ -102,6 +102,7 @@ export class NettyWebSocket extends Transport {
         // HttpResponseDecoder to WebSocketHttpResponseDecoder in the pipeline.
         let handler = new WebSocketClientHandler(WebSocketClientHandshakerFactory
             .newHandshaker(uri, WebSocketVersion.V13, null, false, headers), this)
+        this.b = new Bootstrap()
         this.b.group(group)
             .channel(socketChannelClass)
             .handler(new ChannelInitializer({
@@ -123,18 +124,22 @@ export class NettyWebSocket extends Transport {
                 }
             }))
         this.b.connect(this._host, this._port).addListener(new ChannelFutureListener((future: any) => {
-            this.channel = future.sync().channel()
-            this.onconnection({})
-            handler.handshakeFuture.addListener(new ChannelFutureListener((future: any) => {
-                try {
-                    future.sync()
-                    // only trigger onconnect when not have error
-                    this.onconnect({})
-                } catch (error: any) {
-                    // ignore error exceptionCaught from handler
-                    // this.onerror({ error })
-                }
-            }))
+            try {
+                this.channel = future.sync().channel()
+                this.onconnection({})
+                handler.handshakeFuture.addListener(new ChannelFutureListener((future: any) => {
+                    try {
+                        future.sync()
+                        // only trigger onconnect when not have error
+                        this.onconnect({})
+                    } catch (error: any) {
+                        // ignore error exceptionCaught from handler
+                        // this.onerror({ error })
+                    }
+                }))
+            } catch (error: any) {
+                this.onerror({ error })
+            }
         }))
     }
     doSend(text: string) {