AbstractTownyChannel.java

package at.helpch.chatchat.hooks.towny;

import at.helpch.chatchat.ChatChatPlugin;
import at.helpch.chatchat.api.holder.FormatsHolder;
import at.helpch.chatchat.api.user.ChatUser;
import at.helpch.chatchat.api.user.User;
import at.helpch.chatchat.channel.AbstractChannel;
import at.helpch.chatchat.util.ChannelUtils;
import com.palmergames.bukkit.towny.TownyUniverse;
import com.palmergames.bukkit.towny.object.Resident;
import com.palmergames.bukkit.towny.object.ResidentList;
import org.bukkit.Bukkit;
import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable;

import java.util.List;
import java.util.Optional;
import java.util.Set;
import java.util.UUID;
import java.util.function.Predicate;
import java.util.stream.Collectors;

public abstract class AbstractTownyChannel extends AbstractChannel {
    protected AbstractTownyChannel(@NotNull final String name,
                                   @NotNull final String messagePrefix,
                                   @NotNull final List<String> toggleCommands,
                                   @NotNull final String channelPrefix,
                                   @NotNull final FormatsHolder formats,
                                   final int radius,
                                   final boolean crossServer) {
        super(name, messagePrefix, toggleCommands, channelPrefix, formats, radius, crossServer);
        if (Bukkit.getPluginManager().getPlugin("Towny") == null) {
            throw new RuntimeException("Attempting to use a Towny channel but Towny is not installed.");
        }}

    private Optional<ResidentList> residentList(@NotNull final UUID uuid) {
        return TownyUniverse.getInstance().getResidentOpt(uuid).map(this::residentList);
    }

    @Override
    public boolean isUsableBy(@NotNull final ChatUser user) {
        return super.isUsableBy(user) && residentList(user.uuid()).isPresent();
    }

    protected abstract @Nullable ResidentList residentList(@NotNull final Resident resident);

    private final ChatChatPlugin plugin = ChatChatPlugin.getPlugin(ChatChatPlugin.class);

    @Override
    public Set<User> targets(final @NotNull User source) {
        return residentList(source.uuid()).map(residentList -> residentList.getResidents().stream()
            .filter(Predicate.not(Resident::isNPC))
            .filter(Resident::isOnline)
            .map(Resident::getUUID)
            .map(plugin.usersHolder()::getUser)
            .filter(User::chatEnabled) // Make sure the user has their chat enabled
            .filter(target -> ChannelUtils.isTargetWithinRadius(source, target, radius()))
            .collect(Collectors.toSet())).orElseGet(Set::of);

    }
}