Ends in:
2 DAYS
5 HRS
6 MIN
29 SEC
Ends in:
2 D
5 H
6 M
29 S
Open Closed

AsyncBackgroundJob injected repositories context has null tenant and null user #6417


User avatar
0
mariovh created
  • ABP Framework version: v6.0.0
  • UI Type:Blazor WASM
  • Database System: EF Core (SQL Server)

Hello, im using a AsyncBackgroundJob that need to query data from repositories and store after some operations that include generate a pdf document and send via email. The fact is that injected repositories are returning empty data, watching the context Tenant is null and User is null:

The job is enqueued in an appservice method. If i use the repository in the appservices that enqueues the job, gets and store data correctly. But if the same IRepository type is injected in the backgroundjob doesnt get the data probably because tenant and user are null.

What is the correct way to use an AsyncBackgroundJob, that do some queries and store data via IRepository in a multitenant app?

Thank you!


8 Answer(s)
  • User Avatar
    0
    maliming created
    Support Team Fullstack Developer

    hi

    You can add TenantId and UserId to job parameters.

    Then switch tenant and target user.

  • User Avatar
    0
    mariovh created

    Hi,

    I'm switching tenant, with ICurrentTenant, _currentTenant.Change(args.TenantId) and TenantId is correctly stored. But switching user with ICurrentPrincipalAccessor _currentPrincipalAccessor.Change(claims) where claims are generated like this:

    public static (Guid? userId, ClaimsPrincipal claims) GetUserAsync(Guid? userId, string name, string surname, string userName, string[] roleNames)
            {
                var claimsList = new List<Claim>
                {
                    new(AbpClaimTypes.UserId, userId.ToString()),
                    new(AbpClaimTypes.Name, name ?? "BackgroundJobUser"),
                    new(AbpClaimTypes.SurName, surname ?? "BackgroundJobUser"),
                    new(AbpClaimTypes.UserName, userName)
                };
                claimsList.AddRange(roleNames
                    .Select(_ => new Claim(AbpClaimTypes.Role, _)).ToList());
    
    
                return (userId, new ClaimsPrincipal(new ClaimsIdentity(claimsList)));
            }
    

    But CreatorId still null, what am I doing wrong?

  • User Avatar
    0
    maliming created
    Support Team Fullstack Developer

    hi

    Please share the full code of your BackgroundJob.

  • User Avatar
    0
    mariovh created

    hi, yes sure, basically sends an email and then inserts a domain entity and marks as processed, or sending email error if there's an error.

    public class CertificateEmailSendingJob : AsyncBackgroundJob<CertificateEmailSendingArgs>, ITransientDependency
        {
            private readonly IEmailSender _emailSender;
            private readonly ISettingProvider _settingsProvider;
            private readonly ICurrentTenant _currentTenant;
            private readonly IDonationCertificateRepository _certificateRepository;
            private readonly IUnitOfWorkManager _unitOfWorkManager;
            private readonly ICurrentPrincipalAccessor _currentPrincipalAccessor;
    
            public CertificateEmailSendingJob(IEmailSender emailSender, 
                ISettingProvider settingsProvider, 
                ICurrentTenant currentTenant, 
                IDonationCertificateRepository certificateRepository,
                IUnitOfWorkManager unitOfWorkManager,
                ICurrentPrincipalAccessor currentPrincipalAccessor)
            {
                _emailSender = emailSender;
                _settingsProvider = settingsProvider;
                _currentTenant = currentTenant;
                _certificateRepository = certificateRepository;
                _unitOfWorkManager = unitOfWorkManager;
                _currentPrincipalAccessor = currentPrincipalAccessor;
            }
    
            public override async Task ExecuteAsync(CertificateEmailSendingArgs args)
            {
                var claims = JobsExtensions.GetUserAsync(args.User.Id, args.User.Name, args.User.Surname, args.User.UserName, args.User.Roles);
    
                using (_currentPrincipalAccessor.Change(claims.claims))
                {
                    using (_currentTenant.Change(args.TenantId))
                    {
                        var from = await _settingsProvider.GetOrNullAsync(FundraisingSettingsConst.SmtpUserName);
    
                        using var memoryStream = new MemoryStream(args.CertificateFile);
                        var attachment = new Attachment(memoryStream, new ContentType(MediaTypeNames.Application.Pdf))
                        {
                            ContentDisposition = { FileName = args.CertificateFileName }
                        };
    
                        var message = new MailMessage(
                            from,
                            args.DonorEmail,
                            args.EmailSubject,
                            args.EmailBody);
    
                        message.Attachments.Add(attachment);
    
                        using var uow = _unitOfWorkManager.Begin(
                            requiresNew: true, isTransactional: false);
                       
                        try
                        {
                            await _emailSender.SendAsync(message);
                            var certificateRecord =
                                new DonationCertificate(Guid.NewGuid(), args.DonorId, args.LabelId,
                                    args.EmailTemplateLabelId,
                                    DonationCertificateStatus.Processed,
                                    args.Year,
                                    args.DonationId);
                            await _certificateRepository.InsertAsync(certificateRecord);
    
                        }
                        catch (Exception)
                        {
                            var certificateRecord =
                                new DonationCertificate(Guid.NewGuid(), args.DonorId, args.LabelId,
                                    args.EmailTemplateLabelId,
                                    DonationCertificateStatus.EmailSendingError,
                                    args.Year,
                                    args.DonationId);
                            await _certificateRepository.InsertAsync(certificateRecord);
                        }
                        
                        await uow.CompleteAsync();
                    }
                }
            }
        }
        public static class JobsExtensions
        {
            public static (Guid? userId, ClaimsPrincipal claims) GetUserAsync(Guid? userId, string name, string surname, string userName, string[] roleNames)
            {
                var claimsList = new List<Claim>
                {
                    new(AbpClaimTypes.UserId, userId.ToString()),
                    new(AbpClaimTypes.Name, name ?? "BackgroundJobUser"),
                    new(AbpClaimTypes.SurName, surname ?? "BackgroundJobUser"),
                    new(AbpClaimTypes.UserName, userName)
                };
                claimsList.AddRange(roleNames
                    .Select(_ => new Claim(AbpClaimTypes.Role, _)).ToList());
    
    
                return (userId, new ClaimsPrincipal(new ClaimsIdentity(claimsList)));
            }
        }
        
        public class CertificateEmailSendingArgs
        {
            public Guid? TenantId { get; set; }
            public string DonorEmail { get; set; }
            public string EmailSubject { get; set; }
            public string EmailBody { get; set; }
            public string CertificateFileName { get; set; }
            public byte[] CertificateFile { get; set; }
    
            public Guid DonorId { get; set; }
            public Guid LabelId { get; set; }
            public Guid EmailTemplateLabelId { get; set; }
            public int? Year { get; set; }
            public Guid? DonationId { get; set; }
    
            public UserArgs User { get; set; }
        }
        
        internal class DonationCertificateRepository: EfCoreRepository<FundraisingDbContext, DonationCertificate, Guid>,IDonationCertificateRepository
    

    I tried to switch order of change tenant and change user, same result, CreatorId is null. Something i should be doing wrong changing user, because values when i generate ClaimsPrincipal are correct.

  • User Avatar
    0
    maliming created
    Support Team Fullstack Developer

    hi

    Please inject ICurrentUser to check if there is Id value.

  • User Avatar
    0
    mariovh created

    hi,

    Id es correct, tenant id is null, wich is incorrect. I attach ICurrentUser inspection where you can see TenantId null and query to AbpUsers, where you can see that the user has TenantId not null.

    Thanks!

  • User Avatar
    0
    maliming created
    Support Team Fullstack Developer

    hi

    Can you prepare a project to reproduce this?

    Or you can set the CreatorId with your value.

    ObjectHelper.TrySetProperty(certificateRecord, x => x.CreatorId, () => YourId);
    await _certificateRepository.InsertAsync(certificateRecord);
    
  • User Avatar
    0
    mariovh created

    hello,

    i tried this

    ObjectHelper.TrySetProperty(certificateRecord, x => x.CreatorId, () => YourId);
    await _certificateRepository.InsertAsync(certificateRecord);
    

    And it works fine.

    Thank you!

Made with ❤️ on ABP v9.1.0-preview. Updated on December 02, 2024, 12:35