Merge pull request #34 from jtlibing/dev5

[Please merge this one] Azure Data Factory Dec release updates for Sprint 42

src/ResourceManager/DataFactories/Commands.DataFactories.Test/Commands.DataFactories.Test.csproj

@@ -49,7 +49,7 @@
       <HintPath>..\..\..\packages\Microsoft.Azure.Management.Authorization.0.11.0-preview\lib\net40\Microsoft.Azure.Management.Authorization.dll</HintPath>
     </Reference>
     <Reference Include="Microsoft.Azure.Management.DataFactories">
-      <HintPath>..\..\..\packages\Microsoft.Azure.Management.DataFactories.0.11.4-preview\lib\net40\Microsoft.Azure.Management.DataFactories.dll</HintPath>
+      <HintPath>..\..\..\packages\Microsoft.Azure.Management.DataFactories.0.12.0-preview\lib\net40\Microsoft.Azure.Management.DataFactories.dll</HintPath>
     </Reference>
     <Reference Include="Microsoft.Azure.Monitoring">
       <HintPath>..\..\..\packages\Microsoft.Azure.Monitoring.2.2.0-preview\lib\net40\Microsoft.Azure.Monitoring.dll</HintPath>
@@ -140,7 +140,6 @@
   </ItemGroup>
   <ItemGroup>
     <Compile Include="ScenarioTests\HubTests.cs" />
-    <Compile Include="ScenarioTests\PipelineTests.cs" />
     <Compile Include="UnitTests\GetHubTests.cs" />
     <Compile Include="UnitTests\NewDataFactoryEncryptValueTests.cs" />
     <Compile Include="ScenarioTests\DataFactoryGatewayTests.cs" />
@@ -259,9 +258,6 @@
     <None Include="SessionRecords\Microsoft.Azure.Commands.DataFactories.Test.LinkedServiceTests\TestLinkedServiceWithDataFactoryParameter.json">
       <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
     </None>
-    <None Include="SessionRecords\Microsoft.Azure.Commands.DataFactories.Test.PipelineTests\TestPipeline.json">
-      <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
-    </None>
     <None Include="SessionRecords\Microsoft.Azure.Commands.DataFactories.Test.TableTests\TestGetTableWithEmptyName.json">
       <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
     </None>

src/ResourceManager/DataFactories/Commands.DataFactories.Test/Resources/pipeline.json

@@ -10,7 +10,7 @@
                 inputs: [ {name: "inputTable"} ],
                 outputs: [ {name: "outputTable"} ],
                 linkedServiceName: "foo2",
-                type: "CustomActivity",
+                type: "DotNetActivity",
                 transformation:
                 {
 			        assemblyName: "mycode.dll",

src/ResourceManager/DataFactories/Commands.DataFactories.Test/ScenarioTests/DataFactoryGatewayTests.ps1

@@ -50,10 +50,9 @@ function Test-DataFactoryGateway
         $gwname = "foo"
         $description = "description"
 
-        $actual = New-AzureDataFactoryGateway -ResourceGroupName $rgname -DataFactoryName $dfname -Name $gwname -Location $dflocation
+        $actual = New-AzureDataFactoryGateway -ResourceGroupName $rgname -DataFactoryName $dfname -Name $gwname
         $expected = Get-AzureDataFactoryGateway -ResourceGroupName $rgname -DataFactoryName $dfname -Name $gwname
         Assert-AreEqual $actual.Name $expected.Name
-        Assert-AreEqual $actual.Location $expected.Location
 
         $key = New-AzureDataFactoryGatewayKey -ResourceGroupName $rgname -DataFactoryName $dfname -GatewayName $gwname
         Assert-NotNull $key
@@ -91,10 +90,9 @@ function Test-DataFactoryGatewayWithDataFactoryParameter
         $gwname = "foo"
         $description = "description"
 
-        $actual = New-AzureDataFactoryGateway -DataFactory $datafactory -Name $gwname -Location $dflocation
+        $actual = New-AzureDataFactoryGateway -DataFactory $datafactory -Name $gwname
         $expected = Get-AzureDataFactoryGateway -DataFactory $datafactory -Name $gwname
         Assert-AreEqual $actual.Name $expected.Name
-        Assert-AreEqual $actual.Location $expected.Location
 
         $key = New-AzureDataFactoryGatewayKey -DataFactory $datafactory -GatewayName $gwname
         Assert-NotNull $key

src/ResourceManager/DataFactories/Commands.DataFactories.Test/UnitTests/GetDataFactoryGatewayTests.cs

@@ -47,7 +47,6 @@ public void CanGetGateway()
             var expectedOutput = new PSDataFactoryGateway
             {
                 Name = GatewayName,
-                Location = Location,
                 Status = GatewayStatus.NeedRegistration
             };
 
@@ -74,14 +73,12 @@ public void CanListGateways()
                     new PSDataFactoryGateway()
                         {
                             Name = GatewayName,
-                            Location = Location,
                             Status = GatewayStatus.NeedRegistration
                         },
 
                     new PSDataFactoryGateway()
                         {
                             Name = "foo2",
-                            Location = Location,
                             Status = GatewayStatus.NeedRegistration
                         }
                 };

