GroupActivity.java

package com.osroyale.content.activity;
 
import com.osroyale.net.packet.out.SendMessage;
import com.osroyale.game.world.entity.mob.Mob;
 
import java.util.HashMap;
import java.util.Map;
import java.util.function.BiConsumer;

 
public abstract class GroupActivity extends Activity {

    protected final Map<Mob, Activity> activities;

    private static int nextInstance;

    protected GroupActivity(int cooldown, int capacity) {
        super(cooldown, getNextInstance());
        this.activities = new HashMap<>(capacity);
    }
 
    @Override
    protected void start() {
        activities.values().forEach(Activity::start);
    }
 
    @Override
    public void finish() {
        for (Map.Entry<Mob, Activity> entry : activities.entrySet()) {
            entry.getValue().finish();
            entry.getValue().cleanup();
        }
    }
 
    @Override
    public void cleanup() {
        activities.forEach((mob, activity) -> activity.cleanup());
    }
 
    protected void removeAll() {
        activities.forEach((mob, activity) -> remove(mob));
        activities.clear();
    }

    public final boolean isActive() {
        return !activities.isEmpty();
    }

    public int getActiveSize() {
        return activities.size();
    }

    public void forEachActivity(BiConsumer<Mob, Activity> activity) {
        activities.forEach(activity);
    }

    public final void addActivity(Mob mob, Activity activity) {
        if (!activities.containsKey(mob)) {
            activities.put(mob, activity);
            add(mob);
        }
    }

    public final void removeActivity(Mob mob) {
        if (activities.containsKey(mob)) {
            activities.get(mob).finish();
            activities.get(mob).cleanup();
            activities.remove(mob);
            remove(mob);
        }
    }

    public final void groupMessage(String message) {
        activities.keySet().forEach(mob -> {
            if (mob.isPlayer())
                mob.getPlayer().send(new SendMessage(message));
        });
    }
 
    public Activity getActivity(Mob mob) {
        return activities.get(mob);
    }

    private static int getNextInstance() {
        return nextInstance++;
    }
 
}