Commit test files

Author: platyscript

src/DbApiBuilderEntityGenerator.Core/CodeGenerator.cs

@@ -0,0 +1,150 @@
+using System;
+using DbApiBuilderEntityGenerator.Core.Extensions;
+using DbApiBuilderEntityGenerator.Core.Options;
+using Microsoft.EntityFrameworkCore.Design;
+using Microsoft.EntityFrameworkCore.Scaffolding;
+using Microsoft.EntityFrameworkCore.Scaffolding.Metadata;
+using Microsoft.EntityFrameworkCore.Storage;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+
+namespace DbApiBuilderEntityGenerator.Core;
+
+public class CodeGenerator : ICodeGenerator
+{
+  private readonly ILoggerFactory _loggerFactory;
+  private readonly ILogger _logger;
+  private readonly ModelGenerator _modelGenerator;
+
+  public CodeGenerator(ILoggerFactory loggerFactory)
+  {
+    _loggerFactory = loggerFactory;
+    _logger = loggerFactory.CreateLogger<CodeGenerator>();
+    _modelGenerator = new ModelGenerator(loggerFactory);
+    // _synchronizer = new SourceSynchronizer(loggerFactory);
+  }
+
+  public GeneratorOptions Options { get; set; } = null!;
+  public bool Generate(GeneratorOptions options)
+  {
+    Options = options ?? throw new ArgumentNullException(nameof(options));
+
+    var databaseProviders = GetDatabaseProviders();
+    var databaseModel = GetDatabaseModel(databaseProviders.factory);
+    if (databaseModel == null)
+      throw new InvalidOperationException("Failed to create database model");
+
+    _logger.LogInformation("Loaded database model for: {databaseName}", databaseModel.DatabaseName);
+
+    var context = _modelGenerator.Generate(Options, databaseModel, databaseProviders.mapping);
+
+    return true;
+  }
+  private DatabaseModel GetDatabaseModel(IDatabaseModelFactory factory)
+  {
+    _logger.LogInformation("Loading database model ...");
+
+
+    var connectionString = ResolveConnectionString(Options.ConnectionString, Options.UserSecretsId, Options.ConnectionName);
+    if (string.IsNullOrEmpty(connectionString))
+      throw new InvalidOperationException("Could not find connection string.");
+
+    var options = new DatabaseModelFactoryOptions(Options.Tables, Options.Schemas);
+
+    return factory.Create(connectionString, options);
+  }
+
+  private static string? ResolveConnectionString(string? connectionString,
+   string? userSecretsId,
+   string? connectionName)
+  {
+    if (connectionString.HasValue())
+      return connectionString;
+
+    if (userSecretsId.HasValue() && connectionName.HasValue())
+    {
+      var secretsStore = new SecretsStore(userSecretsId);
+      if (secretsStore.ContainsKey(connectionName))
+        return secretsStore[connectionName];
+    }
+
+    throw new InvalidOperationException("Could not find connection string.");
+  }
+
+  private (IDatabaseModelFactory factory, IRelationalTypeMappingSource mapping) GetDatabaseProviders()
+  {
+    var provider = Options.Provider;
+
+    _logger.LogDebug("Creating database model factory for: {provider}", provider);
+
+    // start a new service container to create the database model factory
+    var services = new ServiceCollection()
+        .AddSingleton(_loggerFactory)
+        .AddEntityFrameworkDesignTimeServices();
+
+    switch (provider)
+    {
+      case DatabaseProviders.SqlServer:
+        ConfigureSqlServerServices(services);
+        break;
+      case DatabaseProviders.PostgreSQL:
+        ConfigurePostgresServices(services);
+        break;
+      case DatabaseProviders.MySQL:
+        ConfigureMySqlServices(services);
+        break;
+      case DatabaseProviders.Sqlite:
+        ConfigureSqliteServices(services);
+        break;
+      case DatabaseProviders.Oracle:
+        ConfigureOracleServices(services);
+        break;
+      default:
+        throw new NotSupportedException($"The specified provider '{provider}' is not supported.");
+    }
+
+    var serviceProvider = services
+        .BuildServiceProvider();
+
+    var databaseModelFactory = serviceProvider
+        .GetRequiredService<IDatabaseModelFactory>();
+
+    var typeMappingSource = serviceProvider
+        .GetRequiredService<IRelationalTypeMappingSource>();
+
+    return (databaseModelFactory, typeMappingSource);
+  }
+  private static void ConfigureMySqlServices(IServiceCollection services)
+  {
+    var designTimeServices = new Pomelo.EntityFrameworkCore.MySql.Design.Internal.MySqlDesignTimeServices();
+    designTimeServices.ConfigureDesignTimeServices(services);
+    services.AddEntityFrameworkMySqlNetTopologySuite();
+  }
+
+  private static void ConfigurePostgresServices(IServiceCollection services)
+  {
+    var designTimeServices = new Npgsql.EntityFrameworkCore.PostgreSQL.Design.Internal.NpgsqlDesignTimeServices();
+    designTimeServices.ConfigureDesignTimeServices(services);
+    services.AddEntityFrameworkNpgsqlNetTopologySuite();
+  }
+
+  private static void ConfigureSqlServerServices(IServiceCollection services)
+  {
+    var designTimeServices = new Microsoft.EntityFrameworkCore.SqlServer.Design.Internal.SqlServerDesignTimeServices();
+    designTimeServices.ConfigureDesignTimeServices(services);
+    services.AddEntityFrameworkSqlServerNetTopologySuite();
+  }
+
+  private static void ConfigureSqliteServices(IServiceCollection services)
+  {
+    var designTimeServices = new Microsoft.EntityFrameworkCore.Sqlite.Design.Internal.SqliteDesignTimeServices();
+    designTimeServices.ConfigureDesignTimeServices(services);
+    services.AddEntityFrameworkSqliteNetTopologySuite();
+  }
+
+  private static void ConfigureOracleServices(IServiceCollection services)
+  {
+    var designTimeServices = new Oracle.EntityFrameworkCore.Design.Internal.OracleDesignTimeServices();
+    designTimeServices.ConfigureDesignTimeServices(services);
+  }
+}

