Update Stream Analytics PowerShell

Updated SDK reference to 1.4.1 version which enables diagnostic feature
for inputs and outputs
Made necessary code changes
Updated and re-recorded tests

Author: atpham256

src/ResourceManager/StreamAnalytics/Commands.StreamAnalytics.Test/Commands.StreamAnalytics.Test.csproj

@@ -62,7 +62,7 @@
       <HintPath>..\..\..\packages\Microsoft.Azure.Management.Authorization.0.18.2-preview\lib\net40\Microsoft.Azure.Management.Authorization.dll</HintPath>
     </Reference>
     <Reference Include="Microsoft.Azure.Management.StreamAnalytics">
-      <HintPath>..\..\..\packages\Microsoft.Azure.Management.StreamAnalytics.1.4.0\lib\net40\Microsoft.Azure.Management.StreamAnalytics.dll</HintPath>
+      <HintPath>..\..\..\packages\Microsoft.Azure.Management.StreamAnalytics.1.4.1\lib\net40\Microsoft.Azure.Management.StreamAnalytics.dll</HintPath>
     </Reference>
     <Reference Include="Microsoft.Azure.ResourceManager, Version=2.0.0.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35, processorArchitecture=MSIL">
       <SpecificVersion>False</SpecificVersion>

src/ResourceManager/StreamAnalytics/Commands.StreamAnalytics.Test/ScenarioTests/EndToEndTests.ps1

@@ -78,6 +78,13 @@ function Test-TestStreamingAnalyticsE2E
 	$expected = 1
 	Assert-AreEqual $expected $actual.CurrentCount
 
+	#Get Diagnostics
+	$actual = Get-AzureStreamAnalyticsInput -JobName $jobName -ResourceGroupName $resourceGroup
+	Assert-NotNull $actual
+	Assert-NotNull $actual.Properties.Diagnostics
+	Assert-NotNull $actual.Properties.Diagnostics.Conditions
+	Assert-NotNull $actual.Properties.Diagnostics.Conditions.Message
+
 	# Stop Job
     $actual = Stop-AzureStreamAnalyticsJob -Name $jobName -ResourceGroupName $resourceGroup	
 	$expected = "True"

src/ResourceManager/StreamAnalytics/Commands.StreamAnalytics.Test/SessionRecords/Microsoft.Azure.Commands.StreamAnalytics.Test.EndToEndTests/TestStreamingAnalyticsE2E.json

@@ -7,7 +7,7 @@
   <package id="Microsoft.Azure.Gallery" version="2.6.2-preview" targetFramework="net45" />
   <package id="Microsoft.Azure.Management.Authorization" version="0.18.2-preview" targetFramework="net45" />
   <package id="Microsoft.Azure.Management.Resources" version="2.18.0-preview" targetFramework="net45" />
-  <package id="Microsoft.Azure.Management.StreamAnalytics" version="1.4.0" targetFramework="net45" />
+  <package id="Microsoft.Azure.Management.StreamAnalytics" version="1.4.1" targetFramework="net45" />
   <package id="Microsoft.Azure.Test.Framework" version="1.0.5571.32271-prerelease" targetFramework="net45" />
   <package id="Microsoft.Azure.Test.HttpRecorder" version="1.0.5571.32271-prerelease" targetFramework="net45" />
   <package id="Microsoft.Bcl" version="1.1.9" targetFramework="net45" />

src/ResourceManager/StreamAnalytics/Commands.StreamAnalytics.Test/packages.config

@@ -63,7 +63,7 @@
     </Reference>
     <Reference Include="Microsoft.Azure.Management.StreamAnalytics, Version=0.9.0.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35, processorArchitecture=MSIL">
       <SpecificVersion>False</SpecificVersion>
-      <HintPath>..\..\..\packages\Microsoft.Azure.Management.StreamAnalytics.1.4.0\lib\net40\Microsoft.Azure.Management.StreamAnalytics.dll</HintPath>
+      <HintPath>..\..\..\packages\Microsoft.Azure.Management.StreamAnalytics.1.4.1\lib\net40\Microsoft.Azure.Management.StreamAnalytics.dll</HintPath>
     </Reference>
     <Reference Include="Microsoft.Azure.ResourceManager, Version=2.0.0.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35, processorArchitecture=MSIL">
       <SpecificVersion>False</SpecificVersion>

src/ResourceManager/StreamAnalytics/Commands.StreamAnalytics/Commands.StreamAnalytics.csproj

@@ -42,7 +42,7 @@ public virtual List<PSInput> ListInputs(string resourceGroupName, string jobName
         {
             List<PSInput> inputs = new List<PSInput>();
 
-            var response = StreamAnalyticsManagementClient.Inputs.ListInputInJob(resourceGroupName, jobName);
+            var response = StreamAnalyticsManagementClient.Inputs.ListInputInJob(resourceGroupName, jobName, new InputListParameters("*"));
 
             if (response != null && response.Value != null)
             {

src/ResourceManager/StreamAnalytics/Commands.StreamAnalytics/Models/StreamAnalyticsClient.Inputs.cs

@@ -42,7 +42,7 @@ public virtual List<PSOutput> ListOutputs(string resourceGroupName, string jobNa
         {
             List<PSOutput> outputs = new List<PSOutput>();
 
-            var response = StreamAnalyticsManagementClient.Outputs.ListOutputInJob(resourceGroupName, jobName);
+            var response = StreamAnalyticsManagementClient.Outputs.ListOutputInJob(resourceGroupName, jobName, new OutputListParameters("*"));
 
             if (response != null && response.Value != null)
             {

src/ResourceManager/StreamAnalytics/Commands.StreamAnalytics/Models/StreamAnalyticsClient.Outputs.cs

@@ -5,7 +5,7 @@
   <package id="Microsoft.Azure.Common.Authentication" version="1.0.25-preview" targetFramework="net45" />
   <package id="Microsoft.Azure.Common.Dependencies" version="1.0.0" targetFramework="net45" />
   <package id="Microsoft.Azure.Management.Resources" version="2.18.0-preview" targetFramework="net45" />
-  <package id="Microsoft.Azure.Management.StreamAnalytics" version="1.4.0" targetFramework="net45" />
+  <package id="Microsoft.Azure.Management.StreamAnalytics" version="1.4.1" targetFramework="net45" />
   <package id="Microsoft.Bcl" version="1.1.9" targetFramework="net45" />
   <package id="Microsoft.Bcl.Async" version="1.0.168" targetFramework="net45" />
   <package id="Microsoft.Bcl.Build" version="1.0.14" targetFramework="net45" />