#670

pending completion

Build # #670

Build Type

push

github-actions

Committed by

web-flow

Commit Message

<a href="https://github.com/Badgerati/Pode/commit/<a class=hub.com/Badgerati/Pode/commit/b521c9054dc75b9cabc8f6ed72c717ec1ce95779">b521c9054<a href="https://github.com/Badgerati/Pode/commit/b521c9054dc75b9cabc8f6ed72c717ec1ce95779">">Merge </a><a class="double-link" href="https://github.com/Badgerati/Pode/commit/<a class="double-link" href="https://github.com/Badgerati/Pode/commit/87c9dd7c091475cc4ed32065173bd0543fef0c3d">87c9dd7c0</a>">87c9dd7c0</a><a href="https://github.com/Badgerati/Pode/commit/b521c9054dc75b9cabc8f6ed72c717ec1ce95779"> into 073540543">073540543</a>

Run Details

155 of 155 new or added lines in 10 files covered. (100.0%)

2712 of 5602 relevant lines covered (48.41%)

1.25 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/Private/SignalServer.ps1

function Start-PodeSignalServer
{
    # work out which endpoints to listen on
    $endpoints = @()
    @(Get-PodeEndpoints -Type Ws) | ForEach-Object {
        # get the ip address
        $_ip = [string]($_.Address)
        $_ip = (Get-PodeIPAddressesForHostname -Hostname $_ip -Type All | Select-Object -First 1)
        $_ip = (Get-PodeIPAddress $_ip)

        # add endpoint to list
        $endpoints += @{
            Address = $_ip
            Port = $_.Port
            Certificate = $_.Certificate.Raw
            HostName = $_.Url
        }
    }

    # create the listener
    $listener = [Pode.PodeListener]::new($PodeContext.Tokens.Cancellation.Token)
    $listener.ErrorLoggingEnabled = (Test-PodeErrorLoggingEnabled)

    try
    {
        # register endpoints on the listener
        $endpoints | ForEach-Object {
            $socket = [Pode.PodeSocket]::new($_.Address, $_.Port, $PodeContext.Server.Sockets.Ssl.Protocols, $_.Certificate)
            $socket.ReceiveTimeout = $PodeContext.Server.Sockets.ReceiveTimeout
            $listener.Add($socket)
        }

        $listener.Start()
        $PodeContext.Server.WebSockets.Listener = $listener
    }
    catch {
        $_ | Write-PodeErrorLog
        $_.Exception | Write-PodeErrorLog -CheckInnerException
        Close-PodeDisposable -Disposable $listener
        throw $_.Exception
    }

    # script to write messages back to the client(s)
    $signalScript = {
        param(
            [Parameter(Mandatory=$true)]
            [ValidateNotNull()]
            $Listener
        )

        try {
            while ($Listener.IsListening -and !$PodeContext.Tokens.Cancellation.IsCancellationRequested)
            {
                $message = (Wait-PodeTask -Task $Listener.GetSignalAsync($PodeContext.Tokens.Cancellation.Token))

                # get the sockets for the message
                $sockets = @()

                # by clientId
                if (![string]::IsNullOrWhiteSpace($message.ClientId)) {
                    $sockets = @($Listener.WebSockets[$message.ClientId])
                }
                else {
                    $sockets = @($Listener.WebSockets.Values)

                    # by path
                    if (![string]::IsNullOrWhiteSpace($message.Path)) {
                        $sockets = @(foreach ($socket in $sockets) {
                            if ($socket.Path -ieq $message.Path) {
                                $socket
                                break
                            }
                        })
                    }
                }

                # do nothing if no socket found
                if (($null -eq $sockets) -or ($sockets.Length -eq 0)) {
                    continue
                }

                # send the message to all found sockets
                foreach ($socket in $sockets) {
                    try {
                        $socket.Context.Response.SendSignal($message)
                    }
                    catch {
                        $Listener.WebSockets.Remove($socket.ClientId) | Out-Nul
                    }
                }
            }
        }
        catch [System.OperationCanceledException] {}
        catch {
            $_ | Write-PodeErrorLog
            $_.Exception | Write-PodeErrorLog -CheckInnerException
            throw $_.Exception
        }
    }

    Add-PodeRunspace -Type 'Signals' -ScriptBlock $signalScript -Parameters @{ 'Listener' = $listener }

    # script to keep web server listening until cancelled
    $waitScript = {
        param(
            [Parameter(Mandatory=$true)]
            [ValidateNotNull()]
            $Listener
        )

        try {
            while ($Listener.IsListening -and !$PodeContext.Tokens.Cancellation.IsCancellationRequested) {
                Start-Sleep -Seconds 1
            }
        }
        catch [System.OperationCanceledException] {}
        catch {
            $_ | Write-PodeErrorLog
            $_.Exception | Write-PodeErrorLog -CheckInnerException
            throw $_.Exception
        }
        finally {
            Close-PodeDisposable -Disposable $Listener
        }
    }

    Add-PodeRunspace -Type 'Signals' -ScriptBlock $waitScript -Parameters @{ 'Listener' = $listener }
    return @($endpoints.HostName)
}

