Method handleIncompleteDataModel

core/src/stream/agenui_text_stream_plugin.cpp:159–252

}

bool TextStreamPlugin::handleIncompleteDataModel(
    const std::string& buffer,
    std::vector<ProtocolStreamExtractor::ParseResult>& outResults) {

    // 1. Extract the event path
    std::string rawPath = extractStringValue(buffer, "\"path\"");
    std::string eventPath = normalizePath(rawPath);

    // 2. Extract surfaceId
    std::string surfaceId = extractStringValue(buffer, "\"surfaceId\"");

    // 3. Find all registered Text binding paths that match by prefix or suffix
    std::vector<std::string> matchedBindings;
    for (const auto& bp : _textBindingPaths) {
        if (isPathPrefix(eventPath, bp) || isSuffixMatch(eventPath, bp)) {
            matchedBindings.push_back(bp);
        }
    }

    if (matchedBindings.empty()) {
        return false;
    }

    // 4. Navigate to the leaf string value for each matched binding path
    _streamingEntries.clear();
    for (const auto& bp : matchedBindings) {
        std::vector<std::string> segments;
        if (isPathPrefix(eventPath, bp)) {
            // Prefix match: navigate into nested object
            segments = computeRelativeSegments(eventPath, bp);
        } else {
            // Suffix match: value is a direct string; no navigation needed
            segments.clear();
        }

        size_t leafStart = locateNestedStringValue(buffer, segments);
        if (leafStart == std::string::npos) {
            continue;
        }

        // Check whether the leaf value is already closed
        size_t closePos = 0;
        if (isStringValueClosed(buffer, leafStart, closePos)) {
            continue; // Already closed; no streaming needed
        }

        TextDataModelStreamingEntry entry;
        entry.bindingPath = bp;
        entry.eventPath = eventPath;
        entry.surfaceId = surfaceId;
        entry.leafValueStart = leafStart;
        entry.lastSentEnd = 0;
        entry.firstEventSent = false;
        _streamingEntries.push_back(entry);
    }

    if (_streamingEntries.empty()) {
        return false;