feat: add channel support for bungee bukkit sponge

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

packages/api/src/channel.ts

@@ -0,0 +1,58 @@
+import { injectable } from "@ms/container";
+
+export namespace channel {
+    /**
+    * handle plugin message
+    * @param data byte[]
+    */
+    export type ChannelListener = (data: any) => void
+
+    @injectable()
+    export abstract class Channel {
+        private listenerMap = [];
+
+        listen(plugin: any, channel: string, exec: ChannelListener) {
+            if (!plugin || !plugin.description || !plugin.description.name) throw new TypeError('Plugin can\'t be undefiend!');
+            let name = plugin.description.name;
+            let listener = this.register(channel, exec)
+            if (!this.listenerMap[name]) this.listenerMap[name] = [];
+            let offExec = () => {
+                this.unregister(channel, listener);
+                console.debug(`[${name}] unregister channel ${channel}`);
+            };
+            var off = {
+                channel,
+                listener,
+                off: offExec
+            };
+            this.listenerMap[name].push(off);
+            console.debug(`[${name}] register channel ${channel} => ${exec.name || '[anonymous]'}`);
+            return off;
+        }
+        disable(plugin: any) {
+            var channelCache = this.listenerMap[plugin.description.name];
+            if (channelCache) {
+                channelCache.forEach(t => t.off());
+                delete this.listenerMap[plugin.description.name];
+            }
+        }
+
+        /**
+         * Send Channel Message
+         * @param player recover target
+         * @param channel ChannelName
+         * @param data byte[]
+         */
+        abstract send(player: any, channel: string, data: any)
+        /**
+         * register channel
+         * @param channel ChannelName
+         */
+        abstract register(channel: string, listener: ChannelListener): any
+        /**
+         * unregister channel
+         * @param channel ChannelName
+         */
+        abstract unregister(channel: string, listener?: any): void
+    }
+}

packages/api/src/event.ts

@@ -115,7 +115,7 @@ export namespace event {
         * @param priority {string} [LOWEST,LOW,NORMAL,HIGH,HIGHEST,MONITOR]
         * @param ignoreCancel
         */
-        listen(plugin: any, event: string, exec: () => void, priority: EventPriority = EventPriority.NORMAL, ignoreCancel = false) {
+        listen(plugin: any, event: string, exec: (event: any) => void, priority: EventPriority = EventPriority.NORMAL, ignoreCancel = false) {
             if (!plugin || !plugin.description || !plugin.description.name) throw new TypeError('插件名称为空 请检查传入参数!');
             var name = plugin.description.name;
             var eventCls = this.name2Class(name, event);

packages/api/src/index.ts

@@ -2,5 +2,6 @@
 export * from './task'
 export * from './event'
 export * from './console'
+export * from './channel'
 export * from './command'
 export * from './interfaces'