archive
/
AquaDX
mirror of https://github.com/hykilpikonna/AquaDX
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

[O] Split matching apis

matching
Azalea 2024-12-29 05:16:09 -05:00
parent 8a1e17ecd3
commit 667abf2131
2 changed files with 55 additions and 43 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
src/main/java/icu/samnyan/aqua/sega/chusan/ChusanApis.kt
View File

@ -2,8 +2,6 @@ package icu.samnyan.aqua.sega.chusan
import ext.*
import icu.samnyan.aqua.sega.chusan.model.request.UserCMissionResp
import icu.samnyan.aqua.sega.chusan.model.response.data.MatchingMemberInfo
import icu.samnyan.aqua.sega.chusan.model.response.data.MatchingWaitState
import icu.samnyan.aqua.sega.chusan.model.response.data.UserEmoney
import icu.samnyan.aqua.sega.chusan.model.userdata.UserCharge
import icu.samnyan.aqua.sega.chusan.model.userdata.UserItem
@ -12,7 +10,9 @@ import icu.samnyan.aqua.sega.general.model.response.UserRecentRating
import java.time.format.DateTimeFormatter
@Suppress("UNCHECKED_CAST")
val chusanInit: ChusanController.() -> Unit = {
fun ChusanController.chusanInit() {
matchingApiInit()
// Stub handlers
"GetGameRanking" { """{"type":"${data["type"]}","length":"0","gameRankingList":[]}""" }
"GetGameIdlist" { """{"type":"${data["type"]}","length":"0","gameIdlistList":[]}""" }
@ -31,46 +31,6 @@ val chusanInit: ChusanController.() -> Unit = {
"CMUpsertUserPrint" { """{"returnCode":1,"orderId":"0","serialId":"FAKECARDIMAG12345678","apiName":"CMUpsertUserPrintApi"}""" }
"CMUpsertUserPrintlog" { """{"returnCode":1,"orderId":"0","serialId":"FAKECARDIMAG12345678","apiName":"CMUpsertUserPrintlogApi"}""" }
// Matching
data class MatchingRoom(val members: MutableList<MatchingMemberInfo>, val startTime: Long)
val matchingRooms = mutableMapOf<Int, MatchingRoom>()
var matchingLast = 0
val matchingTime = 120 // Seconds
"BeginMatching" {
val memberInfo = parsing { mapper.convert<MatchingMemberInfo>(data["matchingMemberInfo"] as JDict) }
// Check if there are any room available with less than 4 members and not started
var id = matchingRooms.entries.find { it.value.members.size < 4 && it.value.startTime == 0L }?.key
if (id == null) {
matchingLast += 1
id = matchingLast
matchingRooms[id] = MatchingRoom(mutableListOf(memberInfo), millis())
}
mapOf("roomId" to id, "matchingWaitState" to MatchingWaitState(listOf(memberInfo)))
}
"GetMatchingState" api@ {
val roomId = parsing { data["roomId"]!!.int }
val room = matchingRooms[roomId] ?: return@api null
val dt = matchingTime - (millis() - room.startTime) / 1000
val ended = room.members.size == 4 || dt <= 0
mapOf("roomId" to roomId, "matchingWaitState" to MatchingWaitState(room.members, ended, dt.int, 1))
}
"EndMatching" api@ {
val roomId = parsing { data["roomId"]!!.int }
val room = matchingRooms[roomId] ?: return@api null
mapOf(
"matchingMemberInfoList" to room.members,
"matchingMemberRoleList" to room.members.indices.map { mapOf("role" to it) },
"matchingResult" to 1,
"reflectorUri" to "http://reflector.naominet.live:18080/"
)
}
// User handlers
"GetUserData" {
db.userData.findByCard_ExtId(uid)()?.let{ u -> mapOf("userId" to uid, "userData" to u) }

52
src/main/java/icu/samnyan/aqua/sega/chusan/ChusanMatchingApis.kt 100644
View File

@ -0,0 +1,52 @@
package icu.samnyan.aqua.sega.chusan
import ext.JDict
import ext.int
import ext.millis
import ext.parsing
import icu.samnyan.aqua.sega.chusan.model.response.data.MatchingMemberInfo
import icu.samnyan.aqua.sega.chusan.model.response.data.MatchingWaitState
@Suppress("UNCHECKED_CAST")
fun ChusanController.matchingApiInit() {
// Matching
data class MatchingRoom(val members: MutableList<MatchingMemberInfo>, val startTime: Long)
val matchingRooms = mutableMapOf<Int, MatchingRoom>()
var matchingLast = 0
val matchingTime = 120 // Seconds
"BeginMatching" {
val memberInfo = parsing { mapper.convert<MatchingMemberInfo>(data["matchingMemberInfo"] as JDict) }
// Check if there are any room available with less than 4 members and not started
var id = matchingRooms.entries.find { it.value.members.size < 4 && it.value.startTime == 0L }?.key
if (id == null) {
matchingLast += 1
id = matchingLast
matchingRooms[id] = MatchingRoom(mutableListOf(memberInfo), millis())
}
mapOf("roomId" to id, "matchingWaitState" to MatchingWaitState(listOf(memberInfo)))
}
"GetMatchingState" api@ {
val roomId = parsing { data["roomId"]!!.int }
val room = matchingRooms[roomId] ?: return@api null
val dt = matchingTime - (millis() - room.startTime) / 1000
val ended = room.members.size == 4 || dt <= 0
mapOf("roomId" to roomId, "matchingWaitState" to MatchingWaitState(room.members, ended, dt.int, 1))
}
"EndMatching" api@ {
val roomId = parsing { data["roomId"]!!.int }
val room = matchingRooms[roomId] ?: return@api null
mapOf(
"matchingMemberInfoList" to room.members,
"matchingMemberRoleList" to room.members.indices.map { mapOf("role" to it) },
"matchingResult" to 1,
"reflectorUri" to "http://reflector.naominet.live:18080/"
)
}
}