ExchangeSessionManager.java

package com.osroyale.game.world.entity.mob.player.exchange;
 
import com.osroyale.net.packet.out.SendMessage;
import com.osroyale.game.world.entity.mob.player.Player;
import com.osroyale.util.MessageColor;
 
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;

 
public final class ExchangeSessionManager {

    public final List<Player> requested_players = new ArrayList<>();

    public final Player player;

    public ExchangeSessionManager(Player player) {
        this.player = player;
    }

    public boolean request(ExchangeSession session) {
        return session.request();
    }

    public boolean deposit(int slot, int amount) {
        ExchangeSession session = ExchangeSession.getSession(player).orElse(null);
 
        if(session == null) {
            return false;
        }
 
        return session.add(player, slot, amount);
    }

    public boolean withdraw(int slot, int amount) {
        ExchangeSession session = ExchangeSession.getSession(player).orElse(null);
 
        if(session == null) {
            return false;
        }
 
        return session.remove(player, slot, amount);
    }
 

    public void reset(ExchangeSessionType type) {
        Optional<ExchangeSession> session = ExchangeSession.getSession(player, type);
 
        if(!session.isPresent()) {
            return;
        }
 
        session.get().forEach(p -> {
            session.get().finalize(ExchangeCompletionType.RESTORE);
            resetRequests();
            p.interfaceManager.close();
        });
 
        Player other = session.get().getOther(player);
        other.send(new SendMessage("The other player has declined.", MessageColor.RED));
        ExchangeSession.SESSIONS.remove(session.get());
    }

    public boolean reset() {
        Optional<ExchangeSession> session = ExchangeSession.getSession(player);
 
        if(!session.isPresent()) {
            return false;
        }
 
        reset(session.get().type);
        return true;
    }

    public void resetRequests() {
        player.exchangeSession.requested_players.clear();
    }
}