Fix UI sending chat history to backend (opea-project#2225)

Signed-off-by: WenjiaoYue <wenjiao.yue@intel.com>

Author: WenjiaoYue

ChatQnA/ui/svelte/src/lib/network/chat/Network.ts

@@ -18,7 +18,7 @@ import { SSE } from "sse.js";
 const CHAT_BASE_URL = env.CHAT_BASE_URL;
 const MODEL_ID = env.MODEL_ID;
 
-export async function fetchTextStream(query: string) {
+export async function fetchTextStream(query: object) {
 	let payload = {};
 	let url = "";
 	let modelId = "meta-llama/Meta-Llama-3-8B-Instruct";

ChatQnA/ui/svelte/src/routes/+page.svelte

@@ -102,7 +102,7 @@
 		return decoded;
 	}
 
-	const callTextStream = async (query: string, startSendTime: number) => {
+	const callTextStream = async (query: object, startSendTime: number) => {
 		try {
 			const eventSource = await fetchTextStream(query);
 			eventSource.addEventListener("error", (e: any) => {
@@ -179,6 +179,22 @@
 		}
 	};
 
+	function mapRole(r: number): "user" | "assistant" | "system" {
+		if (r === 1) return "user";
+		if (r === 0) return "assistant";
+		return "system";
+	}
+
+	function multiMessages(
+		history: any[]
+	): { role: "user" | "assistant" | "system"; content: string }[] {
+		return history.map((m) => ({
+			role: mapRole(m.role),
+			content:
+				typeof m.content === "string" ? m.content : String(m.content ?? ""),
+		}));
+	}
+
 	const handleTextSubmit = async () => {
 		loading = true;
 		const newMessage = {
@@ -192,7 +208,7 @@
 		storeMessages();
 		query = "";
 
-		await callTextStream(newMessage.content, getCurrentTimeStamp());
+		await callTextStream(multiMessages(chatMessages), getCurrentTimeStamp());
 
 		scrollToBottom(scrollToDiv);
 		storeMessages();