From b9a4e8cf3202455eb329b210fa77b7353b4b8abc Mon Sep 17 00:00:00 2001
From: Lyubov Voloshko <lyubov@voloshko.com>
Date: Fri, 20 Jun 2025 10:27:47 +0300
Subject: [PATCH 1/3] WIP add Create ai thread request

---
 .../db-table-ai-panel.component.html          |  4 +-
 .../db-table-ai-panel.component.ts            | 43 +++++++++++++++++++
 frontend/src/app/services/tables.service.ts   | 26 +++++++----
 3 files changed, 62 insertions(+), 11 deletions(-)

diff --git a/frontend/src/app/components/dashboard/db-table-ai-panel/db-table-ai-panel.component.html b/frontend/src/app/components/dashboard/db-table-ai-panel/db-table-ai-panel.component.html
index 415dda398..e53ee953a 100644
--- a/frontend/src/app/components/dashboard/db-table-ai-panel/db-table-ai-panel.component.html
+++ b/frontend/src/app/components/dashboard/db-table-ai-panel/db-table-ai-panel.component.html
@@ -32,7 +32,7 @@ <h2 class="mat-heading-2 ai-panel-sidebar__title">
                 <mat-action-list role="list">
                     <button mat-list-item *ngFor="let suggestion of aiRequestSuggestions"
                         class="suggestion-button"
-                        (click)="sendMessage(suggestion)"
+                        (click)="createThread(suggestion)"
                         angulartics2On="click"
                         angularticsAction="AI panel: suggested request is clicked">
                         {{suggestion}}
@@ -48,7 +48,7 @@ <h2 class="mat-heading-2 ai-panel-sidebar__title">
             </div>
         </div>
 
-        <form (ngSubmit)="sendMessage()" class="ai-message-form">
+        <form (ngSubmit)="threadID ? sendMessage() : createThread()" class="ai-message-form">
             <mat-form-field class="form-field" appearance="outline" class="ai-message-form__textarea">
                 <mat-label class="ai-message-form__label">What should I analyze?</mat-label>
                 <textarea matInput name="message"
