移除聊天组件中的调试日志
This commit is contained in:
pingchuan
+63
-63
@@ -122,11 +122,11 @@ const handleStream = (
|
||||
onNodeFinished?: IOnNodeFinished,
|
||||
onError?: IOnError,
|
||||
) => {
|
||||
console.log('🌊 [handleStream] 开始处理流式响应:', {
|
||||
status: response.status,
|
||||
statusText: response.statusText,
|
||||
headers: Object.fromEntries(response.headers.entries())
|
||||
});
|
||||
// console.log('🌊 [handleStream] 开始处理流式响应:', {
|
||||
// status: response.status,
|
||||
// statusText: response.statusText,
|
||||
// headers: Object.fromEntries(response.headers.entries())
|
||||
// });
|
||||
|
||||
if (!response.ok) {
|
||||
console.error('❌ [handleStream] 响应错误:', response.status, response.statusText);
|
||||
@@ -141,19 +141,19 @@ const handleStream = (
|
||||
let isFirstMessage = true;
|
||||
let messageCount = 0;
|
||||
|
||||
console.log('📖 [handleStream] 获取reader:', !!reader);
|
||||
// console.log('📖 [handleStream] 获取reader:', !!reader);
|
||||
|
||||
function read() {
|
||||
let hasError = false;
|
||||
reader?.read().then((result: any) => {
|
||||
console.log('📨 [handleStream] 读取数据块:', {
|
||||
done: result.done,
|
||||
valueLength: result.value?.length,
|
||||
messageCount: ++messageCount
|
||||
});
|
||||
// console.log('📨 [handleStream] 读取数据块:', {
|
||||
// done: result.done,
|
||||
// valueLength: result.value?.length,
|
||||
// messageCount: ++messageCount
|
||||
// });
|
||||
|
||||
if (result.done) {
|
||||
console.log('✅ [handleStream] 流式响应完成, 总消息数:', messageCount);
|
||||
// console.log('✅ [handleStream] 流式响应完成, 总消息数:', messageCount);
|
||||
onCompleted && onCompleted();
|
||||
return;
|
||||
}
|
||||
@@ -162,31 +162,31 @@ const handleStream = (
|
||||
buffer += chunk;
|
||||
const lines = buffer.split('\n');
|
||||
|
||||
console.log('🔍 [handleStream] 处理数据块:', {
|
||||
chunkLength: chunk.length,
|
||||
bufferLength: buffer.length,
|
||||
linesCount: lines.length,
|
||||
chunk: chunk.substring(0, 100) + (chunk.length > 100 ? '...' : '')
|
||||
});
|
||||
// console.log('🔍 [handleStream] 处理数据块:', {
|
||||
// chunkLength: chunk.length,
|
||||
// bufferLength: buffer.length,
|
||||
// linesCount: lines.length,
|
||||
// chunk: chunk.substring(0, 100) + (chunk.length > 100 ? '...' : '')
|
||||
// });
|
||||
|
||||
try {
|
||||
lines.forEach((message, index) => {
|
||||
if (message.startsWith('data: ')) {
|
||||
const jsonStr = message.substring(6);
|
||||
console.log(`📋 [handleStream] 解析消息 ${index}:`, {
|
||||
jsonLength: jsonStr.length,
|
||||
preview: jsonStr.substring(0, 200) + (jsonStr.length > 200 ? '...' : '')
|
||||
});
|
||||
// console.log(`📋 [handleStream] 解析消息 ${index}:`, {
|
||||
// jsonLength: jsonStr.length,
|
||||
// preview: jsonStr.substring(0, 200) + (jsonStr.length > 200 ? '...' : '')
|
||||
// });
|
||||
|
||||
try {
|
||||
bufferObj = JSON.parse(jsonStr) as Record<string, any>;
|
||||
console.log('✨ [handleStream] JSON解析成功:', {
|
||||
event: bufferObj.event,
|
||||
hasAnswer: !!bufferObj.answer,
|
||||
answerLength: bufferObj.answer?.length || 0,
|
||||
conversationId: bufferObj.conversation_id,
|
||||
messageId: bufferObj.id || bufferObj.message_id
|
||||
});
|
||||
// console.log('✨ [handleStream] JSON解析成功:', {
|
||||
// event: bufferObj.event,
|
||||
// hasAnswer: !!bufferObj.answer,
|
||||
// answerLength: bufferObj.answer?.length || 0,
|
||||
// conversationId: bufferObj.conversation_id,
|
||||
// messageId: bufferObj.id || bufferObj.message_id
|
||||
// });
|
||||
}
|
||||
catch (e) {
|
||||
console.warn('⚠️ [handleStream] JSON解析失败:', e, 'JSON:', jsonStr);
|
||||
@@ -218,14 +218,14 @@ const handleStream = (
|
||||
|
||||
if (bufferObj.event === 'message' || bufferObj.event === 'agent_message') {
|
||||
const answer = unicodeToChar(bufferObj.answer);
|
||||
console.log('💬 [handleStream] 处理消息事件:', {
|
||||
event: bufferObj.event,
|
||||
isFirstMessage,
|
||||
answerLength: answer.length,
|
||||
answer: answer.substring(0, 50) + (answer.length > 50 ? '...' : ''),
|
||||
conversationId: bufferObj.conversation_id,
|
||||
messageId: bufferObj.id || bufferObj.message_id
|
||||
});
|
||||
// console.log('💬 [handleStream] 处理消息事件:', {
|
||||
// event: bufferObj.event,
|
||||
// isFirstMessage,
|
||||
// answerLength: answer.length,
|
||||
// answer: answer.substring(0, 50) + (answer.length > 50 ? '...' : ''),
|
||||
// conversationId: bufferObj.conversation_id,
|
||||
// messageId: bufferObj.id || bufferObj.message_id
|
||||
// });
|
||||
|
||||
onData(answer, isFirstMessage, {
|
||||
conversationId: bufferObj.conversation_id,
|
||||
@@ -234,44 +234,44 @@ const handleStream = (
|
||||
});
|
||||
isFirstMessage = false;
|
||||
} else if (bufferObj.event === 'agent_thought' && onThought) {
|
||||
console.log('🤔 [handleStream] 处理思考事件:', bufferObj.event);
|
||||
// console.log('🤔 [handleStream] 处理思考事件:', bufferObj.event);
|
||||
onThought(bufferObj as ThoughtItem);
|
||||
} else if (bufferObj.event === 'message_file' && onFile) {
|
||||
console.log('📁 [handleStream] 处理文件事件:', bufferObj.event);
|
||||
// console.log('📁 [handleStream] 处理文件事件:', bufferObj.event);
|
||||
onFile(bufferObj as VisionFile);
|
||||
} else if (bufferObj.event === 'message_end' && onMessageEnd) {
|
||||
console.log('🏁 [handleStream] 处理消息结束事件:', bufferObj.event);
|
||||
// console.log('🏁 [handleStream] 处理消息结束事件:', bufferObj.event);
|
||||
onMessageEnd(bufferObj as MessageEnd);
|
||||
} else if (bufferObj.event === 'message_replace' && onMessageReplace) {
|
||||
console.log('🔄 [handleStream] 处理消息替换事件:', bufferObj.event);
|
||||
// console.log('🔄 [handleStream] 处理消息替换事件:', bufferObj.event);
|
||||
onMessageReplace(bufferObj as MessageReplace);
|
||||
} else if (bufferObj.event === 'workflow_started' && onWorkflowStarted) {
|
||||
console.log('🚀 [handleStream] 处理工作流开始事件:', bufferObj.event);
|
||||
// console.log('🚀 [handleStream] 处理工作流开始事件:', bufferObj.event);
|
||||
onWorkflowStarted(bufferObj as WorkflowStartedResponse);
|
||||
} else if (bufferObj.event === 'workflow_finished' && onWorkflowFinished) {
|
||||
console.log('🎯 [handleStream] 处理工作流完成事件:', bufferObj.event);
|
||||
// console.log('🎯 [handleStream] 处理工作流完成事件:', bufferObj.event);
|
||||
onWorkflowFinished(bufferObj as WorkflowFinishedResponse);
|
||||
} else if (bufferObj.event === 'node_started' && onNodeStarted) {
|
||||
console.log('🔗 [handleStream] 处理节点开始事件:', bufferObj.event);
|
||||
// console.log('🔗 [handleStream] 处理节点开始事件:', bufferObj.event);
|
||||
onNodeStarted(bufferObj as NodeStartedResponse);
|
||||
} else if (bufferObj.event === 'node_finished' && onNodeFinished) {
|
||||
console.log('✅ [handleStream] 处理节点完成事件:', bufferObj.event);
|
||||
// console.log('✅ [handleStream] 处理节点完成事件:', bufferObj.event);
|
||||
onNodeFinished(bufferObj as NodeFinishedResponse);
|
||||
} else {
|
||||
console.log('❓ [handleStream] 未知事件类型:', bufferObj.event);
|
||||
// console.log('❓ [handleStream] 未知事件类型:', bufferObj.event);
|
||||
}
|
||||
} else if (message.trim()) {
|
||||
console.log('📝 [handleStream] 非data消息:', message.substring(0, 100));
|
||||
// console.log('📝 [handleStream] 非data消息:', message.substring(0, 100));
|
||||
}
|
||||
});
|
||||
|
||||
// 保留最后一行（可能是不完整的消息）
|
||||
const lastLine = lines[lines.length - 1];
|
||||
buffer = lastLine;
|
||||
console.log('💾 [handleStream] 保留缓冲区:', {
|
||||
lastLineLength: lastLine.length,
|
||||
preview: lastLine.substring(0, 50)
|
||||
});
|
||||
// console.log('💾 [handleStream] 保留缓冲区:', {
|
||||
// lastLineLength: lastLine.length,
|
||||
// preview: lastLine.substring(0, 50)
|
||||
// });
|
||||
}
|
||||
catch (err) {
|
||||
console.error('❌ [handleStream] 解析响应时出错:', err);
|
||||
@@ -286,10 +286,10 @@ const handleStream = (
|
||||
}
|
||||
|
||||
if (!hasError) {
|
||||
console.log('🔄 [handleStream] 继续读取下一块...');
|
||||
// console.log('🔄 [handleStream] 继续读取下一块...');
|
||||
read();
|
||||
} else {
|
||||
console.log('🛑 [handleStream] 因错误停止读取');
|
||||
// console.log('🛑 [handleStream] 因错误停止读取');
|
||||
}
|
||||
}).catch(err => {
|
||||
console.error('❌ [handleStream] 读取流时出错:', err);
|
||||
@@ -348,11 +348,11 @@ const baseFetch = (url: string, fetchOptions: any, needAllResponseContent: boole
|
||||
.then((res: Response) => {
|
||||
const resClone = res.clone();
|
||||
|
||||
console.log('📥 API Response:', {
|
||||
status: res.status,
|
||||
statusText: res.statusText,
|
||||
url: urlWithPrefix
|
||||
});
|
||||
// console.log('📥 API Response:', {
|
||||
// status: res.status,
|
||||
// statusText: res.statusText,
|
||||
// url: urlWithPrefix
|
||||
// });
|
||||
|
||||
// 错误处理
|
||||
if (!/^(2|3)\d{2}$/.test(res.status.toString())) {
|
||||
@@ -456,11 +456,11 @@ export const ssePost = (
|
||||
|
||||
return fetch(urlWithPrefix, options)
|
||||
.then((res: Response) => {
|
||||
console.log('📡 SSE Response:', {
|
||||
status: res.status,
|
||||
statusText: res.statusText,
|
||||
url: urlWithPrefix
|
||||
});
|
||||
// console.log('📡 SSE Response:', {
|
||||
// status: res.status,
|
||||
// statusText: res.statusText,
|
||||
// url: urlWithPrefix
|
||||
// });
|
||||
|
||||
if (!/^(2|3)\d{2}$/.test(res.status.toString())) {
|
||||
res.json().then((data: any) => {
|
||||
|
||||
Reference in New Issue
Block a user