}
        }
        return versionsToIncubating
    }

    private
    fun CompilationUnit.findAllIncubating() =
        findAll(Node::class.java).filter { it.isIncubating }

    private
    val Node.isIncubating: Boolean
        get() = (this as? NodeWithAnnotations<*>)?.annotations?.any { it.nameAsString == "Incubating" } ?: false

    private

     * @param withRoleType whether to include role type information (currently not used in implementation)
     * @param available whether to filter only available configurations
     * @param idList the list of configuration IDs to retrieve, or null for no ID filtering
     * @return a list of WebConfig objects matching the criteria
     */

        final String name = fessConfig.getQueryBrowserLangParameterName();
        if (StringUtil.isNotBlank(name)) {
            try {
                return requestManager.getParameter(name).filter(StringUtil::isNotBlank).map(LocaleUtils::toLocale);
            } catch (final Exception e) {
                logger.debug("Failed to parse locale: name={}", name, e);
            }
        }

        bool((must, should, mustNot, filter) -> {
            filteredLambda.callback(must, filter);
        }, opLambda);
    }

    public void not(OperatorCall<GroupCQ> notLambda) {
        not(notLambda, null);
    }

    public void not(final OperatorCall<GroupCQ> notLambda, final ConditionOptionCall<BoolQueryBuilder> opLambda) {
        bool((must, should, mustNot, filter) -> notLambda.callback(mustNot), opLambda);
    }

        assertEquals("******@****.***", supportEmail);

        // Count @ occurrences - should be exactly 1
        assertEquals(1, technicalEmail.chars().filter(ch -> ch == '@').count());
        assertEquals(1, supportEmail.chars().filter(ch -> ch == '@').count());
    }

    @Test
    public void test_defaultSettings_securityConfiguration() throws Exception {

# Number of primary shards for crawler filter index.
index.document.crawler.filter.number_of_shards=10
# Number of replicas for crawler queue index.
index.document.crawler.queue.number_of_replicas=1
# Number of replicas for crawler data index.
index.document.crawler.data.number_of_replicas=1
# Number of replicas for crawler filter index.
index.document.crawler.filter.number_of_replicas=1
# Index name for configuration data.

            if (StringUtil.isNotBlank(requiredKeysStr) && StreamUtil.split(requiredKeysStr, ",")
                    .get(stream -> stream.map(String::trim).filter(StringUtil::isNotEmpty).anyMatch(name -> {
                        final String[] values = req.getParameterValues(name);
                        if (values == null || values.length == 0 || StringUtil.isEmpty(values[0])) {

                ),
                "-PflakyTests=${FlakyTestStrategy.EXCLUDE}",
                extraParameters,
                parallelizationMethod.extraBuildParameters,
            ).filter { it.isNotBlank() }.joinToString(separator = " ")

        if (parallelizationMethod is ParallelizationMethod.TeamCityParallelTests) {
            tcParallelTests(parallelizationMethod.numberOfBatches)
        }

                final String name = accessToken.getParameterName();
                stream(request.getParameterValues(name)).of(stream -> stream.filter(StringUtil::isNotBlank).forEach(permissionSet::add));
                return OptionalEntity.of(permissionSet);
            }).orElseThrow(() -> new InvalidAccessTokenException("invalid_token", "Invalid token: " + token));

    /**
     * Creates a new IndexExportJob instance.
     */
    public IndexExportJob() {
        // default constructor
    }

    /**
     * Sets the query to filter which documents to export.
     *
     * @param queryBuilder the query to use for filtering documents
     * @return this instance for method chaining
     */
    public IndexExportJob query(final QueryBuilder queryBuilder) {