src/ResourceManager/DataFactories/Commands.DataFactories.Test/UnitTests/NewDataFactoryEncryptValueTests.cs

@@ -17,6 +17,7 @@
 using Microsoft.WindowsAzure.Commands.ScenarioTest;
 using Moq;
 using System;
+using System.Management.Automation;
 using System.Security;
 using Xunit;
 
@@ -31,7 +32,7 @@ public NewDataFactoryEncryptValueTests()
 
         [Fact]
         [Trait(Category.AcceptanceType, Category.CheckIn)]
-        public void TestOnPermDatasourceEncryptionWithRawJsonContent()
+        public void TestOnPremDatasourceEncryptionSQLAuth()
         {
             SecureString secureString = new SecureString();
             string expectedOutput = "My encrypted string " + Guid.NewGuid();
@@ -47,13 +48,45 @@ public void TestOnPermDatasourceEncryptionWithRawJsonContent()
             };
 
             // Arrange
-            this.dataFactoriesClientMock.Setup(f => f.OnPremisesEncryptString(secureString, ResourceGroupName, DataFactoryName, GatewayName)).Returns(expectedOutput);
+            this.dataFactoriesClientMock.Setup(f => f.OnPremisesEncryptString(secureString, ResourceGroupName, DataFactoryName, GatewayName, null)).Returns(expectedOutput);
 
             // Action
             cmdlet.ExecuteCmdlet();
 
             // Assert
-            this.dataFactoriesClientMock.Verify(f => f.OnPremisesEncryptString(secureString, ResourceGroupName, DataFactoryName, GatewayName), Times.Once());
+            this.dataFactoriesClientMock.Verify(f => f.OnPremisesEncryptString(secureString, ResourceGroupName, DataFactoryName, GatewayName, null), Times.Once());
+            this.commandRuntimeMock.Verify(f => f.WriteObject(expectedOutput), Times.Once());
+        }
+
+        [Fact]
+        [Trait(Category.AcceptanceType, Category.CheckIn)]
+        public void TestOnPremDatasourceEncryptionWinAuth()
+        {
+            SecureString secureString = new SecureString();
+            string expectedOutput = "My encrypted string " + Guid.NewGuid();
+            string winAuthUserName = "foo";
+            SecureString winAuthPassword = new SecureString();
+            PSCredential credential = new PSCredential(winAuthUserName, winAuthPassword);
+
+            var cmdlet = new NewAzureDataFactoryEncryptValueCommand
+            {
+                CommandRuntime = this.commandRuntimeMock.Object,
+                DataFactoryClient = this.dataFactoriesClientMock.Object,
+                Value = secureString,
+                ResourceGroupName = ResourceGroupName,
+                DataFactoryName = DataFactoryName,
+                GatewayName = GatewayName,
+                Credential = credential
+            };
+
+            // Arrange
+            this.dataFactoriesClientMock.Setup(f => f.OnPremisesEncryptString(secureString, ResourceGroupName, DataFactoryName, GatewayName, credential)).Returns(expectedOutput);
+
+            // Action
+            cmdlet.ExecuteCmdlet();
+
+            // Assert
+            this.dataFactoriesClientMock.Verify(f => f.OnPremisesEncryptString(secureString, ResourceGroupName, DataFactoryName, GatewayName, credential), Times.Once());
             this.commandRuntimeMock.Verify(f => f.WriteObject(expectedOutput), Times.Once());
         }
     }

