Add centralized exception handling and new exception types

.github/workflows/main.yaml

@@ -152,6 +152,7 @@ jobs:
     name: Test on Weaviate v${{ matrix.version }}
     permissions:
       contents: read
+      checks: write
     needs: [unit-tests, setup]
     strategy:
       fail-fast: false

.github/workflows/test-on-weaviate-version.yml

@@ -26,6 +26,7 @@ jobs:
     name: Quick Integration Tests - v${{ inputs.weaviate-version }}
     permissions:
       contents: read
+      checks: write
     uses: ./.github/workflows/integration-test.yml
     secrets: inherit
     with:
@@ -38,6 +39,7 @@ jobs:
     name: Slow Integration Tests - v${{ inputs.weaviate-version }}
     permissions:
       contents: read
+      checks: write
     needs: [integration-rbac]
     if: ${{ inputs.run-slow-tests }}
     uses: ./.github/workflows/integration-test.yml
@@ -52,6 +54,7 @@ jobs:
     name: RBAC Integration Tests - v${{ inputs.weaviate-version }}
     permissions:
       contents: read
+      checks: write
     needs: [integration-quick]
     if: ${{ inputs.run-slow-tests }}
     uses: ./.github/workflows/integration-test.yml

src/Weaviate.Client.Tests/Integration/TestAuth.cs

@@ -1,10 +1,8 @@
 namespace Weaviate.Client.Tests.Integration;
 
-using System;
 using System.Net.Http;
 using System.Threading.Tasks;
 using Weaviate.Client;
-using Xunit;
 
 public class TestAuth : IntegrationTests
 {
@@ -208,4 +206,21 @@ await client
 
         // TODO Needs a finalized way to inject a logger and check that no warnings were logged
     }
+
+    [Fact]
+    public async Task TestAuthenticationFailure()
+    {
+        string clientSecret = "invalid-secret";
+        Assert.True(await IsAuthEnabled($"localhost:{OKTA_PORT_CC}"));
+
+        await Assert.ThrowsAsync<WeaviateAuthenticationException>(async () =>
+        {
+            await Connect.Local(
+                hostname: "localhost",
+                restPort: OKTA_PORT_CC,
+                credentials: Auth.ClientCredentials(clientSecret, "some_scope"),
+                httpMessageHandler: _httpMessageHandler
+            );
+        });
+    }
 }

src/Weaviate.Client.Tests/Integration/TestRbacAuthorization.cs

@@ -0,0 +1,86 @@
+namespace Weaviate.Client.Tests.Integration;
+
+using System.Linq;
+using Weaviate.Client;
+using Weaviate.Client.Models;
+using Xunit;
+
+/// <summary>
+/// RBAC Groups integration tests (Rest:8092 gRPC:50063). Authorization checks for various operations.
+/// </summary>
+public class TestRbacAuthorization : IntegrationTests
+{
+    public override ushort RestPort => 8092;
+    public override ushort GrpcPort => 50063;
+    private const string ADMIN_API_KEY = "admin-key";
+
+    public override async ValueTask InitializeAsync()
+    {
+        await base.InitializeAsync();
+
+        RequireVersion("1.32.0");
+    }
+
+    public override ICredentials? Credentials => Auth.ApiKey(ADMIN_API_KEY);
+
+    [Fact, Trait("Category", "RBAC")]
+    public async Task TestAuthorizationFailure()
+    {
+        // Generate random names for collection and user
+        var collectionName = $"AuthorizationTest";
+        var userId = Helpers.GenerateUniqueIdentifier("user");
+
+        // Create collection
+        var collectionConfig = new CollectionConfig
+        {
+            Name = collectionName,
+            Properties = new[]
+            {
+                new Property { Name = "name", DataType = new[] { "string" } },
+            },
+        };
+
+        var client = await CollectionFactory<object>(collectionConfig);
+
+        // Create a role with only read permission for this collection
+        var readOnlyRole = await _weaviate.Roles.Create(
+            "read-only-role",
+            [
+                new Permissions.Collections(collectionName) { Read = true },
+                new Permissions.Data(collectionName, null, null) { Read = true },
+            ],
+            TestContext.Current.CancellationToken
+        );
+
+        // Create a user and assign the read-only role
+        var apiKey = await _weaviate.Users.Db.Create(
+            userId,
+            cancellationToken: TestContext.Current.CancellationToken
+        );
+        await _weaviate.Users.Db.AssignRoles(
+            userId,
+            new[] { readOnlyRole.Name },
+            cancellationToken: TestContext.Current.CancellationToken
+        );
+
+        // Create a new client with the user's API key
+        var userClient = await new WeaviateClientBuilder()
+            .WithRestEndpoint("localhost")
+            .WithRestPort(RestPort)
+            .WithGrpcEndpoint("localhost")
+            .WithGrpcPort(GrpcPort)
+            .WithCredentials(Auth.ApiKey(apiKey))
+            .BuildAsync();
+
+        var userCollection = userClient.Collections.Use(collectionName);
+
+        // Try to insert data and assert that authorization exception is thrown
+        await Assert.ThrowsAsync<WeaviateAuthorizationException>(async () =>
+        {
+            await userCollection.Data.Insert(
+                new { name = "should fail" },
+                cancellationToken: TestContext.Current.CancellationToken
+            );
+        });
+    }
+}