fix: 解决关闭公共聊天后访问后仍然可以聊天的问题 (#40)

Author: LIlGG

src/main/java/run/halo/live2d/chat/AiChatEndpoint.java

@@ -82,21 +82,20 @@ private Mono<ServerResponse> chatProcess(ServerRequest request) {
             );
     }
 
+
     private Flux<ServerSentEvent<ChatResult>> chatCompletion(ChatRequest body) {
         return reactiveSettingFetcher.fetch("aichat", AiChatConfig.class)
-            .doOnNext(aiChatConfig -> ReactiveSecurityContextHolder.getContext()
+            .map(aiChatConfig -> ReactiveSecurityContextHolder.getContext()
                 .map(SecurityContext::getAuthentication)
-                .doOnNext(authentication -> {
+                .flatMapMany(authentication -> {
                     if (!aiChatConfig.aiChatBaseSetting.isAnonymous && !isAuthenticated(
                         authentication)) {
                         throw new ResponseStatusException(HttpStatus.UNAUTHORIZED, "请先登录");
                     }
+                    String systemMessage = aiChatConfig.aiChatBaseSetting.systemMessage;
+                    List<ChatMessage> messages = this.buildChatMessage(systemMessage, body);
+                    return aiChatService.streamChatCompletion(messages);
                 }))
-            .map(aiChatConfig -> {
-                String systemMessage = aiChatConfig.aiChatBaseSetting.systemMessage;
-                List<ChatMessage> messages = this.buildChatMessage(systemMessage, body);
-                return aiChatService.streamChatCompletion(messages);
-            })
             .flatMapMany(Flux::from);
     }