Chat.svelte 54 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094
  1. <script lang="ts">
  2. import { v4 as uuidv4 } from 'uuid';
  3. import { toast } from 'svelte-sonner';
  4. import mermaid from 'mermaid';
  5. import { PaneGroup, Pane, PaneResizer } from 'paneforge';
  6. import { getContext, onDestroy, onMount, tick } from 'svelte';
  7. const i18n: Writable<i18nType> = getContext('i18n');
  8. import { goto } from '$app/navigation';
  9. import { page } from '$app/stores';
  10. import { get, type Unsubscriber, type Writable } from 'svelte/store';
  11. import type { i18n as i18nType } from 'i18next';
  12. import { WEBUI_BASE_URL } from '$lib/constants';
  13. import {
  14. chatId,
  15. chats,
  16. config,
  17. type Model,
  18. models,
  19. tags as allTags,
  20. settings,
  21. showSidebar,
  22. WEBUI_NAME,
  23. banners,
  24. user,
  25. socket,
  26. showControls,
  27. showCallOverlay,
  28. currentChatPage,
  29. temporaryChatEnabled,
  30. mobile,
  31. showOverview,
  32. chatTitle,
  33. showArtifacts,
  34. tools
  35. } from '$lib/stores';
  36. import {
  37. convertMessagesToHistory,
  38. copyToClipboard,
  39. getMessageContentParts,
  40. extractSentencesForAudio,
  41. promptTemplate,
  42. splitStream,
  43. sleep,
  44. removeDetails,
  45. getPromptVariables
  46. } from '$lib/utils';
  47. import { generateChatCompletion } from '$lib/apis/ollama';
  48. import {
  49. addTagById,
  50. createNewChat,
  51. deleteTagById,
  52. deleteTagsById,
  53. getAllTags,
  54. getChatById,
  55. getChatList,
  56. getTagsById,
  57. updateChatById
  58. } from '$lib/apis/chats';
  59. import { generateOpenAIChatCompletion } from '$lib/apis/openai';
  60. import { processWeb, processWebSearch, processYoutubeVideo } from '$lib/apis/retrieval';
  61. import { createOpenAITextStream } from '$lib/apis/streaming';
  62. import { queryMemory } from '$lib/apis/memories';
  63. import { getAndUpdateUserLocation, getUserSettings } from '$lib/apis/users';
  64. import {
  65. chatCompleted,
  66. generateQueries,
  67. chatAction,
  68. generateMoACompletion,
  69. stopTask
  70. } from '$lib/apis';
  71. import { getTools } from '$lib/apis/tools';
  72. import Banner from '../common/Banner.svelte';
  73. import MessageInput from '$lib/components/chat/MessageInput.svelte';
  74. import Messages from '$lib/components/chat/Messages.svelte';
  75. import Navbar from '$lib/components/chat/Navbar.svelte';
  76. import ChatControls from './ChatControls.svelte';
  77. import EventConfirmDialog from '../common/ConfirmDialog.svelte';
  78. import Placeholder from './Placeholder.svelte';
  79. import NotificationToast from '../NotificationToast.svelte';
  80. import Spinner from '../common/Spinner.svelte';
  81. export let chatIdProp = '';
  82. let loading = false;
  83. const eventTarget = new EventTarget();
  84. let controlPane;
  85. let controlPaneComponent;
  86. let autoScroll = true;
  87. let processing = '';
  88. let messagesContainerElement: HTMLDivElement;
  89. let navbarElement;
  90. let showEventConfirmation = false;
  91. let eventConfirmationTitle = '';
  92. let eventConfirmationMessage = '';
  93. let eventConfirmationInput = false;
  94. let eventConfirmationInputPlaceholder = '';
  95. let eventConfirmationInputValue = '';
  96. let eventCallback = null;
  97. let chatIdUnsubscriber: Unsubscriber | undefined;
  98. let selectedModels = [''];
  99. let atSelectedModel: Model | undefined;
  100. let selectedModelIds = [];
  101. $: selectedModelIds = atSelectedModel !== undefined ? [atSelectedModel.id] : selectedModels;
  102. let selectedToolIds = [];
  103. let imageGenerationEnabled = false;
  104. let codeInterpreterEnabled = false;
  105. let webSearchEnabled = false;
  106. let chat = null;
  107. let tags = [];
  108. let history = {
  109. messages: {},
  110. currentId: null
  111. };
  112. let taskId = null;
  113. // Chat Input
  114. let prompt = '';
  115. let chatFiles = [];
  116. let files = [];
  117. let params = {};
  118. $: if (chatIdProp) {
  119. (async () => {
  120. loading = true;
  121. console.log(chatIdProp);
  122. prompt = '';
  123. files = [];
  124. selectedToolIds = [];
  125. webSearchEnabled = false;
  126. imageGenerationEnabled = false;
  127. if (chatIdProp && (await loadChat())) {
  128. await tick();
  129. loading = false;
  130. if (localStorage.getItem(`chat-input-${chatIdProp}`)) {
  131. try {
  132. const input = JSON.parse(localStorage.getItem(`chat-input-${chatIdProp}`));
  133. prompt = input.prompt;
  134. files = input.files;
  135. selectedToolIds = input.selectedToolIds;
  136. webSearchEnabled = input.webSearchEnabled;
  137. imageGenerationEnabled = input.imageGenerationEnabled;
  138. } catch (e) {}
  139. }
  140. window.setTimeout(() => scrollToBottom(), 0);
  141. const chatInput = document.getElementById('chat-input');
  142. chatInput?.focus();
  143. } else {
  144. await goto('/');
  145. }
  146. })();
  147. }
  148. $: if (selectedModels && chatIdProp !== '') {
  149. saveSessionSelectedModels();
  150. }
  151. const saveSessionSelectedModels = () => {
  152. if (selectedModels.length === 0 || (selectedModels.length === 1 && selectedModels[0] === '')) {
  153. return;
  154. }
  155. sessionStorage.selectedModels = JSON.stringify(selectedModels);
  156. console.log('saveSessionSelectedModels', selectedModels, sessionStorage.selectedModels);
  157. };
  158. $: if (selectedModels) {
  159. setToolIds();
  160. }
  161. const setToolIds = async () => {
  162. if (!$tools) {
  163. tools.set(await getTools(localStorage.token));
  164. }
  165. if (selectedModels.length !== 1) {
  166. return;
  167. }
  168. const model = $models.find((m) => m.id === selectedModels[0]);
  169. if (model) {
  170. selectedToolIds = (model?.info?.meta?.toolIds ?? []).filter((id) =>
  171. $tools.find((t) => t.id === id)
  172. );
  173. }
  174. };
  175. const showMessage = async (message) => {
  176. const _chatId = JSON.parse(JSON.stringify($chatId));
  177. let _messageId = JSON.parse(JSON.stringify(message.id));
  178. let messageChildrenIds = history.messages[_messageId].childrenIds;
  179. while (messageChildrenIds.length !== 0) {
  180. _messageId = messageChildrenIds.at(-1);
  181. messageChildrenIds = history.messages[_messageId].childrenIds;
  182. }
  183. history.currentId = _messageId;
  184. await tick();
  185. await tick();
  186. await tick();
  187. const messageElement = document.getElementById(`message-${message.id}`);
  188. if (messageElement) {
  189. messageElement.scrollIntoView({ behavior: 'smooth' });
  190. }
  191. await tick();
  192. saveChatHandler(_chatId);
  193. };
  194. const chatEventHandler = async (event, cb) => {
  195. console.log(event);
  196. if (event.chat_id === $chatId) {
  197. await tick();
  198. let message = history.messages[event.message_id];
  199. if (message) {
  200. const type = event?.data?.type ?? null;
  201. const data = event?.data?.data ?? null;
  202. if (type === 'status') {
  203. if (message?.statusHistory) {
  204. message.statusHistory.push(data);
  205. } else {
  206. message.statusHistory = [data];
  207. }
  208. } else if (type === 'source' || type === 'citation') {
  209. if (data?.type === 'code_execution') {
  210. // Code execution; update existing code execution by ID, or add new one.
  211. if (!message?.code_executions) {
  212. message.code_executions = [];
  213. }
  214. const existingCodeExecutionIndex = message.code_executions.findIndex(
  215. (execution) => execution.id === data.id
  216. );
  217. if (existingCodeExecutionIndex !== -1) {
  218. message.code_executions[existingCodeExecutionIndex] = data;
  219. } else {
  220. message.code_executions.push(data);
  221. }
  222. message.code_executions = message.code_executions;
  223. } else {
  224. // Regular source.
  225. if (message?.sources) {
  226. message.sources.push(data);
  227. } else {
  228. message.sources = [data];
  229. }
  230. }
  231. } else if (type === 'chat:completion') {
  232. chatCompletionEventHandler(data, message, event.chat_id);
  233. } else if (type === 'chat:title') {
  234. chatTitle.set(data);
  235. currentChatPage.set(1);
  236. await chats.set(await getChatList(localStorage.token, $currentChatPage));
  237. } else if (type === 'chat:tags') {
  238. chat = await getChatById(localStorage.token, $chatId);
  239. allTags.set(await getAllTags(localStorage.token));
  240. } else if (type === 'message') {
  241. message.content += data.content;
  242. } else if (type === 'replace') {
  243. message.content = data.content;
  244. } else if (type === 'action') {
  245. if (data.action === 'continue') {
  246. const continueButton = document.getElementById('continue-response-button');
  247. if (continueButton) {
  248. continueButton.click();
  249. }
  250. }
  251. } else if (type === 'confirmation') {
  252. eventCallback = cb;
  253. eventConfirmationInput = false;
  254. showEventConfirmation = true;
  255. eventConfirmationTitle = data.title;
  256. eventConfirmationMessage = data.message;
  257. } else if (type === 'execute') {
  258. eventCallback = cb;
  259. try {
  260. // Use Function constructor to evaluate code in a safer way
  261. const asyncFunction = new Function(`return (async () => { ${data.code} })()`);
  262. const result = await asyncFunction(); // Await the result of the async function
  263. if (cb) {
  264. cb(result);
  265. }
  266. } catch (error) {
  267. console.error('Error executing code:', error);
  268. }
  269. } else if (type === 'input') {
  270. eventCallback = cb;
  271. eventConfirmationInput = true;
  272. showEventConfirmation = true;
  273. eventConfirmationTitle = data.title;
  274. eventConfirmationMessage = data.message;
  275. eventConfirmationInputPlaceholder = data.placeholder;
  276. eventConfirmationInputValue = data?.value ?? '';
  277. } else if (type === 'notification') {
  278. const toastType = data?.type ?? 'info';
  279. const toastContent = data?.content ?? '';
  280. if (toastType === 'success') {
  281. toast.success(toastContent);
  282. } else if (toastType === 'error') {
  283. toast.error(toastContent);
  284. } else if (toastType === 'warning') {
  285. toast.warning(toastContent);
  286. } else {
  287. toast.info(toastContent);
  288. }
  289. } else {
  290. console.log('Unknown message type', data);
  291. }
  292. history.messages[event.message_id] = message;
  293. }
  294. }
  295. };
  296. const onMessageHandler = async (event: {
  297. origin: string;
  298. data: { type: string; text: string };
  299. }) => {
  300. if (event.origin !== window.origin) {
  301. return;
  302. }
  303. // Replace with your iframe's origin
  304. if (event.data.type === 'input:prompt') {
  305. console.debug(event.data.text);
  306. const inputElement = document.getElementById('chat-input');
  307. if (inputElement) {
  308. prompt = event.data.text;
  309. inputElement.focus();
  310. }
  311. }
  312. if (event.data.type === 'action:submit') {
  313. console.debug(event.data.text);
  314. if (prompt !== '') {
  315. await tick();
  316. submitPrompt(prompt);
  317. }
  318. }
  319. if (event.data.type === 'input:prompt:submit') {
  320. console.debug(event.data.text);
  321. if (prompt !== '') {
  322. await tick();
  323. submitPrompt(event.data.text);
  324. }
  325. }
  326. };
  327. onMount(async () => {
  328. console.log('mounted');
  329. window.addEventListener('message', onMessageHandler);
  330. $socket?.on('chat-events', chatEventHandler);
  331. if (!$chatId) {
  332. chatIdUnsubscriber = chatId.subscribe(async (value) => {
  333. if (!value) {
  334. await initNewChat();
  335. }
  336. });
  337. } else {
  338. if ($temporaryChatEnabled) {
  339. await goto('/');
  340. }
  341. }
  342. if (localStorage.getItem(`chat-input-${chatIdProp}`)) {
  343. try {
  344. const input = JSON.parse(localStorage.getItem(`chat-input-${chatIdProp}`));
  345. prompt = input.prompt;
  346. files = input.files;
  347. selectedToolIds = input.selectedToolIds;
  348. webSearchEnabled = input.webSearchEnabled;
  349. imageGenerationEnabled = input.imageGenerationEnabled;
  350. } catch (e) {
  351. prompt = '';
  352. files = [];
  353. selectedToolIds = [];
  354. webSearchEnabled = false;
  355. imageGenerationEnabled = false;
  356. }
  357. }
  358. showControls.subscribe(async (value) => {
  359. if (controlPane && !$mobile) {
  360. try {
  361. if (value) {
  362. controlPaneComponent.openPane();
  363. } else {
  364. controlPane.collapse();
  365. }
  366. } catch (e) {
  367. // ignore
  368. }
  369. }
  370. if (!value) {
  371. showCallOverlay.set(false);
  372. showOverview.set(false);
  373. showArtifacts.set(false);
  374. }
  375. });
  376. const chatInput = document.getElementById('chat-input');
  377. chatInput?.focus();
  378. chats.subscribe(() => {});
  379. });
  380. onDestroy(() => {
  381. chatIdUnsubscriber?.();
  382. window.removeEventListener('message', onMessageHandler);
  383. $socket?.off('chat-events', chatEventHandler);
  384. });
  385. // File upload functions
  386. const uploadGoogleDriveFile = async (fileData) => {
  387. console.log('Starting uploadGoogleDriveFile with:', {
  388. id: fileData.id,
  389. name: fileData.name,
  390. url: fileData.url,
  391. headers: {
  392. Authorization: `Bearer ${token}`
  393. }
  394. });
  395. // Validate input
  396. if (!fileData?.id || !fileData?.name || !fileData?.url || !fileData?.headers?.Authorization) {
  397. throw new Error('Invalid file data provided');
  398. }
  399. const tempItemId = uuidv4();
  400. const fileItem = {
  401. type: 'file',
  402. file: '',
  403. id: null,
  404. url: fileData.url,
  405. name: fileData.name,
  406. collection_name: '',
  407. status: 'uploading',
  408. error: '',
  409. itemId: tempItemId,
  410. size: 0
  411. };
  412. try {
  413. files = [...files, fileItem];
  414. console.log('Processing web file with URL:', fileData.url);
  415. // Configure fetch options with proper headers
  416. const fetchOptions = {
  417. headers: {
  418. Authorization: fileData.headers.Authorization,
  419. Accept: '*/*'
  420. },
  421. method: 'GET'
  422. };
  423. // Attempt to fetch the file
  424. console.log('Fetching file content from Google Drive...');
  425. const fileResponse = await fetch(fileData.url, fetchOptions);
  426. if (!fileResponse.ok) {
  427. const errorText = await fileResponse.text();
  428. throw new Error(`Failed to fetch file (${fileResponse.status}): ${errorText}`);
  429. }
  430. // Get content type from response
  431. const contentType = fileResponse.headers.get('content-type') || 'application/octet-stream';
  432. console.log('Response received with content-type:', contentType);
  433. // Convert response to blob
  434. console.log('Converting response to blob...');
  435. const fileBlob = await fileResponse.blob();
  436. if (fileBlob.size === 0) {
  437. throw new Error('Retrieved file is empty');
  438. }
  439. console.log('Blob created:', {
  440. size: fileBlob.size,
  441. type: fileBlob.type || contentType
  442. });
  443. // Create File object with proper MIME type
  444. const file = new File([fileBlob], fileData.name, {
  445. type: fileBlob.type || contentType
  446. });
  447. console.log('File object created:', {
  448. name: file.name,
  449. size: file.size,
  450. type: file.type
  451. });
  452. if (file.size === 0) {
  453. throw new Error('Created file is empty');
  454. }
  455. // Upload file to server
  456. console.log('Uploading file to server...');
  457. const uploadedFile = await uploadFile(localStorage.token, file);
  458. if (!uploadedFile) {
  459. throw new Error('Server returned null response for file upload');
  460. }
  461. console.log('File uploaded successfully:', uploadedFile);
  462. // Update file item with upload results
  463. fileItem.status = 'uploaded';
  464. fileItem.file = uploadedFile;
  465. fileItem.id = uploadedFile.id;
  466. fileItem.size = file.size;
  467. fileItem.collection_name = uploadedFile?.meta?.collection_name;
  468. fileItem.url = `${WEBUI_API_BASE_URL}/files/${uploadedFile.id}`;
  469. files = files;
  470. toast.success($i18n.t('File uploaded successfully'));
  471. } catch (e) {
  472. console.error('Error uploading file:', e);
  473. files = files.filter((f) => f.itemId !== tempItemId);
  474. toast.error(
  475. $i18n.t('Error uploading file: {{error}}', {
  476. error: e.message || 'Unknown error'
  477. })
  478. );
  479. }
  480. };
  481. const uploadWeb = async (url) => {
  482. console.log(url);
  483. const fileItem = {
  484. type: 'doc',
  485. name: url,
  486. collection_name: '',
  487. status: 'uploading',
  488. url: url,
  489. error: ''
  490. };
  491. try {
  492. files = [...files, fileItem];
  493. const res = await processWeb(localStorage.token, '', url);
  494. if (res) {
  495. fileItem.status = 'uploaded';
  496. fileItem.collection_name = res.collection_name;
  497. fileItem.file = {
  498. ...res.file,
  499. ...fileItem.file
  500. };
  501. files = files;
  502. }
  503. } catch (e) {
  504. // Remove the failed doc from the files array
  505. files = files.filter((f) => f.name !== url);
  506. toast.error(JSON.stringify(e));
  507. }
  508. };
  509. const uploadYoutubeTranscription = async (url) => {
  510. console.log(url);
  511. const fileItem = {
  512. type: 'doc',
  513. name: url,
  514. collection_name: '',
  515. status: 'uploading',
  516. context: 'full',
  517. url: url,
  518. error: ''
  519. };
  520. try {
  521. files = [...files, fileItem];
  522. const res = await processYoutubeVideo(localStorage.token, url);
  523. if (res) {
  524. fileItem.status = 'uploaded';
  525. fileItem.collection_name = res.collection_name;
  526. fileItem.file = {
  527. ...res.file,
  528. ...fileItem.file
  529. };
  530. files = files;
  531. }
  532. } catch (e) {
  533. // Remove the failed doc from the files array
  534. files = files.filter((f) => f.name !== url);
  535. toast.error(`${e}`);
  536. }
  537. };
  538. //////////////////////////
  539. // Web functions
  540. //////////////////////////
  541. const initNewChat = async () => {
  542. if ($page.url.searchParams.get('models')) {
  543. selectedModels = $page.url.searchParams.get('models')?.split(',');
  544. } else if ($page.url.searchParams.get('model')) {
  545. const urlModels = $page.url.searchParams.get('model')?.split(',');
  546. if (urlModels.length === 1) {
  547. const m = $models.find((m) => m.id === urlModels[0]);
  548. if (!m) {
  549. const modelSelectorButton = document.getElementById('model-selector-0-button');
  550. if (modelSelectorButton) {
  551. modelSelectorButton.click();
  552. await tick();
  553. const modelSelectorInput = document.getElementById('model-search-input');
  554. if (modelSelectorInput) {
  555. modelSelectorInput.focus();
  556. modelSelectorInput.value = urlModels[0];
  557. modelSelectorInput.dispatchEvent(new Event('input'));
  558. }
  559. }
  560. } else {
  561. selectedModels = urlModels;
  562. }
  563. } else {
  564. selectedModels = urlModels;
  565. }
  566. } else {
  567. if (sessionStorage.selectedModels) {
  568. selectedModels = JSON.parse(sessionStorage.selectedModels);
  569. sessionStorage.removeItem('selectedModels');
  570. } else {
  571. if ($settings?.models) {
  572. selectedModels = $settings?.models;
  573. } else if ($config?.default_models) {
  574. console.log($config?.default_models.split(',') ?? '');
  575. selectedModels = $config?.default_models.split(',');
  576. }
  577. }
  578. }
  579. selectedModels = selectedModels.filter((modelId) => $models.map((m) => m.id).includes(modelId));
  580. if (selectedModels.length === 0 || (selectedModels.length === 1 && selectedModels[0] === '')) {
  581. if ($models.length > 0) {
  582. selectedModels = [$models[0].id];
  583. } else {
  584. selectedModels = [''];
  585. }
  586. }
  587. await showControls.set(false);
  588. await showCallOverlay.set(false);
  589. await showOverview.set(false);
  590. await showArtifacts.set(false);
  591. if ($page.url.pathname.includes('/c/')) {
  592. window.history.replaceState(history.state, '', `/`);
  593. }
  594. autoScroll = true;
  595. await chatId.set('');
  596. await chatTitle.set('');
  597. history = {
  598. messages: {},
  599. currentId: null
  600. };
  601. chatFiles = [];
  602. params = {};
  603. if ($page.url.searchParams.get('youtube')) {
  604. uploadYoutubeTranscription(
  605. `https://www.youtube.com/watch?v=${$page.url.searchParams.get('youtube')}`
  606. );
  607. }
  608. if ($page.url.searchParams.get('web-search') === 'true') {
  609. webSearchEnabled = true;
  610. }
  611. if ($page.url.searchParams.get('image-generation') === 'true') {
  612. imageGenerationEnabled = true;
  613. }
  614. if ($page.url.searchParams.get('tools')) {
  615. selectedToolIds = $page.url.searchParams
  616. .get('tools')
  617. ?.split(',')
  618. .map((id) => id.trim())
  619. .filter((id) => id);
  620. } else if ($page.url.searchParams.get('tool-ids')) {
  621. selectedToolIds = $page.url.searchParams
  622. .get('tool-ids')
  623. ?.split(',')
  624. .map((id) => id.trim())
  625. .filter((id) => id);
  626. }
  627. if ($page.url.searchParams.get('call') === 'true') {
  628. showCallOverlay.set(true);
  629. showControls.set(true);
  630. }
  631. if ($page.url.searchParams.get('q')) {
  632. prompt = $page.url.searchParams.get('q') ?? '';
  633. if (prompt) {
  634. await tick();
  635. submitPrompt(prompt);
  636. }
  637. }
  638. selectedModels = selectedModels.map((modelId) =>
  639. $models.map((m) => m.id).includes(modelId) ? modelId : ''
  640. );
  641. const userSettings = await getUserSettings(localStorage.token);
  642. if (userSettings) {
  643. settings.set(userSettings.ui);
  644. } else {
  645. settings.set(JSON.parse(localStorage.getItem('settings') ?? '{}'));
  646. }
  647. const chatInput = document.getElementById('chat-input');
  648. setTimeout(() => chatInput?.focus(), 0);
  649. };
  650. const loadChat = async () => {
  651. chatId.set(chatIdProp);
  652. chat = await getChatById(localStorage.token, $chatId).catch(async (error) => {
  653. await goto('/');
  654. return null;
  655. });
  656. if (chat) {
  657. tags = await getTagsById(localStorage.token, $chatId).catch(async (error) => {
  658. return [];
  659. });
  660. const chatContent = chat.chat;
  661. if (chatContent) {
  662. console.log(chatContent);
  663. selectedModels =
  664. (chatContent?.models ?? undefined) !== undefined
  665. ? chatContent.models
  666. : [chatContent.models ?? ''];
  667. history =
  668. (chatContent?.history ?? undefined) !== undefined
  669. ? chatContent.history
  670. : convertMessagesToHistory(chatContent.messages);
  671. chatTitle.set(chatContent.title);
  672. const userSettings = await getUserSettings(localStorage.token);
  673. if (userSettings) {
  674. await settings.set(userSettings.ui);
  675. } else {
  676. await settings.set(JSON.parse(localStorage.getItem('settings') ?? '{}'));
  677. }
  678. params = chatContent?.params ?? {};
  679. chatFiles = chatContent?.files ?? [];
  680. autoScroll = true;
  681. await tick();
  682. if (history.currentId) {
  683. history.messages[history.currentId].done = true;
  684. }
  685. await tick();
  686. return true;
  687. } else {
  688. return null;
  689. }
  690. }
  691. };
  692. const scrollToBottom = async () => {
  693. await tick();
  694. if (messagesContainerElement) {
  695. messagesContainerElement.scrollTop = messagesContainerElement.scrollHeight;
  696. }
  697. };
  698. const createMessagesList = (history, responseMessageId) => {
  699. if (responseMessageId === null) {
  700. return [];
  701. }
  702. const message = history.messages[responseMessageId];
  703. if (message?.parentId) {
  704. return [...createMessagesList(history, message.parentId), message];
  705. } else {
  706. return [message];
  707. }
  708. };
  709. const chatCompletedHandler = async (chatId, modelId, responseMessageId, messages) => {
  710. const res = await chatCompleted(localStorage.token, {
  711. model: modelId,
  712. messages: messages.map((m) => ({
  713. id: m.id,
  714. role: m.role,
  715. content: m.content,
  716. info: m.info ? m.info : undefined,
  717. timestamp: m.timestamp,
  718. ...(m.sources ? { sources: m.sources } : {})
  719. })),
  720. chat_id: chatId,
  721. session_id: $socket?.id,
  722. id: responseMessageId
  723. }).catch((error) => {
  724. toast.error(`${error}`);
  725. messages.at(-1).error = { content: error };
  726. return null;
  727. });
  728. if (res !== null && res.messages) {
  729. // Update chat history with the new messages
  730. for (const message of res.messages) {
  731. if (message?.id) {
  732. // Add null check for message and message.id
  733. history.messages[message.id] = {
  734. ...history.messages[message.id],
  735. ...(history.messages[message.id].content !== message.content
  736. ? { originalContent: history.messages[message.id].content }
  737. : {}),
  738. ...message
  739. };
  740. }
  741. }
  742. }
  743. await tick();
  744. if ($chatId == chatId) {
  745. if (!$temporaryChatEnabled) {
  746. chat = await updateChatById(localStorage.token, chatId, {
  747. models: selectedModels,
  748. messages: messages,
  749. history: history,
  750. params: params,
  751. files: chatFiles
  752. });
  753. currentChatPage.set(1);
  754. await chats.set(await getChatList(localStorage.token, $currentChatPage));
  755. }
  756. }
  757. };
  758. const chatActionHandler = async (chatId, actionId, modelId, responseMessageId, event = null) => {
  759. const messages = createMessagesList(history, responseMessageId);
  760. const res = await chatAction(localStorage.token, actionId, {
  761. model: modelId,
  762. messages: messages.map((m) => ({
  763. id: m.id,
  764. role: m.role,
  765. content: m.content,
  766. info: m.info ? m.info : undefined,
  767. timestamp: m.timestamp,
  768. ...(m.sources ? { sources: m.sources } : {})
  769. })),
  770. ...(event ? { event: event } : {}),
  771. chat_id: chatId,
  772. session_id: $socket?.id,
  773. id: responseMessageId
  774. }).catch((error) => {
  775. toast.error(`${error}`);
  776. messages.at(-1).error = { content: error };
  777. return null;
  778. });
  779. if (res !== null && res.messages) {
  780. // Update chat history with the new messages
  781. for (const message of res.messages) {
  782. history.messages[message.id] = {
  783. ...history.messages[message.id],
  784. ...(history.messages[message.id].content !== message.content
  785. ? { originalContent: history.messages[message.id].content }
  786. : {}),
  787. ...message
  788. };
  789. }
  790. }
  791. if ($chatId == chatId) {
  792. if (!$temporaryChatEnabled) {
  793. chat = await updateChatById(localStorage.token, chatId, {
  794. models: selectedModels,
  795. messages: messages,
  796. history: history,
  797. params: params,
  798. files: chatFiles
  799. });
  800. currentChatPage.set(1);
  801. await chats.set(await getChatList(localStorage.token, $currentChatPage));
  802. }
  803. }
  804. };
  805. const getChatEventEmitter = async (modelId: string, chatId: string = '') => {
  806. return setInterval(() => {
  807. $socket?.emit('usage', {
  808. action: 'chat',
  809. model: modelId,
  810. chat_id: chatId
  811. });
  812. }, 1000);
  813. };
  814. const createMessagePair = async (userPrompt) => {
  815. prompt = '';
  816. if (selectedModels.length === 0) {
  817. toast.error($i18n.t('Model not selected'));
  818. } else {
  819. const modelId = selectedModels[0];
  820. const model = $models.filter((m) => m.id === modelId).at(0);
  821. const messages = createMessagesList(history, history.currentId);
  822. const parentMessage = messages.length !== 0 ? messages.at(-1) : null;
  823. const userMessageId = uuidv4();
  824. const responseMessageId = uuidv4();
  825. const userMessage = {
  826. id: userMessageId,
  827. parentId: parentMessage ? parentMessage.id : null,
  828. childrenIds: [responseMessageId],
  829. role: 'user',
  830. content: userPrompt ? userPrompt : `[PROMPT] ${userMessageId}`,
  831. timestamp: Math.floor(Date.now() / 1000)
  832. };
  833. const responseMessage = {
  834. id: responseMessageId,
  835. parentId: userMessageId,
  836. childrenIds: [],
  837. role: 'assistant',
  838. content: `[RESPONSE] ${responseMessageId}`,
  839. done: true,
  840. model: modelId,
  841. modelName: model.name ?? model.id,
  842. modelIdx: 0,
  843. timestamp: Math.floor(Date.now() / 1000)
  844. };
  845. if (parentMessage) {
  846. parentMessage.childrenIds.push(userMessageId);
  847. history.messages[parentMessage.id] = parentMessage;
  848. }
  849. history.messages[userMessageId] = userMessage;
  850. history.messages[responseMessageId] = responseMessage;
  851. history.currentId = responseMessageId;
  852. await tick();
  853. if (autoScroll) {
  854. scrollToBottom();
  855. }
  856. if (messages.length === 0) {
  857. await initChatHandler();
  858. } else {
  859. await saveChatHandler($chatId);
  860. }
  861. }
  862. };
  863. const addMessages = async ({ modelId, parentId, messages }) => {
  864. const model = $models.filter((m) => m.id === modelId).at(0);
  865. let parentMessage = history.messages[parentId];
  866. let currentParentId = parentMessage ? parentMessage.id : null;
  867. for (const message of messages) {
  868. let messageId = uuidv4();
  869. if (message.role === 'user') {
  870. const userMessage = {
  871. id: messageId,
  872. parentId: currentParentId,
  873. childrenIds: [],
  874. timestamp: Math.floor(Date.now() / 1000),
  875. ...message
  876. };
  877. if (parentMessage) {
  878. parentMessage.childrenIds.push(messageId);
  879. history.messages[parentMessage.id] = parentMessage;
  880. }
  881. history.messages[messageId] = userMessage;
  882. parentMessage = userMessage;
  883. currentParentId = messageId;
  884. } else {
  885. const responseMessage = {
  886. id: messageId,
  887. parentId: currentParentId,
  888. childrenIds: [],
  889. done: true,
  890. model: model.id,
  891. modelName: model.name ?? model.id,
  892. modelIdx: 0,
  893. timestamp: Math.floor(Date.now() / 1000),
  894. ...message
  895. };
  896. if (parentMessage) {
  897. parentMessage.childrenIds.push(messageId);
  898. history.messages[parentMessage.id] = parentMessage;
  899. }
  900. history.messages[messageId] = responseMessage;
  901. parentMessage = responseMessage;
  902. currentParentId = messageId;
  903. }
  904. }
  905. history.currentId = currentParentId;
  906. await tick();
  907. if (autoScroll) {
  908. scrollToBottom();
  909. }
  910. if (messages.length === 0) {
  911. await initChatHandler();
  912. } else {
  913. await saveChatHandler($chatId);
  914. }
  915. };
  916. const chatCompletionEventHandler = async (data, message, chatId) => {
  917. const { id, done, choices, content, sources, selected_model_id, error, usage } = data;
  918. if (error) {
  919. await handleOpenAIError(error, message);
  920. }
  921. if (sources) {
  922. message.sources = sources;
  923. }
  924. if (choices) {
  925. if (choices[0]?.message?.content) {
  926. // Non-stream response
  927. message.content += choices[0]?.message?.content;
  928. } else {
  929. // Stream response
  930. let value = choices[0]?.delta?.content ?? '';
  931. if (message.content == '' && value == '\n') {
  932. console.log('Empty response');
  933. } else {
  934. message.content += value;
  935. if (navigator.vibrate && ($settings?.hapticFeedback ?? false)) {
  936. navigator.vibrate(5);
  937. }
  938. // Emit chat event for TTS
  939. const messageContentParts = getMessageContentParts(
  940. message.content,
  941. $config?.audio?.tts?.split_on ?? 'punctuation'
  942. );
  943. messageContentParts.pop();
  944. // dispatch only last sentence and make sure it hasn't been dispatched before
  945. if (
  946. messageContentParts.length > 0 &&
  947. messageContentParts[messageContentParts.length - 1] !== message.lastSentence
  948. ) {
  949. message.lastSentence = messageContentParts[messageContentParts.length - 1];
  950. eventTarget.dispatchEvent(
  951. new CustomEvent('chat', {
  952. detail: {
  953. id: message.id,
  954. content: messageContentParts[messageContentParts.length - 1]
  955. }
  956. })
  957. );
  958. }
  959. }
  960. }
  961. }
  962. if (content) {
  963. // REALTIME_CHAT_SAVE is disabled
  964. message.content = content;
  965. if (navigator.vibrate && ($settings?.hapticFeedback ?? false)) {
  966. navigator.vibrate(5);
  967. }
  968. // Emit chat event for TTS
  969. const messageContentParts = getMessageContentParts(
  970. message.content,
  971. $config?.audio?.tts?.split_on ?? 'punctuation'
  972. );
  973. messageContentParts.pop();
  974. // dispatch only last sentence and make sure it hasn't been dispatched before
  975. if (
  976. messageContentParts.length > 0 &&
  977. messageContentParts[messageContentParts.length - 1] !== message.lastSentence
  978. ) {
  979. message.lastSentence = messageContentParts[messageContentParts.length - 1];
  980. eventTarget.dispatchEvent(
  981. new CustomEvent('chat', {
  982. detail: {
  983. id: message.id,
  984. content: messageContentParts[messageContentParts.length - 1]
  985. }
  986. })
  987. );
  988. }
  989. }
  990. if (selected_model_id) {
  991. message.selectedModelId = selected_model_id;
  992. message.arena = true;
  993. }
  994. if (usage) {
  995. message.usage = usage;
  996. }
  997. history.messages[message.id] = message;
  998. if (done) {
  999. message.done = true;
  1000. if ($settings.responseAutoCopy) {
  1001. copyToClipboard(message.content);
  1002. }
  1003. if ($settings.responseAutoPlayback && !$showCallOverlay) {
  1004. await tick();
  1005. document.getElementById(`speak-button-${message.id}`)?.click();
  1006. }
  1007. // Emit chat event for TTS
  1008. let lastMessageContentPart =
  1009. getMessageContentParts(message.content, $config?.audio?.tts?.split_on ?? 'punctuation')?.at(
  1010. -1
  1011. ) ?? '';
  1012. if (lastMessageContentPart) {
  1013. eventTarget.dispatchEvent(
  1014. new CustomEvent('chat', {
  1015. detail: { id: message.id, content: lastMessageContentPart }
  1016. })
  1017. );
  1018. }
  1019. eventTarget.dispatchEvent(
  1020. new CustomEvent('chat:finish', {
  1021. detail: {
  1022. id: message.id,
  1023. content: message.content
  1024. }
  1025. })
  1026. );
  1027. history.messages[message.id] = message;
  1028. await chatCompletedHandler(
  1029. chatId,
  1030. message.model,
  1031. message.id,
  1032. createMessagesList(history, message.id)
  1033. );
  1034. }
  1035. console.log(data);
  1036. if (autoScroll) {
  1037. scrollToBottom();
  1038. }
  1039. };
  1040. //////////////////////////
  1041. // Chat functions
  1042. //////////////////////////
  1043. const submitPrompt = async (userPrompt, { _raw = false } = {}) => {
  1044. console.log('submitPrompt', userPrompt, $chatId);
  1045. const messages = createMessagesList(history, history.currentId);
  1046. const _selectedModels = selectedModels.map((modelId) =>
  1047. $models.map((m) => m.id).includes(modelId) ? modelId : ''
  1048. );
  1049. if (JSON.stringify(selectedModels) !== JSON.stringify(_selectedModels)) {
  1050. selectedModels = _selectedModels;
  1051. }
  1052. if (userPrompt === '') {
  1053. toast.error($i18n.t('Please enter a prompt'));
  1054. return;
  1055. }
  1056. if (selectedModels.includes('')) {
  1057. toast.error($i18n.t('Model not selected'));
  1058. return;
  1059. }
  1060. if (messages.length != 0 && messages.at(-1).done != true) {
  1061. // Response not done
  1062. return;
  1063. }
  1064. if (messages.length != 0 && messages.at(-1).error) {
  1065. // Error in response
  1066. toast.error($i18n.t(`Oops! There was an error in the previous response.`));
  1067. return;
  1068. }
  1069. if (
  1070. files.length > 0 &&
  1071. files.filter((file) => file.type !== 'image' && file.status === 'uploading').length > 0
  1072. ) {
  1073. toast.error(
  1074. $i18n.t(`Oops! There are files still uploading. Please wait for the upload to complete.`)
  1075. );
  1076. return;
  1077. }
  1078. if (
  1079. ($config?.file?.max_count ?? null) !== null &&
  1080. files.length + chatFiles.length > $config?.file?.max_count
  1081. ) {
  1082. toast.error(
  1083. $i18n.t(`You can only chat with a maximum of {{maxCount}} file(s) at a time.`, {
  1084. maxCount: $config?.file?.max_count
  1085. })
  1086. );
  1087. return;
  1088. }
  1089. prompt = '';
  1090. await tick();
  1091. // Reset chat input textarea
  1092. const chatInputElement = document.getElementById('chat-input');
  1093. if (chatInputElement) {
  1094. chatInputElement.style.height = '';
  1095. }
  1096. const _files = JSON.parse(JSON.stringify(files));
  1097. chatFiles.push(..._files.filter((item) => ['doc', 'file', 'collection'].includes(item.type)));
  1098. chatFiles = chatFiles.filter(
  1099. // Remove duplicates
  1100. (item, index, array) =>
  1101. array.findIndex((i) => JSON.stringify(i) === JSON.stringify(item)) === index
  1102. );
  1103. files = [];
  1104. prompt = '';
  1105. // Create user message
  1106. let userMessageId = uuidv4();
  1107. let userMessage = {
  1108. id: userMessageId,
  1109. parentId: messages.length !== 0 ? messages.at(-1).id : null,
  1110. childrenIds: [],
  1111. role: 'user',
  1112. content: userPrompt,
  1113. files: _files.length > 0 ? _files : undefined,
  1114. timestamp: Math.floor(Date.now() / 1000), // Unix epoch
  1115. models: selectedModels
  1116. };
  1117. // Add message to history and Set currentId to messageId
  1118. history.messages[userMessageId] = userMessage;
  1119. history.currentId = userMessageId;
  1120. // Append messageId to childrenIds of parent message
  1121. if (messages.length !== 0) {
  1122. history.messages[messages.at(-1).id].childrenIds.push(userMessageId);
  1123. }
  1124. // Wait until history/message have been updated
  1125. await tick();
  1126. // focus on chat input
  1127. const chatInput = document.getElementById('chat-input');
  1128. chatInput?.focus();
  1129. saveSessionSelectedModels();
  1130. sendPrompt(userPrompt, userMessageId, { newChat: true });
  1131. };
  1132. const sendPrompt = async (
  1133. prompt: string,
  1134. parentId: string,
  1135. { modelId = null, modelIdx = null, newChat = false } = {}
  1136. ) => {
  1137. // If modelId is provided, use it, else use selected model
  1138. let selectedModelIds = modelId
  1139. ? [modelId]
  1140. : atSelectedModel !== undefined
  1141. ? [atSelectedModel.id]
  1142. : selectedModels;
  1143. // Create response messages for each selected model
  1144. const responseMessageIds: Record<PropertyKey, string> = {};
  1145. const _chatId = JSON.parse(JSON.stringify($chatId));
  1146. // Create new chat if newChat is true and first user message
  1147. if (
  1148. newChat &&
  1149. history.messages[history.currentId].parentId === null &&
  1150. history.messages[history.currentId].role === 'user'
  1151. ) {
  1152. await initChatHandler();
  1153. } else {
  1154. await saveChatHandler(_chatId);
  1155. }
  1156. for (const [_modelIdx, modelId] of selectedModelIds.entries()) {
  1157. const model = $models.filter((m) => m.id === modelId).at(0);
  1158. if (model) {
  1159. let responseMessageId = uuidv4();
  1160. let responseMessage = {
  1161. parentId: parentId,
  1162. id: responseMessageId,
  1163. childrenIds: [],
  1164. role: 'assistant',
  1165. content: '',
  1166. model: model.id,
  1167. modelName: model.name ?? model.id,
  1168. modelIdx: modelIdx ? modelIdx : _modelIdx,
  1169. userContext: null,
  1170. timestamp: Math.floor(Date.now() / 1000) // Unix epoch
  1171. };
  1172. // Add message to history and Set currentId to messageId
  1173. history.messages[responseMessageId] = responseMessage;
  1174. history.currentId = responseMessageId;
  1175. // Append messageId to childrenIds of parent message
  1176. if (parentId !== null && history.messages[parentId]) {
  1177. // Add null check before accessing childrenIds
  1178. history.messages[parentId].childrenIds = [
  1179. ...history.messages[parentId].childrenIds,
  1180. responseMessageId
  1181. ];
  1182. }
  1183. responseMessageIds[`${modelId}-${modelIdx ? modelIdx : _modelIdx}`] = responseMessageId;
  1184. }
  1185. }
  1186. await tick();
  1187. // Save chat after all messages have been created
  1188. saveChatHandler(_chatId);
  1189. await Promise.all(
  1190. selectedModelIds.map(async (modelId, _modelIdx) => {
  1191. console.log('modelId', modelId);
  1192. const model = $models.filter((m) => m.id === modelId).at(0);
  1193. if (model) {
  1194. const messages = createMessagesList(history, parentId);
  1195. // If there are image files, check if model is vision capable
  1196. const hasImages = messages.some((message) =>
  1197. message?.files?.some((file) => file.type === 'image')
  1198. );
  1199. if (hasImages && !(model.info?.meta?.capabilities?.vision ?? true)) {
  1200. toast.error(
  1201. $i18n.t('Model {{modelName}} is not vision capable', {
  1202. modelName: model.name ?? model.id
  1203. })
  1204. );
  1205. }
  1206. let responseMessageId =
  1207. responseMessageIds[`${modelId}-${modelIdx ? modelIdx : _modelIdx}`];
  1208. let responseMessage = history.messages[responseMessageId];
  1209. let userContext = null;
  1210. if ($settings?.memory ?? false) {
  1211. if (userContext === null) {
  1212. const res = await queryMemory(localStorage.token, prompt).catch((error) => {
  1213. toast.error(`${error}`);
  1214. return null;
  1215. });
  1216. if (res) {
  1217. if (res.documents[0].length > 0) {
  1218. userContext = res.documents[0].reduce((acc, doc, index) => {
  1219. const createdAtTimestamp = res.metadatas[0][index].created_at;
  1220. const createdAtDate = new Date(createdAtTimestamp * 1000)
  1221. .toISOString()
  1222. .split('T')[0];
  1223. return `${acc}${index + 1}. [${createdAtDate}]. ${doc}\n`;
  1224. }, '');
  1225. }
  1226. console.log(userContext);
  1227. }
  1228. }
  1229. }
  1230. responseMessage.userContext = userContext;
  1231. const chatEventEmitter = await getChatEventEmitter(model.id, _chatId);
  1232. scrollToBottom();
  1233. await sendPromptSocket(history, model, responseMessageId, _chatId);
  1234. if (chatEventEmitter) clearInterval(chatEventEmitter);
  1235. } else {
  1236. toast.error($i18n.t(`Model {{modelId}} not found`, { modelId }));
  1237. }
  1238. })
  1239. );
  1240. currentChatPage.set(1);
  1241. chats.set(await getChatList(localStorage.token, $currentChatPage));
  1242. };
  1243. const sendPromptSocket = async (history, model, responseMessageId, _chatId) => {
  1244. const responseMessage = history.messages[responseMessageId];
  1245. const userMessage = history.messages[responseMessage.parentId];
  1246. let files = JSON.parse(JSON.stringify(chatFiles));
  1247. files.push(
  1248. ...(userMessage?.files ?? []).filter((item) =>
  1249. ['doc', 'file', 'collection'].includes(item.type)
  1250. ),
  1251. ...(responseMessage?.files ?? []).filter((item) => ['web_search_results'].includes(item.type))
  1252. );
  1253. // Remove duplicates
  1254. files = files.filter(
  1255. (item, index, array) =>
  1256. array.findIndex((i) => JSON.stringify(i) === JSON.stringify(item)) === index
  1257. );
  1258. scrollToBottom();
  1259. eventTarget.dispatchEvent(
  1260. new CustomEvent('chat:start', {
  1261. detail: {
  1262. id: responseMessageId
  1263. }
  1264. })
  1265. );
  1266. await tick();
  1267. const stream =
  1268. model?.info?.params?.stream_response ??
  1269. $settings?.params?.stream_response ??
  1270. params?.stream_response ??
  1271. true;
  1272. const messages = [
  1273. params?.system || $settings.system || (responseMessage?.userContext ?? null)
  1274. ? {
  1275. role: 'system',
  1276. content: `${promptTemplate(
  1277. params?.system ?? $settings?.system ?? '',
  1278. $user.name,
  1279. $settings?.userLocation
  1280. ? await getAndUpdateUserLocation(localStorage.token)
  1281. : undefined
  1282. )}${
  1283. (responseMessage?.userContext ?? null)
  1284. ? `\n\nUser Context:\n${responseMessage?.userContext ?? ''}`
  1285. : ''
  1286. }`
  1287. }
  1288. : undefined,
  1289. ...createMessagesList(history, responseMessageId).map((message) => ({
  1290. ...message,
  1291. content: removeDetails(message.content, ['reasoning', 'code_interpreter'])
  1292. }))
  1293. ]
  1294. .filter((message) => message?.content?.trim())
  1295. .map((message, idx, arr) => ({
  1296. role: message.role,
  1297. ...((message.files?.filter((file) => file.type === 'image').length > 0 ?? false) &&
  1298. message.role === 'user'
  1299. ? {
  1300. content: [
  1301. {
  1302. type: 'text',
  1303. text: message?.merged?.content ?? message.content
  1304. },
  1305. ...message.files
  1306. .filter((file) => file.type === 'image')
  1307. .map((file) => ({
  1308. type: 'image_url',
  1309. image_url: {
  1310. url: file.url
  1311. }
  1312. }))
  1313. ]
  1314. }
  1315. : {
  1316. content: message?.merged?.content ?? message.content
  1317. })
  1318. }));
  1319. const res = await generateOpenAIChatCompletion(
  1320. localStorage.token,
  1321. {
  1322. stream: stream,
  1323. model: model.id,
  1324. messages: messages,
  1325. params: {
  1326. ...$settings?.params,
  1327. ...params,
  1328. format: $settings.requestFormat ?? undefined,
  1329. keep_alive: $settings.keepAlive ?? undefined,
  1330. stop:
  1331. (params?.stop ?? $settings?.params?.stop ?? undefined)
  1332. ? (params?.stop.split(',').map((token) => token.trim()) ?? $settings.params.stop).map(
  1333. (str) => decodeURIComponent(JSON.parse('"' + str.replace(/\"/g, '\\"') + '"'))
  1334. )
  1335. : undefined
  1336. },
  1337. files: (files?.length ?? 0) > 0 ? files : undefined,
  1338. tool_ids: selectedToolIds.length > 0 ? selectedToolIds : undefined,
  1339. features: {
  1340. image_generation: imageGenerationEnabled,
  1341. code_interpreter: codeInterpreterEnabled,
  1342. web_search: webSearchEnabled
  1343. },
  1344. variables: {
  1345. ...getPromptVariables(
  1346. $user.name,
  1347. $settings?.userLocation ? await getAndUpdateUserLocation(localStorage.token) : undefined
  1348. )
  1349. },
  1350. session_id: $socket?.id,
  1351. chat_id: $chatId,
  1352. id: responseMessageId,
  1353. ...(!$temporaryChatEnabled &&
  1354. (messages.length == 1 ||
  1355. (messages.length == 2 &&
  1356. messages.at(0)?.role === 'system' &&
  1357. messages.at(1)?.role === 'user')) &&
  1358. selectedModels[0] === model.id
  1359. ? {
  1360. background_tasks: {
  1361. title_generation: $settings?.title?.auto ?? true,
  1362. tags_generation: $settings?.autoTags ?? true
  1363. }
  1364. }
  1365. : {}),
  1366. ...(stream && (model.info?.meta?.capabilities?.usage ?? false)
  1367. ? {
  1368. stream_options: {
  1369. include_usage: true
  1370. }
  1371. }
  1372. : {})
  1373. },
  1374. `${WEBUI_BASE_URL}/api`
  1375. ).catch((error) => {
  1376. console.log(error);
  1377. responseMessage.error = {
  1378. content: error
  1379. };
  1380. responseMessage.done = true;
  1381. history.messages[responseMessageId] = responseMessage;
  1382. return null;
  1383. });
  1384. console.log(res);
  1385. if (res) {
  1386. taskId = res.task_id;
  1387. }
  1388. await tick();
  1389. scrollToBottom();
  1390. };
  1391. const handleOpenAIError = async (error, responseMessage) => {
  1392. let errorMessage = '';
  1393. let innerError;
  1394. if (error) {
  1395. innerError = error;
  1396. }
  1397. console.error(innerError);
  1398. if ('detail' in innerError) {
  1399. toast.error(innerError.detail);
  1400. errorMessage = innerError.detail;
  1401. } else if ('error' in innerError) {
  1402. if ('message' in innerError.error) {
  1403. toast.error(innerError.error.message);
  1404. errorMessage = innerError.error.message;
  1405. } else {
  1406. toast.error(innerError.error);
  1407. errorMessage = innerError.error;
  1408. }
  1409. } else if ('message' in innerError) {
  1410. toast.error(innerError.message);
  1411. errorMessage = innerError.message;
  1412. }
  1413. responseMessage.error = {
  1414. content: $i18n.t(`Uh-oh! There was an issue with the response.`) + '\n' + errorMessage
  1415. };
  1416. responseMessage.done = true;
  1417. if (responseMessage.statusHistory) {
  1418. responseMessage.statusHistory = responseMessage.statusHistory.filter(
  1419. (status) => status.action !== 'knowledge_search'
  1420. );
  1421. }
  1422. history.messages[responseMessage.id] = responseMessage;
  1423. };
  1424. const stopResponse = () => {
  1425. if (taskId) {
  1426. const res = stopTask(localStorage.token, taskId).catch((error) => {
  1427. return null;
  1428. });
  1429. if (res) {
  1430. taskId = null;
  1431. const responseMessage = history.messages[history.currentId];
  1432. responseMessage.done = true;
  1433. history.messages[history.currentId] = responseMessage;
  1434. if (autoScroll) {
  1435. scrollToBottom();
  1436. }
  1437. }
  1438. }
  1439. };
  1440. const submitMessage = async (parentId, prompt) => {
  1441. let userPrompt = prompt;
  1442. let userMessageId = uuidv4();
  1443. let userMessage = {
  1444. id: userMessageId,
  1445. parentId: parentId,
  1446. childrenIds: [],
  1447. role: 'user',
  1448. content: userPrompt,
  1449. models: selectedModels
  1450. };
  1451. if (parentId !== null) {
  1452. history.messages[parentId].childrenIds = [
  1453. ...history.messages[parentId].childrenIds,
  1454. userMessageId
  1455. ];
  1456. }
  1457. history.messages[userMessageId] = userMessage;
  1458. history.currentId = userMessageId;
  1459. await tick();
  1460. await sendPrompt(userPrompt, userMessageId);
  1461. };
  1462. const regenerateResponse = async (message) => {
  1463. console.log('regenerateResponse');
  1464. if (history.currentId) {
  1465. let userMessage = history.messages[message.parentId];
  1466. let userPrompt = userMessage.content;
  1467. if ((userMessage?.models ?? [...selectedModels]).length == 1) {
  1468. // If user message has only one model selected, sendPrompt automatically selects it for regeneration
  1469. await sendPrompt(userPrompt, userMessage.id);
  1470. } else {
  1471. // If there are multiple models selected, use the model of the response message for regeneration
  1472. // e.g. many model chat
  1473. await sendPrompt(userPrompt, userMessage.id, {
  1474. modelId: message.model,
  1475. modelIdx: message.modelIdx
  1476. });
  1477. }
  1478. }
  1479. };
  1480. const continueResponse = async () => {
  1481. console.log('continueResponse');
  1482. const _chatId = JSON.parse(JSON.stringify($chatId));
  1483. if (history.currentId && history.messages[history.currentId].done == true) {
  1484. const responseMessage = history.messages[history.currentId];
  1485. responseMessage.done = false;
  1486. await tick();
  1487. const model = $models
  1488. .filter((m) => m.id === (responseMessage?.selectedModelId ?? responseMessage.model))
  1489. .at(0);
  1490. if (model) {
  1491. await sendPromptSocket(history, model, responseMessage.id, _chatId);
  1492. }
  1493. }
  1494. };
  1495. const mergeResponses = async (messageId, responses, _chatId) => {
  1496. console.log('mergeResponses', messageId, responses);
  1497. const message = history.messages[messageId];
  1498. const mergedResponse = {
  1499. status: true,
  1500. content: ''
  1501. };
  1502. message.merged = mergedResponse;
  1503. history.messages[messageId] = message;
  1504. try {
  1505. const [res, controller] = await generateMoACompletion(
  1506. localStorage.token,
  1507. message.model,
  1508. history.messages[message.parentId].content,
  1509. responses
  1510. );
  1511. if (res && res.ok && res.body) {
  1512. const textStream = await createOpenAITextStream(res.body, $settings.splitLargeChunks);
  1513. for await (const update of textStream) {
  1514. const { value, done, sources, error, usage } = update;
  1515. if (error || done) {
  1516. break;
  1517. }
  1518. if (mergedResponse.content == '' && value == '\n') {
  1519. continue;
  1520. } else {
  1521. mergedResponse.content += value;
  1522. history.messages[messageId] = message;
  1523. }
  1524. if (autoScroll) {
  1525. scrollToBottom();
  1526. }
  1527. }
  1528. await saveChatHandler(_chatId);
  1529. } else {
  1530. console.error(res);
  1531. }
  1532. } catch (e) {
  1533. console.error(e);
  1534. }
  1535. };
  1536. const initChatHandler = async () => {
  1537. if (!$temporaryChatEnabled) {
  1538. chat = await createNewChat(localStorage.token, {
  1539. id: $chatId,
  1540. title: $i18n.t('New Chat'),
  1541. models: selectedModels,
  1542. system: $settings.system ?? undefined,
  1543. params: params,
  1544. history: history,
  1545. messages: createMessagesList(history, history.currentId),
  1546. tags: [],
  1547. timestamp: Date.now()
  1548. });
  1549. currentChatPage.set(1);
  1550. await chats.set(await getChatList(localStorage.token, $currentChatPage));
  1551. await chatId.set(chat.id);
  1552. window.history.replaceState(history.state, '', `/c/${chat.id}`);
  1553. } else {
  1554. await chatId.set('local');
  1555. }
  1556. await tick();
  1557. };
  1558. const saveChatHandler = async (_chatId) => {
  1559. if ($chatId == _chatId) {
  1560. if (!$temporaryChatEnabled) {
  1561. chat = await updateChatById(localStorage.token, _chatId, {
  1562. models: selectedModels,
  1563. history: history,
  1564. messages: createMessagesList(history, history.currentId),
  1565. params: params,
  1566. files: chatFiles
  1567. });
  1568. currentChatPage.set(1);
  1569. await chats.set(await getChatList(localStorage.token, $currentChatPage));
  1570. }
  1571. }
  1572. };
  1573. </script>
  1574. <svelte:head>
  1575. <title>
  1576. {$chatTitle
  1577. ? `${$chatTitle.length > 30 ? `${$chatTitle.slice(0, 30)}...` : $chatTitle} | ${$WEBUI_NAME}`
  1578. : `${$WEBUI_NAME}`}
  1579. </title>
  1580. </svelte:head>
  1581. <audio id="audioElement" src="" style="display: none;" />
  1582. <EventConfirmDialog
  1583. bind:show={showEventConfirmation}
  1584. title={eventConfirmationTitle}
  1585. message={eventConfirmationMessage}
  1586. input={eventConfirmationInput}
  1587. inputPlaceholder={eventConfirmationInputPlaceholder}
  1588. inputValue={eventConfirmationInputValue}
  1589. on:confirm={(e) => {
  1590. if (e.detail) {
  1591. eventCallback(e.detail);
  1592. } else {
  1593. eventCallback(true);
  1594. }
  1595. }}
  1596. on:cancel={() => {
  1597. eventCallback(false);
  1598. }}
  1599. />
  1600. <div
  1601. class="h-screen max-h-[100dvh] transition-width duration-200 ease-in-out {$showSidebar
  1602. ? ' md:max-w-[calc(100%-260px)]'
  1603. : ' '} w-full max-w-full flex flex-col"
  1604. id="chat-container"
  1605. >
  1606. {#if chatIdProp === '' || (!loading && chatIdProp)}
  1607. {#if $settings?.backgroundImageUrl ?? null}
  1608. <div
  1609. class="absolute {$showSidebar
  1610. ? 'md:max-w-[calc(100%-260px)] md:translate-x-[260px]'
  1611. : ''} top-0 left-0 w-full h-full bg-cover bg-center bg-no-repeat"
  1612. style="background-image: url({$settings.backgroundImageUrl}) "
  1613. />
  1614. <div
  1615. class="absolute top-0 left-0 w-full h-full bg-gradient-to-t from-white to-white/85 dark:from-gray-900 dark:to-[#171717]/90 z-0"
  1616. />
  1617. {/if}
  1618. <Navbar
  1619. bind:this={navbarElement}
  1620. chat={{
  1621. id: $chatId,
  1622. chat: {
  1623. title: $chatTitle,
  1624. models: selectedModels,
  1625. system: $settings.system ?? undefined,
  1626. params: params,
  1627. history: history,
  1628. timestamp: Date.now()
  1629. }
  1630. }}
  1631. title={$chatTitle}
  1632. bind:selectedModels
  1633. shareEnabled={!!history.currentId}
  1634. {initNewChat}
  1635. />
  1636. <PaneGroup direction="horizontal" class="w-full h-full">
  1637. <Pane defaultSize={50} class="h-full flex w-full relative">
  1638. {#if $banners.length > 0 && !history.currentId && !$chatId && selectedModels.length <= 1}
  1639. <div class="absolute top-12 left-0 right-0 w-full z-30">
  1640. <div class=" flex flex-col gap-1 w-full">
  1641. {#each $banners.filter( (b) => (b.dismissible ? !JSON.parse(localStorage.getItem('dismissedBannerIds') ?? '[]').includes(b.id) : true) ) as banner}
  1642. <Banner
  1643. {banner}
  1644. on:dismiss={(e) => {
  1645. const bannerId = e.detail;
  1646. localStorage.setItem(
  1647. 'dismissedBannerIds',
  1648. JSON.stringify(
  1649. [
  1650. bannerId,
  1651. ...JSON.parse(localStorage.getItem('dismissedBannerIds') ?? '[]')
  1652. ].filter((id) => $banners.find((b) => b.id === id))
  1653. )
  1654. );
  1655. }}
  1656. />
  1657. {/each}
  1658. </div>
  1659. </div>
  1660. {/if}
  1661. <div class="flex flex-col flex-auto z-10 w-full">
  1662. {#if $settings?.landingPageMode === 'chat' || createMessagesList(history, history.currentId).length > 0}
  1663. <div
  1664. class=" pb-2.5 flex flex-col justify-between w-full flex-auto overflow-auto h-0 max-w-full z-10 scrollbar-hidden"
  1665. id="messages-container"
  1666. bind:this={messagesContainerElement}
  1667. on:scroll={(e) => {
  1668. autoScroll =
  1669. messagesContainerElement.scrollHeight - messagesContainerElement.scrollTop <=
  1670. messagesContainerElement.clientHeight + 5;
  1671. }}
  1672. >
  1673. <div class=" h-full w-full flex flex-col">
  1674. <Messages
  1675. chatId={$chatId}
  1676. bind:history
  1677. bind:autoScroll
  1678. bind:prompt
  1679. {selectedModels}
  1680. {sendPrompt}
  1681. {showMessage}
  1682. {submitMessage}
  1683. {continueResponse}
  1684. {regenerateResponse}
  1685. {mergeResponses}
  1686. {chatActionHandler}
  1687. {addMessages}
  1688. bottomPadding={files.length > 0}
  1689. />
  1690. </div>
  1691. </div>
  1692. <div class=" pb-[1rem]">
  1693. <MessageInput
  1694. {history}
  1695. {selectedModels}
  1696. bind:files
  1697. bind:prompt
  1698. bind:autoScroll
  1699. bind:selectedToolIds
  1700. bind:imageGenerationEnabled
  1701. bind:codeInterpreterEnabled
  1702. bind:webSearchEnabled
  1703. bind:atSelectedModel
  1704. transparentBackground={$settings?.backgroundImageUrl ?? false}
  1705. {stopResponse}
  1706. {createMessagePair}
  1707. onChange={(input) => {
  1708. if (input.prompt) {
  1709. localStorage.setItem(`chat-input-${$chatId}`, JSON.stringify(input));
  1710. } else {
  1711. localStorage.removeItem(`chat-input-${$chatId}`);
  1712. }
  1713. }}
  1714. on:upload={async (e) => {
  1715. const { type, data } = e.detail;
  1716. if (type === 'web') {
  1717. await uploadWeb(data);
  1718. } else if (type === 'youtube') {
  1719. await uploadYoutubeTranscription(data);
  1720. } else if (type === 'google-drive') {
  1721. await uploadGoogleDriveFile(data);
  1722. }
  1723. }}
  1724. on:submit={async (e) => {
  1725. if (e.detail) {
  1726. await tick();
  1727. submitPrompt(
  1728. ($settings?.richTextInput ?? true)
  1729. ? e.detail.replaceAll('\n\n', '\n')
  1730. : e.detail
  1731. );
  1732. }
  1733. }}
  1734. />
  1735. <div
  1736. class="absolute bottom-1 text-xs text-gray-500 text-center line-clamp-1 right-0 left-0"
  1737. >
  1738. <!-- {$i18n.t('LLMs can make mistakes. Verify important information.')} -->
  1739. </div>
  1740. </div>
  1741. {:else}
  1742. <div class="overflow-auto w-full h-full flex items-center">
  1743. <Placeholder
  1744. {history}
  1745. {selectedModels}
  1746. bind:files
  1747. bind:prompt
  1748. bind:autoScroll
  1749. bind:selectedToolIds
  1750. bind:imageGenerationEnabled
  1751. bind:codeInterpreterEnabled
  1752. bind:webSearchEnabled
  1753. bind:atSelectedModel
  1754. transparentBackground={$settings?.backgroundImageUrl ?? false}
  1755. {stopResponse}
  1756. {createMessagePair}
  1757. on:upload={async (e) => {
  1758. const { type, data } = e.detail;
  1759. if (type === 'web') {
  1760. await uploadWeb(data);
  1761. } else if (type === 'youtube') {
  1762. await uploadYoutubeTranscription(data);
  1763. }
  1764. }}
  1765. on:submit={async (e) => {
  1766. if (e.detail) {
  1767. await tick();
  1768. submitPrompt(
  1769. ($settings?.richTextInput ?? true)
  1770. ? e.detail.replaceAll('\n\n', '\n')
  1771. : e.detail
  1772. );
  1773. }
  1774. }}
  1775. />
  1776. </div>
  1777. {/if}
  1778. </div>
  1779. </Pane>
  1780. <ChatControls
  1781. bind:this={controlPaneComponent}
  1782. bind:history
  1783. bind:chatFiles
  1784. bind:params
  1785. bind:files
  1786. bind:pane={controlPane}
  1787. chatId={$chatId}
  1788. modelId={selectedModelIds?.at(0) ?? null}
  1789. models={selectedModelIds.reduce((a, e, i, arr) => {
  1790. const model = $models.find((m) => m.id === e);
  1791. if (model) {
  1792. return [...a, model];
  1793. }
  1794. return a;
  1795. }, [])}
  1796. {submitPrompt}
  1797. {stopResponse}
  1798. {showMessage}
  1799. {eventTarget}
  1800. />
  1801. </PaneGroup>
  1802. {:else if loading}
  1803. <div class=" flex items-center justify-center h-full w-full">
  1804. <div class="m-auto">
  1805. <Spinner />
  1806. </div>
  1807. </div>
  1808. {/if}
  1809. </div>