[Datafactory] Adding 3 new commands to ADF V2 for blob event triggers

src/DataFactory/DataFactoryV2.Test/Resources/blobeventtrigger.json

@@ -0,0 +1,25 @@
+{
+  "properties": {
+    "type": "BlobTrigger",
+    "typeProperties": {
+      "maxConcurrency": "10",
+      "folderPath": "blobtriggertestpath",
+      "linkedService": {
+        "referenceName": "foo1",
+        "type": "LinkedServiceReference"
+      }
+
+    },
+    "pipelines": [
+      {
+        "pipelineReference": {
+          "type": "PipelineReference",
+          "referenceName": "samplePipeline"
+        },
+        "parameters": {
+          "OutputBlobName": "triggertest"
+        }
+      }
+    ]
+  }
+}

src/DataFactory/DataFactoryV2.Test/ScenarioTests/TriggerTests.cs

@@ -55,5 +55,26 @@ public void TestTriggerWithResourceId()
         {
             RunPowerShellTest(_logger, "Test-TriggerWithResourceId");
         }
+
+        [Fact]
+        [Trait(Category.AcceptanceType, Category.CheckIn)]
+        public void TestBlobEventTriggerSubscriptions()
+        {
+            RunPowerShellTest(_logger, "Test-BlobEventTriggerSubscriptions");
+        }
+
+        [Fact]
+        [Trait(Category.AcceptanceType, Category.CheckIn)]
+        public void TestBlobEventTriggerSubscriptionsByInputObject()
+        {
+            RunPowerShellTest(_logger, "Test-BlobEventTriggerSubscriptionsByInputObject");
+        }
+
+        [Fact]
+        [Trait(Category.AcceptanceType, Category.CheckIn)]
+        public void TestBlobEventTriggerSubscriptionsByResourceId()
+        {
+            RunPowerShellTest(_logger, "Test-BlobEventTriggerSubscriptionsByResourceId");
+        }
     }
 }

src/DataFactory/DataFactoryV2.Test/ScenarioTests/TriggerTests.ps1

@@ -145,6 +145,199 @@ function Test-TriggerRun
     }
 }
 
