Merge pull request #775 from bcgov/yj

ychung-mot · web-flow · commit 24224bae791b · 2024-11-06T10:50:23.000-08:00
Yj
diff --git a/server/StrDss.Api/Controllers/DelistingController.cs b/server/StrDss.Api/Controllers/DelistingController.cs
@@ -211,6 +211,27 @@ public async Task<ActionResult> SendBatchtakedownNotice([FromForm] BatchTakedown
             return NoContent();
         }
 
+        [ApiAuthorize(Permissions.ProvinceAction)]
+        [HttpPost("complianceorders/preview", Name = "GetComplianceOrdersFromListingPreview")]
+        public async Task<ActionResult> GetComplianceOrdersFromListingPreview(ComplianceOrderDto[] requests)
+        {
+            await Task.CompletedTask;
+
+            var preview = new EmailPreview
+            {
+                Content = "To: john.doe@my.email, jane.smith@my.email<br/><br/><br/>Bcc: young-jin.chung@gov.bc.ca<br/><br/>\r\nDear Host,<br/><br/>\r\nThis message has been sent to you by B.C.'s Short-Term Rental Compliance Unit regarding your short-term rental<br/>\r\nlisting: <b>https://example.com/1000012/</b><br/><br/>\r\ntesting<br/>\r\n"
+            };
+
+            return Ok(preview);
+        }
+
+        [ApiAuthorize(Permissions.ProvinceAction)]
+        [HttpPost("complianceorders", Name = "CreateComplianceOrdersFromListingPreview")]
+        public async Task<ActionResult> CreateComplianceOrdersFromListingPreview(ComplianceOrderDto[] requests)
+        {
+            await Task.CompletedTask;
 
+            return NoContent();
+        }
     }
 }
diff --git a/server/StrDss.Api/Program.cs b/server/StrDss.Api/Program.cs
@@ -221,17 +221,17 @@
 
 app.Use(async (context, next) =>
 {
-    context.Response.Headers.Add("content-security-policy", $"default-src 'self'; style-src 'self' 'img-src 'self' data:; frame-ancestors 'self'; object-src 'none'; base-uri 'self'; form-action 'self';");
-    context.Response.Headers.Add("strict-transport-security", "max-age=15768000; includeSubDomains; preload");
-    context.Response.Headers.Add("x-content-type-options", "nosniff");
-    context.Response.Headers.Add("x-frame-options", "SAMEORIGIN");
-    context.Response.Headers.Add("x-xss-protection", "0");
-    context.Response.Headers.Add("permissions-policy", "geolocation=(),midi=(),sync-xhr=(),microphone=(),camera=(),magnetometer=(),gyroscope=(),fullscreen=(self),payment=()");
-    context.Response.Headers.Add("referrer-policy", "strict-origin");
-    context.Response.Headers.Add("x-dns-prefetch-control", "off");
-    context.Response.Headers.Add("cache-control", "no-cache, no-store, must-revalidate");
-    context.Response.Headers.Add("pragma", "no-cache");
-    context.Response.Headers.Add("expires", "0");
+    context.Response.Headers.Append("content-security-policy", $"default-src 'self'; style-src 'self'; img-src 'self' data:; frame-ancestors 'self'; object-src 'none'; base-uri 'self'; form-action 'self';");
+    context.Response.Headers.Append("strict-transport-security", "max-age=15768000; includeSubDomains; preload");
+    context.Response.Headers.Append("x-content-type-options", "nosniff");
+    context.Response.Headers.Append("x-frame-options", "SAMEORIGIN");
+    context.Response.Headers.Append("x-xss-protection", "0");
+    context.Response.Headers.Append("permissions-policy", "geolocation=(), midi=(), sync-xhr=(), microphone=(), camera=(), magnetometer=(), gyroscope=(), fullscreen=(self), payment=()");
+    context.Response.Headers.Append("referrer-policy", "strict-origin");
+    context.Response.Headers.Append("x-dns-prefetch-control", "off");
+    context.Response.Headers.Append("cache-control", "no-cache, no-store, must-revalidate");
+    context.Response.Headers.Append("pragma", "no-cache");
+    context.Response.Headers.Append("expires", "0");
     await next.Invoke();
 });
 
