localbus

[benanderson_475]

hi , i am trying to work with localbus but i don't receive any logs from the groupcallback  function, i want to monitor several obj in a resident script.
in the attached i can see the handlers table but also udp{unconnected} maybe this is my problem ??

Code:

123456789101112131415161718

lb = require('localbus').new() lb:sethandler('groupwrite', groupcallback) lb:sethandler('groupread', groupcallback) lb:sethandler('groupresponse', groupcallback) log(lb) function groupcallback(event)      log(event)     if event.dst == '0/2/1' then        local value = knxdatatype.decode(event.datahex, dt.uint16)        log(value)       end end

many thanks

[fleeceable]

Hi!
Does script engine gives you any errors?

Check that on error log...

[admin]

You need to call step for it to receive data. You should also define callback before setting it.

Code:

123456789101112131415161718

if not lb then   lb = require('localbus').new(1)   function groupcallback(event)       log(event)          if event.dst == '0/2/1' then           local value = knxdatatype.decode(event.datahex, dt.uint16)           log(value)     end   end   lb:sethandler('groupwrite', groupcallback)   lb:sethandler('groupread', groupcallback)   lb:sethandler('groupresponse', groupcallback) end lb:step()

[benanderson_475]

You need to call step for it to receive data. You should also define callback before setting it.

Code:

123456789101112131415161718

if not lb then   lb = require('localbus').new(1)   function groupcallback(event)      log(event)         if event.dst == '0/2/1' then          local value = knxdatatype.decode(event.datahex, dt.uint16)          log(value)     end   end   lb:sethandler('groupwrite', groupcallback)   lb:sethandler('groupread', groupcallback)   lb:sethandler('groupresponse', groupcallback) end lb:step()

Many Thanks

[Svanda]

You need to call step for it to receive data. You should also define callback before setting it.

Code:

123456789101112131415161718

if not lb then   lb = require('localbus').new(1)   function groupcallback(event)      log(event)         if event.dst == '0/2/1' then          local value = knxdatatype.decode(event.datahex, dt.uint16)          log(value)     end   end   lb:sethandler('groupwrite', groupcallback)   lb:sethandler('groupread', groupcallback)   lb:sethandler('groupresponse', groupcallback) end lb:step()

Hello Admin,
can I ask you for documentation for localbus library?

We are confusing what happens with queue if is too long?
Can get somehow batch of e.g. ten telegrams in one step?
Can we filter somehow range of group addresess to listen?
What is return value of lb.step?

Thanks a lot!

[admin]

There's no documentation because localbus is not needed for most users.

We are confusing what happens with queue if is too long?

If the queue is too long then new message will be dropped.

Can get somehow batch of e.g. ten telegrams in one step?

You can use lb:loop(timeout) to loop for a certain time. For this to work correctly you should set default timeout to a smaller value when creating localbus socket via new(timeout).

Can we filter somehow range of group addresess to listen?

Localbus will receive all messages anyway so you need to filter groups manually in callback functions.

What is return value of lb.step?

step return true when any message was received or nil, error on timeout.

If you want to correctly communicate with multiple sockets/timers the easiest way is to use copas.
Here's how to wrap localbus socket into copas context:

Code:

123456

copas.addserver(lb.sock, function()   lb.sock = copas.wrap(lb.sock)   while true do     lb:step()   end end, 1)