add bwc

Signed-off-by: Hailong Cui <[email protected]>
opensearch-project · Jul 29, 2024 · 1c274b8 · 1c274b8
1 parent a82db1e
commit 1c274b8
Showing 1 changed file with 15 additions and 7 deletions.
diff --git a/...src/main/java/org/opensearch/ml/memory/action/conversation/CreateConversationRequest.java b/...src/main/java/org/opensearch/ml/memory/action/conversation/CreateConversationRequest.java
@@ -24,11 +24,13 @@
 import java.util.Map;
 
 import org.opensearch.OpenSearchParseException;
+import org.opensearch.Version;
 import org.opensearch.action.ActionRequest;
 import org.opensearch.action.ActionRequestValidationException;
 import org.opensearch.core.common.io.stream.StreamInput;
 import org.opensearch.core.common.io.stream.StreamOutput;
 import org.opensearch.core.xcontent.XContentParser;
+import org.opensearch.ml.common.CommonValue;
 import org.opensearch.ml.common.conversation.ActionConstants;
 import org.opensearch.rest.RestRequest;
 
@@ -38,6 +40,8 @@
  * Action Request for creating a conversation
  */
 public class CreateConversationRequest extends ActionRequest {
+    public static final Version MINIMAL_SUPPORTED_VERSION_FOR_ADDITIONAL_INFO = CommonValue.VERSION_2_17_0;
+
     @Getter
     private String name = null;
     @Getter
@@ -54,8 +58,10 @@ public CreateConversationRequest(StreamInput in) throws IOException {
         super(in);
         this.name = in.readOptionalString();
         this.applicationType = in.readOptionalString();
-        if (in.readBoolean()) {
-            this.additionalInfos = in.readMap(StreamInput::readString, StreamInput::readString);
+        if (in.getVersion().onOrAfter(MINIMAL_SUPPORTED_VERSION_FOR_ADDITIONAL_INFO)) {
+            if (in.readBoolean()) {
+                this.additionalInfos = in.readMap(StreamInput::readString, StreamInput::readString);
+            }
         }
     }
 
@@ -102,11 +108,13 @@ public void writeTo(StreamOutput out) throws IOException {
         super.writeTo(out);
         out.writeOptionalString(name);
         out.writeOptionalString(applicationType);
-        if (additionalInfos == null) {
-            out.writeBoolean(false);
-        } else {
-            out.writeBoolean(true);
-            out.writeMap(additionalInfos, StreamOutput::writeString, StreamOutput::writeString);
+        if (out.getVersion().onOrAfter(MINIMAL_SUPPORTED_VERSION_FOR_ADDITIONAL_INFO)) {
+            if (additionalInfos == null) {
+                out.writeBoolean(false);
+            } else {
+                out.writeBoolean(true);
+                out.writeMap(additionalInfos, StreamOutput::writeString, StreamOutput::writeString);
+            }
         }
     }