diff --git a/server/StrDss.Api/StrDss.Api.csproj b/server/StrDss.Api/StrDss.Api.csproj
@@ -5,6 +5,7 @@
 		<Nullable>enable</Nullable>
 		<ImplicitUsings>enable</ImplicitUsings>
 		<GenerateDocumentationFile>True</GenerateDocumentationFile>
+		<NoWarn>1591</NoWarn>
 	</PropertyGroup>
 
 	<ItemGroup>
diff --git a/server/StrDss.Model/DelistingDtos/ComplianceOrderDto.cs b/server/StrDss.Model/DelistingDtos/ComplianceOrderDto.cs
@@ -0,0 +1,13 @@
+﻿using System.Text.Json.Serialization;
+
+namespace StrDss.Model.DelistingDtos
+{
+    public class ComplianceOrderDto
+    {
+        public long RentalListingId { get; set; }
+        public List<string> BccList { get; set; } = new List<string>();
+        public string Comment { get; set; } = "";
+        [JsonIgnore]
+        public List<string> HostEmails { get; set; } = new List<string>();
+    }
+}
diff --git a/server/StrDss.Service/DelistingService.cs b/server/StrDss.Service/DelistingService.cs
@@ -9,6 +9,7 @@
 using StrDss.Model;
 using StrDss.Model.DelistingDtos;
 using StrDss.Model.OrganizationDtos;
+using StrDss.Model.RentalReportDtos;
 using StrDss.Service.CsvHelpers;
 using StrDss.Service.EmailTemplates;
 using System.Text.RegularExpressions;
@@ -28,6 +29,8 @@ public interface IDelistingService
         Task<(Dictionary<string, List<string>> errors, EmailPreview preview)> GetTakedownNoticesFromListingPreviewAsync(TakedownNoticesFromListingDto[] listings);
         Task<Dictionary<string, List<string>>> CreateTakedownRequestsFromListingAsync(TakedownRequestsFromListingDto[] listings);
         Task<(Dictionary<string, List<string>> errors, EmailPreview preview)> GetTakedownRequestsFromListingPreviewAsync(TakedownRequestsFromListingDto[] listings);
