package com.automarket.scanner.scanner; import com.automarket.scanner.AutoMarketScannerClient; import com.automarket.scanner.config.ScannerConfig; import com.automarket.scanner.config.WatchedItem; import com.automarket.scanner.discord.DiscordNotifier; import com.automarket.scanner.scam.ScamDetector; import net.minecraft.client.MinecraftClient; import net.minecraft.client.network.ClientPlayerEntity; import net.minecraft.item.ItemStack; import net.minecraft.screen.ScreenHandler; import net.minecraft.screen.slot.Slot; import net.minecraft.text.Text; import java.util.ArrayList; import java.util.List; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class MarketScanner { private final ScannerConfig config; private final DiscordNotifier discordNotifier; private final ScamDetector scamDetector; private final ExecutorService executor; private int tickCounter = 0; private boolean isScanning = false; private List lastFoundOffers = new ArrayList<>(); public MarketScanner(ScannerConfig config) { this.config = config; this.discordNotifier = new DiscordNotifier(config); this.scamDetector = new ScamDetector(); this.executor = Executors.newFixedThreadPool(4); } public void tick() { MinecraftClient client = MinecraftClient.getInstance(); if (client.player == null || client.currentScreen == null) { return; } tickCounter++; if (tickCounter >= config.scanInterval * 20) { tickCounter = 0; if (!isScanning) { scanCurrentScreen(); } } } public void scanCurrentScreen() { MinecraftClient client = MinecraftClient.getInstance(); ClientPlayerEntity player = client.player; if (player == null || client.currentScreen == null) { return; } ScreenHandler handler = player.currentScreenHandler; if (handler == null) { return; } isScanning = true; config.incrementStat("totalScans"); CompletableFuture.runAsync(() -> { try { List offers = new ArrayList<>(); for (Slot slot : handler.slots) { ItemStack stack = slot.getStack(); if (stack.isEmpty()) { continue; } MarketOffer offer = parseMarketOffer(stack, slot.id); if (offer != null) { offers.add(offer); } } processOffers(offers); } catch (Exception e) { AutoMarketScannerClient.LOGGER.error("Error during market scan", e); } finally { isScanning = false; } }, executor); } private MarketOffer parseMarketOffer(ItemStack stack, int slotId) { Text displayName = stack.getName(); List lore = stack.getTooltip(null, net.minecraft.client.item.TooltipType.BASIC); double price = extractPrice(lore); int quantity = stack.getCount(); if (price <= 0) { return null; } return new MarketOffer(stack, slotId, price, quantity); } private double extractPrice(List lore) { for (Text line : lore) { String text = line.getString(); if (text.contains("$") || text.toLowerCase().contains("price") || text.toLowerCase().contains("cena")) { String cleaned = text.replaceAll("[^0-9.]", ""); try { return Double.parseDouble(cleaned); } catch (NumberFormatException e) { continue; } } } return 0; } private void processOffers(List offers) { lastFoundOffers.clear(); for (MarketOffer offer : offers) { for (WatchedItem watched : config.watchlist) { if (!watched.matches(offer.itemStack)) { continue; } double priceToCompare = config.comparePerUnit ? offer.getPricePerUnit() : offer.price; if (priceToCompare <= watched.maxPrice) { double discount = ((watched.maxPrice - priceToCompare) / watched.maxPrice) * 100; if (discount >= config.minDiscountPercent) { offer.isGoodDeal = true; offer.discount = discount; lastFoundOffers.add(offer); config.incrementStat("dealsFound"); notifyDeal(offer, watched); } } if (config.enableScamDetection && scamDetector.isScam(offer.itemStack, watched)) { offer.isScam = true; config.incrementStat("scamsDetected"); notifyScam(offer); } } } } private void notifyDeal(MarketOffer offer, WatchedItem watched) { MinecraftClient client = MinecraftClient.getInstance(); if (config.enableNotifications && client.player != null) { client.execute(() -> { client.player.sendMessage( Text.translatable("text.automarketscanner.found_deal") .append(" ") .append(offer.itemStack.getName()) .append(String.format(" - %.0f%% off", offer.discount)), false ); }); } if (!config.discordWebhook.isEmpty()) { discordNotifier.sendDealNotification(offer, watched); } } private void notifyScam(MarketOffer offer) { MinecraftClient client = MinecraftClient.getInstance(); if (config.enableNotifications && client.player != null) { client.execute(() -> { client.player.sendMessage( Text.translatable("text.automarketscanner.scam_detected") .append(" ") .append(offer.itemStack.getName()), false ); }); } if (!config.discordWebhook.isEmpty()) { discordNotifier.sendScamNotification(offer); } } public List getLastFoundOffers() { return new ArrayList<>(lastFoundOffers); } public boolean isScanning() { return isScanning; } }