# Find the project root by looking for pom.xml
PROJECT_ROOT="${SCRIPT_DIR}"
while [[ ! -f "${PROJECT_ROOT}/pom.xml" ]] && [[ "${PROJECT_ROOT}" != "/" ]]; do
    PROJECT_ROOT="$(dirname "${PROJECT_ROOT}")"
done
GENERATE_THUMBNAIL="${PROJECT_ROOT}/src/main/assemblies/files/generate-thumbnail"
TEST_DIR="${SCRIPT_DIR}"
OUTPUT_DIR="/tmp/thumbnail_test_$$"

# Color codes for output
RED='\033[0;31m'
GREEN='\033[0;32m'

                        }
                    }
                }

                @Override
                public void onChunk(final String content, final boolean done) {
                    try {
                        if (content != null && !content.isEmpty()) {
                            sendSseEvent(writer, "chunk", Map.of("content", content));
                        }

This can save everyone a lot of time and frustration.

For any non-trivial change, we need to be able to answer these questions:

* Why is this change done? What's the use case?
* For user-facing features, what will the API look like?
* What test cases should it have? What could go wrong?
* How will it roughly be implemented? We'll happily provide code pointers to save you time.

return f},ce.extend({Deferred:function(e){var o=[["notify","progress",ce.Callbacks("memory"),ce.Callbacks("memory"),2],["resolve","done",ce.Callbacks("once memory"),ce.Callbacks("once memory"),0,"resolved"],["reject","fail",ce.Callbacks("once memory"),ce.Callbacks("once memory"),1,"rejected"]],i="pending",a={state:function(){return i},always:function(){return s.done(arguments).fail(arguments),this},"catch":function(e){return a.then(null,e)},pipe:function(){var i=arguments;return ce.Deferred(func...

                }
            }
            callback.onChunk("response", true);
        });

        client.generateSummaryResponse("summarize", documents, history, (chunk, done) -> {});

        final String systemMsg = captured.toString();
        assertTrue(systemMsg.contains("HTML content"));
        assertFalse(systemMsg.contains("<p>"));
        assertFalse(systemMsg.contains("<strong>"));

                            dataMap.get(ComponentUtil.getFessConfig().getIndexFieldUrl()));
                }
            } finally {
                if (keyObj != null) {
                    crawlerStatsHelper.done(keyObj);
                }
            }
        });
    }

    /**
     * Retrieves a parameter value from the data store parameters map.
     *
     * @param paramMap the parameter map to search

     * is performed by the init() method which is called after construction.
     */
    public RankFusionProcessor() {
        // Default constructor - initialization is done in init() method
    }

    /**
     * Initializes the rank fusion processor after construction.
     * Sets up the window size based on configuration and loads available searchers.

      },
      "french_stop": {
        "type":       "stop",
        "stopwords":  "_french_"
      },
      "french_keywords": {
        "type":       "keyword_marker",
        "keywords": ["Bonjour", "monde", "recherche"]
      },
      "french_stemmer": {
        "type":       "stemmer",
        "language":   "light_french"
      },
      "german_stop": {
        "type":       "stop",

hasRun?this.result:(f=a,g.haltValidation(this.$form),this.haltedFormValidation=!0,this.isRunning=!0,this.$input.attr("disabled","disabled").addClass("async-validation"),this.$form.addClass("async-validation"),b(function(a){this.done(a)}.bind(this)),null)},d.prototype.done=function(a){this.result=a,this.hasRun=!0,this.isRunning=!1,this.$input.removeAttr("disabled").removeClass("async-validation"),this.$form.removeClass("async-validation"),this.haltedFormValidation&&(g.unHaltValidation(this.$form)...

            if (data.sources && data.sources.length > 0 && messageElement) {
                addSourcesToMessage(messageElement, data.sources);
            }
        });

        eventSource.addEventListener('done', function(e) {
            var data = JSON.parse(e.data);
            state.sessionId = data.sessionId;

            // Replace streaming text with rendered HTML content if available