src/DbApiBuilderEntityGenerator.Core/DbApiBuilderEntityGenerator.Core.csproj

@@ -24,6 +24,8 @@
     <PackageReference Include="YamlDotNet" Version="16.3.0" />
   </ItemGroup>
 <ItemGroup>
+  <Folder Include="Metadata\" />
+  <Folder Include="Metadata\Generation\" />
   <Folder Include="Serialization\" />
 </ItemGroup>
 </Project>

src/DbApiBuilderEntityGenerator.Core/Extensions/EnumerableExtensions.cs

@@ -0,0 +1,45 @@
+using System;
+
+namespace DbApiBuilderEntityGenerator.Core.Extensions;
+
+/// <summary>
+/// Provides extension methods for <see cref="IEnumerable{T}"/> to assist with string formatting and conversion.
+/// </summary>
+public static partial class EnumerableExtensions
+{
+  /// <summary>
+  /// Concatenates the members of a sequence, using the specified delimiter between each member, and returns the resulting string.
+  /// </summary>
+  /// <typeparam name="T">
+  /// The type of the elements in the sequence.
+  /// </typeparam>
+  /// <param name="values">
+  /// The sequence of values to concatenate. Each value will be converted to a string using its <c>ToString()</c> method.
+  /// </param>
+  /// <param name="delimiter">
+  /// The string to use as a delimiter. If <c>null</c>, a comma (",") is used by default.
+  /// </param>
+  /// <returns>
+  /// A string that consists of the elements in <paramref name="values"/> delimited by the <paramref name="delimiter"/> string.
+  /// If <paramref name="values"/> is empty, returns <see cref="string.Empty"/>.
+  /// </returns>
+  public static string ToDelimitedString<T>(this IEnumerable<T?> values, string? delimiter = ",")
+      => string.Join(delimiter ?? ",", values);
+
+  /// <summary>
+  /// Concatenates the members of a sequence of strings, using the specified delimiter between each member, and returns the resulting string.
+  /// </summary>
+  /// <param name="values">
+  /// The sequence of string values to concatenate. <c>null</c> values are treated as empty strings.
+  /// </param>
+  /// <param name="delimiter">
+  /// The string to use as a delimiter. If <c>null</c>, a comma (",") is used by default.
+  /// </param>
+  /// <returns>
+  /// A string that consists of the elements in <paramref name="values"/> delimited by the <paramref name="delimiter"/> string.
+  /// If <paramref name="values"/> is empty, returns <see cref="string.Empty"/>.
+  /// </returns>
+  public static string ToDelimitedString(this IEnumerable<string?> values, string? delimiter = ",")
+      => string.Join(delimiter ?? ",", values);
+
+}

src/DbApiBuilderEntityGenerator.Core/ICodeGenerator.cs

@@ -0,0 +1,9 @@
+using System;
+using DbApiBuilderEntityGenerator.Core.Options;
+
+namespace DbApiBuilderEntityGenerator.Core;
+
+public interface ICodeGenerator
+{
+  bool Generate(GeneratorOptions options);
+}

src/DbApiBuilderEntityGenerator.Core/Metadata/Generation/Cardinality.cs

@@ -0,0 +1,9 @@
+namespace DbApiBuilderEntityGenerator.Core.Metadata.Generation;
+
+public enum Cardinality
+{
+  ZeroOrOne,
+  One,
+  Many
+
+}