TestUserService.cs

using System.Security.Claims;
using Microsoft.AspNetCore.Http;
using Microsoft.Identity.Web;
using PrismaApi.Application.Interfaces.Repositories;
using PrismaApi.Application.Interfaces.Services;
using PrismaApi.Application.Mapping;
using PrismaApi.Domain.Dtos;

namespace PrismaApi.Test.Mocks;

public class TestUserService : IUserService
{
    private readonly IUserRepository _userRepository;

    public TestUserService(IUserRepository userRepository)
    {
        _userRepository = userRepository;
    }

    public async Task<List<UserOutgoingDto>> GetAllAsync()
    {
        var users = await _userRepository.GetAllAsync(withTracking: false);
        return users.ToOutgoingDtos();
    }

    public async Task<List<UserOutgoingDto>> SearchUsersAsync(string query)
    {
        var users = await _userRepository.GetAllAsync(withTracking: false);
        return users.Where(u => u.Name.Contains(query, StringComparison.OrdinalIgnoreCase)).ToOutgoingDtos();
    }


    public async Task<UserOutgoingDto> GetOrCreateUserFromContextAsync(HttpContext context)
    {
        var oid = context.User.Claims.FirstOrDefault(c => c.Type == ClaimConstants.Oid)?.Value
            ?? context.User.Claims.FirstOrDefault(c => c.Type == ClaimConstants.ObjectId)?.Value;

        if (string.IsNullOrEmpty(oid))
        {
            throw new InvalidOperationException("No Id found in Claims");
        }

        var name = context.User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Name)?.Value ?? "Test User";
        var user = await _userRepository.GetOrAddByIdAsync(new UserIncomingDto
        {
            Id = oid,
            Name = name
        });

        return user.ToOutgoingDto();
    }

    public async Task<List<UserOutgoingDto>> GetByIdsAsync(IEnumerable<string> ids)
    {
        var users = await _userRepository.GetByIdsAsync(ids, withTracking: false);
        return users.ToOutgoingDtos();
    }

    public async Task DeleteUserAsync(string userId, UserOutgoingDto user, CancellationToken ct = default)
    {
        // user is the user making the request, and only allows to delete itself.
        if (userId != user.Id)
        {
            throw new InvalidOperationException("Users can only delete themselves.");
        }
        await _userRepository.DeleteByIdsAsync([userId], ct: ct);
    }
}