ambidextrous/gemp-lotr
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Finished MerchantRequestHandler.

Browse Source
This commit is contained in:
marcins78
2013-01-09 16:00:11 +00:00
parent e1230fc107
commit 15d2f3dbcc
2 changed files with 215 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

211
gemp-lotr/gemp-lotr-async/src/main/java/com/gempukku/lotro/async/handler/MerchantRequestHandler.java Normal file
View File

@@ -0,0 +1,211 @@
package com.gempukku.lotro.async.handler;
import com.gempukku.lotro.async.ResponseWriter;
import com.gempukku.lotro.cards.packs.RarityReader;
import com.gempukku.lotro.cards.packs.SetRarity;
import com.gempukku.lotro.collection.CollectionsManager;
import com.gempukku.lotro.game.*;
import com.gempukku.lotro.game.formats.LotroFormatLibrary;
import com.gempukku.lotro.merchant.MerchantException;
import com.gempukku.lotro.merchant.MerchantService;
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.jboss.netty.handler.codec.http.multipart.HttpPostRequestDecoder;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;
import java.lang.reflect.Type;
import java.util.*;
public class MerchantRequestHandler extends LotroServerRequestHandler implements UriRequestHandler {
private HashMap<String, SetRarity> _rarities;
private CollectionsManager _collectionsManager;
private SortAndFilterCards _sortAndFilterCards;
private MerchantService _merchantService;
private LotroCardBlueprintLibrary _library;
private LotroFormatLibrary _formatLibrary;
public MerchantRequestHandler(Map<Type, Object> context) {
super(context);
_collectionsManager = extractObject(context, CollectionsManager.class);
_sortAndFilterCards = new SortAndFilterCards();
_merchantService = extractObject(context, MerchantService.class);
_library = extractObject(context, LotroCardBlueprintLibrary.class);
_formatLibrary = extractObject(context, LotroFormatLibrary.class);
_rarities = new HashMap<String, SetRarity>();
RarityReader reader = new RarityReader();
_rarities.put("0", reader.getSetRarity("0"));
_rarities.put("1", reader.getSetRarity("1"));
_rarities.put("2", reader.getSetRarity("2"));
_rarities.put("3", reader.getSetRarity("3"));
_rarities.put("4", reader.getSetRarity("4"));
_rarities.put("5", reader.getSetRarity("5"));
_rarities.put("6", reader.getSetRarity("6"));
_rarities.put("7", reader.getSetRarity("7"));
_rarities.put("8", reader.getSetRarity("8"));
_rarities.put("9", reader.getSetRarity("9"));
_rarities.put("10", reader.getSetRarity("10"));
_rarities.put("11", reader.getSetRarity("11"));
_rarities.put("12", reader.getSetRarity("12"));
_rarities.put("13", reader.getSetRarity("13"));
_rarities.put("14", reader.getSetRarity("14"));
_rarities.put("15", reader.getSetRarity("15"));
_rarities.put("16", reader.getSetRarity("16"));
_rarities.put("17", reader.getSetRarity("17"));
_rarities.put("18", reader.getSetRarity("18"));
_rarities.put("19", reader.getSetRarity("19"));
}
@Override
public void handleRequest(String uri, HttpRequest request, Map<Type, Object> context, ResponseWriter responseWriter, MessageEvent e) throws Exception {
if (uri.equals("") && request.getMethod() == HttpMethod.GET) {
getMerchantOffers(request, responseWriter);
} else if (uri.equals("/buy") && request.getMethod() == HttpMethod.POST) {
buy(request, responseWriter);
} else if (uri.equals("/sell") && request.getMethod() == HttpMethod.POST) {
sell(request, responseWriter);
} else if (uri.equals("/tradeFoil") && request.getMethod() == HttpMethod.POST) {
tradeInFoil(request, responseWriter);
} else {
responseWriter.writeError(404);
}
}
private void tradeInFoil(HttpRequest request, ResponseWriter responseWriter) throws Exception {
HttpPostRequestDecoder postDecoder = new HttpPostRequestDecoder(request);
String participantId = getFormParameterSafely(postDecoder, "participantId");
String blueprintId = getFormParameterSafely(postDecoder, "blueprintId");
Player resourceOwner = getResourceOwnerSafely(request, participantId);
try {
_merchantService.tradeForFoil(resourceOwner, blueprintId);
responseWriter.writeResponse(null);
} catch (MerchantException exp) {
responseWriter.writeResponse(marshalException(exp));
}
}
private void sell(HttpRequest request, ResponseWriter responseWriter) throws Exception {
HttpPostRequestDecoder postDecoder = new HttpPostRequestDecoder(request);
String participantId = getFormParameterSafely(postDecoder, "participantId");
String blueprintId = getFormParameterSafely(postDecoder, "blueprintId");
int price = Integer.parseInt(getFormParameterSafely(postDecoder, "price"));
Player resourceOwner = getResourceOwnerSafely(request, participantId);
try {
_merchantService.merchantBuysCard(resourceOwner, blueprintId, price);
responseWriter.writeResponse(null);
} catch (MerchantException exp) {
responseWriter.writeResponse(marshalException(exp));
}
}
private void buy(HttpRequest request, ResponseWriter responseWriter) throws Exception {
HttpPostRequestDecoder postDecoder = new HttpPostRequestDecoder(request);
String participantId = getFormParameterSafely(postDecoder, "participantId");
String blueprintId = getFormParameterSafely(postDecoder, "blueprintId");
int price = Integer.parseInt(getFormParameterSafely(postDecoder, "price"));
Player resourceOwner = getResourceOwnerSafely(request, participantId);
try {
_merchantService.merchantSellsCard(resourceOwner, blueprintId, price);
responseWriter.writeResponse(null);
} catch (MerchantException exp) {
responseWriter.writeResponse(marshalException(exp));
}
}
private void getMerchantOffers(HttpRequest request, ResponseWriter responseWriter) throws Exception {
QueryStringDecoder queryDecoder = new QueryStringDecoder(request.getUri());
String participantId = getQueryParameterSafely(queryDecoder, "participantId");
String filter = getQueryParameterSafely(queryDecoder, "filter");
int ownedMin = Integer.parseInt(getQueryParameterSafely(queryDecoder, "ownedMin"));
int start = Integer.parseInt(getQueryParameterSafely(queryDecoder, "start"));
int count = Integer.parseInt(getQueryParameterSafely(queryDecoder, "count"));
Player resourceOwner = getResourceOwnerSafely(request, participantId);
CardCollection collection = _collectionsManager.getPlayerCollection(resourceOwner, "permanent");
Set<CardItem> cardItems = new HashSet<CardItem>();
final Collection<CardCollection.Item> allItems = collection.getAll().values();
for (CardCollection.Item item : allItems) {
if (item.getCount() >= ownedMin)
cardItems.add(item);
}
if (ownedMin <= 0) {
Set<CardItem> items = _merchantService.getSellableItems();
for (CardItem item : items) {
if (collection.getItemCount(item.getBlueprintId()) == 0)
cardItems.add(item);
}
}
List<CardItem> filteredResult = _sortAndFilterCards.process(filter, cardItems, _library, _formatLibrary, _rarities);
List<CardItem> pageToDisplay = new ArrayList<CardItem>();
for (int i = start; i < start + count; i++) {
if (i >= 0 && i < filteredResult.size())
pageToDisplay.add(filteredResult.get(i));
}
MerchantService.PriceGuarantee priceGuarantee = _merchantService.priceCards(resourceOwner, pageToDisplay);
Map<String, Integer> buyPrices = priceGuarantee.getBuyPrices();
Map<String, Integer> sellPrices = priceGuarantee.getSellPrices();
DocumentBuilderFactory documentBuilderFactory = DocumentBuilderFactory.newInstance();
DocumentBuilder documentBuilder = documentBuilderFactory.newDocumentBuilder();
Document doc = documentBuilder.newDocument();
Element merchantElem = doc.createElement("merchant");
merchantElem.setAttribute("currency", String.valueOf(_collectionsManager.getPlayerCollection(resourceOwner, "permanent").getCurrency()));
merchantElem.setAttribute("count", String.valueOf(filteredResult.size()));
doc.appendChild(merchantElem);
for (CardItem cardItem : pageToDisplay) {
String blueprintId = cardItem.getBlueprintId();
Element elem;
if (blueprintId.contains("_"))
elem = doc.createElement("card");
else
elem = doc.createElement("pack");
elem.setAttribute("count", String.valueOf(collection.getItemCount(blueprintId)));
if (blueprintId.contains("_") && !blueprintId.endsWith("*") && collection.getItemCount(blueprintId) >= 4)
elem.setAttribute("tradeFoil", "true");
elem.setAttribute("blueprintId", blueprintId);
Integer buyPrice = buyPrices.get(blueprintId);
if (buyPrice != null && collection.getItemCount(blueprintId) > 0)
elem.setAttribute("buyPrice", buyPrice.toString());
Integer sellPrice = sellPrices.get(blueprintId);
if (sellPrice != null)
elem.setAttribute("sellPrice", sellPrice.toString());
merchantElem.appendChild(elem);
}
responseWriter.writeResponse(doc);
}
private Document marshalException(MerchantException 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;
}
}

