Jasper-564(DARS)

SCV.sln

@@ -12,6 +12,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "db", "db\db.csproj", "{E15B
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "pcss-client", "pcss-client\pcss-client.csproj", "{C1736008-CC5B-40AC-A0A4-48C85E49067F}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "dars-client", "dars-client\dars-client.csproj", "{764F912A-D0FA-4272-ADEF-1335B8BE8D9C}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -38,6 +40,10 @@ Global
 		{C1736008-CC5B-40AC-A0A4-48C85E49067F}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{C1736008-CC5B-40AC-A0A4-48C85E49067F}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{C1736008-CC5B-40AC-A0A4-48C85E49067F}.Release|Any CPU.Build.0 = Release|Any CPU
+		{764F912A-D0FA-4272-ADEF-1335B8BE8D9C}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{764F912A-D0FA-4272-ADEF-1335B8BE8D9C}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{764F912A-D0FA-4272-ADEF-1335B8BE8D9C}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{764F912A-D0FA-4272-ADEF-1335B8BE8D9C}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

api/Controllers/DarsController.cs

@@ -0,0 +1,94 @@
+using DARSCommon.Clients.LogNotesServices;
+using DARSCommon.Models;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Logging;
+using Scv.Api.Infrastructure.Authorization;
+using Scv.Api.Services;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace Scv.Api.Controllers
+{
+    [Authorize(AuthenticationSchemes = "SiteMinder, OpenIdConnect", Policy = nameof(ProviderAuthorizationHandler))]
+    [Route("api/[controller]")]
+    [ApiController]
+    public class DarsController(IDarsService darsService, ILogger<DarsController> logger) : ControllerBase
+    {
+        /// <summary>
+        /// Search for DARS audio recordings by date, location, and court room.
+        /// </summary>
+        /// <param name="date">The date to search for recordings</param>
+        /// <param name="locationId">The location ID</param>
+        /// <param name="courtRoomCd">The court room code</param>
+        /// <returns>A collection of audio recording log notes</returns>
+        [HttpGet("search")]
+        [ProducesResponseType(typeof(IEnumerable<DarsSearchResults>), 200)]
+        [ProducesResponseType(400)]
+        [ProducesResponseType(404)]
+        [ProducesResponseType(500)]
+        public async Task<IActionResult> Search(DateTime date, int locationId, string courtRoomCd)
+        {
+            logger.LogInformation(
+                "DARS search requested - Date: {Date}, LocationId: {LocationId}, CourtRoom: {CourtRoom}",
+                date,
+                locationId,
+                courtRoomCd
+            );
+
+            // Validate input parameters
+            if (locationId <= 0)
+            {
+                logger.LogWarning("Invalid locationId provided: {LocationId}", locationId);
+                return BadRequest("LocationId must be greater than 0.");
+            }
+
+            try
+            {
+                var result = await darsService.DarsApiSearch(date, locationId, courtRoomCd);
+
+                if (result == null || !result.Any())
+                {
+                    logger.LogInformation(
+                        "No DARS recordings found for Date: {Date}, LocationId: {LocationId}, CourtRoom: {CourtRoom}",
+                        date,
+                        locationId,
+                        courtRoomCd
+                    );
+                    return NotFound();
+                }
+
+                logger.LogInformation(
+                    "Found {Count} DARS recording(s) for Date: {Date}, LocationId: {LocationId}, CourtRoom: {CourtRoom}",
+                    result.Count(),
+                    date,
+                    locationId,
+                    courtRoomCd
+                );
+
+                return Ok(result);
+            }
+            catch (ApiException ex)
+            {
+                logger.LogError(
+                    ex,
+                    "DARS API exception while searching - Date: {Date}, LocationId: {LocationId}, CourtRoom: {CourtRoom}, Status: {StatusCode}",
+                    date,
+                    locationId,
+                    courtRoomCd,
+                    ex.StatusCode
+                );
+
+                // Return 404 for not found from upstream API
+                if (ex.StatusCode == 404)
+                {
+                    return NotFound();
+                }
+
+                return StatusCode(500, "An error occurred while searching for audio recordings.");
+            }
+        }
+    }
+}

