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

[F] Fix apis

pull/131/head
Azalea 2025-03-19 04:58:32 -04:00
parent b519537b69
commit aa6730b9da
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/icu/samnyan/aqua/net/transfer/TransferApis.kt
View File

@ -15,8 +15,7 @@ class TransferApis {
log.info("Transfer check: $allNet") log.info("Transfer check: $allNet")
mapOf("gameUrl" to allNet.gameUrl, "userId" to allNet.userId) mapOf("gameUrl" to allNet.gameUrl, "userId" to allNet.userId)
} catch (e: Exception) { } catch (e: Exception) {
log.error("Transfer check error", e) 400 - "Transfer check failed. Please check your host and keychip.\n${e.message}"
400 - "Transfer check error: ${e.message}"
} }
fun HttpServletResponse.initStream(): PrintWriter { fun HttpServletResponse.initStream(): PrintWriter {
@ -26,7 +25,7 @@ class TransferApis {
} }
fun PrintWriter.sendJson(m: Any) { fun PrintWriter.sendJson(m: Any) {
println("data: ${m.toJson()}\n") println(m.toJson())
flush() flush()
} }
@ -50,11 +49,14 @@ class TransferApis {
} }
} }
class PushReq(val client: AllNetClient, val data: String)
@API("/push") @API("/push")
fun push(@RB allNet: AllNetClient, data: String) = try { fun push(@RB obj: PushReq) = try {
val allNet = obj.client
log.info("Transfer push: $allNet") log.info("Transfer push: $allNet")
val broker = allNet.findDataBroker { log.info(it) } val broker = allNet.findDataBroker { log.info(it) }
broker.push(data) broker.push(obj.data)
mapOf("status" to "ok") mapOf("status" to "ok")
} catch (e: Exception) { } catch (e: Exception) {
log.error("Transfer push error", e) log.error("Transfer push error", e)