Refactor gRPC Client and Protobuf Namespace

- Updated the gRPC client implementation to use the new Grpc.Protobuf namespace for all client calls.
- Changed the namespace from Weaviate.Client.gRPC to Weaviate.Client.Grpc for consistency.
- Modified all references to V1 types to use Grpc.Protobuf.V1 in the client code.
- Updated proto files to include the csharp_namespace option for proper namespace mapping.
- Removed the obsolete file_replication.proto and adjusted the batch.proto for better structure.
- Enhanced the BatchStreamRequest and BatchStreamReply messages for improved functionality.
- Added a new GenerativeContextualAI message to the generative.proto file.
- Updated the proto_sync.sh script to automatically add the csharp_namespace option to new proto files.

Author: mpartipilo

src/Weaviate.Client.Tests/Unit/TestFilters.cs

@@ -1,6 +1,6 @@
 using System.Reflection;
+using Weaviate.Client.Grpc.Protobuf.V1;
 using Weaviate.Client.Models;
-using Weaviate.V1;
 
 namespace Weaviate.Client.Tests.Unit;
 
@@ -201,11 +201,11 @@ public void Filter_ContainsNone()
         var uuid2 = Guid.NewGuid();
         var f1 = Filter.Property("uuids").ContainsNone(new[] { uuid1, uuid2 });
 
-        var expectedF1 = new V1.Filters
+        var expectedF1 = new Filters
         {
-            Target = new V1.FilterTarget() { Property = "uuids" },
-            Operator = V1.Filters.Types.Operator.ContainsNone,
-            ValueTextArray = new V1.TextArray() { Values = { uuid1.ToString(), uuid2.ToString() } },
+            Target = new FilterTarget() { Property = "uuids" },
+            Operator = Filters.Types.Operator.ContainsNone,
+            ValueTextArray = new TextArray() { Values = { uuid1.ToString(), uuid2.ToString() } },
         };
 
         // Act
@@ -222,21 +222,21 @@ public void Filter_Not()
         var uuid2 = Guid.NewGuid();
         var f1 = Filter.Not(Filter.ID.ContainsAny(new[] { uuid1, uuid2 }));
 
-        var expectedF1 = new V1.Filters
+        var expectedF1 = new Filters
         {
             Filters_ =
             {
-                new V1.Filters
+                new Filters
                 {
-                    Target = new V1.FilterTarget() { Property = "_id" },
-                    Operator = V1.Filters.Types.Operator.ContainsAny,
-                    ValueTextArray = new V1.TextArray()
+                    Target = new FilterTarget() { Property = "_id" },
+                    Operator = Filters.Types.Operator.ContainsAny,
+                    ValueTextArray = new TextArray()
                     {
                         Values = { uuid1.ToString(), uuid2.ToString() },
                     },
                 },
             },
-            Operator = V1.Filters.Types.Operator.Not,
+            Operator = Filters.Types.Operator.Not,
         };
 
         // Act

src/Weaviate.Client.Tests/Unit/TestGrpcCancellation.cs

@@ -1,6 +1,6 @@
 using Weaviate.Client.Grpc;
+using Weaviate.Client.Grpc.Protobuf.V1;
 using Weaviate.Client.Tests.Unit.Mocks;
-using Weaviate.V1;
 
 namespace Weaviate.Client.Tests.Unit;
 

src/Weaviate.Client.Tests/Unit/TestResults.cs

@@ -41,7 +41,7 @@ public void SearchReply_Builds_GenerativeGroupByResult_Response()
         JsonParser jsonParser = new JsonParser(
             JsonParser.Settings.Default.WithIgnoreUnknownFields(true)
         );
-        V1.SearchReply reply = jsonParser.Parse<V1.SearchReply>(json);
+        Grpc.Protobuf.V1.SearchReply reply = jsonParser.Parse<Grpc.Protobuf.V1.SearchReply>(json);
 
         Assert.NotNull(reply);
 

src/Weaviate.Client/DataClient.cs

@@ -1,6 +1,5 @@
 using System.Collections;
 using System.Collections.Frozen;
-using System.Diagnostics;
 using Weaviate.Client.Models;
 using Weaviate.Client.Rest.Dto;
 using Weaviate.Client.Validation;
