Upstream/Minestom
1
0
Fork 0
mirror of https://github.com/Minestom/Minestom.git synced 2025-01-04 23:47:59 +01:00
Code Issues Projects Releases Wiki Activity

Add RecursiveEvent

Browse Source
This commit is contained in:
TheMode 2021-08-20 10:05:44 +02:00
parent e16a662908
commit a365676848
2 changed files with 30 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/main/java/net/minestom/server/event/EventNodeImpl.java
View File

@ -1,6 +1,7 @@
package net.minestom.server.event; package net.minestom.server.event;
import net.minestom.server.MinecraftServer; import net.minestom.server.MinecraftServer;
import net.minestom.server.event.trait.RecursiveEvent;
import net.minestom.server.utils.validate.Check; import net.minestom.server.utils.validate.Check;
import org.jetbrains.annotations.Contract; import org.jetbrains.annotations.Contract;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
@ -237,6 +238,9 @@ class EventNodeImpl<T extends Event> implements EventNode<T> {
} }
private void propagateEvent(Class<? extends T> eventClass) { private void propagateEvent(Class<? extends T> eventClass) {
// Recursive event
forEachRecursive(eventType, recursiveClass -> propagateEvent((Class<? extends T>) recursiveClass));
// Propagate
final var parent = this.parent; final var parent = this.parent;
if (parent == null) return; if (parent == null) return;
Handle<? super T> parentHandle = parent.handleMap.get(eventClass); Handle<? super T> parentHandle = parent.handleMap.get(eventClass);
@ -255,6 +259,21 @@ class EventNodeImpl<T extends Event> implements EventNode<T> {
return nameCheck && typeCheck; return nameCheck && typeCheck;
} }
private static boolean isRecursive(Class<?> type) {
if (type == null) return false;
return RecursiveEvent.class.isAssignableFrom(type);
}
private static void forEachRecursive(Class<?> type, Consumer<Class<? extends RecursiveEvent>> consumer) {
if (isRecursive(type)) {
final var superclass = type.getSuperclass();
if (isRecursive(superclass)) consumer.accept((Class<? extends RecursiveEvent>) superclass);
for (var inter : type.getInterfaces()) {
if (isRecursive(inter)) consumer.accept((Class<? extends RecursiveEvent>) inter);
}
}
}
private static class ListenerEntry<T extends Event> { private static class ListenerEntry<T extends Event> {
final List<EventListener<T>> listeners = new CopyOnWriteArrayList<>(); final List<EventListener<T>> listeners = new CopyOnWriteArrayList<>();
final Set<Consumer<T>> bindingConsumers = new CopyOnWriteArraySet<>(); final Set<Consumer<T>> bindingConsumers = new CopyOnWriteArraySet<>();
@ -283,6 +302,11 @@ class EventNodeImpl<T extends Event> implements EventNode<T> {
final var handleType = eventType; final var handleType = eventType;
ListenerEntry<E> entry = targetNode.listenerMap.get(handleType); ListenerEntry<E> entry = targetNode.listenerMap.get(handleType);
if (entry != null) appendEntry(listeners, entry, targetNode); if (entry != null) appendEntry(listeners, entry, targetNode);
// Recursive event
forEachRecursive(eventType, recursiveClass -> {
ListenerEntry<E> recursiveEntry = targetNode.listenerMap.get(recursiveClass);
if (recursiveEntry != null) appendEntry(listeners, recursiveEntry, targetNode);
});
// Add children // Add children
final var children = targetNode.children; final var children = targetNode.children;
if (children.isEmpty()) return; if (children.isEmpty()) return;

6
src/main/java/net/minestom/server/event/trait/RecursiveEvent.java Normal file
View File

@ -0,0 +1,6 @@
package net.minestom.server.event.trait;
import net.minestom.server.event.Event;
public interface RecursiveEvent extends Event {
}