more draft stuff

Mage.Server/src/main/java/mage/server/ServerImpl.java

@@ -47,6 +47,7 @@ import mage.interfaces.Server;
 import mage.interfaces.ServerState;
 import mage.interfaces.callback.ClientCallback;
 import mage.server.game.DeckValidatorFactory;
+import mage.server.game.DraftManager;
 import mage.server.game.GameFactory;
 import mage.server.game.GameManager;
 import mage.server.game.GamesRoomManager;
@@ -159,6 +160,21 @@ public class ServerImpl extends RemoteServer implements Server {
 		return false;
 	}
 
+	@Override
+	public boolean joinDraftTable(UUID sessionId, UUID roomId, UUID tableId, String name) throws MageException, GameException {
+		try {
+			boolean ret = GamesRoomManager.getInstance().getRoom(roomId).joinDraftTable(sessionId, tableId, name);
+			logger.info("Session " + sessionId + " joined table " + tableId);
+			return ret;
+		}
+		catch (Exception ex) {
+			if (ex instanceof GameException)
+				throw (GameException)ex;
+			handleException(ex);
+		}
+		return false;
+	}
+
 	@Override
 	public boolean submitDeck(UUID sessionId, UUID tableId, DeckCardLists deckList) throws MageException, GameException {
 		try {
@@ -232,13 +248,13 @@ public class ServerImpl extends RemoteServer implements Server {
 	}
 
 	@Override
-	public void startDraft(final UUID sessionId, final UUID roomId, final UUID draftId) throws MageException {
+	public void startDraft(final UUID sessionId, final UUID roomId, final UUID tableId) throws MageException {
 		try {
 			rmiExecutor.execute(
 				new Runnable() {
 					@Override
 					public void run() {
-//						TableManager.getInstance().startMatch(sessionId, roomId, tableId);
+						TableManager.getInstance().startDraft(sessionId, roomId, tableId);
 					}
 				}
 			);
@@ -394,6 +410,23 @@ public class ServerImpl extends RemoteServer implements Server {
 		}
 	}
 
+	@Override
+	public void joinDraft(final UUID draftId, final UUID sessionId) throws MageException {
+		try {
+			rmiExecutor.execute(
+				new Runnable() {
+					@Override
+					public void run() {
+						DraftManager.getInstance().joinDraft(draftId, sessionId);
+					}
+				}
+			);
+		}
+		catch (Exception ex) {
+			handleException(ex);
+		}
+	}
+
 	@Override
 	public UUID getGameChatId(UUID gameId) throws MageException {
 		try {
@@ -474,13 +507,13 @@ public class ServerImpl extends RemoteServer implements Server {
 	}
 
 	@Override
-	public void sendCardPick(final UUID gameId, final UUID sessionId, final UUID cardPick) throws MageException {
+	public void sendCardPick(final UUID draftId, final UUID sessionId, final UUID cardPick) throws MageException {
 		try {
 			rmiExecutor.execute(
 				new Runnable() {
 					@Override
 					public void run() {
-//						GameManager.getInstance().sendPlayerUUID(gameId, sessionId, data);
+						DraftManager.getInstance().sendCardPick(draftId, sessionId, cardPick);
 					}
 				}
 			);

Mage.Server/src/main/java/mage/server/Session.java

@@ -95,6 +95,10 @@ public class Session {
 		fireCallback(new ClientCallback("startGame", new TableClientMessage(gameId, playerId)));
 	}
 
+	public void draftStarted(final UUID draftId, final UUID playerId) {
+		fireCallback(new ClientCallback("startDraft", new TableClientMessage(draftId, playerId)));
+	}
+
 	public void sideboard(final Deck deck, final UUID tableId) {
 		fireCallback(new ClientCallback("sideboard", new TableClientMessage(deck, tableId)));
 	}

Mage.Server/src/main/java/mage/server/game/DraftController.java

@@ -0,0 +1,202 @@
+/*
+* 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.server.game;
+
+import java.io.File;
+import java.util.UUID;
+import java.util.Map.Entry;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ExecutorService;
+import java.util.logging.Logger;
+
+import mage.game.draft.Draft;
+import mage.game.draft.DraftPlayer;
+import mage.game.events.Listener;
+import mage.game.events.PlayerQueryEvent;
+import mage.game.events.TableEvent;
+import mage.server.ChatManager;
+import mage.server.util.ThreadExecutor;
+import mage.util.Logging;
+import mage.view.DraftPickView;
+import mage.view.ChatMessage.MessageColor;
+import mage.view.DraftView;
+
+/**
+ *
+ * @author BetaSteward_at_googlemail.com
+ */
+public class DraftController {
+
+//	private static ExecutorService gameExecutor = ThreadExecutor.getInstance().getGameExecutor();
+	private final static Logger logger = Logging.getLogger(GameController.class.getName());
+	public static final String INIT_FILE_PATH = "config" + File.separator + "init.txt";
+
+	private ConcurrentHashMap<UUID, DraftSession> draftSessions = new ConcurrentHashMap<UUID, DraftSession>();
+//	private ConcurrentHashMap<UUID, GameWatcher> watchers = new ConcurrentHashMap<UUID, GameWatcher>();
+	private ConcurrentHashMap<UUID, UUID> sessionPlayerMap;
+	private UUID draftSessionId;
+	private Draft draft;
+	private UUID chatId;
+	private UUID tableId;
+
+	public DraftController(Draft draft, ConcurrentHashMap<UUID, UUID> sessionPlayerMap, UUID tableId) {
+		draftSessionId = UUID.randomUUID();
+		this.sessionPlayerMap = sessionPlayerMap;
+		chatId = ChatManager.getInstance().createChatSession();
+		this.draft = draft;
+		this.tableId = tableId;
+		init();
+	}
+
+	private void init() {
+		draft.addTableEventListener(
+			new Listener<TableEvent> () {
+				@Override
+				public void event(TableEvent event) {
+					switch (event.getEventType()) {
+						case UPDATE:
+							updateDraft();
+							break;
+					}
+				}
+			}
+		);
+		draft.addPlayerQueryEventListener(
+			new Listener<PlayerQueryEvent> () {
+				@Override
+				public void event(PlayerQueryEvent event) {
+					switch (event.getQueryType()) {
+						case PICK_CARD:
+							pickCard(event.getPlayerId());
+							break;
+					}
+				}
+			}
+		);
+	}
+
+	private UUID getPlayerId(UUID sessionId) {
+		return sessionPlayerMap.get(sessionId);
+	}
+
+	public void join(UUID sessionId) {
+		UUID playerId = sessionPlayerMap.get(sessionId);
+		DraftSession draftSession = new DraftSession(sessionId, draft.getId());
+		draftSessions.put(playerId, draftSession);
+		logger.info("player " + playerId + " has joined draft " + draft.getId());
+		ChatManager.getInstance().broadcast(chatId, "", draft.getPlayer(playerId).getPlayer().getName() + " has joined the draft", MessageColor.BLACK);
+		if (allJoined()) {
+			ThreadExecutor.getInstance().getRMIExecutor().execute(
+				new Runnable() {
+					@Override
+					public void run() {
+						startDraft();
+					}
+			});
+		}
+	}
+
+	private synchronized void startDraft() {
+		for (final Entry<UUID, DraftSession> entry: draftSessions.entrySet()) {
+			if (!entry.getValue().init(getDraftView())) {
+				logger.severe("Unable to initialize client");
+				//TODO: generate client error message
+				return;
+			}
+		}
+	}
+
+	private boolean allJoined() {
+		for (DraftPlayer player: draft.getPlayers()) {
+			if (player.getPlayer().isHuman() && draftSessions.get(player.getPlayer().getId()) == null) {
+				return false;
+			}
+		}
+		return true;
+	}
+
+	private void leave(UUID sessionId) {
+		draft.leave(getPlayerId(sessionId));
+	}
+
+	public void kill(UUID sessionId) {
+		if (sessionPlayerMap.containsKey(sessionId)) {
+			draftSessions.get(sessionPlayerMap.get(sessionId)).setKilled();
+			draftSessions.remove(sessionPlayerMap.get(sessionId));
+			leave(sessionId);
+			sessionPlayerMap.remove(sessionId);
+		}
+	}
+
+	public void timeout(UUID sessionId) {
+		if (sessionPlayerMap.containsKey(sessionId)) {
+			ChatManager.getInstance().broadcast(chatId, "", draft.getPlayer(sessionPlayerMap.get(sessionId)).getPlayer().getName() + " has timed out.  Auto picking.", MessageColor.BLACK);
+			draft.autoPick(sessionPlayerMap.get(sessionId));
+		}
+	}
+
+	public void endDraft(final String message) {
+		for (final DraftSession draftSession: draftSessions.values()) {
+			draftSession.gameOver(message);
+		}
+		TableManager.getInstance().endGame(tableId);
+	}
+
+	public UUID getSessionId() {
+		return this.draftSessionId;
+	}
+
+	public UUID getChatId() {
+		return chatId;
+	}
+
+	public void sendCardPick(UUID sessionId, UUID cardId) {
+		draft.addPick(sessionPlayerMap.get(sessionId), cardId);
+	}
+
+	private synchronized void updateDraft() {
+		for (final Entry<UUID, DraftSession> entry: draftSessions.entrySet()) {
+			entry.getValue().update(getDraftView());
+		}
+	}
+
+	private synchronized void pickCard(UUID playerId) {
+		if (draftSessions.containsKey(playerId))
+			draftSessions.get(playerId).pickCard(getDraftPickView(playerId));
+	}
+
+	private DraftView getDraftView() {
+		return new DraftView(draft);
+	}
+
+	private DraftPickView getDraftPickView(UUID playerId) {
+		return new DraftPickView();
+	}
+
+}

Mage.Server/src/main/java/mage/server/game/DraftFactory.java

@@ -0,0 +1,79 @@
+/*
+* 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.server.game;
+
+import java.lang.reflect.Constructor;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+import mage.game.draft.Draft;
+import mage.game.draft.DraftOptions;
+import mage.util.Logging;
+
+/**
+ *
+ * @author BetaSteward_at_googlemail.com
+ */
+public class DraftFactory {
+
+	private final static DraftFactory INSTANCE = new DraftFactory();
+	private final static Logger logger = Logging.getLogger(DraftFactory.class.getName());
+
+	private Map<String, Class<Draft>> drafts = new HashMap<String, Class<Draft>>();
+
+	public static DraftFactory getInstance() {
+		return INSTANCE;
+	}
+
+	private DraftFactory() {}
+
+	public Draft createDraft(String draftType, DraftOptions options) {
+
+		Draft draft;
+		Constructor<Draft> con;
+		try {
+			con = drafts.get(draftType).getConstructor(new Class[]{DraftOptions.class});
+			draft = con.newInstance(new Object[] {options});
+		} catch (Exception ex) {
+			logger.log(Level.SEVERE, null, ex);
+			return null;
+		}
+		logger.info("Draft created: " + draftType); // + game.getId().toString());
+
+		return draft;
+	}
+
+	public void addDraftType(String name, Class draft) {
+		if (draft != null) {
+			this.drafts.put(name, draft);
+		}
+	}
+
+}

Mage.Server/src/main/java/mage/server/game/DraftManager.java

@@ -0,0 +1,90 @@
+/*
+* 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.server.game;
+
+import java.util.UUID;
+import java.util.concurrent.ConcurrentHashMap;
+import mage.game.draft.Draft;
+
+/**
+ *
+ * @author BetaSteward_at_googlemail.com
+ */
+public class DraftManager {
+	private final static DraftManager INSTANCE = new DraftManager();
+
+	public static DraftManager getInstance() {
+		return INSTANCE;
+	}
+
+	private DraftManager() {}
+
+	private ConcurrentHashMap<UUID, DraftController> draftControllers = new ConcurrentHashMap<UUID, DraftController>();
+
+	public UUID createDraftSession(Draft draft, ConcurrentHashMap<UUID, UUID> sessionPlayerMap, UUID tableId) {
+		DraftController draftController = new DraftController(draft, sessionPlayerMap, tableId);
+		draftControllers.put(draft.getId(), draftController);
+		return draftController.getSessionId();
+	}
+
+	public void joinDraft(UUID draftId, UUID sessionId) {
+		draftControllers.get(draftId).join(sessionId);
+	}
+
+	public void destroyChatSession(UUID gameId) {
+		draftControllers.remove(gameId);
+	}
+
+	public UUID getChatId(UUID draftId) {
+		return draftControllers.get(draftId).getChatId();
+	}
+
+	public void sendCardPick(UUID draftId, UUID sessionId, UUID cardId) {
+		draftControllers.get(draftId).sendCardPick(sessionId, cardId);
+	}
+
+	public void removeSession(UUID sessionId) {
+		for (DraftController controller: draftControllers.values()) {
+			controller.kill(sessionId);
+		}
+	}
+
+	public void kill(UUID draftId, UUID sessionId) {
+		draftControllers.get(draftId).kill(sessionId);
+	}
+
+	void timeout(UUID gameId, UUID sessionId) {
+		draftControllers.get(gameId).timeout(sessionId);
+	}
+
+	void removeDraft(UUID draftId) {
+		draftControllers.remove(draftId);
+	}
+
+}

Mage.Server/src/main/java/mage/server/game/DraftSession.java

@@ -0,0 +1,150 @@
+/*
+* Copyright 2011 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.server.game;
+
+import java.rmi.RemoteException;
+import java.util.UUID;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.ScheduledFuture;
+import java.util.concurrent.TimeUnit;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+import mage.interfaces.callback.ClientCallback;
+import mage.server.Session;
+import mage.server.SessionManager;
+import mage.server.util.ThreadExecutor;
+import mage.util.Logging;
+import mage.view.DraftClientMessage;
+import mage.view.DraftPickView;
+import mage.view.DraftView;
+import mage.view.GameClientMessage;
+
+/**
+ *
+ * @author BetaSteward_at_googlemail.com
+ */
+public class DraftSession {
+
+	protected final static Logger logger = Logging.getLogger(GameWatcher.class.getName());
+
+	protected UUID sessionId;
+	protected UUID draftId;
+	protected boolean killed = false;
+
+	private ScheduledFuture<?> futureTimeout;
+	protected static ScheduledExecutorService timeoutExecutor = ThreadExecutor.getInstance().getTimeoutExecutor();
+
+	public DraftSession(UUID sessionId, UUID draftId) {
+		this.sessionId = sessionId;
+		this.draftId = draftId;
+	}
+
+	public boolean init(final DraftView draftView) {
+		if (!killed) {
+			Session session = SessionManager.getInstance().getSession(sessionId);
+			if (session != null) {
+				session.clearAck();
+				session.fireCallback(new ClientCallback("draftInit", draftView));
+				if (waitForAck("draftInit"))
+					return true;
+			}
+		}
+		return false;
+	}
+
+	public boolean waitForAck(String message) {
+		Session session = SessionManager.getInstance().getSession(sessionId);
+		do {
+			//TODO: add timeout
+		} while (!session.getAckMessage().equals(message) && !killed);
+		return true;
+	}
+
+	public void update(final DraftView draftView) {
+		if (!killed) {
+			Session session = SessionManager.getInstance().getSession(sessionId);
+			if (session != null)
+				session.fireCallback(new ClientCallback("draftUpdate", draftView));
+		}
+	}
+
+	public void inform(final String message, final DraftView draftView) {
+		if (!killed) {
+			Session session = SessionManager.getInstance().getSession(sessionId);
+			if (session != null)
+				session.fireCallback(new ClientCallback("draftInform", new DraftClientMessage(draftView, message)));
+		}
+	}
+
+	public void gameOver(final String message) {
+		if (!killed) {
+			Session session = SessionManager.getInstance().getSession(sessionId);
+			if (session != null)
+				session.fireCallback(new ClientCallback("gameOver", message));
+		}
+	}
+
+	public void pickCard(final DraftPickView draftPickView) {
+		if (!killed) {
+			setupTimeout(20);
+			Session session = SessionManager.getInstance().getSession(sessionId);
+			if (session != null)
+				session.fireCallback(new ClientCallback("draftPick", new DraftClientMessage(draftPickView)));
+		}
+	}
+
+	private synchronized void setupTimeout(int seconds) {
+		cancelTimeout();
+		futureTimeout = timeoutExecutor.schedule(
+			new Runnable() {
+				@Override
+				public void run() {
+					DraftManager.getInstance().timeout(draftId, sessionId);
+				}
+			},
+			seconds, TimeUnit.SECONDS
+		);
+	}
+
+	private synchronized void cancelTimeout() {
+		if (futureTimeout != null) {
+			futureTimeout.cancel(false);
+		}
+	}
+
+	protected void handleRemoteException(RemoteException ex) {
+		logger.log(Level.SEVERE, null, ex);
+		DraftManager.getInstance().kill(draftId, sessionId);
+	}
+
+	public void setKilled() {
+		killed = true;
+	}
+
+}

Mage.Server/src/main/java/mage/server/game/GamesRoom.java

@@ -32,6 +32,7 @@ import java.util.List;
 import java.util.UUID;
 import mage.cards.decks.DeckCardLists;
 import mage.game.GameException;
+import mage.game.draft.DraftOptions;
 import mage.game.match.MatchOptions;
 import mage.view.TableView;
 
@@ -43,7 +44,9 @@ public interface GamesRoom extends Room {
 
 	public List<TableView> getTables();
 	public boolean joinTable(UUID sessionId, UUID tableId, String name, DeckCardLists deckList) throws GameException;
+	public boolean joinDraftTable(UUID sessionId, UUID tableId, String name) throws GameException;
 	public TableView createTable(UUID sessionId, MatchOptions options);
+	public TableView createDraftTable(UUID sessionId, DraftOptions options);
 	public void removeTable(UUID sessionId, UUID tableId);
 	public TableView getTable(UUID tableId);
 	public void leaveTable(UUID sessionId, UUID tableId);

Mage.Server/src/main/java/mage/server/game/GamesRoomImpl.java

@@ -37,6 +37,7 @@ import java.util.concurrent.ConcurrentHashMap;
 import java.util.logging.Logger;
 import mage.cards.decks.DeckCardLists;
 import mage.game.GameException;
+import mage.game.draft.DraftOptions;
 import mage.game.match.MatchOptions;
 import mage.util.Logging;
 import mage.view.TableView;
@@ -76,6 +77,22 @@ public class GamesRoomImpl extends RoomImpl implements GamesRoom, Serializable {
 		return new TableView(table);
 	}
 
+	@Override
+	public boolean joinDraftTable(UUID sessionId, UUID tableId, String name) throws GameException {
+		if (tables.containsKey(tableId)) {
+			return TableManager.getInstance().joinDraft(sessionId, tableId, name);
+		} else {
+			return false;
+		}
+	}
+
+	@Override
+	public TableView createDraftTable(UUID sessionId, DraftOptions options) {
+		Table table = TableManager.getInstance().createDraftTable(sessionId, options);
+		tables.put(table.getId(), table);
+		return new TableView(table);
+	}
+
 	@Override
 	public TableView getTable(UUID tableId) {
 		return new TableView(tables.get(tableId));

Mage.Server/src/main/java/mage/server/game/TableController.java

@@ -54,6 +54,8 @@ import mage.game.GameException;
 import mage.game.GameStates;
 import mage.game.match.Match;
 import mage.game.Seat;
+import mage.game.draft.Draft;
+import mage.game.draft.DraftOptions;
 import mage.game.events.Listener;
 import mage.game.events.TableEvent;
 import mage.game.match.MatchOptions;
@@ -78,6 +80,8 @@ public class TableController {
 	private Table table;
 	private Match match;
 	private MatchOptions options;
+	private Draft draft;
+	private DraftOptions draftOptions;
 	private ConcurrentHashMap<UUID, UUID> sessionPlayerMap = new ConcurrentHashMap<UUID, UUID>();
 
 	public TableController(UUID sessionId, MatchOptions options) {
@@ -89,6 +93,15 @@ public class TableController {
 		init();
 	}
 
+	public TableController(UUID sessionId, DraftOptions options) {
+		this.sessionId = sessionId;
+		chatId = ChatManager.getInstance().createChatSession();
+		this.draftOptions = options;
+		draft = DraftFactory.getInstance().createDraft(options.getDraftType(), options);
+		table = new Table(options.getDraftType(), options.getName(), DeckValidatorFactory.getInstance().createDeckValidator("Limited"), options.getPlayerTypes());
+		init();
+	}
+
 	private void init() {
 		table.addTableEventListener(
 			new Listener<TableEvent> () {
@@ -107,6 +120,26 @@ public class TableController {
 		);
 	}
 
+	public synchronized boolean joinDraft(UUID sessionId, String name) throws GameException {
+		if (table.getState() != TableState.WAITING) {
+			return false;
+		}
+		Seat seat = table.getNextAvailableSeat();
+		if (seat == null) {
+			throw new GameException("No available seats.");
+		}
+		Player player = createPlayer(name, seat.getPlayerType());
+		draft.addPlayer(player);
+		table.joinTable(player, seat);
+		logger.info("player joined " + player.getId());
+		//only add human players to sessionPlayerMap
+		if (seat.getPlayer().isHuman()) {
+			sessionPlayerMap.put(sessionId, player.getId());
+		}
+
+		return true;
+	}
+
 	public synchronized boolean joinTable(UUID sessionId, String name, DeckCardLists deckList) throws GameException {
 		if (table.getState() != TableState.WAITING) {
 			return false;
@@ -210,6 +243,18 @@ public class TableController {
 		}
 	}
 
+	public synchronized void startDraft(UUID sessionId) {
+		if (sessionId.equals(this.sessionId) && table.getState() == TableState.STARTING) {
+			draft.start();
+			table.initDraft();
+			DraftManager.getInstance().createDraftSession(draft, sessionPlayerMap, table.getId());
+			SessionManager sessionManager = SessionManager.getInstance();
+			for (Entry<UUID, UUID> entry: sessionPlayerMap.entrySet()) {
+				sessionManager.getSession(entry.getKey()).draftStarted(draft.getId(), entry.getValue());
+			}
+		}
+	}
+
 	private void sideboard() {
 		table.sideboard();
 		for (MatchPlayer player: match.getPlayers()) {

Mage.Server/src/main/java/mage/server/game/TableManager.java

@@ -35,6 +35,7 @@ import java.util.concurrent.ConcurrentHashMap;
 import java.util.logging.Logger;
 import mage.cards.decks.DeckCardLists;
 import mage.game.GameException;
+import mage.game.draft.DraftOptions;
 import mage.game.match.MatchOptions;
 import mage.util.Logging;
 
@@ -61,6 +62,13 @@ public class TableManager {
 		return tableController.getTable();
 	}
 
+	public Table createDraftTable(UUID sessionId, DraftOptions options) {
+		TableController tableController = new TableController(sessionId, options);
+		controllers.put(tableController.getTable().getId(), tableController);
+		tables.put(tableController.getTable().getId(), tableController.getTable());
+		return tableController.getTable();
+	}
+
 	public Table getTable(UUID tableId) {
 		return tables.get(tableId);
 	}
@@ -73,6 +81,10 @@ public class TableManager {
 		return controllers.get(tableId).joinTable(sessionId, name, deckList);
 	}
 
+	public boolean joinDraft(UUID sessionId, UUID tableId, String name) throws GameException {
+		return controllers.get(tableId).joinDraft(sessionId, name);
+	}
+
 	public boolean submitDeck(UUID sessionId, UUID tableId, DeckCardLists deckList) throws GameException {
 		return controllers.get(tableId).submitDeck(sessionId, deckList);
 	}
@@ -106,6 +118,10 @@ public class TableManager {
 		controllers.get(tableId).startMatch(sessionId);
 	}
 
+	public void startDraft(UUID sessionId, UUID roomId, UUID tableId) {
+		controllers.get(tableId).startDraft(sessionId);
+	}
+
 	public boolean watchTable(UUID sessionId, UUID tableId) {
 		return controllers.get(tableId).watchTable(sessionId);
 	}