await this.updateConversationName(this.activeConversation.id, title);
}
- const allMessages = await DatabaseStore.getConversationMessages(this.activeConversation.id);
const assistantMessage = await this.createAssistantMessage(userMessage.id);
if (!assistantMessage) {
this.activeMessages.push(assistantMessage);
// Don't update currNode until after streaming completes to maintain proper conversation path
- await this.streamChatCompletion(allMessages, assistantMessage, undefined, (error: Error) => {
- if (error.name === 'ContextError' && userMessage) {
- const userMessageIndex = this.findMessageIndex(userMessage.id);
- if (userMessageIndex !== -1) {
- this.activeMessages.splice(userMessageIndex, 1);
- DatabaseStore.deleteMessage(userMessage.id).catch(console.error);
+ const conversationContext = this.activeMessages.slice(0, -1);
+
+ await this.streamChatCompletion(
+ conversationContext,
+ assistantMessage,
+ undefined,
+ (error: Error) => {
+ if (error.name === 'ContextError' && userMessage) {
+ const userMessageIndex = this.findMessageIndex(userMessage.id);
+
+ if (userMessageIndex !== -1) {
+ this.activeMessages.splice(userMessageIndex, 1);
+ DatabaseStore.deleteMessage(userMessage.id).catch(console.error);
+ }
}
}
- });
+ );
} catch (error) {
if (this.isAbortError(error)) {
this.isLoading = false;
this.currentResponse = '';
try {
- const allMessages = await DatabaseStore.getConversationMessages(this.activeConversation.id);
const assistantMessage = await this.createAssistantMessage();
if (!assistantMessage) {
await DatabaseStore.updateCurrentNode(this.activeConversation.id, assistantMessage.id);
this.activeConversation.currNode = assistantMessage.id;
- await this.streamChatCompletion(allMessages, assistantMessage);
+ const conversationContext = this.activeMessages.slice(0, -1);
+
+ await this.streamChatCompletion(conversationContext, assistantMessage);
} catch (regenerateError) {
console.error('Failed to regenerate response:', regenerateError);
this.isLoading = false;