/* * Copyright 2010 BetaSteward_at_googlemail.com. All rights reserved. * * Redistribution and use in source and binary forms, with or without modification, are * permitted provided that the following conditions are met: * * 1. Redistributions of source code must retain the above copyright notice, this list of * conditions and the following disclaimer. * * 2. Redistributions in binary form must reproduce the above copyright notice, this list * of conditions and the following disclaimer in the documentation and/or other materials * provided with the distribution. * * THIS SOFTWARE IS PROVIDED BY BetaSteward_at_googlemail.com ``AS IS'' AND ANY EXPRESS OR IMPLIED * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND * FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL BetaSteward_at_googlemail.com OR * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON * ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. * * The views and conclusions contained in the software and documentation are those of the * authors and should not be interpreted as representing official policies, either expressed * or implied, of BetaSteward_at_googlemail.com. */ package mage.game.draft; import java.util.Collection; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; import mage.cards.Card; import mage.cards.ExpansionSet; import mage.game.draft.DraftOptions.TimingOption; import mage.game.events.Listener; import mage.game.events.PlayerQueryEvent; import mage.game.events.PlayerQueryEventSource; import mage.game.events.TableEvent; import mage.game.events.TableEvent.EventType; import mage.game.events.TableEventSource; import mage.players.Player; import mage.players.PlayerList; /** * * @author BetaSteward_at_googlemail.com */ public abstract class DraftImpl implements Draft { protected final UUID id; protected final Map players = new HashMap<>(); protected final PlayerList table = new PlayerList(); protected int numberBoosters; protected DraftCube draftCube; protected List sets; protected List setCodes; protected int boosterNum = 0; protected int cardNum = 0; protected TimingOption timing; protected int[] times = {75, 70, 65, 60, 55, 50, 45, 40, 35, 30, 25, 20, 15, 10, 5}; protected boolean abort = false; protected transient TableEventSource tableEventSource = new TableEventSource(); protected transient PlayerQueryEventSource playerQueryEventSource = new PlayerQueryEventSource(); public DraftImpl(DraftOptions options, List sets) { id = UUID.randomUUID(); this.setCodes = options.getSetCodes(); this.draftCube = options.getDraftCube(); this.timing = options.getTiming(); this.sets = sets; this.numberBoosters = options.getNumberBoosters(); } @Override public UUID getId() { return id; } @Override public void addPlayer(Player player) { DraftPlayer draftPlayer = new DraftPlayer(player); players.put(player.getId(), draftPlayer); table.add(player.getId()); } @Override public boolean replacePlayer(Player oldPlayer, Player newPlayer) { if (newPlayer != null) { DraftPlayer newDraftPlayer = new DraftPlayer(newPlayer); DraftPlayer oldDraftPlayer = players.get(oldPlayer.getId()); newDraftPlayer.setBooster(oldDraftPlayer.getBooster()); Map newPlayers = new HashMap<>(); PlayerList newTable = new PlayerList(); synchronized (players) { for(Map.Entry entry :players.entrySet()) { if (entry.getKey().equals(oldPlayer.getId())) { newPlayers.put(newPlayer.getId(), newDraftPlayer); } else { newPlayers.put(entry.getKey(), entry.getValue()); } } players.clear(); for (Map.Entry entry: newPlayers.entrySet()) { players.put(entry.getKey(), entry.getValue()); } } synchronized (table) { for(UUID playerId :table) { if (playerId.equals(oldPlayer.getId())) { newTable.add(newPlayer.getId()); } else { newTable.add(playerId); } } table.clear(); table.addAll(newTable); } if (oldDraftPlayer.isPicking()) { newDraftPlayer.setPicking(); newDraftPlayer.getPlayer().pickCard(newDraftPlayer.getBooster(), newDraftPlayer.getDeck(), this); } return true; } return false; } @Override public Collection getPlayers() { synchronized (players) { return players.values(); } } @Override public DraftPlayer getPlayer(UUID playerId) { return players.get(playerId); } @Override public DraftCube getDraftCube() { return draftCube; } /** * Number of boosters that each player gets in this draft * * @return */ @Override public int getNumberBoosters() { return numberBoosters; } @Override public List getSets() { return sets; } @Override public int getBoosterNum() { return boosterNum; } @Override public int getCardNum() { return cardNum; } @Override public void leave(UUID playerId) { //TODO: implement this } @Override public void autoPick(UUID playerId) { this.addPick(playerId, players.get(playerId).getBooster().get(0).getId()); } protected void passLeft() { synchronized (players) { UUID startId = table.get(0); UUID currentId = startId; UUID nextId = table.getNext(); DraftPlayer current = players.get(currentId); DraftPlayer next = players.get(nextId); List currentBooster = current.booster; while (true) { List nextBooster = next.booster; next.setBooster(currentBooster); if (nextId == startId) { break; } currentBooster = nextBooster; nextId = table.getNext(); next = players.get(nextId); } } } protected void passRight() { synchronized (players) { UUID startId = table.get(0); UUID currentId = startId; UUID prevId = table.getPrevious(); DraftPlayer current = players.get(currentId); DraftPlayer prev = players.get(prevId); List currentBooster = current.booster; while (true) { List prevBooster = prev.booster; prev.setBooster(currentBooster); if (prevId == startId) { break; } currentBooster = prevBooster; prevId = table.getPrevious(); prev = players.get(prevId); } } } protected void openBooster() { if (boosterNum < numberBoosters) { for (DraftPlayer player: players.values()) { if (draftCube != null) { player.setBooster(draftCube.createBooster()); } else { player.setBooster(sets.get(boosterNum).createBooster()); } } } boosterNum++; cardNum = 1; fireUpdatePlayersEvent(); } protected boolean pickCards() { cardNum++; for (DraftPlayer player: players.values()) { if (player.getBooster().isEmpty()) { return false; } player.setPicking(); player.getPlayer().pickCard(player.getBooster(), player.getDeck(), this); } synchronized(this) { while (!donePicking()) { try { this.wait(); } catch (InterruptedException ex) { } } } return true; } protected boolean donePicking() { if(isAbort()) { return true; } for (DraftPlayer player: players.values()) { if (player.isPicking()) { return false; } } return true; } @Override public boolean allJoined() { for (DraftPlayer player: this.players.values()) { if (!player.isJoined()) { return false; } } return true; } @Override public void addTableEventListener(Listener listener) { tableEventSource.addListener(listener); } @Override public void fireUpdatePlayersEvent() { tableEventSource.fireTableEvent(EventType.UPDATE, null, this); } @Override public void fireEndDraftEvent() { tableEventSource.fireTableEvent(EventType.END, null, this); } @Override public void addPlayerQueryEventListener(Listener listener) { playerQueryEventSource.addListener(listener); } @Override public void firePickCardEvent(UUID playerId) { DraftPlayer player = players.get(playerId); if (cardNum > 15) { cardNum = 15; } int time = times[cardNum - 1] * timing.getFactor(); playerQueryEventSource.pickCard(playerId, "Pick card", player.getBooster(), time); } @Override public boolean addPick(UUID playerId, UUID cardId) { DraftPlayer player = players.get(playerId); if (player.isPicking()) { for (Card card: player.booster) { if (card.getId().equals(cardId)) { player.addPick(card); player.booster.remove(card); break; } } synchronized(this) { this.notifyAll(); } } return !player.isPicking(); } @Override public boolean isAbort() { return abort; } @Override public void setAbort(boolean abort) { this.abort = abort; } }