src/ResourceManager/DataFactories/Commands.DataFactories.Test/UnitTests/NewDataFactoryGatewayKeyTests.cs

@@ -54,7 +54,6 @@ public void CanNewGatewayKey()
             var expectedOutput = new PSDataFactoryGateway
             {
                 Name = GatewayName,
-                Location = Location,
                 Status = GatewayStatus.Online,
                 Description = "New gateway description for test"
             };

src/ResourceManager/DataFactories/Commands.DataFactories.Test/UnitTests/NewDataFactoryGatewayTests.cs

@@ -49,7 +49,6 @@ public void CanNewGateway()
             var expectedOutput = new PSDataFactoryGateway
             {
                 Name = GatewayName,
-                Location = Location,
                 Status = GatewayStatus.Online,
                 Description = "New gateway description for test",
             };
@@ -71,7 +70,6 @@ public void CanNewGateway()
 
             _cmdlet.Name = GatewayName;
             _cmdlet.DataFactoryName = DataFactoryName;
-            _cmdlet.Location = Location;
 
             _cmdlet.ExecuteCmdlet();
 
@@ -86,7 +84,6 @@ public void CanThrowWhenCreateExistingGateway()
             var expectedOutput = new PSDataFactoryGateway
             {
                 Name = GatewayName,
-                Location = Location,
                 Status = GatewayStatus.Online,
                 Description = "New gateway description for test"
             };
@@ -97,7 +94,6 @@ public void CanThrowWhenCreateExistingGateway()
 
             _cmdlet.Name = GatewayName;
             _cmdlet.DataFactoryName = DataFactoryName;
-            _cmdlet.Location = Location;
 
             Assert.Throws<PSInvalidOperationException>(() => _cmdlet.ExecuteCmdlet());
 

src/ResourceManager/DataFactories/Commands.DataFactories.Test/UnitTests/SetDataFactoryGatewayTests.cs

@@ -48,7 +48,6 @@ public void CanSetGateway()
             var expectedOutput = new PSDataFactoryGateway
             {
                 Name = GatewayName,
-                Location = Location,
                 Status = GatewayStatus.NeedRegistration,
                 Description = description
             };

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

@@ -4,7 +4,7 @@
   <package id="Hydra.SpecTestSupport" version="1.0.5417.13285-prerelease" targetFramework="net45" />
   <package id="Microsoft.Azure.Gallery" version="2.2.0-preview" targetFramework="net45" />
   <package id="Microsoft.Azure.Management.Authorization" version="0.11.0-preview" targetFramework="net45" />
-  <package id="Microsoft.Azure.Management.DataFactories" version="0.11.4-preview" targetFramework="net45" />
+  <package id="Microsoft.Azure.Management.DataFactories" version="0.12.0-preview" targetFramework="net45" />
   <package id="Microsoft.Azure.Management.Resources" version="2.7.0-preview" targetFramework="net45" />
   <package id="Microsoft.Azure.Monitoring" version="2.2.0-preview" targetFramework="net45" />
   <package id="Microsoft.Bcl" version="1.1.9" targetFramework="net45" />

src/ResourceManager/DataFactories/Commands.DataFactories/Commands.DataFactories.csproj

@@ -49,14 +49,13 @@
   </PropertyGroup>
   <ItemGroup>
     <Reference Include="Microsoft.Azure.Management.DataFactories">
-      <SpecificVersion>False</SpecificVersion>
-      <HintPath>..\..\..\packages\Microsoft.Azure.Management.DataFactories.0.11.4-preview\lib\net40\Microsoft.Azure.Management.DataFactories.dll</HintPath>
+      <HintPath>..\..\..\packages\Microsoft.Azure.Management.DataFactories.0.12.0-preview\lib\net40\Microsoft.Azure.Management.DataFactories.dll</HintPath>
     </Reference>
     <Reference Include="Microsoft.DataFactories.Runtime">
       <HintPath>..\..\..\packages\Microsoft.DataFactories.Runtime.0.11.1-preview\lib\net45\Microsoft.DataFactories.Runtime.dll</HintPath>
     </Reference>
     <Reference Include="Microsoft.DataTransfer.Gateway.Encryption">
