template for generic drivers - Printable Version

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()

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