No commit message

glide-core/src/protobuf/command_request.proto

@@ -257,6 +257,8 @@ enum RequestType {
     ScriptFlush = 216;
     ScriptKill = 217;
     ScriptShow = 218;
+
+    FtCreate = 2000;
 }
 
 message Command {

glide-core/src/request_type.rs

@@ -227,6 +227,7 @@ pub enum RequestType {
     ScriptFlush = 216,
     ScriptKill = 217,
     ScriptShow = 218,
+    FtCreate = 2000,
 }
 
 fn get_two_word_command(first: &str, second: &str) -> Cmd {
@@ -457,6 +458,7 @@ impl From<::protobuf::EnumOrUnknown<ProtobufRequestType>> for RequestType {
             ProtobufRequestType::ScriptFlush => RequestType::ScriptFlush,
             ProtobufRequestType::ScriptKill => RequestType::ScriptKill,
             ProtobufRequestType::ScriptShow => RequestType::ScriptShow,
+            ProtobufRequestType::FtCreate => RequestType::FtCreate,
         }
     }
 }
@@ -685,6 +687,7 @@ impl RequestType {
             RequestType::ScriptExists => Some(get_two_word_command("SCRIPT", "EXISTS")),
             RequestType::ScriptFlush => Some(get_two_word_command("SCRIPT", "FLUSH")),
             RequestType::ScriptKill => Some(get_two_word_command("SCRIPT", "KILL")),
+            RequestType::FtCreate => Some(cmd("FT.CREATE")),
         }
     }
 }

java/client/src/main/java/glide/api/BaseClient.java

@@ -25,6 +25,7 @@
 import static command_request.CommandRequestOuterClass.RequestType.ExpireTime;
 import static command_request.CommandRequestOuterClass.RequestType.FCall;
 import static command_request.CommandRequestOuterClass.RequestType.FCallReadOnly;
+import static command_request.CommandRequestOuterClass.RequestType.FtCreate;
 import static command_request.CommandRequestOuterClass.RequestType.GeoAdd;
 import static command_request.CommandRequestOuterClass.RequestType.GeoDist;
 import static command_request.CommandRequestOuterClass.RequestType.GeoHash;
@@ -209,6 +210,7 @@
 import glide.api.commands.StreamBaseCommands;
 import glide.api.commands.StringBaseCommands;
 import glide.api.commands.TransactionsBaseCommands;
+import glide.api.commands.VectorSearchBaseCommands;
 import glide.api.models.ClusterValue;
 import glide.api.models.GlideString;
 import glide.api.models.PubSubMessage;
@@ -264,6 +266,8 @@
 import glide.api.models.commands.stream.StreamReadGroupOptions;
 import glide.api.models.commands.stream.StreamReadOptions;
 import glide.api.models.commands.stream.StreamTrimOptions;
+import glide.api.models.commands.vss.FTCreateOptions.FieldInfo;
+import glide.api.models.commands.vss.FTCreateOptions.IndexType;
 import glide.api.models.configuration.BaseClientConfiguration;
 import glide.api.models.configuration.BaseSubscriptionConfiguration;
 import glide.api.models.exceptions.ConfigurationError;
@@ -279,6 +283,7 @@
 import glide.managers.CommandManager;
 import glide.managers.ConnectionManager;
 import glide.utils.ArgsBuilder;
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.EnumSet;
 import java.util.HashMap;
@@ -310,6 +315,7 @@ public abstract class BaseClient
                 HyperLogLogBaseCommands,
                 GeospatialIndicesBaseCommands,
                 ScriptingAndFunctionsBaseCommands,
+                VectorSearchBaseCommands,
                 TransactionsBaseCommands,
                 PubSubBaseCommands {
 
@@ -5142,4 +5148,23 @@ public CompletableFuture<Long> wait(long numreplicas, long timeout) {
                 new String[] {Long.toString(numreplicas), Long.toString(timeout)},
                 this::handleLongResponse);
     }
+
+    @Override
+    public CompletableFuture<String> ftcreate(
+            @NonNull String indexName,
+            @NonNull IndexType indexType,
+            @NonNull String[] prefixes,
+            @NonNull FieldInfo[] fields) {
+        var args = new ArrayList<>(List.of(indexName, "ON", indexType.toString()));
+        if (prefixes.length > 0) {
+            args.add("PREFIX");
+            args.add(Integer.toString(prefixes.length));
+            args.addAll(List.of(prefixes));
+        }
+        args.add("SCHEMA");
+        Arrays.stream(fields).forEach(f -> args.addAll(List.of(f.toArgs())));
+
+        return commandManager.submitNewCommand(
+                FtCreate, args.toArray(String[]::new), this::handleStringResponse);
+    }
 }

java/client/src/main/java/glide/api/commands/VectorSearchBaseCommands.java

@@ -0,0 +1,26 @@
+/** Copyright Valkey GLIDE Project Contributors - SPDX Identifier: Apache-2.0 */
+package glide.api.commands;
+
+import glide.api.models.commands.vss.FTCreateOptions.FieldInfo;
+import glide.api.models.commands.vss.FTCreateOptions.IndexType;
+import java.util.concurrent.CompletableFuture;
+
+public interface VectorSearchBaseCommands {
+    // TODO GlideString???
+    /**
+     * Creates an index and initiates a backfill of that index.
+     *
+     * @see TODO
+     * @param indexName Key name where index is stored.
+     * @param indexType The index type.
+     * @param prefixes (Optional) A list of prefixes of index definitions
+     * @param fields Fields to populate into the index.
+     * @return <code>OK</code>.
+     * @example
+     *     <pre>{@code
+     * // TODO
+     * }</pre>
+     */
+    CompletableFuture<String> ftcreate(
+            String indexName, IndexType indexType, String[] prefixes, FieldInfo[] fields);
+}