builder.endObject(); L166: builder.flush(); L167: try (OutputStream out = builder.getOutputStream()) { L168: stats = ((ByteArrayOutputStream) out).toString(Constants.UTF_8); L169: } L170: } catch (final Exception e) { L171: appendException(buf, e).append(','); L172: } L173: buf.append("\"search_engine\":").append(stats).append(','); L174: } L175:}...

essConfig; L21:import org.codelibs.fess.mylasta.direction.FessProp; L22:import org.codelibs.fess.unit.UnitFessTestCase; L23: L24:public class ParameterUtilTest extends UnitFessTestCase { L25: L26: @Override L27: public void setUp() throws Exception { L28: super.setUp(); L29: FessProp.propMap.clear(); L30: FessConfig fessConfig = new FessConfig.SimpleImpl() { L31: @Override L32: public String getAppEncryptPropertyPattern() { L33: return...

org.apache.logging.log4j.Logger; L31:import org.codelibs.core.lang.StringUtil; L32:import org.codelibs.core.timer.TimeoutTask; L33:import org.codelibs.fess.Constants; L34:import org.codelibs.fess.es.config.exbhv.ScheduledJobBhv; L35:import org.codelibs.fess.exception.JobProcessingException; L36:import org.codelibs.fess.exec.Crawler; L37:import org.codelibs.fess.helper.ProcessHelper; L38:import org.codelibs.fess.helper.SystemHelper; L39:import org.codelibs.fess.mylasta.direction.FessConfig; L40:import org.cod...

; L33:import org.codelibs.fess.app.web.base.SearchForm; L34:import org.codelibs.fess.entity.SearchRenderData; L35:import org.codelibs.fess.entity.SearchRequestParams.SearchRequestType; L36:import org.codelibs.fess.exception.InvalidQueryException; L37:import org.codelibs.fess.exception.ResultOffsetExceededException; L38:import org.codelibs.fess.helper.RelatedContentHelper; L39:import org.codelibs.fess.helper.RelatedQueryHelper; L40:import org.codelibs.fess.util.RenderDataUtil; L41:import org.last...

License. L15: */ L16:package org.codelibs.fess.es.config.exentity; L17: L18:import org.codelibs.core.lang.StringUtil; L19:import org.codelibs.fess.Constants; L20:import org.codelibs.fess.es.config.bsentity.BsScheduledJob; L21:import org.codelibs.fess.exception.JobNotFoundException; L22:import org.codelibs.fess.util.ComponentUtil; L23:import org.lastaflute.job.LaScheduledJob; L24:import org.lastaflute.job.key.LaJobUnique; L25: L26:/** L27: * @author FreeGen L28: */ L29:public class ScheduledJob extends...

L48:import org.opensearch.search.sort.FieldSortBuilder; L49: L50:public class CrawlingConfigHelperTest extends UnitFessTestCase { L51: private CrawlingConfigHelper crawlingConfigHelper; L52: L53: @Override L54: public void setUp() throws Exception { L55: super.setUp(); L56: final File propFile = File.createTempFile("system", ".properties"); L57: propFile.deleteOnExit(); L58: FileUtil.writeBytes(propFile.getAbsolutePath(), "".getBytes()); L59: ComponentUtil.register(new...

L21:import java.util.Map; L22: L23:import org.apache.logging.log4j.LogManager; L24:import org.apache.logging.log4j.Logger; L25:import org.apache.lucene.search.Query; L26:import org.codelibs.fess.entity.QueryContext; L27:import org.codelibs.fess.exception.InvalidQueryException; L28:import org.lastaflute.core.message.UserMessages; L29:import org.opensearch.index.query.QueryBuilder; L30: L31:import jakarta.annotation.PostConstruct; L32: L33:public class QueryProcessor { L34: private static final...

getUserBean().map(FessUserBean::getUserId).get(); L70: try { L71: userService.changePassword(username, form.newPassword); L72: saveInfo(messages -> messages.addSuccessChangedPassword(GLOBAL)); L73: } catch (final Exception e) { L74: logger.warn("Failed to change password for {}", username, e); L75: throwValidationError(messages -> messages.addErrorsFailedToChangePassword(GLOBAL), toIndexPage); L76: } L77: return redirect(getClass());...

outputCallback.accept(line); L72: } L73: if (list.size() > bufferSize) { L74: list.remove(0); L75: } L76: } L77: } catch (final Exception e) { L78: running = false; L79: if (logger.isDebugEnabled()) { L80: logger.debug("Failed to process an input stream.", e); L81: } L82: } L83: } L84: } L85: L86:...

org.xml.sax.InputSource; L28: L29:public class GsaConfigParserTest extends UnitFessTestCase { L30: L31: private static final Logger logger = LogManager.getLogger(GsaConfigParserTest.class); L32: L33: @Override L34: public void setUp() throws Exception { L35: super.setUp(); L36: ComponentUtil.register(new SystemHelper(), "systemHelper"); L37: } L38: L39: public void test_parse() throws IOException { L40: GsaConfigParser parser = new GsaConfigParser(); L41: try...