+        Task<(Dictionary<string, List<string>> errors, EmailPreview preview)> GetComplianceOrdersFromListingPreviewAsync(ComplianceOrderDto[] listings);
+        Task<Dictionary<string, List<string>>> CreateComplianceOrdersFromListingAsync(ComplianceOrderDto[] listings);
     }
     public class DelistingService : ServiceBase, IDelistingService
     {
@@ -268,7 +271,7 @@ public async Task<Dictionary<string, List<string>>> CreateTakedownNoticesFromLis
                 var template = CreateTakedownNoticeTemplate(listing, rentalListing);
                 templates.Add(template);
 
-                ValidateCcListEmails(listing.CcList, emailRegex, errors);
+                ValidateEmails(listing.CcList, emailRegex, "ccList", errors);
                 ValidateLocalGovernmentContactEmail(listing, emailRegex, errors);
                 ValidateAndSetHostEmails(listing, rentalListing, emailRegex, template, errors);
 
@@ -410,7 +413,7 @@ private async Task SendTakedownNoticeEmailFromListingAsync(TakedownNoticesFromLi
                 var template = CreateTakedownNoticeTemplate(listing, rentalListing);
                 templates.Add(template);
 
-                ValidateCcListEmails(listing.CcList, emailRegex, errors);
+                ValidateEmails(listing.CcList, emailRegex, "ccList", errors);
                 ValidateLocalGovernmentContactEmail(listing, emailRegex, errors);
                 ValidateAndSetHostEmails(listing, rentalListing, emailRegex, template, errors);
 
@@ -478,7 +481,7 @@ private async Task ProcessListings(TakedownRequestsFromListingDto[] listings, Di
 
             foreach (var listing in listings)
             {
-                ValidateCcListEmails(listing.CcList, emailRegex, errors);
+                ValidateEmails(listing.CcList, emailRegex, "ccList", errors);
 
                 var rentalListing = await _listingRepo.GetRentalListingForTakedownAction(listing.RentalListingId, false);
 
@@ -495,13 +498,13 @@ private async Task ProcessListings(TakedownRequestsFromListingDto[] listings, Di
             }
         }
 
-        private void ValidateCcListEmails(List<string> ccList, RegexInfo emailRegex, Dictionary<string, List<string>> errors)
+        private void ValidateEmails(List<string> emails, RegexInfo emailRegex, string field, Dictionary<string, List<string>> errors)
         {
-            foreach (var email in ccList)
+            foreach (var email in emails)
             {
                 if (!Regex.IsMatch(email, emailRegex.Regex))
                 {
-                    errors.AddItem("ccList", $"Email ({email}) is invalid");
+                    errors.AddItem(field, $"Email ({email}) is invalid");
                 }
             }
         }
@@ -630,7 +633,7 @@ public async Task<Dictionary<string, List<string>>> CreateTakedownRequestAsync(T
                 return errors;
             }
 
-            await SendTakedownRequestAsync(dto, platform, lg);
+            await SendTakedownRequestAsync(dto, platform!, lg!);
 
             return errors;
         }
@@ -780,11 +783,11 @@ public async Task ProcessTakedownRequestBatchEmailsAsync()
 
                 try
                 {
-                    await ProcessTakedownRequestBatchEmailAsync(platform, allEmails);
+                    await ProcessTakedownRequestBatchEmailAsync(platform!, allEmails);
                 }
                 catch (Exception ex)
                 {
-                    _logger.LogError($"Error while processing '{EmailMessageTypes.BatchTakedownRequest}' email for {platform.OrganizationNm}");
+                    _logger.LogError($"Error while processing '{EmailMessageTypes.BatchTakedownRequest}' email for {platform!.OrganizationNm}");
                     _logger.LogError(ex.ToString());
                     //send email to admin?
                 } 
@@ -883,7 +886,7 @@ public async Task<Dictionary<string, List<string>>> SendBatchTakedownRequestAsyn
             }
 
             //the existence of the contact email has been validated above
-            var contacts = platform.ContactPeople
+            var contacts = platform!.ContactPeople
                 .Where(x => x.IsPrimary && x.EmailAddressDsc.IsNotEmpty() && x.EmailMessageType == EmailMessageTypes.BatchTakedownRequest)
                 .Select(x => x.EmailAddressDsc)
                 .ToArray();
@@ -1067,5 +1070,137 @@ private async Task<Dictionary<string, List<string>>> ValidateBatchTakedownNotice
 
             return errors;
         }
