#599

pending completion

Build # #599

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/8602c658d5741461b902bf1f0fe27b5b2420328b">8602c658d<a href="https://github.com/Badgerati/Pode/commit/8602c658d5741461b902bf1f0fe27b5b2420328b">">Merge </a><a class="double-link" href="https://github.com/Badgerati/Pode/commit/<a class="double-link" href="https://github.com/Badgerati/Pode/commit/21544ac33f9e8d2b702b483019344f71ff082979">21544ac33</a>">21544ac33</a><a href="https://github.com/Badgerati/Pode/commit/8602c658d5741461b902bf1f0fe27b5b2420328b"> into a1e2baa36">a1e2baa36</a>

Run Details

132 of 132 new or added lines in 8 files covered. (100.0%)

2568 of 5759 relevant lines covered (44.59%)

1.14 hits per line

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

0.0

/src/Private/WebServer.ps1

function Start-PodeWebServer
{
    param (
        [switch]
        $Browse
    )

    # setup any inbuilt middleware
    $inbuilt_middleware = @(
        (Get-PodeAccessMiddleware),
        (Get-PodeLimitMiddleware),
        (Get-PodePublicMiddleware),
        (Get-PodeRouteValidateMiddleware),
        (Get-PodeBodyMiddleware),
        (Get-PodeQueryMiddleware)
    )

    $PodeContext.Server.Middleware = ($inbuilt_middleware + $PodeContext.Server.Middleware)

    # work out which endpoints to listen on
    $endpoints = @()
    @(Get-PodeEndpoints -Type Http) | ForEach-Object {
        # get the ip address
        $_ip = "$($_.Address)"
        if ($_ip -ieq '0.0.0.0') {
            $_ip = '*'
        }

        # if this endpoint is https, generate a self-signed cert or bind an existing one
        if ($_.Ssl) {
            $addr = (Resolve-PodeValue -Check $_.IsIPAddress -TrueValue $_.Address -FalseValue $_.HostName)
            $selfSigned = $_.Certificate.SelfSigned
            Set-PodeCertificate -Address $addr -Port $_.Port -Certificate $_.Certificate.Name -Thumbprint $_.Certificate.Thumbprint -SelfSigned:$selfSigned
        }

        # add endpoint to list
        $endpoints += @{
            Prefix = "$($_.Protocol)://$($_ip):$($_.Port)/"
            HostName = $_.Url
        }
    }

    # create the listener on http and/or https
    $listener = New-Object System.Net.HttpListener

    try
    {
        # start listening on defined endpoints
        $endpoints | ForEach-Object {
            $listener.Prefixes.Add($_.Prefix)
        }

        $listener.Start()
    }
    catch {
        $_ | Write-PodeErrorLog

        if ($null -ne $Listener) {
            if ($Listener.IsListening) {
                $Listener.Stop()
            }

            Close-PodeDisposable -Disposable $Listener -Close
        }

        throw $_.Exception
    }

    # script for listening out for incoming requests
    $listenScript = {
        param (
            [Parameter(Mandatory=$true)]
            [ValidateNotNull()]
            $Listener,

            [Parameter(Mandatory=$true)]
            [int]
            $ThreadId
        )

        try
        {
            while ($Listener.IsListening -and !$PodeContext.Tokens.Cancellation.IsCancellationRequested)
            {
                # get request and response
                $context = (Wait-PodeTask -Task $Listener.GetContextAsync())

                try
                {
                    $request = $context.Request
                    $response = $context.Response

                    # reset event data
                    $WebEvent = @{
                        OnEnd = @()
                        Auth = @{}
                        Response = $response
                        Request = $request
                        Lockable = $PodeContext.Lockable
                        Path = ($request.RawUrl -isplit "\?")[0]
                        Method = $request.HttpMethod.ToLowerInvariant()
                        Protocol = $request.Url.Scheme
                        Endpoint = $request.Url.Authority
                        ContentType = $request.ContentType
                        ErrorType = $null
                        Cookies = $request.Cookies
                        PendingCookies = @{}
                        Streamed = $true
                        Route = $null
                        StaticContent = $null
                        Timestamp = [datetime]::UtcNow
                        TransferEncoding = $null
                        AcceptEncoding = $null
                    }

                    $WebEvent.TransferEncoding = (Get-PodeTransferEncoding -TransferEncoding (Get-PodeHeader -Name 'X-Transfer-Encoding') -ThrowError)
                    $WebEvent.AcceptEncoding = (Get-PodeAcceptEncoding -AcceptEncoding (Get-PodeHeader -Name 'Accept-Encoding') -ThrowError)

                    # set pode in server response header
                    Set-PodeServerHeader -AllowEmptyType

                    # add logging endware for post-request
                    Add-PodeRequestLogEndware -WebEvent $WebEvent

                    # invoke global and route middleware
                    if ((Invoke-PodeMiddleware -WebEvent $WebEvent -Middleware $PodeContext.Server.Middleware -Route $WebEvent.Path)) {
                        if ((Invoke-PodeMiddleware -WebEvent $WebEvent -Middleware $WebEvent.Route.Middleware))
                        {
                            # invoke the route
                            if ($null -ne $WebEvent.StaticContent) {
                                if ($WebEvent.StaticContent.IsDownload) {
                                    Set-PodeResponseAttachment -Path $e.Path
                                }
                                else {
                                    $cachable = $WebEvent.StaticContent.IsCachable
                                    Write-PodeFileResponse -Path $WebEvent.StaticContent.Source -MaxAge $PodeContext.Server.Web.Static.Cache.MaxAge -Cache:$cachable
                                }
                            }
                            else {
                                Invoke-PodeScriptBlock -ScriptBlock $WebEvent.Route.Logic -Arguments (@($WebEvent) + @($WebEvent.Route.Arguments)) -Scoped -Splat
                            }
                        }
                    }
                }
                catch [System.Net.Http.HttpRequestException] {
                    $code = [int]($_.Exception.Data['PodeStatusCode'])
                    if ($code -le 0) {
                        $code = 400
                    }

                    Set-PodeResponseStatus -Code $code -Exception $_
                }
                catch {
                    $_ | Write-PodeErrorLog
                    $_.Exception | Write-PodeErrorLog -CheckInnerException
                    Set-PodeResponseStatus -Code 500 -Exception $_
                }
                finally {
                    Update-PodeServerRequestMetrics -WebEvent $WebEvent
                }

                # invoke endware specifc to the current web event
                $_endware = ($WebEvent.OnEnd + @($PodeContext.Server.Endware))
                Invoke-PodeEndware -WebEvent $WebEvent -Endware $_endware

                # close response stream (check if exists, as closing the writer closes this stream on unix)
                if ($response.OutputStream) {
                    Close-PodeDisposable -Disposable $response.OutputStream -Close -CheckNetwork
                }
            }
        }
        catch [System.OperationCanceledException] {}
        catch {
            $_ | Write-PodeErrorLog
            throw $_.Exception
        }
    }

    # start the runspace for listening on x-number of threads
    1..$PodeContext.Threads.Web | ForEach-Object {
        Add-PodeRunspace -Type 'Main' -ScriptBlock $listenScript `
            -Parameters @{ 'Listener' = $listener; 'ThreadId' = $_ }
    }

    # 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
            throw $_.Exception
        }
        finally {
            if ($null -ne $Listener) {
                if ($Listener.IsListening) {
                    $Listener.Stop()
                }

                Close-PodeDisposable -Disposable $Listener -Close
            }
        }
    }

    Add-PodeRunspace -Type 'Main' -ScriptBlock $waitScript -Parameters @{ 'Listener' = $listener }

    # browse to the first endpoint, if flagged
    if ($Browse) {
        Start-Process $endpoints[0].HostName
    }

    return @($endpoints.HostName)
}

1	function Start-PodeWebServer
2	{
3	param (
4	[switch]
5	$Browse
6	)
7
8	# setup any inbuilt middleware
9	$inbuilt_middleware = @(	×
10	(Get-PodeAccessMiddleware),	×
11	(Get-PodeLimitMiddleware),	×
12	(Get-PodePublicMiddleware),	×
13	(Get-PodeRouteValidateMiddleware),	×
14	(Get-PodeBodyMiddleware),	×
15	(Get-PodeQueryMiddleware)	×
16	)
17
18	$PodeContext.Server.Middleware = ($inbuilt_middleware + $PodeContext.Server.Middleware)	×
19
20	# work out which endpoints to listen on
21	$endpoints = @()	×
22	@(Get-PodeEndpoints -Type Http) \| ForEach-Object {	×
23	# get the ip address
24	$_ip = "$($_.Address)"	×
25	if ($_ip -ieq '0.0.0.0') {	×
26	$_ip = '*'	×
27	}
28
29	# if this endpoint is https, generate a self-signed cert or bind an existing one
30	if ($_.Ssl) {	×
31	$addr = (Resolve-PodeValue -Check $_.IsIPAddress -TrueValue $_.Address -FalseValue $_.HostName)	×
32	$selfSigned = $_.Certificate.SelfSigned	×
33	Set-PodeCertificate -Address $addr -Port $_.Port -Certificate $_.Certificate.Name -Thumbprint $_.Certificate.Thumbprint -SelfSigned:$selfSigned	×
34	}
35
36	# add endpoint to list
37	$endpoints += @{	×
38	Prefix = "$($_.Protocol)://$($_ip):$($_.Port)/"	×
39	HostName = $_.Url	×
40	}
41	}
42
43	# create the listener on http and/or https
44	$listener = New-Object System.Net.HttpListener	×
45
46	try
47	{
48	# start listening on defined endpoints
49	$endpoints \| ForEach-Object {	×
50	$listener.Prefixes.Add($_.Prefix)	×
51	}
52
53	$listener.Start()	×
54	}
55	catch {
56	$_ \| Write-PodeErrorLog	×
57
58	if ($null -ne $Listener) {	×
59	if ($Listener.IsListening) {	×
60	$Listener.Stop()	×
61	}
62
63	Close-PodeDisposable -Disposable $Listener -Close	×
64	}
65
66	throw $_.Exception	×
67	}
68
69	# script for listening out for incoming requests
70	$listenScript = {	×
71	param (
72	[Parameter(Mandatory=$true)]
73	[ValidateNotNull()]
74	$Listener,
75
76	[Parameter(Mandatory=$true)]
77	[int]
78	$ThreadId
79	)
80
81	try
82	{
83	while ($Listener.IsListening -and !$PodeContext.Tokens.Cancellation.IsCancellationRequested)	×
84	{
85	# get request and response
86	$context = (Wait-PodeTask -Task $Listener.GetContextAsync())	×
87
88	try
89	{
90	$request = $context.Request	×
91	$response = $context.Response	×
92
93	# reset event data
94	$WebEvent = @{	×
95	OnEnd = @()	×
96	Auth = @{}	×
97	Response = $response	×
98	Request = $request	×
99	Lockable = $PodeContext.Lockable	×
100	Path = ($request.RawUrl -isplit "\?")[0]	×
101	Method = $request.HttpMethod.ToLowerInvariant()	×
102	Protocol = $request.Url.Scheme	×
103	Endpoint = $request.Url.Authority	×
104	ContentType = $request.ContentType	×
105	ErrorType = $null	×
106	Cookies = $request.Cookies	×
107	PendingCookies = @{}	×
108	Streamed = $true	×
109	Route = $null	×
110	StaticContent = $null	×
111	Timestamp = [datetime]::UtcNow	×
112	TransferEncoding = $null	×
113	AcceptEncoding = $null	×
114	}
115
116	$WebEvent.TransferEncoding = (Get-PodeTransferEncoding -TransferEncoding (Get-PodeHeader -Name 'X-Transfer-Encoding') -ThrowError)	×
117	$WebEvent.AcceptEncoding = (Get-PodeAcceptEncoding -AcceptEncoding (Get-PodeHeader -Name 'Accept-Encoding') -ThrowError)	×
118
119	# set pode in server response header
120	Set-PodeServerHeader -AllowEmptyType	×
121
122	# add logging endware for post-request
123	Add-PodeRequestLogEndware -WebEvent $WebEvent	×
124
125	# invoke global and route middleware
126	if ((Invoke-PodeMiddleware -WebEvent $WebEvent -Middleware $PodeContext.Server.Middleware -Route $WebEvent.Path)) {	×
127	if ((Invoke-PodeMiddleware -WebEvent $WebEvent -Middleware $WebEvent.Route.Middleware))	×
128	{
129	# invoke the route
130	if ($null -ne $WebEvent.StaticContent) {	×
131	if ($WebEvent.StaticContent.IsDownload) {	×
132	Set-PodeResponseAttachment -Path $e.Path	×
133	}
134	else {
135	$cachable = $WebEvent.StaticContent.IsCachable	×
136	Write-PodeFileResponse -Path $WebEvent.StaticContent.Source -MaxAge $PodeContext.Server.Web.Static.Cache.MaxAge -Cache:$cachable	×
137	}
138	}
139	else {
140	Invoke-PodeScriptBlock -ScriptBlock $WebEvent.Route.Logic -Arguments (@($WebEvent) + @($WebEvent.Route.Arguments)) -Scoped -Splat	×
141	}
142	}
143	}
144	}
145	catch [System.Net.Http.HttpRequestException] {
146	$code = [int]($_.Exception.Data['PodeStatusCode'])	×
147	if ($code -le 0) {	×
148	$code = 400	×
149	}
150
151	Set-PodeResponseStatus -Code $code -Exception $_	×
152	}
153	catch {
154	$_ \| Write-PodeErrorLog	×
155	$_.Exception \| Write-PodeErrorLog -CheckInnerException	×
156	Set-PodeResponseStatus -Code 500 -Exception $_	×
157	}
158	finally {
159	Update-PodeServerRequestMetrics -WebEvent $WebEvent	×
160	}
161
162	# invoke endware specifc to the current web event
163	$_endware = ($WebEvent.OnEnd + @($PodeContext.Server.Endware))	×
164	Invoke-PodeEndware -WebEvent $WebEvent -Endware $_endware	×
165
166	# close response stream (check if exists, as closing the writer closes this stream on unix)
167	if ($response.OutputStream) {	×
168	Close-PodeDisposable -Disposable $response.OutputStream -Close -CheckNetwork	×
169	}
170	}
171	}
172	catch [System.OperationCanceledException] {}
173	catch {
174	$_ \| Write-PodeErrorLog	×
175	throw $_.Exception	×
176	}
177	}
178
179	# start the runspace for listening on x-number of threads
180	1..$PodeContext.Threads.Web \| ForEach-Object {	×
181	Add-PodeRunspace -Type 'Main' -ScriptBlock $listenScript `	×
182	-Parameters @{ 'Listener' = $listener; 'ThreadId' = $_ }	×
183	}
184
185	# script to keep web server listening until cancelled
186	$waitScript = {	×
187	param (
188	[Parameter(Mandatory=$true)]
189	[ValidateNotNull()]
190	$Listener
191	)
192
193	try
194	{
195	while ($Listener.IsListening -and !$PodeContext.Tokens.Cancellation.IsCancellationRequested)	×
196	{
197	Start-Sleep -Seconds 1	×
198	}
199	}
200	catch [System.OperationCanceledException] {}
201	catch {
202	$_ \| Write-PodeErrorLog	×
203	throw $_.Exception	×
204	}
205	finally {
206	if ($null -ne $Listener) {	×
207	if ($Listener.IsListening) {	×
208	$Listener.Stop()	×
209	}
210
211	Close-PodeDisposable -Disposable $Listener -Close	×
212	}
213	}
214	}
215
216	Add-PodeRunspace -Type 'Main' -ScriptBlock $waitScript -Parameters @{ 'Listener' = $listener }	×
217
218	# browse to the first endpoint, if flagged
219	if ($Browse) {	×
220	Start-Process $endpoints[0].HostName	×
221	}
222
223	return @($endpoints.HostName)	×
224	}

Badgerati / Pode / #599

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