{}); L82: body.crudMode = CrudMode.CREATE; L83: final DuplicateHost duplicateHost = getDuplicateHost(body).map(entity -> { L84: try { L85: duplicateHostService.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...

tStreamUtil; L23:import org.codelibs.core.io.ResourceUtil; L24:import org.codelibs.fess.Constants; L25:import org.codelibs.fess.exception.FessSystemException; L26:import org.codelibs.fess.helper.PluginHelper.Artifact; L27:import org.codelibs.fess.helper.PluginHelper.ArtifactType; L28:import org.codelibs.fess.unit.UnitFessTestCase; L29:import org.lastaflute.di.exception.IORuntimeException; L30: L31:public class PluginHelperTest extends UnitFessTestCase { L32: private PluginHelper pluginHelper;...

codingException; L19:import java.net.URLEncoder; L20:import java.util.Map; L21: L22:import org.apache.groovy.util.Maps; L23:import org.codelibs.fess.Constants; L24:import org.codelibs.fess.crawler.util.FieldConfigs; L25:import org.codelibs.fess.exception.FessSystemException; L26:import org.codelibs.fess.unit.UnitFessTestCase; L27: L28:public class FessFileTransformerTest extends UnitFessTestCase { L29: L30: private String encodeUrl(final String url) { L31: try { L32: 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...

okhttp3.Headers; L20:import okhttp3.OkHttpClient; L21:import okhttp3.Request; L22:import okhttp3.Response; L23: L24:public final class SynchronousGet { L25: private final OkHttpClient client = new OkHttpClient(); L26: L27: public void run() throws Exception { L28: Request request = new Request.Builder() L29: .url("https://publicobject.com/helloworld.txt") L30: .build(); L31: L32: try (Response response = client.newCall(request).execute()) { L33: if (!response.isSuccessful())...

org.codelibs.curl.Curl; L49:import org.codelibs.curl.CurlRequest; L50:import org.codelibs.curl.CurlResponse; L51:import org.codelibs.fess.crawler.Constants; L52:import org.codelibs.fess.exception.PluginException; L53:import org.codelibs.fess.util.ComponentUtil; L54:import org.codelibs.fess.util.ResourceUtil; L55:import org.lastaflute.di.exception.IORuntimeException; L56:import org.w3c.dom.Document; L57:import org.w3c.dom.Node; L58:import org.w3c.dom.NodeList; L59:import org.xml.sax.SAXException; L60: L61:import ...

okhttp3.OkHttpClient; L21:import okhttp3.Request; L22:import okhttp3.RequestBody; L23:import okhttp3.Response; L24: L25:public final class PostForm { L26: private final OkHttpClient client = new OkHttpClient(); L27: L28: public void run() throws Exception { L29: RequestBody formBody = new FormBody.Builder() L30: .add("search", "Jurassic Park") L31: .build(); L32: Request request = new Request.Builder() L33: .url("https://en.wikipedia.org/w/index.php") L34: .post(formBody)...

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