@@ -193,7 +192,7 @@ public async Task<BatchInsertResponse> InsertMany(
             .Select(
                 (r, idx) =>
                 {
-                    var o = new V1.BatchObject
+                    var o = new Grpc.Protobuf.V1.BatchObject
                     {
                         Collection = _collectionName,
                         Uuid = (r.ID ?? Guid.NewGuid()).ToString(),
@@ -205,7 +204,7 @@ public async Task<BatchInsertResponse> InsertMany(
                     {
                         foreach (var reference in r.References!)
                         {
-                            var strp = new Weaviate.V1.BatchObject.Types.SingleTargetRefProps()
+                            var strp = new Grpc.Protobuf.V1.BatchObject.Types.SingleTargetRefProps()
                             {
                                 PropName = reference.Name,
                                 Uuids = { reference.TargetID.Select(id => id.ToString()) },
@@ -218,15 +217,15 @@ public async Task<BatchInsertResponse> InsertMany(
                     if (r.Vectors != null)
                     {
                         o.Vectors.AddRange(
-                            r.Vectors.Select(v => new V1.Vectors
+                            r.Vectors.Select(v => new Grpc.Protobuf.V1.Vectors
                             {
                                 Name = v.Key,
                                 VectorBytes = v.Value.ToByteString(),
                                 Type = typeof(System.Collections.IEnumerable).IsAssignableFrom(
                                     v.Value.ValueType
                                 )
-                                    ? V1.Vectors.Types.VectorType.MultiFp32
-                                    : V1.Vectors.Types.VectorType.SingleFp32,
+                                    ? Grpc.Protobuf.V1.Vectors.Types.VectorType.MultiFp32
+                                    : Grpc.Protobuf.V1.Vectors.Types.VectorType.SingleFp32,
                             })
                         );
                     }
@@ -312,7 +311,7 @@ public async Task<BatchReferenceReturn> ReferenceAddMany(
         CancellationToken cancellationToken = default
     )
     {
-        var stopwatch = Stopwatch.StartNew();
+        var stopwatch = System.Diagnostics.Stopwatch.StartNew();
 
         var result = await _client.RestClient.ReferenceAddMany(
             _collectionName,

src/Weaviate.Client/Errors.cs

@@ -1,4 +1,4 @@
-using Weaviate.Client.gRPC;
+using Weaviate.Client.Grpc;
 using Weaviate.Client.Rest;
 
 namespace Weaviate.Client;
@@ -131,5 +131,3 @@ public override string ToString()
         return $"{base.ToString()} ResourceType: {ResourceType}.";
     }
 }
-
-// TODO WeaviateUnauthorizedException, WeaviateUnauthenticatedException, WeaviateBadRequestException

src/Weaviate.Client/Models/Aggregate.cs

@@ -1,5 +1,7 @@
 namespace Weaviate.Client.Models;
 
+using V1 = Grpc.Protobuf.V1;
+
 public partial record AggregateGroupByResult
 {
     public partial record Group
@@ -103,7 +105,7 @@ internal static AggregateResult FromGrpcReply(V1.AggregateReply reply)
     }
 
     internal static Aggregate.Property FromGrpcProperty(
-        Weaviate.V1.AggregateReply.Types.Aggregations.Types.Aggregation x
+        V1.AggregateReply.Types.Aggregations.Types.Aggregation x
     )
     {
         return x.AggregationCase switch

src/Weaviate.Client/Models/Filter.cs

@@ -1,4 +1,4 @@
-using Weaviate.V1;
+using Weaviate.Client.Grpc.Protobuf.V1;
 
 namespace Weaviate.Client.Models;
 
@@ -116,7 +116,7 @@ internal TypedValue(PropertyFilter parent)
 
 public partial record Filter
 {
-    internal V1.Filters InternalFilter { get; init; } = new V1.Filters();
+    internal Filters InternalFilter { get; init; } = new Filters();
 
     protected Filter() { }
 
@@ -269,7 +269,7 @@ public record PropertyFilter : Filter
 {
     FilterTarget? _target;
 
-    internal PropertyFilter(FilterTarget target, V1.Filters parentFilter)
+    internal PropertyFilter(FilterTarget target, Filters parentFilter)
     {
         InternalFilter = parentFilter;
         _target = target;
@@ -400,13 +400,12 @@ internal NestedFilter(Filters.Types.Operator op, params Filter[] filters) =>
 }
 
 public record AndNestedFilter(params Filter[] filters)
-    : NestedFilter(V1.Filters.Types.Operator.And, filters) { }
+    : NestedFilter(Filters.Types.Operator.And, filters) { }
 
 public record OrNestedFilter(params Filter[] filters)
-    : NestedFilter(V1.Filters.Types.Operator.Or, filters) { }
+    : NestedFilter(Filters.Types.Operator.Or, filters) { }
 
-public record NotNestedFilter(Filter filter)
-    : NestedFilter(V1.Filters.Types.Operator.Not, filter) { }
+public record NotNestedFilter(Filter filter) : NestedFilter(Filters.Types.Operator.Not, filter) { }
 
 public record TimeFilter : TypedValue<DateTime>
 {

src/Weaviate.Client/Models/Sort.cs

@@ -1,5 +1,7 @@
 namespace Weaviate.Client.Models;
 
+using V1 = Grpc.Protobuf.V1;
+
 public record Sort
 {
     private Sort() { }

src/Weaviate.Client/Models/TargetVectors.cs

@@ -1,5 +1,7 @@
 namespace Weaviate.Client.Models;
 
+using V1 = Grpc.Protobuf.V1;
+
 public class TargetVectors : IEnumerable<string>
 {
     public List<string> Targets { get; } = new List<string>();
@@ -68,7 +70,6 @@ public static TargetVectors ManualWeights(
     )
     {
         var dict = weights.ToDictionary(w => w.name, w => w.weight.ToList());
-
         return new TargetVectors(dict.Keys, V1.CombinationMethod.TypeManual, dict);
     }
 
@@ -78,7 +79,6 @@ public static TargetVectors RelativeScore(
     )
     {
         var dict = weights.ToDictionary(w => w.name, w => w.weight.ToList());
-
         return new TargetVectors(dict.Keys, V1.CombinationMethod.TypeRelativeScore, dict);
     }
 }

src/Weaviate.Client/Models/Tenant.cs

@@ -1,5 +1,7 @@
 namespace Weaviate.Client.Models;
 
+using V1 = Grpc.Protobuf.V1;
+
 public enum TenantActivityStatus
 {
     [System.Runtime.Serialization.EnumMember(Value = "unspecified")]