aion-server 4.8

package com.aionemu.gameserver.skillengine.effect;

import javax.xml.bind.annotation.XmlAccessType;
import javax.xml.bind.annotation.XmlAccessorType;
import javax.xml.bind.annotation.XmlAttribute;
import javax.xml.bind.annotation.XmlType;

import com.aionemu.gameserver.controllers.observer.ActionObserver;
import com.aionemu.gameserver.controllers.observer.ObserverType;
import com.aionemu.gameserver.model.gameobjects.Creature;
import com.aionemu.gameserver.model.gameobjects.Npc;
import com.aionemu.gameserver.skillengine.model.Effect;
import com.aionemu.gameserver.utils.ThreadPoolManager;
import com.aionemu.gameserver.utils.stats.StatFunctions;

import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.atomic.AtomicReference;

/**
 * @author ATracer,
 * Updated by Yeats 26.02.20
 */
@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "HostileUpEffect")
public class HostileUpEffect extends EffectTemplate {

	@XmlAttribute(name = "temp_duration")
	protected int tempDuration = 0;
	@XmlAttribute(name = "temp_value")
	protected int tempValue = 0;
	@XmlAttribute(name = "temp_delta")
	protected int tempDelta = 0;

	private int tempHate = 0;

	@Override
	public void applyEffect(Effect effect) {
		Creature effected = effect.getEffected();
		if (effected instanceof Npc) {
			int totalHate = effect.getTauntHate();
			// FIXME some skills never broadcast regular hate. that's why the following check exists as a workaround, which should be removed once fixed
			// hate broadcasts in Effect.startEffect (if added to EffectController) and applyEffect (if there are no successEffects), so some never do
			if (effect.getSuccessEffects().size() == 1) // only this effect template is present, therefore we know regular hate will never broadcast
				totalHate += effect.getEffectHate();
			effected.getAggroList().addHate(effect.getEffector(), totalHate + tempHate);
			if (tempHate > 0) {
				AtomicReference<ActionObserver> observerRef = new AtomicReference<>();
				ScheduledFuture<?> task = ThreadPoolManager.getInstance().schedule(new Runnable() {
					@Override
					public void run() {
						if (effected.getAggroList().isHating(effect.getEffector())) {
							effected.getAggroList().addHate(effect.getEffector(), -1 * tempHate);
						}
						if (observerRef.get() != null) {
							effect.getEffector().getObserveController().removeObserver(observerRef.get());
						}
					}
				}, tempDuration);

				observerRef.set(new ActionObserver(ObserverType.DEATH) {
					@Override
					public void died(Creature creature) {
						task.cancel(false);
						effect.getEffector().getObserveController().removeObserver(this);
					}
				});
				effect.getEffector().getObserveController().addObserver(observerRef.get());
			}
		}
	}

	@Override
	public void calculate(Effect effect) {
		if (!super.calculate(effect, null, null))
			return;
		effect.setTauntHate(calculateBaseValue(effect));
		tempHate = tempValue + tempDelta * effect.getSkillLevel();
		if (tempHate > 0)
			tempHate = StatFunctions.calculateHate(effect.getEffected(), tempHate);
	}
}