refactor: 重新调整项目框架

Signed-off-by: 502647092 <admin@yumc.pw>
2017-10-30 20:47:10 +08:00
parent e2566c4bf1
commit e454066cce
37 changed files with 320 additions and 319 deletions
--- a/src/main/resources/internal/bukkit/event.js
+++ b/src/main/resources/internal/bukkit/event.js
@ -0,0 +1,156 @@
+'use strict';
+/**
+ * Bukkit 事件相关类
+ */
+/*global Java, base, module, exports, require, __FILE__*/
+var Thread = Java.type("java.lang.Thread");
+var Bukkit = Java.type("org.bukkit.Bukkit");
+var Listener = Java.type("org.bukkit.event.Listener");
+var Modifier = Java.type("java.lang.reflect.Modifier");
+var BukkitEvent = Java.type("org.bukkit.event.Event");
+var EventPriority = Java.type("org.bukkit.event.EventPriority");
+var EventExecutor = Java.type("org.bukkit.plugin.EventExecutor");
+
+var plugin = require('./server').plugin.self;
+
+var ref = require('reflect');
+
+var listenerMap = [];
+
+/**
+ * 扫描包 org.bukkit.event 下的所有事件
+ * 映射简写名称 org.bukkit.event.player.PlayerLoginEvent => playerloginevent
+ */
+function mapEventName() {
+    var eventPackageDir = "org/bukkit/event";
+    var count = 0;
+    var dirs = Thread.currentThread().getContextClassLoader().getResources(eventPackageDir);
+    while (dirs.hasMoreElements()) {
+        var url = dirs.nextElement();
+        var protocol = url.protocol;
+        if (protocol === "jar") {
+            // noinspection JSUnresolvedVariable
+            var jar = url.openConnection().jarFile;
+            var entries = jar.entries();
+            while (entries.hasMoreElements()) {
+                var entry = entries.nextElement();
+                var name = entry.name;
+                // 以 org/bukkit/event 开头 并且以 .class 结尾
+                if (name.startsWith(eventPackageDir) && name.endsWith(".class")) {
+                    var i = name.replaceAll('/', '.');
+                    try {
+                        var clz = base.getClass(i.substring(0, i.length - 6));
+                        // 继承于 org.bukkit.event.Event 访问符为Public
+                        if (isVaildEvent(clz)) {
+                            // noinspection JSUnresolvedVariable
+                            var simpleName = clz.simpleName.toLowerCase();
+                            console.debug("Mapping Event [%s] => %s".format(clz.name, simpleName));
+                            mapEvent[simpleName] = clz;
+                            count++;
+                        }
+                    } catch (ex) {
+                        //ignore already loaded class
+                    }
+                }
+            }
+        }
+    }
+    return count;
+}
+
+/**
+ * 判断是否为一个有效的事件类
+ * @param clz
+ * @returns {*|boolean}
+ */
+function isVaildEvent(clz) {
+    // noinspection JSUnresolvedVariable 继承于 org.bukkit.event.Event
+    return BukkitEvent.class.isAssignableFrom(clz) &&
+        // 访问符为Public
+        Modifier.isPublic(clz.getModifiers()) &&
+        // 不是抽象类
+        !Modifier.isAbstract(clz.getModifiers());
+}
+
+/**
+ * 添加事件监听
+ * @param jsp
+ * @param event
+ * @param exec {function}
+ * @param priority
+ * @param ignoreCancel
+ */
+function listen(jsp, event, exec, priority, ignoreCancel) {
+    var name = jsp.description.name;
+    if (ext.isNull(name)) throw new TypeError('插件名称为空 请检查传入参数!');
+    var eventCls = mapEvent[event] || mapEvent[event.toLowerCase()] || mapEvent[event + 'Event'] || mapEvent[event.toLowerCase() + 'event'];
+    if (!eventCls) {
+        try {
+            eventCls = base.getClass(eventCls);
+        } catch (ex) {
+            console.warn("事件 %s 未找到!".format(event));
+            return;
+        }
+    }
+    if (typeof priority === 'boolean') {
+        ignoreCancel = priority
+    }
+    priority = priority || 'NORMAL';
+    ignoreCancel = ignoreCancel || false;
+    var listener = new Listener({});
+    // noinspection JSUnusedGlobalSymbols
+    /**
+     * @param event Event type to register
+     * @param listener Listener to register
+     * @param priority Priority to register this event at
+     * @param executor EventExecutor to register
+     * @param plugin Plugin to register
+     * @param ignoreCancel
+     */
+    Bukkit.getPluginManager().registerEvent(
+        eventCls,
+        listener,
+        EventPriority[priority],
+        new EventExecutor({
+            execute: function (listener, event) {
+                try {
+                    exec(event);
+                } catch (ex) {
+                    console.console('§6插件 §b%s §6处理 §d%s §6事件时发生异常 §4%s'.format(name, event.class.simpleName, ex));
+                    console.ex(ex);
+                }
+            }
+        }),
+        plugin,
+        ignoreCancel);
+    // 添加到缓存 用于关闭插件的时候关闭事件
+    if (!listenerMap[name]) listenerMap[name] = [];
+    var listeners = listenerMap[name];
+    var off = {
+        event: eventCls,
+        listener: listener,
+        off: function () {
+            ref.on(this.event).call('getHandlerList').get().unregister(this.listener);
+            console.debug('插件 %s 注销事件 %s'.format(name, this.event.simpleName));
+        }
+    };
+    listeners.push(off);
+    // noinspection JSUnresolvedVariable
+    console.debug('插件 %s 注册事件 %s => %s'.format(name, eventCls.simpleName, exec.name === '' ? '匿名方法' : exec.name));
+    return off;
+}
+
+var mapEvent = [];
+// 映射事件名称
+console.info('Bukkit 事件映射完毕 共计 %s 个事件!'.format(mapEventName().toFixed(0)));
+
+module.exports = {
+    on: listen,
+    disable: function (jsp) {
+        var jspl = listenerMap[jsp.description.name];
+        if (jspl) {
+            jspl.forEach(function (t) t.off());
+            delete listenerMap[jsp.description.name];
+        }
+    }
+};