feat: 引擎等MQ场景接入SCS框架 #7443 接入websocket和auth服务

src/backend/ci/core/websocket/biz-websocket/src/main/kotlin/com/tencent/devops/websocket/configuration/WebsocketConfiguration.kt

@@ -71,9 +71,7 @@ class WebsocketConfiguration {
     }
 
     @Bean
-    fun transferDispatch(
-        streamBridge: StreamBridge
-    ): TransferDispatch {
-        return TransferDispatch(streamBridge)
+    fun transferDispatch(): TransferDispatch {
+        return TransferDispatch()
     }
 }

src/backend/ci/core/websocket/biz-websocket/src/main/kotlin/com/tencent/devops/websocket/controller/UserWebsocketResourceImpl.kt

@@ -32,13 +32,14 @@ import com.tencent.devops.common.web.RestResource
 import com.tencent.devops.websocket.api.UserWebsocketResource
 import com.tencent.devops.websocket.servcie.WebsocketService
 import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.cloud.stream.function.StreamBridge
 
 @RestResource
 class UserWebsocketResourceImpl @Autowired constructor(
-    val websocketService: WebsocketService
-
+    val websocketService: WebsocketService,
+    val streamBridge: StreamBridge
 ) : UserWebsocketResource {
     override fun clearSession(userId: String, sessionId: String): Result<Boolean> {
-        return websocketService.clearAllBySession(userId, sessionId)
+        return websocketService.clearAllBySession(streamBridge, userId, sessionId)
     }
 }

src/backend/ci/core/websocket/biz-websocket/src/main/kotlin/com/tencent/devops/websocket/handler/SessionHandler.kt

@@ -63,7 +63,7 @@ class SessionHandler @Autowired constructor(
             super.afterConnectionClosed(session, closeStatus)
         } else {
             logger.info("connection closed closeStatus[$closeStatus] user[$userId] page[$page], session[$sessionId]")
-            websocketService.clearAllBySession(userId, sessionId)
+            websocketService.removeCacheSession(sessionId)
         }
 
         super.afterConnectionClosed(session, closeStatus)