Merge pull request #81 from GeneriekPublicatiePlatformWoo/39-informat…

…iecategorieen-toekennen

39 informatiecategorieen toekennen

ODPC.Server/Apis/Odrc/OdrcClientFactory.cs

@@ -5,12 +5,12 @@ namespace ODPC.Apis.Odrc
 {
     public interface IOdrcClientFactory
     {
-        HttpClient Create(OdpUser user, string handeling);
+        HttpClient Create(string handeling);
     }
 
-    public class OdrcClientFactory(IHttpClientFactory httpClientFactory, IConfiguration config) : IOdrcClientFactory
+    public class OdrcClientFactory(IHttpClientFactory httpClientFactory, IConfiguration config, OdpcUser user) : IOdrcClientFactory
     {
-        public HttpClient Create(OdpUser user, string? handeling)
+        public HttpClient Create(string? handeling)
         {
             var client = httpClientFactory.CreateClient();
             client.BaseAddress = new(config["ODRC_BASE_URL"]!);

ODPC.Server/Apis/Odrc/PagedResponseModel.cs

@@ -2,7 +2,7 @@
 {
     public class PagedResponseModel<T>
     {
-        public List<T> results { get; set; }
+        public required IReadOnlyList<T> Results { get; set; }
         public int Count { get; set; }
         public string? Next { get; set; }
         public string? Previous { get; set; }

ODPC.Server/Apis/Odrc/WaardelijstResponseModel.cs

@@ -1,13 +1,8 @@
-using System.ComponentModel;
-using System.Text.Json.Serialization;
-
-namespace ODPC.Apis.Odrc
+namespace ODPC.Apis.Odrc
 {
     public class WaardelijstResponseModel
-    {       
-            [JsonPropertyName("uuid")]
-            public required string Id { get; set; }
-            [JsonPropertyName("naam")]
-            public required string Name { get; set; }    
+    {
+        public required string Uuid { get; set; }
+        public required string Naam { get; set; }
     }
 }

ODPC.Server/Authentication/AuthenticationExtensions.cs

@@ -22,14 +22,14 @@ public static void AddAuth(this IServiceCollection services, Action<AuthOptions>
 
             services.AddHttpContextAccessor();
 
-            services.AddScoped<OdpUser>(s =>
+            services.AddScoped<OdpcUser>(s =>
             {
                 var user = s.GetRequiredService<IHttpContextAccessor>().HttpContext?.User;
                 var isLoggedIn = user?.Identity?.IsAuthenticated ?? false;
                 var name = user?.FindFirst(nameClaimType)?.Value;
                 var id = user?.FindFirst(x => idClaimTypes.Contains(x.Type))?.Value;
                 var roles = user?.FindAll(roleClaimType).Select(x=> x.Value).ToArray() ?? [];
-                return new OdpUser { IsLoggedIn = isLoggedIn, FullName = name, Id = id, Roles = roles };
+                return new OdpcUser { IsLoggedIn = isLoggedIn, FullName = name, Id = id, Roles = roles };
             });
 
             var authBuilder = services.AddAuthentication(options =>
@@ -107,7 +107,7 @@ public static void AddAuth(this IServiceCollection services, Action<AuthOptions>
         public static IEndpointRouteBuilder MapOdpcAuthEndpoints(this IEndpointRouteBuilder endpoints)
         {
             endpoints.MapGet("api/logoff", LogoffAsync).AllowAnonymous();
-            endpoints.MapGet("api/me", (OdpUser user) => user).AllowAnonymous();
+            endpoints.MapGet("api/me", (OdpcUser user) => user).AllowAnonymous();
             endpoints.MapGet("api/challenge", ChallengeAsync).AllowAnonymous();
 
             return endpoints;

ODPC.Server/Authentication/OdpUser.cs → ODPC.Server/Authentication/OdpcUser.cs

@@ -1,6 +1,6 @@
 namespace ODPC.Authentication
 {
-    public record OdpUser
+    public record OdpcUser
     {
         public required bool IsLoggedIn { get; init; }
         public required string? Id { get; init; }

ODPC.Server/Features/GebruikerWaardelijstItemsService.cs

@@ -0,0 +1,27 @@
+using Microsoft.EntityFrameworkCore;
+using ODPC.Authentication;
+using ODPC.Data;
+
+namespace ODPC.Features
+{
+    public interface IGebruikerWaardelijstItemsService
+    {
+        Task<IReadOnlyList<string>> GetAsync(CancellationToken token);
+    }
+
+    public class GebruikerWaardelijstItemsService(OdpcUser user, OdpcDbContext context) : IGebruikerWaardelijstItemsService
+    {
+        public async Task<IReadOnlyList<string>> GetAsync(CancellationToken token)
+        {
+            var groepIds = context.GebruikersgroepGebruikers
+                .Where(x => x.GebruikerId == user.Id)
+                .Select(x => x.GebruikersgroepUuid);
+
+            return await context.GebruikersgroepWaardelijsten
+                .Where(x => groepIds.Contains(x.GebruikersgroepUuid))
+                .Select(x => x.WaardelijstId)
+                .Distinct()
+                .ToListAsync(token);
+        }
+    }
+}

ODPC.Server/Features/Informatiecategorieen/AlleInformatiecategorieen/InformatiecategorieenController.cs

@@ -0,0 +1,28 @@
+using System.Text.Json.Nodes;
+using Microsoft.AspNetCore.Mvc;
+using ODPC.Apis.Odrc;
+
+namespace ODPC.Features.Informatiecategorieen.AlleInformatiecategorieen
+{
+    [ApiController]
+    public class InformatiecategorieenController(IOdrcClientFactory clientFactory) : ControllerBase
+    {
+        [HttpGet("api/v1/informatiecategorieen")]
+        public async Task<IActionResult> Get([FromQuery] string? page, CancellationToken token)
+        {
+            //infocategorien ophalen uit het ODRC
+            using var client = clientFactory.Create("Alle informatiecategorieen ophalen");
+            var json = await client.GetFromJsonAsync<PagedResponseModel<JsonNode>>("/api/v1/informatiecategorieen?page=" + page, token);
+            if (json != null)
+            {
+                json.Previous = GetPathAndQuery(json.Previous);
+                json.Next = GetPathAndQuery(json.Next);
+            }
+            return Ok(json);
+        }
+
+        private static string? GetPathAndQuery(string? url) => Uri.TryCreate(url, UriKind.RelativeOrAbsolute, out var uri) 
+            ? uri.PathAndQuery 
+            : url;
+    }
+}

ODPC.Server/Features/Informatiecategorieen/MijnInformatiecategorieen/MijnInformatiecategorieenController.cs

@@ -0,0 +1,38 @@
+using System.Runtime.CompilerServices;
+using System.Text.Json.Nodes;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.EntityFrameworkCore;
+using ODPC.Apis.Odrc;
+
+namespace ODPC.Features.Informatiecategorieen.MijnInformatiecategorieen
+{
+    [ApiController]
+    public class MijnInformatiecategorieenController(IOdrcClientFactory clientFactory, IGebruikerWaardelijstItemsService waardelijstItemsService) : ControllerBase
+    {
+        [HttpGet("api/v1/mijn-informatiecategorieen")]
+        public async IAsyncEnumerable<JsonObject> Get([EnumeratorCancellation] CancellationToken token)
+        {
+            var categorieen = await waardelijstItemsService.GetAsync(token);
+
+            if (categorieen.Count == 0) yield break;
+
+            using var client = clientFactory.Create("Eigen informatiecategorieen ophalen");
+            var url = "api/v1/informatiecategorieen";
+
+            // omdat we zelf moeten filteren obv van de waardelijstitems waar de gebruiker toegang toe heeft,
+            // kunnen we geen paginering gebruiker. we lopen door alle pagina's van de ODRC
+            while (!string.IsNullOrWhiteSpace(url))
+            {
+                var page = await client.GetFromJsonAsync<PagedResponseModel<JsonObject>>(url, token) ?? new() { Results = [] };
+                foreach (var item in page.Results)
+                {
+                    if (item["uuid"]?.GetValue<string>() is string uuid && categorieen.Contains(uuid))
+                    {
+                        yield return item;
+                    }
+                }
+                url = page?.Next;
+            }
+        }
+    }
+}

ODPC.Server/Features/Organisaties/AlleOrganisaties/OrganisatiesController.cs

@@ -0,0 +1,16 @@
+using Microsoft.AspNetCore.Mvc;
+using ODPC.Apis.Odrc;
+
+namespace ODPC.Features.Organisaties.AlleOrganisaties
+{
+    [ApiController]
+    public class OrganisatiesController : ControllerBase
+    {
+        [HttpGet("api/v1/organisaties")]
+        public IActionResult Get([FromQuery] string? page) => Ok(new PagedResponseModel<WaardelijstResponseModel>
+        {
+            Results = OrganisatiesMock.Organisaties.Values.ToList(),
+            Count = OrganisatiesMock.Organisaties.Count,
+        });
+    }
+}

ODPC.Server/Features/Organisaties/OrganisatiesMock.cs

@@ -0,0 +1,13 @@
+using ODPC.Apis.Odrc;
+
+namespace ODPC.Features.Organisaties
+{
+    public class OrganisatiesMock
+    {
+        public static readonly Dictionary<string, WaardelijstResponseModel> Organisaties = new WaardelijstResponseModel[]
+        {
+            new() { Uuid = "8f939b51-dad3-436d-a5fa-495b42317d64", Naam = "Organisatie 2" },
+            new() { Uuid = "5c14e7e2-00a2-4990-adbb-7290cd89fb6e", Naam = "Organisatie 3" }
+        }.ToDictionary(x => x.Uuid);
+    }
+}

ODPC.Server/Features/Publicaties/Publicatie.cs

@@ -7,6 +7,7 @@ public class Publicatie
         public string? VerkorteTitel { get; set; }
         public string? Omschrijving { get; set; }
         public DateTime Registratiedatum { get; set; }
-        public string Status { get; set; }
+        public string? Status { get; set; }
+        public List<string>? GekoppeldeInformatiecategorieen { get; set; }
     }
 }

ODPC.Server/Features/Publicaties/PublicatieBijwerken/PublicatieBijwerkenController.cs

@@ -3,11 +3,19 @@
 namespace ODPC.Features.Publicaties.PublicatieBijwerken
 {
     [ApiController]
-    public class PublicatieBijwerkenController : ControllerBase
+    public class PublicatieBijwerkenController(IGebruikerWaardelijstItemsService waardelijstItemsService) : ControllerBase
     {
         [HttpPut("api/v1/publicaties/{uuid}")]
-        public IActionResult Put(Guid uuid, Publicatie publicatie)
+        public async Task<IActionResult> Put(Guid uuid, Publicatie publicatie, CancellationToken token)
         {
+            var categorieen = await waardelijstItemsService.GetAsync(token);
+
+            if (publicatie.GekoppeldeInformatiecategorieen != null && publicatie.GekoppeldeInformatiecategorieen.Any(c => !categorieen.Contains(c)))
+            {
+                ModelState.AddModelError(nameof(publicatie.GekoppeldeInformatiecategorieen), "Gebruiker is niet geautoriseerd voor deze informatiecategorieën");
+                return BadRequest(ModelState);
+            }
+
             PublicatiesMock.Publicaties[uuid] = publicatie;
             return Ok(publicatie);
         }

ODPC.Server/Features/Publicaties/PublicatieRegistreren/PublicatieRegistrerenController.cs

@@ -1,37 +1,40 @@
-using System.Text.Json;
-using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.Mvc;
 using ODPC.Apis.Odrc;
-using ODPC.Authentication;
-using ODPC.Config;
 
 namespace ODPC.Features.Publicaties.PublicatieRegistreren
 {
     [ApiController]
-    public class PublicatieRegistrerenController(OdpUser user, IOdrcClientFactory clientFactory) : ControllerBase
+    public class PublicatieRegistrerenController(IOdrcClientFactory clientFactory, IGebruikerWaardelijstItemsService waardelijstItemsService) : ControllerBase
     {
         private readonly IOdrcClientFactory _clientFactory = clientFactory;
 
         [HttpPost("api/v1/publicaties")]
-        public async Task<IActionResult> Post(Publicatie publicatie)
+        public async Task<IActionResult> Post(Publicatie publicatie, CancellationToken token)
         {
-            publicatie.Uuid = Guid.NewGuid();
-            publicatie.Registratiedatum = DateTime.Now;
+            var categorieen = await waardelijstItemsService.GetAsync(token);
 
-            //de mock laten we er nog even in totdat ook het ophalen van gegevens via het register verloopt
-            PublicatiesMock.Publicaties[publicatie.Uuid] = publicatie;
+            if (publicatie.GekoppeldeInformatiecategorieen != null && publicatie.GekoppeldeInformatiecategorieen.Any(c => !categorieen.Contains(c)))
+            {
+                ModelState.AddModelError(nameof(publicatie.GekoppeldeInformatiecategorieen), "Gebruiker is niet geautoriseerd voor deze informatiecategorieën");
+                return BadRequest(ModelState);
+            }
 
-            var client = _clientFactory.Create(user, "Publicatie geregistreerd");
+            var client = _clientFactory.Create("Publicatie geregistreerd");
+            var response = await client.PostAsJsonAsync("/api/v1/publicaties", publicatie, token);
 
-            var response = await client.PostAsJsonAsync("/api/v1/publicaties", publicatie, new CancellationToken());
-
             response.EnsureSuccessStatusCode();
-
-            var responseBody = await response.Content.ReadAsStringAsync();                   
+            var viewModel = await response.Content.ReadFromJsonAsync<Publicatie>(token);
 
-            var viewModel = JsonSerializer.Deserialize<Publicatie>(responseBody, JsonSerialization.Options);
+            // TODO deze regel kan eraf als deze story is geimplementeerd: https://github.com/GeneriekPublicatiePlatformWoo/registratie-component/issues/48
+            viewModel!.GekoppeldeInformatiecategorieen = publicatie.GekoppeldeInformatiecategorieen;
+
+            // TODO deze regel kan eraf als deze story is geimplementeerd: https://github.com/GeneriekPublicatiePlatformWoo/registratie-component/issues/49
+            viewModel!.Status = publicatie.Status;
+
+            // TODO de mock laten we er nog even in totdat ook het ophalen van gegevens via het register verloopt: https://github.com/GeneriekPublicatiePlatformWoo/Openbaar-Documenten-Publicatie-Component/issues/68
+            PublicatiesMock.Publicaties[viewModel!.Uuid] = viewModel;
 
             return Ok(viewModel);
         }
-
     }
 }