Method parse_stream_content

src/common/AutoModel/modeling_lfm2.cpp:97–264

}

StreamResult LFM2::parse_stream_content(const std::string content) {
    const std::string TOOL_START = "<|tool_call_start|>";
    const std::string TOOL_END = "<|tool_call_end|>";

    StreamResult result;
    buffer_ += content;  

    while (true) {
        if (!is_in_tool_block_) {
            size_t tool_start_pos = buffer_.find(TOOL_START);

            if (tool_start_pos != std::string::npos) {
                if (tool_start_pos > 0) {
                    result.content = buffer_.substr(0, tool_start_pos);
                    result.type = StreamEventType::CONTENT;
                    buffer_ = buffer_.substr(tool_start_pos);
                    return result;
                }

                is_in_tool_block_ = true;
                tool_name_.clear();
                buffer_ = buffer_.substr(TOOL_START.length());
                result.type = StreamEventType::WAITING;
                return result;
            }
            else {
                if (!buffer_.empty()) {
                    result.content = buffer_;
                    result.type = StreamEventType::CONTENT;
                    buffer_.clear();
                    return result;
                }
                break;
            }
        }

        if (is_in_tool_block_) {
            size_t tool_end_pos = buffer_.find(TOOL_END);

            if (tool_end_pos != std::string::npos) {
                tool_name_ += buffer_.substr(0, tool_end_pos);
                buffer_ = buffer_.substr(tool_end_pos + TOOL_END.length());
                is_in_tool_block_ = false;

                std::string raw = tool_name_;

                size_t start = raw.find_first_not_of(" \t\n\r[");
                if (start == std::string::npos) {
                    result.type = StreamEventType::CONTENT;
                    result.content = "[Error: Empty tool call]";
                    return result;
                }
                raw = raw.substr(start);

                size_t pos_open = raw.find('(');
                if (pos_open == std::string::npos) {
                    result.type = StreamEventType::CONTENT;
                    result.content = "[Error: No function bracket found]";