Search points.

Author: Oceania2018

Diff for: README.md

@@ -11,9 +11,38 @@ var client = new QdrantHttpClient
         apiKey: ""
     );
 
-// create a new collection
-await client.CreateCollection("my_collection", new VectorParams(size: 100, distance: Distance.COSINE));
+var collectionName = "my_collection";
 
-// list all the collections
+// Create a new collection
+await client.CreateCollection(collectionName, new VectorParams(size: 4, distance: Distance.DOT));
+
+// List all the collections
 var collections = await client.GetCollections();
+
+// Insert vectors
+await client.Upsert(collectionName, points: new List<PointStruct>
+{
+    new PointStruct(id:1, vector: new float[]{ 0.05f, 0.61f, 0.76f, 0.74f }),
+    new PointStruct(id:2, vector: new float[]{ 0.19f, 0.81f, 0.75f, 0.11f }),
+    new PointStruct(id:3, vector: new float[]{ 0.36f, 0.55f, 0.47f, 0.94f }),
+    new PointStruct(id:4, vector: new float[]{ 0.18f, 0.01f, 0.85f, 0.80f }),
+    new PointStruct(id:5, vector: new float[]{ 0.24f, 0.18f, 0.22f, 0.44f }),
+    new PointStruct(id:6, vector: new float[]{ 0.35f, 0.08f, 0.11f, 0.44f })
+});
+
+// Get collection info
+var collectionInfo = await client.GetCollection(collectionName);
+
+Console.WriteLine($"Upserted {collectionInfo.Result.VectorsCount} points");
+
+// Vector search
+var result = await client.Search
+(
+    collectionName,
+    new float[] { 0.2f, 0.1f, 0.9f, 0.7f },
+    limit: 3
+);
+
+// Delete collection
+await client.DeleteCollection(collectionName);
 ```

Diff for: src/QdrantCSharp/Models/QdrantHttpResponse.cs

@@ -1,8 +1,8 @@
 namespace QdrantCSharp.Models;
 
-public class QdrantHttpResponse<T> where T : new()
+public class QdrantHttpResponse<T>
 {
     public float Time { get; set; }
     public string Status { get; set; } = "ok";
-    public T Result { get; set; } = new();
+    public T Result { get; set; }
 }

Diff for: src/QdrantCSharp/Models/ScoredPoint.cs

@@ -0,0 +1,9 @@
+namespace QdrantCSharp.Models;
+
+public class ScoredPoint
+{
+    public int Id { get; set; }
+    public int Version { get; set; }
+    public float Score { get; set; }
+    public float[] Vector { get; set; }
+}

Diff for: src/QdrantCSharp/Models/SearchBody.cs

@@ -0,0 +1,12 @@
+using System.Text.Json.Serialization;
+
+namespace QdrantCSharp.Models;
+
+public class SearchBody
+{
+    public float[] Vector { get; set; }
+    public int Limit { get; set; }
+    public int Offset { get; set; }
+    [JsonPropertyName("score_threshold")]
+    public float ScoreThreshold { get; set; }
+}

Diff for: src/QdrantCSharp/QdrantHttpClient.cs

@@ -62,4 +62,12 @@ public async Task<QdrantHttpResponse<UpdateResult>> Upsert(string collectionName
         {
             Points = points
         });
+
+    public async Task<QdrantHttpResponse<ScoredPoint[]>> Search(string collectionName, float[] queryVector, int limit = 10, int offset = 0)
+        => await _pointsApi.Search(collectionName, new SearchBody
+        {
+            Limit = limit,
+            Offset = offset,
+            Vector = queryVector
+        });
 }

Diff for: src/QdrantCSharp/RestAPIs/IQdrantPointApi.cs

@@ -7,4 +7,7 @@ public interface IQdrantPointApi
 {
     [Put("/collections/{collection_name}/points")]
     Task<QdrantHttpResponse<UpdateResult>> Upsert([AliasAs("collection_name")] string collectionName, [Body] PointsUpsertBody body);
+
+    [Post("/collections/{collection_name}/points/search")]
+    Task<QdrantHttpResponse<ScoredPoint[]>> Search([AliasAs("collection_name")] string collectionName, [Body] SearchBody body);
 }

Diff for: test/ConsoleApp/Program.cs

@@ -1,16 +1,19 @@
 // See https://aka.ms/new-console-template for more information
 
 using QdrantCSharp;
+using QdrantCSharp.Enums;
 using QdrantCSharp.Models;
 
 var client = new QdrantHttpClient
     (
         url: "https://808bac29-e17d-4f4e-bcc5-2bb3f873b1a1.us-east-1-0.aws.cloud.qdrant.io:6333",
         apiKey: ""
 );
-// await client.CreateCollection("my_collection", new VectorParams(size: 4, distance: Distance.COSINE));
+
+var collectionName = "my_collection";
+await client.CreateCollection(collectionName, new VectorParams(size: 4, distance: Distance.DOT));
 var collections = await client.GetCollections();
-await client.Upsert("my_collection", points: new List<PointStruct>
+await client.Upsert(collectionName, points: new List<PointStruct>
 {
     new PointStruct(id:1, vector: new float[]{ 0.05f, 0.61f, 0.76f, 0.74f }),
     new PointStruct(id:2, vector: new float[]{ 0.19f, 0.81f, 0.75f, 0.11f }),
@@ -19,9 +22,15 @@
     new PointStruct(id:5, vector: new float[]{ 0.24f, 0.18f, 0.22f, 0.44f }),
     new PointStruct(id:6, vector: new float[]{ 0.35f, 0.08f, 0.11f, 0.44f })
 });
-var collectionInfo = await client.GetCollection("my_collection");
+var collectionInfo = await client.GetCollection(collectionName);
 Console.WriteLine($"Upserted {collectionInfo.Result.VectorsCount} points");
-// await client.DeleteCollection("my_collection");
+var result = await client.Search
+(
+    collectionName,
+    new float[] { 0.2f, 0.1f, 0.9f, 0.7f },
+    limit: 3
+);
+await client.DeleteCollection(collectionName);
 collections = await client.GetCollections();
 
 Console.ReadLine();