Compare commits

...

5 Commits

Author SHA1 Message Date
b5fac23c5c v0.22.0 2022-05-21 15:05:14 +08:00
148f6c28c4 feat enable faster load mode
Signed-off-by: MiaoWoo <admin@yumc.pw>
2022-05-21 11:54:40 +08:00
880065495e feat: add database web manager
Signed-off-by: MiaoWoo <admin@yumc.pw>
2022-05-21 11:54:09 +08:00
7fc70a92d5 v0.21.2 2022-05-14 16:44:25 +08:00
df6da12a8a feat: modify package description
Signed-off-by: MiaoWoo <admin@yumc.pw>
2022-05-14 16:43:50 +08:00
33 changed files with 200 additions and 129 deletions

View File

@@ -1,5 +1,5 @@
{ {
"version": "0.21.0", "version": "0.22.0",
"useWorkspaces": true, "useWorkspaces": true,
"npmClient": "yarn", "npmClient": "yarn",
"packages": [ "packages": [
@@ -8,10 +8,6 @@
"command": { "command": {
"run": { "run": {
"stream": true "stream": true
},
"publish": {
"access": "public",
"registry": "https://repo.yumc.pw/repository/npm-hosted/"
} }
} }
} }

View File

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

View File

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

View File

@@ -35,6 +35,9 @@ export namespace database {
abstract createDatabase(name: string, config: DataBaseConfig): DataBase abstract createDatabase(name: string, config: DataBaseConfig): DataBase
abstract removeDatabase(name: string): boolean abstract removeDatabase(name: string): boolean
abstract getDatabase(name: string): DataBase abstract getDatabase(name: string): DataBase
abstract startWebManager(...args: string[])
abstract stopWebManager()
abstract shutdown()
} }
@injectable() @injectable()
export abstract class DataBase { export abstract class DataBase {

View File

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

View File

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

View File

@@ -1,7 +1,7 @@
{ {
"private": true, "private": true,
"name": "@ccms/client", "name": "@ccms/client",
"version": "0.21.0", "version": "0.22.0",
"description": "MiaoScript client package", "description": "MiaoScript client package",
"keywords": [ "keywords": [
"miaoscript", "miaoscript",

View File

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

View File

@@ -0,0 +1,35 @@
export type Version = [string, string, string]
export class VersionUtils {
static isEqual(version: string, targetVersion: string): boolean {
return version == targetVersion
}
static isGreaterOrEqual(version: string, targetVersion: string): boolean {
const v1 = parseVersion(version)
const v2 = parseVersion(targetVersion)
return (
v1[0] > v2[0] ||
(v1[0] === v2[0] && v1[1] > v2[1]) ||
(v1[0] === v2[0] && v1[1] === v2[1] && v1[2] >= v2[2])
)
}
static isGreater(version: string, targetVersion: string): boolean {
const v1 = parseVersion(version)
const v2 = parseVersion(targetVersion)
return (
v1[0] > v2[0] ||
(v1[0] === v2[0] && v1[1] > v2[1]) ||
(v1[0] === v2[0] && v1[1] === v2[1] && v1[2] > v2[2])
)
}
}
function parseVersion(version: string = ""): Version {
const v: Version = ['0', '0', '0']
version.split(".").forEach((value, i) => (v[i] = value))
return v
}

View File

@@ -1,6 +1,6 @@
{ {
"name": "@ccms/compile", "name": "@ccms/compile",
"version": "0.21.0", "version": "0.22.0",
"description": "MiaoScript compile package", "description": "MiaoScript compile package",
"keywords": [ "keywords": [
"miaoscript", "miaoscript",

View File

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

View File

@@ -102,8 +102,8 @@ export const MavenDepend = (groupId: string, artifactId: string, version: string
const loadedMavenDepend = new Set<string>() const loadedMavenDepend = new Set<string>()
export function loadMavenDepend(groupId: string, artifactId: string, version: string, recursion = false) { export function loadMavenDepend(groupId: string, artifactId: string, version: string, recursion = false) {
const key = `${groupId}:${artifactId}:${version}`
try { try {
const key = `${groupId}:${artifactId}:${version}`
if (loadedMavenDepend.has(key)) { return } if (loadedMavenDepend.has(key)) { return }
console.info('loading maven dependency', key) console.info('loading maven dependency', key)
let [pom, _] = base.loadMavenDepend(groupId, artifactId, version) let [pom, _] = base.loadMavenDepend(groupId, artifactId, version)
@@ -137,7 +137,7 @@ export function loadMavenDepend(groupId: string, artifactId: string, version: st
} }
} }
} catch (error: any) { } catch (error: any) {
console.warn('attachMavenDepend failed. Error: ' + error) console.warn('load maven dependency', key, 'failed. Error:', error)
if (global.debug) { if (global.debug) {
console.ex(error) console.ex(error)
} }

View File

@@ -1,7 +1,7 @@
{ {
"name": "@ccms/core", "name": "@ccms/core",
"version": "0.21.0", "version": "0.22.0",
"description": "MiaoScript api package", "description": "MiaoScript core package",
"keywords": [ "keywords": [
"miaoscript", "miaoscript",
"minecraft", "minecraft",
@@ -24,8 +24,8 @@
"typescript": "^4.6.3" "typescript": "^4.6.3"
}, },
"dependencies": { "dependencies": {
"@ccms/api": "^0.21.0", "@ccms/api": "^0.22.0",
"@ccms/container": "^0.21.0" "@ccms/container": "^0.22.0"
}, },
"gitHead": "781524f83e52cad26d7c480513e3c525df867121" "gitHead": "781524f83e52cad26d7c480513e3c525df867121"
} }

View File

@@ -6,6 +6,7 @@ console.i18n("ms.core.ioc.completed", { scope: global.scope, time: (Date.now() -
import * as yaml from 'js-yaml' import * as yaml from 'js-yaml'
import http from '@ccms/common/dist/http' import http from '@ccms/common/dist/http'
import * as fs from '@ccms/common/dist/fs' import * as fs from '@ccms/common/dist/fs'
import { VersionUtils } from '@ccms/common/dist/version'
const UUID = Java.type('java.util.UUID') const UUID = Java.type('java.util.UUID')
@@ -25,6 +26,11 @@ class MiaoScriptCore {
this.loadServerConsole() this.loadServerConsole()
this.loadPlugins() this.loadPlugins()
process.emit('core.after.enable') process.emit('core.after.enable')
console.i18n("ms.core.engine.completed", {
loader: base.version,
version: 'v' + global.ScriptEngineVersion,
time: (Date.now() - global.ScriptEngineStartTime) / 1000
})
return () => this.disable() return () => this.disable()
} }
@@ -123,6 +129,30 @@ function loadMiaoScriptConfig() {
global.ScriptSlowExecuteTime = global.ScriptEngineConfig.slow_execute || 50 global.ScriptSlowExecuteTime = global.ScriptEngineConfig.slow_execute || 50
} }
function createCore() {
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()
process.emit('core.before.initialize.detect')
console.i18n("ms.core.initialize.detect", { scope: global.scope, type })
container.bind(server.ServerType).toConstantValue(type)
container.bind(server.ServerChecker).toSelf().inSingletonScope()
container.bind(server.NativePluginManager).toSelf().inSingletonScope()
process.emit('core.after.initialize.detect')
process.emit('core.before.package.initialize')
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", { scope: global.scope, type, time: (Date.now() - corePackageStartTime) / 1000 })
process.emit('core.after.package.initialize')
return container.get<MiaoScriptCore>(MiaoScriptCore)
}
function initialize() { function initialize() {
process.emit('core.before.initialize') process.emit('core.before.initialize')
loadMiaoScriptConfig() loadMiaoScriptConfig()
@@ -130,43 +160,22 @@ function initialize() {
global.setGlobal('loadCoreScript', loadCoreScript) global.setGlobal('loadCoreScript', loadCoreScript)
loadCoreScript('initialize') loadCoreScript('initialize')
try { try {
let corePackageStartTime = new Date().getTime() let core = createCore()
container.bind(ContainerInstance).toConstantValue(container) if (VersionUtils.isGreaterOrEqual(base.version, '0.22.0')) { return core }
container.bind(plugin.PluginInstance).toConstantValue(base.getInstance()) return core.enable()
container.bind(plugin.PluginFolder).toConstantValue('plugins')
let type = detectServer()
process.emit('core.before.initialize.detect')
console.i18n("ms.core.initialize.detect", { scope: global.scope, type })
container.bind(server.ServerType).toConstantValue(type)
container.bind(server.ServerChecker).toSelf().inSingletonScope()
container.bind(server.NativePluginManager).toSelf().inSingletonScope()
process.emit('core.after.initialize.detect')
process.emit('core.before.package.initialize')
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", { scope: global.scope, type, time: (Date.now() - corePackageStartTime) / 1000 })
process.emit('core.after.package.initialize')
let disable = container.get<MiaoScriptCore>(MiaoScriptCore).enable()
console.i18n("ms.core.engine.completed", {
loader: base.version,
version: 'v' + global.ScriptEngineVersion,
time: (Date.now() - global.ScriptEngineStartTime) / 1000
})
process.emit('core.after.initialize')
return disable
} catch (error: any) { } catch (error: any) {
if (console.console) { if (console.console) {
console.i18n("ms.core.initialize.error", { error }) console.i18n("core.initialize.error", { error })
console.ex(error) console.ex(error)
} else { } else {
error.printStackTrace() error.printStackTrace()
} }
return () => console.i18n('ms.core.engine.disable.abnormal') process.emit('core.initialize.error')
return {
enable: () => console.i18n('ms.core.engine.disable.abnormal')
}
} finally {
process.emit('core.after.initialize')
} }
} }

View File

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

View File

@@ -1,6 +1,7 @@
import { database } from '@ccms/api' import { database } from '@ccms/api'
import { JSClass, postConstruct } from '@ccms/container' import { JSClass, postConstruct } from '@ccms/container'
const JavaString = Java.type('java.lang.String')
const Properties = Java.type('java.util.Properties') const Properties = Java.type('java.util.Properties')
/** /**
@@ -47,11 +48,11 @@ export class DataBase extends database.DataBase {
} else { } else {
this.dataSource = dbConfig.url this.dataSource = dbConfig.url
} }
this.jdbcTemplate = new this.JdbcTemplate(this.dataSource)
} }
@postConstruct() getDataSource() {
private initialize() { return this.dataSource
this.jdbcTemplate = new this.JdbcTemplate(this.dataSource)
} }
/** /**
@@ -62,7 +63,7 @@ export class DataBase extends database.DataBase {
query<T>(sql: string, ...args: any[]): Array<T> { query<T>(sql: string, ...args: any[]): Array<T> {
let startTime = Date.now() let startTime = Date.now()
let result = Java.from<any>(this.jdbcTemplate.queryForList(sql, args)) let result = Java.from<any>(this.jdbcTemplate.queryForList(sql, args))
console.debug(java.lang.String.format(`\n[DB] query \nSQL : ${sql.replace(/\?/ig, '%s')} \nCOST : ${Date.now() - startTime}ms`, args)) console.debug(JavaString.format(`\n[DB] query \nSQL : ${sql.replace(/\?/ig, '%s')} \nCOST : ${Date.now() - startTime}ms`, args))
return result return result
} }
@@ -74,7 +75,7 @@ export class DataBase extends database.DataBase {
update(sql: string, ...args: any[]): number { update(sql: string, ...args: any[]): number {
let startTime = Date.now() let startTime = Date.now()
let result = this.jdbcTemplate.update(sql, args) let result = this.jdbcTemplate.update(sql, args)
console.debug(java.lang.String.format(`\n[DB] update \nSQL : ${sql.replace(/\?/ig, '%s')} \nCOST : ${Date.now() - startTime}ms`, args)) console.debug(JavaString.format(`\n[DB] update \nSQL : ${sql.replace(/\?/ig, '%s')} \nCOST : ${Date.now() - startTime}ms`, args))
return result return result
} }
@@ -85,7 +86,7 @@ export class DataBase extends database.DataBase {
execute(sql: string): void { execute(sql: string): void {
let startTime = Date.now() let startTime = Date.now()
this.jdbcTemplate.execute(sql) this.jdbcTemplate.execute(sql)
console.debug(java.lang.String.format(`\n[DB] execute \nSQL : sql} \nCOST : ${Date.now() - startTime}ms`)) console.debug(`\n[DB] execute \nSQL : ${sql} \nCOST : ${Date.now() - startTime}ms`)
} }
close() { close() {

View File

@@ -1,5 +1,5 @@
import { database } from '@ccms/api' import { database } from '@ccms/api'
import { provideSingleton } from '@ccms/container' import { JSClass, provideSingleton } from '@ccms/container'
import { DataBase } from './database' import { DataBase } from './database'
@provideSingleton(database.DataBaseManager) @provideSingleton(database.DataBaseManager)
@@ -7,11 +7,32 @@ export class DataBaseManager extends database.DataBaseManager {
private mainDatabase: DataBase private mainDatabase: DataBase
private databases = new Map<string, DataBase>() private databases = new Map<string, DataBase>()
@JSClass('org.h2.tools.Server')
private Server: any
private webManager: any
constructor() { constructor() {
super() super()
process.on('exit', () => this.disable()) process.on('exit', () => this.shutdown())
} }
startWebManager(...args: string[]) {
this.webManager = this.Server.createWebServer(args)
this.webManager.start()
}
stopWebManager() {
if (this.webManager) {
this.webManager.stop()
this.webManager.shutdown()
}
}
shutdown() {
this.stopWebManager()
this.disable()
}
/** /**
* 设置主数据库 * 设置主数据库
* @param mainDatabase 主数据库 * @param mainDatabase 主数据库

View File

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

View File

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

View File

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

View File

@@ -1,7 +1,7 @@
{ {
"name": "@ccms/nashorn", "name": "@ccms/nashorn",
"version": "0.21.0", "version": "0.22.0",
"description": "MiaoScript api package", "description": "MiaoScript nashorn package",
"keywords": [ "keywords": [
"miaoscript", "miaoscript",
"minecraft", "minecraft",

View File

@@ -48,7 +48,10 @@ declare global {
scope: string scope: string
logger: any logger: any
debug: boolean debug: boolean
level: string /**
* 引擎日志等级
*/
ScriptEngineLoggerLevel: string
/** /**
* 引擎配置 * 引擎配置
*/ */

View File

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

View File

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

View File

@@ -1,7 +1,7 @@
{ {
"name": "@ccms/plugin", "name": "@ccms/plugin",
"version": "0.21.0", "version": "0.22.0",
"description": "MiaoScript api package", "description": "MiaoScript plugin package",
"keywords": [ "keywords": [
"miaoscript", "miaoscript",
"minecraft", "minecraft",
@@ -26,10 +26,10 @@
"typescript": "^4.6.3" "typescript": "^4.6.3"
}, },
"dependencies": { "dependencies": {
"@ccms/api": "^0.21.0", "@ccms/api": "^0.22.0",
"@ccms/common": "^0.21.0", "@ccms/common": "^0.22.0",
"@ccms/container": "^0.21.0", "@ccms/container": "^0.22.0",
"@ccms/i18n": "^0.21.0", "@ccms/i18n": "^0.22.0",
"@ccms/verify": "^0.21.1", "@ccms/verify": "^0.21.1",
"crypto-js": "^4.1.1", "crypto-js": "^4.1.1",
"js-yaml": "^4.1.0" "js-yaml": "^4.1.0"

View File

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

View File

@@ -14,3 +14,4 @@ global.setGlobal('Proxy', require('./proxy').Proxy)
global.setGlobal('XMLHttpRequest', require('./xml-http-request').XMLHttpRequest) global.setGlobal('XMLHttpRequest', require('./xml-http-request').XMLHttpRequest)
global.setGlobal('Blob', require('blob-polyfill').Blob) global.setGlobal('Blob', require('blob-polyfill').Blob)
console.i18n("ms.polyfill.completed", { time: (new Date().getTime() - polyfillStartTime) / 1000 }) console.i18n("ms.polyfill.completed", { time: (new Date().getTime() - polyfillStartTime) / 1000 })
export default true

View File

@@ -15,7 +15,7 @@ const DelayQueue = Java.type('java.util.concurrent.DelayQueue')
const JavaScriptTask = Java.type(base.getJavaScriptTaskClass().name) const JavaScriptTask = Java.type(base.getJavaScriptTaskClass().name)
const threadCount = new AtomicInteger(0) const threadCount = new AtomicInteger(0)
const threadGroup = new ThreadGroup("@ccms/ployfill-micro-task") const threadGroup = new ThreadGroup("@ccms/micro-task")
const microTaskPool = new ThreadPoolExecutor( const microTaskPool = new ThreadPoolExecutor(
100, 200, 60, TimeUnit.SECONDS, 100, 200, 60, TimeUnit.SECONDS,
new LinkedBlockingQueue(300), new LinkedBlockingQueue(300),
@@ -76,16 +76,16 @@ class Process extends EventEmitter {
class EventLoop { class EventLoop {
private eventLoopMainThread = undefined private eventLoopMainThread = undefined
private eventLoopTaskQueue = new DelayQueue() private eventLoopTaskQueue = new DelayQueue()
private taskExecTimeout = 3 private taskExecuteTimeout = 3000
private fixedThreadPool = undefined private fixedThreadPool = undefined
constructor() { constructor() {
this.taskExecTimeout = parseInt(process.env.MS_NODE_EVENT_LOOP_TIMEOUT) || 3 this.taskExecuteTimeout = parseInt(process.env.MS_TASK_EXECUTE_TIMEOUT) || 3000
this.fixedThreadPool = new ThreadPoolExecutor( this.fixedThreadPool = new ThreadPoolExecutor(
1, 1, 0, TimeUnit.SECONDS, 1, 1, 0, TimeUnit.SECONDS,
new LinkedBlockingQueue(300), new LinkedBlockingQueue(500),
new ThreadFactory((run: any) => { new ThreadFactory((run: any) => {
let thread = new Thread(run, "@ccms/node-shim/event-loop-exec") let thread = new Thread(run, "@ccms/event-loop")
thread.setDaemon(true) thread.setDaemon(true)
return thread return thread
})) }))
@@ -115,7 +115,7 @@ class EventLoop {
this.intervalTasks = undefined this.intervalTasks = undefined
this.eventLoopMainThread = undefined this.eventLoopMainThread = undefined
} }
}, "@ccms/node-shim/event-loop") }, "@ccms/event-loop")
this.eventLoopMainThread.setDaemon(true) this.eventLoopMainThread.setDaemon(true)
process.on('exit', () => { process.on('exit', () => {
this.eventLoopMainThread.interrupt() this.eventLoopMainThread.interrupt()
@@ -137,7 +137,9 @@ class EventLoop {
if (!callback) { if (!callback) {
throw new Error(`task ${name} callback function can't be null!`) throw new Error(`task ${name} callback function can't be null!`)
} }
if (this.fixedThreadPool.isShutdown()) { return console.warn(`FixedThreadPool isTerminated! ignore Task ${name}!`) } if (this.fixedThreadPool.isShutdown()) {
return console.warn(`FixedThreadPool isTerminated! ignore Task ${name}!`)
}
try { try {
this.fixedThreadPool.submit(new Callable({ this.fixedThreadPool.submit(new Callable({
call: () => { call: () => {
@@ -153,13 +155,13 @@ class EventLoop {
} }
} }
} }
})).get(this.taskExecTimeout, TimeUnit.SECONDS) })).get(this.taskExecuteTimeout, TimeUnit.MILLISECONDS)
} catch (error: any) { } catch (error: any) {
if (error instanceof InterruptedException) { if (error instanceof InterruptedException) {
return console.warn(`FixedThreadPool isInterrupted exit! Task ${name} exec exit!`) return console.warn(`FixedThreadPool isInterrupted exit! Task ${name} exec exit!`)
} }
if (error instanceof TimeoutException) { if (error instanceof TimeoutException) {
return console.warn(`Task ${name} => ${callback} exec time greater than ${this.taskExecTimeout}s!`) return console.warn(`Task ${name} => ${callback} exec time greater than ${this.taskExecuteTimeout}s!`)
} }
throw error.getCause && error.getCause() || error throw error.getCause && error.getCause() || error
} }

View File

@@ -1,6 +1,6 @@
{ {
"name": "@ccms/protocol", "name": "@ccms/protocol",
"version": "0.21.0", "version": "0.22.0",
"description": "MiaoScript protocol package", "description": "MiaoScript protocol package",
"keywords": [ "keywords": [
"miaoscript", "miaoscript",

View File

@@ -1,7 +1,7 @@
{ {
"name": "@ccms/sponge", "name": "@ccms/sponge",
"version": "0.21.0", "version": "0.22.0",
"description": "MiaoScript api package", "description": "MiaoScript sponge package",
"keywords": [ "keywords": [
"miaoscript", "miaoscript",
"minecraft", "minecraft",
@@ -25,8 +25,8 @@
"typescript": "^4.6.3" "typescript": "^4.6.3"
}, },
"dependencies": { "dependencies": {
"@ccms/api": "^0.21.0", "@ccms/api": "^0.22.0",
"@ccms/common": "^0.21.0", "@ccms/common": "^0.22.0",
"@ccms/container": "^0.21.0" "@ccms/container": "^0.22.0"
} }
} }

View File

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

View File

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

View File

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