Skip to content

Commit 23b2e2d

Browse files
committed
add support for sending live messages
1 parent 21a55a0 commit 23b2e2d

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

src/app/components/chat/chat.component.ts

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1110,6 +1110,10 @@ export class ChatComponent implements OnInit, AfterViewInit, OnDestroy {
11101110

11111111
submitAgentRunRequest(req: AgentRunRequest) {
11121112
this.autoSelectLatestEvent = true;
1113+
if (this.useLive()) {
1114+
this.streamChatService.sendMessage(req, {});
1115+
return;
1116+
}
11131117
this.agentService.runSse(req).subscribe({
11141118
next: async (chunkJson: any) => {
11151119
if (chunkJson.error) {
@@ -1150,7 +1154,7 @@ export class ChatComponent implements OnInit, AfterViewInit, OnDestroy {
11501154
});
11511155
}
11521156

1153-
private appendEventRow(apiEvent: any, reverseOrder: boolean = false) {
1157+
private appendEventRow(apiEvent: AdkEvent, reverseOrder: boolean = false) {
11541158
if (apiEvent.inputTranscription !== undefined) {
11551159
apiEvent.author = 'user';
11561160
} else if (apiEvent.outputTranscription !== undefined) {
@@ -1173,7 +1177,7 @@ export class ChatComponent implements OnInit, AfterViewInit, OnDestroy {
11731177
if (apiEvent?.longRunningToolIds && apiEvent.longRunningToolIds.length > 0) {
11741178
const startIndex = this.longRunningEvents.length;
11751179
this.getAsyncFunctionsFromParts(
1176-
apiEvent.longRunningToolIds, apiEvent.content.parts, apiEvent.invocationId);
1180+
apiEvent.longRunningToolIds, apiEvent.content.parts, apiEvent.invocationId!!);
11771181

11781182
// Store event ID for later reference
11791183
this.functionCallEventId = apiEvent.id;

0 commit comments

Comments
 (0)