Skip to content

Commit 7f4d206

Browse files
committed
Improve message handling and logging in chat flow
Removed unnecessary console logs from PlanChatBody. Enhanced logging in WebSocketService for better message type tracking. Fixed PlanPage to clear streaming buffer and correctly handle agent and final result messages, improving UI state management.
1 parent f58c816 commit 7f4d206

File tree

3 files changed

+13
-8
lines changed

3 files changed

+13
-8
lines changed

src/frontend/src/components/content/PlanChatBody.tsx

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,6 @@ const PlanChatBody: React.FC<SimplifiedPlanChatProps> = ({
1414
OnChatSubmit,
1515
waitingForPlan
1616
}) => {
17-
console.log("Rendering PlanChatBody", { planData, input, submittingChatDisableInput, waitingForPlan });
18-
1917
return (
2018

2119
<div style={{

src/frontend/src/pages/PlanPage.tsx

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -149,6 +149,7 @@ const PlanPage: React.FC = () => {
149149
console.log('✅ Parsed clarification message:', agentMessageData);
150150
setClarificationMessage(clarificationMessage.data as ParsedUserClarification | null);
151151
setAgentMessages(prev => [...prev, agentMessageData]);
152+
setStreamingMessageBuffer("");
152153
setSubmittingChatDisableInput(false);
153154
scrollToBottom();
154155

@@ -178,12 +179,12 @@ const PlanPage: React.FC = () => {
178179
timestamp: Date.now(),
179180
steps: [], // intentionally always empty
180181
next_steps: [], // intentionally always empty
181-
raw_content: finalMessage.content || '',
182-
raw_data: finalMessage || '',
182+
raw_content: finalMessage.data.content || '',
183+
raw_data: finalMessage.data || '',
183184
} as AgentMessageData;
184185
console.log('✅ Parsed final result message:', agentMessageData);
186+
setStreamingMessageBuffer("");
185187
setAgentMessages(prev => [...prev, agentMessageData]);
186-
setSubmittingChatDisableInput(true);
187188
scrollToBottom();
188189

189190
});
@@ -438,7 +439,7 @@ const PlanPage: React.FC = () => {
438439
);
439440
}
440441
} finally {
441-
setSubmittingChatDisableInput(false);
442+
442443
}
443444
},
444445
[planData?.plan, showToast, dismissToast, loadPlanData]

src/frontend/src/services/WebSocketService.tsx

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -183,13 +183,13 @@ class WebSocketService {
183183

184184
//console.log('WebSocket message received:', message);
185185
const hasClarification = /\bclarifications?\b/i.test(message.data || '');
186-
console.log("Message ':", message);
186+
187187
if (hasClarification) {
188188
console.log("Message contains 'clarification':", message.data);
189189
}
190190
switch (message.type) {
191191
case WebsocketMessageType.PLAN_APPROVAL_REQUEST: {
192-
console.log("enter plan approval request");
192+
console.log("Message Plan Approval Request':", message);
193193
const parsedData = PlanDataService.parsePlanApprovalRequest(message.data);
194194
if (parsedData) {
195195
const structuredMessage: ParsedPlanApprovalRequest = {
@@ -206,6 +206,7 @@ class WebSocketService {
206206
}
207207

208208
case WebsocketMessageType.AGENT_MESSAGE: {
209+
console.log("Message Agent':", message);
209210
if (message.data) {
210211
console.log('WebSocket message received:', message);
211212
const transformed = PlanDataService.parseAgentMessage(message);
@@ -224,6 +225,7 @@ class WebSocketService {
224225
}
225226

226227
case WebsocketMessageType.USER_CLARIFICATION_REQUEST: {
228+
console.log("Message clarification':", message);
227229
if (message.data) {
228230
const transformed = PlanDataService.parseUserClarificationRequest(message);
229231
console.log('WebSocket USER_CLARIFICATION_REQUEST message received:', transformed);
@@ -234,13 +236,15 @@ class WebSocketService {
234236

235237

236238
case WebsocketMessageType.AGENT_TOOL_MESSAGE: {
239+
console.log("Message agent tool':", message);
237240
if (message.data) {
238241
//const transformed = PlanDataService.parseUserClarificationRequest(message);
239242
this.emit(WebsocketMessageType.AGENT_TOOL_MESSAGE, message);
240243
}
241244
break;
242245
}
243246
case WebsocketMessageType.FINAL_RESULT_MESSAGE: {
247+
console.log("Message final result':", message);
244248
if (message.data) {
245249
//const transformed = PlanDataService.parseFinalResultMessage(message);
246250
this.emit(WebsocketMessageType.FINAL_RESULT_MESSAGE, message);
@@ -254,11 +258,13 @@ class WebSocketService {
254258
case WebsocketMessageType.AGENT_STREAM_START:
255259
case WebsocketMessageType.AGENT_STREAM_END:
256260
case WebsocketMessageType.SYSTEM_MESSAGE: {
261+
console.log("Message other types':", message);
257262
this.emit(message.type, message);
258263
break;
259264
}
260265

261266
default: {
267+
console.log("Message default':", message);
262268
this.emit(message.type, message);
263269
break;
264270
}

0 commit comments

Comments
 (0)