L53: final EncodingFilter filter = new EncodingFilter(); L54: Map<String, String[]> paramMap; L55: L56: paramMap = filter.parseQueryString("a=", "UTF-8"); L57: assertEquals(1, paramMap.size()); L58: assertEquals("", paramMap.get("a")[0]); L59: L60: paramMap = filter.parseQueryString("a", "UTF-8"); L61: assertEquals(1, paramMap.size()); L62: assertEquals("", paramMap.get("a")[0]); L63: L64: paramMap = filter.parseQueryString("=1", "UTF-8");...

fessConfig.getQueryMaxLengthAsInteger(); L159: L160: stream(conditions.get(SearchRequestParams.AS_OCCURRENCE)) L161: .of(stream -> stream.filter(this::isOccurrence).findFirst().ifPresent(q -> queryBuf.insert(0, q + ":"))); L162: L163: stream(conditions.get(SearchRequestParams.AS_Q)).of(stream -> stream L164: .filter(q -> StringUtil.isNotBlank(q) && q.length() <= maxQueryLength).forEach(q -> queryBuf.append(' ').append(q))); L165: stream(conditions.get(Sear...

L20:import java.util.LinkedHashMap; L21:import java.util.List; L22:import java.util.Map; L23: L24:import org.codelibs.fess.Constants; L25:import org.opensearch.search.aggregations.Aggregations; L26:import org.opensearch.search.aggregations.bucket.filter.Filter; L27:import org.opensearch.search.aggregations.bucket.terms.Terms; L28: L29:import com.google.common.io.BaseEncoding; L30: L31:public class FacetResponse { L32: protected Map<String, Long> queryCountMap = new LinkedHashMap<>(); L33: L34: ...

form.permissions = stream(entity.getPermissions()).get(stream -> stream.map(s -> permissionHelper.decode(s)) L154: .filter(StringUtil::isNotBlank).distinct().collect(Collectors.joining("\n"))); L155: form.virtualHosts = stream(entity.getVirtualHosts()) L156: .get(stream -> stream.filter(StringUtil::isNotBlank).map(String::trim).collect(Collectors.joining("\n"))); L157: form.name = null; L158: ...

form.permissions = stream(entity.getPermissions()).get(stream -> stream.map(s -> permissionHelper.decode(s)) L158: .filter(StringUtil::isNotBlank).distinct().collect(Collectors.joining("\n"))); L159: form.virtualHosts = stream(entity.getVirtualHosts()) L160: .get(stream -> stream.filter(StringUtil::isNotBlank).map(String::trim).collect(Collectors.joining("\n"))); L161: form.name = null; L162: ...

final String[] permissions = split(getValue(list, 2), ",").get(stream -> stream.map(permissionHelper::encode) L202: .filter(StringUtil::isNotBlank).distinct().toArray(n -> new String[n])); L203: final String[] labels = split(getValue(list, 3), ",") L204: .get(stream -> stream.filter(StringUtil::isNotBlank).distinct().toArray(n -> new String[n])); L205: ElevateWord elevateWord = elevateWordBhv.selectEntity(cb...

AggregationBuilders.missing(name).field(field); L191: regA(builder); L192: return builder; L193: } L194: L195: protected FilterAggregationBuilder regFilterA(String name, QueryBuilder filter) { L196: FilterAggregationBuilder builder = AggregationBuilders.filter(name, filter); L197: regA(builder); L198: return builder; L199: } L200: L201: protected GlobalAggregationBuilder regGlobalA(String name) { L202: GlobalAggregationBuilder builder = Aggrega...

invalidIndexArrayFields(final Map<String, Object> source) { L1310: // TODO always returns empty list L1311: return split(getIndexAdminArrayFields(), ",").get(stream -> stream.filter(StringUtil::isNotBlank).map(String::trim) L1312: .filter(s -> isNonEmptyValue(source.get(s))).filter(s -> false) // TODO L1313: .collect(Collectors.toList())); L1314: } L1315: L1316: String getIndexAdminDateFields(); L1317: L1318: default Set<String> getIndexAdminDateFieldSet()...

L223: } L224: } L225: L226: // ----------------------------------------------------- L227: // Parameter Logging L228: // ----------------- L229: // logging filter cannot show the parameters when multi-part so logging here L230: protected void showFieldLoggingTitle() { L231: if (logger.isDebugEnabled()) { L232: logger.debug("[Multipart Request Parameter]"); L233: } L234: } L235:...

assertTrue(called.get()); L48: assertEquals(BoolQueryBuilder.class, queryBuilder.getClass()); L49: L50: called.set(false); L51: final AtomicBoolean calledFirst = new AtomicBoolean(false); L52: queryProcessor.addFilter(new QueryProcessor.Filter() { L53: @Override L54: public QueryBuilder execute(QueryContext context, Query query, float boost, FilterChain chain) { L55: calledFirst.set(true); L56: assertFalse(called.get()); L57: ...