This is an automated email from the ASF dual-hosted git repository.
tallison pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/tika.git
The following commit(s) were added to refs/heads/main by this push:
new 86857ce8af TIKA-4644 - improve config endpoints (#2566)
86857ce8af is described below
commit 86857ce8af9c1ae2bc13841d8bc0173c7011a37e
Author: Tim Allison <[email protected]>
AuthorDate: Sun Feb 1 09:27:35 2026 -0500
TIKA-4644 - improve config endpoints (#2566)
---
.../server/core/ConfigEndpointSecurityFilter.java | 48 +++++++
.../apache/tika/server/core/TikaServerConfig.java | 11 +-
.../apache/tika/server/core/TikaServerProcess.java | 3 +
.../core/resource/RecursiveMetadataResource.java | 8 +-
.../tika/server/core/resource/TikaResource.java | 26 +++-
.../core/ConfigEndpointSecurityEnabledTest.java | 111 ++++++++++++++++
.../server/core/ConfigEndpointSecurityTest.java | 143 +++++++++++++++++++++
.../tika/server/standard/TikaResourceTest.java | 26 ++--
8 files changed, 351 insertions(+), 25 deletions(-)
diff --git
a/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/ConfigEndpointSecurityFilter.java
b/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/ConfigEndpointSecurityFilter.java
new file mode 100644
index 0000000000..16787e441b
--- /dev/null
+++
b/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/ConfigEndpointSecurityFilter.java
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.tika.server.core;
+
+import jakarta.ws.rs.container.ContainerRequestContext;
+import jakarta.ws.rs.container.ContainerRequestFilter;
+import jakarta.ws.rs.core.MediaType;
+import jakarta.ws.rs.core.Response;
+import jakarta.ws.rs.ext.Provider;
+
+/**
+ * JAX-RS filter that gates /config endpoints behind the
enableUnsecureFeatures flag.
+ * When enableUnsecureFeatures is false, requests to paths containing
"/config" will
+ * receive a 403 Forbidden response.
+ */
+@Provider
+public class ConfigEndpointSecurityFilter implements ContainerRequestFilter {
+
+ private final boolean enableUnsecureFeatures;
+
+ public ConfigEndpointSecurityFilter(boolean enableUnsecureFeatures) {
+ this.enableUnsecureFeatures = enableUnsecureFeatures;
+ }
+
+ @Override
+ public void filter(ContainerRequestContext requestContext) {
+ if (!enableUnsecureFeatures &&
requestContext.getUriInfo().getPath().contains("/config")) {
+ requestContext.abortWith(Response.status(Response.Status.FORBIDDEN)
+ .entity("Config endpoints are disabled. Set
enableUnsecureFeatures=true in server config.")
+ .type(MediaType.TEXT_PLAIN)
+ .build());
+ }
+ }
+}
diff --git
a/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/TikaServerConfig.java
b/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/TikaServerConfig.java
index 698f95500f..fa7bb3f93d 100644
---
a/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/TikaServerConfig.java
+++
b/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/TikaServerConfig.java
@@ -49,9 +49,14 @@ public class TikaServerConfig {
private static final long DEFAULT_MAX_FILES = 100000;
private static final int DEFAULT_DIGEST_MARK_LIMIT = 20 * 1024 * 1024;
private static final String UNSECURE_WARNING =
- "WARNING: You have chosen to run tika-server with unsecure
features enabled.\n" + "Whoever has access to your service now has the same
read permissions\n" +
- "as you've given your fetchers and the same write
permissions " + "as your emitters.\n" + "Users could request and receive a
sensitive file from your\n" +
- "drive or a webpage from your intranet and/or send
malicious content to\n" + " your emitter endpoints. See CVE-2015-3271.\n" +
+ "WARNING: You have chosen to run tika-server with unsecure
features enabled.\n" +
+ "Whoever has access to your service now has the same read
permissions\n" +
+ "as you've given your fetchers and the same write
permissions as your emitters.\n" +
+ "Users could request and receive a sensitive file from
your\n" +
+ "drive or a webpage from your intranet and/or send
malicious content to\n" +
+ "your emitter endpoints. See CVE-2015-3271.\n" +
+ "Additionally, /config endpoints allow per-request parser
configuration\n" +
+ "which could enable dangerous operations.\n" +
"Please make sure you know what you are doing.";
private static final List<String> ONLY_IN_FORK_MODE = Arrays.asList(
new String[]{"maxFiles", "javaPath", "maxRestarts", "numRestarts",
"forkedStatusFile", "maxForkedStartupMillis",
diff --git
a/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/TikaServerProcess.java
b/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/TikaServerProcess.java
index 23e44852ea..725fd91d1d 100644
---
a/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/TikaServerProcess.java
+++
b/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/TikaServerProcess.java
@@ -297,6 +297,9 @@ public class TikaServerProcess {
writers.add(new
TikaServerParseExceptionMapper(tikaServerConfig.isReturnStackTrace()));
writers.add(new JSONObjWriter());
+ // Add ConfigEndpointSecurityFilter to gate /config endpoints
+ writers.add(new
ConfigEndpointSecurityFilter(tikaServerConfig.isEnableUnsecureFeatures()));
+
TikaLoggingFilter logFilter = null;
if (!StringUtils.isBlank(tikaServerConfig.getLogLevel())) {
String logLevel = tikaServerConfig.getLogLevel();
diff --git
a/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/resource/RecursiveMetadataResource.java
b/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/resource/RecursiveMetadataResource.java
index f3ae76785e..7fbf7f2566 100644
---
a/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/resource/RecursiveMetadataResource.java
+++
b/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/resource/RecursiveMetadataResource.java
@@ -136,15 +136,15 @@ public class RecursiveMetadataResource {
/**
* Multipart endpoint with per-request ParseContext configuration.
* Accepts two parts: "file" (the document) and "config" (JSON
configuration with parseContext).
+ * Uses the default handler type (XML).
*/
@POST
@Consumes("multipart/form-data")
@Produces({"application/json"})
- @Path("config{" + HANDLER_TYPE_PARAM + " : (/\\w+)?}")
+ @Path("config")
public Response getMetadataWithConfig(
List<Attachment> attachments,
- @Context HttpHeaders httpHeaders,
- @PathParam(HANDLER_TYPE_PARAM) String handlerTypeName) throws
Exception {
+ @Context HttpHeaders httpHeaders) throws Exception {
ParseContext context = TikaResource.createParseContext();
Metadata metadata = Metadata.newInstance(context);
@@ -154,7 +154,7 @@ public class RecursiveMetadataResource {
return Response
.ok(parseMetadataWithContext(tis, metadata,
httpHeaders.getRequestHeaders(),
-
buildHandlerConfig(httpHeaders.getRequestHeaders(), handlerTypeName != null ?
handlerTypeName.substring(1) : null, ParseMode.RMETA),
+
buildHandlerConfig(httpHeaders.getRequestHeaders(), null, ParseMode.RMETA),
context))
.build();
}
diff --git
a/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/resource/TikaResource.java
b/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/resource/TikaResource.java
index 57c2d76d92..5819ccb551 100644
---
a/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/resource/TikaResource.java
+++
b/tika-server/tika-server-core/src/main/java/org/apache/tika/server/core/resource/TikaResource.java
@@ -591,11 +591,15 @@ public class TikaResource {
* - "file" part (required): the document to parse
* - "config" part (optional): JSON configuration for parser settings and
handler type
* <p>
- * Returns XHTML by default. Use /tika/text, /tika/html, or /tika/xml for
other formats.
+ * Returns XHTML by default. Use /tika/config/text, /tika/config/html, or
/tika/config/xml for other formats.
+ * <p>
+ * This endpoint is gated behind enableUnsecureFeatures=true because
per-request
+ * configuration could enable dangerous operations.
*/
@POST
@Consumes("multipart/form-data")
@Produces("text/xml")
+ @Path("config")
public StreamingOutput postRaw(List<Attachment> attachments, @Context
HttpHeaders httpHeaders)
throws IOException {
ParseContext context = createParseContext();
@@ -611,11 +615,14 @@ public class TikaResource {
* Accepts multipart with:
* - "file" part (required): the document to parse
* - "config" part (optional): JSON configuration for parser settings
+ * <p>
+ * This endpoint is gated behind enableUnsecureFeatures=true because
per-request
+ * configuration could enable dangerous operations.
*/
@POST
@Consumes("multipart/form-data")
@Produces("text/plain")
- @Path("text")
+ @Path("config/text")
public StreamingOutput postText(List<Attachment> attachments, @Context
HttpHeaders httpHeaders)
throws IOException {
ParseContext context = createParseContext();
@@ -630,11 +637,14 @@ public class TikaResource {
* Accepts multipart with:
* - "file" part (required): the document to parse
* - "config" part (optional): JSON configuration for parser settings
+ * <p>
+ * This endpoint is gated behind enableUnsecureFeatures=true because
per-request
+ * configuration could enable dangerous operations.
*/
@POST
@Consumes("multipart/form-data")
@Produces("text/html")
- @Path("html")
+ @Path("config/html")
public StreamingOutput postHtml(List<Attachment> attachments, @Context
HttpHeaders httpHeaders)
throws IOException {
ParseContext context = createParseContext();
@@ -649,11 +659,14 @@ public class TikaResource {
* Accepts multipart with:
* - "file" part (required): the document to parse
* - "config" part (optional): JSON configuration for parser settings
+ * <p>
+ * This endpoint is gated behind enableUnsecureFeatures=true because
per-request
+ * configuration could enable dangerous operations.
*/
@POST
@Consumes("multipart/form-data")
@Produces("text/xml")
- @Path("xml")
+ @Path("config/xml")
public StreamingOutput postXml(List<Attachment> attachments, @Context
HttpHeaders httpHeaders)
throws IOException {
ParseContext context = createParseContext();
@@ -670,11 +683,14 @@ public class TikaResource {
* - "config" part (optional): JSON configuration for parser settings and
handler type
* <p>
* Default handler is text. Use config to specify different handler type.
+ * <p>
+ * This endpoint is gated behind enableUnsecureFeatures=true because
per-request
+ * configuration could enable dangerous operations.
*/
@POST
@Consumes("multipart/form-data")
@Produces("application/json")
- @Path("json")
+ @Path("config/json")
public Metadata postJson(List<Attachment> attachments, @Context
HttpHeaders httpHeaders)
throws IOException {
ParseContext context = createParseContext();
diff --git
a/tika-server/tika-server-core/src/test/java/org/apache/tika/server/core/ConfigEndpointSecurityEnabledTest.java
b/tika-server/tika-server-core/src/test/java/org/apache/tika/server/core/ConfigEndpointSecurityEnabledTest.java
new file mode 100644
index 0000000000..0646f75ecd
--- /dev/null
+++
b/tika-server/tika-server-core/src/test/java/org/apache/tika/server/core/ConfigEndpointSecurityEnabledTest.java
@@ -0,0 +1,111 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.tika.server.core;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+import java.io.InputStream;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+
+import jakarta.ws.rs.core.Response;
+import org.apache.cxf.jaxrs.JAXRSServerFactoryBean;
+import org.apache.cxf.jaxrs.client.WebClient;
+import org.apache.cxf.jaxrs.ext.multipart.Attachment;
+import org.apache.cxf.jaxrs.ext.multipart.ContentDisposition;
+import org.apache.cxf.jaxrs.ext.multipart.MultipartBody;
+import org.apache.cxf.jaxrs.lifecycle.SingletonResourceProvider;
+import org.junit.jupiter.api.Test;
+
+import org.apache.tika.server.core.resource.TikaResource;
+import org.apache.tika.server.core.writer.JSONMessageBodyWriter;
+
+/**
+ * Tests that /config endpoints work when enableUnsecureFeatures=true.
+ */
+public class ConfigEndpointSecurityEnabledTest extends CXFTestBase {
+
+ private static final String TIKA_PATH = "/tika";
+ private static final String TEST_DOC =
"test-documents/mock/hello_world.xml";
+
+ @Override
+ protected void setUpResources(JAXRSServerFactoryBean sf) {
+ sf.setResourceClasses(TikaResource.class);
+ sf.setResourceProvider(TikaResource.class, new
SingletonResourceProvider(new TikaResource()));
+ }
+
+ @Override
+ protected void setUpProviders(JAXRSServerFactoryBean sf) {
+ List<Object> providers = new ArrayList<>();
+ providers.add(new TikaServerParseExceptionMapper(false));
+ providers.add(new JSONMessageBodyWriter());
+ // Add security filter with enableUnsecureFeatures=true
+ providers.add(new ConfigEndpointSecurityFilter(true));
+ sf.setProviders(providers);
+ }
+
+ @Test
+ public void testConfigEndpointAllowedWhenEnabled() throws Exception {
+ // POST to /tika/config should work with 200
+ ContentDisposition fileCd = new ContentDisposition("form-data;
name=\"file\"; filename=\"test.xml\"");
+ Attachment fileAtt = new Attachment("file",
+ ClassLoader.getSystemResourceAsStream(TEST_DOC), fileCd);
+
+ Response response = WebClient
+ .create(endPoint + TIKA_PATH + "/config")
+ .type("multipart/form-data")
+ .post(new MultipartBody(Arrays.asList(fileAtt)));
+
+ assertEquals(200, response.getStatus());
+ String responseMsg = getStringFromInputStream((InputStream)
response.getEntity());
+ assertTrue(responseMsg.contains("hello world"));
+ }
+
+ @Test
+ public void testConfigTextEndpointAllowedWhenEnabled() throws Exception {
+ // POST to /tika/config/text should work
+ ContentDisposition fileCd = new ContentDisposition("form-data;
name=\"file\"; filename=\"test.xml\"");
+ Attachment fileAtt = new Attachment("file",
+ ClassLoader.getSystemResourceAsStream(TEST_DOC), fileCd);
+
+ Response response = WebClient
+ .create(endPoint + TIKA_PATH + "/config/text")
+ .type("multipart/form-data")
+ .post(new MultipartBody(Arrays.asList(fileAtt)));
+
+ assertEquals(200, response.getStatus());
+ String responseMsg = getStringFromInputStream((InputStream)
response.getEntity());
+ assertTrue(responseMsg.contains("hello world"));
+ }
+
+ @Test
+ public void testConfigJsonEndpointAllowedWhenEnabled() throws Exception {
+ // POST to /tika/config/json should work
+ ContentDisposition fileCd = new ContentDisposition("form-data;
name=\"file\"; filename=\"test.xml\"");
+ Attachment fileAtt = new Attachment("file",
+ ClassLoader.getSystemResourceAsStream(TEST_DOC), fileCd);
+
+ Response response = WebClient
+ .create(endPoint + TIKA_PATH + "/config/json")
+ .type("multipart/form-data")
+ .post(new MultipartBody(Arrays.asList(fileAtt)));
+
+ assertEquals(200, response.getStatus());
+ }
+}
diff --git
a/tika-server/tika-server-core/src/test/java/org/apache/tika/server/core/ConfigEndpointSecurityTest.java
b/tika-server/tika-server-core/src/test/java/org/apache/tika/server/core/ConfigEndpointSecurityTest.java
new file mode 100644
index 0000000000..cbb7b5aa86
--- /dev/null
+++
b/tika-server/tika-server-core/src/test/java/org/apache/tika/server/core/ConfigEndpointSecurityTest.java
@@ -0,0 +1,143 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.tika.server.core;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+import java.io.InputStream;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+
+import jakarta.ws.rs.core.Response;
+import org.apache.cxf.jaxrs.JAXRSServerFactoryBean;
+import org.apache.cxf.jaxrs.client.WebClient;
+import org.apache.cxf.jaxrs.ext.multipart.Attachment;
+import org.apache.cxf.jaxrs.ext.multipart.ContentDisposition;
+import org.apache.cxf.jaxrs.ext.multipart.MultipartBody;
+import org.apache.cxf.jaxrs.lifecycle.SingletonResourceProvider;
+import org.junit.jupiter.api.Test;
+
+import org.apache.tika.server.core.resource.TikaResource;
+import org.apache.tika.server.core.writer.JSONMessageBodyWriter;
+
+/**
+ * Tests for ConfigEndpointSecurityFilter.
+ * Verifies that /config endpoints are gated behind enableUnsecureFeatures.
+ */
+public class ConfigEndpointSecurityTest extends CXFTestBase {
+
+ private static final String TIKA_PATH = "/tika";
+ private static final String TEST_DOC =
"test-documents/mock/hello_world.xml";
+
+ @Override
+ protected void setUpResources(JAXRSServerFactoryBean sf) {
+ sf.setResourceClasses(TikaResource.class);
+ sf.setResourceProvider(TikaResource.class, new
SingletonResourceProvider(new TikaResource()));
+ }
+
+ @Override
+ protected void setUpProviders(JAXRSServerFactoryBean sf) {
+ List<Object> providers = new ArrayList<>();
+ providers.add(new TikaServerParseExceptionMapper(false));
+ providers.add(new JSONMessageBodyWriter());
+ // Add security filter with enableUnsecureFeatures=false
+ providers.add(new ConfigEndpointSecurityFilter(false));
+ sf.setProviders(providers);
+ }
+
+ @Test
+ public void testConfigEndpointBlockedWhenDisabled() throws Exception {
+ // POST to /tika/config should be blocked with 403
+ ContentDisposition fileCd = new ContentDisposition("form-data;
name=\"file\"; filename=\"test.xml\"");
+ Attachment fileAtt = new Attachment("file",
+ ClassLoader.getSystemResourceAsStream(TEST_DOC), fileCd);
+
+ Response response = WebClient
+ .create(endPoint + TIKA_PATH + "/config")
+ .type("multipart/form-data")
+ .post(new MultipartBody(Arrays.asList(fileAtt)));
+
+ assertEquals(403, response.getStatus());
+ String responseMsg = getStringFromInputStream((InputStream)
response.getEntity());
+ assertTrue(responseMsg.contains("Config endpoints are disabled"));
+ }
+
+ @Test
+ public void testConfigTextEndpointBlockedWhenDisabled() throws Exception {
+ // POST to /tika/config/text should be blocked with 403
+ ContentDisposition fileCd = new ContentDisposition("form-data;
name=\"file\"; filename=\"test.xml\"");
+ Attachment fileAtt = new Attachment("file",
+ ClassLoader.getSystemResourceAsStream(TEST_DOC), fileCd);
+
+ Response response = WebClient
+ .create(endPoint + TIKA_PATH + "/config/text")
+ .type("multipart/form-data")
+ .post(new MultipartBody(Arrays.asList(fileAtt)));
+
+ assertEquals(403, response.getStatus());
+ }
+
+ @Test
+ public void testConfigJsonEndpointBlockedWhenDisabled() throws Exception {
+ // POST to /tika/config/json should be blocked with 403
+ ContentDisposition fileCd = new ContentDisposition("form-data;
name=\"file\"; filename=\"test.xml\"");
+ Attachment fileAtt = new Attachment("file",
+ ClassLoader.getSystemResourceAsStream(TEST_DOC), fileCd);
+
+ Response response = WebClient
+ .create(endPoint + TIKA_PATH + "/config/json")
+ .type("multipart/form-data")
+ .post(new MultipartBody(Arrays.asList(fileAtt)));
+
+ assertEquals(403, response.getStatus());
+ }
+
+ @Test
+ public void testNonConfigEndpointsNotBlocked() throws Exception {
+ // GET to /tika should still work
+ Response response = WebClient
+ .create(endPoint + TIKA_PATH)
+ .get();
+
+ assertEquals(200, response.getStatus());
+ assertEquals(TikaResource.GREETING,
getStringFromInputStream((InputStream) response.getEntity()));
+ }
+
+ @Test
+ public void testPutEndpointsNotBlocked() throws Exception {
+ // PUT to /tika/text should still work (no /config in path)
+ Response response = WebClient
+ .create(endPoint + TIKA_PATH + "/text")
+ .put(ClassLoader.getSystemResourceAsStream(TEST_DOC));
+
+ assertEquals(200, response.getStatus());
+ String responseMsg = getStringFromInputStream((InputStream)
response.getEntity());
+ assertTrue(responseMsg.contains("hello world"));
+ }
+
+ @Test
+ public void testPutJsonEndpointNotBlocked() throws Exception {
+ // PUT to /tika/json should still work (no /config in path)
+ Response response = WebClient
+ .create(endPoint + TIKA_PATH + "/json")
+ .put(ClassLoader.getSystemResourceAsStream(TEST_DOC));
+
+ assertEquals(200, response.getStatus());
+ }
+}
diff --git
a/tika-server/tika-server-standard/src/test/java/org/apache/tika/server/standard/TikaResourceTest.java
b/tika-server/tika-server-standard/src/test/java/org/apache/tika/server/standard/TikaResourceTest.java
index c68220f9aa..0b4fe94fb0 100644
---
a/tika-server/tika-server-standard/src/test/java/org/apache/tika/server/standard/TikaResourceTest.java
+++
b/tika-server/tika-server-standard/src/test/java/org/apache/tika/server/standard/TikaResourceTest.java
@@ -260,7 +260,7 @@ public class TikaResourceTest extends CXFTestBase {
new
java.io.ByteArrayInputStream(configJson.getBytes(StandardCharsets.UTF_8)));
Response response = WebClient
- .create(endPoint + TIKA_PATH)
+ .create(endPoint + TIKA_PATH + "/config")
.type("multipart/form-data")
.post(new MultipartBody(Arrays.asList(fileAtt, configAtt)));
String responseMsg = getStringFromInputStream((InputStream)
response.getEntity());
@@ -289,7 +289,7 @@ public class TikaResourceTest extends CXFTestBase {
new
java.io.ByteArrayInputStream(configJson.getBytes(StandardCharsets.UTF_8)));
Response response = WebClient
- .create(endPoint + TIKA_PATH)
+ .create(endPoint + TIKA_PATH + "/config")
.type("multipart/form-data")
.post(new MultipartBody(Arrays.asList(fileAtt, configAtt)));
String responseMsg = getStringFromInputStream((InputStream)
response.getEntity());
@@ -304,7 +304,7 @@ public class TikaResourceTest extends CXFTestBase {
new
java.io.ByteArrayInputStream(configJson.getBytes(StandardCharsets.UTF_8)));
response = WebClient
- .create(endPoint + TIKA_PATH)
+ .create(endPoint + TIKA_PATH + "/config")
.type("multipart/form-data")
.post(new MultipartBody(Arrays.asList(fileAtt, configAtt)));
responseMsg = getStringFromInputStream((InputStream)
response.getEntity());
@@ -325,7 +325,7 @@ public class TikaResourceTest extends CXFTestBase {
new
java.io.ByteArrayInputStream(configJson.getBytes(StandardCharsets.UTF_8)));
response = WebClient
- .create(endPoint + TIKA_PATH)
+ .create(endPoint + TIKA_PATH + "/config")
.type("multipart/form-data")
.post(new MultipartBody(Arrays.asList(fileAtt, configAtt)));
responseMsg = getStringFromInputStream((InputStream)
response.getEntity());
@@ -346,7 +346,7 @@ public class TikaResourceTest extends CXFTestBase {
new
java.io.ByteArrayInputStream(configJson.getBytes(StandardCharsets.UTF_8)));
response = WebClient
- .create(endPoint + TIKA_PATH)
+ .create(endPoint + TIKA_PATH + "/config")
.type("multipart/form-data")
.post(new MultipartBody(Arrays.asList(fileAtt, configAtt)));
assertEquals(422, response.getStatus());
@@ -382,7 +382,7 @@ public class TikaResourceTest extends CXFTestBase {
new
java.io.ByteArrayInputStream(configJson.getBytes(StandardCharsets.UTF_8)));
response = WebClient
- .create(endPoint + TIKA_PATH + "/text")
+ .create(endPoint + TIKA_PATH + "/config/text")
.type("multipart/form-data")
.post(new MultipartBody(Arrays.asList(fileAtt, configAtt)));
responseMsg = getStringFromInputStream((InputStream)
response.getEntity());
@@ -425,7 +425,7 @@ public class TikaResourceTest extends CXFTestBase {
try {
Response response = WebClient
- .create(endPoint + TIKA_PATH)
+ .create(endPoint + TIKA_PATH + "/config")
.type("multipart/form-data")
.post(new MultipartBody(Arrays.asList(fileAtt,
configAtt)));
assertEquals(500, response.getStatus());
@@ -450,7 +450,7 @@ public class TikaResourceTest extends CXFTestBase {
try {
Response response = WebClient
- .create(endPoint + TIKA_PATH)
+ .create(endPoint + TIKA_PATH + "/config")
.type("multipart/form-data")
.post(new MultipartBody(Arrays.asList(fileAtt,
configAtt)));
assertEquals(422, response.getStatus());
@@ -480,7 +480,7 @@ public class TikaResourceTest extends CXFTestBase {
new
java.io.ByteArrayInputStream(configJson.getBytes(StandardCharsets.UTF_8)));
Response response = WebClient
- .create(endPoint + TIKA_PATH)
+ .create(endPoint + TIKA_PATH + "/config")
.type("multipart/form-data")
.post(new MultipartBody(Arrays.asList(fileAtt, configAtt)));
assertEquals(422, response.getStatus());
@@ -502,7 +502,7 @@ public class TikaResourceTest extends CXFTestBase {
new
java.io.ByteArrayInputStream(configJson.getBytes(StandardCharsets.UTF_8)));
Response response = WebClient
- .create(endPoint + TIKA_PATH)
+ .create(endPoint + TIKA_PATH + "/config")
.type("multipart/form-data")
.post(new MultipartBody(Arrays.asList(fileAtt, configAtt)));
assertEquals(200, response.getStatus());
@@ -527,7 +527,7 @@ public class TikaResourceTest extends CXFTestBase {
new
java.io.ByteArrayInputStream(configJson.getBytes(StandardCharsets.UTF_8)));
Response response = WebClient
- .create(endPoint + TIKA_PATH + "/text")
+ .create(endPoint + TIKA_PATH + "/config/text")
.type("multipart/form-data")
.post(new MultipartBody(Arrays.asList(fileAtt, configAtt)));
String responseMsg = getStringFromInputStream((InputStream)
response.getEntity());
@@ -549,7 +549,7 @@ public class TikaResourceTest extends CXFTestBase {
new
java.io.ByteArrayInputStream(configJson.getBytes(StandardCharsets.UTF_8)));
Response response = WebClient
- .create(endPoint + TIKA_PATH + "/text")
+ .create(endPoint + TIKA_PATH + "/config/text")
.type("multipart/form-data")
.post(new MultipartBody(Arrays.asList(fileAtt, configAtt)));
String responseMsg = getStringFromInputStream((InputStream)
response.getEntity());
@@ -580,7 +580,7 @@ public class TikaResourceTest extends CXFTestBase {
new
java.io.ByteArrayInputStream(configJson.getBytes(StandardCharsets.UTF_8)));
response = WebClient
- .create(endPoint + TIKA_PATH)
+ .create(endPoint + TIKA_PATH + "/config")
.type("multipart/form-data")
.post(new MultipartBody(Arrays.asList(fileAtt, configAtt)));
responseMsg = getStringFromInputStream((InputStream)
response.getEntity());
