Feature/#1117_-_Execute commands defined in edge model

src/AzureIoTHub.Portal.Tests.Unit/Client/Pages/Configurations/EdgeModule/ModuleDialogTab1Tests.cs

@@ -22,7 +22,6 @@ public void ModuleDialogTab1ShouldBeRenderedProperly()
             var module = new IoTEdgeModule()
             {
                 ModuleName = Guid.NewGuid().ToString(),
-                Version = Guid.NewGuid().ToString(),
                 Status = "running",
                 EnvironmentVariables = new List<IoTEdgeModuleEnvironmentVariable>(),
                 ModuleIdentityTwinSettings = new List<IoTEdgeModuleTwinSetting>(),
@@ -43,7 +42,6 @@ public void ClickOnAddShouldAddRow()
             var module = new IoTEdgeModule()
             {
                 ModuleName = Guid.NewGuid().ToString(),
-                Version = Guid.NewGuid().ToString(),
                 Status = "running",
                 EnvironmentVariables = new List<IoTEdgeModuleEnvironmentVariable>()
                 {
@@ -78,7 +76,6 @@ public void ClickOnRemoveShouldDeleteRow()
             var module = new IoTEdgeModule()
             {
                 ModuleName = Guid.NewGuid().ToString(),
-                Version = Guid.NewGuid().ToString(),
                 Status = "running",
                 EnvironmentVariables = new List<IoTEdgeModuleEnvironmentVariable>()
                 {

src/AzureIoTHub.Portal.Tests.Unit/Client/Pages/Configurations/EdgeModule/ModuleDialogTab2Tests.cs

@@ -22,7 +22,6 @@ public void ModuleDialogTab2ShouldBeRenderedProperly()
             var module = new IoTEdgeModule()
             {
                 ModuleName = Guid.NewGuid().ToString(),
-                Version = Guid.NewGuid().ToString(),
                 Status = "running",
                 EnvironmentVariables = new List<IoTEdgeModuleEnvironmentVariable>(),
                 ModuleIdentityTwinSettings = new List<IoTEdgeModuleTwinSetting>(),
@@ -43,7 +42,6 @@ public void ClickOnAddShouldAddRow()
             var module = new IoTEdgeModule()
             {
                 ModuleName = Guid.NewGuid().ToString(),
-                Version = Guid.NewGuid().ToString(),
                 Status = "running",
                 EnvironmentVariables = new List<IoTEdgeModuleEnvironmentVariable>(),
                 ModuleIdentityTwinSettings = new List<IoTEdgeModuleTwinSetting>()
@@ -78,7 +76,6 @@ public void ClickOnRemoveShouldDeleteRow()
             var module = new IoTEdgeModule()
             {
                 ModuleName = Guid.NewGuid().ToString(),
-                Version = Guid.NewGuid().ToString(),
                 Status = "running",
                 EnvironmentVariables = new List<IoTEdgeModuleEnvironmentVariable>(),
                 ModuleIdentityTwinSettings = new List<IoTEdgeModuleTwinSetting>()

src/AzureIoTHub.Portal.Tests.Unit/Client/Pages/Configurations/EdgeModule/ModuleDialogTab3Tests.cs

@@ -22,7 +22,6 @@ public void ModuleDialogTab3ShouldBeRenderedProperly()
             var module = new IoTEdgeModule()
             {
                 ModuleName = Guid.NewGuid().ToString(),
-                Version = Guid.NewGuid().ToString(),
                 Status = "running",
                 EnvironmentVariables = new List<IoTEdgeModuleEnvironmentVariable>(),
                 ModuleIdentityTwinSettings = new List<IoTEdgeModuleTwinSetting>(),
@@ -43,7 +42,6 @@ public void ClickOnAddShouldAddRow()
             var module = new IoTEdgeModule()
             {
                 ModuleName = Guid.NewGuid().ToString(),
-                Version = Guid.NewGuid().ToString(),
                 Status = "running",
                 EnvironmentVariables = new List<IoTEdgeModuleEnvironmentVariable>(),
                 ModuleIdentityTwinSettings = new List<IoTEdgeModuleTwinSetting>(),
@@ -76,7 +74,6 @@ public void ClickOnRemoveShouldDeleteRow()
             var module = new IoTEdgeModule()
             {
                 ModuleName = Guid.NewGuid().ToString(),
-                Version = Guid.NewGuid().ToString(),
                 Status = "running",
                 EnvironmentVariables = new List<IoTEdgeModuleEnvironmentVariable>(),
                 ModuleIdentityTwinSettings = new List<IoTEdgeModuleTwinSetting>(),

src/AzureIoTHub.Portal.Tests.Unit/Client/Pages/Configurations/EdgeModule/ModuleDialogTests.cs

@@ -29,7 +29,6 @@ public async Task ModuleDialogTestMustBeRenderedOnShow()
             var module = new IoTEdgeModule()
             {
                 ModuleName = moduleName,
-                Version = "1.0",
                 Status = "running",
                 ImageURI = moduleImageUri,
                 EnvironmentVariables = new List<IoTEdgeModuleEnvironmentVariable>(),
@@ -73,7 +72,6 @@ public async Task ClickOnSubmitShouldUpdateModuleValues()
             var module = new IoTEdgeModule()
             {
                 ModuleName = moduleName,
-                Version = moduleVersion,
                 Status = "running",
                 ImageURI = moduleImageUri,
                 EnvironmentVariables = new List<IoTEdgeModuleEnvironmentVariable>(),

src/AzureIoTHub.Portal.Tests.Unit/Client/Pages/EdgeDevices/EdgeDeviceDetailPageTests.cs

@@ -262,7 +262,7 @@ public void ClickOnRebootShouldDisplaySnackbarIfError()
                     Status = 500
                 });
 
-            _ = this.mockSnackbarService.Setup(c => c.Add(It.IsAny<string>(), Severity.Error, It.IsAny<Action<SnackbarOptions>>())).Returns((Snackbar)null);
+            _ = this.mockSnackbarService.Setup(c => c.Add(It.IsAny<string>(), Severity.Error, It.IsAny<Action<SnackbarOptions>>())).Returns(value: null);
 
             var cut = RenderComponent<EdgeDeviceDetailPage>(ComponentParameter.CreateParameter("deviceId", this.mockdeviceId));
 
@@ -357,6 +357,7 @@ public void ClickOnLogsShouldDisplayLogs()
         [Test]
         public void ClickOnConnectShouldDisplayDeviceCredentials()
         {
+            // Arrange
             _ = SetupOnInitialisation();
 
             var cut = RenderComponent<EdgeDeviceDetailPage>(ComponentParameter.CreateParameter("deviceId", this.mockdeviceId));
@@ -376,6 +377,80 @@ public void ClickOnConnectShouldDisplayDeviceCredentials()
             cut.WaitForAssertion(() => MockRepository.VerifyAll());
         }
 
+        [Test]
+        public void ClickOnCommandModuleShouldReturn200()
+        {
+            // Arrange
+            _ = SetupOnInitialisation();
+
+            var cut = RenderComponent<EdgeDeviceDetailPage>(ComponentParameter.CreateParameter("deviceId", this.mockdeviceId));
+            cut.WaitForAssertion(() => cut.Find("#commandTest"));
+
+            var commandButton = cut.Find("#commandTest");
+
+            _ = this.mockEdgeDeviceClientService
+                .Setup(x => x.ExecuteModuleCommand(It.Is<string>(c => c.Equals(this.mockdeviceId, StringComparison.Ordinal)), It.IsAny<string>(), It.IsAny<string>()))
+                .ReturnsAsync(new C2Dresult() { Status = 200 });
+
+            _ = this.mockSnackbarService
+                .Setup(c => c.Add(It.IsAny<string>(), Severity.Success, It.IsAny<Action<SnackbarOptions>>()))
+                .Returns(value: null);
+
+            // Act
+            commandButton.Click();
+
+            // Assert
+            cut.WaitForAssertion(() => MockRepository.VerifyAll());
+        }
+
+        [Test]
+        public void ClickOnCommandModuleShouldReturn400()
+        {
+            // Arrange
+            _ = SetupOnInitialisation();
+
+            var cut = RenderComponent<EdgeDeviceDetailPage>(ComponentParameter.CreateParameter("deviceId", this.mockdeviceId));
+            cut.WaitForAssertion(() => cut.Find("#commandTest"));
+
+            var commandButton = cut.Find("#commandTest");
+
+            _ = this.mockEdgeDeviceClientService
+                .Setup(x => x.ExecuteModuleCommand(It.Is<string>(c => c.Equals(this.mockdeviceId, StringComparison.Ordinal)), It.IsAny<string>(), It.IsAny<string>()))
+                .ReturnsAsync(new C2Dresult() { Status = 400 });
+
+            _ = this.mockSnackbarService
+                .Setup(c => c.Add(It.IsAny<string>(), Severity.Error, It.IsAny<Action<SnackbarOptions>>()))
+                .Returns(value: null);
+
+            // Act
+            commandButton.Click();
+
+            // Assert
+            cut.WaitForAssertion(() => MockRepository.VerifyAll());
+        }
+
+        [Test]
+        public void ClickOnCommandModuleShouldProcessProblemDetailsExceptionWhenIssueOccurs()
+        {
+            // Arrange
+            _ = SetupOnInitialisation();
+
+            var cut = RenderComponent<EdgeDeviceDetailPage>(ComponentParameter.CreateParameter("deviceId", this.mockdeviceId));
+            cut.WaitForAssertion(() => cut.Find("#commandTest"));
+
+            var commandButton = cut.Find("#commandTest");
+
+            _ = this.mockEdgeDeviceClientService
+                .Setup(x => x.ExecuteModuleCommand(It.Is<string>(c => c.Equals(this.mockdeviceId, StringComparison.Ordinal)), It.IsAny<string>(), It.IsAny<string>()))
+                .ThrowsAsync(new ProblemDetailsException(new ProblemDetailsWithExceptionDetails()));
+
+            // Act
+            commandButton.Click();
+
+            // Assert
+            cut.WaitForAssertion(() => MockRepository.VerifyAll());
+        }
+
         [Test]
         public void ClickOnDeleteShouldDisplayConfirmationDialogAndReturnIfAborted()
         {
@@ -434,7 +509,15 @@ private IoTEdgeDevice SetupOnInitialisation()
                 DeviceId = this.mockdeviceId,
                 ConnectionState = "Connected",
                 ModelId = Guid.NewGuid().ToString(),
-                Tags = tags
+                Tags = tags,
+                Modules = new List<IoTEdgeModule>()
+                {
+                    new IoTEdgeModule()
+                    {
+                        ModuleName = "moduleTest",
+                        ImageURI = Guid.NewGuid().ToString()
+                    }
+                }
             };
 
             _ = this.mockEdgeDeviceClientService.Setup(service => service.GetDevice(this.mockdeviceId))
@@ -444,7 +527,19 @@ private IoTEdgeDevice SetupOnInitialisation()
                 .Setup(service => service.GetIoTEdgeModel(It.Is<string>(x => x.Equals(mockIoTEdgeDevice.ModelId, StringComparison.Ordinal))))
                 .ReturnsAsync(new IoTEdgeModel()
                 {
-                    ModelId = mockIoTEdgeDevice.ModelId
+                    ModelId = mockIoTEdgeDevice.ModelId,
+                    EdgeModules = new List<IoTEdgeModule>()
+                    {
+                        new IoTEdgeModule()
+                        {
+                            ModuleName = "moduleTest",
+                            ImageURI = Guid.NewGuid().ToString(),
+                            Commands = new List<Portal.Shared.Models.v10.IoTEdgeModuleCommand>()
+                            {
+                                new Portal.Shared.Models.v10.IoTEdgeModuleCommand(){ Name = "commandTest"}
+                            }
+                        }
+                    }
                 });
 
             _ = this.mockDeviceTagSettingsClientService

src/AzureIoTHub.Portal.Tests.Unit/Client/Pages/EdgeDevices/ModuleLogsDialogTests.cs

@@ -41,7 +41,6 @@ public async Task ModuleLogsDialogParametersMustBeCorrect()
 
             var edgeModule = new IoTEdgeModule
             {
-                Version = "1.0",
                 ModuleName = Guid.NewGuid().ToString()
             };
 
@@ -84,7 +83,6 @@ public async Task ModuleLogsShouldProcessProblemDetailsExceptionWhenIssueOccursO
 
             var edgeModule = new IoTEdgeModule
             {
-                Version = "1.0",
                 ModuleName = Guid.NewGuid().ToString()
             };
 
@@ -120,7 +118,6 @@ public async Task ModuleLogsMustCloseOnCLickOnCloseButton()
 
             var edgeModule = new IoTEdgeModule
             {
-                Version = "1.0",
                 ModuleName = Guid.NewGuid().ToString()
             };
 

src/AzureIoTHub.Portal.Tests.Unit/Client/Services/EdgeDeviceClientServiceTests.cs

@@ -180,7 +180,6 @@ public async Task GetEdgeDeviceLogsMustReturnLogsWhenNoError()
 
             var edgeModule = new IoTEdgeModule
             {
-                Version = "1.0",
                 ModuleName = Guid.NewGuid().ToString()
             };
 
@@ -208,5 +207,53 @@ public async Task GetEdgeDeviceLogsMustReturnLogsWhenNoError()
 
             _ = result.Count.Should().Be(1);
         }
+
+        [Test]
+        public async Task ExecuteModuleMethodShouldReturn200()
+        {
+            // Arrange
+            var deviceId = Fixture.Create<string>();
+
+            var edgeModule = new IoTEdgeModule()
+            {
+                ModuleName = Guid.NewGuid().ToString()
+            };
+
+            var methodName = Fixture.Create<string>();
+            var c2Dresult = Fixture.Create<C2Dresult>();
+
+            _ = MockHttpClient.When(HttpMethod.Post, $"/api/edge/devices/{deviceId}/{edgeModule.ModuleName}/{methodName}")
+                .RespondJson(c2Dresult);
+
+            // Act
+            var result = await this.edgeDeviceClientService.ExecuteModuleMethod(deviceId, edgeModule, methodName);
+
+            // Assert
+            _ = result.Should().BeEquivalentTo(c2Dresult);
+            MockHttpClient.VerifyNoOutstandingRequest();
+            MockHttpClient.VerifyNoOutstandingExpectation();
+        }
+
+        [Test]
+        public async Task ExecuteModuleCommandShouldReturn200()
+        {
+            // Arrange
+            var deviceId = Fixture.Create<string>();
+            var commandName = Fixture.Create<string>();
+            var moduleName = Fixture.Create<string>();
+
+            var c2Dresult = Fixture.Create<C2Dresult>();
+
+            _ = MockHttpClient.When(HttpMethod.Post, $"/api/edge/devices/{deviceId}/{moduleName}/custom/{commandName}")
+                .RespondJson(c2Dresult);
+
+            // Act
+            var result = await this.edgeDeviceClientService.ExecuteModuleCommand(deviceId, moduleName, commandName);
+
+            // Assert
+            _ = result.Should().BeEquivalentTo(c2Dresult);
+            MockHttpClient.VerifyNoOutstandingRequest();
+            MockHttpClient.VerifyNoOutstandingExpectation();
+        }
     }
 }

src/AzureIoTHub.Portal.Tests.Unit/Server/Controllers/v1.0/EdgeDevicesControllerTests.cs

@@ -1,7 +1,7 @@
 // Copyright (c) CGI France. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-namespace AzureIoTHub.Portal.Tests.Unit.Server.Controllers.v1._0
+namespace AzureIoTHub.Portal.Tests.Unit.Server.Controllers.v10
 {
     using System;
     using System.Collections.Generic;
@@ -271,7 +271,6 @@ public async Task GetEdgeDeviceLogsMustReturnLogsWhenNoErrorIsReturned()
 
             var edgeModule = new IoTEdgeModule
             {
-                Version = "1.0",
                 ModuleName = Guid.NewGuid().ToString()
             };
 
@@ -387,13 +386,38 @@ public async Task ExecuteMethodShouldExecuteC2DMethod(string methodName)
             var deviceId = Guid.NewGuid().ToString();
 
             _ = this.mockEdgeDeviceService
-                .Setup(x => x.ExecuteModuleMethod(It.IsAny<IoTEdgeModule>(),
+                .Setup(x => x.ExecuteModuleMethod(It.IsAny<string>(),
                 It.Is<string>(c => c.Equals(deviceId, StringComparison.Ordinal)),
                 It.Is<string>(c => c.Equals(methodName, StringComparison.Ordinal))))
                 .ReturnsAsync(new C2Dresult());
 
             // Act
-            var result = await edgeDeviceController.ExecuteModuleMethod(module, deviceId, methodName);
+            var result = await edgeDeviceController.ExecuteModuleMethod(module.ModuleName, deviceId, methodName);
+
+            // Assert
+            Assert.IsNotNull(result);
+
+            this.mockRepository.VerifyAll();
+        }
+
+        [TestCase("test")]
+        public async Task ExecuteCustomModuleMethodShouldExecuteC2DMethod(string commandName)
+        {
+            // Arrange
+            var edgeDeviceController = CreateEdgeDevicesController();
+
+            var deviceId =  Guid.NewGuid().ToString();
+            var moduleName = Guid.NewGuid().ToString();
+
+            _ = this.mockEdgeDeviceService
+                .Setup(x => x.ExecuteModuleCommand(
+                    It.Is<string>(c => c.Equals(deviceId, StringComparison.Ordinal)),
+                    It.Is<string>(c => c.Equals(moduleName, StringComparison.Ordinal)),
+                    It.Is<string>(c => c.Equals(commandName, StringComparison.Ordinal))))
+                .ReturnsAsync(new C2Dresult());
+
+            // Act
+            var result = await edgeDeviceController.ExecuteCustomModuleMethod(deviceId, moduleName, commandName);
 
             // Assert
             Assert.IsNotNull(result);

src/AzureIoTHub.Portal.Tests.Unit/Server/Helpers/ConfigHelperTest.cs

@@ -115,7 +115,6 @@ public void CreateGatewayModuleShouldReturnValue()
             // Assert
             Assert.IsNotNull(result);
             Assert.AreEqual("running", result.Status);
-            Assert.AreEqual("1.0", result.Version);
             Assert.AreEqual("image_test", result.ImageURI);
             Assert.AreEqual(1, result.EnvironmentVariables.Count);
         }
@@ -161,7 +160,6 @@ public void GenerateModulesContentShouldReturnValue()
                     {
                         ModuleName = "ModuleTest",
                         Status = "running",
-                        Version = "1.0",
                         ImageURI = "image",
                         EnvironmentVariables = new List<IoTEdgeModuleEnvironmentVariable>()
                         {