misc/chomens-bot-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: some improvements to listener manager

Browse Source
This commit is contained in:
ChomeNS
2025-04-23 15:16:53 +07:00
parent 00e7bd59c0
commit 6a93b3ef63
1 changed files with 28 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
src/main/java/me/chayapak1/chomens_bot/plugins/ListenerManagerPlugin.java
View File

@@ -20,41 +20,45 @@ public class ListenerManagerPlugin {
}
public void dispatch (final Consumer<Listener> consumer) {
for (final Listener listener : listeners) {
try {
consumer.accept(listener);
} catch (final Exception e) {
bot.logger.error(
Component.translatable(
"Caught exception while trying to dispatch an event to %s!",
Component.text(listener.getClass().getSimpleName())
)
);
bot.logger.error(e);
synchronized (listeners) {
for (final Listener listener : listeners) {
try {
consumer.accept(listener);
} catch (final Exception e) {
bot.logger.error(
Component.translatable(
"Caught exception while trying to dispatch an event to %s!",
Component.text(listener.getClass().getSimpleName())
)
);
bot.logger.error(e);
}
}
}
}
public void dispatchWithCheck (final Function<Listener, Boolean> function) {
for (final Listener listener : listeners) {
try {
final Boolean result = function.apply(listener);
synchronized (listeners) {
for (final Listener listener : listeners) {
try {
final Boolean result = function.apply(listener);
if (result != null && !result) break;
} catch (final Exception e) {
bot.logger.error(
Component.translatable(
"Caught exception while trying to dispatch an event with a returning boolean to %s!",
Component.text(listener.getClass().getSimpleName())
)
);
bot.logger.error(e);
if (result != null && !result) break;
} catch (final Exception e) {
bot.logger.error(
Component.translatable(
"Caught exception while trying to dispatch an event with a returning boolean to %s!",
Component.text(listener.getClass().getSimpleName())
)
);
bot.logger.error(e);
}
}
}
}
public void addListener (final Listener listener) {
if (listeners.contains(listener)) throw new IllegalStateException(
if (listeners.contains(listener)) throw new IllegalArgumentException(
"This listener is already in the listeners list. " +
"Please call `removeListener(listener)` first."
);