aboutsummaryrefslogtreecommitdiff
path: root/src/main/kotlin/moe/nea/firmament/repo/HypixelStaticData.kt
diff options
context:
space:
mode:
authorLinnea Gräf <nea@nea.moe>2024-08-28 19:04:24 +0200
committerLinnea Gräf <nea@nea.moe>2024-08-28 19:04:24 +0200
commitd2f240ff0ca0d27f417f837e706c781a98c31311 (patch)
tree0db7aff6cc14deaf36eed83889d59fd6b3a6f599 /src/main/kotlin/moe/nea/firmament/repo/HypixelStaticData.kt
parenta6906308163aa3b2d18fa1dc1aa71ac9bbcc83ab (diff)
downloadfirmament-d2f240ff0ca0d27f417f837e706c781a98c31311.tar.gz
firmament-d2f240ff0ca0d27f417f837e706c781a98c31311.tar.bz2
firmament-d2f240ff0ca0d27f417f837e706c781a98c31311.zip
Refactor source layout
Introduce compat source sets and move all kotlin sources to the main directory [no changelog]
Diffstat (limited to 'src/main/kotlin/moe/nea/firmament/repo/HypixelStaticData.kt')
-rw-r--r--src/main/kotlin/moe/nea/firmament/repo/HypixelStaticData.kt107
1 files changed, 0 insertions, 107 deletions
diff --git a/src/main/kotlin/moe/nea/firmament/repo/HypixelStaticData.kt b/src/main/kotlin/moe/nea/firmament/repo/HypixelStaticData.kt
deleted file mode 100644
index 5c2a2fc..0000000
--- a/src/main/kotlin/moe/nea/firmament/repo/HypixelStaticData.kt
+++ /dev/null
@@ -1,107 +0,0 @@
-
-
-package moe.nea.firmament.repo
-
-import io.ktor.client.call.body
-import io.ktor.client.request.get
-import org.apache.logging.log4j.LogManager
-import org.lwjgl.glfw.GLFW
-import kotlinx.coroutines.async
-import kotlinx.coroutines.awaitAll
-import kotlinx.coroutines.launch
-import kotlinx.coroutines.withTimeoutOrNull
-import kotlinx.serialization.SerialName
-import kotlinx.serialization.Serializable
-import kotlin.time.Duration.Companion.minutes
-import moe.nea.firmament.Firmament
-import moe.nea.firmament.apis.CollectionResponse
-import moe.nea.firmament.apis.CollectionSkillData
-import moe.nea.firmament.keybindings.IKeyBinding
-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
-
- @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
- 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 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)) }
- }
- }
- }
-
- 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 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")
- }
-
-}