jyapayne/Nim
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Let asynchttpserver pass control of socket to cb for upgrades.

Browse source
This commit is contained in:
Dominik Picheta 2016-06-02 19:19:47 +01:00
commit 9df1704aa1
1 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
lib/pure/asynchttpserver.nim
View file

@ -28,8 +28,7 @@
import tables, asyncnet, asyncdispatch, parseutils, uri, strutils import tables, asyncnet, asyncdispatch, parseutils, uri, strutils
import httpcore import httpcore
export HttpHeaders, httpcore.`[]`, httpcore.`[]=`, httpcore.add, httpcore.`==`, export httpcore except parseHeader
httpcore.HttpCode, httpcore.HttpVersion, httpcore.toString
# TODO: If it turns out that the decisions that asynchttpserver makes # TODO: If it turns out that the decisions that asynchttpserver makes
# explicitly, about whether to close the client sockets or upgrade them are # explicitly, about whether to close the client sockets or upgrade them are
@ -186,6 +185,9 @@ proc processClient(client: AsyncSocket, address: string,
await request.respond(Http400, "Invalid request method. Got: " & await request.respond(Http400, "Invalid request method. Got: " &
request.reqMethod) request.reqMethod)
if "upgrade" in request.headers.getOrDefault("connection"):
return
# Persistent connections # Persistent connections
if (request.protocol == HttpVer11 and if (request.protocol == HttpVer11 and
request.headers.getOrDefault("connection").normalize != "close") or request.headers.getOrDefault("connection").normalize != "close") or