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:

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889

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:

1234567891011

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

[rocfusion]

Hi,

Maybe someone has an idea, based on the above template. I have this TCP device which the LM is controlling. In this case you set a color light value. The light changes to the requested value by cycling through values and returning back a status for each light change. Now there is one caveat, I can bring this light on from the off state to a particular color with the exception of white. When I turn on white it will cycle through to the last light color that was previously on and then the what value has to be resent to get it to change. The time taken to change between any color is variable, changing from one color to another is not always the same. The number of times I receive a the status that the light is changing color is inconsistent.

For example, I wish to turn the light to white and the last color the light was on with was green.

SEND GOTO WHITE

1 sec later, received LIGHT IS GREEN
1.1 sec later, received LIGHT IS GREEN
0.5 sec later, received LIGHT IS GREEN
2 sec later, received LIGHT IS GREEN
1 sec later, received LIGHT IS GREEN
1.5 sec later, received LIGHT IS GREEN

NOW I SEND GOTO WHITE

Now for some light colors I may have to wait for 42 responses before I can change to white.

My idea is to create some kind of timer every time a status is received. This gets cancelled on receiving a new status. When the timer is reached then send the request to change to white.

Now my question is how can I realize this when working with my template. Using Sleep is not really an option because whilst the status of the light is coming back there can be other status values coming back. Is there a way to delay a non blocking function call with the option to cancel it in LUA?

Thanks,


Roger

[rocfusion]

Nobody has an idea?

[admin]

Have a look at this script, it has timers together with receiving data from a socket:
https://forum.logicmachine.net/showthrea...45#pid2945

[rocfusion]

Hi,

That script I understand, in my script above I am working with Copas, its like nothing is being executed unless there is a send or receive to\from the socket.

Thanks,

Roger

[admin]

You have to use copas.step instead of copas.loop

[rocfusion]

Ok when I use step that code would only execute every time the socket is sending or receiving something.

[rocfusion]

Hi Admin,

I figured it out.  I can use copas to add a new thread, then put it to sleep until its needed.

Code:

1234567

 co = copas.addthread(function()     while true do       copas.sleep(2) -- wait 2 seconds       alert("send some command")       copas.sleep(-1) -- put the thread to sleep until wakeup is called     end   end)

then when I need to activate it I use

Code:

1

copas.wakeup(co)

Thanks,


Roger