4
gemp-lotr/gemp-lotr-async/src/main/java/com/gempukku/lotro/async/handler/RootUriRequestHandler.java
View File

@@ -22,6 +22,7 @@ public class RootUriRequestHandler implements UriRequestHandler {
private DeliveryRequestHandler _deliveryRequestHandler;
private GameRequestHandler _gameRequestHandler;
private LeagueRequestHandler _leagueRequestHandler;
private MerchantRequestHandler _merchantRequestHandler;
public RootUriRequestHandler(Map<Type, Object> context) {
_hallRequestHandler = new HallRequestHandler(context);
@@ -34,6 +35,7 @@ public class RootUriRequestHandler implements UriRequestHandler {
_deliveryRequestHandler = new DeliveryRequestHandler(context);
_gameRequestHandler = new GameRequestHandler(context);
_leagueRequestHandler = new LeagueRequestHandler(context);
_merchantRequestHandler = new MerchantRequestHandler(context);
}
@Override
@@ -60,6 +62,8 @@ public class RootUriRequestHandler implements UriRequestHandler {
_gameRequestHandler.handleRequest(uri.substring(_serverContextPath.length()+4), request, context, responseWriter, e);
} else if (uri.startsWith(_serverContextPath + "league")) {
_leagueRequestHandler.handleRequest(uri.substring(_serverContextPath.length()+6), request, context, responseWriter, e);
} else if (uri.startsWith(_serverContextPath + "merchant")) {
_merchantRequestHandler.handleRequest(uri.substring(_serverContextPath.length()+8), request, context, responseWriter, e);
} else if (uri.equals(_serverContextPath)) {
_statusRequestHandler.handleRequest(uri.substring(_serverContextPath.length()), request, context, responseWriter, e);
} else {