api/Infrastructure/Mappings/DarsMapping.cs

@@ -0,0 +1,19 @@
+using Mapster;
+using DARSCommon.Clients.LogNotesServices;
+using DARSCommon.Models;
+
+namespace Scv.Api.Infrastructure.Mappings;
+
+public class DarsMapping : IRegister
+{
+    public void Register(TypeAdapterConfig config)
+    {
+        config.NewConfig<Lognotes, DarsSearchResults>()
+            .Map(dest => dest.Date, src => src.DateTime)
+            .Map(dest => dest.LocationId, src => src.Location)
+            .Map(dest => dest.CourtRoomCd, src => src.Room)
+            .Map(dest => dest.Url, src => src.Url)
+            .Map(dest => dest.FileName, src => src.FileName)
+            .Map(dest => dest.LocationNm, src => src.LocationName);
+    }
+}

api/Infrastructure/ServiceCollectionExtensions.cs

@@ -44,6 +44,8 @@
 using PCSSPersonServices = PCSSCommon.Clients.PersonServices;
 using PCSSReportServices = PCSSCommon.Clients.ReportServices;
 using PCSSSearchDateServices = PCSSCommon.Clients.SearchDateServices;
+using LogNotesServices = DARSCommon.Clients.LogNotesServices;
+using Microsoft.AspNetCore.Hosting;
 
 namespace Scv.Api.Infrastructure
 {
@@ -186,6 +188,9 @@ public static IServiceCollection AddHttpClientsAndScvServices(this IServiceColle
             services
                 .AddHttpClient<PCSSPersonServices.PersonServicesClient>(client => { ConfigureHttpClient(client, configuration, "PCSS"); })
                 .AddHttpMessageHandler<TimingHandler>();
+            services
+                .AddHttpClient<LogNotesServices.LogNotesServicesClient>(client => { ConfigureHttpClient(client, configuration, "DARS"); })
+                .AddHttpMessageHandler<TimingHandler>();
 
             services.AddHttpContextAccessor();
             services.AddTransient(s => s.GetService<IHttpContextAccessor>()?.HttpContext?.User);
@@ -194,6 +199,7 @@ public static IServiceCollection AddHttpClientsAndScvServices(this IServiceColle
             services.AddScoped<LocationService>();
             services.AddScoped<CourtListService>();
             services.AddScoped<VcCivilFileAccessHandler>();
+            services.AddScoped<DarsService>();
             services.AddSingleton<JCUserService>();
             services.AddSingleton<AesGcmEncryption>();
             services.AddSingleton<JudicialCalendarService>();
@@ -210,6 +216,7 @@ public static IServiceCollection AddHttpClientsAndScvServices(this IServiceColle
                 services.AddScoped<ICrudService<GroupDto>, GroupService>();
                 services.AddScoped<ICaseService, CaseService>();
                 services.AddScoped<IUserService, UserService>();
+                services.AddScoped<IDarsService, DarsService>();
                 services.AddScoped<IBinderFactory, BinderFactory>();
                 services.AddScoped<IBinderService, BinderService>();
                 services.AddTransient<IRecurringJob, SyncDocumentCategoriesJob>();

api/Models/Civil/Appearances/CivilAppearance.cs

@@ -13,6 +13,7 @@ public class CivilAppearance : JCCommon.Clients.FileServices.CivilAppearanceDeta
         public string AppearanceStatusDsc { get; set; }
         public string CourtLocationId { get; set; }
         public string CourtLocation { get; set; }
+        public string LocationId { get; set; } //PCSS - DARS location id.
         public string DocumentTypeDsc { get; set; }
         [AdaptIgnore]
         [JsonIgnore]

api/Models/Criminal/Appearances/CriminalAppearanceDetail.cs

@@ -15,6 +15,7 @@ public class CriminalAppearanceDetail : JCCommon.Clients.FileServices.CriminalAp
         public string AppearanceReasonDsc { get; set; }
         public string AppearanceResultDsc { get; set; }
         public string AppearanceStatusDsc { get; set; }
+        public string LocationId { get; set; } // The location id from PCSS, DARS.
         public string CourtLocationId { get; set; }
         public string CourtLocation { get; set; }
         [AdaptIgnore]

api/Services/DarsService.cs

@@ -0,0 +1,81 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using DARSCommon.Clients.LogNotesServices;
+using DARSCommon.Models;
+using MapsterMapper;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+using Scv.Api.Helpers;
+
+namespace Scv.Api.Services
+{
+    public interface IDarsService
+    {
+        Task<IEnumerable<DarsSearchResults>> DarsApiSearch(DateTime date, int locationId, string courtRoomCd);
+    }
+    public class DarsService(
+        IConfiguration configuration,
+        ILogger<DarsService> logger,
+        LogNotesServicesClient logNotesServicesClient,
+        IMapper mapper) : IDarsService
+    {
+
+        #region Variables
+        private readonly string _logsheetBaseUrl = configuration.GetNonEmptyValue("DARS:LogsheetUrl");
+
+        #endregion Variables
+
+        public async Task<IEnumerable<DarsSearchResults>> DarsApiSearch(DateTime date, int locationId, string courtRoomCd)
+        {
+            logger.LogInformation("DarsApiSearch called for LocationId: {LocationId}, CourtRoomCd: {CourtRoomCd}, Date: {Date}", locationId, courtRoomCd, date.ToString("yyyy-MM-dd"));
+            var darsResult = await logNotesServicesClient.GetBaseAsync(room: courtRoomCd, datetime: date, location: locationId);
+            logger.LogInformation("DarsApiSearch returned {ResultCount} results for LocationId: {LocationId}, CourtRoomCd: {CourtRoomCd}, Date: {Date}", darsResult?.Count() ?? 0, locationId, courtRoomCd, date.ToString("yyyy-MM-dd"));
+            var mappedResults = mapper.Map<IEnumerable<DarsSearchResults>>(darsResult).ToList();
+
+            // Use LINQ's Select to append the base URL to each result's Url property
+            var resultsWithUrl = mappedResults
+                .Select(result =>
+                {
+                    if (!string.IsNullOrWhiteSpace(result.Url) && !string.IsNullOrWhiteSpace(_logsheetBaseUrl))
+                    {
+                        result.Url = $"{_logsheetBaseUrl.TrimEnd('/')}/{result.Url.TrimStart('/')}";
+                    }
+                    return result;
+                })
+                .ToList();
+
+            var darsResultsPerRoom = GetResultPerRoom(resultsWithUrl);
+            return darsResultsPerRoom;
+        }
+
+        // only return result for each room, preferring CCD json, then FLS, then CCD html.
+        // Note: multiple logsheets should be returned if there are multiple (FLS only) logsheets. CODE ORIGINALLY FROM PCSS.
+        private static List<DarsSearchResults> GetResultPerRoom(List<DarsSearchResults> allResults)
+        {
+            var resultsForRoom = allResults.GroupBy(result => result.CourtRoomCd);
+            List<DarsSearchResults> filteredResults = new List<DarsSearchResults>(allResults.Count);
+            foreach (IGrouping<string, DarsSearchResults> roomResults in resultsForRoom)
+            {
+                var actualResult = roomResults.FirstOrDefault(roomResult => roomResult.FileName != null && roomResult.FileName.ToLowerInvariant().Contains("json"));
+                if (actualResult != null)
+                {
+                    filteredResults.Add(actualResult);
+                }
+                var flsResults = roomResults.Where(roomResult => roomResult.FileName != null && roomResult.FileName.ToLowerInvariant().Contains("fls")).ToList();
+                if (flsResults.Count >= 1)
+                {
+                    filteredResults.AddRange(flsResults);
+                    continue;
+                }
+                if (actualResult == null)
+                {
+                    filteredResults.Add(roomResults.FirstOrDefault());
+                }
+
+            }
+            return filteredResults;
+        }
+    }
+}

api/Services/Files/CivilFilesService.cs

@@ -370,6 +370,7 @@ private async Task<CivilAppearanceResponse> PopulateDetailAppearancesAsync(Futur
                 appearance.AppearanceStatusDsc = await _lookupService.GetCivilAppearanceStatusDescription(appearance.AppearanceStatusCd.ToString());
                 appearance.CourtLocationId = await _locationService.GetLocationAgencyIdentifier(appearance.CourtAgencyId);
                 appearance.CourtLocation = await _locationService.GetLocationName(appearance.CourtAgencyId);
+                appearance.LocationId = await _locationService.GetLocationId(appearance.CourtAgencyId);
                 appearance.DocumentTypeDsc = await _lookupService.GetDocumentDescriptionAsync(appearance.DocumentTypeCd);
             }
             return civilAppearances;

api/Services/Files/CriminalFilesService.cs

@@ -268,6 +268,7 @@ private async Task<CriminalFileAppearances> PopulateDetailsAppearancesAsync(stri
                 tasks.Add(Task.Run(async () => appearance.AppearanceStatusDsc = await _lookupService.GetCriminalAppearanceStatusDescription(appearance.AppearanceStatusCd.ToString())));
                 tasks.Add(Task.Run(async () => appearance.CourtLocationId = await _locationService.GetLocationAgencyIdentifier(appearance.CourtAgencyId)));
                 tasks.Add(Task.Run(async () => appearance.CourtLocation = await _locationService.GetLocationName(appearance.CourtAgencyId)));
+                appearance.LocationId = await _locationService.GetLocationId(appearance.CourtAgencyId);
             }
 
             await Task.WhenAll(tasks);

api/Services/LocationService.cs

@@ -84,7 +84,13 @@ public virtual async Task<string> GetLocationShortName(string locationId)
         public async Task<string> GetLocationCodeFromId(string code)
         {
             var locations = await GetLocations();
-            return locations.FirstOrDefault(loc => loc.LocationId == code)?.Code;
+            return locations.FirstOrDefault(loc => loc.Code == code)?.Code;
+        }
+
+        public async Task<string> GetLocationId(string code)
+        {
+            var locations = await GetLocations();
+            return locations.FirstOrDefault(loc => loc.Code == code)?.LocationId;
         }
 
         public async Task<string> GetLocationAgencyIdentifier(string code) => FindShortDescriptionFromCode(await GetLocations(), code);

api/api.csproj

@@ -39,6 +39,7 @@
     <PackageReference Include="EFCore.NamingConventions" Version="9.0.0" />
   </ItemGroup>
   <ItemGroup>
+    <ProjectReference Include="..\dars-client\dars-client.csproj" />
     <ProjectReference Include="..\db\db.csproj" />
     <ProjectReference Include="..\jc-interface-client\jc-interface-client.csproj" />
     <ProjectReference Include="..\pcss-client\pcss-client.csproj" />

api/appsettings.Development.json

@@ -1,9 +1,13 @@
 {
   "Logging": {
     "LogLevel": {
-      "Default": "Information",
+      "Default": "Debug",
       "Microsoft": "Warning",
       "Microsoft.Hosting.Lifetime": "Information"
     }
+  },
+  "DARS": {
+    "LogsheetUrl": "https://test.jag.gov.bc.ca/darspc/",
+    "URL": "https://wsgw.test.jag.gov.bc.ca/courts/DARS"
   }
 }

api/appsettings.json

@@ -23,6 +23,9 @@
     "FileExpiryMinutes": "2"
   },
   "MaximumArchiveDocumentCount": "100",
-  "ExcludeDocumentTypeCodesForCounsel": "IPR,SRR,RFR,SCL,VOC,CAR,RFS,RFSR,WAA,WAE,WAW,WFA,WOA,WOC,WOI,FULL,OI,FF"
-}
-
+  "ExcludeDocumentTypeCodesForCounsel": "IPR,SRR,RFR,SCL,VOC,CAR,RFS,RFSR,WAA,WAE,WAW,WFA,WOA,WOC,WOI,FULL,OI,FF",
+  "DARS": {
+    "LogsheetUrl": "https://jag.gov.bc.ca/darspc/",
+    "URL": "https://wsgw.jag.gov.bc.ca/courts/DARS"
+  }
+}