org.codelibs.fess.util.ComponentUtil; L27:import org.codelibs.fess.util.RenderDataUtil; L28:import org.dbflute.optional.OptionalEntity; L29:import org.dbflute.optional.OptionalThing; L30:import org.lastaflute.web.Execute; L31:import org.lastaflute.web.login.exception.LoginFailureException; L32:import org.lastaflute.web.response.HtmlResponse; L33:import org.lastaflute.web.validation.VaErrorHook; L34: L35:import jakarta.annotation.Resource; L36:import jakarta.servlet.http.HttpSession; L37: L38:public class LoginAction...

getWebAuthentication(form).ifPresent(entity -> { L204: try { L205: webAuthenticationService.store(entity); L206: saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL)); L207: } catch (final Exception e) { L208: logger.warn("Failed to process a request.", e); L209: throwValidationError(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)), L210: this::asEditHtml);...

java.io.OutputStreamWriter; L22:import java.io.Writer; L23:import java.util.Map; L24:import java.util.function.Consumer; L25: L26:import org.apache.logging.log4j.LogManager; L27:import org.apache.logging.log4j.Logger; L28:import org.codelibs.core.exception.IORuntimeException; L29:import org.codelibs.fess.Constants; L30: L31:public class ThreadDumpUtil { L32: private static final Logger logger = LogManager.getLogger(ThreadDumpUtil.class); L33: L34: protected ThreadDumpUtil() { L35: // noop...

private static final String IMGUR_CLIENT_ID = "9199fdef135c122"; L33: private static final MediaType MEDIA_TYPE_PNG = MediaType.get("image/png"); L34: L35: private final OkHttpClient client = new OkHttpClient(); L36: L37: public void run() throws Exception { L38: // Use the imgur image upload API as documented at https://api.imgur.com/endpoints/image L39: RequestBody requestBody = new MultipartBody.Builder() L40: .setType(MultipartBody.FORM) L41: .addFormDataPart("title", "Square...

= 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...

validateApi(body, messages -> {}); L87: body.crudMode = CrudMode.CREATE; L88: final WebConfig webConfig = getWebConfig(body).map(entity -> { L89: try { L90: webConfigService.store(entity); L91: } catch (final Exception e) { L92: logger.warn("Failed to process a request.", e); L93: throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e))); L94: } L95: return...

L26:import org.apache.logging.log4j.LogManager; L27:import org.apache.logging.log4j.Logger; L28:import org.codelibs.core.lang.StringUtil; L29:import org.codelibs.core.timer.TimeoutTask; L30:import org.codelibs.fess.Constants; L31:import org.codelibs.fess.exception.JobProcessingException; L32:import org.codelibs.fess.helper.ProcessHelper; L33:import org.codelibs.fess.mylasta.direction.FessConfig; L34:import org.codelibs.fess.util.ComponentUtil; L35:import org.codelibs.fess.util.InputStreamThread; L36:import...

validateApi(body, messages -> {}); L82: body.crudMode = CrudMode.CREATE; L83: final KeyMatch keyMatch = getKeyMatch(body).map(entity -> { L84: try { L85: keyMatchService.store(entity); L86: } catch (final Exception e) { L87: logger.warn("Failed to process a request.", e); L88: throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e))); L89: } L90: return...

Api(messages -> { L71: messages.addErrorsCrudFailedToCreateInstance(GLOBAL); L72: }); L73: return null; L74: }); L75: try { L76: roleService.store(entity); L77: } catch (final Exception e) { L78: logger.warn("Failed to process a request.", e); L79: throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e))); L80: } L81: return asJson(new...

ockWebServer; L26: L27:/** L28: * Create UNIX domain sockets for MockWebServer and OkHttp and connect 'em together. Note that we L29: * cannot do TLS over domain sockets. L30: */ L31:public class ClientAndServer { L32: public void run() throws Exception { L33: File socketFile = new File("/tmp/ClientAndServer.sock"); L34: socketFile.delete(); // Clean up from previous runs. L35: L36: MockWebServer server = new MockWebServer(); L37: server.setServerSocketFactory(new UnixDomainServerSo...