circlecloud/ms
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

feat: add example plugins

Browse Source 
Signed-off-by: MiaoWoo <admin@yumc.pw>
This commit is contained in:
MiaoWoo
2019-09-22 23:31:52 +08:00
parent 7d33368ebd
commit 0931d69188
5 changed files with 627 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
packages/plugins/package.json
View File

@ -1,4 +1,5 @@
{
"private": true,
"name": "@ms/plugins",
"version": "0.0.0",
"description": "MiaoScript plugins package",

163
packages/plugins/src/MiaoScriptPackageManager.ts Normal file
View File

@ -0,0 +1,163 @@
import { plugin as pluginApi, task } from '@ms/api'
import { inject } from '@ms/container';
import { plugin, cmd, tab } from '@ms/plugin'
let help = [
'§6========= §6[§aMiaoScriptPackageManager§6] 帮助 §aBy §b喵♂呜 §6=========',
'§6/mpm §ainstall §e<插件名称> §6- §3安装插件',
'§6/mpm §alist [install]§6- §3列出仓库插件[已安装的插件]',
'§6/mpm §aupdate §e<插件名称> §6- §3更新插件(无插件名称则更新源)',
'§6/mpm §aupgrade §e<插件名称> §6- §3及时更新插件(update需要重启生效)',
'§6/mpm §areload §e<插件名称> §6- §3重载插件(无插件名称则重载自身)',
'§6/mpm §arun §e<JS代码> §6- §3运行JS代码',
'§6/mpm §acreate §e<插件名称> [作者] [版本] [主命令] §6- §3通过模板创建名称',
'§6/mpm §crestart §6- §4重启MiaoScript脚本引擎'
];
@plugin({ name: 'MiaoScriptPackageManager', prefix: 'PM', version: '1.0.0', author: 'MiaoWoo', source: __filename })
export class MiaoScriptPackageManager {
@inject(pluginApi.PluginManager)
private pluginManager: pluginApi.PluginManager;
@inject(task.TaskManager)
private taskManager: task.TaskManager;
private pluginCache = [];
private packageCache = [];
private packageNameCache = [];
load() {
this.taskManager.create(() => {
this.pluginCache = [...this.pluginManager.getPlugins().keys()];
// JSON.parse(http.get(self.config.center)).data.forEach(function cachePackageName(pkg) {
// packageCache[pkg.name] = pkg;
// })
// packageNameCache = Object.keys(packageCache);
}).async().submit();
}
enable() {
}
@cmd()
mpm(sender: any, command: string, args: string[]) {
this.taskManager.create(() => this.main(sender, command, args)).async().submit();
}
main(sender: any, command: string, args: string[]) {
if (!args[0] || args[1] === 'help') {
console.sender(sender, help);
return;
}
switch (args[0]) {
case "list":
if (args[1]) {
console.sender(sender, '§6当前 §bMiaoScript §6已安装下列插件:');
this.pluginCache.forEach(function listInfo(pluginName) {
// var desc = manager.plugins[pluginName].description;
// console.sender(sender, `§6插件名称: §b${desc.name} §6版本: §a${desc.version|| '1.0'} §6作者: §3${desc.author || '未知'}`)
})
} else {
console.sender(sender, '§6当前 §bMiaoScriptPackageCenter §6中存在下列插件:');
for (var pkgName in this.packageCache) {
var pkg = this.packageCache[pkgName];
// console.sender(sender, '§6插件名称: §b%s §6版本: §a%s §6作者: §3%s'.format(pkg.name, pkg.version || '1.0', pkg.author || '未知'))
}
}
break;
case "install":
// if (args.length > 1) {
// download(sender, args[1]);
// } else {
// console.sender(sender, '§c请输入插件名称!')
// }
break;
case "update":
// if (args.length > 1) {
// update(sender, args[1]);
// } else {
// load();
// console.sender(sender, "§a仓库缓存刷新成功 共存在 §b" + Object.keys(packageCache).length + " §a个插件!")
// }
break;
case "upgrade":
break;
case "delete":
// if (args.length > 1) {
// del(sender, args[1]);
// } else {
// console.sender(sender, '§c请输入插件名称!')
// }
break;
case "reload":
// if (args.length > 1) {
// var pname = args[1];
// if (pluginCache.indexOf(pname) !== -1) {
// manager.reload(pname)
// console.sender(sender, '§6插件 §b%s §a重载完成!'.format(pname))
// } else {
// console.sender(sender, '§c插件 §b%s §c不存在!'.format(pname))
// }
// } else {
// self.reloadConfig();
// load();
// }
break;
case "restart":
try {
console.sender(sender, '§6Reloading §3MiaoScript Engine...');
ScriptEngineContextHolder.disableEngine();
ScriptEngineContextHolder.enableEngine();
console.sender(sender, '§3MiaoScript Engine §6Reload §aSuccessful...');
} catch (ex) {
console.sender(sender, "§3MiaoScript Engine §6Reload §cError! ERR: " + ex);
console.sender(sender, console.stack(ex));
}
break;
case "run":
args.shift();
try {
var script = args.join(' ')
console.sender(sender, '§b运行脚本:§r', script)
console.sender(sender, '§a返回结果:§r', eval(script) || '§4没有返回结果!');
} catch (ex) {
console.sender(sender, console.stack(ex))
}
break;
case "create":
// var name = args[1];
// if (!name) {
// console.sender(sender, '§4参数错误 /mpm create <插件名称> [作者] [版本] [主命令]');
// return;
// }
// var result = template.create(http.get(self.config.template)).render({
// name: name,
// author: args[2] || 'MiaoWoo',
// version: args[3] || '1.0',
// command: args[4] || name.toLowerCase(),
// });
// fs.save(fs.file(__dirname, name + '.js'), result);
// console.sender(sender, '§6插件 §a' + name + ' §6已生成到插件目录...');
break;
default:
console.sender(sender, help);
break;
}
}
@tab()
tabmpm(sender, command, args) {
if (args.length === 1) return ['list', 'install', 'update', 'upgrade', 'reload', 'restart', 'run', 'help', 'create'];
if (args.length > 1) {
switch (args[0]) {
case "install":
return this.packageNameCache;
case "update":
case "upgrade":
case "reload":
return this.pluginCache;
}
}
}
}

149
packages/plugins/src/Test.ts
View File

@ -1,14 +1,153 @@
import { plugin, interfaces } from '@ms/plugin'
import { plugin as pluginApi } from '@ms/api'
import { plugin, interfaces, cmd, listener, tab } from '@ms/plugin'
import { inject, DefaultContainer as container } from '@ms/container';
import * as ref from '@ms/common/dist/reflect'
@plugin({ name: 'Test', version: '1.0.0', author: 'MiaoWoo' })
@plugin({ name: 'Test', version: '1.0.0', author: 'MiaoWoo', source: __filename })
export class Test extends interfaces.Plugin {
@inject(pluginApi.PluginManager)
private PluginManager: pluginApi.PluginManager;
private channel: any;
private childHandler: any;
load() {
this.logger.log('');
this.logger.log('Test Plugin load from MiaoScript Plugin System...');
}
enable() {
throw new Error("Method not implemented.");
this.logger.log('Test Plugin enable from MiaoScript Plugin System...');
}
bukkitenable() {
let Bukkit = Java.type('org.bukkit.Bukkit');
let promise = ref.on(Bukkit.getServer()).get('console').get('serverConnection').get('f').get().get(0);
this.channel = ref.on(promise).get('channel').get().pipeline().first();
this.childHandler = ref.on(this.channel).get('childHandler').get();
let ChannelHandler = Java.extend(Java.type('io.netty.channel.ChannelInitializer'), {
initChannel: function(channel: any) {
container.get<any>('handle')(channel);
}
})
//=======================
let ChannelInboundHandlerAdapter = Java.type('io.netty.channel.ChannelInboundHandlerAdapter');
let CharsetUtil = Java.type('io.netty.util.CharsetUtil')
let MiaoDetectHandler = Java.extend(ChannelInboundHandlerAdapter, {
channelRead: function(ctx: any, msg: any) {
msg.markReaderIndex();
console.log(msg.readChar());
msg.resetReaderIndex();
let message: string = msg.toString(CharsetUtil.UTF_8);
console.log(message);
let channel = ctx.channel();
let pipeline = channel.pipeline();
if (message.indexOf('HTTP/1.1') > 0) {
'timeout legacy_query splitter decoder prepender encoder packet_handler'.split(' ').forEach(f => channel.pipeline().remove(f))
let HttpServerCodec = Java.type('io.netty.handler.codec.http.HttpServerCodec');
let ChunkedWriteHandler = Java.type('io.netty.handler.stream.ChunkedWriteHandler');
let HttpObjectAggregator = Java.type('io.netty.handler.codec.http.HttpObjectAggregator');
let WebSocketServerProtocolHandler = Java.type('io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler');
let SimpleChannelInboundHandler = Java.type('io.netty.channel.SimpleChannelInboundHandler');
let TextWebSocketFrame = Java.type('io.netty.handler.codec.http.websocketx.TextWebSocketFrame');
let textWsHandler;
let TextWebSocketFrameHandler = Java.extend(SimpleChannelInboundHandler, {
userEventTriggered: (ctx: any, msg: any) => {
ctx.writeAndFlush(new TextWebSocketFrame(`Client ${ctx.channel} connect successful...`))
//@ts-ignore
Java.super(textWsHandler).userEventTriggered(ctx, msg);
},
channelRead0: (ctx: any, msg: any) => {
console.log(msg);
console.log(typeof msg);
console.log(msg.class);
ctx.writeAndFlush(msg.retain())
}
})
textWsHandler = new TextWebSocketFrameHandler()
pipeline.addLast('http', new HttpServerCodec());
pipeline.addLast('chunk', new ChunkedWriteHandler());
pipeline.addLast('httpobj', new HttpObjectAggregator(64 * 1024));
pipeline.addLast('websocket', new WebSocketServerProtocolHandler("/ws"));
pipeline.addLast('websocket_handler', textWsHandler);
}
pipeline.remove('miaowebsocket');
console.log(`Connect Complate. channel: ${channel}, pipeline: ${Java.from(channel.pipeline().names()).join(' ')}`)
msg.resetReaderIndex();
ctx.fireChannelRead(msg);
}
})
ref.on(this.channel).set('childHandler', new ChannelHandler());
container.bind('handle').toFunction(channel => {
ref.on(this.childHandler).call('initChannel', channel);
console.log(`channel: ${channel}, pipeline: ${Java.from(channel.pipeline().names()).join(' ')}`)
let pipeline = channel.pipeline();
pipeline.addFirst('miaowebsocket', new MiaoDetectHandler());
console.log(`channel: ${channel}, pipeline: ${Java.from(channel.pipeline().names()).join(' ')}`)
});
}
disable() {
throw new Error("Method not implemented.");
this.logger.log('Test Plugin disable from MiaoScript Plugin System...');
}
bukkitdisable() {
ref.on(this.channel).set('childHandler', this.childHandler);
container.unbind('handle')
}
@cmd()
test(sender: any, command: string, args: string[]) {
switch (args[0]) {
case "run":
var script = args.slice(1).join(' ');
console.sender(sender, '§b运行脚本:§r', script);
console.sender(sender, '§a返回结果:§r', eval(script) || '§4没有返回结果!');
break;
case "reload":
this.PluginManager.reload(this);
break;
case "channel":
console.sender(sender, Java.from(sender.handle.playerConnection.networkManager.channel.pipeline().names()).join(' '))
break;
case "add":
break;
case "yaml":
let yaml = require("js-yaml");
this.logger.log(yaml.safeDump({ key: 'value', map: { k1: 1, k2: '2' } }));
break;
case "speed":
this.logger.sender(sender, sender.location);
break;
case "top":
let loc = sender.location;
let topY = loc.world.getHighestBlockYAt(loc);
loc.y = topY;
sender.teleport(loc);
break;
case "up":
if (!sender.openInventory) { return; }
var player = sender;
var location = player.location;
player.velocity = player.velocity.setY(0.5);
setTimeout(() => location.block.type = Java.type('org.bukkit.Material').STONE, 8);
break;
default:
this.logger.log(sender, command, args);
sender.sendMessage(JSON.stringify({ command, ...args }))
}
}
@tab()
tabtest(_sender: any, _command: string, _args: string[]) {
return ['run', 'reload', 'channel', 'add', 'yaml', 'speed', 'top', 'up']
}
@listener({ servertype: 'bukkit' })
playerjoin(event: any) {
this.logger.console('PlayerJoinEvent: ', event.player.name)
}
}