1 files changed, 78 insertions, 74 deletions
diff --git a/src/main/kotlin/repo/HypixelStaticData.kt b/src/main/kotlin/repo/HypixelStaticData.kt
index 5c2a2fc..727a962 100644
--- a/src/main/kotlin/repo/HypixelStaticData.kt
+++ b/src/main/kotlin/repo/HypixelStaticData.kt
@@ -1,5 +1,3 @@
-
-
 package moe.nea.firmament.repo
 
 import io.ktor.client.call.body
@@ -21,87 +19,93 @@ import moe.nea.firmament.util.SkyblockId
 import moe.nea.firmament.util.async.waitForInput
 
 object HypixelStaticData {
-    private val logger = LogManager.getLogger("Firmament.HypixelStaticData")
-    private val moulberryBaseUrl = "https://moulberry.codes"
-    private val hypixelApiBaseUrl = "https://api.hypixel.net"
-    var lowestBin: Map<SkyblockId, Double> = mapOf()
-        private set
-    var bazaarData: Map<SkyblockId, BazaarData> = mapOf()
-        private set
-    var collectionData: Map<String, CollectionSkillData> = mapOf()
-        private set
+	private val logger = LogManager.getLogger("Firmament.HypixelStaticData")
+	private val moulberryBaseUrl = "https://moulberry.codes"
+	private val hypixelApiBaseUrl = "https://api.hypixel.net"
+	var lowestBin: Map<SkyblockId, Double> = mapOf()
+		private set
+	var bazaarData: Map<SkyblockId, BazaarData> = mapOf()
+		private set
+	var collectionData: Map<String, CollectionSkillData> = mapOf()
+		private set
+
+	@Serializable
+	data class BazaarData(
+		@SerialName("product_id")
+		val productId: SkyblockId.BazaarStock,
+		@SerialName("quick_status")
+		val quickStatus: BazaarStatus,
+	)
 
-    @Serializable
-    data class BazaarData(
-        @SerialName("product_id")
-        val productId: SkyblockId.BazaarStock,
-        @SerialName("quick_status")
-        val quickStatus: BazaarStatus,
-    )
+	@Serializable
+	data class BazaarStatus(
+		val sellPrice: Double,
+		val sellVolume: Long,
+		val sellMovingWeek: Long,
+		val sellOrders: Long,
+		val buyPrice: Double,
+		val buyVolume: Long,
+		val buyMovingWeek: Long,
+		val buyOrders: Long
+	)
 
-    @Serializable
-    data class BazaarStatus(
-        val sellPrice: Double,
-        val sellVolume: Long,
-        val sellMovingWeek: Long,
-        val sellOrders: Long,
-        val buyPrice: Double,
-        val buyVolume: Long,
-        val buyMovingWeek: Long,
-        val buyOrders: Long
-    )
+	@Serializable
+	private data class BazaarResponse(
+		val success: Boolean,
+		val products: Map<SkyblockId.BazaarStock, BazaarData> = mapOf(),
+	)
 
-    @Serializable
-    private data class BazaarResponse(
-        val success: Boolean,
-        val products: Map<SkyblockId.BazaarStock, BazaarData> = mapOf(),
-    )
+	fun getPriceOfItem(item: SkyblockId): Double? = bazaarData[item]?.quickStatus?.buyPrice ?: lowestBin[item]
 
-    fun getPriceOfItem(item: SkyblockId): Double? = bazaarData[item]?.quickStatus?.buyPrice ?: lowestBin[item]
+	fun hasBazaarStock(item: SkyblockId): Boolean {
+		return item in bazaarData
+	}
 
+	fun hasAuctionHouseOffers(item: SkyblockId): Boolean {
+		return (item in lowestBin) // TODO: || (item in biddableAuctionPrices)
+	}
 
-    fun spawnDataCollectionLoop() {
-        Firmament.coroutineScope.launch {
-            logger.info("Updating collection data")
-            updateCollectionData()
-        }
-        Firmament.coroutineScope.launch {
-            while (true) {
-                logger.info("Updating NEU prices")
-                updatePrices()
-                withTimeoutOrNull(10.minutes) { waitForInput(IKeyBinding.ofKeyCode(GLFW.GLFW_KEY_U)) }
-            }
-        }
-    }
+	fun spawnDataCollectionLoop() {
+		Firmament.coroutineScope.launch {
+			logger.info("Updating collection data")
+			updateCollectionData()
+		}
+		Firmament.coroutineScope.launch {
+			while (true) {
+				logger.info("Updating NEU prices")
+				updatePrices()
+			}
+		}
+	}
 
-    private suspend fun updatePrices() {
-        awaitAll(
-            Firmament.coroutineScope.async { fetchBazaarPrices() },
-            Firmament.coroutineScope.async { fetchPricesFromMoulberry() },
-        )
-    }
+	private suspend fun updatePrices() {
+		awaitAll(
+			Firmament.coroutineScope.async { fetchBazaarPrices() },
+			Firmament.coroutineScope.async { fetchPricesFromMoulberry() },
+		)
+	}
 
-    private suspend fun fetchPricesFromMoulberry() {
-        lowestBin = Firmament.httpClient.get("$moulberryBaseUrl/lowestbin.json")
-            .body<Map<SkyblockId, Double>>()
-    }
+	private suspend fun fetchPricesFromMoulberry() {
+		lowestBin = Firmament.httpClient.get("$moulberryBaseUrl/lowestbin.json")
+			.body<Map<SkyblockId, Double>>()
+	}
 
-    private suspend fun fetchBazaarPrices() {
-        val response = Firmament.httpClient.get("$hypixelApiBaseUrl/skyblock/bazaar").body<BazaarResponse>()
-        if (!response.success) {
-            logger.warn("Retrieved unsuccessful bazaar data")
-        }
-        bazaarData = response.products.mapKeys { it.key.toRepoId() }
-    }
+	private suspend fun fetchBazaarPrices() {
+		val response = Firmament.httpClient.get("$hypixelApiBaseUrl/skyblock/bazaar").body<BazaarResponse>()
+		if (!response.success) {
+			logger.warn("Retrieved unsuccessful bazaar data")
+		}
+		bazaarData = response.products.mapKeys { it.key.toRepoId() }
+	}
 
-    private suspend fun updateCollectionData() {
-        val response =
-            Firmament.httpClient.get("$hypixelApiBaseUrl/resources/skyblock/collections").body<CollectionResponse>()
-        if (!response.success) {
-            logger.warn("Retrieved unsuccessful collection data")
-        }
-        collectionData = response.collections
-        logger.info("Downloaded ${collectionData.values.sumOf { it.items.values.size }} collections")
-    }
+	private suspend fun updateCollectionData() {
+		val response =
+			Firmament.httpClient.get("$hypixelApiBaseUrl/resources/skyblock/collections").body<CollectionResponse>()
+		if (!response.success) {
+			logger.warn("Retrieved unsuccessful collection data")
+		}
+		collectionData = response.collections
+		logger.info("Downloaded ${collectionData.values.sumOf { it.items.values.size }} collections")
+	}
 
 }