Removed TenantCreatedEto handling

Removed TenantCreatedEto handling from
- Administration
- IdentityService

services/administration/src/EShopOnAbp.AdministrationService.HttpApi.Host/DbMigrations/AdministrationServiceDatabaseMigrationEventHandler.cs

@@ -1,10 +1,9 @@
 using EShopOnAbp.AdministrationService.EntityFrameworkCore;
 using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations.EfCore;
-using Microsoft.Extensions.Logging;
+using Serilog;
 using System;
 using System.Linq;
 using System.Threading.Tasks;
-using Serilog;
 using Volo.Abp.Authorization.Permissions;
 using Volo.Abp.Data;
 using Volo.Abp.DistributedLocking;
@@ -17,7 +16,6 @@ namespace EShopOnAbp.AdministrationService.DbMigrations
 {
     public class AdministrationServiceDatabaseMigrationEventHandler
         : DatabaseEfCoreMigrationEventHandler<AdministrationServiceDbContext>,
-            IDistributedEventHandler<TenantCreatedEto>,
             IDistributedEventHandler<ApplyDatabaseMigrationsEto>
     {
         private readonly IPermissionDefinitionManager _permissionDefinitionManager;
@@ -70,20 +68,6 @@ namespace EShopOnAbp.AdministrationService.DbMigrations
             }
         }
 
-        public async Task HandleEventAsync(TenantCreatedEto eventData)
-        {
-            try
-            {
-                await MigrateDatabaseSchemaAsync(eventData.Id);
-                Logger.LogInformation("Starting AdministrationService DataSeeder...");
-                await SeedDataAsync(eventData.Id);
-            }
-            catch (Exception ex)
-            {
-                await HandleErrorTenantCreatedAsync(eventData, ex);
-            }
-        }
-
         private async Task SeedDataAsync(Guid? tenantId)
         {
             using (CurrentTenant.Change(tenantId))

services/identity/src/EShopOnAbp.IdentityService.HttpApi.Host/DbMigrations/IdentityServiceDatabaseMigrationEventHandler.cs

@@ -1,22 +1,20 @@
 using EShopOnAbp.IdentityService.EntityFrameworkCore;
+using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations.EfCore;
 using Serilog;
 using System;
-using System.Collections.Generic;
 using System.Threading.Tasks;
-using EShopOnAbp.Shared.Hosting.Microservices.DbMigrations.EfCore;
 using Volo.Abp.Data;
+using Volo.Abp.DistributedLocking;
 using Volo.Abp.EventBus.Distributed;
 using Volo.Abp.EventBus.Local;
 using Volo.Abp.Identity;
 using Volo.Abp.MultiTenancy;
 using Volo.Abp.Uow;
-using Volo.Abp.DistributedLocking;
 
 namespace EShopOnAbp.IdentityService.DbMigrations
 {
     public class IdentityServiceDatabaseMigrationEventHandler
         : DatabaseEfCoreMigrationEventHandler<IdentityServiceDbContext>,
-            IDistributedEventHandler<TenantCreatedEto>,
             IDistributedEventHandler<ApplyDatabaseMigrationsEto>
     {
         private readonly IIdentityDataSeeder _identityDataSeeder;
@@ -57,7 +55,7 @@ namespace EShopOnAbp.IdentityService.DbMigrations
                 await using (var handle = await DistributedLockProvider.TryAcquireAsync(DatabaseName))
                 {
                     Log.Information("IdentityService has acquired lock for db migration...");
-                    
+
                     if (handle != null)
                     {
                         Log.Information("IdentityService is migrating database...");
@@ -79,22 +77,6 @@ namespace EShopOnAbp.IdentityService.DbMigrations
             }
         }
 
-        public async Task HandleEventAsync(TenantCreatedEto eventData)
-        {
-            try
-            {
-                await MigrateDatabaseSchemaAsync(eventData.Id);
-                await SeedDataAsync(
-                    tenantId: eventData.Id,
-                    adminEmail: eventData.Properties.GetOrDefault(IdentityDataSeedContributor.AdminEmailPropertyName) ?? IdentityServiceDbProperties.DefaultAdminEmailAddress,
-                    adminPassword: eventData.Properties.GetOrDefault(IdentityDataSeedContributor.AdminPasswordPropertyName) ?? IdentityServiceDbProperties.DefaultAdminPassword
-                );
-            }
-            catch (Exception ex)
-            {
-                await HandleErrorTenantCreatedAsync(eventData, ex);
-            }
-        }
         private async Task SeedDataAsync(Guid? tenantId, string adminEmail, string adminPassword)
         {
             using (CurrentTenant.Change(tenantId))

shared/EShopOnAbp.Shared.Hosting.Microservices/DbMigrations/EfCore/DatabaseEfCoreMigrationEventHandler.cs

@@ -127,28 +127,6 @@ public abstract class DatabaseEfCoreMigrationEventHandler<TDbContext> : Database
         }
     }
 
-    protected virtual async Task HandleErrorTenantCreatedAsync(
-        TenantCreatedEto eventData,
-        Exception exception)
-    {
-        var tryCount = IncrementEventTryCount(eventData);
-        if (tryCount <= MaxEventTryCount)
-        {
-            Log.Warning(
-                $"Could not perform tenant created event. Re-queueing the operation. TenantId = {eventData.Id}, TenantName = {eventData.Name}.");
-            Logger.LogException(exception, LogLevel.Warning);
-
-            await Task.Delay(RandomHelper.GetRandom(5000, 15000));
-            await DistributedEventBus.PublishAsync(eventData);
-        }
-        else
-        {
-            Logger.LogError(
-                $"Could not perform tenant created event. Canceling the operation. TenantId = {eventData.Id}, TenantName = {eventData.Name}.");
-            Logger.LogException(exception);
-        }
-    }
-
     protected virtual async Task HandleErrorTenantConnectionStringUpdatedAsync(
         TenantConnectionStringUpdatedEto eventData,
         Exception exception)

shared/EShopOnAbp.Shared.Hosting.Microservices/DbMigrations/MongoDb/DatabaseMongoDbMigrationEventHandler.cs

@@ -140,28 +140,6 @@ public abstract class DatabaseMongoDbMigrationEventHandler<TDbContext> : Databas
         }
     }
 
-    protected virtual async Task HandleErrorTenantCreatedAsync(
-        TenantCreatedEto eventData,
-        Exception exception)
-    {
-        var tryCount = IncrementEventTryCount(eventData);
-        if (tryCount <= MaxEventTryCount)
-        {
-            Logger.LogWarning(
-                $"Could not perform tenant created event. Re-queueing the operation. TenantId = {eventData.Id}, TenantName = {eventData.Name}.");
-            Logger.LogException(exception, LogLevel.Warning);
-
-            await Task.Delay(RandomHelper.GetRandom(5000, 15000));
-            await DistributedEventBus.PublishAsync(eventData);
-        }
-        else
-        {
-            Logger.LogError(
-                $"Could not perform tenant created event. Canceling the operation. TenantId = {eventData.Id}, TenantName = {eventData.Name}.");
-            Logger.LogException(exception);
-        }
-    }
-
     protected virtual async Task HandleErrorTenantConnectionStringUpdatedAsync(
         TenantConnectionStringUpdatedEto eventData,
         Exception exception)