Add a workflow to a new tenant programmatically

[tcobbfis]

I'm currently trying to add a workflow to a tenant that I've created through code. I'm able to get the module to build and run, but the workflow is never added to the db after the tenant is created. Any advice? I'm using a simple workflow sample to avoid complexity.

    [HttpPost]
    [ValidateAntiForgeryToken]
    public async Task<IActionResult> AddInsContact(AddInsContactViewModel model)
    {
        if (!ModelState.IsValid) return View(model);

        var setupOptions = new TenantSetupOptions
        {
            AdminEmail = "[email protected]",
            AdminPassword = GetRequiredConfigValue("OrchardCore:OrchardCore_AutoSetup:Tenants:0:AdminPassword"),
            AdminUsername = "admin",
            DatabaseConnectionString = GetRequiredConfigValue("OrchardCore:ConnectionString"),
            DatabaseProvider = GetRequiredConfigValue("OrchardCore:DatabaseProvider"),
            DatabaseSchema = string.Empty,
            DatabaseTablePrefix = model.RequestUrlPrefix,
            FeatureProfile = string.Empty,
            RecipeName = "FWS.Sites.Contact",
            RequestUrlHost = string.Empty,
            RequestUrlPrefix = model.RequestUrlPrefix,
            ShellName = string.Empty,
            SiteName = model.SiteName,
            SiteTimeZone = "America/Chicago",
        };

        var shellSettings = new ShellSettings
        {
            Name = model.SiteName,
            RequestUrlHost = string.Empty,
            RequestUrlPrefix = model.RequestUrlPrefix,
            State = TenantState.Uninitialized,
        };

        shellSettings["OrchardCore_DataProtection_Azure:ConnectionString"] =
            GetRequiredConfigValue("OrchardCore:OrchardCore_DataProtection_Azure:ConnectionString");
        shellSettings["OrchardCore_Media_Azure:ConnectionString"] =
            GetRequiredConfigValue("OrchardCore:OrchardCore_Media_Azure:ConnectionString");
        shellSettings["OrchardCore_Media_Azure:ContainerName"] =
            GetRequiredConfigValue("OrchardCore:OrchardCore_Media_Azure:ContainerName");
        shellSettings["OrchardCore_Redis:Configuration"] =
            GetRequiredConfigValue("OrchardCore:OrchardCore_Redis:Configuration");

        var setupContext = await GetSetupContextAsync(setupOptions, shellSettings).ConfigureAwait(false);
        await _setupService.SetupAsync(setupContext).ConfigureAwait(false);

        // Activate the tenant shell
        var tenantShell = await _shellHost.GetScopeAsync(shellSettings);

        using var scope = tenantShell.ServiceProvider.CreateScope();
        var session = scope.ServiceProvider.GetRequiredService<YesSql.ISession>();

        var workflowType = new WorkflowType
        {
            Name = "Contact Form Workflow",
            IsEnabled = true,
            IsSingleton = false,
            Activities = new List<ActivityRecord>
        {
            new ActivityRecord
            {
                ActivityId = "1",
                Name = "HttpRequestEvent",
                Properties = new JsonObject
                {
                    ["HttpMethods"] = "POST",
                    ["Path"] = "/contact/submit",
                },
            },
            new ActivityRecord
            {
                ActivityId = "2",
                Name = "LogMessageTask",
                Properties = new JsonObject
                {
                    ["Message"] = "Contact form submitted successfully.",
                    ["LogLevel"] = "Information",
                },
            },
        },
            Transitions = new List<Transition>
            {
                new Transition
                {
                    SourceActivityId = "1",
                    DestinationActivityId = "2",
                },
            },
        };

        await session.SaveAsync(workflowType);
        await session.FlushAsync();

        return RedirectToAction("Success");
    }

[weirdyang]

I had the same problem, so what I did was move it to a ModularTenantEvents and used ShellScope.AddDeferredTask, perhaps you can just try using ShellScope.AddDeferredTask

[tcobbfis]