-      <HintPath>..\..\..\packages\Microsoft.DataTransfer.Gateway.Encryption.1.0.0-preview\lib\net45\Microsoft.DataTransfer.Gateway.Encryption.dll</HintPath>
+      <HintPath>..\..\..\packages\Microsoft.DataTransfer.Gateway.Encryption.1.1.0-preview\lib\net45\Microsoft.DataTransfer.Gateway.Encryption.dll</HintPath>
     </Reference>
     <Reference Include="Microsoft.Threading.Tasks, Version=1.0.12.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a, processorArchitecture=MSIL">
       <SpecificVersion>False</SpecificVersion>
@@ -224,6 +223,7 @@
   <ItemGroup>
     <Content Include="Microsoft.Azure.Commands.DataFactories.dll-Help.xml">
       <CopyToOutputDirectory>Always</CopyToOutputDirectory>
+      <SubType>Designer</SubType>
     </Content>
   </ItemGroup>
   <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />

src/ResourceManager/DataFactories/Commands.DataFactories/Encrypt/NewAzureDataFactoryEncryptValueCommand.cs

@@ -43,6 +43,10 @@ public class NewAzureDataFactoryEncryptValueCommand : DataFactoryBaseCmdlet
         [Parameter(ParameterSetName = ByFactoryName, Position = 3, Mandatory = false, HelpMessage = "The gateway group name.")]
         public string GatewayName { get; set; }
 
+        [Parameter(ParameterSetName = ByFactoryObject, Position = 3, Mandatory = false, HelpMessage = "The windows authentication credential.")]
+        [Parameter(ParameterSetName = ByFactoryName, Position = 4, Mandatory = false, HelpMessage = "The windows authentication credential.")]
+        public PSCredential Credential { get; set; }
+
         [EnvironmentPermission(SecurityAction.Demand, Unrestricted = true)]
         public override void ExecuteCmdlet()
         {
@@ -68,7 +72,7 @@ public override void ExecuteCmdlet()
             else
             {
                 // On-premises encryption with Gateway
-                encryptedValue = DataFactoryClient.OnPremisesEncryptString(Value, ResourceGroupName, DataFactoryName, GatewayName);
+                encryptedValue = DataFactoryClient.OnPremisesEncryptString(Value, ResourceGroupName, DataFactoryName, GatewayName, Credential);
             }
 
             WriteObject(encryptedValue);

src/ResourceManager/DataFactories/Commands.DataFactories/Gateway/NewAzureDataFactoryGatewayCommand.cs

@@ -39,12 +39,7 @@ public class NewAzureDataFactoryGatewayCommand : DataFactoryBaseCmdlet
         [ValidateNotNullOrEmpty]
         public string Name { get; set; }
 
-        [Parameter(Position = 3, Mandatory = true, ValueFromPipelineByPropertyName = true,
-            HelpMessage = "The geographic region to create the data factory.")]
-        [ValidateNotNullOrEmpty]
-        public string Location { get; set; }
-
-        [Parameter(Position = 4, Mandatory = false, ValueFromPipelineByPropertyName = true,
+        [Parameter(Position = 3, Mandatory = false, ValueFromPipelineByPropertyName = true,
             HelpMessage = "The description to update.")]
         public string Description { get; set; }
 
@@ -79,21 +74,11 @@ public override void ExecuteCmdlet()
             var request = new PSDataFactoryGateway
             {
                 Name = Name,
-                Location = NormalizeLocation(Location),
                 Description = Description
             };
 
             PSDataFactoryGateway response = DataFactoryClient.CreateOrUpdateGateway(ResourceGroupName, DataFactoryName, request);
             WriteObject(response);
         }
-
-        // As a nested resource of data factory, CSM will not normalize location when
-        // creating gateway, so we have to do this by ourselves.
-        private static string NormalizeLocation(string location)
-        {
-            return String.IsNullOrEmpty(location)
-                       ? String.Empty
-                       : location.Trim().Replace(" ", String.Empty).ToUpperInvariant();
-        }
     }
 }