L305: L306: @Execute L307: @Secured({ ROLE, ROLE + VIEW }) L308: public ActionResponse download(final String id) { L309: if (stream(fessConfig.getIndexBackupAllTargets()).get(stream -> stream.anyMatch(s -> s.equals(id)))) { L310: if ("system.properties".equals(id)) { L311: return asStream(id).contentTypeOctetStream().stream(out -> { L312: try (final ByteArrayOutputStream baos = new ByteArrayOutputStream()) { L313: Co...

propMap.put(DEFAULT_SORT_VALUES, list); L240: } L241: return list.stream().map(p -> { L242: final String key = p.getFirst(); L243: if (StringUtil.isEmpty(key) || userBean L244: .map(user -> stream(user.getRoles()).get(stream -> stream.anyMatch(s -> (ROLE_VALUE_PREFIX + s).equals(key))) L245: || stream(user.getGroups()).get(stream -> stream.anyMatch(s -> (GROUP_VALUE_PREFIX + s).equals(key)))) L246: ...

L115: final Set<String> permissionSet = new HashSet<>(); L116: permissionSet.add(systemHelper.getSearchRoleByUser(name)); L117: stream(groups).of(stream -> stream.forEach(s -> permissionSet.add(systemHelper.getSearchRoleByGroup(s)))); L118: stream(roles).of(stream -> stream.forEach(s -> permissionSet.add(systemHelper.getSearchRoleByRole(s)))); L119: permissions = permissionSet.toArray(new String[permissionSet.size()]); L120: ...

ComponentUtil.getFessConfig(); L94: split(fessConfig.getSuggestFieldContents(), ",") L95: .of(stream -> stream.filter(StringUtil::isNotBlank).forEach(contentFieldNameSet::add)); L96: split(fessConfig.getSuggestFieldTags(), ",").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(tagFieldNameSet::add)); L97: split(fessConfig.getSuggestFieldRoles(), ",").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(roleFieldNameSet::add)); L98: contentFieldList = Arra...

License. L15: */ L16:package org.codelibs.fess.query; L17: L18:import static org.codelibs.core.stream.StreamUtil.split; L19:import static org.codelibs.core.stream.StreamUtil.stream; L20: L21:import java.util.ArrayList; L22:import java.util.Collections; L23:import java.util.HashSet; L24:import java.util.List; L25:import java.util.Set; L26:import java.util.function.Consumer; L27:import java.util.stream.Stream; L28: L29:import org.apache.logging.log4j.LogManager; L30:import org.apache.logging.log4j.Logger;...

seInnerHitsName() + "_hash", bitsField.getValues().get(0)); L90: } L91: docMap.put(fessConfig.getQueryCollapseInnerHitsName(), StreamUtil.stream(innerSearchHits.getHits()) L92: .get(stream -> stream.map(v -> parseSearchHit(fessConfig, hlPrefix, v)).toArray(n -> new Map[n]))); L93: } L94: } L95: } L96: } L97: L98: ...

builder.setQuery(parameter.getQuery()); L785: stream(parameter.getSuggestFields()).of(stream -> stream.forEach(builder::addField)); L786: roleQueryHelper.build(SearchRequestType.SUGGEST).stream().forEach(builder::addRole); L787: builder.setSize(parameter.getNum()); L788: stream(langs).of(stream -> stream.forEach(builder::addLang)); L789: L790: stream(parameter.getTags()).of(stream -> stream.forEach(builder::addTag)); L791: final String...

public StreamResponse get$file(final String id) { L65: final FessConfig fessConfig = ComponentUtil.getFessConfig(); L66: if (stream(fessConfig.getIndexBackupAllTargets()).get(stream -> stream.anyMatch(s -> s.equals(id)))) { L67: if ("system.properties".equals(id)) { L68: return asStream(id).contentTypeOctetStream().stream(out -> { L69: try (final ByteArrayOutputStream baos = new ByteArrayOutputStream()) { L70: Compo...

addFessConfigProperties(final List<String> cmdList) { L151: System.getProperties().keySet().stream().filter(k -> k != null && k.toString().startsWith(Constants.FESS_CONFIG_PREFIX)) L152: .forEach(k -> addSystemProperty(cmdList, k.toString(), null, null)); L153: } L154: L155: protected void addFessSystemProperties(final List<String> cmdList) { L156: System.getProperties().keySet().stream().filter(k -> k != null && k.toString().startsWith(Constants.SYSTEM_PROP_PREFIX)) L157:...

getFileProtocols() { L139: return fileProtocols; L140: } L141: L142: public boolean isValidWebProtocol(final String url) { L143: return stream(webProtocols).get(stream -> stream.anyMatch(s -> url.startsWith(s))); L144: } L145: L146: public boolean isValidFileProtocol(final String url) { L147: return stream(fileProtocols).get(stream -> stream.anyMatch(s -> url.startsWith(s))); L148: } L149: L150: public void addWebProtocol(final String protocol) { L151: final String prefix...