Internal/Invoke-RScript.ps1

function Invoke-RScript {

    <#

    .SYNOPSIS Invokes a RScript command

    .PARAMETER ArgumentList
    Specifies the arguments that are passed to RScript.
    All arguments are casted to string.

    #>


    [CmdletBinding()]
    param (
        [Parameter( Mandatory )]
        [string[]]
        $ArgumentList,

        [Parameter(Mandatory=$true)]
        [ValidateNotNull()]
        [int]
        $Timeout,

        [switch] $ParseOutput
    )

    if ( -not $RScriptPath ) {
        Write-Error 'Path to Rscript.exe is not net. Please run Set-RScriptPath.'
    } elseif ( -not ( Test-Path $RScriptPath -PathType Leaf )) {
        Write-Error 'Path to Rscript.exe is invalid. Please re-run Set-RScriptPath.'
    }

    $arguments = $ArgumentList | ForEach-Object {
        Write-Output '-e'
        Write-Output $_
    }

    # Configure process
    $process = New-Object System.Diagnostics.Process
    $process.StartInfo.Filename = $RScriptPath
    $process.StartInfo.Arguments = $arguments
    $process.StartInfo.RedirectStandardOutput = $true
    $process.StartInfo.RedirectStandardError = $true
    $process.StartInfo.UseShellExecute = $false
    $process.StartInfo.CreateNoWindow = $true

    # Connect output events
    $standardOutputBuffer = New-Object System.Collections.SortedList
    $standardErrorBuffer = New-Object System.Collections.SortedList

    $EventAction = {
        if ( -not [String]::IsNullOrEmpty( $EventArgs.Data )) {
            $Event.MessageData.Add( $event.EventIdentifier, $EventArgs.Data ) | Out-Null
            Write-Verbose $EventArgs.Data
        }
    }

    $outputEvent = Register-ObjectEvent -InputObject $process `
        -EventName 'OutputDataReceived' -Action $EventAction -MessageData $standardOutputBuffer
    $errorEvent = Register-ObjectEvent -InputObject $process `
        -EventName 'ErrorDataReceived' -Action $EventAction -MessageData $standardErrorBuffer

    try {
        $processCall = "$( $process.StartInfo.FileName ) $( $process.StartInfo.Arguments )"
        if ( $processCall.Length -ge 250 ) { $processCall = "$( $processCall.Substring(252) )..." }
        Write-Verbose "Process started: $processCall"

        $process.Start() | Out-Null
        $process.BeginOutputReadLine()
        $process.BeginErrorReadLine()

        # Wait for exit
        if ( $Timeout ) {
            $process.WaitForExit( $Timeout * 1000 ) | Out-Null
        }
        $process.WaitForExit() | Out-Null # Ensure streams are flushed

        Write-Verbose "Process exited (code $( $process.ExitCode )) after $( $process.TotalProcessorTime )."
    } finally {
        Unregister-Event -SourceIdentifier $outputEvent.Name
        Unregister-Event -SourceIdentifier $errorEvent.Name
    }

    $lineIndex = 0

    # Process output
    if ( $standardOutputBuffer.Count  ) {
        if ( $ParseOutput ) {
            $standardOutputBuffer.Values | ForEach-Object {
                $lineIndex += 1
                $prefix = "[$lineIndex] "
                if ( $_.StartsWith( $prefix ) ) {
                    Write-Output $_.Substring( $prefix.Length ).Trim()
                }
            }
        } else {
            $standardOutput = $standardOutputBuffer.Values -join "`r`n"
            Write-Output $standardOutput
        }
    } else {
        Write-Verbose 'No process output'
    }

    # process error
    if ( $standardErrorBuffer.Count ) {
        foreach ( $line in $standardErrorBuffer.Values ) {
            if ( $line ) {
                Write-Warning $line -ErrorAction 'Continue'
            }
        }
    } else {
        Write-Verbose 'No process error output'
    }

    if ( $process.ExitCode ) {
        Write-Error "Proccess failed ($processCall) after $( $process.TotalProcessorTime )."
    }

    if ( $Timeout -gt 0 -and $process.TotalProcessorTime.TotalSeconds -ge $Timeout ) {
        Write-Error "Process timed out ($processCall) after $( $process.TotalProcessorTime )."
    }
}