Method Feed

internal/toolcall/parser.go:41–102

Feed 把新 chunk 喂入解析器,返回 (textDelta, toolCalls)。 textDelta 是本轮新产生的可输出文本(不含 标签及其内部 JSON); toolCalls 是本轮闭合的 tool_call 列表,顺序与出现顺序一致。

(chunk string)

// textDelta 是本轮新产生的可输出文本(不含 <tool_call> 标签及其内部 JSON);
// toolCalls 是本轮闭合的 tool_call 列表,顺序与出现顺序一致。
func (p *Parser) Feed(chunk string) (textDelta string, toolCalls []official.ToolCall) {
	p.buffer = normalize(p.buffer + chunk)
	var text strings.Builder
	for len(p.buffer) > 0 {
		if !p.inside {
			startIdx := strings.Index(p.buffer, StartTag)
			if startIdx >= 0 {
				pre := p.buffer[:startIdx]
				if pre != "" {
					// 已经被吐出的"半个标签"防误切,以及可能被截断的 JSON 防御
					// (looksLikeJSONJunk + 还没任何输出):这两种情况不输出,留待下个 chunk
					if !(p.emittedCount == 0 && p.emittedText == false && looksLikeJSONJunk(pre)) {
						text.WriteString(pre)
						if strings.TrimSpace(pre) != "" {
							p.emittedText = true
						}
					}
				}
				p.inside = true
				p.buffer = p.buffer[startIdx+len(StartTag):]
				continue
			}
			// 没找到 <tool_call>;但 buffer 末尾可能是 "<tool_call>" / "<tool_c" 等
			// "半个标签",需要保留若干字符避免误切。
			flushIndex := len(p.buffer)
			for i := 1; i < len(StartTag); i++ {
				if strings.HasSuffix(p.buffer, StartTag[:i]) {
					flushIndex = len(p.buffer) - i
					break
				}
			}
			pre := p.buffer[:flushIndex]
			if pre != "" {
				head := strings.TrimSpace(pre)
				// 防御:在还没有任何文本/工具被吐出的情况下,若 pre 看起来像 JSON
				// (被截断的 tool_call),先不要输出,等下一段判断
				if p.emittedCount == 0 && !p.emittedText && (strings.HasPrefix(head, "{") || strings.HasPrefix(head, "`")) {
					break
				}
				text.WriteString(pre)
				if strings.TrimSpace(pre) != "" {
					p.emittedText = true
				}
			}
			p.buffer = p.buffer[flushIndex:]
			break
		}
		// inside 模式:在 buffer 中寻找 </tool_call>
		endIdx := strings.Index(p.buffer, EndTag)
		if endIdx < 0 {
			break
		}
		raw := strings.TrimSpace(p.buffer[:endIdx])
		if tc := buildToolCallFromRaw(raw); tc != nil {
			toolCalls = append(toolCalls, *tc)
			p.emittedCount++
		}
		p.inside = false