using Dpz.Core.Service.Mediator.Features.Account.Internal;

namespace Dpz.Core.Service.Mediator.Features.Account.Queries;

public class GetUserInfoHandler(
    IMapper mapper,
    IRepository<User> userRepository,
    IRepository<UserExtendedInfo> userExtendedInfoRepository
) : IRequestHandler<GetUserInfoRequest, VmUserInfo?>
{
    public async ValueTask<VmUserInfo?> Handle(
        GetUserInfoRequest request,
        CancellationToken cancellationToken
    )
    {
        if (string.IsNullOrWhiteSpace(request.Account) && string.IsNullOrWhiteSpace(request.Name))
        {
            return null;
        }

        User? user = null;
        if (!string.IsNullOrWhiteSpace(request.Account))
        {
            user = await AccountRepositoryHelper.GetUserAsync(
                userRepository,
                request.Account,
                cancellationToken
            );
        }
        else if (!string.IsNullOrWhiteSpace(request.Name))
        {
            user = await userRepository
                .SearchFor(x => x.Name == request.Name)
                .SingleOrDefaultAsync(cancellationToken: cancellationToken);
        }

        if (user == null)
        {
            return null;
        }
        var userInfo = mapper.Map<VmUserInfo>(user.GetUserInfo());

        var extendedInfo = await userExtendedInfoRepository
            .SearchFor(x => x.Id == userInfo.Id)
            .SingleOrDefaultAsync(cancellationToken: cancellationToken);
        userInfo.Email = extendedInfo?.Email ?? "";
        userInfo.EmailVerified = extendedInfo?.EmailVerified ?? false;
        // 从DB获取用户信息是没有SessionId的
        // SessionId 从这里初始化
        userInfo.SessionId = Guid.NewGuid().ToString("N");
        return userInfo;
    }
}