lluv-websocket
This library includes stream interface for lluv and lluv backend for lua-websockets
lluv status
- PING/PONG - done
- WSS supports - done
- UTF8 validate - done (except some fast fail cases)
- IPv6 - done
- Check mask flag according RFC 6455 - done
- Validate RSV bits - done
- Extensions general (Section 9 of RFC 6455 and RFC 7692 ) - supported (need more tests)
- Extensions PMCE(Section 7 of RFC 7692) (permessage-deflate) - supported (need more tests)
lua-websockets backend status
- Async server - done (not tested)
- Async client - done (not tested)
- Sync client - done (not tested)
Autobahn|Testsuite
Usage
Echo client/server
local uv = require"lluv"
local ws = require"lluv.websocket"
local wsurl, sprot = "ws://127.0.0.1:12345", "echo"
local server = ws.new()
server:bind(wsurl, sprot, function(self, err)
if err then
print("Server error:", err)
return server:close()
end
server:listen(function(self, err)
if err then
print("Server listen:", err)
return server:close()
end
local cli = server:accept()
cli:handshake(function(self, err, protocol)
if err then
print("Server handshake error:", err)
return cli:close()
end
print("New server connection:", protocol)
cli:start_read(function(self, err, message, opcode)
if err then
print("Server read error:", err)
return cli:close()
end
cli:write(message, opcode)
end)
end)
end)
end)
local cli = ws.new()
cli:connect(wsurl, sprot, function(self, err)
if err then
print("Client connect error:", err)
return cli:close()
end
local counter = 1
cli:start_read(function(self, err, message, opcode)
if err then
print("Client read error:", err)
return cli:close()
end
print("Client recv:", message)
if counter > 10 then
return cli:close(function(self, ...)
print("Client close:", ...)
server:close(function(self, ...)
print("Server close:", ...)
end)
end)
end
cli:write("Echo #" .. counter)
counter = counter + 1
end)
cli:write("Echo #0")
end)
uv.run()