[ksqlDB.RestApi.Client]: added PseudoColumnNameValidator #96

Author: tomasfabian

ksqlDb.RestApi.Client/FluentAPI/Builders/FieldTypeBuilder.cs

@@ -1,4 +1,5 @@
-using System.Linq.Expressions;
+using ksqlDB.RestApi.Client.Infrastructure.Extensions;
+using ksqlDB.RestApi.Client.KSql.RestApi.Validation;
 using ksqlDb.RestApi.Client.Metadata;
 
 namespace ksqlDb.RestApi.Client.FluentAPI.Builders
@@ -68,8 +69,15 @@ public IFieldTypeBuilder<TProperty> AsStruct()
       return this;
     }
 
+    private readonly PseudoColumnValidator pseudoColumnValidator = new();
+
     public IFieldTypeBuilder<TProperty> AsPseudoColumn()
     {
+      var columnName = fieldMetadata.ColumnName ?? fieldMetadata.MemberInfo.GetMemberName(default(EntityMetadata?));
+
+      if (!pseudoColumnValidator.IsValid(columnName))
+        throw new InvalidOperationException($"{columnName} is not a valid pseudocolumn name");
+
       fieldMetadata.IsPseudoColumn = true;
       return this;
     }

ksqlDb.RestApi.Client/KSql/RestApi/Validation/PseudoColumnValidator.cs

@@ -0,0 +1,21 @@
+using ksqlDb.RestApi.Client.KSql.RestApi.Parsers;
+using ksqlDB.RestApi.Client.Infrastructure.Extensions;
+
+namespace ksqlDB.RestApi.Client.KSql.RestApi.Validation
+{
+  internal class PseudoColumnValidator
+  {
+    private readonly string[] allowedPseudoColumnNames =
+    [
+      "Headers".ToUpper(),
+      nameof(SystemColumns.ROWOFFSET).ToUpper(),
+      nameof(SystemColumns.ROWPARTITION).ToUpper(),
+      nameof(SystemColumns.ROWTIME).ToUpper()
+    ];
+
+    internal bool IsValid(string columnName)
+    {
+      return columnName.ToUpper().IsOneOfFollowing(allowedPseudoColumnNames);
+    }
+  }
+}