status-im/nim-websock
2
0
Fork 0
mirror of https://github.com/status-im/nim-websock.git synced 2025-03-01 17:50:31 +00:00
Code Issues Projects Releases Wiki Activity

text formatting: consistent indentation

Browse Source 
using 2 spaces for both `testtlswebsockets.nim` and
`tests/testwebsockets.nim`
This commit is contained in:
jangko 2021-05-21 15:56:13 +07:00
parent 2ed87ca58d
commit 4de768910b
No known key found for this signature in database
GPG Key ID: 31702AE10541E6B9
2 changed files with 730 additions and 726 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
tests/testtlswebsockets.nim
View File

@ -28,7 +28,6 @@ let
secureKey = TLSPrivateKey.init(SecureKey) secureKey = TLSPrivateKey.init(SecureKey)
secureCert = TLSCertificate.init(SecureCert) secureCert = TLSCertificate.init(SecureCert)
suite "Test websocket TLS handshake": suite "Test websocket TLS handshake":
teardown: teardown:
await server.closeWait() await server.closeWait()

17
tests/testwebsockets.nim
View File

@ -184,7 +184,12 @@ suite "Test transmission":
await wsClient.close() await wsClient.close()
test "Client - test reading simple frame": test "Client - test reading simple frame":
#[let testString = "Hello!" when defined(windows):
# TODO: fix this err on Windows
# Unhandled exception: Stream is already closed! [AsyncStreamIncorrectDefect]
skip()
else:
let testString = "Hello!"
proc cb(r: RequestFence): Future[HttpResponseRef] {.async.} = proc cb(r: RequestFence): Future[HttpResponseRef] {.async.} =
if r.isErr(): if r.isErr():
return dumbResponse() return dumbResponse()
@ -207,10 +212,7 @@ suite "Test transmission":
var clientRes = await wsClient.recv() var clientRes = await wsClient.recv()
check string.fromBytes(clientRes) == testString check string.fromBytes(clientRes) == testString
await waitForClose(wsClient)]# await waitForClose(wsClient)
# TODO: fix this err on Windows
# Unhandled exception: Stream is already closed! [AsyncStreamIncorrectDefect]
skip()
test "AsyncStream leaks test": test "AsyncStream leaks test":
check: check:
@ -347,6 +349,7 @@ suite "Test ping-pong":
check: check:
ping ping
pong pong
let res = HttpServerRef.new(address, cb) let res = HttpServerRef.new(address, cb)
server = res.get() server = res.get()
server.start() server.start()
@ -494,6 +497,7 @@ suite "Test Closing":
let request = r.get() let request = r.get()
check request.uri.path == "/ws" check request.uri.path == "/ws"
proc closeServer(status: Status, reason: string): CloseResult{.gcsafe, proc closeServer(status: Status, reason: string): CloseResult{.gcsafe,
raises: [Defect].} = raises: [Defect].} =
try: try:
@ -716,7 +720,6 @@ suite "Test Closing":
# Close with payload of length 2 # Close with payload of length 2
await wsClient.close(reason = "HH") await wsClient.close(reason = "HH")
test "AsyncStream leaks test": test "AsyncStream leaks test":
check: check:
getTracker("async.stream.reader").isLeaked() == false getTracker("async.stream.reader").isLeaked() == false
@ -724,6 +727,7 @@ suite "Test Closing":
getTracker("stream.server").isLeaked() == false getTracker("stream.server").isLeaked() == false
getTracker("stream.transport").isLeaked() == false getTracker("stream.transport").isLeaked() == false
suite "Test Payload": suite "Test Payload":
teardown: teardown:
await server.closeWait() await server.closeWait()
@ -846,6 +850,7 @@ suite "Test Payload":
check: check:
ping ping
pong pong
test "AsyncStream leaks test": test "AsyncStream leaks test":
check: check:
getTracker("async.stream.reader").isLeaked() == false getTracker("async.stream.reader").isLeaked() == false