You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
40 lines
841 B
40 lines
841 B
local socket = require'socket'
|
|
local sync = require'websocket.sync'
|
|
local tools = require'websocket.tools'
|
|
|
|
local new = function(ws)
|
|
ws = ws or {}
|
|
local copas = require'copas'
|
|
|
|
local self = {}
|
|
|
|
self.sock_connect = function(self,host,port)
|
|
self.sock = socket.tcp()
|
|
if ws.timeout ~= nil then
|
|
self.sock:settimeout(ws.timeout)
|
|
end
|
|
local _,err = copas.connect(self.sock,host,port)
|
|
if err and err ~= 'already connected' then
|
|
self.sock:close()
|
|
return nil,err
|
|
end
|
|
end
|
|
|
|
self.sock_send = function(self,...)
|
|
return copas.send(self.sock,...)
|
|
end
|
|
|
|
self.sock_receive = function(self,...)
|
|
return copas.receive(self.sock,...)
|
|
end
|
|
|
|
self.sock_close = function(self)
|
|
self.sock:shutdown()
|
|
self.sock:close()
|
|
end
|
|
|
|
self = sync.extend(self)
|
|
return self
|
|
end
|
|
|
|
return new
|
|
|