+        public async Task<(Dictionary<string, List<string>> errors, EmailPreview preview)> GetComplianceOrdersFromListingPreviewAsync(ComplianceOrderDto[] listings)
+        {
+            var errors = new Dictionary<string, List<string>>();
+            var templates = new List<ComplianceOrderFromListing>();
+
+            await ProcessComplianceOrderListings(listings, errors, templates);
+
+            if (errors.Count > 0)
+            {
+                return (errors, new EmailPreview());
+            }
+
+            var template = templates.FirstOrDefault();
+
+            if (template == null)
+            {
+                errors.AddItem("template", "Wasn't able to create email templates from the selected listings");
+                return (errors, new EmailPreview());
+            }
+
+            template.Preview = true;
+
+            return (errors, new EmailPreview()
+            {
+                Content = template.GetHtmlPreview()
+            });
+        }
+
+        private async Task ProcessComplianceOrderListings(ComplianceOrderDto[] listings, Dictionary<string, List<string>> errors,
+            List<ComplianceOrderFromListing> templates)
+        {
+            var emailRegex = RegexDefs.GetRegexInfo(RegexDefs.Email);
+
+            foreach (var listing in listings)
+            {
+                var rentalListing = await _listingRepo.GetRentalListing(listing.RentalListingId, false);
+
+                if (rentalListing == null) continue;
+
+                var template = CreateComplianceOrderTemplate(listing, rentalListing);
+
+                ValidateEmails(listing.BccList, emailRegex, "bccList", errors);
+
+                listing.HostEmails = GetValidHostEmails(rentalListing.Hosts.ToArray(), emailRegex);
+
+                template.OrgCd = rentalListing.OfferingOrganizationCd!;
+                template.RentalListingId = rentalListing.RentalListingId ?? 0;
+                template.To = listing.HostEmails;
+                template.Bcc = listing.BccList;
+                template.Comment = listing.Comment;
+                templates.Add(template);
+            }
+        }
+        public async Task<Dictionary<string, List<string>>> CreateComplianceOrdersFromListingAsync(ComplianceOrderDto[] listings)
+        {
+            var errors = new Dictionary<string, List<string>>();
+            var emailRegex = RegexDefs.GetRegexInfo(RegexDefs.Email);
+            var templates = new List<ComplianceOrderFromListing>();
+
+            await ProcessComplianceOrderListings(listings, errors, templates);
+
+            if (errors.Count > 0)
+            {
+                return errors;
+            }
+
+            await SendComplianceOrderEmailsFromListingAsync(listings, templates, errors);
+
+            return errors;
+        }
+
+        private ComplianceOrderFromListing CreateComplianceOrderTemplate(ComplianceOrderDto listing, RentalListingViewDto rentalListing)
+        {
+            return new ComplianceOrderFromListing(_emailService)
+            {
+                Url = rentalListing.PlatformListingUrl ?? "",
+                ListingId = rentalListing.PlatformListingNo,
+                Comment = listing.Comment,
+                Info = $"{rentalListing.OfferingOrganizationCd}-{rentalListing.PlatformListingNo}"
+            };
+        }
+
+        private List<string> GetValidHostEmails(RentalListingContactDto[] contacts, RegexInfo emailRegex)
+        {
+            return contacts
+                .Where(contact => !string.IsNullOrEmpty(contact.EmailAddressDsc) && Regex.IsMatch(contact.EmailAddressDsc, emailRegex.Regex))
+                .Select(contact => contact.EmailAddressDsc ?? "")
+                .ToList();
+        }
+
+        private async Task SendComplianceOrderEmailsFromListingAsync(ComplianceOrderDto[] listings, List<ComplianceOrderFromListing> templates, Dictionary<string, List<string>> errors)
+        {
+            foreach (var template in templates)
+            {
+                try
+                {
+                    await SendComplianceOrderEmailFromListingAsync(listings, template);
+                }
+                catch (Exception ex)
+                {
+                    _logger.LogError(ex.ToString());
+                    errors.AddItem($"{template.OrgCd}-{template.ListingId}", "Failed to send email for the listing.");
+                }
+            }
+        }
+
+        private async Task SendComplianceOrderEmailFromListingAsync(ComplianceOrderDto[] listings, ComplianceOrderFromListing template)
+        {
+            var listing = listings.First(x => x.RentalListingId == template.RentalListingId);
+
+            var emailEntity = new DssEmailMessage
+            {
+                EmailMessageType = template.EmailMessageType,
+                MessageDeliveryDtm = DateTime.UtcNow,
+                MessageTemplateDsc = template.GetContent(),
+                IsSubmitterCcRequired = true, //todo: 
+                UnreportedListingNo = template.ListingId,
+                HostEmailAddressDsc = listing.HostEmails.FirstOrDefault(),
+                LgEmailAddressDsc = null,
+                CcEmailAddressDsc = string.Join("; ", template.Bcc),
+                UnreportedListingUrl = template.Url,
+                InitiatingUserIdentityId = _currentUser.Id,
+                AffectedByUserIdentityId = null,
+                ConcernedWithRentalListingId = listing.RentalListingId,
+            };
+
+            await _emailRepo.AddEmailMessage(emailEntity);
+
+            emailEntity.ExternalMessageNo = await template.SendEmail();
+
+            _unitOfWork.Commit();
+        }
     }
 }
