From 4bfd85bfe12b1afb7ce7b5543c4c5b1427c6393e Mon Sep 17 00:00:00 2001 From: "marcins78@gmail.com" Date: Wed, 9 Jan 2013 04:22:35 +0000 Subject: [PATCH] Finished Hall resource in async. --- .../lotro/async/DeckRequestHandler.java | 62 ++++++ .../lotro/async/HallRequestHandler.java | 201 ++++++++++++++++++ .../lotro/async/RootUriRequestHandler.java | 4 + 3 files changed, 267 insertions(+) create mode 100644 gemp-lotr/gemp-lotr-async/src/main/java/com/gempukku/lotro/async/DeckRequestHandler.java diff --git a/gemp-lotr/gemp-lotr-async/src/main/java/com/gempukku/lotro/async/DeckRequestHandler.java b/gemp-lotr/gemp-lotr-async/src/main/java/com/gempukku/lotro/async/DeckRequestHandler.java new file mode 100644 index 000000000..0c5e91b8d --- /dev/null +++ b/gemp-lotr/gemp-lotr-async/src/main/java/com/gempukku/lotro/async/DeckRequestHandler.java @@ -0,0 +1,62 @@ +package com.gempukku.lotro.async; + +import com.gempukku.lotro.db.DeckDAO; +import com.gempukku.lotro.game.Player; +import org.jboss.netty.channel.MessageEvent; +import org.jboss.netty.handler.codec.http.HttpMethod; +import org.jboss.netty.handler.codec.http.HttpRequest; +import org.jboss.netty.handler.codec.http.QueryStringDecoder; +import org.w3c.dom.Document; +import org.w3c.dom.Element; + +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; +import java.lang.reflect.Type; +import java.util.ArrayList; +import java.util.Collections; +import java.util.List; +import java.util.Map; + +public class DeckRequestHandler extends LotroServerRequestHandler implements UriRequestHandler { + private DeckDAO _deckDao; + + public DeckRequestHandler(Map context) { + super(context); + _deckDao = extractObject(context, DeckDAO.class); + } + + @Override + public void handleRequest(String uri, HttpRequest request, Map context, ResponseWriter responseWriter, MessageEvent e) { + if (uri.equals("/list") && request.getMethod() == HttpMethod.GET) { + listDecks(request, responseWriter); + } else { + responseWriter.writeError(404); + } + } + + private void listDecks(HttpRequest request, ResponseWriter responseWriter) { + try { + QueryStringDecoder queryDecoder = new QueryStringDecoder(request.getUri()); + String participantId = getQueryParameterSafely(queryDecoder, "participantId"); + + Player resourceOwner = getResourceOwnerSafely(request, participantId); + + List names = new ArrayList(_deckDao.getPlayerDeckNames(resourceOwner)); + Collections.sort(names); + + DocumentBuilderFactory documentBuilderFactory = DocumentBuilderFactory.newInstance(); + DocumentBuilder documentBuilder = documentBuilderFactory.newDocumentBuilder(); + Document doc = documentBuilder.newDocument(); + Element decksElem = doc.createElement("decks"); + for (String name : names) { + Element deckElem = doc.createElement("deck"); + deckElem.appendChild(doc.createTextNode(name)); + decksElem.appendChild(deckElem); + } + doc.appendChild(decksElem); + responseWriter.writeResponse(doc); + } catch (Exception exp) { + responseWriter.writeError(500); + } + } +} diff --git a/gemp-lotr/gemp-lotr-async/src/main/java/com/gempukku/lotro/async/HallRequestHandler.java b/gemp-lotr/gemp-lotr-async/src/main/java/com/gempukku/lotro/async/HallRequestHandler.java index b19da8282..79bbcebb1 100644 --- a/gemp-lotr/gemp-lotr-async/src/main/java/com/gempukku/lotro/async/HallRequestHandler.java +++ b/gemp-lotr/gemp-lotr-async/src/main/java/com/gempukku/lotro/async/HallRequestHandler.java @@ -4,13 +4,16 @@ import com.gempukku.lotro.SubscriptionConflictException; import com.gempukku.lotro.SubscriptionExpiredException; import com.gempukku.lotro.collection.CollectionsManager; import com.gempukku.lotro.db.vo.League; +import com.gempukku.lotro.game.LotroCardBlueprintLibrary; import com.gempukku.lotro.game.LotroFormat; import com.gempukku.lotro.game.Player; import com.gempukku.lotro.game.formats.LotroFormatLibrary; import com.gempukku.lotro.hall.HallChannelVisitor; +import com.gempukku.lotro.hall.HallException; import com.gempukku.lotro.hall.HallServer; import com.gempukku.lotro.league.LeagueSerieData; import com.gempukku.lotro.league.LeagueService; +import com.gempukku.lotro.logic.GameUtils; import org.jboss.netty.channel.MessageEvent; import org.jboss.netty.handler.codec.http.HttpMethod; import org.jboss.netty.handler.codec.http.HttpRequest; @@ -23,6 +26,7 @@ import javax.ws.rs.WebApplicationException; import javax.ws.rs.core.Response; import javax.xml.parsers.DocumentBuilder; import javax.xml.parsers.DocumentBuilderFactory; +import javax.xml.parsers.ParserConfigurationException; import java.lang.reflect.Type; import java.util.Map; @@ -31,6 +35,7 @@ public class HallRequestHandler extends LotroServerRequestHandler implements Uri private LotroFormatLibrary _formatLibrary; private HallServer _hallServer; private LeagueService _leagueService; + private LotroCardBlueprintLibrary _library; private long _longPollingLength = 5000; private long _longPollingInterval = 200; @@ -40,19 +45,215 @@ public class HallRequestHandler extends LotroServerRequestHandler implements Uri _formatLibrary = extractObject(context, LotroFormatLibrary.class); _hallServer = extractObject(context, HallServer.class); _leagueService = extractObject(context, LeagueService.class); + _library = extractObject(context, LotroCardBlueprintLibrary.class); } @Override public void handleRequest(String uri, HttpRequest request, Map context, ResponseWriter responseWriter, MessageEvent e) { if (uri.equals("") && request.getMethod() == HttpMethod.GET) { getHall(request, responseWriter); + } else if (uri.equals("") && request.getMethod() == HttpMethod.POST) { + createTable(request, responseWriter); } else if (uri.equals("/update") && request.getMethod() == HttpMethod.POST) { updateHall(request, responseWriter); + } else if (uri.equals("/formats/html") && request.getMethod() == HttpMethod.GET) { + getFormats(request, responseWriter); + } else if (uri.startsWith("/format/") && request.getMethod() == HttpMethod.GET) { + getFormat(request, uri.substring(8), responseWriter); + } else if (uri.startsWith("/queue/") && request.getMethod() == HttpMethod.POST) { + if (uri.endsWith("/leave")) { + leaveQueue(request, uri.substring(7, uri.length() - 6), responseWriter); + } else { + joinQueue(request, uri.substring(7), responseWriter); + } + } else if (uri.startsWith("/tournament/") && uri.endsWith("/leave") && request.getMethod() == HttpMethod.POST) { + dropFromTournament(request, uri.substring(12, uri.length() - 6), responseWriter); + } else if (uri.equals("/leave") && request.getMethod() == HttpMethod.POST) { + leaveTable(request, responseWriter); + } else if (uri.startsWith("/") && request.getMethod() == HttpMethod.POST) { + joinTable(request, uri.substring(1), responseWriter); } else { responseWriter.writeError(404); } } + private void joinTable(HttpRequest request, String tableId, ResponseWriter responseWriter) { + try { + HttpPostRequestDecoder postDecoder = new HttpPostRequestDecoder(request); + String participantId = getFormParameterSafely(postDecoder, "participantId"); + Player resourceOwner = getResourceOwnerSafely(request, participantId); + + String deckName = getFormParameterSafely(postDecoder, "deckName"); + + _hallServer.joinTableAsPlayer(tableId, resourceOwner, deckName); + responseWriter.writeResponse(null); + } catch (Exception exp) { + responseWriter.writeError(500); + } + } + + private void leaveTable(HttpRequest request, ResponseWriter responseWriter) { + try { + HttpPostRequestDecoder postDecoder = new HttpPostRequestDecoder(request); + String participantId = getFormParameterSafely(postDecoder, "participantId"); + Player resourceOwner = getResourceOwnerSafely(request, participantId); + + _hallServer.leaveAwaitingTables(resourceOwner); + responseWriter.writeResponse(null); + } catch (Exception exp) { + responseWriter.writeError(500); + } + } + + private void createTable(HttpRequest request, ResponseWriter responseWriter) { + try { + HttpPostRequestDecoder postDecoder = new HttpPostRequestDecoder(request); + String participantId = getFormParameterSafely(postDecoder, "participantId"); + String format = getFormParameterSafely(postDecoder, "format"); + String deckName = getFormParameterSafely(postDecoder, "deckName"); + + Player resourceOwner = getResourceOwnerSafely(request, participantId); + + try { + _hallServer.createNewTable(format, resourceOwner, deckName); + responseWriter.writeResponse(null); + } catch (HallException e) { + responseWriter.writeResponse(marshalException(e)); + } + } catch (Exception exp) { + responseWriter.writeError(500); + } + } + + private void dropFromTournament(HttpRequest request, String tournamentId, ResponseWriter responseWriter) { + try { + HttpPostRequestDecoder postDecoder = new HttpPostRequestDecoder(request); + String participantId = getFormParameterSafely(postDecoder, "participantId"); + Player resourceOwner = getResourceOwnerSafely(request, participantId); + + _hallServer.dropFromTournament(tournamentId, resourceOwner); + + responseWriter.writeResponse(null); + } catch (Exception exp) { + responseWriter.writeError(500); + } + } + + private void joinQueue(HttpRequest request, String queueId, ResponseWriter responseWriter) { + try { + HttpPostRequestDecoder postDecoder = new HttpPostRequestDecoder(request); + String participantId = getFormParameterSafely(postDecoder, "participantId"); + String deckName = getFormParameterSafely(postDecoder, "deckName"); + + Player resourceOwner = getResourceOwnerSafely(request, participantId); + + try { + _hallServer.joinQueue(queueId, resourceOwner, deckName); + responseWriter.writeResponse(null); + } catch (HallException e) { + responseWriter.writeResponse(marshalException(e)); + } + } catch (Exception exp) { + responseWriter.writeError(500); + } + } + + private void leaveQueue(HttpRequest request, String queueId, ResponseWriter responseWriter) { + try { + HttpPostRequestDecoder postDecoder = new HttpPostRequestDecoder(request); + String participantId = getFormParameterSafely(postDecoder, "participantId"); + + Player resourceOwner = getResourceOwnerSafely(request, participantId); + + _hallServer.leaveQueue(queueId, resourceOwner); + + responseWriter.writeResponse(null); + } catch (Exception exp) { + responseWriter.writeError(500); + } + } + + private Document marshalException(HallException e) throws ParserConfigurationException { + DocumentBuilderFactory documentBuilderFactory = DocumentBuilderFactory.newInstance(); + DocumentBuilder documentBuilder = documentBuilderFactory.newDocumentBuilder(); + + Document doc = documentBuilder.newDocument(); + + Element error = doc.createElement("error"); + error.setAttribute("message", e.getMessage()); + doc.appendChild(error); + return doc; + } + + private void getFormat(HttpRequest request, String format, ResponseWriter responseWriter) { + StringBuilder result = new StringBuilder(); + LotroFormat lotroFormat = _formatLibrary.getFormat(format); + result.append("" + lotroFormat.getName() + ""); + result.append("
    "); + result.append("
  • valid sets: "); + for (Integer integer : lotroFormat.getValidSets()) + result.append(integer + ", "); + result.append("
    • "); + result.append("
  • sites from block: " + lotroFormat.getSiteBlock().getHumanReadable() + "
    • "); + result.append("
  • Ring-bearer skirmish can be cancelled: " + (lotroFormat.canCancelRingBearerSkirmish() ? "yes" : "no") + "
    • "); + result.append("
  • X-listed: "); + for (String blueprintId : lotroFormat.getBannedCards()) + result.append(GameUtils.getCardLink(blueprintId, _library.getLotroCardBlueprint(blueprintId)) + ", "); + if (lotroFormat.getBannedCards().size() == 0) + result.append("none,"); + result.append("
    • "); + result.append("
  • R-listed: "); + for (String blueprintId : lotroFormat.getRestrictedCards()) + result.append(GameUtils.getCardLink(blueprintId, _library.getLotroCardBlueprint(blueprintId)) + ", "); + if (lotroFormat.getRestrictedCards().size() == 0) + result.append("none,"); + result.append("
    • "); + result.append("
  • Additional valid: "); + for (String blueprintId : lotroFormat.getValidCards()) + result.append(GameUtils.getCardLink(blueprintId, _library.getLotroCardBlueprint(blueprintId)) + ", "); + if (lotroFormat.getValidCards().size() == 0) + result.append("none,"); + result.append("
    • "); + result.append("
"); + + responseWriter.writeHtmlResponse(result.toString()); + } + + private void getFormats(HttpRequest request, ResponseWriter responseWriter) { + StringBuilder result = new StringBuilder(); + for (LotroFormat lotroFormat : _formatLibrary.getHallFormats().values()) { + result.append("" + lotroFormat.getName() + ""); + result.append("
    "); + result.append("
  • valid sets: "); + for (Integer integer : lotroFormat.getValidSets()) + result.append(integer + ", "); + result.append("
    • "); + result.append("
  • sites from block: " + lotroFormat.getSiteBlock().getHumanReadable() + "
    • "); + result.append("
  • Ring-bearer skirmish can be cancelled: " + (lotroFormat.canCancelRingBearerSkirmish() ? "yes" : "no") + "
    • "); + result.append("
  • X-listed: "); + for (String blueprintId : lotroFormat.getBannedCards()) + result.append(GameUtils.getCardLink(blueprintId, _library.getLotroCardBlueprint(blueprintId)) + ", "); + if (lotroFormat.getBannedCards().size() == 0) + result.append("none,"); + result.append("
    • "); + result.append("
  • R-listed: "); + for (String blueprintId : lotroFormat.getRestrictedCards()) + result.append(GameUtils.getCardLink(blueprintId, _library.getLotroCardBlueprint(blueprintId)) + ", "); + if (lotroFormat.getRestrictedCards().size() == 0) + result.append("none,"); + result.append("
    • "); + result.append("
  • Additional valid: "); + for (String blueprintId : lotroFormat.getValidCards()) + result.append(GameUtils.getCardLink(blueprintId, _library.getLotroCardBlueprint(blueprintId)) + ", "); + if (lotroFormat.getValidCards().size() == 0) + result.append("none,"); + result.append("
    • "); + result.append("
"); + } + + responseWriter.writeHtmlResponse(result.toString()); + } + private void getHall(HttpRequest request, ResponseWriter responseWriter) { QueryStringDecoder queryDecoder = new QueryStringDecoder(request.getUri()); diff --git a/gemp-lotr/gemp-lotr-async/src/main/java/com/gempukku/lotro/async/RootUriRequestHandler.java b/gemp-lotr/gemp-lotr-async/src/main/java/com/gempukku/lotro/async/RootUriRequestHandler.java index 746c489f4..657fe54c0 100644 --- a/gemp-lotr/gemp-lotr-async/src/main/java/com/gempukku/lotro/async/RootUriRequestHandler.java +++ b/gemp-lotr/gemp-lotr-async/src/main/java/com/gempukku/lotro/async/RootUriRequestHandler.java @@ -13,9 +13,11 @@ public class RootUriRequestHandler implements UriRequestHandler { private WebRequestHandler _webRequestHandler = new WebRequestHandler(); private LoginRequestHandler _loginRequestHandler; private StatusRequestHandler _statusRequestHandler; + private DeckRequestHandler _deckRequestHandler; public RootUriRequestHandler(Map context) { _hallRequestHandler = new HallRequestHandler(context); + _deckRequestHandler = new DeckRequestHandler(context); _loginRequestHandler = new LoginRequestHandler(context); _statusRequestHandler = new StatusRequestHandler(context); } @@ -26,6 +28,8 @@ public class RootUriRequestHandler implements UriRequestHandler { _webRequestHandler.handleRequest(uri.substring(_webContextPath.length()), request, context, responseWriter, e); } else if (uri.startsWith(_serverContextPath +"hall")) { _hallRequestHandler.handleRequest(uri.substring(_serverContextPath.length()+4), request, context, responseWriter, e); + } else if (uri.startsWith(_serverContextPath+"deck")) { + _deckRequestHandler.handleRequest(uri.substring(_serverContextPath.length()+4), request, context, responseWriter, e); } else if (uri.startsWith(_serverContextPath+"login")) { _loginRequestHandler.handleRequest(uri.substring(_serverContextPath.length()+5), request, context, responseWriter, e); } else if (uri.equals(_serverContextPath)) {