1	function Start-PodeSignalServer
2	{
3	# work out which endpoints to listen on
4	$endpoints = @()	×
5	@(Get-PodeEndpoints -Type Ws) \| ForEach-Object {	×
6	# get the ip address
7	$_ip = [string]($_.Address)	×
8	$_ip = (Get-PodeIPAddressesForHostname -Hostname $_ip -Type All \| Select-Object -First 1)	×
9	$_ip = (Get-PodeIPAddress $_ip)	×
10
11	# add endpoint to list
12	$endpoints += @{	×
13	Address = $_ip	×
14	Port = $_.Port	×
15	Certificate = $_.Certificate.Raw	×
16	HostName = $_.Url	×
17	}
18	}
19
20	# create the listener
21	$listener = [Pode.PodeListener]::new($PodeContext.Tokens.Cancellation.Token)	×
22	$listener.ErrorLoggingEnabled = (Test-PodeErrorLoggingEnabled)	×
23
24	try
25	{
26	# register endpoints on the listener
27	$endpoints \| ForEach-Object {	×
28	$socket = [Pode.PodeSocket]::new($_.Address, $_.Port, $PodeContext.Server.Sockets.Ssl.Protocols, $_.Certificate)	×
29	$socket.ReceiveTimeout = $PodeContext.Server.Sockets.ReceiveTimeout	×
30	$listener.Add($socket)	×
31	}
32
33	$listener.Start()	×
34	$PodeContext.Server.WebSockets.Listener = $listener	×
35	}
36	catch {
37	$_ \| Write-PodeErrorLog	×
38	$_.Exception \| Write-PodeErrorLog -CheckInnerException	×
39	Close-PodeDisposable -Disposable $listener	×
40	throw $_.Exception	×
41	}
42
43	# script to write messages back to the client(s)
44	$signalScript = {	×
45	param(
46	[Parameter(Mandatory=$true)]
47	[ValidateNotNull()]
48	$Listener
49	)
50
51	try {
52	while ($Listener.IsListening -and !$PodeContext.Tokens.Cancellation.IsCancellationRequested)	×
53	{
54	$message = (Wait-PodeTask -Task $Listener.GetSignalAsync($PodeContext.Tokens.Cancellation.Token))	×
55
56	# get the sockets for the message
57	$sockets = @()	×
58
59	# by clientId
60	if (![string]::IsNullOrWhiteSpace($message.ClientId)) {	×
61	$sockets = @($Listener.WebSockets[$message.ClientId])	×
62	}
63	else {
64	$sockets = @($Listener.WebSockets.Values)	×
65
66	# by path
67	if (![string]::IsNullOrWhiteSpace($message.Path)) {	×
68	$sockets = @(foreach ($socket in $sockets) {	×
69	if ($socket.Path -ieq $message.Path) {	×
70	$socket	×
71	break
72	}
73	})
74	}
75	}
76
77	# do nothing if no socket found
78	if (($null -eq $sockets) -or ($sockets.Length -eq 0)) {	×
79	continue
80	}
81
82	# send the message to all found sockets
83	foreach ($socket in $sockets) {	×
84	try {
85	$socket.Context.Response.SendSignal($message)	×
86	}
87	catch {
88	$Listener.WebSockets.Remove($socket.ClientId) \| Out-Nul	×
89	}
90	}
91	}
92	}
93	catch [System.OperationCanceledException] {}
94	catch {
95	$_ \| Write-PodeErrorLog	×
96	$_.Exception \| Write-PodeErrorLog -CheckInnerException	×
97	throw $_.Exception	×
98	}
99	}
100
101	Add-PodeRunspace -Type 'Signals' -ScriptBlock $signalScript -Parameters @{ 'Listener' = $listener }	×
102
103	# script to keep web server listening until cancelled
104	$waitScript = {	×
105	param(
106	[Parameter(Mandatory=$true)]
107	[ValidateNotNull()]
108	$Listener
109	)
110
111	try {
112	while ($Listener.IsListening -and !$PodeContext.Tokens.Cancellation.IsCancellationRequested) {	×
113	Start-Sleep -Seconds 1	×
114	}
115	}
116	catch [System.OperationCanceledException] {}
117	catch {
118	$_ \| Write-PodeErrorLog	×
119	$_.Exception \| Write-PodeErrorLog -CheckInnerException	×
120	throw $_.Exception	×
121	}
122	finally {
123	Close-PodeDisposable -Disposable $Listener	×
124	}
125	}
126
127	Add-PodeRunspace -Type 'Signals' -ScriptBlock $waitScript -Parameters @{ 'Listener' = $listener }	×
128	return @($endpoints.HostName)	×
129	}

Badgerati / Pode / #670

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous