Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Compatible Delete and Update rest actions #58246

Merged
merged 64 commits into from
Jul 14, 2020
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
64 commits
Select commit Hold shift + click to select a range
96ebb5c
init work. 221 vs 231 failing
pgomulka Mar 25, 2020
2e922bf
allow registering multiple rest actions under the same path
pgomulka Mar 27, 2020
e7eda97
revert out dirs
pgomulka Mar 27, 2020
5dac4b9
Merge branch 'compat_rest_api' into compat/create_index_include_type
pgomulka Mar 27, 2020
a213e6c
extend restcreateindexaction
pgomulka Mar 27, 2020
f1ad677
code style and discovery nodes in indexaction
pgomulka Mar 27, 2020
8ff3463
fix double registration
pgomulka Mar 30, 2020
9b8a26a
add search action v7
pgomulka Mar 30, 2020
b0a12bd
search & multisearch
pgomulka Mar 31, 2020
b94be5c
types with consumer
pgomulka Apr 1, 2020
f78e021
cleanup type funciton
pgomulka Apr 1, 2020
9eb1c68
packages fixed
pgomulka Apr 1, 2020
a421d56
update by query, delete by query, multi term and term
pgomulka Apr 1, 2020
3364141
package rename
pgomulka Apr 1, 2020
8abcc0a
spotless
pgomulka Apr 1, 2020
6efdb30
checkstyle
pgomulka Apr 1, 2020
90c37e2
fake request build iwth compat
pgomulka Apr 1, 2020
484e4ac
fixing some tests
pgomulka Apr 1, 2020
6184a9d
term vector body not finished
pgomulka Apr 2, 2020
1ee4487
additional testing and using version
pgomulka Apr 2, 2020
abe1d28
unused method
pgomulka Apr 2, 2020
d8fc2e5
method handlers - returning null when no handler under a method was r…
pgomulka Apr 2, 2020
d998555
comments
pgomulka Apr 3, 2020
ec8df43
remove unused constant
pgomulka Apr 3, 2020
8602f65
Merge branch 'compat_rest_api' into compat/create_index_include_type
pgomulka Apr 20, 2020
f3d25e0
fix javadoc
pgomulka Apr 20, 2020
7024913
compile
pgomulka Apr 20, 2020
446c114
Merge branch 'compat/create_index_include_type' into compat/search
pgomulka Apr 20, 2020
cafee2f
spotless
pgomulka Apr 20, 2020
f52dbc1
spotless
pgomulka Apr 20, 2020
0b07539
Merge branch 'compat_rest_api' into compat/create_index_include_type
pgomulka Apr 21, 2020
07a5dbc
Merge branch 'compat/create_index_include_type' into compat/search
pgomulka Apr 21, 2020
8135794
v7 name
pgomulka Apr 22, 2020
2087c6a
Merge branch 'compat/create_index_include_type' into compat/search
pgomulka Apr 22, 2020
7e7ed63
versions and names
pgomulka Apr 22, 2020
81a62fe
spotless
pgomulka Apr 22, 2020
d65a4a2
import fix
pgomulka Apr 22, 2020
adb1a1e
fix tests
pgomulka Apr 22, 2020
f819313
fix test
pgomulka Apr 22, 2020
6e28d24
javadoc
pgomulka Apr 22, 2020
a77716e
Merge branch 'compat_rest_api' into compat/create_index_include_type
pgomulka Apr 23, 2020
dcf588c
Merge branch 'compat/create_index_include_type' into compat/search
pgomulka Apr 23, 2020
da0edd7
Merge branch 'compat_rest_api' into compat/search
pgomulka Apr 28, 2020
42b40ec
fix merge problem
pgomulka Apr 29, 2020
8912c60
Merge branch 'compat_rest_api' into compat/search
pgomulka Apr 29, 2020
6c67db3
Merge branch 'compat_rest_api' into compat/search
pgomulka Apr 29, 2020
5a720c5
Merge branch 'compat_rest_api' into compat/search
pgomulka Jun 17, 2020
5f3158c
compile fix for deprecate method rename
pgomulka Jun 17, 2020
0249a8d
Compatible Delete and Update rest actions
pgomulka Jun 17, 2020
69f408b
checkstyle
pgomulka Jun 17, 2020
2d5274f
validate handlers version
pgomulka Jun 18, 2020
e8b28d6
Merge branch 'compat_rest_api' into compat/search
pgomulka Jul 7, 2020
83afde4
fix after merge master
pgomulka Jul 7, 2020
660f086
spotless
pgomulka Jul 7, 2020
7e1ab7f
Merge branch 'compat_rest_api' into compat/delete_update
pgomulka Jul 7, 2020
9c3031f
Merge branch 'compat/search' into compat/delete_update
pgomulka Jul 7, 2020
188bab2
checkstyle
pgomulka Jul 7, 2020
f070e03
fix tests
pgomulka Jul 7, 2020
7bad475
cleanup
pgomulka Jul 7, 2020
1f04044
Merge branch 'compat_rest_api' into compat/search
pgomulka Jul 8, 2020
8595c33
Merge branch 'compat/search' into compat/delete_update
pgomulka Jul 8, 2020
24a44a8
Merge branch 'compat_rest_api' into compat/search
pgomulka Jul 8, 2020
25788ff
Merge branch 'compat/search' into compat/delete_update
pgomulka Jul 8, 2020
fd4a274
Merge branch 'compat_rest_api' into compat/delete_update
pgomulka Jul 14, 2020
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
* 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
* 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
Expand All @@ -33,10 +33,12 @@
import org.elasticsearch.rest.RestController;
import org.elasticsearch.rest.RestHandler;
import org.elasticsearch.rest.action.admin.indices.RestCreateIndexActionV7;
import org.elasticsearch.rest.action.document.RestDeleteActionV7;
import org.elasticsearch.rest.action.document.RestGetActionV7;
import org.elasticsearch.rest.action.document.RestIndexActionV7;
import org.elasticsearch.rest.action.document.RestMultiTermVectorsActionV7;
import org.elasticsearch.rest.action.document.RestTermVectorsActionV7;
import org.elasticsearch.rest.action.document.RestUpdateActionV7;
import org.elasticsearch.rest.action.search.RestMultiSearchActionV7;
import org.elasticsearch.rest.action.search.RestSearchActionV7;
import org.elasticsearch.script.mustache.RestMultiSearchTemplateActionV7;
Expand Down Expand Up @@ -74,7 +76,9 @@ public List<RestHandler> getRestHandlers(
new RestSearchActionV7(),
new RestMultiSearchActionV7(settings),
new RestSearchTemplateActionV7(),
new RestMultiSearchTemplateActionV7(settings)
new RestMultiSearchTemplateActionV7(settings),
new RestDeleteActionV7(),
new RestUpdateActionV7()
);
}
return Collections.emptyList();
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,62 @@
/*
* Licensed to Elasticsearch under one or more contributor
* license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright
* ownership. Elasticsearch 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.elasticsearch.rest.action.document;

import org.elasticsearch.Version;
import org.elasticsearch.client.node.NodeClient;
import org.elasticsearch.common.logging.DeprecationLogger;
import org.elasticsearch.rest.RestRequest;

import java.io.IOException;
import java.util.List;

import static org.elasticsearch.rest.RestRequest.Method.DELETE;

public class RestDeleteActionV7 extends RestDeleteAction {
private static final DeprecationLogger deprecationLogger = DeprecationLogger.getLogger(RestDeleteActionV7.class);
public static final String TYPES_DEPRECATION_MESSAGE = "[types removal] Specifying types in "
+ "document index requests is deprecated, use the /{index}/_doc/{id} endpoint instead.";

@Override
public List<Route> routes() {
return List.of(new Route(DELETE, "/{index}/{type}/{id}"));
}

@Override
public String getName() {
return "document_delete_action_v7";
}

@Override
public Version compatibleWithVersion() {
return Version.V_7_0_0;
}

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
if (request.hasParam("type")) {
request.param("type");
deprecationLogger.deprecate("delete_with_types", TYPES_DEPRECATION_MESSAGE);
// todo compatible log
}

return super.prepareRequest(request, client);
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,62 @@
/*
* Licensed to Elasticsearch under one or more contributor
* license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright
* ownership. Elasticsearch 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.elasticsearch.rest.action.document;

import org.elasticsearch.Version;
import org.elasticsearch.client.node.NodeClient;
import org.elasticsearch.common.logging.DeprecationLogger;
import org.elasticsearch.rest.RestRequest;

import java.io.IOException;
import java.util.List;

import static org.elasticsearch.rest.RestRequest.Method.POST;

public class RestUpdateActionV7 extends RestUpdateAction {
private static final DeprecationLogger deprecationLogger = DeprecationLogger.getLogger(RestGetActionV7.class);
public static final String TYPES_DEPRECATION_MESSAGE = "[types removal] Specifying types in "
+ "document update requests is deprecated, use the endpoint /{index}/_update/{id} instead.";

@Override
public List<Route> routes() {
return List.of(new Route(POST, "/{index}/{type}/{id}/_update"));
}

@Override
public String getName() {
return "document_update_action_v7";
}

@Override
public Version compatibleWithVersion() {
return Version.V_7_0_0;
}

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
if (request.hasParam("type")) {
request.param("type");
deprecationLogger.deprecate("update_with_types", TYPES_DEPRECATION_MESSAGE);
// todo compatible log
}

return super.prepareRequest(request, client);
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,46 @@
/*
* Licensed to Elasticsearch under one or more contributor
* license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright
* ownership. Elasticsearch 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.elasticsearch.rest.action.document;

import org.elasticsearch.compat.FakeCompatRestRequestBuilder;
import org.elasticsearch.rest.RestRequest;
import org.elasticsearch.test.rest.RestActionTestCase;
import org.junit.Before;

public class RestDeleteActionV7Tests extends RestActionTestCase {
@Before
public void setUpAction() {
controller().registerHandler(new RestDeleteActionV7());
controller().registerHandler(new RestDeleteAction());
}

public void testTypeInPath() {
RestRequest deprecatedRequest = new FakeCompatRestRequestBuilder(xContentRegistry()).withMethod(RestRequest.Method.DELETE)
.withPath("/some_index/some_type/some_id")
.build();
dispatchRequest(deprecatedRequest);
assertWarnings(RestDeleteActionV7.TYPES_DEPRECATION_MESSAGE);

RestRequest validRequest = new FakeCompatRestRequestBuilder(xContentRegistry()).withMethod(RestRequest.Method.DELETE)
.withPath("/some_index/_doc/some_id")
.build();
dispatchRequest(validRequest);
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,46 @@
/*
* Licensed to Elasticsearch under one or more contributor
* license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright
* ownership. Elasticsearch 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.elasticsearch.rest.action.document;

import org.elasticsearch.compat.FakeCompatRestRequestBuilder;
import org.elasticsearch.rest.RestRequest;
import org.elasticsearch.test.rest.RestActionTestCase;
import org.junit.Before;

public class RestUpdateActionV7Tests extends RestActionTestCase {
@Before
public void setUpAction() {
controller().registerHandler(new RestUpdateActionV7());
controller().registerHandler(new RestUpdateAction());
}

public void testTypeInPath() {
RestRequest deprecatedRequest = new FakeCompatRestRequestBuilder(xContentRegistry()).withMethod(RestRequest.Method.POST)
.withPath("/some_index/some_type/some_id/_update")
.build();
dispatchRequest(deprecatedRequest);
assertWarnings(RestUpdateActionV7.TYPES_DEPRECATION_MESSAGE);

RestRequest validRequest = new FakeCompatRestRequestBuilder(xContentRegistry()).withMethod(RestRequest.Method.POST)
.withPath("/some_index/_update/some_id")
.build();
dispatchRequest(validRequest);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -148,6 +148,14 @@ protected final String unrecognized(
return message.toString();
}

@Override
public String toString() {
return this.getClass()+"{" +
"name=" + this.getName() + ", " +
"compatibleWithVersion=" + this.compatibleWithVersion() +
'}';
}

/**
* REST requests are handled by preparing a channel consumer that represents the execution of
* the request against a channel.
Expand Down