formatting

Author: reakaleek

src/Elastic.Documentation.Site/Assets/web-components/SearchOrAskAi/AskAi/chat.store.ts

@@ -95,5 +95,6 @@ export const chatStore = create<ChatState>((set) => ({
 }))
 
 export const useChatMessages = () => chatStore((state) => state.chatMessages)
-export const useConversationId = () => chatStore((state) => state.conversationId)
+export const useConversationId = () =>
+    chatStore((state) => state.conversationId)
 export const useChatActions = () => chatStore((state) => state.actions)

src/Elastic.Documentation.Site/Assets/web-components/SearchOrAskAi/AskAi/useAskAi.ts

@@ -136,7 +136,10 @@ export const useAskAi = (props: Props): UseAskAiResponse => {
                 setEvents([])
                 clearQueue()
                 lastSentQuestionRef.current = question
-                const payload = createAskAiRequest(question, props.conversationId)
+                const payload = createAskAiRequest(
+                    question,
+                    props.conversationId
+                )
 
                 try {
                     await sendMessage(payload)

src/api/Elastic.Documentation.Api.Infrastructure/Adapters/AskAi/LlmGatewayStreamTransformer.cs

@@ -2,9 +2,6 @@
 // Elasticsearch B.V licenses this file to you under the Apache 2.0 License.
 // See the LICENSE file in the project root for more information
 
-using System.Buffers;
-using System.IO.Pipelines;
-using System.Text;
 using System.Text.Json;
 using Elastic.Documentation.Api.Core.AskAi;
 using Microsoft.Extensions.Logging;
@@ -34,11 +31,6 @@ public class LlmGatewayStreamTransformer(ILogger<LlmGatewayStreamTransformer> lo
 		var id = message.GetProperty("id").GetString()!;
 		var messageData = message.GetProperty("data");
 
-		// LLM gateway does not emit conversation start events with thread IDs
-		// so we create a synthetic conversation start event here
-		if (conversationId is null)
-			return new AskAiEvent.ConversationStart(id, timestamp, Guid.NewGuid().ToString());
-
 		return type switch
 		{
 			"ai_message_chunk" when messageData.TryGetProperty("content", out var content) =>

src/api/Elastic.Documentation.Api.Infrastructure/Adapters/AskAi/StreamTransformerFactory.cs

@@ -39,9 +39,9 @@ private IStreamTransformer GetTransformer()
 	public string AgentId => GetTransformer().AgentId;
 	public string AgentProvider => GetTransformer().AgentProvider;
 
-	public async Task<Stream> TransformAsync(Stream rawStream, System.Diagnostics.Activity? parentActivity, CancellationToken cancellationToken = default)
+	public async Task<Stream> TransformAsync(Stream rawStream, string? conversationId, System.Diagnostics.Activity? parentActivity, Cancel cancellationToken = default)
 	{
 		var transformer = GetTransformer();
-		return await transformer.TransformAsync(rawStream, parentActivity, cancellationToken);
+		return await transformer.TransformAsync(rawStream, conversationId, parentActivity, cancellationToken);
 	}
 }