nore tests

.gitignore

@@ -66,3 +66,4 @@ ResourceProvisioner/test/ResourceProvisioner_PyFunctions_Tests/venv/*
 /Portal/src/Datahub.Portal/MissingTranslations-default..json
 ServerlessOperations/test/CodeCoverage/
 ServerlessOperations/test/Datahub.Functions.UnitTests/TestResults/
+TestResults/

CleanCoverage.ps1

@@ -13,11 +13,24 @@ if (-Not $coverageFilePath) {
 # Read the entire file as a single string
 [xml]$coverageXml = Get-Content $coverageFilePath.FullName -Raw
 
-# Find and remove the class nodes for DirectFunctionExecutor
-$classesToRemove = $coverageXml.coverage.packages.package.classes.class | Where-Object { $_.name -like "Datahub.Functions.DirectFunctionExecutor*" }
+# Define the list of class name patterns to remove
+$classPatternsToRemove = @(
+    "Datahub.Functions.DirectFunctionExecutor*",
+    "Datahub.Functions.FunctionExecutorHostBuilderExtensions",
+    "Datahub.Functions.FunctionExecutorAutoStartup*",
+    "Datahub.Functions.FunctionExecutorHostBuilderExtensions*",
+    "Datahub.Functions.FunctionMetadataProviderAutoStartup*",
+    "Datahub.Functions.GeneratedFunctionMetadataProvider",
+    "Datahub.Functions.WorkerHostBuilderFunctionMetadataProviderExtension",
+    "Datahub.Functions.WorkerExtensionStartupCodeExecutor"
+)
 
-foreach ($class in $classesToRemove) {
-    $class.ParentNode.RemoveChild($class) | Out-Null
+# Find and remove the class nodes matching the patterns
+foreach ($pattern in $classPatternsToRemove) {
+    $classesToRemove = $coverageXml.coverage.packages.package.classes.class | Where-Object { $_.name -like $pattern }
+    foreach ($class in $classesToRemove) {
+        $class.ParentNode.RemoveChild($class) | Out-Null
+    }
 }
 
 # Save the modified XML back to the file

Datahub.sln

@@ -7,14 +7,17 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution
 		.editorconfig = .editorconfig
 		Analyzers.ruleset = Analyzers.ruleset
 		bleach.ps1 = bleach.ps1
+		CleanCoverage.ps1 = CleanCoverage.ps1
 		COPYRIGHT.md = COPYRIGHT.md
+		coverage.runsettings = coverage.runsettings
 		dh-portal.ps1 = dh-portal.ps1
 		dotnet-upgrade.ps1 = dotnet-upgrade.ps1
 		gen-all-settings.ps1 = gen-all-settings.ps1
 		global.json = global.json
 		LICENSE.md = LICENSE.md
 		nuget.config = nuget.config
 		README.md = README.md
+		RunTest.bat = RunTest.bat
 		stylecop.json = stylecop.json
 	EndProjectSection
 EndProject
@@ -356,9 +359,9 @@ Global
 		{DB462B58-CFC4-4AEE-920E-AA308F14029C} = {8620F501-1D36-439E-9BF0-3BBEFB84DC56}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
-		SolutionGuid = {9DC4B901-16FF-4FF2-9ED6-B286EA17048E}
-		RESX_AutoCreateNewLanguageFiles = True
 		RESX_ConfirmAddLanguageFile = True
+		RESX_AutoCreateNewLanguageFiles = True
+		SolutionGuid = {9DC4B901-16FF-4FF2-9ED6-B286EA17048E}
 	EndGlobalSection
 	GlobalSection(SharedMSBuildProjectFiles) = preSolution
 		Shared\src\Datahub.Shared\Datahub.Shared.projitems*{57703cec-08b9-40b8-b5e2-064a196b1587}*SharedItemsImports = 5

ServerlessOperations/src/Datahub.Functions/Datahub.Functions.csproj

@@ -73,6 +73,10 @@
     <ItemGroup>
         <InternalsVisibleTo Include="Datahub.Functions.UnitTests" />
     </ItemGroup>
+
+	<ItemGroup>
+		<InternalsVisibleTo Include="DynamicProxyGenAssembly2" />
+	</ItemGroup>
 
     <ItemGroup>
         <ProjectReference Include="..\..\..\Portal\src\Datahub.Core\Datahub.Core.csproj" />

ServerlessOperations/src/Datahub.Functions/GetUsersStatus.cs

@@ -20,7 +20,7 @@ public GetUsersStatus(ILoggerFactory loggerFactory, AzureConfig configuration)
             _configuration = configuration;
         }
 
-        private GraphServiceClient GetAuthenticatedGraphClient()
+        internal virtual GraphServiceClient GetAuthenticatedGraphClient()
         {
             var scopes = new[] { "https://graph.microsoft.com/.default" };
 

ServerlessOperations/test/Datahub.Functions.UnitTests/Datahub.Functions.UnitTests.csproj

@@ -41,4 +41,8 @@
       </None>
     </ItemGroup>
 
+    <ItemGroup>
+      <Folder Include="TestResults\" />
+    </ItemGroup>
+
 </Project>

ServerlessOperations/test/Datahub.Functions.UnitTests/Exceptions/ProjectUsageExceptionsTests.cs

@@ -0,0 +1,72 @@
+using Datahub.Functions.Domain.Exceptions;
+using FluentAssertions;
+
+namespace Datahub.Functions.UnitTests
+{
+    [TestFixture]
+    public class ProjectUsageExceptionsTests
+    {
+        [TestCase("Blob download error")]
+        public void BlobDownloadException_ShouldSetMessage(string message)
+        {
+            var exception = new BlobDownloadException(message);
+            message.Should().Be(exception.Message);
+        }
+
+        [TestCase("Blob upload error")]
+        public void BlobUploadException_ShouldSetMessage(string message)
+        {
+            var exception = new BlobUploadException(message);
+            message.Should().Be(exception.Message);
+        }
+
+        [TestCase("Cost update error")]
+        public void CostUpdateException_ShouldSetMessage(string message)
+        {
+            var exception = new CostUpdateException(message);
+            message.Should().Be(exception.Message);
+        }
+
+        [TestCase("Cost refresh error")]
+        public void CostRefreshException_ShouldSetMessage(string message)
+        {
+            var exception = new CostRefreshException(message);
+            message.Should().Be(exception.Message);
+        }
+
+        [TestCase("Budget update error")]
+        public void BudgetUpdateException_ShouldSetMessage(string message)
+        {
+            var exception = new BudgetUpdateException(message);
+            message.Should().Be(exception.Message);
+        }
+
+        [TestCase("Rollover error")]
+        public void RolloverException_ShouldSetMessage(string message)
+        {
+            var exception = new RolloverException(message);
+            message.Should().Be(exception.Message);
+        }
+
+        [TestCase("Cost query error")]
+        public void CostQueryException_ShouldSetMessage(string message)
+        {
+            var exception = new CostQueryException(message);
+            message.Should().Be(exception.Message);
+        }
+
+        [TestCase("Project filtering error")]
+        public void ProjectFilteringException_ShouldSetMessage(string message)
+        {
+            var exception = new ProjectFilteringException(message);
+            message.Should().Be(exception.Message);
+        }
+
+        [TestCase("Message scheduling error")]
+        public void MessageSchedulingException_ShouldSetMessage(string message)
+        {
+            var exception = new MessageSchedulingException(message);
+            message.Should().Be(exception.Message);
+        }
+    }
+}

ServerlessOperations/test/Datahub.Functions.UnitTests/Functions/BugReportTests.cs

@@ -1,5 +1,6 @@
 using Azure.Core.Amqp;
 using Azure.Messaging.ServiceBus;
+using Datahub.Functions.Entities;
 using Datahub.Functions.Services;
 using Datahub.Infrastructure.Queues.Messages;
 using FluentAssertions;
@@ -8,7 +9,10 @@
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Logging;
 using Microsoft.TeamFoundation.WorkItemTracking.WebApi.Models;
+using Moq.Protected;
+using Moq;
 using NSubstitute;
+using System.Net;
 using System.Text;
 using System.Text.Json;
 using System.Text.Json.Nodes;
@@ -37,14 +41,31 @@ public void SetUp()
         _logger = _loggerFactory.CreateLogger<BugReport>();
 
         var httpClientFactory = Substitute.For<IHttpClientFactory>();
-        var httpClient = new HttpClient();
-
+
+        var handlerMock = new Mock<HttpMessageHandler>();
+        handlerMock
+            .Protected()
+            .Setup<Task<HttpResponseMessage>>(
+                "SendAsync",
+                ItExpr.IsAny<HttpRequestMessage>(),
+                ItExpr.IsAny<CancellationToken>()
+            )
+            .ReturnsAsync(new HttpResponseMessage
+            {
+                StatusCode = HttpStatusCode.OK,
+                Content = new StringContent("Success"),
+            });
+
+        var httpClient = new HttpClient(handlerMock.Object);
 
         httpClientFactory.CreateClient(Arg.Any<string>()).Returns(httpClient);
 
+        _config["BugReportTeamsWebhookUrl"].Returns("https://fake_webhook_url.tld");
         _azureConfig = new AzureConfig(_config);
+
         _emailService = new EmailService(_loggerFactory.CreateLogger<EmailService>());
-        _alertRecordService = new AlertRecordService(_azureConfig);
+
+        _alertRecordService = Substitute.For<IAlertRecordService>();
 
         _bugReport = new BugReport(_logger, _azureConfig, _emailService, _iSendEndpointProvider, _alertRecordService, httpClientFactory);
         _bugReportMessage = new BugReportMessage(
@@ -116,6 +137,10 @@ public void Run_WithValidMessage_ReturnsSuccess()
             {
                 Encoding.UTF8.GetBytes(messageEnvelope.ToJsonString())
             })), new BinaryData("lockToken"u8.ToArray()));
+
+        _alertRecordService.GetRecentAlertForBugMessage(Arg.Any<BugReportMessage>())
+            .Returns(Task.FromResult(new ReceivedAlert { EmailSent=true }));
+
 
 
         // Act
@@ -126,4 +151,89 @@ public void Run_WithValidMessage_ReturnsSuccess()
         //result.To[0].Should().Be(_azureConfig.Email.AdminEmail);
         //result.Template.Should().Be("bug_report.html");
     }
+
+    [Test]
+    public void Run_WithNewInfrastructureError_ReturnsSuccess()
+    {
+        // Arrange
+        var bugInfrastructureErrorMessage = new BugReportMessage(
+            UserName: "Test",
+            UserEmail: "example@email.com",
+            UserOrganization: "ssc-spc",
+            PortalLanguage: "en",
+            PreferredLanguage: "en",
+            Timezone: "EST",
+            Workspaces: "DIE1",
+            Topics: "Test",
+            URL: "google.com",
+            UserAgent: "test",
+            Resolution: "1920x1080",
+            LocalStorage: "{}",
+            BugReportType: BugReportTypes.InfrastructureError,
+            Description: "Test report"
+        );
+
+        var messageEnvelope = new JsonObject
+        {
+            ["message"] = JsonSerializer.SerializeToNode(bugInfrastructureErrorMessage)
+        };
+        var serviceBusReceivedMessage = ServiceBusReceivedMessage.FromAmqpMessage(
+            new AmqpAnnotatedMessage(new AmqpMessageBody(new List<ReadOnlyMemory<byte>>
+            {
+                Encoding.UTF8.GetBytes(messageEnvelope.ToJsonString())
+            })), new BinaryData("lockToken"u8.ToArray()));
+
+        _alertRecordService.GetRecentAlertForBugMessage(Arg.Any<BugReportMessage>())
+            .Returns(Task.FromResult(new ReceivedAlert { EmailSent = false }));
+
+        // Act
+        var result = _bugReport.Run(serviceBusReceivedMessage);
+
+        // Assert
+        result.Should().NotBeNull();
+        // Failing to post the issue to ADO.
+        // TODO: continue tests after TODO in BugReport.cs is done - enable configuration for _postToDevops 
+    }
+
+    [Test]
+    public void Run_WithInfrastructureErrorAlreadySent_ReturnsSuccess()
+    {
+        // Arrange
+        var bugInfrastructureErrorMessage = new BugReportMessage(
+            UserName: "Test",
+            UserEmail: "example@email.com",
+            UserOrganization: "ssc-spc",
+            PortalLanguage: "en",
+            PreferredLanguage: "en",
+            Timezone: "EST",
+            Workspaces: "DIE1",
+            Topics: "Test",
+            URL: "google.com",
+            UserAgent: "test",
+            Resolution: "1920x1080",
+            LocalStorage: "{}",
+            BugReportType: BugReportTypes.InfrastructureError,
+            Description: "Test report"
+        );
+
+        var messageEnvelope = new JsonObject
+        {
+            ["message"] = JsonSerializer.SerializeToNode(bugInfrastructureErrorMessage)
+        };
+        var serviceBusReceivedMessage = ServiceBusReceivedMessage.FromAmqpMessage(
+            new AmqpAnnotatedMessage(new AmqpMessageBody(new List<ReadOnlyMemory<byte>>
+            {
+                Encoding.UTF8.GetBytes(messageEnvelope.ToJsonString())
+            })), new BinaryData("lockToken"u8.ToArray()));
+
+        _alertRecordService.GetRecentAlertForBugMessage(Arg.Any<BugReportMessage>())
+            .Returns(Task.FromResult(new ReceivedAlert { EmailSent = true }));
+
+        // Act
+        var result = _bugReport.Run(serviceBusReceivedMessage);
+
+        // Assert
+        result.Should().NotBeNull();
+        result.Status.Should().Be(TaskStatus.RanToCompletion); 
+    }
 }