template for generic drivers

[rocfusion]

Hi,

Maybe this helps someone.  Here is basic bi-directional example for connecting the LM to some device that is controlled over TCP.

Thanks,

Roger


Place a resident script with a sleep interval of 0

Code:

if not ready then
 socket = require("socket")
 copas = require("copas")
 alert('not Ready')
 ready=true
 
 function parse(data)
  alert('parsing: %s', data)
   -- use this function to parse the data you receive from the tcp device
 end

  function sendTo(command)
   skt:send(command)
   --optional delay between commands sent tcp device you are controlling
   sleep(1)
  end
   
 function fromKNX(command)
  alert('from knx: %s', command)
   local telegram = string.split(command,',')
   -- for every object that has the event script
   if(telegram[1]=='1/1/1')then      
      sendTo('thisComand ='..telegram[2]..'\r')
   end
 end

  -- use this function to get the status of the remote tcp device
  function init()
   alert('Getting status of tcp device')
   sendTo('some command \r')

  end
 
 local server = socket.udp()
 server:setsockname("127.0.0.1",23456)
 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: ", erro)
       break
     end
     alert("Received data, bytes: "..s)
     fromKNX(s)
   end
 end
 copas.addserver(server, handler, 1)  
end

if not skt then
  -- create tcp client
  skt, err = socket.connect('10.10.10.41', 4999)
  -- 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
          parse(resp)
        end
      end)
    if skt then
      alert('[tcp-client] connection ok')
      -- optional init function use to get initial status of remote device
      -- 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()

Create event based script for

Code:

if event.type=='groupwrite' then
 require('socket')
 local client = socket.udp()
 local evt = event.dst..','..tostring(event.getvalue())
 if client then
   client:sendto(evt, '127.0.0.1', 23456)
   client:close()
 end
elseif event.type =='groupread' then
 grp.response(event.dst,event.getvalue())
end