diff --git a/server/StrDss.Service/EmailTemplates/ComplianceOrderFromListing.cs b/server/StrDss.Service/EmailTemplates/ComplianceOrderFromListing.cs
@@ -0,0 +1,36 @@
+﻿using StrDss.Common;
+
+namespace StrDss.Service.EmailTemplates
+{
+    public class ComplianceOrderFromListing : EmailTemplateBase
+    {
+        public ComplianceOrderFromListing(IEmailMessageService emailService)
+            : base(emailService)
+        {
+            EmailMessageType = EmailMessageTypes.ComplianceOrder;
+            From = Environment.GetEnvironmentVariable("STR_CEU_EMAIL") ?? From;
+            Subject = "New mail from the Short-term Rental Compliance and Enforcement Unit";
+        }
+
+        public long RentalListingId { get; set; }
+        public string OrgCd { get; set; } = "";
+        public string Url { get; set; } = "";
+        public string? ListingId { get; set; }
+        public string Comment { get; set; } = "";
+
+        public override string GetContent()
+        {
+            return (Preview ? GetPreviewHeader() : "") + $@"
+Dear Host,<br/><br/>
+This message has been sent to you by B.C.'s Short-Term Rental Compliance Unit regarding your short-term rental<br/>
+listing: <b>{Url}</b><br/><br/>
+{Comment}<br/>
+";
+        }
+
+        public string GetHtmlPreview()
+        {
+            return GetContent();
+        }
+    }
+}
diff --git a/server/StrDss.Test/DelistingServiceShould.cs b/server/StrDss.Test/DelistingServiceShould.cs
@@ -19,7 +19,6 @@ public async Task ValidateDelistingWarning_ValidDto_ReturnsNoErrors(
             OrganizationDto platform,
             [Frozen] Mock<IConfiguration> configMock,
             [Frozen] Mock<IOrganizationService> orgServiceMock,
-            [Frozen] Mock<IEmailMessageService> emailServiceMock,
             [Frozen] Mock<ICurrentUser> currentUserMock,
             DelistingService sut)
         {
@@ -352,7 +351,6 @@ public async Task SendDelistingWarningAsync_WhenCalled_ShouldSendEmail(
         public async Task SendDelistingWarningAsync_WhenHostEmailIsNotEmpty_AddsHostEmailToToList(
             TakedownNoticeCreateDto dto,
             OrganizationDto platform,
-            [Frozen] Mock<IEmailMessageService> emailServiceMock,
             [Frozen] Mock<ICurrentUser> currentUserMock,
             [Frozen] Mock<IOrganizationService> orgServiceMock,
             DelistingService sut)
@@ -383,7 +381,6 @@ public async Task SendDelistingWarningAsync_WhenHostEmailIsNotEmpty_AddsHostEmai
         [AutoDomainData]
         public async Task SendDelistingWarningAsync_WhenHostEmailIsEmpty_DoesNotAddHostEmailToToList(
             TakedownNoticeCreateDto dto,
-            [Frozen] Mock<IEmailMessageService> emailServiceMock,
             DelistingService sut)
         {
             // Arrange
@@ -401,7 +398,6 @@ public async Task SendDelistingWarningAsync_WhenHostEmailIsEmpty_DoesNotAddHostE
         public async Task SendDelistingWarningAsync_Always_AddsCurrentUserEmailToCcList(
             TakedownNoticeCreateDto dto,
             OrganizationDto platform,
-            [Frozen] Mock<IEmailMessageService> emailServiceMock,
             [Frozen] Mock<ICurrentUser> currentUserMock,
             [Frozen] Mock<IOrganizationService> orgServiceMock,
             DelistingService sut)
