wip

Author: JVerwolf

server/src/main/java/org/elasticsearch/TransportVersion.java

@@ -33,13 +33,6 @@
  * Each transport version constant has an id number, which for versions prior to 8.9.0 is the same as the release version for backwards
  * compatibility. In 8.9.0 this is changed to an incrementing number, disconnected from the release version.
  * <p>
- * Each version constant has a unique id string. This is not actually used in the binary protocol, but is there to ensure each protocol
- * version is only added to the source file once. This string needs to be unique (normally a UUID, but can be any other unique nonempty
- * string). If two concurrent PRs add the same transport version, the different unique ids cause a git conflict, ensuring that the second PR
- * to be merged must be updated with the next free version first. Without the unique id string, git will happily merge the two versions
- * together, resulting in the same transport version being used across multiple commits, causing problems when you try to upgrade between
- * those two merged commits.
- *
  * <h2>Version compatibility</h2>
  * The earliest compatible version is hardcoded in the {@link TransportVersions#MINIMUM_COMPATIBLE} field. Previously, this was dynamically
  * calculated from the major/minor versions of {@link Version}, but {@code TransportVersion} does not have separate major/minor version
@@ -150,7 +143,7 @@ public static TransportVersion fromString(String str) {
     /**
      * Returns {@code true} if this version is a patch version at or after {@code version}.
      * <p>
-     * This should not be used normally. It is used for matching patch versions of the same base version,
+     * This should not normally be used. It is used for matching patch versions of the same major and minor version,
      * using the standard version number format specified in {@link TransportVersions}.
      * When a patch version of an existing transport version is created, {@code transportVersion.isPatchFrom(patchVersion)}
      * will match any transport version at or above {@code patchVersion} that is also of the same base version.

server/src/main/java/org/elasticsearch/action/ActionModule.java

@@ -209,6 +209,9 @@
 import org.elasticsearch.action.termvectors.TransportMultiTermVectorsAction;
 import org.elasticsearch.action.termvectors.TransportShardMultiTermsVectorAction;
 import org.elasticsearch.action.termvectors.TransportTermVectorsAction;
+import org.elasticsearch.action.tvbackport.RestTVBackportAction;
+import org.elasticsearch.action.tvbackport.TVBackportAction;
+import org.elasticsearch.action.tvbackport.TransportTVBackportAction;
 import org.elasticsearch.action.update.TransportUpdateAction;
 import org.elasticsearch.client.internal.node.NodeClient;
 import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
@@ -806,6 +809,9 @@ public <Request extends ActionRequest, Response extends ActionResponse> void reg
         actions.register(GetSynonymRuleAction.INSTANCE, TransportGetSynonymRuleAction.class);
         actions.register(DeleteSynonymRuleAction.INSTANCE, TransportDeleteSynonymRuleAction.class);
 
+        // Transport Version Backport Testing
+        actions.register(TVBackportAction.INSTANCE, TransportTVBackportAction.class);
+
         return unmodifiableMap(actions.getRegistry());
     }
 
@@ -1032,6 +1038,9 @@ public void initRestHandlers(Supplier<DiscoveryNodes> nodesInCluster, Predicate<
         registerHandler.accept(new RestPutSynonymRuleAction());
         registerHandler.accept(new RestGetSynonymRuleAction());
         registerHandler.accept(new RestDeleteSynonymRuleAction());
+
+        // Transport Version Backport Testing
+        registerHandler.accept(new RestTVBackportAction());
     }
 
     @Override

server/src/main/java/org/elasticsearch/action/tvbackport/RestTVBackportAction.java

@@ -0,0 +1,37 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the "Elastic License
+ * 2.0", the "GNU Affero General Public License v3.0 only", and the "Server Side
+ * Public License v 1"; you may not use this file except in compliance with, at
+ * your election, the "Elastic License 2.0", the "GNU Affero General Public
+ * License v3.0 only", or the "Server Side Public License, v 1".
+ */
+
+package org.elasticsearch.action.tvbackport;
+
+import org.elasticsearch.client.internal.node.NodeClient;
+import org.elasticsearch.rest.BaseRestHandler;
+import org.elasticsearch.rest.RestRequest;
+import org.elasticsearch.rest.action.RestToXContentListener;
+
+import java.io.IOException;
+import java.util.List;
+
+public class RestTVBackportAction extends BaseRestHandler {
+    @Override
+    public String getName() {
+        return "_tv_backport_action";
+    }
+
+    @Override
+    public List<Route> routes() {
+        return List.of(new Route(RestRequest.Method.GET, "/_tv_backport"));
+    }
+
+    @Override
+    protected RestChannelConsumer prepareRequest(RestRequest request, NodeClient client) throws IOException {
+        TVBackportRequest tvBackportRequest = new TVBackportRequest();
+        // Here you can set any parameters from the request to the tvBackportRequest if needed
+        return channel -> client.execute(TVBackportAction.INSTANCE, tvBackportRequest, new RestToXContentListener<>(channel));
+    }
+}

server/src/main/java/org/elasticsearch/action/tvbackport/TVBackportAction.java

@@ -0,0 +1,21 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the "Elastic License
+ * 2.0", the "GNU Affero General Public License v3.0 only", and the "Server Side
+ * Public License v 1"; you may not use this file except in compliance with, at
+ * your election, the "Elastic License 2.0", the "GNU Affero General Public
+ * License v3.0 only", or the "Server Side Public License, v 1".
+ */
+
+package org.elasticsearch.action.tvbackport;
+
+import org.elasticsearch.action.ActionType;
+
+public class TVBackportAction extends ActionType<TVBackportResponse> {
+    public static final TVBackportAction INSTANCE = new TVBackportAction();
+    public static final String NAME = "indices:data/read/tvbackport";
+
+    private TVBackportAction() {
+        super(NAME);
+    }
+}

server/src/main/java/org/elasticsearch/action/tvbackport/TVBackportRequest.java

@@ -0,0 +1,21 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the "Elastic License
+ * 2.0", the "GNU Affero General Public License v3.0 only", and the "Server Side
+ * Public License v 1"; you may not use this file except in compliance with, at
+ * your election, the "Elastic License 2.0", the "GNU Affero General Public
+ * License v3.0 only", or the "Server Side Public License, v 1".
+ */
+
+package org.elasticsearch.action.tvbackport;
+
+import org.elasticsearch.action.ActionRequest;
+import org.elasticsearch.action.ActionRequestValidationException;
+
+public class TVBackportRequest extends ActionRequest {
+
+    @Override
+    public ActionRequestValidationException validate() {
+        return null;
+    }
+}

server/src/main/java/org/elasticsearch/action/tvbackport/TVBackportResponse.java

@@ -0,0 +1,30 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the "Elastic License
+ * 2.0", the "GNU Affero General Public License v3.0 only", and the "Server Side
+ * Public License v 1"; you may not use this file except in compliance with, at
+ * your election, the "Elastic License 2.0", the "GNU Affero General Public
+ * License v3.0 only", or the "Server Side Public License, v 1".
+ */
+
+package org.elasticsearch.action.tvbackport;
+
+import org.elasticsearch.action.ActionResponse;
+import org.elasticsearch.common.io.stream.StreamOutput;
+import org.elasticsearch.xcontent.ToXContentObject;
+import org.elasticsearch.xcontent.XContentBuilder;
+
+import java.io.IOException;
+
+public class TVBackportResponse extends ActionResponse implements ToXContentObject {
+    @Override
+    public void writeTo(StreamOutput out) throws IOException {
+        // TODO: Implement the serialization logic for the response
+    }
+
+    @Override
+    public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
+        // TODO: Implement the logic to convert the response to XContent format
+        return null;
+    }
+}

server/src/main/java/org/elasticsearch/action/tvbackport/TransportTVBackportAction.java

@@ -0,0 +1,40 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the "Elastic License
+ * 2.0", the "GNU Affero General Public License v3.0 only", and the "Server Side
+ * Public License v 1"; you may not use this file except in compliance with, at
+ * your election, the "Elastic License 2.0", the "GNU Affero General Public
+ * License v3.0 only", or the "Server Side Public License, v 1".
+ */
+
+package org.elasticsearch.action.tvbackport;
+
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.elasticsearch.action.ActionListener;
+import org.elasticsearch.action.support.ActionFilters;
+import org.elasticsearch.action.support.TransportAction;
+import org.elasticsearch.injection.guice.Inject;
+import org.elasticsearch.tasks.Task;
+import org.elasticsearch.tasks.TaskManager;
+
+import java.util.concurrent.Executor;
+
+public class TransportTVBackportAction extends TransportAction<TVBackportRequest, TVBackportResponse> {
+    private static final Logger logger = LogManager.getLogger(TransportTVBackportAction.class);
+
+    @Inject
+    public TransportTVBackportAction(
+        ActionFilters actionFilters,
+        TaskManager taskManager,
+        Executor executor
+    ) {
+        super(TVBackportAction.NAME, actionFilters, taskManager, executor);
+    }
+
+    @Override
+    protected void doExecute(Task task, TVBackportRequest request, ActionListener<TVBackportResponse> listener) {
+        logger.info("Executing TVBackportAction for request");
+        listener.onResponse(new TVBackportResponse());
+    }
+}