+<#
+.SYNOPSIS
+Creates a trigger and then does a Get to compare the results.
+Starts and Stops trigger and checks that there is at least one Trigger Run
+Deletes the created trigger at the end.
+#>
+function Test-BlobEventTriggerSubscriptions
+{
+    $dfname = Get-DataFactoryName
+    $rgname = Get-ResourceGroupName
+    $rglocation = Get-ProviderLocation ResourceManagement
+    $dflocation = Get-ProviderLocation DataFactoryManagement
+
+    New-AzResourceGroup -Name $rgname -Location $rglocation -Force
+
+    try
+    {
+        Set-AzDataFactoryV2 -ResourceGroupName $rgname -Name $dfname -Location $dflocation -Force
+
+        $lsName = "foo1"
+        Set-AzDataFactoryV2LinkedService -ResourceGroupName $rgname -DataFactoryName $dfname -File .\Resources\linkedService.json -Name $lsName -Force
+
+        Set-AzDataFactoryV2Dataset -ResourceGroupName $rgname -DataFactoryName $dfname -Name "dsIn" -File .\Resources\dataset-dsIn.json -Force
+        Set-AzDataFactoryV2Dataset -ResourceGroupName $rgname -DataFactoryName $dfname -Name "ds0_0" -File .\Resources\dataset-ds0_0.json -Force
+        Set-AzDataFactoryV2Dataset -ResourceGroupName $rgname -DataFactoryName $dfname -Name "ds1_0" -File .\Resources\dataset-ds1_0.json -Force
+
+        $pipelineName = "samplePipeline"   
+        Set-AzDataFactoryV2Pipeline -ResourceGroupName $rgname -Name $pipelineName -DataFactoryName $dfname -File ".\Resources\pipeline.json" -Force
+
+        $triggername = "foo"
+        $expected = Set-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -File .\Resources\blobeventtrigger.json -Force
+        $actual = Get-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername
+
+        Verify-Trigger $expected $actual $rgname $dfname $triggername
+
+        $startDate = [DateTime]::Parse("09/10/2017")
+		Add-AzDataFactoryV2TriggerSubscription -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername
+		$status = Get-AzDataFactoryV2TriggerSubscriptionStatus -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername
+		while ($status.Status -ne "Enabled"){
+			if ([Microsoft.Azure.Test.HttpRecorder.HttpMockServer]::Mode -ne [Microsoft.Azure.Test.HttpRecorder.HttpRecorderMode]::Playback) {
+				Start-Sleep -s 150
+			}
+			$status = Get-AzDataFactoryV2TriggerSubscriptionStatus -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername
+		}
+
+        Start-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -Force
+        $started = Get-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername
+
+        Assert-AreEqual 'Started' $started.RuntimeState 
+
+		Remove-AzDataFactoryV2TriggerSubscription -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -Force
+
+        Stop-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -Force
+        $stopped = Get-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername
+
+        Assert-AreEqual 'Stopped' $stopped.RuntimeState 
+
+        Remove-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -Force
+    }
+    finally
+    {
+        CleanUp $rgname $dfname
+    }
+}
+
+<#
+.SYNOPSIS
+Creates a trigger and then does a Get to compare the results.
+Starts and Stops trigger and checks that there is at least one Trigger Run
+Deletes the created trigger at the end.
+#>
+function Test-BlobEventTriggerSubscriptionsByInputObject
+{
+    $dfname = Get-DataFactoryName
+    $rgname = Get-ResourceGroupName
+    $rglocation = Get-ProviderLocation ResourceManagement
+    $dflocation = Get-ProviderLocation DataFactoryManagement
+
+    New-AzResourceGroup -Name $rgname -Location $rglocation -Force
+
+    try
+    {
+        Set-AzDataFactoryV2 -ResourceGroupName $rgname -Name $dfname -Location $dflocation -Force
+
+        $lsName = "foo1"
+        Set-AzDataFactoryV2LinkedService -ResourceGroupName $rgname -DataFactoryName $dfname -File .\Resources\linkedService.json -Name $lsName -Force
+
+        Set-AzDataFactoryV2Dataset -ResourceGroupName $rgname -DataFactoryName $dfname -Name "dsIn" -File .\Resources\dataset-dsIn.json -Force
+        Set-AzDataFactoryV2Dataset -ResourceGroupName $rgname -DataFactoryName $dfname -Name "ds0_0" -File .\Resources\dataset-ds0_0.json -Force
+        Set-AzDataFactoryV2Dataset -ResourceGroupName $rgname -DataFactoryName $dfname -Name "ds1_0" -File .\Resources\dataset-ds1_0.json -Force
+
+        $pipelineName = "samplePipeline"   
+        Set-AzDataFactoryV2Pipeline -ResourceGroupName $rgname -Name $pipelineName -DataFactoryName $dfname -File ".\Resources\pipeline.json" -Force
+
+        $triggername = "foo"
+        $expected = Set-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -File .\Resources\blobeventtrigger.json -Force
+        $actual = Get-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername
+
+        Verify-Trigger $expected $actual $rgname $dfname $triggername
+
+		Add-AzDataFactoryV2TriggerSubscription $actual
+		$status = Get-AzDataFactoryV2TriggerSubscriptionStatus $actual
+		while ($status.Status -ne "Enabled"){
+			if ([Microsoft.Azure.Test.HttpRecorder.HttpMockServer]::Mode -ne [Microsoft.Azure.Test.HttpRecorder.HttpRecorderMode]::Playback) {
+				Start-Sleep -s 150
+			}
+			$status = Get-AzDataFactoryV2TriggerSubscriptionStatus $actual
+		}
+
+        Start-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -Force
+        $started = Get-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername
+
+        Assert-AreEqual 'Started' $started.RuntimeState 
+
+		Remove-AzDataFactoryV2TriggerSubscription $started -Force
+
+        Stop-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -Force
+        $stopped = Get-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername
+
+        Assert-AreEqual 'Stopped' $stopped.RuntimeState 
+
+        Remove-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -Force
+    }
+    finally
+    {
+        CleanUp $rgname $dfname
+    }
+}
+
+<#
+.SYNOPSIS
+Creates a trigger and then does a Get to compare the results.
+Starts and Stops trigger and checks that there is at least one Trigger Run
+Deletes the created trigger at the end.
+#>
+function Test-BlobEventTriggerSubscriptionsByResourceId
+{
+    $dfname = Get-DataFactoryName
+    $rgname = Get-ResourceGroupName
+    $rglocation = Get-ProviderLocation ResourceManagement
+    $dflocation = Get-ProviderLocation DataFactoryManagement
+
+    New-AzResourceGroup -Name $rgname -Location $rglocation -Force
+
+    try
+    {
+        Set-AzDataFactoryV2 -ResourceGroupName $rgname -Name $dfname -Location $dflocation -Force
+
+        $lsName = "foo1"
+        Set-AzDataFactoryV2LinkedService -ResourceGroupName $rgname -DataFactoryName $dfname -File .\Resources\linkedService.json -Name $lsName -Force
+
+        Set-AzDataFactoryV2Dataset -ResourceGroupName $rgname -DataFactoryName $dfname -Name "dsIn" -File .\Resources\dataset-dsIn.json -Force
+        Set-AzDataFactoryV2Dataset -ResourceGroupName $rgname -DataFactoryName $dfname -Name "ds0_0" -File .\Resources\dataset-ds0_0.json -Force
+        Set-AzDataFactoryV2Dataset -ResourceGroupName $rgname -DataFactoryName $dfname -Name "ds1_0" -File .\Resources\dataset-ds1_0.json -Force
+
+        $pipelineName = "samplePipeline"   
+        Set-AzDataFactoryV2Pipeline -ResourceGroupName $rgname -Name $pipelineName -DataFactoryName $dfname -File ".\Resources\pipeline.json" -Force
+
+        $triggername = "foo"
+        $expected = Set-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -File .\Resources\blobeventtrigger.json -Force
+        $actual = Get-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername
+
+        Verify-Trigger $expected $actual $rgname $dfname $triggername
+
+		Add-AzDataFactoryV2TriggerSubscription -ResourceId $expected.Id
+		$status = Get-AzDataFactoryV2TriggerSubscriptionStatus -ResourceId $expected.Id
+		while ($status.Status -ne "Enabled"){
+			if ([Microsoft.Azure.Test.HttpRecorder.HttpMockServer]::Mode -ne [Microsoft.Azure.Test.HttpRecorder.HttpRecorderMode]::Playback) {
+				Start-Sleep -s 150
+			}
+			$status = Get-AzDataFactoryV2TriggerSubscriptionStatus -ResourceId $expected.Id
+		}
+
+        Start-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -Force
+        $started = Get-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername
+
+        Assert-AreEqual 'Started' $started.RuntimeState 
+
+		Remove-AzDataFactoryV2TriggerSubscription -ResourceId $expected.Id -Force
+
+        Stop-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -Force
+        $stopped = Get-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername
+
+        Assert-AreEqual 'Stopped' $stopped.RuntimeState 
+
+        Remove-AzDataFactoryV2Trigger -ResourceGroupName $rgname -DataFactoryName $dfname -Name $triggername -Force
+    }
+    finally
+    {
+        CleanUp $rgname $dfname
+    }
+}
+
 <#
 .SYNOPSIS
 Creates a trigger and then does a Get with resource id to compare the results.