Shamrock: fix #180

This commit is contained in:
WhiteChi 2024-01-01 00:37:12 +08:00
parent c28c9981c4
commit 8df799a6e4
2 changed files with 11 additions and 1 deletions

View File

@ -131,6 +131,8 @@ internal object FavAddImageMsg: IActionHandler() {
val pb = ProtoUtils.decodeFromByteArray(data) val pb = ProtoUtils.decodeFromByteArray(data)
itemId = pb[2, 20009, 1].asUtf8String itemId = pb[2, 20009, 1].asUtf8String
} }
System.gc()
} }
return ok(PicInfo( return ok(PicInfo(

View File

@ -37,7 +37,7 @@ import kotlin.concurrent.timer
internal abstract class WebSocketClientServlet( internal abstract class WebSocketClientServlet(
url: String, url: String,
private val heartbeatInterval: Long, private val heartbeatInterval: Long,
wsHeaders: Map<String, String> private val wsHeaders: Map<String, String>
) : BaseTransmitServlet, WebSocketClient(URI(url), wsHeaders) { ) : BaseTransmitServlet, WebSocketClient(URI(url), wsHeaders) {
private val sendLock = Mutex() private val sendLock = Mutex()
@ -85,6 +85,14 @@ internal abstract class WebSocketClientServlet(
} }
override fun onClose(code: Int, reason: String?, remote: Boolean) { override fun onClose(code: Int, reason: String?, remote: Boolean) {
if (code == 403) {
if (wsHeaders.containsKey("authorization")) {
val token = wsHeaders["authorization"]!!.substring(7)
LogCenter.log("WebSocketClient连接被拒绝, token: $token 失效", Level.WARN)
} else {
LogCenter.log("WebSocketClient连接被拒绝, 未设置token", Level.WARN)
}
}
LogCenter.log("WebSocketClient onClose: $code, $reason, $remote") LogCenter.log("WebSocketClient onClose: $code, $reason, $remote")
cancelFlowJobs() cancelFlowJobs()
} }