[ZEPPELIN-6742] Connect the AI Assistant frontend to conversation REST and WebSocket APIs

zeppelin-web-angular/projects/zeppelin-react/src/entities/assistant/model/assistantContract.ts

@@ -48,9 +48,6 @@ export interface AssistantMessagePage {
   /** Pass as `before` to load older messages; null at the start of the conversation. */
   cursor: string | null;
 }
-export interface AssistantRunBody {
-  content: string;
-}
 export type AssistantRunEvent =
   | { type: 'run.started'; runId?: string }
   | { type: 'run.completed'; runId?: string }
@@ -60,19 +57,13 @@ export type AssistantRunEvent =
   | { type: 'tool_call.started'; toolCallId: string; name: string }
   | { type: 'tool_call.done'; toolCallId: string };
 
-export type AssistantRunState = 'idle' | 'running' | 'disconnected';
-
-export interface AssistantTransport {
-  /** Conversations of the note the transport was created for. */
+export interface AssistantConversationApi {
+  /** Conversations of the note the API was created for. */
   listConversations(): Promise<AssistantConversation[]>;
   createConversation(body: { title?: string }): Promise<AssistantConversation>;
   deleteConversation(conversationId: string): Promise<void>;
   /** The latest page of history, or the page before `before` (a page cursor). */
   getMessages(conversationId: string, before?: string): Promise<AssistantMessagePage>;
-  /** Observe local run state, including a lost connection until history is reloaded. */
-  subscribeRunState?(conversationId: string, listener: (state: AssistantRunState) => void): () => void;
-  /** Aborting stops local event consumption; it does not cancel a run already accepted by the server. */
-  openRun(conversationId: string, body: AssistantRunBody, signal: AbortSignal): AsyncIterable<AssistantRunEvent>;
 }
 
 export class AssistantStreamError extends Error {