ArangoDB-Community · rafsanulhasan · Oct 25, 2025 · Oct 25, 2025 · Oct 25, 2025 · Oct 25, 2025
diff --git a/ArangoDB.Extensions.VectorData.Tests/ArangoDB.Extensions.VectorData.Tests.csproj b/ArangoDB.Extensions.VectorData.Tests/ArangoDB.Extensions.VectorData.Tests.csproj
@@ -0,0 +1,128 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+	<PropertyGroup>
+		<TargetFramework>net9.0</TargetFramework>
+		<ImplicitUsings>enable</ImplicitUsings>
+		<Nullable>enable</Nullable>
+		<IsPackable>false</IsPackable>
+		<UserSecretsId>733488cf-ebe1-45f3-8f3d-64056225edb6</UserSecretsId>
+	</PropertyGroup>
+
+	<ItemGroup>
+		<PackageReference Include="ArangoDBNetStandard" Version="3.1.0" />
+		<PackageReference Include="Bogus" Version="35.6.4" />
+		<PackageReference Include="coverlet.collector" Version="6.0.4" />
+		<PackageReference Include="Microsoft.AspNetCore.Mvc.Testing" Version="9.0.9" />
+		<PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.14.1" />
+		<PackageReference Include="Microsoft.Extensions.AI.Abstractions" Version="9.9.1" />
+		<PackageReference Include="Microsoft.Extensions.AI.OpenAI" Version="9.9.1-preview.1.25474.6" />
+		<PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="9.0.9" />
+		<PackageReference Include="NSubstitute" Version="5.3.0" />
+		<PackageReference Include="NSubstitute.Analyzers.CSharp" Version="1.0.17">
+			<PrivateAssets>all</PrivateAssets>
+			<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+		</PackageReference>
+		<PackageReference Include="NUnit" Version="4.4.0" />
+		<PackageReference Include="NUnit.Analyzers" Version="4.10.0">
+		  <PrivateAssets>all</PrivateAssets>
+		  <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+		</PackageReference>
+		<PackageReference Include="NUnit3TestAdapter" Version="5.1.0" />
+		<PackageReference Include="Shouldly" Version="4.3.0" />
+		<PackageReference Include="System.Data.SqlClient" Version="4.9.0" />
+		<PackageReference Include="Testcontainers.ArangoDb" Version="4.7.0" />
+	</ItemGroup>
+
+	<ItemGroup>
+	  <ProjectReference Include="..\ArangoDB.Extensions.VectorData\ArangoDB.Extensions.VectorData.csproj" />
+	</ItemGroup>
+
+	<ItemGroup>
+		<Using Include="ArangoDBNetStandard" />
+		<Using Include="ArangoDBNetStandard.CollectionApi" />
+		<Using Include="ArangoDBNetStandard.CursorApi" />
+		<Using Include="ArangoDBNetStandard.DocumentApi" />
+		<Using Include="ArangoDB.Extensions.VectorData" />
+		<Using Include="ArangoDB.Extensions.VectorData.Helpers" />
+		<Using Include="Bogus" />
+		<Using Include="Microsoft.Extensions.VectorData" />
+		<Using Include="NSubstitute" />
+		<Using Include="NUnit.Framework" />
+		<Using Include="Shouldly" />
+		<Using Include="System.Diagnostics.CodeAnalysis" />
+	</ItemGroup>
+
+	<ItemGroup>
+		<Compile Update="UnitTests\ArangoCollectionUnitTests.DeleteAsync.cs">
+			<DependentUpon>ArangoCollectionUnitTests.cs</DependentUpon>
+		</Compile>
+		<Compile Update="UnitTests\ArangoCollectionUnitTests.EnsureCollectionDeletedAsync.cs">
+			<DependentUpon>ArangoCollectionUnitTests.cs</DependentUpon>
+		</Compile>
+		<Compile Update="UnitTests\ArangoCollectionUnitTests.EnsureCollectionExistsAsync.cs">
+			<DependentUpon>ArangoCollectionUnitTests.cs</DependentUpon>
+		</Compile>
+		<Compile Update="UnitTests\ArangoCollectionUnitTests.GetAsync.cs">
+			<DependentUpon>ArangoCollectionUnitTests.cs</DependentUpon>
+		</Compile>
+		<Compile Update="UnitTests\ArangoCollectionUnitTests.GetAsyncWithFilter.cs">
+			<DependentUpon>ArangoCollectionUnitTests.cs</DependentUpon>
+		</Compile>
+		<Compile Update="UnitTests\ArangoCollectionUnitTests.GetService.cs">
+			<DependentUpon>ArangoCollectionUnitTests.cs</DependentUpon>
+		</Compile>
+		<Compile Update="UnitTests\ArangoCollectionUnitTests.SearchAsync.cs">
+			<DependentUpon>ArangoCollectionUnitTests.cs</DependentUpon>
+		</Compile>
+	</ItemGroup>
+
+	<ItemGroup>
+		<Compile Update="IntegrationTests\ArangoCollectionIntegrationTests.CollectionExistsAsync.cs">
+			<DependentUpon>ArangoCollectionIntegrationTests.cs</DependentUpon>
+		</Compile>
+		<Compile Update="IntegrationTests\ArangoCollectionIntegrationTests.DeleteAsync.cs">
+			<DependentUpon>ArangoCollectionIntegrationTests.cs</DependentUpon>
+		</Compile>
+		<Compile Update="IntegrationTests\ArangoCollectionIntegrationTests.EnsureCollectionDeletedAsync.cs">
+			<DependentUpon>ArangoCollectionIntegrationTests.cs</DependentUpon>
+		</Compile>
+		<Compile Update="IntegrationTests\ArangoCollectionIntegrationTests.EnsureCollectionExistsAsync.cs">
+			<DependentUpon>ArangoCollectionIntegrationTests.cs</DependentUpon>
+		</Compile>
+		<Compile Update="IntegrationTests\ArangoCollectionIntegrationTests.GetAsync.cs">
+			<DependentUpon>ArangoCollectionIntegrationTests.cs</DependentUpon>
+		</Compile>
+		<Compile Update="IntegrationTests\ArangoCollectionIntegrationTests.GetAsyncWithFilter.cs">
+			<DependentUpon>ArangoCollectionIntegrationTests.cs</DependentUpon>
+		</Compile>
+		<Compile Update="IntegrationTests\ArangoCollectionIntegrationTests.GetService.cs">
+			<DependentUpon>ArangoCollectionIntegrationTests.cs</DependentUpon>
+		</Compile>
+		<Compile Update="IntegrationTests\ArangoCollectionIntegrationTests.SearchAsync.cs">
+			<DependentUpon>ArangoCollectionIntegrationTests.cs</DependentUpon>
+		</Compile>
+		<Compile Update="IntegrationTests\ArangoCollectionIntegrationTests.UpsertAsync.cs">
+			<DependentUpon>ArangoCollectionIntegrationTests.cs</DependentUpon>
+		</Compile>
+	</ItemGroup>
+
+
+	<ItemGroup>
+		<Compile Update="IntegrationTests\ArangoCollectionIntegrationTests.GetAsyncWithFilter.EqualityOperator.cs">
+			<DependentUpon>ArangoCollectionIntegrationTests.GetAsyncWithFilter.cs</DependentUpon>
+		</Compile>
+		<Compile Update="IntegrationTests\ArangoCollectionIntegrationTests.GetAsyncWithFilter.EqualsMethods.cs">
+			<DependentUpon>ArangoCollectionIntegrationTests.GetAsyncWithFilter.cs</DependentUpon>
+		</Compile>
+		<Compile Update="IntegrationTests\ArangoCollectionIntegrationTests.GetAsyncWithFilter.LikeMethods.cs">
+			<DependentUpon>ArangoCollectionIntegrationTests.GetAsyncWithFilter.cs</DependentUpon>
+		</Compile>
+		<Compile Update="IntegrationTests\ArangoCollectionIntegrationTests.GetAsyncWithFilter.CollectionContainsMethods.cs">
+			<DependentUpon>ArangoCollectionIntegrationTests.GetAsyncWithFilter.cs</DependentUpon>
+		</Compile>
+		<Compile Update="IntegrationTests\ArangoCollectionIntegrationTests.GetAsyncWithFilter.StringContainsMethods.cs">
+			<DependentUpon>ArangoCollectionIntegrationTests.GetAsyncWithFilter.cs</DependentUpon>
+		</Compile>
+	</ItemGroup>
+
+</Project>
diff --git a/...ctorData.Tests/IntegrationTests/ArangoCollectionIntegrationTests.CollectionExistsAsync.cs b/...ctorData.Tests/IntegrationTests/ArangoCollectionIntegrationTests.CollectionExistsAsync.cs
@@ -0,0 +1,41 @@
+namespace ArangoDB.Extensions.VectorData.Tests.IntegrationTests;
+
+[TestFixture]
+public partial class ArangoCollectionIntegrationTests
+{
+    [Test]
+    public async Task CollectionExistsAsync_ShouldReturnTrue_WhenCollectionExists()
+    {
+        // Arrange
+        string collectionName = Faker.Name.LastName();
+        await ArangoDbClient
+            .Collection
+            .PostCollectionAsync(new ()
+            {
+                Name = collectionName
+            });
+        using VectorStoreCollection<string, TestRecord> collection = VectorStore
+            .GetCollection<string, TestRecord>(collectionName, null);
+
+        // Act
+        bool exists = await collection.CollectionExistsAsync();
+
+        // Assert
+        exists.ShouldBeTrue();
+    }
+
+    [Test]
+    public async Task CollectionExistsAsync_ShouldReturnFalse_WhenCollectionDoesNotExist()
+    {
+        // Arrange
+        string randomCollectionName = Faker.Random.Word().ToLower();
+        VectorStoreCollection<string, TestRecord> collection = VectorStore
+            .GetCollection<string, TestRecord>(randomCollectionName, null);
+
+        // Act
+        bool exists = await collection.CollectionExistsAsync();
+
+        // Assert
+        exists.ShouldBeFalse();
+    }
+}
diff --git a/...ensions.VectorData.Tests/IntegrationTests/ArangoCollectionIntegrationTests.DeleteAsync.cs b/...ensions.VectorData.Tests/IntegrationTests/ArangoCollectionIntegrationTests.DeleteAsync.cs
@@ -0,0 +1,48 @@
+using ArangoDBNetStandard.DocumentApi.Models;
+
+using System.Net;
+
+namespace ArangoDB.Extensions.VectorData.Tests.IntegrationTests;
+
+public partial class ArangoCollectionIntegrationTests
+{
+    [Test]
+    public async Task DeleteAsync_ShouldDeleteDocument_WhenDocumentExists()
+    {
+        // Arrange
+        VectorStoreCollection<string, TestRecord> collection = VectorStore
+            .GetCollection<string, TestRecord>(CollectionName, null);
+        string key = Guid.NewGuid().ToString();
+        TestRecord record = new()
+        {
+            Key = key,
+            Name = Faker.Person.FullName
+        };
+        PostDocumentResponse<TestRecord> postDocumentResponse = await ArangoDbClient
+            .Document
+            .PostDocumentAsync(collection.Name, record);
+
+        // Act
+        await collection.DeleteAsync(postDocumentResponse._key);
+
+        // Assert
+        using (Assert.EnterMultipleScope())
+        {
+            try
+            {
+                TestRecord testRecord = await ArangoDbClient
+                    .Document
+                    .GetDocumentAsync<TestRecord>(
+                        postDocumentResponse._id,
+                        Arg.Any<DocumentHeaderProperties>(),
+                        Arg.Any<CancellationToken>());
+            }
+            catch (ApiErrorException ex)
+            {
+                ex.ShouldBeOfType<ApiErrorException>();
+                ex.ApiError.Code.ShouldBe(HttpStatusCode.NotFound);
+            }
+        }
+    }
+
+}
diff --git a/...a.Tests/IntegrationTests/ArangoCollectionIntegrationTests.EnsureCollectionDeletedAsync.cs b/...a.Tests/IntegrationTests/ArangoCollectionIntegrationTests.EnsureCollectionDeletedAsync.cs
@@ -0,0 +1,36 @@
+using ArangoDBNetStandard.CollectionApi.Models;
+
+namespace ArangoDB.Extensions.VectorData.Tests.IntegrationTests;
+
+public partial class ArangoCollectionIntegrationTests
+{
+    [Test]
+    public async Task EnsureCollectionDeletedAsync_ShouldDeleteCollection_WhenCollectionExists()
+    {
+        // Arrange
+        string collectionName = Faker.Random.String2(10);
+        await ArangoDbClient
+            .Collection
+            .PostCollectionAsync(new()
+            {
+                Name = collectionName,
+                Type = CollectionType.Document
+            });
+        VectorStoreCollection<string, TestRecord> collection = VectorStore
+            .GetCollection<string, TestRecord>(collectionName, null);
+
+        // Act & Assert
+        await Should.NotThrowAsync(() => collection.EnsureCollectionDeletedAsync());
+    }
+
+    [Test]
+    public async Task EnsureCollectionDeletedAsync_ShouldIgnoreException_WhenDocumentDoesNotExist()
+    {
+        // Arrange
+        VectorStoreCollection<string, TestRecord> collection = VectorStore
+            .GetCollection<string, TestRecord>(Faker.Random.String2(10), null);
+
+        // Act & Assert
+        await Should.NotThrowAsync(() => collection.EnsureCollectionDeletedAsync());
+    }
+}
diff --git a/...ta.Tests/IntegrationTests/ArangoCollectionIntegrationTests.EnsureCollectionExistsAsync.cs b/...ta.Tests/IntegrationTests/ArangoCollectionIntegrationTests.EnsureCollectionExistsAsync.cs
@@ -0,0 +1,47 @@
+using ArangoDBNetStandard.CollectionApi.Models;
+
+using System.Net;
+
+namespace ArangoDB.Extensions.VectorData.Tests.IntegrationTests;
+
+public partial class ArangoCollectionIntegrationTests
+{
+    [Test]
+    public async Task EnsureCollectionExistsAsync_ShouldCreateCollection_WhenDoesNotExist()
+    {
+        // Arrange
+        string collectionName = Faker.Random.String2(10);
+        VectorStoreCollection<string, TestRecord> collection = VectorStore.GetCollection<string, TestRecord>(
+            collectionName,
+            null);
+
+        // Act
+
+        // Assert
+        using (Assert.EnterMultipleScope())
+        {
+            await Should.NotThrowAsync(()
+                => collection.EnsureCollectionExistsAsync());
+            GetCollectionResponse getCollectionResponse = await ArangoDbClient
+                .Collection
+                .GetCollectionAsync(collectionName);
+            getCollectionResponse.Name.ShouldBe(collectionName);
+            getCollectionResponse.Type.ShouldBe(CollectionType.Document);
+            getCollectionResponse.Code.ShouldBe(HttpStatusCode.OK);
+        }
+    }
+
+
+    [Test]
+    public async Task EnsureCollectionExistsAsync_ShouldIgnoreException_WhenAlreadyExists()
+    {
+        // Arrange
+        VectorStoreCollection<string, TestRecord> collection = VectorStore.GetCollection<string, TestRecord>(
+            CollectionName,
+            null);
+
+        // Act & Assert
+        await Should.NotThrowAsync(()
+            => collection.EnsureCollectionExistsAsync());
+    }
+}
diff --git a/...Extensions.VectorData.Tests/IntegrationTests/ArangoCollectionIntegrationTests.GetAsync.cs b/...Extensions.VectorData.Tests/IntegrationTests/ArangoCollectionIntegrationTests.GetAsync.cs
@@ -0,0 +1,56 @@
+using ArangoDBNetStandard.DocumentApi.Models;
+
+namespace ArangoDB.Extensions.VectorData.Tests.IntegrationTests;
+
+public partial class ArangoCollectionIntegrationTests
+{
+    [Test]
+    public async Task GetAysnc_ReturnsDocument_WhenDocumentExists()
+    {
+        // Arrange
+        string documentName = Faker.Random.Word();
+        TestRecord rec = new()
+        {
+            Name = documentName,
+        };
+        PostDocumentResponse<TestRecord> newDoc = await ArangoDbClient
+            .Document
+            .PostDocumentAsync(CollectionName, rec);
+
+        using var collection = VectorStore.GetCollection<string, TestRecord>(CollectionName, null);
+
+        // Act & Assert
+        using (Assert.EnterMultipleScope())
+        {
+            TestRecord? fetchedDoc = null;
+            await Should.NotThrowAsync(async () => fetchedDoc = await collection.GetAsync(newDoc._id));
+            fetchedDoc.ShouldNotBeNull();
+            fetchedDoc.Name.ShouldBe(documentName);
+        }
+    }
+
+    [Test]
+    public async Task GetAysnc_ReturnsNullWithoutThrowingException_WhenDocumentDoesNotExist()
+    {
+        // Arrange
+        string documentName = Faker.Name.LastName();
+        TestRecord rec = new()
+        {
+            Name = documentName,
+        };
+        string id=$"{CollectionName}/{Faker.Name.LastName()}";
+
+        using var collection = VectorStore.GetCollection<string, TestRecord>(CollectionName, null);
+
+        // Act & Assert
+        using (Assert.EnterMultipleScope())
+        {
+            TestRecord? fetchedDoc = null;
+            await Should.NotThrowAsync(async () =>
+            {
+                fetchedDoc = await collection.GetAsync(id);
+            });
+            fetchedDoc.ShouldBeNull();
+        }
+    }
+}