webzine/Webzine.Repository/DbCommentaireRepository.cs

namespace Webzine.Repository;

using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Logging;

using Webzine.EntitiesContext;
using Webzine.Entity;
using Webzine.Repository.Contracts;

/// <summary>
/// Classe qui implémente le repository pour les commentaires en utilisant une base de données.
/// </summary>
public class DbCommentaireRepository : ICommentaireRepository
{
    private readonly ILogger<DbCommentaireRepository> logger;
    private readonly WebzineDbContext context;

    /// <summary>
    /// Initialisation de <see cref="DbCommentaireRepository"/>.
    /// </summary>
    /// <param name="logger">Le service de journalisation.</param>
    /// <param name="context">Le contexte de base de données injecté.</param>
    public DbCommentaireRepository(ILogger<DbCommentaireRepository> logger, WebzineDbContext context)
    {
        this.logger = logger;
        this.context = context;
        this.logger.LogDebug("NLog injecté dans DbCommentaireRepository");
    }

    /// <inheritdoc/>
    public void Add(Commentaire commentaire)
    {
        try
        {
            this.context.Commentaires.Add(commentaire);
            this.context.SaveChanges();
            this.logger.LogDebug("Commentaire ajouté avec l'id : {Id}", commentaire.IdCommentaire);
        }
        catch (DbUpdateException dbex)
        {
            this.logger.LogError(dbex, "Erreur de base de données lors de l'ajout du commentaire de l'auteur : {Auteur}", commentaire?.Auteur);
            throw;
        }
        catch (Exception ex)
        {
            this.logger.LogError(ex, "Une erreur est survenue lors de l'ajout d'un commentaire.");
            throw new Exception("Une erreur est survenue lors de l'ajout du commentaire.", ex);
        }
    }

    /// <inheritdoc/>
    public void Delete(Commentaire commentaire)
    {
        try
        {
            this.context.Commentaires.Remove(commentaire);
            this.context.SaveChanges();
            this.logger.LogDebug("Le commentaire {IdCommentaire} a bien été supprimé", commentaire.IdCommentaire);
        }
        catch (DbUpdateException dbex)
        {
            this.logger.LogError(dbex, "Erreur de base de données lors de la suppression du commentaire : {Id}", commentaire.IdCommentaire);
            throw;
        }
        catch (Exception ex)
        {
            this.logger.LogError(ex, "Une erreur est survenue lors de la suppression du commentaire {Id}.", commentaire?.IdCommentaire);
            throw new Exception("Une erreur est survenue lors de la suppression du commentaire.", ex);
        }
    }

    /// <inheritdoc/>
    public Commentaire Find(int idCommentaire)
    {
        this.logger.LogDebug("Recherche du commentaire avec l'id : {Id}", idCommentaire);

        // On inclut le titre car il est souvent affiché avec le commentaire
        return this.context.Commentaires
            .Include(c => c.Titre)
            .SingleOrDefault(c => c.IdCommentaire == idCommentaire);
    }

    /// <inheritdoc/>
    public IEnumerable<Commentaire> FindAll()
    {
        var commentaires = this.context.Commentaires
            .AsNoTracking()
            .Include(c => c.Titre)
            .OrderByDescending(c => c.DateCreation);

        this.logger.LogDebug("La liste de commentaires a été récupérée.");
        return commentaires;
    }

    /// <inheritdoc/>
    public IEnumerable<Commentaire> FindCommentaires(int offset, int limit)
    {
        try
        {
            this.logger.LogDebug("Recherche paginée des commentaires (offset : {Offset}, limit : {Limit})", offset, limit);

            var commentaires = this.context.Commentaires
                .AsNoTracking()
                .Include(c => c.Titre)
                .OrderByDescending(c => c.DateCreation)
                .Skip(offset)
                .Take(limit);

            return commentaires;
        }
        catch (Exception ex)
        {
            this.logger.LogError(ex, "Erreur lors de la pagination des commentaires (offset : {Offset}, limit : {Limit})", offset, limit);
            throw new Exception("Une erreur est survenue lors de la pagination des commentaires.", ex);
        }
    }

    /// <inheritdoc/>
    public int Count()
    {
        try
        {
            this.logger.LogDebug("Comptage du nombre total de commentaires");
            return Enumerable.Count(this.context.Commentaires);
        }
        catch (Exception ex)
        {
            this.logger.LogError(ex, "Erreur lors du comptage des commentaires");
            throw new Exception("Une erreur est survenue lors du comptage des commentaires.", ex);
        }
    }
}