ELK M1 Alarm panel

[rocfusion]

Hi Admin,

Thank you, I am trying to get the connection working with ssl,  but the connection gets closed.  I want to use copas since this gives more flexibility of building a non-blocking solution.  I have the option also to run code in separate threads. 

Code:

if not ready then
 socket = require("socket")
 copas = require("copas")
 require('ssl')
 ready=true
 esys = {}  

 function checksum(str)
   local sum = 0
   for i = 1, #str do
     sum = (sum + string.byte(str,i)) % 256
   end
   x = 256-sum
   return string.format('%02X', 256 - sum)
 end
 
 function validchecksum(str)
   calccs = checksum(str:sub(1, -3))    -- calculated checksum from message data
   recvcs = str:sub(-2, -1)        -- received checksum
   return calccs == recvcs        -- when they the same return true
 end
 
 --helper functions to round and increment values  
 function increment(n)
   n = n + 1
   return n
 end
 
 function parse(data)
   alert('elk parsing: %s', data)
   if(validchecksum(data)==true)then
     local response = string.sub(data,3,-5)
     alert('elk message is: %s',response)
   end
 end
 
 function sendElk(command)
   skt:send(command)
   sleep(1)    
 end
   
 function init()
   alert('running init')

 end
 
 function fromKNX(command)
   local telegram = string.split(command,',')
   alert('from knx %s',command)

 end
 
 local server = socket.udp()
 server:setsockname("127.0.0.1",33456)
 function handler(skts)
   skts = copas.wrap(skts)
   alert("UDP connection handler")
   while true do
     local s, err
     alert("UDP receiving..")
     s, erro = skts:receive(2048)
     if not s then
       alert("UDP Receive error: %s", erro)
       break
     end
     alert("UDP Received data, bytes: %s",s)
     fromKNX(s)
   end
 end
   
 copas.addserver(server, handler, 1)


--[[ co = copas.addthread(function()
     while true do  
       copas.sleep(5) -- wait 5 seconds in case of other events

       copas.sleep(-1) -- put the thread to sleep until wakeup is called
     end
   end)]]--
end

if not skt then
 -- create tcp client
 sslparams = {
 mode = "client",
 protocol = "sslv3",
 key = "crt/ca-key.pem",
 certificate = "crt/client.pem",
 cafile = "crt/ca-cert.pem",
 verify = "peer",
 options = {"all", "sslv3"}
  }
 skt = copas.wrap(socket.tcp(), sslparams)

 skt, err = socket.connect('192.168.0.11', 2601)
 -- when theres no error connect ok, initialize
 if(not err) then
   skt:settimeout(0)
   -- add receive thread

   copas.addthread(function()
       while true do
         local resp,err = copas.receive(skt)
         -- if theres no connection start a new connection
         if not resp then
           alert("[tcp-client] Receive error: %s", err)
           copas.removeserver(skt)
           skt = nil
           break
         end
         if(string.find(resp,'^16XK')==false)then -- don't process timer messages
           local fd,prtd = pcall(parse,resp)
           if(fd==false)then
             alert("Error with parsemsg %s ",prtd)
           end
         end
       end
     end)
   if skt then
     alert('[tcp-client] connection ok')
     init()
     -- error while connecting,
   else
     if warningfailed then alert('[tcp-client] connection failed (conn): %s', err) end
     return
   end
 else
   alert('[tcp-client] error connecting %s',err)
   return
 end
end
copas.loop()

What am I doing wrong?

Thanks,


Roger