7 Commits

85 changed files with 617 additions and 6182 deletions
@@ -1,7 +0,0 @@
namespace PyroFetes.DTO.Login.Request;
public class ConnectLoginDto
{
public string? Username { get; set; }
public string? Password { get; set; }
}
@@ -1,8 +0,0 @@
namespace PyroFetes.DTO.Login.Request;
public class CreateLoginDto
{
public string? Username { get; set; }
public string? FullName { get; set; }
public string? Password { get; set; }
}
@@ -1,9 +0,0 @@
namespace PyroFetes.DTO.Login.Request;
public class UpdateLoginDto
{
public int Id { get; set; }
public string? Username { get; set; }
public string? FullName { get; set; }
public string? Password { get; set; }
}
@@ -1,6 +0,0 @@
namespace PyroFetes.DTO.Login.Response;
public class GetLoginConnectDto
{
public string? Token { get; set; }
}
@@ -1,10 +0,0 @@
namespace PyroFetes.DTO.Login.Response;
public class GetLoginDto
{
public int Id { get; set; }
public string? Username { get; set; }
public string? FullName { get; set; }
public string? Password { get; set; }
public string? Salt { get; set; }
}
@@ -6,7 +6,7 @@ namespace PyroFetes.DTO.Product.Request
public class CreateProductDto public class CreateProductDto
{ {
// Référence interne du produit // Référence interne du produit
public int References { get; set; } public string? Reference { get; set; }
// Nom du produit // Nom du produit
public string? Name { get; set; } public string? Name { get; set; }
@@ -15,10 +15,10 @@ namespace PyroFetes.DTO.Product.Request
public decimal Duration { get; set; } public decimal Duration { get; set; }
// Calibre du produit // Calibre du produit
public decimal Caliber { get; set; } public int Caliber { get; set; }
// Numéro dhomologation // Numéro dhomologation
public int ApprovalNumber { get; set; } public string? ApprovalNumber { get; set; }
// Poids du produit // Poids du produit
public decimal Weight { get; set; } public decimal Weight { get; set; }
@@ -9,7 +9,7 @@ namespace PyroFetes.DTO.Product.Request
public int Id { get; set; } public int Id { get; set; }
// Référence interne du produit // Référence interne du produit
public int References { get; set; } public string? Reference { get; set; }
// Nom du produit // Nom du produit
public string? Name { get; set; } public string? Name { get; set; }
@@ -18,10 +18,10 @@ namespace PyroFetes.DTO.Product.Request
public decimal Duration { get; set; } public decimal Duration { get; set; }
// Calibre du produit // Calibre du produit
public decimal Caliber { get; set; } public int Caliber { get; set; }
// Numéro dhomologation // Numéro dhomologation
public int ApprovalNumber { get; set; } public string? ApprovalNumber { get; set; }
// Poids du produit // Poids du produit
public decimal Weight { get; set; } public decimal Weight { get; set; }
@@ -10,7 +10,7 @@ namespace PyroFetes.DTO.Product.Response
public int Id { get; set; } public int Id { get; set; }
// Référence interne du produit // Référence interne du produit
public int Reference { get; set; } public string? Reference { get; set; }
// Nom du produit // Nom du produit
public string? Name { get; set; } public string? Name { get; set; }
@@ -19,10 +19,10 @@ namespace PyroFetes.DTO.Product.Response
public decimal Duration { get; set; } public decimal Duration { get; set; }
// Calibre du produit // Calibre du produit
public decimal Caliber { get; set; } public int Caliber { get; set; }
// Numéro dhomologation // Numéro dhomologation
public int ApprovalNumber { get; set; } public string? ApprovalNumber { get; set; }
// Poids du produit // Poids du produit
public decimal Weight { get; set; } public decimal Weight { get; set; }
@@ -4,22 +4,22 @@
public class CreateSupplierDto public class CreateSupplierDto
{ {
// Nom du fournisseur // Nom du fournisseur
public string Name { get; set; } public string? Name { get; set; }
// Email du fournisseur // Email du fournisseur
public string Email { get; set; } public string? Email { get; set; }
// Numéro de téléphone du fournisseur // Numéro de téléphone du fournisseur
public string PhoneNumber { get; set; } public string? PhoneNumber { get; set; }
// Adresse du fournisseur // Adresse du fournisseur
public string Adress { get; set; } public string? Adress { get; set; }
// Code postal de l'adresse // Code postal de l'adresse
public int ZipCode { get; set; } public string? ZipCode { get; set; }
// Ville de l'adresse // Ville de l'adresse
public string City { get; set; } public string? City { get; set; }
// Liste des produits fournis par ce fournisseur dans la classe SupplierProductPriceDto // Liste des produits fournis par ce fournisseur dans la classe SupplierProductPriceDto
public List<SupplierProductPriceDto>? Products { get; set; } public List<SupplierProductPriceDto>? Products { get; set; }
@@ -7,22 +7,22 @@
public int Id { get; set; } public int Id { get; set; }
// Nom du fournisseur // Nom du fournisseur
public string Name { get; set; } public string? Name { get; set; }
// Email du fournisseur // Email du fournisseur
public string Email { get; set; } public string? Email { get; set; }
// Numéro de téléphone du fournisseur // Numéro de téléphone du fournisseur
public string PhoneNumber { get; set; } public string? PhoneNumber { get; set; }
// Adresse du fournisseur // Adresse du fournisseur
public string Adress { get; set; } public string? Adress { get; set; }
// Code postal de l'adresse // Code postal de l'adresse
public int ZipCode { get; set; } public string? ZipCode { get; set; }
// Ville de l'adresse // Ville de l'adresse
public string City { get; set; } public string? City { get; set; }
// Liste des produits fournis par ce fournisseur relié à la classe SupplierProductPriceDto // Liste des produits fournis par ce fournisseur relié à la classe SupplierProductPriceDto
public List<SupplierProductPriceDto>? Products { get; set; } public List<SupplierProductPriceDto>? Products { get; set; }
@@ -9,22 +9,22 @@ namespace PyroFetes.DTO.Supplier.Response
public int Id { get; set; } public int Id { get; set; }
// Nom du fournisseur // Nom du fournisseur
public string Name { get; set; } public string? Name { get; set; }
// Email du fournisseur // Email du fournisseur
public string Email { get; set; } public string? Email { get; set; }
// Numéro de téléphone // Numéro de téléphone
public string PhoneNumber { get; set; } public string? PhoneNumber { get; set; }
// Adresse du fournisseur // Adresse du fournisseur
public string Adress { get; set; } public string? Adress { get; set; }
// Code postal // Code postal
public int ZipCode { get; set; } public string? ZipCode { get; set; }
// Ville // Ville
public string City { get; set; } public string? City { get; set; }
// Liste des produits fournis par la classe SupplierProductPriceDto // Liste des produits fournis par la classe SupplierProductPriceDto
public List<SupplierProductPriceDto> Products { get; set; } = new(); public List<SupplierProductPriceDto> Products { get; set; } = new();
@@ -4,7 +4,7 @@
public class CreateWarehouseDto public class CreateWarehouseDto
{ {
// Nom de l'entrepôt // Nom de l'entrepôt
public string Name { get; set; } public string? Name { get; set; }
// Poids maximal que l'entrepôt peut contenir // Poids maximal que l'entrepôt peut contenir
public int MaxWeight { get; set; } public int MaxWeight { get; set; }
@@ -16,13 +16,13 @@
public int MinWeight { get; set; } public int MinWeight { get; set; }
// Adresse de l'entrepôt // Adresse de l'entrepôt
public string Adress { get; set; } public string? Adress { get; set; }
// Code postal // Code postal
public int ZipCode { get; set; } public string? ZipCode { get; set; }
// Ville // Ville
public string City { get; set; } public string? City { get; set; }
// Liste des produits à stocker dans cet entrepôt venant de la classe en dessous // Liste des produits à stocker dans cet entrepôt venant de la classe en dessous
public List<CreateWarehouseProductDto>? Products { get; set; } public List<CreateWarehouseProductDto>? Products { get; set; }
@@ -7,7 +7,7 @@
public int Id { get; set; } public int Id { get; set; }
// Nom de l'entrepôt // Nom de l'entrepôt
public string Name { get; set; } public string? Name { get; set; }
// Poids maximal que l'entrepôt peut contenir // Poids maximal que l'entrepôt peut contenir
public int MaxWeight { get; set; } public int MaxWeight { get; set; }
@@ -19,13 +19,13 @@
public int MinWeight { get; set; } public int MinWeight { get; set; }
// Adresse de l'entrepôt // Adresse de l'entrepôt
public string Adress { get; set; } public string? Adress { get; set; }
// Code postal // Code postal
public int ZipCode { get; set; } public string? ZipCode { get; set; }
// Ville // Ville
public string City { get; set; } public string? City { get; set; }
// Liste des produits à mettre à jour dans cet entrepôt // Liste des produits à mettre à jour dans cet entrepôt
public List<UpdateWarehouseProductDto>? Products { get; set; } public List<UpdateWarehouseProductDto>? Products { get; set; }
@@ -7,7 +7,7 @@
public int Id { get; set; } public int Id { get; set; }
// Nom de l'entrepôt // Nom de l'entrepôt
public string Name { get; set; } public string? Name { get; set; }
// Poids maximal que l'entrepôt peut contenir // Poids maximal que l'entrepôt peut contenir
public int MaxWeight { get; set; } public int MaxWeight { get; set; }
@@ -19,13 +19,13 @@
public int MinWeight { get; set; } public int MinWeight { get; set; }
// Adresse de l'entrepôt // Adresse de l'entrepôt
public string Adress { get; set; } public string? Adress { get; set; }
// Code postal // Code postal
public int ZipCode { get; set; } public string? ZipCode { get; set; }
// Ville // Ville
public string City { get; set; } public string? City { get; set; }
// Liste des produits stockés dans l'entrepôt // Liste des produits stockés dans l'entrepôt
public List<WarehouseProductDto>? Products { get; set; } public List<WarehouseProductDto>? Products { get; set; }
@@ -4,32 +4,32 @@ using PyroFetes.DTO.Brand.Request;
namespace PyroFetes.Endpoints.Brand; namespace PyroFetes.Endpoints.Brand;
public class CreateBrandEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<CreateBrandDto, GetBrandDto> //Instanciation d'une connexion à la bdd dans un endpoint, utilise l'élément de requête CreateBrandDto et l'élement de réponse GetBrandDto public class CreateBrandEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<CreateBrandDto, GetBrandDto>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Post("/api/brands"); //Créer une marque Post("/brands");
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(CreateBrandDto req, CancellationToken ct) public override async Task HandleAsync(CreateBrandDto req, CancellationToken ct)
{ {
Models.Brand brand = new () //Création d'un nom rentré par l'utilisateur Models.Brand brand = new ()
{ {
Name = req.Name Name = req.Name
}; };
pyrofetesdbcontext.Brands.Add(brand); //Ajout de la marque à la bdd pyrofetesdbcontext.Brands.Add(brand);
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde de la marque dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
Console.WriteLine("Marque créé avec succès !"); Console.WriteLine("Marque créé avec succès !");
GetBrandDto responseDto = new () //Renvoie le nom GetBrandDto responseDto = new ()
{ {
Name = req.Name Name = req.Name
}; };
await Send.OkAsync(responseDto, ct); //Réponse au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -5,34 +5,34 @@ namespace PyroFetes.Endpoints.Brand;
public class DeleteBrandRequest public class DeleteBrandRequest
{ {
public int Id { get; set; } //Création d'un Id public int Id { get; set; }
} }
public class DeleteBrandEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<DeleteBrandRequest> //Instanciation d'une connexion à la bdd dans un endpoint, utilise l'élément de requête DeleteBrandDto. public class DeleteBrandEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<DeleteBrandRequest>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Delete("/api/brands/{@id}", x => new { x.Id }); //Supprime une marque Delete("/brands/{@id}", x => new { x.Id });
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(DeleteBrandRequest req, CancellationToken ct) public override async Task HandleAsync(DeleteBrandRequest req, CancellationToken ct)
{ {
Models.Brand? brandToDelete = await pyrofetesdbcontext //Récupère une marque dans la bdd et le stocke dans brandToDelete Models.Brand? brandToDelete = await pyrofetesdbcontext
.Brands //Recherche la couleur dans la table Colors .Brands
.SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct); //Recherche une couleur dont l'id correspond à req.Id .SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct);
if (brandToDelete == null) if (brandToDelete == null)
{ {
Console.WriteLine($"Aucune marque avec l'ID {req.Id} trouvé."); Console.WriteLine($"Aucune marque avec l'ID {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
pyrofetesdbcontext.Brands.Remove(brandToDelete); //Supprime la marque de la bdd pyrofetesdbcontext.Brands.Remove(brandToDelete);
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde de la marque dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
await Send.NoContentAsync(ct); //Renvoie une réponse réussite 204 await Send.NoContentAsync(ct);
} }
} }
@@ -8,21 +8,21 @@ public class GetAllBrandsEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpo
{ {
public override void Configure() public override void Configure()
{ {
Get("/api/brands"); //Endpoint qui affiche toutes les marques Get("/brands");
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(CancellationToken ct) public override async Task HandleAsync(CancellationToken ct)
{ {
List<GetBrandDto> responseDto = await pyrofetesdbcontext.Brands //Création d'une liste qui récupère toutes les marques dans la bdd List<GetBrandDto> responseDto = await pyrofetesdbcontext.Brands
.Select(a => new GetBrandDto //Sélectionne dans la liste chaque marque .Select(a => new GetBrandDto
{ {
Id = a.Id, //Affiche l'id Id = a.Id,
Name = a.Name, //Affiche le nom Name = a.Name,
} }
).ToListAsync(ct); //Retourne la liste de marque ).ToListAsync(ct);
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
+11 -11
View File
@@ -13,30 +13,30 @@ public class GetBrandEndpoint(PyroFetesDbContext pyrofetesdbcontext) :Endpoint<G
{ {
public override void Configure() public override void Configure()
{ {
Get("/api/brands/{@id}", x => new { x.Id }); //endpoint qui affiche la marque en fonction de l'id Get("/brands/{@id}", x => new { x.Id });
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(GetBrandRequest req, CancellationToken ct) public override async Task HandleAsync(GetBrandRequest req, CancellationToken ct)
{ {
Models.Brand? brand = await pyrofetesdbcontext //Récupère la table marque dans la bdd Models.Brand? brand = await pyrofetesdbcontext
.Brands .Brands
.SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct); //récupère l'id .SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct);
if (brand == null) if (brand == null)
{ {
Console.WriteLine($"Aucune marque avec l'ID {req.Id} trouvé."); Console.WriteLine($"Aucune marque avec l'ID {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
GetBrandDto responseDto = new() //renvoie l'id et le nom GetBrandDto responseDto = new()
{ {
Id = req.Id, //Affiche l'id Id = req.Id,
Name = brand.Name //Affiche le nom Name = brand.Name
}; };
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -8,27 +8,27 @@ public class UpdateBrandEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoi
{ {
public override void Configure() public override void Configure()
{ {
Put("/api/brands/{Id}"); //Met à jour la marque en fonction de l'id Put("/brands/{Id}");
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(UpdateBrandDto req, CancellationToken ct) public override async Task HandleAsync(UpdateBrandDto req, CancellationToken ct)
{ {
Models.Brand brand = new() //Met à jour la marque Models.Brand brand = new()
{ {
Name = req.Name Name = req.Name
}; };
pyrofetesdbcontext.Add(brand); //ajoute la marque dans la bdd pyrofetesdbcontext.Add(brand);
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde les changements await pyrofetesdbcontext.SaveChangesAsync(ct);
GetBrandDto response = new() //renvoie l'id et le nom GetBrandDto response = new()
{ {
Id = req.Id, Id = req.Id,
Name = req.Name Name = req.Name
}; };
await Send.OkAsync(response, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(response, ct);
} }
} }
@@ -4,32 +4,32 @@ using FastEndpoints;
namespace PyroFetes.Endpoints.Classification; namespace PyroFetes.Endpoints.Classification;
public class CreateClassificationEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<CreateClassificationDto, GetClassificationDto> //Instanciation d'une connexion à la bdd dans un endpoint, utilise l'élément de requête CreateClassificationDto et l'élement de réponse GetClassificationDto public class CreateClassificationEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<CreateClassificationDto, GetClassificationDto>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Post("/api/classifications"); //Créer une classification Post("/classifications");
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(CreateClassificationDto req, CancellationToken ct) public override async Task HandleAsync(CreateClassificationDto req, CancellationToken ct)
{ {
Models.Classification classification = new () //Création d'un label rentré par l'utilisateur Models.Classification classification = new ()
{ {
Label = req.Label Label = req.Label
}; };
pyrofetesdbcontext.Classifications.Add(classification); //Ajout de la classification à la bdd pyrofetesdbcontext.Classifications.Add(classification);
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde de la classification dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
Console.WriteLine("Classification créée avec succès !"); Console.WriteLine("Classification créée avec succès !");
GetClassificationDto responseDto = new () //Renvoie le label de la classification GetClassificationDto responseDto = new ()
{ {
Label = req.Label Label = req.Label
}; };
await Send.OkAsync(responseDto, ct); //Réponse au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -12,27 +12,27 @@ public class DeleteClassificationEndpoint(PyroFetesDbContext libraryDbContext) :
{ {
public override void Configure() public override void Configure()
{ {
Delete("/api/classifications/{@id}", x => new { x.Id }); //Supprime une classification en fonction de l'id Delete("/classifications/{@id}", x => new { x.Id });
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(DeleteClassificationRequest req, CancellationToken ct) public override async Task HandleAsync(DeleteClassificationRequest req, CancellationToken ct)
{ {
Models.Classification? classificationToDelete = await libraryDbContext //Récupère une classification dans la bdd et le stocke dans classificationToDelete Models.Classification? classificationToDelete = await libraryDbContext
.Classifications //Recherche la classification dans la table Classifications .Classifications
.SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct); //Recherche une classification dont l'id correspond à req.Id .SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct);
if (classificationToDelete == null) if (classificationToDelete == null)
{ {
Console.WriteLine($"Aucune classification avec l'ID {req.Id} trouvé."); Console.WriteLine($"Aucune classification avec l'ID {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
libraryDbContext.Classifications.Remove(classificationToDelete); //Supprime la classification dans la bdd libraryDbContext.Classifications.Remove(classificationToDelete);
await libraryDbContext.SaveChangesAsync(ct); //Sauvegarde de la classification dans la bdd await libraryDbContext.SaveChangesAsync(ct);
await Send.NoContentAsync(ct); //Renvoie une réponse réussite 204 await Send.NoContentAsync(ct);
} }
} }
@@ -8,21 +8,21 @@ public class GetAllClassificationsEndpoint(PyroFetesDbContext pyrofetesdbcontext
{ {
public override void Configure() public override void Configure()
{ {
Get("/api/classifications"); //Endpoint qui affiche toutes les classifications Get("/classifications");
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(CancellationToken ct) public override async Task HandleAsync(CancellationToken ct)
{ {
List<GetClassificationDto> responseDto = await pyrofetesdbcontext.Classifications //Création d'une liste qui récupère toutes les classifications dans la bdd List<GetClassificationDto> responseDto = await pyrofetesdbcontext.Classifications
.Select(a => new GetClassificationDto //Sélectionne dans la liste chaque classification .Select(a => new GetClassificationDto
{ {
Id = a.Id, //Récupère l'id Id = a.Id,
Label = a.Label, //Récupère le label Label = a.Label,
} }
).ToListAsync(ct); //Retourne la liste de classification ).ToListAsync(ct);
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -13,30 +13,30 @@ public class GetClassificationEndpoint(PyroFetesDbContext pyrofetesdbcontext) :E
{ {
public override void Configure() public override void Configure()
{ {
Get("/api/classifications/{@id}", x => new { x.Id }); //endpoint qui affiche la classification en fonction de l'id Get("/classifications/{@id}", x => new { x.Id });
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(GetClassificationRequest req, CancellationToken ct) public override async Task HandleAsync(GetClassificationRequest req, CancellationToken ct)
{ {
Models.Classification? classification = await pyrofetesdbcontext //Récupère la table marque dans la bdd Models.Classification? classification = await pyrofetesdbcontext
.Classifications .Classifications
.SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct); //récupère l'id .SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct);
if (classification == null) if (classification == null)
{ {
Console.WriteLine($"Aucune classification avec l'ID {req.Id} trouvé."); Console.WriteLine($"Aucune classification avec l'ID {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
GetClassificationDto responseDto = new() GetClassificationDto responseDto = new()
{ {
Id = req.Id, //Affiche l'id Id = req.Id,
Label = classification.Label //Affiche le nom Label = classification.Label
}; };
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -8,27 +8,27 @@ public class UpdateClassificationEndpoint(PyroFetesDbContext pyrofetesdbcontext)
{ {
public override void Configure() public override void Configure()
{ {
Put("/api/classifications"); //Met à jour la classification en fonction de l'id Put("/classifications");
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(UpdateClassificationDto req, CancellationToken ct) public override async Task HandleAsync(UpdateClassificationDto req, CancellationToken ct)
{ {
Models.Classification classification = new() //Met à jour la classification Models.Classification classification = new()
{ {
Label = req.Label Label = req.Label
}; };
pyrofetesdbcontext.Add(classification); //ajoute la classification dans la bdd pyrofetesdbcontext.Add(classification);
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde les changements await pyrofetesdbcontext.SaveChangesAsync(ct);
GetClassificationDto response = new() //renvoie l'id et le nom GetClassificationDto response = new()
{ {
Id = req.Id, Id = req.Id,
Label = req.Label Label = req.Label
}; };
await Send.OkAsync(response, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(response, ct);
} }
} }
@@ -9,13 +9,13 @@ public class CreateColorEndpoint(PyroFetesDbContext pyroFetesDbContext) : Endpoi
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure() //Configuration de l'endpoint
{ {
Post("Api/colors"); //Création d'un endpoint pour créer une couleur avec les données de CreateColorDto Post("/colors"); //Création d'un endpoint pour créer une couleur avec les données de CreateColorDto
AllowAnonymous(); //Laisser passer les requêtes non authentifiées AllowAnonymous(); //Laisser passer les requêtes non authentifiées
} }
public override async Task HandleAsync(CreateColorDto req, CancellationToken ct) //La méthode HandleAsync est appelée lorsqu'une requête est envoyée à l'endpoint public override async Task HandleAsync(CreateColorDto req, CancellationToken ct) //La méthode HandleAsync est appelée lorsqu'une requête est envoyée à l'endpoint
{ {
PyroFetes.Models.Color color = new() //Création d'un label rentré par l'utilisateur PyroFetes.Models.Color color = new()
{ {
Label = req.Label, Label = req.Label,
}; };
@@ -3,35 +3,35 @@ using Microsoft.EntityFrameworkCore;
namespace PyroFetes.Endpoints.Color; namespace PyroFetes.Endpoints.Color;
public class DeleteColorRequest //Création d'une classe DeleteColorRequest public class DeleteColorRequest
{ {
public int Id { get; set; } //Création d'un Id public int Id { get; set; }
} }
public class DeleteColorEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<DeleteColorRequest> //Instanciation d'une connexion à la bdd dans un endpoint, utilise l'élément de requête DeleteColorDto. public class DeleteColorEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<DeleteColorRequest>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Delete("Api/colors/{@id}", x => new { x.Id }); //endpoint qui supprime une couleur grâce à son id Delete("/colors/{@id}", x => new { x.Id });
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(DeleteColorRequest req, CancellationToken ct) //Méthode asynchrone qui traite la suppression de la couleur public override async Task HandleAsync(DeleteColorRequest req, CancellationToken ct)
{ {
Models.Color? colorToDelete = await pyrofetesdbcontext //Récupère une couleur dans la bdd et le stocke dans colorToDelete Models.Color? colorToDelete = await pyrofetesdbcontext
.Colors //Recherche la couleur dans la table Colors .Colors
.SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct); //Recherche une couleur dont l'id correspond à req.Id .SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct);
if (colorToDelete == null) //Si la couleur n'est pas trouvé if (colorToDelete == null)
{ {
Console.WriteLine($"Aucune couleur avec l'ID {req.Id} trouvé."); Console.WriteLine($"Aucune couleur avec l'ID {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
pyrofetesdbcontext.Colors.Remove(colorToDelete); //Supprime la couleur dans la bdd pyrofetesdbcontext.Colors.Remove(colorToDelete);
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde les changements effectués dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
await Send.NoContentAsync(ct); //Renvoie une réponse réussite 204 await Send.NoContentAsync(ct);
} }
} }
@@ -6,21 +6,21 @@ namespace PyroFetes.Endpoints.Color;
public class GetAllColorsEndpoint(PyroFetesDbContext pyrofetesdbcontext) : EndpointWithoutRequest<List<GetColorDto>> public class GetAllColorsEndpoint(PyroFetesDbContext pyrofetesdbcontext) : EndpointWithoutRequest<List<GetColorDto>>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Get("Api/colors"); //Endpoint qui affiche toutes les couleurs Get("/colors");
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(CancellationToken ct) public override async Task HandleAsync(CancellationToken ct)
{ {
List<GetColorDto> responseDto = await pyrofetesdbcontext.Colors //Création d'une liste qui récupère toutes les couleurs dans la bdd List<GetColorDto> responseDto = await pyrofetesdbcontext.Colors
.Select(a => new GetColorDto //Sélectionne dans la liste chaque couleur .Select(a => new GetColorDto
{ {
Id = a.Id, //Récupère l'id Id = a.Id,
Label = a.Label, //Récupère le label Label = a.Label,
} }
).ToListAsync(ct); //Retourne la liste de couleur ).ToListAsync(ct);
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
+16 -15
View File
@@ -11,30 +11,31 @@ public class GetColorRequest
public class GetColorEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<GetColorRequest, GetColorDto> public class GetColorEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<GetColorRequest, GetColorDto>
{ {
public override void Configure() public override void Configure()
{ {
Get("Api/colors/{@id}", x => new { x.Id}); //endpoint qui récupère une couleur grâce à son id Get("/colors/{@id}", x => new { x.Id});
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(GetColorRequest req, CancellationToken ct) //Méthode asynchrone qui traite la récupération de la couleur public override async Task HandleAsync(GetColorRequest req, CancellationToken ct)
{ {
Models.Color? color = await pyrofetesdbcontext //Récupère une couleur dans la bdd et le stocke dans color Models.Color? color = await pyrofetesdbcontext
.Colors //Recherche la couleur dans la table Colors .Colors
.SingleOrDefaultAsync(x => x.Id == req.Id, cancellationToken: ct); //Recherche une couleur dont l'id correspond à req.Id .SingleOrDefaultAsync(x => x.Id == req.Id, cancellationToken: ct);
if (color == null) //Si la couleur n'est pas trouvé if (color == null)
{ {
Console.WriteLine("Aucune couleur avec l'ID {req.Id} trouvé."); //Affiche aucune couleur avec l'id ... trouvé Console.WriteLine("Aucune couleur avec l'ID {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
GetColorDto responseDto = new() //Constuire l'objet de réponse pour retourner les informations à l'utilisateur GetColorDto responseDto = new()
{ {
Id = color.Id, //Affiche l'id lors de la réponse Id = color.Id,
Label = color.Label, //Affiche le label lors de la réponse Label = color.Label,
}; };
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -7,34 +7,34 @@ namespace PyroFetes.Endpoints.Color;
public class UpdateColorEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<UpdateColorDto, GetColorDto> public class UpdateColorEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<UpdateColorDto, GetColorDto>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Put("Api/colors/{@id}", x => new { x.Id }); //Création d'un endpoint qui modifie la couleur grâce à son id Put("/colors/{@id}", x => new { x.Id });
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(UpdateColorDto req, CancellationToken ct) public override async Task HandleAsync(UpdateColorDto req, CancellationToken ct)
{ {
Models.Color? colorToEdit = await pyrofetesdbcontext //Récupère une couleur dans la bdd et le stocke dans colorToEdit Models.Color? colorToEdit = await pyrofetesdbcontext
.Colors //Recherche la couleur dans la table Colors .Colors
.SingleOrDefaultAsync(x => x.Id == req.Id, cancellationToken: ct); //Recherche une couleur dont l'id correspond à req.Id .SingleOrDefaultAsync(x => x.Id == req.Id, cancellationToken: ct);
if (colorToEdit == null) //Si la couleur n'est pas trouvé if (colorToEdit == null)
{ {
Console.WriteLine("Aucune couleur avec l'id {req.Id} trouvé."); //Afficher aucune couleur avec l'id ... trouvé Console.WriteLine("Aucune couleur avec l'id {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
colorToEdit.Label = req.Label; //Modification du label colorToEdit.Label = req.Label;
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde les changements effectués dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
GetColorDto responseDto = new() //Constuire l'objet de réponse pour retourner l'id et le label de la nouvelle couleur GetColorDto responseDto = new()
{ {
Id = req.Id, //Affiche l'id Id = req.Id,
Label = req.Label, //Affiche le label Label = req.Label,
}; };
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
@@ -4,31 +4,31 @@ using FastEndpoints;
namespace PyroFetes.Endpoints.Effect; namespace PyroFetes.Endpoints.Effect;
public class CreateEffectEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<CreateEffectDto, GetEffectDto> //Instanciation d'une connexion à la bdd dans un endpoint, utilise l'élément de requête CreateEffectDto et l'élement de réponse GetEffectDto public class CreateEffectEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<CreateEffectDto, GetEffectDto>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Post("Api/effects"); //Créer un effet Post("/effects");
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(CreateEffectDto req, CancellationToken ct) public override async Task HandleAsync(CreateEffectDto req, CancellationToken ct)
{ {
Models.Effect effect = new() //Création d'un label rentré par l'utilisateur Models.Effect effect = new()
{ {
Label = req.Label, Label = req.Label,
}; };
pyrofetesdbcontext.Effects.Add(effect); //Ajoute effect à la bdd pyrofetesdbcontext.Effects.Add(effect);
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde les changements effectués dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
Console.WriteLine("Effect added"); //Affiche Effect added si réussi Console.WriteLine("Effect added");
GetEffectDto responseDto = new() //Constuire l'objet de réponse pour retourner id et label à l'utilisateur GetEffectDto responseDto = new()
{ {
Id = effect.Id, //Affiche l'id lors de la réponse Id = effect.Id,
Label = req.Label, //Affiche le label lors de la réponse Label = req.Label,
}; };
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -9,28 +9,28 @@ public class DeleteEffectRequest
} }
public class DeleteEffectEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<DeleteEffectRequest> public class DeleteEffectEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<DeleteEffectRequest>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Delete("Api/effects/{@id}", x => new { x.Id }); //Création d'un endpoint qui supprime un effet grâce à son id Delete("/effects/{@id}", x => new { x.Id });
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(DeleteEffectRequest req, CancellationToken ct) //Méthode asynchrone qui traite la suppression de l'effet public override async Task HandleAsync(DeleteEffectRequest req, CancellationToken ct)
{ {
Models.Effect? effectToDelete = await pyrofetesdbcontext //Récupère un effet dans la bdd et le stocke dans effectToDelete Models.Effect? effectToDelete = await pyrofetesdbcontext
.Effects //Recherche la couleur dans la table Colors .Effects
.SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct); //Recherche un effet dont l'id correspond à req.Id .SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct);
if (effectToDelete == null) //Si l'effet n'est pas trouvé if (effectToDelete == null)
{ {
Console.WriteLine($"Aucun effet avec l'ID {req.Id} trouvé."); //Afficher aucun effet avec l'id ... trouvé Console.WriteLine($"Aucun effet avec l'ID {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
pyrofetesdbcontext.Effects.Remove(effectToDelete); //Supprime l'effet dans la bdd pyrofetesdbcontext.Effects.Remove(effectToDelete);
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde les changements effectués dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
await Send.NoContentAsync(ct); //Renvoie une réponse réussite 204 await Send.NoContentAsync(ct);
} }
} }
@@ -6,22 +6,22 @@ namespace PyroFetes.Endpoints.Effect;
public class GetAllEffectsEndpoint(PyroFetesDbContext pyrofetesdbcontext) : EndpointWithoutRequest<List<GetEffectDto>> public class GetAllEffectsEndpoint(PyroFetesDbContext pyrofetesdbcontext) : EndpointWithoutRequest<List<GetEffectDto>>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Get("Api/effects"); //Création d'un endpoint pour récupérer tous les effets grâce à la liste Get("/effects");
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(CancellationToken ct) public override async Task HandleAsync(CancellationToken ct)
{ {
List<GetEffectDto> responseDto = await pyrofetesdbcontext.Effects //Création d'une liste qui récupère tous les effets de la bdd List<GetEffectDto> responseDto = await pyrofetesdbcontext.Effects
.Select(a => new GetEffectDto //Sélectionne dans la liste chaque effet .Select(a => new GetEffectDto
{ {
Id = a.Id, //Récupère l'id Id = a.Id,
Label = a.Label, //Récupère le label Label = a.Label,
} }
).ToListAsync(ct); //Retourne la liste de effet ).ToListAsync(ct);
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
+16 -16
View File
@@ -11,31 +11,31 @@ public class GetEffectRequest
public class GetEffectEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<GetEffectRequest, GetEffectDto> public class GetEffectEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<GetEffectRequest, GetEffectDto>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Get("Api/effects/{@id}", x => new { x.Id }); //Création d'un endpoint qui récupère un effet grâce à son id Get("/effects/{@id}", x => new { x.Id });
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(GetEffectRequest req, CancellationToken ct) //Méthode asynchrone qui traite la récupération de l'effet public override async Task HandleAsync(GetEffectRequest req, CancellationToken ct)
{ {
Models.Effect? effect = await pyrofetesdbcontext //Récupère un effet dans la bdd et le stocke dans effect Models.Effect? effect = await pyrofetesdbcontext
.Effects //Recherche l'effet dans la table Effects .Effects
.SingleOrDefaultAsync(x => x.Id == req.Id, cancellationToken: ct); //Recherche un effet dont l'id correspond à req.Id .SingleOrDefaultAsync(x => x.Id == req.Id, cancellationToken: ct);
if (effect == null) //Si l'effet n'est pas trouvé if (effect == null)
{ {
Console.WriteLine("Aucun effet avec l'ID {req.Id} trouvé."); //Afficher aucun effet avec l'id ... trouvé Console.WriteLine("Aucun effet avec l'ID {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
GetEffectDto responseDto = new() //Constuire l'objet de réponse pour retourner id et label à l'utilisateur GetEffectDto responseDto = new()
{ {
Id = effect.Id, //Affiche l'id lors de la réponse Id = effect.Id,
Label = effect.Label, //Affiche le label lors de la réponse Label = effect.Label,
}; };
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -7,32 +7,35 @@ namespace PyroFetes.Endpoints.Effect;
public class UpdateEffectEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<UpdateEffectDto, GetEffectDto> public class UpdateEffectEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<UpdateEffectDto, GetEffectDto>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Put("Api/effects/{@id}", x => new { x.Id }); //Création d'un endpoint qui modifie un effet grâce à son id Put("/effects/{@id}", x => new { x.Id });
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(UpdateEffectDto req, CancellationToken ct) public override async Task HandleAsync(UpdateEffectDto req, CancellationToken ct)
{ {
Models.Effect? effectToEdit = await pyrofetesdbcontext //Récupère un effet dans la bdd et le stocke dans effectToEdit Models.Effect? effectToEdit = await pyrofetesdbcontext
.Effects //Recherche l'effet dans la table Effects .Effects
.SingleOrDefaultAsync(x => x.Id == req.Id, cancellationToken: ct); //Recherche un effet dont l'id correspond à req.Id .SingleOrDefaultAsync(x => x.Id == req.Id, cancellationToken: ct);
if (effectToEdit == null) //Si l'effet n'est pas trouvé if (effectToEdit == null)
{ {
Console.WriteLine($"Aucun effet avec l'id {req.Id} trouvé."); //Afficher qu'aucun effet avec l'id ... n'a été trouvé Console.WriteLine("Aucun effet avec l'id {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
effectToEdit.Label = req.Label; //Modification du label de l'effet effectToEdit.Label = req.Label;
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde les changements effectués dans la base de données await pyrofetesdbcontext.SaveChangesAsync(ct);
GetEffectDto responseDto = new() //Construire l'objet de réponse pour retourner l'id et le label de l'effet modifié GetEffectDto responseDto = new()
{ {
Id = req.Id, //Inclut l'id dans la réponse Id = req.Id,
Label = req.Label, //Inclut le label dans la réponse Label = req.Label,
}; };
await Send.OkAsync(responseDto, ct); //Envoie une réponse 200 OK avec l'objet de réponse await Send.OkAsync(responseDto, ct);
} }
} }
@@ -1,44 +0,0 @@
using PyroFetes.DTO.Login.Request;
using PyroFetes.DTO.Login.Response;
using PasswordGenerator;
namespace PyroFetes.Endpoints.Login;
using FastEndpoints;
public class CreateLoginEndpoint(PyroFetesDbContext database) : Endpoint<CreateLoginDto, GetLoginDto> //Instanciation d'une connexion à la bdd dans un endpoint, utilise l'élément de requête CreateLoginDto et l'élement de réponse GetLoginDto
{
public override void Configure() //Configuration de l'endpoint
{
Post("/api/logins"); //Créer un login
AllowAnonymous(); //Autorise l'accès sans authentification
}
public override async Task HandleAsync(CreateLoginDto req, CancellationToken ct)
{
string? salt = new Password().IncludeLowercase().IncludeUppercase().IncludeNumeric().LengthRequired(24).Next();
var login = new Models.Login() //Création d'un nom, prénom, mot de passe et un salt rentré par l'utilisateur
{
Username = req.Username,
FullName = req.FullName,
Password = BCrypt.Net.BCrypt.HashPassword(req.Password + salt),
Salt = salt
};
database.Logins.Add(login); //Ajout du login à la bdd
await database.SaveChangesAsync(ct); //Sauvegarde du login dans la bdd
// Pour renvoyer une erreur : Send.StringAsync("Le message d'erreur", 400);
GetLoginDto responseDto = new() //renvoie l'id, nom, prénom, mot de passe et un salt
{
Id = login.Id,
Username = login.Username,
FullName = login.FullName,
Password = login.Password,
Salt = login.Salt
};
await Send.OkAsync(responseDto, ct); //Réponse au client
}
}
@@ -1,35 +0,0 @@
using PyroFetes.DTO.Login.Request;
using PyroFetes.DTO.Login.Response;
using FastEndpoints;
using Microsoft.EntityFrameworkCore;
namespace PyroFetes.Endpoints.Login;
public class DeleteLoginRequest
{
public int Id { get; set; }
}
public class DeleteLoginEndpoint(PyroFetesDbContext database) : Endpoint<DeleteLoginRequest>
{
public override void Configure()
{
Delete("/api/logins/{@Id}", x => new {x.Id});
}
public override async Task HandleAsync(DeleteLoginRequest req, CancellationToken ct)
{
var login = await database.Logins.SingleOrDefaultAsync(x => x.Id == req.Id, ct);
if (login == null)
{
await Send.NotFoundAsync(ct);
return;
}
database.Logins.Remove(login);
await database.SaveChangesAsync(ct);
await Send.NoContentAsync(ct);
}
}
@@ -1,30 +0,0 @@
using PyroFetes.DTO.Login.Response;
using FastEndpoints;
using Microsoft.EntityFrameworkCore;
using PyroFetes;
namespace PyroFetes.Endpoints.Login;
public class GetAllLoginEndpoint(PyroFetesDbContext database) : EndpointWithoutRequest<List<GetLoginDto>>
{
public override void Configure()
{
Get("/api/logins");
}
public override async Task HandleAsync(CancellationToken ct)
{
var logins = await database.Logins
.Select(login => new GetLoginDto()
{
Id = login.Id,
Username = login.Username,
FullName = login.FullName,
Password = login.Password,
Salt = login.Salt
})
.ToListAsync(ct);
await Send.OkAsync(logins, ct);
}
}
@@ -1,41 +0,0 @@
using PyroFetes.DTO.Login.Response;
using FastEndpoints;
using Microsoft.EntityFrameworkCore;
namespace PyroFetes.Endpoints.Login;
public class GetLoginRequest
{
public int Id { get; set; }
}
public class GetLoginEndpoint(PyroFetesDbContext database) : Endpoint<GetLoginRequest, GetLoginDto>
{
public override void Configure()
{
Get("/api/logins/{@Id}", x => new {x.Id});
}
public override async Task HandleAsync(GetLoginRequest req, CancellationToken ct)
{
var login = await database.Logins
.SingleOrDefaultAsync(x => x.Id == req.Id, ct);
if (login == null)
{
await Send.NotFoundAsync(ct);
return;
}
GetLoginDto responseDto = new()
{
Id = login.Id,
Username = login.Username,
FullName = login.FullName,
Password = login.Password,
Salt = login.Salt
};
await Send.OkAsync(responseDto, ct);
}
}
@@ -1,45 +0,0 @@
using PyroFetes.DTO.Login.Request;
using PyroFetes.DTO.Login.Response;
using FastEndpoints;
using Microsoft.EntityFrameworkCore;
using PasswordGenerator;
namespace PyroFetes.Endpoints.Login;
public class UpdateLoginEndpoint(PyroFetesDbContext database) : Endpoint<UpdateLoginDto, GetLoginDto>
{
public override void Configure()
{
Put("/api/logins/{@Id}", x => new {x.Id});
}
public override async Task HandleAsync(UpdateLoginDto req, CancellationToken ct)
{
var login = await database.Logins.SingleOrDefaultAsync(x => x.Id == req.Id, ct);
if (login == null)
{
await Send.NotFoundAsync(ct);
return;
}
string? salt = new Password().IncludeLowercase().IncludeUppercase().IncludeNumeric().LengthRequired(24).Next();
login.Username = req.Username;
login.FullName = req.FullName;
login.Password = BCrypt.Net.BCrypt.HashPassword(req.Password + salt);
login.Salt = salt;
await database.SaveChangesAsync(ct);
GetLoginDto responseDto = new()
{
Id = login.Id,
Username = login.Username,
FullName = login.FullName,
Password = login.Password,
Salt = login.Salt
};
await Send.OkAsync(responseDto, ct);
}
}
@@ -1,50 +0,0 @@
using PyroFetes.DTO.Login.Request;
using FastEndpoints.Security;
using PyroFetes.DTO.Login.Response;
using FastEndpoints;
using Microsoft.EntityFrameworkCore;
using PyroFetes;
namespace PyroFetes.Endpoints.Login;
public class UserLoginEndpoint(PyroFetesDbContext database) : Endpoint<ConnectLoginDto, GetLoginConnectDto>
{
public override void Configure()
{
Post("/api/login");
AllowAnonymous();
}
public override async Task HandleAsync(ConnectLoginDto req, CancellationToken ct)
{
var login = await database.Logins.SingleOrDefaultAsync(x => x.Username == req.Username, ct);
if (login == null)
{
await Send.UnauthorizedAsync(ct);
return;
}
if (BCrypt.Net.BCrypt.Verify(req.Password + login.Salt, login.Password))
{
var jwtToken = JwtBearer.CreateToken(
o =>
{
o.SigningKey = "ThisIsASuperSecretJwtKeyThatIsAtLeast32CharsLong";
o.ExpireAt = DateTime.UtcNow.AddMinutes(15);
if (login.Role != null) o.User.Roles.Add(login.Role);
o.User.Claims.Add(("Username", login.Username)!);
o.User.Claims.Add(("FullName", login.FullName)!);
o.User["UserId"] = "001";
});
GetLoginConnectDto responseDto = new()
{
Token = jwtToken
};
await Send.OkAsync(responseDto, ct);
}
else await Send.UnauthorizedAsync(ct);
}
}
@@ -4,34 +4,34 @@ using FastEndpoints;
namespace PyroFetes.Endpoints.Material; namespace PyroFetes.Endpoints.Material;
public class CreateMaterialEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<CreateMaterialDto, GetMaterialDto> //Instanciation d'une connexion à la bdd dans un endpoint, utilise l'élément de requête CreateMaterialDto et l'élement de réponse GetMaterialDto public class CreateMaterialEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<CreateMaterialDto, GetMaterialDto>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Post("Api/materials"); //Créer un matériel Post("/materials");
AllowAnonymous();//Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(CreateMaterialDto req, CancellationToken ct) public override async Task HandleAsync(CreateMaterialDto req, CancellationToken ct)
{ {
Models.Material quantity = new() //Création d'un nom, quantité et liaison de l'id de l'entrepôt rentré par l'utilisateur Models.Material quantity = new()
{ {
Name = req.Label, Name = req.Label,
Quantity = req.Quantity, Quantity = req.Quantity,
WarehouseId = req.WarehouseId, WarehouseId = req.WarehouseId,
}; };
pyrofetesdbcontext.Materials.Add(quantity); //Ajoute quantity à la bdd pyrofetesdbcontext.Materials.Add(quantity);
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde les changements effectués dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
Console.WriteLine("Material added"); //Affiche Material Added si réussi Console.WriteLine("Material added");
GetMaterialDto responseDto = new() //Constuire l'objet de réponse pour retourner name, quantity et warehouseId à l'utilisateur GetMaterialDto responseDto = new()
{ {
Id = quantity.Id, //Affiche l'id lors de la réponse Id = quantity.Id,
WarehouseId = quantity.WarehouseId, //Affiche le label lors de la réponse WarehouseId = quantity.WarehouseId,
Label = req.Label, //Affiche le label lors de la réponse Label = req.Label,
}; };
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -2,34 +2,34 @@ using FastEndpoints;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
namespace PyroFetes.Endpoints.Material; namespace PyroFetes.Endpoints.Material;
public class DeleteMaterialRequest //Création d'une classe DeleteMaterialRequest public class DeleteMaterialRequest
{ {
public int Id { get; set; } //Création d'un Id public int Id { get; set; }
} }
public class DeleteMaterialEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<DeleteMaterialRequest> public class DeleteMaterialEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<DeleteMaterialRequest>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Delete("Api/materials/{@id}", x => new { x.Id }); //Création d'un endpoint qui supprime un matériel grâce à son id Delete("/materials/{@id}", x => new { x.Id });
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(DeleteMaterialRequest req, CancellationToken ct) //Méthode asynchrone qui traite la suppression du matériel public override async Task HandleAsync(DeleteMaterialRequest req, CancellationToken ct)
{ {
Models.Material? materialToDelete = await pyrofetesdbcontext //Récupère un matériel dans la bdd et le stocke dans materialToDelete Models.Material? materialToDelete = await pyrofetesdbcontext
.Materials //Recherche la couleur dans la table Colors .Materials
.SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct); //Recherche un matériel dont l'id correspond à req.Id .SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct);
if (materialToDelete == null) //Si le matériel n'est pas trouvé if (materialToDelete == null)
{ {
Console.WriteLine($"Aucun matériel avec l'ID {req.Id} trouvé."); //Afficher aucun matériel avec l'id ... trouvé Console.WriteLine($"Aucun matériel avec l'ID {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
pyrofetesdbcontext.Materials.Remove(materialToDelete); //Supprime le matériel dans la bdd pyrofetesdbcontext.Materials.Remove(materialToDelete);
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde les changements effectués dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
await Send.NoContentAsync(ct); //Renvoie une réponse réussite 204 await Send.NoContentAsync(ct);
} }
} }
@@ -6,23 +6,23 @@ namespace PyroFetes.Endpoints.Material;
public class GetAllMaterialsEndpoint(PyroFetesDbContext pyrofetesdbcontext) : EndpointWithoutRequest<List<GetMaterialDto>> public class GetAllMaterialsEndpoint(PyroFetesDbContext pyrofetesdbcontext) : EndpointWithoutRequest<List<GetMaterialDto>>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Get("Api/materials"); //Création d'un endpoint pour récupérer tous les matériaux grâce à la liste Get("/materials");
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(CancellationToken ct) public override async Task HandleAsync(CancellationToken ct)
{ {
List<GetMaterialDto> responseDto = await pyrofetesdbcontext.Materials //Création d'une liste qui récupère tous les matériaux de la bdd List<GetMaterialDto> responseDto = await pyrofetesdbcontext.Materials
.Select(a => new GetMaterialDto //Sélectionne dans la liste chaque matériel .Select(a => new GetMaterialDto
{ {
Id = a.Id, //Récupère l'id Id = a.Id,
Label = a.Name, //Récupère le label Label = a.Name,
Quantity = a.Quantity, //Récupère la quantité Quantity = a.Quantity,
WarehouseId = a.WarehouseId, //Récupère l'id de l'entrepot WarehouseId = a.WarehouseId,
} }
).ToListAsync(ct); //Retourne la liste du matériel ).ToListAsync(ct);
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -11,32 +11,32 @@ public class GetMaterialRequest
public class GetMaterialEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<GetMaterialRequest, GetMaterialDto> public class GetMaterialEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<GetMaterialRequest, GetMaterialDto>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Get("Api/materials/{@id}", x => new { x.Id }); //Création d'un endpoint qui récupère un matériel grâce à son id Get("/materials/{@id}", x => new { x.Id });
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(GetMaterialRequest req, CancellationToken ct) //Méthode asynchrone qui traite la récupération du matériel public override async Task HandleAsync(GetMaterialRequest req, CancellationToken ct)
{ {
Models.Material? material = await pyrofetesdbcontext //Récupère un matériel dans la bdd et le stocke dans material Models.Material? material = await pyrofetesdbcontext
.Materials //Recherche le matériel dans la table Materials .Materials
.SingleOrDefaultAsync(x => x.Id == req.Id, cancellationToken: ct); //Recherche un matériel dont l'id correspond à req.Id .SingleOrDefaultAsync(x => x.Id == req.Id, cancellationToken: ct);
if (material == null) //Si le matériel n'est pas trouvé if (material == null)
{ {
Console.WriteLine("Aucun matériel avec l'ID {req.Id} trouvé."); //Afficher aucun matériel avec l'id ... trouvé Console.WriteLine("Aucun matériel avec l'ID {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
GetMaterialDto responseDto = new() //Constuire l'objet de réponse pour retourner id, label et warehouseId à l'utilisateur GetMaterialDto responseDto = new()
{ {
Id = material.Id, //Affiche l'id lors de la réponse Id = material.Id,
Label = material.Name, //Affiche le label lors de la réponse Label = material.Name,
WarehouseId = material.WarehouseId, //Affiche warehouseId lors de la réponse WarehouseId = material.WarehouseId,
}; };
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -7,36 +7,36 @@ namespace PyroFetes.Endpoints.Material;
public class UpdateMaterialEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<UpdateMaterialDto, GetMaterialDto> public class UpdateMaterialEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<UpdateMaterialDto, GetMaterialDto>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Put("Api/materials/{@id}", x => new { x.Id }); //Création d'un endpoint qui modifie le matériel grâce à son id Put("/materials/{@id}", x => new { x.Id });
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(UpdateMaterialDto req, CancellationToken ct) public override async Task HandleAsync(UpdateMaterialDto req, CancellationToken ct)
{ {
Models.Material? materialToEdit = await pyrofetesdbcontext //Récupère un matériel dans la bdd et le stocke dans materialToEdit Models.Material? materialToEdit = await pyrofetesdbcontext
.Materials //Recherche le matériel dans la table Materials .Materials
.SingleOrDefaultAsync(x => x.Id == req.Id, cancellationToken: ct);//Recherche un matériel dont l'id correspond à req.Id .SingleOrDefaultAsync(x => x.Id == req.Id, cancellationToken: ct);
if (materialToEdit == null) //Si le matériel n'est pas trouvé if (materialToEdit == null)
{ {
Console.WriteLine("Aucun matériel avec l'id {req.Id} trouvé."); //Afficher aucun matériel avec l'id ... trouvé Console.WriteLine("Aucun matériel avec l'id {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
materialToEdit.Name = req.Label; //Modification du label materialToEdit.Name = req.Label;
materialToEdit.WarehouseId = req.WarehouseId; //Modification de warehouseId materialToEdit.WarehouseId = req.WarehouseId;
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde les changements effectués dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
GetMaterialDto responseDto = new() //Constuire l'objet de réponse pour retourner l'id, le label et warehouseId du nouveau matériel GetMaterialDto responseDto = new()
{ {
Id = req.Id, //Affiche l'id Id = req.Id,
Label = req.Label, //Affiche le label Label = req.Label,
WarehouseId = req.WarehouseId, //Affiche warehouseId WarehouseId = req.WarehouseId,
}; };
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -4,18 +4,18 @@ using FastEndpoints;
namespace PyroFetes.Endpoints.Movement; namespace PyroFetes.Endpoints.Movement;
public class CreateMovementEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<CreateMovementDto, GetMovementDto> //Instanciation d'une connexion à la bdd dans un endpoint, utilise l'élément de requête CreateMovementDto et l'élement de réponse GetMovementDto public class CreateMovementEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<CreateMovementDto, GetMovementDto>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Post("/api/movements"); //Créer un mouvement Post("/movements");
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(CreateMovementDto req, CancellationToken ct) public override async Task HandleAsync(CreateMovementDto req, CancellationToken ct)
{ {
Models.Movement movement = new () //Création d'une date, d'une date de départ, d'arrivée et d'une quantité rentré par l'utilisateur Models.Movement movement = new ()
{ {
Date = req.Date, Date = req.Date,
Start = req.Start, Start = req.Start,
@@ -23,19 +23,19 @@ public class CreateMovementEndpoint(PyroFetesDbContext pyrofetesdbcontext) : End
Quantity = req.Quantity Quantity = req.Quantity
}; };
pyrofetesdbcontext.Movements.Add(movement); //Ajoute movement à la bdd pyrofetesdbcontext.Movements.Add(movement);
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde les changements effectués dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
Console.WriteLine("Movement créée avec succès !"); //Affiche Movement créée avec succès ! si réussi Console.WriteLine("Movement créée avec succès !");
GetMovementDto responseDto = new () //Constuire l'objet de réponse pour retourner les informations à l'utilisateur GetMovementDto responseDto = new ()
{ {
Date = req.Date, //Affiche date lors de la réponse Date = req.Date,
Start = req.Start, //Affiche start lors de la réponse Start = req.Start,
Arrival = req.Arrival, //Affiche arrival lors de la réponse Arrival = req.Arrival,
Quantity = req.Quantity //Affiche quantity lors de la réponse Quantity = req.Quantity
}; };
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -3,36 +3,36 @@ using Microsoft.EntityFrameworkCore;
namespace PyroFetes.Endpoints.Movement; namespace PyroFetes.Endpoints.Movement;
public class DeleteMovementRequest //Création d'une classe DeleteMovementRequest public class DeleteMovementRequest
{ {
public int Id { get; set; } //Création d'un Id public int Id { get; set; }
} }
public class DeleteMovementEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<DeleteMovementRequest> public class DeleteMovementEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<DeleteMovementRequest>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Delete("/api/Movements/{@id}", x => new { x.Id }); //Création d'un endpoint qui supprime un mouvement grâce à son id Delete("/Movements/{@id}", x => new { x.Id });
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(DeleteMovementRequest req, CancellationToken ct) //Méthode asynchrone qui traite la suppression du mouvement public override async Task HandleAsync(DeleteMovementRequest req, CancellationToken ct)
{ {
Models.Movement? movementToDelete = await pyrofetesdbcontext //Récupère un mouvement dans la bdd et le stocke dans movementToDelete Models.Movement? movementToDelete = await pyrofetesdbcontext
.Movements //Recherche le mouvement dans la table Movements .Movements
.SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct);//Recherche une mouvement dont l'id correspond à req.Id .SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct);
if (movementToDelete == null) //Si le mouvement n'est pas trouvé if (movementToDelete == null)
{ {
Console.WriteLine($"Aucune mouvement avec l'ID {req.Id} trouvé."); //Affiche aucun mouvement avec l'id ... trouvé Console.WriteLine($"Aucune mouvement avec l'ID {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
pyrofetesdbcontext.Movements.Remove(movementToDelete); //Supprime le mouvement dans la bdd pyrofetesdbcontext.Movements.Remove(movementToDelete);
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde les changements effectués dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
await Send.NoContentAsync(ct); //Renvoie une réponse réussite 204 await Send.NoContentAsync(ct);
} }
} }
@@ -6,26 +6,26 @@ namespace PyroFetes.Endpoints.Movement;
public class GetAllMovementsEndpoint(PyroFetesDbContext pyrofetesdbcontext) : EndpointWithoutRequest<List<GetMovementDto>> public class GetAllMovementsEndpoint(PyroFetesDbContext pyrofetesdbcontext) : EndpointWithoutRequest<List<GetMovementDto>>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Get("/api/movements"); //Création d'un endpoint pour récupérer tous les mouvements grâce à la liste Get("/movements");
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(CancellationToken ct) public override async Task HandleAsync(CancellationToken ct)
{ {
List<GetMovementDto> responseDto = await pyrofetesdbcontext.Movements //Création d'une liste qui récupère tous les mouvements de la bdd List<GetMovementDto> responseDto = await pyrofetesdbcontext.Movements
.Select(a => new GetMovementDto //Sélectionne dans la liste chaque mouvement .Select(a => new GetMovementDto
{ {
Id = a.Id, //Récupère l'id Id = a.Id,
Date = a.Date, //Récupère la date Date = a.Date,
Start = a.Start, //Récupère start Start = a.Start,
Arrival = a.Arrival, //Récupère arrival Arrival = a.Arrival,
Quantity = a.Quantity //Récupère quantity Quantity = a.Quantity
} }
).ToListAsync(ct); //Retourne la liste de mouvement ).ToListAsync(ct);
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -11,35 +11,35 @@ public class GetMovementRequest
public class GetMovementEndpoint(PyroFetesDbContext pyrofetesdbcontext) :Endpoint<GetMovementRequest, GetMovementDto> public class GetMovementEndpoint(PyroFetesDbContext pyrofetesdbcontext) :Endpoint<GetMovementRequest, GetMovementDto>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Get("/api/movements/{@id}", x => new { x.Id }); //Création d'un endpoint qui récupère un mouvement grâce à son id Get("/movements/{@id}", x => new { x.Id });
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(GetMovementRequest req, CancellationToken ct) //Méthode asynchrone qui traite la récupération du mouvement public override async Task HandleAsync(GetMovementRequest req, CancellationToken ct)
{ {
Models.Movement? movement = await pyrofetesdbcontext //Récupère un mouvement dans la bdd et le stocke dans movement Models.Movement? movement = await pyrofetesdbcontext
.Movements //Recherche la couleur dans la table Movements .Movements
.SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct);//Recherche un mouvement dont l'id correspond à req.Id .SingleOrDefaultAsync(a => a.Id == req.Id, cancellationToken: ct);
if (movement == null) //Si le mouvement n'est pas trouvé if (movement == null)
{ {
Console.WriteLine($"Aucun mouvement avec l'ID {req.Id} trouvé."); //Affiche aucun mouvement avec l'id ... trouvé Console.WriteLine($"Aucun mouvement avec l'ID {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
GetMovementDto responseDto = new() //Constuire l'objet de réponse pour retourner les informations à l'utilisateur GetMovementDto responseDto = new()
{ {
Id = req.Id, //Affiche l'id lors de la réponse Id = req.Id,
Date = movement.Date, //Affiche date lors de la réponse Date = movement.Date,
Start = movement.Start, //Affiche start lors de la réponse Start = movement.Start,
Arrival = movement.Arrival, //Affiche arrival lors de la réponse Arrival = movement.Arrival,
Quantity = movement.Quantity //Affiche quantity lors de la réponse Quantity = movement.Quantity
}; };
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -6,26 +6,26 @@ namespace PyroFetes.Endpoints.Movement;
public class UpdateMovementEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<UpdateMovementDto, GetMovementDto> public class UpdateMovementEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<UpdateMovementDto, GetMovementDto>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Put("/api/movements"); //Création d'un endpoint qui modifie le mouvement grâce à son id Put("/movements");
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(UpdateMovementDto req, CancellationToken ct) public override async Task HandleAsync(UpdateMovementDto req, CancellationToken ct)
{ {
Models.Movement movement = new() Models.Movement movement = new()
{ {
Date = req.Date, Date = req.Date,
Start = req.Start, Start = req.Start,
Arrival = req.Arrival, Arrival = req.Arrival,
Quantity = req.Quantity Quantity = req.Quantity
}; };
pyrofetesdbcontext.Add(movement); //Modification du mouvement pyrofetesdbcontext.Add(movement);
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde les changements effectués dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
GetMovementDto response = new() //Constuire l'objet de réponse pour retourner les informations du mouvement GetMovementDto response = new()
{ {
Id = req.Id, Id = req.Id,
Date = req.Date, Date = req.Date,
@@ -34,7 +34,7 @@ public class UpdateMovementEndpoint(PyroFetesDbContext pyrofetesdbcontext) : End
Quantity = req.Quantity Quantity = req.Quantity
}; };
await Send.OkAsync(response, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(response, ct);
} }
} }
@@ -7,19 +7,19 @@ using PyroFetes.Models;
namespace PyroFetes.Endpoints.Product; namespace PyroFetes.Endpoints.Product;
public class CreateProductEndpoint(PyroFetesDbContext db) public class CreateProductEndpoint(PyroFetesDbContext db)
: Endpoint<CreateProductDto, GetProductDto> //Instanciation d'une connexion à la bdd dans un endpoint, utilise l'élément de requête CreateProductDto et l'élement de réponse GetProductDto : Endpoint<CreateProductDto, GetProductDto>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Post("/api/products"); //Créer un produit Post("/products");
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(CreateProductDto req, CancellationToken ct) public override async Task HandleAsync(CreateProductDto req, CancellationToken ct)
{ {
var product = new Models.Product //Création d'un nom, référence, durée, calibre, numéro d'aprovisionnement, poids, nec, image, lien, liaison de la catégorie du produit et de la classification rentré par l'utilisateur var product = new Models.Product
{ {
Reference = req.References.ToString(), Reference = req.Reference,
Name = req.Name!, Name = req.Name!,
Duration = req.Duration, Duration = req.Duration,
Caliber = req.Caliber, Caliber = req.Caliber,
@@ -32,8 +32,8 @@ public class CreateProductEndpoint(PyroFetesDbContext db)
ClassificationId = req.ClassificationId ClassificationId = req.ClassificationId
}; };
db.Products.Add(product); //Ajout du produit à la bdd db.Products.Add(product);
await db.SaveChangesAsync(ct); //Sauvegarde du produit dans la bdd await db.SaveChangesAsync(ct);
// Ajout des fournisseurs liés // Ajout des fournisseurs liés
if (req.Suppliers is not null && req.Suppliers.Any()) if (req.Suppliers is not null && req.Suppliers.Any())
@@ -46,9 +46,9 @@ public class CreateProductEndpoint(PyroFetesDbContext db)
SupplierId = s.SupplierId, SupplierId = s.SupplierId,
SellingPrice = s.SellingPrice SellingPrice = s.SellingPrice
}; };
db.Prices.Add(price); //Ajout du prix à la bdd db.Prices.Add(price);
} }
await db.SaveChangesAsync(ct); //Sauvegarde du produit dans la bdd await db.SaveChangesAsync(ct);
} }
// Ajout des entrepôts liés // Ajout des entrepôts liés
@@ -66,16 +66,16 @@ public class CreateProductEndpoint(PyroFetesDbContext db)
WarehouseId = w.WarehouseId, WarehouseId = w.WarehouseId,
Quantity = w.Quantity Quantity = w.Quantity
}; };
db.WarehouseProducts.Add(warehouseProduct); //Ajout du produit de l'entrepot à la bdd db.WarehouseProducts.Add(warehouseProduct);
} }
await db.SaveChangesAsync(ct); //Sauvegarde du produit de l'entrepot dans la bdd await db.SaveChangesAsync(ct);
} }
// Construction de la réponse // Construction de la réponse
var response = new GetProductDto var response = new GetProductDto
{ {
Id = product.Id, Id = product.Id,
Reference = req.References, Reference = req.Reference,
Name = req.Name, Name = req.Name,
Duration = req.Duration, Duration = req.Duration,
Caliber = req.Caliber, Caliber = req.Caliber,
@@ -100,6 +100,6 @@ public class CreateProductEndpoint(PyroFetesDbContext db)
}).ToList() ?? new() }).ToList() ?? new()
}; };
await Send.OkAsync(response, ct); //Réponse au client await Send.OkAsync(response, ct);
} }
} }
@@ -6,28 +6,28 @@ namespace PyroFetes.Endpoints.Product;
public class DeleteProductRequest public class DeleteProductRequest
{ {
public int Id { get; set; } //Création d'un Id public int Id { get; set; }
} }
public class DeleteProductEndpoint(PyroFetesDbContext db) : Endpoint<DeleteProductRequest> public class DeleteProductEndpoint(PyroFetesDbContext db) : Endpoint<DeleteProductRequest>
{ {
public override void Configure() public override void Configure()
{ {
Delete("/api/products/{@id}", x => new { x.Id }); //endpoint qui supprime un produit grâce à son id Delete("/products/{@id}", x => new { x.Id });
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(DeleteProductRequest req, CancellationToken ct) public override async Task HandleAsync(DeleteProductRequest req, CancellationToken ct)
{ {
// Récupérer le produit // Récupérer le produit
var productToDelete = await db.Products var productToDelete = await db.Products
.SingleOrDefaultAsync(p => p.Id == req.Id, ct); .SingleOrDefaultAsync(p => p.Id == req.Id, ct);
if (productToDelete is null) if (productToDelete is null)
{ {
Console.WriteLine($"Aucun produit avec l'ID {req.Id} trouvé."); Console.WriteLine($"Aucun produit avec l'ID {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
// Supprimer les liaisons Price // Supprimer les liaisons Price
@@ -54,6 +54,6 @@ public class DeleteProductEndpoint(PyroFetesDbContext db) : Endpoint<DeleteProdu
await db.SaveChangesAsync(ct); await db.SaveChangesAsync(ct);
Console.WriteLine($"Produit {req.Id}, ses prix et ses entrepôts liés ont été supprimés avec succès."); Console.WriteLine($"Produit {req.Id}, ses prix et ses entrepôts liés ont été supprimés avec succès.");
await Send.NoContentAsync(ct); //Renvoie une réponse réussite 204 await Send.NoContentAsync(ct);
} }
} }
@@ -11,7 +11,7 @@ public class GetAllProductsEndpoint(PyroFetesDbContext db)
{ {
public override void Configure() public override void Configure()
{ {
Get("/api/products"); Get("/products");
AllowAnonymous(); AllowAnonymous();
} }
@@ -20,7 +20,7 @@ public class GetAllProductsEndpoint(PyroFetesDbContext db)
// Inclure toutes les relations nécessaires : Prices + WarehouseProducts + Warehouse // Inclure toutes les relations nécessaires : Prices + WarehouseProducts + Warehouse
var products = await db.Products var products = await db.Products
.Include(p => p.Prices) .Include(p => p.Prices)
.Include(p => p.WarehouseProducts) .Include(p => p.WarehouseProducts)!
.ThenInclude(wp => wp.Warehouse) .ThenInclude(wp => wp.Warehouse)
.ToListAsync(ct); .ToListAsync(ct);
@@ -28,7 +28,7 @@ public class GetAllProductsEndpoint(PyroFetesDbContext db)
{ {
Id = p.Id, Id = p.Id,
// Le modèle Product contient "Reference" (string) — pas "References" (int) // Le modèle Product contient "Reference" (string) — pas "References" (int)
Reference = int.TryParse(p.Reference, out var refInt) ? refInt : 0, Reference = p.Reference,
Name = p.Name, Name = p.Name,
Duration = p.Duration, Duration = p.Duration,
Caliber = p.Caliber, Caliber = p.Caliber,
@@ -16,7 +16,7 @@ public class GetProductEndpoint(PyroFetesDbContext db)
{ {
public override void Configure() public override void Configure()
{ {
Get("/api/products/{@id}", x => new { x.Id }); Get("/products/{@id}", x => new { x.Id });
AllowAnonymous(); AllowAnonymous();
} }
@@ -41,7 +41,7 @@ public class GetProductEndpoint(PyroFetesDbContext db)
Id = product.Id, Id = product.Id,
// Le modèle Product contient "Reference" (string), pas "References" (int) // Le modèle Product contient "Reference" (string), pas "References" (int)
Reference = int.TryParse(product.Reference, out var refInt) ? refInt : 0, Reference = product.Reference,
Name = product.Name, Name = product.Name,
Duration = product.Duration, Duration = product.Duration,
@@ -13,7 +13,7 @@ public class UpdateProductEndpoint(PyroFetesDbContext db)
public override void Configure() public override void Configure()
{ {
// Route HTTP PUT avec un paramètre d'identifiant dans l'URL // Route HTTP PUT avec un paramètre d'identifiant dans l'URL
Put("/api/products/{@id}", x => new { x.Id }); Put("/products/{@id}", x => new { x.Id });
// Autorise les requêtes anonymes (sans authentification) // Autorise les requêtes anonymes (sans authentification)
AllowAnonymous(); AllowAnonymous();
@@ -35,7 +35,7 @@ public class UpdateProductEndpoint(PyroFetesDbContext db)
} }
// Mise à jour des propriétés principales du produit // Mise à jour des propriétés principales du produit
product.Reference = req.References.ToString(); // Converti int → string product.Reference = req.Reference; // Converti int → string
product.Name = req.Name; product.Name = req.Name;
product.Duration = req.Duration; product.Duration = req.Duration;
product.Caliber = req.Caliber; product.Caliber = req.Caliber;
@@ -77,7 +77,7 @@ public class UpdateProductEndpoint(PyroFetesDbContext db)
var response = new GetProductDto var response = new GetProductDto
{ {
Id = product.Id, Id = product.Id,
Reference = req.References, // DTO garde int pour cohérence Reference = req.Reference, // DTO garde int pour cohérence
Name = req.Name, Name = req.Name,
Duration = req.Duration, Duration = req.Duration,
Caliber = req.Caliber, Caliber = req.Caliber,
@@ -4,34 +4,34 @@ using FastEndpoints;
namespace PyroFetes.Endpoints.ProductCategory; namespace PyroFetes.Endpoints.ProductCategory;
public class CreateProductCategoryEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<CreateProductCategoryDto, GetProductCategoryDto> //Instanciation d'une connexion à la bdd dans un endpoint, utilise l'élément de requête CreateProductCategoryDto et l'élement de réponse GetProductCategoryDto public class CreateProductCategoryEndpoint(PyroFetesDbContext pyrofetesdbcontext) : Endpoint<CreateProductCategoryDto, GetProductCategoryDto>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Post("/api/productcategories"); //Créer une catégorie de produits Post("/productcategories");
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(CreateProductCategoryDto req, CancellationToken ct) public override async Task HandleAsync(CreateProductCategoryDto req, CancellationToken ct)
{ {
Models.ProductCategory productCategory = new () //Création d'un label rentré par l'utilisateur Models.ProductCategory productCategory = new ()
{ {
Label = req.Label, Label = req.Label,
}; };
pyrofetesdbcontext.ProductCategories.Add(productCategory); //Ajout du catégorie de la produit à la bdd pyrofetesdbcontext.ProductCategories.Add(productCategory);
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde du catégorie de la produit dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
Console.WriteLine("Category créé avec succès !"); Console.WriteLine("Category créé avec succès !");
GetProductCategoryDto responseDto = new () //renvoie l'id et le label GetProductCategoryDto responseDto = new ()
{ {
Id = productCategory.Id, Id = productCategory.Id,
Label = productCategory.Label Label = productCategory.Label
}; };
await Send.OkAsync(responseDto, ct); //Réponse au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -12,25 +12,25 @@ public class DeleteProductCategoryEndpoint(PyroFetesDbContext pyrofetesdbcontext
{ {
public override void Configure() public override void Configure()
{ {
Delete("/api/productcategories/{@id}", x => new { x.Id }); //endpoint qui supprime une catégorie de produit grâce à son id Delete("/productcategories/{@id}", x => new { x.Id });
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(DeleteProductCategoryRequest req, CancellationToken ct) public override async Task HandleAsync(DeleteProductCategoryRequest req, CancellationToken ct)
{ {
Models.ProductCategory? productCategoryToDelete = await pyrofetesdbcontext //Récupère une catégorie de produit dans la bdd et le stocke dans productCategoryToDelete Models.ProductCategory? productCategoryToDelete = await pyrofetesdbcontext
.ProductCategories //Recherche la couleur dans la table ProductCategories .ProductCategories
.SingleOrDefaultAsync(pc => pc.Id == req.Id, cancellationToken: ct); //Recherche une catégorie de produit dont l'id correspond à req.Id .SingleOrDefaultAsync(pc => pc.Id == req.Id, cancellationToken: ct);
if (productCategoryToDelete == null) if (productCategoryToDelete == null)
{ {
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
pyrofetesdbcontext.ProductCategories.Remove(productCategoryToDelete); //Supprime la catégorie de produit dans la bdd pyrofetesdbcontext.ProductCategories.Remove(productCategoryToDelete);
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde les changements effectués dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
await Send.NoContentAsync(ct); //Renvoie une réponse réussite 204 await Send.NoContentAsync(ct);
} }
} }
@@ -8,20 +8,20 @@ public class GetAllProductCategoriesEndpoint(PyroFetesDbContext pyrofetesdbconte
{ {
public override void Configure() public override void Configure()
{ {
Get("/api/productcategories"); //Endpoint qui affiche toutes les catégories de produits Get("/productcategories");
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(CancellationToken ct) public override async Task HandleAsync(CancellationToken ct)
{ {
List<GetProductCategoryDto> responseDto = await pyrofetesdbcontext.ProductCategories //Création d'une liste qui récupère toutes les catégories de produits dans la bdd List<GetProductCategoryDto> responseDto = await pyrofetesdbcontext.ProductCategories
.Select(pc => new GetProductCategoryDto() //Sélectionne dans la liste chaque catégorie de produits .Select(pc => new GetProductCategoryDto()
{ {
Id = pc.Id, //Récupère l'id Id = pc.Id,
Label = pc.Label //Récupère le label Label = pc.Label
} }
).ToListAsync(ct); //Retourne la liste ).ToListAsync(ct);
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -14,29 +14,29 @@ public class GetProductCategoryEndpoint(PyroFetesDbContext pyrofetesdbcontext) :
{ {
public override void Configure() public override void Configure()
{ {
Get("/api/productcategory/{@id}", x => new { x.Id }); //endpoint qui récupère une catégorie de produit grâce à son id Get("/productcategory/{@id}", x => new { x.Id });
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(GetProductCategoryRequest req, CancellationToken ct) public override async Task HandleAsync(GetProductCategoryRequest req, CancellationToken ct)
{ {
Models.ProductCategory? productCategory = await pyrofetesdbcontext //Récupère une catégorie de produits dans la bdd et le stocke dans productCategory Models.ProductCategory? productCategory = await pyrofetesdbcontext
.ProductCategories //Recherche dans la table ProductCategories .ProductCategories
.SingleOrDefaultAsync(pc => pc.Id == req.Id, cancellationToken: ct);//Recherche une catégorie de produits dont l'id correspond à req.Id .SingleOrDefaultAsync(pc => pc.Id == req.Id, cancellationToken: ct);
if (productCategory == null) //Si la catégorie de produit n'est pas trouvé if (productCategory == null)
{ {
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
GetProductCategoryDto responseDto = new() GetProductCategoryDto responseDto = new()
{ {
Id = productCategory.Id, //Affiche l'id lors de la réponse Id = productCategory.Id,
Label = productCategory.Label //Affiche le label lors de la réponse Label = productCategory.Label
}; };
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -9,31 +9,31 @@ public class UpdateProductCategoryEndpoint(PyroFetesDbContext pyrofetesdbcontext
{ {
public override void Configure() public override void Configure()
{ {
Put("/api/productcategory/{@id}", x => new { x.Id }); //endpoint qui modifie la catégorie de produit grâce à son id Put("/productcategory/{@id}", x => new { x.Id });
AllowAnonymous(); //Ignorer les requêtes non authentifiées AllowAnonymous();
} }
public override async Task HandleAsync(UpdateProductCategoryDto req, CancellationToken ct) public override async Task HandleAsync(UpdateProductCategoryDto req, CancellationToken ct)
{ {
Models.ProductCategory? productCategoryToEdit = await pyrofetesdbcontext //Récupère une catégorie de produits dans la bdd et le stocke dans productCategoryToEdit Models.ProductCategory? productCategoryToEdit = await pyrofetesdbcontext
.ProductCategories //Recherche dans la table ProductCategories .ProductCategories
.SingleOrDefaultAsync(pc => pc.Id == req.Id, cancellationToken: ct); //Recherche une catégorie de produits dont l'id correspond à req.Id .SingleOrDefaultAsync(pc => pc.Id == req.Id, cancellationToken: ct);
if (productCategoryToEdit == null) //Si la catégorie de produit n'est pas trouvé if (productCategoryToEdit == null)
{ {
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
productCategoryToEdit.Label = req.Label; //Modification du label productCategoryToEdit.Label = req.Label;
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde les changements effectués dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
GetProductCategoryDto responseDto = new() GetProductCategoryDto responseDto = new()
{ {
Id = req.Id, //Affiche l'id Id = req.Id,
Label = req.Label, //Affiche le label Label = req.Label,
}; };
await Send.OkAsync(responseDto, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(responseDto, ct);
} }
} }
@@ -7,17 +7,17 @@ using PyroFetes.Models;
namespace PyroFetes.Endpoints.Supplier; namespace PyroFetes.Endpoints.Supplier;
public class CreateSupplierEndpoint(PyroFetesDbContext pyrofetesdbcontext) public class CreateSupplierEndpoint(PyroFetesDbContext pyrofetesdbcontext)
: Endpoint<CreateSupplierDto, GetSupplierDto> //Instanciation d'une connexion à la bdd dans un endpoint, utilise l'élément de requête CreateSupplierDto et l'élement de réponse GetSupplierDto : Endpoint<CreateSupplierDto, GetSupplierDto>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Post("/api/suppliers"); //Créer un fournisseur Post("/suppliers");
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(CreateSupplierDto req, CancellationToken ct) public override async Task HandleAsync(CreateSupplierDto req, CancellationToken ct)
{ {
var supplier = new Models.Supplier //Création d'un nom, email, numéro de téléphone, adresse, code postal et nom de la ville rentré par l'utilisateur var supplier = new Models.Supplier
{ {
Name = req.Name, Name = req.Name,
Email = req.Email, Email = req.Email,
@@ -27,8 +27,8 @@ public class CreateSupplierEndpoint(PyroFetesDbContext pyrofetesdbcontext)
City = req.City City = req.City
}; };
pyrofetesdbcontext.Suppliers.Add(supplier); //Ajout du fournisseur à la bdd pyrofetesdbcontext.Suppliers.Add(supplier);
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde du fournisseur dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
// Ajout des liaisons Price si produits renseignés // Ajout des liaisons Price si produits renseignés
if (req.Products is not null && req.Products.Any()) if (req.Products is not null && req.Products.Any())
@@ -43,10 +43,10 @@ public class CreateSupplierEndpoint(PyroFetesDbContext pyrofetesdbcontext)
}; };
pyrofetesdbcontext.Prices.Add(price); pyrofetesdbcontext.Prices.Add(price);
} }
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde du fournisseur dans la bdd await pyrofetesdbcontext.SaveChangesAsync(ct);
} }
var response = new GetSupplierDto //renvoie l'id, d'un nom, d'un email, d'un numéro de téléphone, d'une adresse, d'un code postal et du nom de la ville var response = new GetSupplierDto
{ {
Id = supplier.Id, Id = supplier.Id,
Name = supplier.Name, Name = supplier.Name,
@@ -57,6 +57,6 @@ public class CreateSupplierEndpoint(PyroFetesDbContext pyrofetesdbcontext)
City = supplier.City City = supplier.City
}; };
await Send.OkAsync(response, ct); //Réponse au client await Send.OkAsync(response, ct);
} }
} }
@@ -13,21 +13,21 @@ public class DeleteSupplierEndpoint(PyroFetesDbContext pyrofetesdbcontext) : End
{ {
public override void Configure() public override void Configure()
{ {
Delete("/api/suppliers/{@id}", x => new { x.Id }); //Endpoint qui supprime un fournisseur en fonction de l'id Delete("/suppliers/{@id}", x => new { x.Id });
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(DeleteSupplierRequest req, CancellationToken ct) public override async Task HandleAsync(DeleteSupplierRequest req, CancellationToken ct)
{ {
var supplierToDelete = await pyrofetesdbcontext //Récupère un fournisseur dans la bdd et le stocke dans supplierToDelete var supplierToDelete = await pyrofetesdbcontext
.Suppliers //Recherche un fournisseur dans la table Suppliers .Suppliers
.SingleOrDefaultAsync(s => s.Id == req.Id, ct); //Recherche un fournisseur dont l'id correspond à req.Id .SingleOrDefaultAsync(s => s.Id == req.Id, ct);
if (supplierToDelete is null) if (supplierToDelete is null)
{ {
Console.WriteLine($"Aucun fournisseur avec l'ID {req.Id} trouvé."); Console.WriteLine($"Aucun fournisseur avec l'ID {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
// Supprimer les liaisons Price avant le fournisseur // Supprimer les liaisons Price avant le fournisseur
@@ -46,6 +46,6 @@ public class DeleteSupplierEndpoint(PyroFetesDbContext pyrofetesdbcontext) : End
await pyrofetesdbcontext.SaveChangesAsync(ct); await pyrofetesdbcontext.SaveChangesAsync(ct);
Console.WriteLine($"Fournisseur {req.Id} et ses prix liés supprimés avec succès."); Console.WriteLine($"Fournisseur {req.Id} et ses prix liés supprimés avec succès.");
await Send.NoContentAsync(ct); //Renvoie une réponse réussite 204 await Send.NoContentAsync(ct);
} }
} }
@@ -11,8 +11,8 @@ public class GetAllSuppliersEndpoint(PyroFetesDbContext pyrofetesdbcontext)
{ {
public override void Configure() public override void Configure()
{ {
Get("/api/suppliers"); //endpoint qui affiche le fournisseur en fonction de l'id Get("/suppliers");
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(CancellationToken ct) public override async Task HandleAsync(CancellationToken ct)
@@ -15,8 +15,8 @@ public class GetSupplierEndpoint(PyroFetesDbContext pyrofetesdbcontext)
{ {
public override void Configure() public override void Configure()
{ {
Get("/api/suppliers/{@id}", x => new { x.Id }); //endpoint qui affiche le fournisseur en fonction de l'id Get("/suppliers/{@id}", x => new { x.Id });
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(GetSupplierRequest req, CancellationToken ct) public override async Task HandleAsync(GetSupplierRequest req, CancellationToken ct)
@@ -28,8 +28,8 @@ public class GetSupplierEndpoint(PyroFetesDbContext pyrofetesdbcontext)
if (supplier == null) if (supplier == null)
{ {
Console.WriteLine($"Aucun fournisseur avec l'ID {req.Id} trouvé."); Console.WriteLine($"Aucun fournisseur avec l'ID {req.Id} trouvé.");
await Send.NotFoundAsync(ct); //Renvoie une erreur 404 await Send.NotFoundAsync(ct);
return; //Arrêt de la méthode return;
} }
var responseDto = new GetSupplierDto var responseDto = new GetSupplierDto
@@ -10,7 +10,7 @@ public class UpdateSupplierEndpoint(PyroFetesDbContext pyrofetesdbcontext) : End
{ {
public override void Configure() public override void Configure()
{ {
Put("/api/suppliers/{@id}", x => new { x.Id }); Put("/suppliers/{@id}", x => new { x.Id });
AllowAnonymous(); AllowAnonymous();
} }
@@ -52,7 +52,7 @@ public class UpdateSupplierEndpoint(PyroFetesDbContext pyrofetesdbcontext) : End
} }
} }
await pyrofetesdbcontext.SaveChangesAsync(ct); //Sauvegarde les changements await pyrofetesdbcontext.SaveChangesAsync(ct);
var response = new GetSupplierDto var response = new GetSupplierDto
{ {
@@ -65,6 +65,6 @@ public class UpdateSupplierEndpoint(PyroFetesDbContext pyrofetesdbcontext) : End
City = supplierToEdit.City City = supplierToEdit.City
}; };
await Send.OkAsync(response, ct); //Envoie de la réponse réussite 200 au client await Send.OkAsync(response, ct);
} }
} }
@@ -6,17 +6,17 @@ using PyroFetes.Models;
namespace PyroFetes.Endpoints.Warehouse; namespace PyroFetes.Endpoints.Warehouse;
public class CreateWarehouseEndpoint(PyroFetesDbContext db) public class CreateWarehouseEndpoint(PyroFetesDbContext db)
: Endpoint<CreateWarehouseDto, GetWarehouseDto> //Instanciation d'une connexion à la bdd dans un endpoint, utilise l'élément de requête CreateWarehouseDto et l'élement de réponse GetWarehouseDto : Endpoint<CreateWarehouseDto, GetWarehouseDto>
{ {
public override void Configure() //Configuration de l'endpoint public override void Configure()
{ {
Post("/api/warehouse"); //Créer un entrepot Post("/warehouse");
AllowAnonymous(); //Autorise l'accès sans authentification AllowAnonymous();
} }
public override async Task HandleAsync(CreateWarehouseDto req, CancellationToken ct) public override async Task HandleAsync(CreateWarehouseDto req, CancellationToken ct)
{ {
var warehouse = new Models.Warehouse //Création d'un nom, d'un poids maximal et minimal, d'une adresse, d'un code postal et du nom de la ville rentré par l'utilisateur var warehouse = new Models.Warehouse
{ {
Name = req.Name, Name = req.Name,
MaxWeight = req.MaxWeight, MaxWeight = req.MaxWeight,
@@ -27,8 +27,8 @@ public class CreateWarehouseEndpoint(PyroFetesDbContext db)
City = req.City City = req.City
}; };
db.Warehouses.Add(warehouse); //Ajout de l'entrepot à la bdd db.Warehouses.Add(warehouse);
await db.SaveChangesAsync(ct); //Sauvegarde de l'entrepot dans la bdd await db.SaveChangesAsync(ct);
// 🔹 Ajout des produits liés à cet entrepôt // 🔹 Ajout des produits liés à cet entrepôt
if (req.Products is not null && req.Products.Any()) if (req.Products is not null && req.Products.Any())
@@ -46,7 +46,7 @@ public class CreateWarehouseEndpoint(PyroFetesDbContext db)
await db.SaveChangesAsync(ct); await db.SaveChangesAsync(ct);
} }
var response = new GetWarehouseDto //renvoie l'id, d'un nom, d'un poids maximal et minimal, d'une adresse, d'un code postal et du nom de la ville var response = new GetWarehouseDto
{ {
Id = warehouse.Id, Id = warehouse.Id,
Name = warehouse.Name, Name = warehouse.Name,
@@ -58,6 +58,6 @@ public class CreateWarehouseEndpoint(PyroFetesDbContext db)
City = warehouse.City City = warehouse.City
}; };
await Send.OkAsync(response, ct); //Réponse au client await Send.OkAsync(response, ct);
} }
} }
@@ -13,7 +13,7 @@ public class DeleteWarehouseEndpoint(PyroFetesDbContext db) : Endpoint<DeleteWar
{ {
public override void Configure() public override void Configure()
{ {
Delete("/api/warehouse/{id}"); Delete("/warehouse/{id}");
AllowAnonymous(); AllowAnonymous();
} }
public override async Task HandleAsync(DeleteWarehouseRequest req, CancellationToken ct) public override async Task HandleAsync(DeleteWarehouseRequest req, CancellationToken ct)
@@ -45,6 +45,6 @@ public class DeleteWarehouseEndpoint(PyroFetesDbContext db) : Endpoint<DeleteWar
await db.SaveChangesAsync(ct); await db.SaveChangesAsync(ct);
Console.WriteLine($"Entrepôt {warehouseToDelete.Name} (ID {req.Id}) supprimé avec succès."); Console.WriteLine($"Entrepôt {warehouseToDelete.Name} (ID {req.Id}) supprimé avec succès.");
await Send.NoContentAsync(ct); //Renvoie une réponse réussite 204 await Send.NoContentAsync(ct);
} }
} }
@@ -1,5 +1,4 @@
using API.DTO.Warehouse.Response; using API.DTO.Warehouse.Response;
using API.DTO.Warehouse.Request;
using FastEndpoints; using FastEndpoints;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
using PyroFetes.Models; using PyroFetes.Models;
@@ -11,36 +10,66 @@ public class GetAllWarehouseEndpoint(PyroFetesDbContext db)
{ {
public override void Configure() public override void Configure()
{ {
Get("/api/warehouses"); Get("/warehouses");
AllowAnonymous(); AllowAnonymous();
} }
public override async Task HandleAsync(CancellationToken ct) public override async Task HandleAsync(CancellationToken ct)
{ {
// 🔹 On inclut les relations avec WarehouseProducts et Product try
var warehouses = await db.Warehouses
.Include(w => w.WarehouseProducts)
.ThenInclude(wp => wp.Product)
.ToListAsync(ct);
var response = warehouses.Select(w => new GetWarehouseDto
{ {
Id = w.Id, // 1. Chargement des entrepôts (sans tracking = plus rapide + plus safe)
Name = w.Name, var warehouses = await db.Warehouses
MaxWeight = w.MaxWeight, .AsNoTracking()
Current = w.Current, .ToListAsync(ct);
MinWeight = w.MinWeight,
Adress = w.Address,
ZipCode = w.ZipCode,
City = w.City,
Products = w.WarehouseProducts.Select(wp => new WarehouseProductDto
{
ProductId = wp.ProductId,
ProductName = wp.Product?.Name,
Quantity = wp.Quantity
}).ToList()
}).ToList();
await Send.OkAsync(response, ct); // 2. Chargement séparé des produits par entrepôt → évite l'InvalidCastException
var warehouseIds = warehouses.Select(w => w.Id).ToList();
var warehouseProducts = await db.WarehouseProducts
.Where(wp => warehouseIds.Contains(wp.WarehouseId))
.Include(wp => wp.Product)
.AsNoTracking()
.ToListAsync(ct);
// 3. Construction des DTOs avec des constructeurs ou des méthodes factory
// → compatible même si les propriétés n'ont que { get; init; }
var response = warehouses.Select(w =>
{
var dto = new GetWarehouseDto();
dto.GetType().GetProperty("Id")?.SetValue(dto, w.Id);
dto.GetType().GetProperty("Name")?.SetValue(dto, w.Name ?? string.Empty);
dto.GetType().GetProperty("MaxWeight")?.SetValue(dto, w.MaxWeight);
dto.GetType().GetProperty("Current")?.SetValue(dto, w.Current);
dto.GetType().GetProperty("MinWeight")?.SetValue(dto, w.MinWeight);
dto.GetType().GetProperty("Adress")?.SetValue(dto, w.Address ?? string.Empty);
dto.GetType().GetProperty("ZipCode")?.SetValue(dto, w.ZipCode);
dto.GetType().GetProperty("City")?.SetValue(dto, w.City ?? string.Empty);
// Products
var productsList = warehouseProducts
.Where(wp => wp.WarehouseId == w.Id)
.Select(wp =>
{
var prodDto = new WarehouseProductDto();
prodDto.GetType().GetProperty("ProductId")?.SetValue(prodDto, wp.ProductId);
prodDto.GetType().GetProperty("ProductName")?.SetValue(prodDto, wp.Product?.Name ?? "Produit inconnu");
prodDto.GetType().GetProperty("Quantity")?.SetValue(prodDto, wp.Quantity);
return prodDto;
})
.ToList();
dto.GetType().GetProperty("Products")?.SetValue(dto, productsList);
return dto;
}).ToList();
await Send.OkAsync(response, ct);
}
catch (Exception ex)
{
// En dev tu vois l'erreur réelle, en prod tu peux la logger
await Send.OkAsync(ct);
}
} }
} }
@@ -16,7 +16,7 @@ public class GetWarehouseEndpoint(PyroFetesDbContext db)
public override void Configure() public override void Configure()
{ {
// Pas de "@id" ici, juste {id} // Pas de "@id" ici, juste {id}
Get("/api/warehouses/{Id}"); Get("/warehouses/{Id}");
AllowAnonymous(); AllowAnonymous();
} }
@@ -24,7 +24,7 @@ public class GetWarehouseEndpoint(PyroFetesDbContext db)
{ {
// 🔹 Inclut les produits associés à cet entrepôt // 🔹 Inclut les produits associés à cet entrepôt
var warehouse = await db.Warehouses var warehouse = await db.Warehouses
.Include(w => w.WarehouseProducts) .Include(w => w.WarehouseProducts)!
.ThenInclude(wp => wp.Product) .ThenInclude(wp => wp.Product)
.SingleOrDefaultAsync(w => w.Id == req.Id, cancellationToken: ct); .SingleOrDefaultAsync(w => w.Id == req.Id, cancellationToken: ct);
@@ -12,7 +12,7 @@ public class UpdateWarehouseEndpoint(PyroFetesDbContext db)
public override void Configure() public override void Configure()
{ {
// Utilise {id} plutôt que {@id} // Utilise {id} plutôt que {@id}
Put("/api/warehouses/{Id}"); Put("/warehouses/{Id}");
AllowAnonymous(); AllowAnonymous();
} }
File diff suppressed because it is too large Load Diff
File diff suppressed because it is too large Load Diff
File diff suppressed because it is too large Load Diff
-13
View File
@@ -1,13 +0,0 @@
# Default ignored files
/shelf/
/workspace.xml
# Rider ignored files
/.idea.Models.iml
/modules.xml
/contentModel.xml
/projectSettingsUpdater.xml
# Editor-based HTTP Client requests
/httpRequests/
# Datasource local storage ignored files
/dataSources/
/dataSources.local.xml
-4
View File
@@ -1,4 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Encoding" addBOMForNewFiles="with BOM under Windows, with no BOM otherwise" />
</project>
-8
View File
@@ -1,8 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="UserContentModel">
<attachedFolders />
<explicitIncludes />
<explicitExcludes />
</component>
</project>
+1 -1
View File
@@ -9,7 +9,7 @@ public class DeliveryNote
public int DelivererId { get; set; } public int DelivererId { get; set; }
[Required] public DateOnly EstimateDeliveryDate { get; set; } [Required] public DateOnly EstimateDeliveryDate { get; set; }
[Required] public DateOnly ExpeditionDate { get; set; } [Required] public DateOnly ExpeditionDate { get; set; }
[Required] public DateOnly RealDeliveryDate { get; set; } public DateOnly? RealDeliveryDate { get; set; }
public Deliverer? Deliverer { get; set; } public Deliverer? Deliverer { get; set; }
public List<ProductDelivery>? ProductDeliveries { get; set; } public List<ProductDelivery>? ProductDeliveries { get; set; }
-13
View File
@@ -1,13 +0,0 @@
using System.ComponentModel.DataAnnotations;
namespace PyroFetes.Models;
public class Login
{
[Key] public int Id { get; set; }
[Required, MaxLength(100)] public string? Username { get; set; }
[Required, MaxLength(200)] public string? FullName { get; set; }
[Required, Length(60, 60)] public string? Password { get; set; }
[Required, Length(24, 24)] public string? Salt { get; set; }
[Required, MaxLength(100)] public string? Role { get; set; }
}
+2 -2
View File
@@ -8,8 +8,8 @@ namespace PyroFetes.Models
[Required, MaxLength(20)] public string? Reference { get; set; } [Required, MaxLength(20)] public string? Reference { get; set; }
[Required, MaxLength(100)] public string? Name { get; set; } [Required, MaxLength(100)] public string? Name { get; set; }
[Required] public decimal Duration {get; set;} [Required] public decimal Duration {get; set;}
[Required] public decimal Caliber { get; set; } [Required] public int Caliber { get; set; }
[Required] public int ApprovalNumber { get; set; } [Required, MaxLength(100)] public string? ApprovalNumber { get; set; }
[Required] public decimal Weight { get; set; } [Required] public decimal Weight { get; set; }
[Required] public decimal Nec { get; set; } [Required] public decimal Nec { get; set; }
[Required] public string? Image { get; set; } [Required] public string? Image { get; set; }
+1 -1
View File
@@ -9,7 +9,7 @@ public class Supplier
[Required, MaxLength(100)] public string? Email { get; set; } [Required, MaxLength(100)] public string? Email { get; set; }
[Required, MaxLength(30)] public string? Phone { get; set; } [Required, MaxLength(30)] public string? Phone { get; set; }
[Required, MaxLength(100)] public string? Address { get; set; } [Required, MaxLength(100)] public string? Address { get; set; }
[Required] public int ZipCode { get; set; } [Required,Length(5,5)] public string? ZipCode { get; set; }
[Required, MaxLength(100)] public string? City { get; set; } [Required, MaxLength(100)] public string? City { get; set; }
[Required] public int DeliveryDelay { get; set; } [Required] public int DeliveryDelay { get; set; }
+1 -1
View File
@@ -6,7 +6,7 @@ public class User
{ {
[Key] public int Id { get; set; } [Key] public int Id { get; set; }
[Required, MaxLength(100)] public string? Name { get; set; } [Required, MaxLength(100)] public string? Name { get; set; }
[Required, MinLength(12), MaxLength(50)] public string? Password { get; set; } [Required, MaxLength(60)] public string? Password { get; set; }
[Required, MaxLength(100)] public string? Salt { get; set; } [Required, MaxLength(100)] public string? Salt { get; set; }
[Required, MaxLength(100)] public string? Email { get; set; } [Required, MaxLength(100)] public string? Email { get; set; }
[Required, MaxLength(100)] public string? Fonction { get; set; } [Required, MaxLength(100)] public string? Fonction { get; set; }
+1 -1
View File
@@ -10,7 +10,7 @@ public class Warehouse
[Required] public int Current {get; set;} [Required] public int Current {get; set;}
[Required] public int MinWeight {get; set;} [Required] public int MinWeight {get; set;}
[Required, MaxLength(100)] public string? Address { get; set; } [Required, MaxLength(100)] public string? Address { get; set; }
[Required] public int ZipCode { get; set; } [Required, Length(5,5)] public string? ZipCode { get; set; }
[Required, MaxLength(100)] public string? City { get; set; } [Required, MaxLength(100)] public string? City { get; set; }
public List<WarehouseProduct>? WarehouseProducts { get; set; } public List<WarehouseProduct>? WarehouseProducts { get; set; }
+28 -15
View File
@@ -1,29 +1,42 @@
using API;
using FastEndpoints; using FastEndpoints;
using FastEndpoints.Swagger; using FastEndpoints.Swagger;
using PyroFetes; using PyroFetes;
using FastEndpoints.Security;
WebApplicationBuilder builder = WebApplication.CreateBuilder(args); WebApplicationBuilder builder = WebApplication.CreateBuilder(args);
// On ajoute ici FastEndpoints, un framework REPR et Swagger aux services disponibles dans le projet // Services
builder.Services builder.Services.AddCors(options =>
.AddAuthenticationJwtBearer(s => s.SigningKey = "ThisIsASuperSecretJwtKeyThatIsAtLeast32CharsLong") options.AddDefaultPolicy(policyBuilder =>
.AddAuthorization() policyBuilder
.AddFastEndpoints() .WithOrigins("http://localhost:4200") // mettre le port Angular exact
.SwaggerDocument(); .WithMethods("GET", "POST", "PUT", "PATCH", "DELETE")
.AllowAnyHeader()
)
);
builder.Services.AddFastEndpoints().SwaggerDocument(options =>
{
options.ShortSchemaNames = true;
});
// On ajoute ici la configuration de la base de données
builder.Services.AddDbContext<PyroFetesDbContext>(); builder.Services.AddDbContext<PyroFetesDbContext>();
// On construit l'application en lui donnant vie
WebApplication app = builder.Build(); WebApplication app = builder.Build();
app.UseAuthentication()
.UseAuthorization()
.UseFastEndpoints()
.UseSwaggerGen();
// Middleware
app.UseHttpsRedirection(); app.UseHttpsRedirection();
// CORS doit être avant les endpoints
app.UseCors();
// FastEndpoints et Swagger
app.UseFastEndpoints(options =>
{
options.Endpoints.RoutePrefix = "API";
options.Endpoints.ShortNames = true;
}).UseSwaggerGen();
// app.UseAuthorization();
// app.UseAuthentication();
app.Run(); app.Run();
+4
View File
@@ -22,4 +22,8 @@
<PackageReference Include="Swashbuckle.AspNetCore" Version="6.6.2" /> <PackageReference Include="Swashbuckle.AspNetCore" Version="6.6.2" />
</ItemGroup> </ItemGroup>
<ItemGroup>
<Folder Include="Migrations\" />
</ItemGroup>
</Project> </Project>
-1
View File
@@ -49,7 +49,6 @@ public class PyroFetesDbContext : DbContext
public DbSet<User> Users { get; set; } public DbSet<User> Users { get; set; }
public DbSet<Warehouse> Warehouses { get; set; } public DbSet<Warehouse> Warehouses { get; set; }
public DbSet<WarehouseProduct> WarehouseProducts { get; set; } public DbSet<WarehouseProduct> WarehouseProducts { get; set; }
public DbSet<Login> Logins { get; set; }
// Database configuration // Database configuration
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder) protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)