I'm using a recipe for the workflow, but I really want to be able to pull the new user info from the model. Tried using the deferred task, but the new user doesn't show in the new tenant.

    [HttpPost]
    [ValidateAntiForgeryToken]
    public async Task<IActionResult> AddInsContact(AddInsContactViewModel model)
    {
        if (!ModelState.IsValid) return View(model);

        var setupOptions = new TenantSetupOptions
        {
            AdminEmail = "[email protected]",
            AdminPassword = GetRequiredConfigValue("OrchardCore:OrchardCore_AutoSetup:Tenants:0:AdminPassword"),
            AdminUsername = "admin",
            DatabaseConnectionString = GetRequiredConfigValue("OrchardCore:ConnectionString"),
            DatabaseProvider = GetRequiredConfigValue("OrchardCore:DatabaseProvider"),
            DatabaseSchema = string.Empty,
            DatabaseTablePrefix = model.RequestUrlPrefix,
            FeatureProfile = string.Empty,
            RecipeName = "Contact",
            RequestUrlHost = string.Empty,
            RequestUrlPrefix = model.RequestUrlPrefix,
            ShellName = string.Empty,
            SiteName = model.SiteName,
            SiteTimeZone = "America/Chicago",
        };

        var shellSettings = new ShellSettings
        {
            Name = model.SiteName,
            RequestUrlHost = string.Empty,
            RequestUrlPrefix = model.RequestUrlPrefix,
            State = TenantState.Uninitialized,
        };

        shellSettings["OrchardCore_DataProtection_Azure:ConnectionString"] =
            GetRequiredConfigValue("OrchardCore:OrchardCore_DataProtection_Azure:ConnectionString");
        shellSettings["OrchardCore_Media_Azure:ConnectionString"] =
            GetRequiredConfigValue("OrchardCore:OrchardCore_Media_Azure:ConnectionString");
        shellSettings["OrchardCore_Media_Azure:ContainerName"] =
            GetRequiredConfigValue("OrchardCore:OrchardCore_Media_Azure:ContainerName");
        shellSettings["OrchardCore_Redis:Configuration"] =
            GetRequiredConfigValue("OrchardCore:OrchardCore_Redis:Configuration");

        try
        {
            var setupContext = await GetSetupContextAsync(setupOptions, shellSettings).ConfigureAwait(false);
            await _setupService.SetupAsync(setupContext).ConfigureAwait(false);

            await _shellHost.ReloadShellContextAsync(shellSettings);
            var tenantShell = await _shellHost.GetScopeAsync(shellSettings);

            using var scope = tenantShell.ServiceProvider.CreateScope();

            var recipeExecutor = scope.ServiceProvider.GetRequiredService<IRecipeExecutor>();
            var recipeHarvester = scope.ServiceProvider.GetRequiredService<IRecipeHarvester>();

            var recipes = await recipeHarvester.HarvestRecipesAsync();
            var workflowRecipe = recipes.FirstOrDefault(r => r.Name == "Contact.Workflow");

            if (workflowRecipe != null)
            {
                await recipeExecutor.ExecuteAsync(workflowRecipe.Name, workflowRecipe, new Dictionary<string, object>(), CancellationToken.None);
            }
            else
            {
                _logger.LogWarning("Workflow recipe 'Contact.Workflow' not found.");
            }

            // Schedule hardcoded user creation as a deferred task
            ShellScope.AddDeferredTask(async deferredScope =>
            {
                var userManager = deferredScope.ServiceProvider.GetRequiredService<UserManager<IUser>>();

                var newUser = new User
                {
                    UserName = "newuser",
                    Email = "[email protected]",
                    EmailConfirmed = true,
                };

                var createResult = await userManager.CreateAsync(newUser, "UserPassword123!");

                if (createResult.Succeeded)
                {
                    await userManager.AddToRoleAsync(newUser, "Administrator");
                    _logger.LogInformation("Deferred: New user 'newuser' created successfully.");
                }
                else
                {
                    foreach (var error in createResult.Errors)
                    {
                        _logger.LogError("Deferred: Error creating user: {Error}", error.Description);
                    }
                }
            });
        }
        catch (Exception e)
        {
            _logger.LogError(e, "Tenant setup failed.");
            return StatusCode(500, "Tenant setup failed. Please check the logs.");
        }

        return RedirectToAction("Success");
    }
    

[weirdyang]

Likely because your ShellScope is the scope handling the request. Was the user created in the default tenant? maybe something like this will wokr?

            ShellScope.AddDeferredTask(async deferredScope =>
            {
                IShellHost tenantHost = deferredScope.ServiceProvider.GetRequiredService<IShellHost>();
                await tenantHost.InitializeAsync();
                ShellScope tenantscope = await tenantHost.GetScopeAsync("TenantName");
                UserManager<IUser> users = deferredScope.ServiceProvider.GetRequiredService<UserManager<IUser>>();
                ....
            });

[tcobbfis]

you were correct.

ShellScope.AddDeferredTask(async deferredScope =>
{
    try
    {
        var tenantHost = deferredScope.ServiceProvider.GetRequiredService<IShellHost>();
        var tenantScope = await tenantHost.GetScopeAsync(shellSettingsForTask);

        using var scope = tenantScope.ServiceProvider.CreateScope();

        var userManager = scope.ServiceProvider.GetRequiredService<UserManager<IUser>>();
        var roleManager = scope.ServiceProvider.GetRequiredService<RoleManager<IRole>>();
   ...