diff --git a/frontend/src/app/components/dashboard/db-table-ai-panel/db-table-ai-panel.component.ts b/frontend/src/app/components/dashboard/db-table-ai-panel/db-table-ai-panel.component.ts
index ee8ce73e6..a30308503 100644
--- a/frontend/src/app/components/dashboard/db-table-ai-panel/db-table-ai-panel.component.ts
+++ b/frontend/src/app/components/dashboard/db-table-ai-panel/db-table-ai-panel.component.ts
@@ -40,6 +40,7 @@ export class DbTableAiPanelComponent implements OnInit, OnDestroy {
   public isAIpanelOpened: boolean = false;
   public message: string = '';
   public charactrsNumber: number = 0;
+  public threadID: string = '';
   public messagesChain: {
     type: string;
     text: string
@@ -99,6 +100,48 @@ export class DbTableAiPanelComponent implements OnInit, OnDestroy {
     }
   }
 
+  createThread(suggestedMessage?: string) {
+    if (suggestedMessage) {
+      this.message = suggestedMessage;
+    }
+    this.submitting = true;
+    this.messagesChain.push({
+      type: 'user',
+      text: this.message
+    });
+    const messageCopy = this.message;
+    this.message = '';
+
+    this._tables.createThread(this.connectionID, this.tableName, messageCopy).subscribe((response) => {
+      // this.messagesChain = [];
+      console.log('Thread created successfully', response);
+      this.threadID = response.thread_id;
+
+      this.messagesChain.push({
+        type: 'ai',
+        text: this.markdownService.parse(response.response_message) as string
+      });
+      this.submitting = false;
+
+      this.angulartics2.eventTrack.next({
+        action: 'AI panel: thread created successfully',
+      });
+    },
+      (error_message) => {
+        this.messagesChain.push({
+          type: 'ai-error',
+          text: error_message
+        });
+        this.angulartics2.eventTrack.next({
+          action: 'AI panel: thread creation returned an error',
+        });
+      },
+      () => {
+        this.submitting = false;
+      }
+    );
+  }
+
   sendMessage(suggestedMessage?: string): void {
     if (suggestedMessage) {
       this.message = suggestedMessage;
diff --git a/frontend/src/app/services/tables.service.ts b/frontend/src/app/services/tables.service.ts
index 3e29f7c2f..cfeaa664b 100644
--- a/frontend/src/app/services/tables.service.ts
+++ b/frontend/src/app/services/tables.service.ts
@@ -470,6 +470,23 @@ export class TablesService {
       );
   }
 
+  createThread(connectionID, tableName, message) {
+    return this._http.post<any>(`/ai/thread/${connectionID}`, {user_message: message}, {
+      params: {
+        tableName
+      }
+    })
+      .pipe(
+        map((res) => {
+          return res
+        }),
+        catchError((err) => {
+          console.log(err);
+          return throwError(() => new Error(err.error.message));
+        })
+      );
+  }
+
   requestAI(connectionID: string, tableName: string, message: string) {
     return this._http.post<any>(`/ai/request/${connectionID}`, {user_message: message}, {
       params: {
@@ -478,19 +495,10 @@ export class TablesService {
     })
       .pipe(
         map((res) => {
-          // this.tables.next('activate actions');
-          // this._notifications.showSuccessSnackbar(`${action.title} is done for ${primaryKeys.length} rows.`);
           return res
         }),
         catchError((err) => {
           console.log(err);
-          // this._notifications.showAlert(AlertType.Error, {abstract: err.error.message, details: err.error.originalMessage}, [
-          //   {
-          //     type: AlertActionType.Button,
-          //     caption: 'Dismiss',
-          //     action: (id: number) => this._notifications.dismissAlert()
-          //   }
-          // ]);
           return throwError(() => new Error(err.error.message));
         })
       );

From 190fbf603de20c54bc1c05b27f56b452a2e07f18 Mon Sep 17 00:00:00 2001
From: Lyubov Voloshko <lyubov@voloshko.com>
Date: Sat, 28 Jun 2025 22:36:13 +0300
Subject: [PATCH 2/3] ai assistant: create thread on first message and keep
 dialog in one thread

---
 .../db-table-ai-panel.component.ts             | 18 ++++++++----------
 frontend/src/app/services/tables.service.ts    | 17 ++++++++++++-----
 2 files changed, 20 insertions(+), 15 deletions(-)

diff --git a/frontend/src/app/components/dashboard/db-table-ai-panel/db-table-ai-panel.component.ts b/frontend/src/app/components/dashboard/db-table-ai-panel/db-table-ai-panel.component.ts
index a30308503..b3f89312e 100644
--- a/frontend/src/app/components/dashboard/db-table-ai-panel/db-table-ai-panel.component.ts
+++ b/frontend/src/app/components/dashboard/db-table-ai-panel/db-table-ai-panel.component.ts
@@ -1,6 +1,6 @@
+import { Angulartics2, Angulartics2Module } from 'angulartics2';
 import { Component, ElementRef, Input, OnDestroy, OnInit, ViewChild } from '@angular/core';
 
-import { Angulartics2, Angulartics2Module } from 'angulartics2';
 import { CommonModule } from '@angular/common';
 import { ConnectionsService } from 'src/app/services/connections.service';
 import { FormsModule } from '@angular/forms';
@@ -10,9 +10,9 @@ import { MatButtonModule } from '@angular/material/button';
 import { MatFormFieldModule } from '@angular/material/form-field';
 import { MatIconModule } from '@angular/material/icon';
 import { MatInputModule } from '@angular/material/input';
+import { MatListModule } from '@angular/material/list';
 import { TableStateService } from 'src/app/services/table-state.service';
 import { TablesService } from 'src/app/services/tables.service';
-import { MatListModule } from '@angular/material/list';
 
 @Component({
   selector: 'app-db-table-ai-panel',
@@ -40,7 +40,7 @@ export class DbTableAiPanelComponent implements OnInit, OnDestroy {
   public isAIpanelOpened: boolean = false;
   public message: string = '';
   public charactrsNumber: number = 0;
-  public threadID: string = '';
+  public threadID: string = null;
   public messagesChain: {
     type: string;
     text: string
@@ -95,7 +95,7 @@ export class DbTableAiPanelComponent implements OnInit, OnDestroy {
         });
       } else {
         event.preventDefault();
-        this.sendMessage();
+        this.createThread();
       }
     }
   }
@@ -112,14 +112,12 @@ export class DbTableAiPanelComponent implements OnInit, OnDestroy {
     const messageCopy = this.message;
     this.message = '';
 
-    this._tables.createThread(this.connectionID, this.tableName, messageCopy).subscribe((response) => {
-      // this.messagesChain = [];
-      console.log('Thread created successfully', response);
-      this.threadID = response.thread_id;
+    this._tables.createAIthread(this.connectionID, this.tableName, messageCopy).subscribe((response) => {
+      this.threadID = response.threadId;
 
       this.messagesChain.push({
         type: 'ai',
-        text: this.markdownService.parse(response.response_message) as string
+        text: this.markdownService.parse(response.responseMessage) as string
       });
       this.submitting = false;
 
@@ -154,7 +152,7 @@ export class DbTableAiPanelComponent implements OnInit, OnDestroy {
     const messageCopy = this.message;
     this.message = '';
     this.charactrsNumber = 0;
-    this._tables.requestAI(this.connectionID, this.tableName, messageCopy).subscribe((response) => {
+    this._tables.requestAImessage(this.connectionID, this.tableName, this.threadID, messageCopy).subscribe((response) => {
       this.messagesChain.push({
         type: 'ai',
         text: this.markdownService.parse(response.response_message) as string
diff --git a/frontend/src/app/services/tables.service.ts b/frontend/src/app/services/tables.service.ts
index cfeaa664b..3f1323745 100644
--- a/frontend/src/app/services/tables.service.ts
+++ b/frontend/src/app/services/tables.service.ts
@@ -1,11 +1,11 @@
 import { AlertActionType, AlertType } from '../models/alert';
 import { BehaviorSubject, EMPTY, throwError } from 'rxjs';
 import { CustomAction, Rule, TableSettings, Widget } from '../models/table';
+import { HttpClient, HttpHeaders } from '@angular/common/http';
 import { NavigationEnd, Router } from '@angular/router';
 import { catchError, filter, map } from 'rxjs/operators';
 
 import { Angulartics2 } from 'angulartics2';
-import { HttpClient } from '@angular/common/http';
 import { Injectable } from '@angular/core';
 import { NotificationsService } from './notifications.service';
 
@@ -470,15 +470,22 @@ export class TablesService {
       );
   }
 
-  createThread(connectionID, tableName, message) {
+  createAIthread(connectionID, tableName, message) {
     return this._http.post<any>(`/ai/thread/${connectionID}`, {user_message: message}, {
+      responseType: 'text' as 'json',
+      observe: 'response',
       params: {
         tableName
       }
     })
       .pipe(
         map((res) => {
-          return res
+          const threadId = res.headers.get('x-openai-thread-id');
+          this.angulartics2.eventTrack.next({
+            action: 'AI: thread created'
+          });
+          const responseMessage = res.body as string;
+          return {threadId, responseMessage}
         }),
         catchError((err) => {
           console.log(err);
@@ -487,8 +494,8 @@ export class TablesService {
       );
   }
 
-  requestAI(connectionID: string, tableName: string, message: string) {
-    return this._http.post<any>(`/ai/request/${connectionID}`, {user_message: message}, {
+  requestAImessage(connectionID: string, tableName: string, threadId: string, message: string) {
+    return this._http.post<any>(`/ai/thread/message/${connectionID}/${threadId}`, {user_message: message}, {
       params: {
         tableName
       }

From 87aa2e0f61015da6ae8354ade4d4997bb94f0ba7 Mon Sep 17 00:00:00 2001
From: Lyubov Voloshko <lyubov@voloshko.com>
Date: Tue, 22 Jul 2025 16:09:07 +0300
Subject: [PATCH 3/3] update ai thread request url

---
 frontend/src/app/services/tables.service.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/frontend/src/app/services/tables.service.ts b/frontend/src/app/services/tables.service.ts
index 3f1323745..85498185e 100644
--- a/frontend/src/app/services/tables.service.ts
+++ b/frontend/src/app/services/tables.service.ts
@@ -471,7 +471,7 @@ export class TablesService {
   }
 
   createAIthread(connectionID, tableName, message) {
-    return this._http.post<any>(`/ai/thread/${connectionID}`, {user_message: message}, {
+    return this._http.post<any>(`/ai/v2/request/${connectionID}`, {user_message: message}, {
       responseType: 'text' as 'json',
       observe: 'response',
       params: {