[ksqlDB.RestApi.Client]: added TypeExtensionsTests.GetMemberNameunit tests

Author: tomasfabian

Tests/ksqlDB.RestApi.Client.Tests/Infrastructure/Extensions/TypeExtensionsTests.cs

@@ -1,4 +1,6 @@
 using System.Collections;
+using System.Linq.Expressions;
+using System.Reflection;
 using System.Text;
 using System.Text.Json.Serialization;
 using FluentAssertions;
@@ -358,6 +360,8 @@ public void TryGetAttribute()
     attribute.Should().BeOfType<KeyAttribute>();
   }
 
+  #region GetMemberName
+
   private record MySensor
   {
     [JsonPropertyName("SensorId")]
@@ -416,4 +420,64 @@ public void GetMemberName_ModelBuilderHasColumnName()
     //Assert
     memberName.Should().Be(columnName);
   }
+
+  [Test]
+  public void GetMemberName_MemberExpression_ModelBuilderHasColumnName()
+  {
+    //Arrange
+    var columnName = "Id";
+    Expression<Func<MySensor, string>> expression = c => c.SensorId2;
+
+    var modelBuilder = new ModelBuilder();
+    modelBuilder.Entity<MySensor>()
+      .Property(expression)
+      .HasColumnName(columnName);
+
+    //Act
+    var memberName = ((MemberExpression)expression.Body).GetMemberName(modelBuilder);
+
+    //Assert
+    memberName.Should().Be(columnName);
+  }
+
+  [Test]
+  public void GetMemberName_FromMemberExpression_JsonPropertyNameAttributeWasUsed()
+  {
+    //Arrange
+    Expression<Func<MySensor, string>> expression = c => c.SensorId2;
+
+    var modelBuilder = new ModelBuilder();
+    modelBuilder.Entity<MySensor>()
+      .Property(expression)
+      .WithHeaders();
+    var memberExpression = (MemberExpression) expression.Body;
+
+    //Act
+    var memberName = memberExpression.GetMemberName(modelBuilder);
+
+    //Assert
+    var jsonPropertyNameAttribute = memberExpression.Member.GetCustomAttribute<JsonPropertyNameAttribute>();
+    memberName.Should().Be(jsonPropertyNameAttribute?.Name);
+  }
+
+  [Test]
+  public void GetMemberName_FromMemberExpression_PropertyNameWasUsed()
+  {
+    //Arrange
+    Expression<Func<MySensor, string>> expression = c => c.Title;
+
+    var modelBuilder = new ModelBuilder();
+    modelBuilder.Entity<MySensor>()
+      .Property(expression)
+      .WithHeaders();
+    var memberExpression = (MemberExpression)expression.Body;
+
+    //Act
+    var memberName = memberExpression.GetMemberName(modelBuilder);
+
+    //Assert
+    memberName.Should().Be(nameof(MySensor.Title));
+  }
+
+  #endregion
 }

Tests/ksqlDB.RestApi.Client.Tests/KSql/Query/KSqlQueryGeneratorTests.cs

@@ -27,6 +27,7 @@ public class KSqlQueryGeneratorTests : TestBase
   readonly string streamName = nameof(Location) + "s";
 
   private KSqlDBContextOptions contextOptions = null!;
+  private ModelBuilder modelBuilder = null!;
   private QueryContext queryContext = null!;
 
   [SetUp]
@@ -35,7 +36,11 @@ public override void TestInitialize()
     base.TestInitialize();
 
     contextOptions = new KSqlDBContextOptions(TestParameters.KsqlDbUrl);
-    queryContext = new QueryContext();
+    modelBuilder = new ModelBuilder();
+    queryContext = new QueryContext()
+    {
+      ModelBuilder = modelBuilder
+    };
     ClassUnderTest = new KSqlQueryGenerator(contextOptions);
   }
 
@@ -93,7 +98,6 @@ public void BuildKSql_ModelBuilder_HasColumnNameOverride()
   {
     //Arrange
     string idColumnName = "Id";
-    ModelBuilder modelBuilder = new ModelBuilder();
     modelBuilder.Entity<MySensor>()
       .Property(c => c.SensorId2)
       .HasColumnName(idColumnName);
@@ -103,11 +107,6 @@ public void BuildKSql_ModelBuilder_HasColumnNameOverride()
       .Where(c => c.SensorId2 == "1")
       .Select(c => c.SensorId2);
 
-    queryContext = new QueryContext()
-    {
-      ModelBuilder = modelBuilder
-    };
-
     //Act
     var ksql = ClassUnderTest.BuildKSql(query.Expression, queryContext);
 
@@ -133,7 +132,6 @@ public void BuildKSql_ModelBuilder_HasColumnNameOverride_ForPropertyInBaseClass(
   {
     //Arrange
     string idColumnName = "SensorId";
-    ModelBuilder modelBuilder = new ModelBuilder();
     modelBuilder.Entity<Derived>()
       .Property(c => c.Id)
       .HasColumnName(idColumnName);
@@ -142,12 +140,7 @@ public void BuildKSql_ModelBuilder_HasColumnNameOverride_ForPropertyInBaseClass(
       .CreatePushQuery<Derived>()
       .Where(c => c.Id == 1)
       .Select(c => c.Id);
-
-    queryContext = new QueryContext()
-    {
-      ModelBuilder = modelBuilder
-    };
-
+    
     //Act
     var ksql = ClassUnderTest.BuildKSql(query.Expression, queryContext);