Refactoring

Extracted Get-PipelineProcessor

Author: alan-null

Slack.Backup/Private/pipelines/Get-PipelineProcessor.ps1

@@ -0,0 +1,22 @@
+function Get-PipelineProcessor {
+    param (
+        [Parameter(Mandatory = $true, Position = 0 )]
+        [string]$Name,
+
+        [Parameter(Mandatory = $true, Position = 0 )]
+        [System.Object[]]$Parameters
+    )
+    process {
+        Get-Command -Name $Name -CommandType Alias | `
+            Sort-Object -Property Name | `
+            ? { $_.Parameters.Count -gt 0 } | `
+            ? {
+            $commandParameters = $_.Parameters
+            $valid = $true
+            $Parameters | % {
+                $valid = $valid -and ($commandParameters.ContainsKey($_.Name) -and $commandParameters[$_.Name].ParameterType.Name -eq $_.Type)
+            }
+            $valid
+        }
+    }
+}

Slack.Backup/Private/pipelines/Invoke-FileDataProcessingPipeline.ps1

@@ -4,15 +4,10 @@ function Invoke-FileDataProcessingPipeline {
         [byte[]]$SlackFile
     )
     process {
-        Get-Command -Name Invoke-FileDataProcessor* -CommandType Alias | `
-            Sort-Object -Property Name | `
-            ? { $_.Parameters.Count -gt 0 } | `
-            ? { $_.Parameters.ContainsKey("SlackFile") } | `
-            ? { $_.Parameters['SlackFile'].ParameterType.Name -eq [byte[]] } | `
-            % {
-                Write-Verbose "Invoking processor: $($_.Name)"
-                $SlackFile = &($_.Name) -SlackFile $SlackFile
-            }
+        Get-PipelineProcessor -Name Invoke-FileDataProcessor* -Parameters @( @{Name = "SlackFile"; Type = [byte[]] } ) | % {
+            Write-Verbose "Invoking processor: $($_.Name)"
+            $SlackFile = &($_.Name) -SlackFile $SlackFile
+        }
         $SlackFile
     }
 }

Slack.Backup/Private/pipelines/Invoke-FileProcessingPipeline.ps1

@@ -4,15 +4,10 @@ function Invoke-FileProcessingPipeline {
         [System.Object]$SlackFile
     )
     process {
-        Get-Command -Name Invoke-FileProcessor* -CommandType Alias | `
-            Sort-Object -Property Name | `
-            ? { $_.Parameters.Count -gt 0 } | `
-            ? { $_.Parameters.ContainsKey("SlackFile") } | `
-            ? { $_.Parameters['SlackFile'].ParameterType.Name -eq "Object" } | `
-            % {
-                Write-Verbose "Invoking processor: $($_.Name)"
-                $SlackFile = &($_.Name) -SlackFile $SlackFile
-            }
+        Get-PipelineProcessor -Name Invoke-FileProcessor* -Parameters @( @{Name = "SlackFile"; Type = "Object" } ) | % {
+            Write-Verbose "Invoking processor: $($_.Name)"
+            $SlackFile = &($_.Name) -SlackFile $SlackFile
+        }
         $SlackFile
     }
 }

Slack.Backup/Private/pipelines/Invoke-MessageProcessingPipeline.ps1

@@ -4,14 +4,10 @@ function Invoke-MessageProcessingPipeline {
         [System.Object]$SlackMessage
     )
     process {
-        Get-Command -Name Invoke-MessageProcessor*  -CommandType Alias | `
-            Sort-Object -Property Name | `
-            ? { $_.Parameters.ContainsKey("SlackMessage") } | `
-            ? { $_.Parameters['SlackMessage'].ParameterType.Name -eq "Object" } | `
-            % {
-                Write-Verbose "Invoking processor: $($_.Name)"
-                $SlackMessage = &($_.Name) -SlackMessage $SlackMessage
-            }
+        Get-PipelineProcessor -Name Invoke-MessageProcessor* -Parameters @( @{Name = "SlackMessage"; Type = "Object" } ) | % {
+            Write-Verbose "Invoking processor: $($_.Name)"
+            $SlackMessage = &($_.Name) -SlackMessage $SlackMessage
+        }
         $SlackMessage
     }
 }