entity.UrlQueue; L23:import org.codelibs.fess.crawler.exception.CrawlingAccessException; L24:import org.codelibs.fess.crawler.exception.MultipleCrawlingAccessException; L25:import org.codelibs.fess.crawler.helper.impl.LogHelperImpl; L26:import org.codelibs.fess.crawler.log.LogType; L27:import org.codelibs.fess.es.config.exentity.CrawlingConfig; L28:import org.codelibs.fess.es.config.exentity.FailureUrl; L29:import org.codelibs.fess.exception.ContainerNotAvailableException; L30:import org.codelib...

fId : getFileConfigIds(NAME_PREFIX)) { L119: deleteMethod("/api/admin/fileconfig/setting/" + fId); L120: } L121: L122: deleteTestToken(); L123: } L124: L125: @Test L126: public void searchTestWith1Word() throws Exception { L127: String query = "java"; L128: Map<String, String> params = new HashMap<>(); L129: params.put("q", query); L130: params.put("num", "100"); L131: String response = checkMethodBase(new HashMap<>()).params(p...

Utils; L28:import org.apache.logging.log4j.LogManager; L29:import org.apache.logging.log4j.Logger; L30:import org.codelibs.core.io.CloseableUtil; L31:import org.codelibs.fess.Constants; L32:import org.codelibs.fess.exception.JobNotFoundException; L33:import org.codelibs.fess.exception.JobProcessingException; L34:import org.codelibs.fess.util.InputStreamThread; L35:import org.codelibs.fess.util.JobProcess; L36: L37:import jakarta.annotation.PreDestroy; L38: L39:public class ProcessHelper { L40: ...

= getFessConfig().getCrawlerDocumentSiteEncoding(); L94: } else { L95: enc = encoding; L96: } L97: L98: try { L99: url = URLDecoder.decode(url, enc); L100: } catch (final Exception e) {} L101: } L102: L103: return abbreviateSite(url); L104: } L105: L106: default void putResultDataBody(final Map<String, Object> dataMap, final String key, final Object value) { L107: final FessConfig fessConfig = Co...

resultBuf.append("Skipped to purge user info logs.\n"); L81: } L82: } catch (final Exception e) { L83: logger.error("Failed to purge user info.", e); L84: resultBuf.append(e.getMessage()).append("\n"); L85: } L86: L87: // update job logs L88: try { L89: jobLogService.updateStatus(); L90: } catch (final Exception e) { L91: logger.error("Failed to purge job logs.", e); L92: resultBuf.append(e.ge...

License for the specific language L14: * governing permissions and limitations under the License. L15: */ L16:package org.codelibs.fess.exception; L17: L18:public class ThumbnailGenerationException extends FessSystemException { L19: L20: private static final long serialVersionUID = 1L; L21: L22: public ThumbnailGenerationException(final String message, final Exception cause) { L23: super(message, cause); L24: } L25: L26: public ThumbnailGenerationException(final String message) { L27:...

L60: } L61: L62: protected StringBuilder appendException(final StringBuilder buf, final Exception exception) { L63: try (ByteArrayOutputStream baos = new ByteArrayOutputStream(); L64: PrintWriter writer = new PrintWriter(baos, false, Constants.CHARSET_UTF_8)) { L65: exception.printStackTrace(writer); L66: writer.flush(); L67: append(buf, "exception", () -> StringEscapeUtils.escapeJson(new String(baos.toByteArray(), Constants.CHARSET_UTF_8)));...

"AS IS" BASIS, L12: * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, L13: * either express or implied. See the License for the specific language L14: * governing permissions and limitations under the License. L15: */ L16:package org.codelibs.fess.exception; L17: L18:public class WebApiException extends FessSystemException { L19: L20: private static final long serialVersionUID = 1L; L21: L22: private final int statusCode; L23: L24: public int getStatusCode() { L25: return statusCode;...

specific language L14: * governing permissions and limitations under the License. L15: */ L16:package org.codelibs.fess.exception; L17: L18:public class ScheduledJobException extends FessSystemException { L19: L20: private static final long serialVersionUID = 1L; L21: L22: /** L23: * @param message Exception message. L24: * @param cause Root cause for this exception. L25: */ L26: public ScheduledJobException(final String message, final Throwable cause) { L27: super(message,...

return redirect(getClass()); // no-op L82: } L83: String line; L84: while ((line = ReaderUtil.readLine(reader)) != null) { L85: buf.append(line); L86: } L87: } catch (final Exception e) { L88: throwValidationError(messages -> messages.addErrorsFailedToReadRequestFile(GLOBAL, e.getMessage()), L89: () -> asListHtml(this::saveToken)); L90: } L91: L92: final CurlRequest curlRequest = g...