publisher.lua

Go to the documentation of this file.

#!/usr/bin/env lua
 
package.cpath = "/lib/lua/?.so;" .. package.cpath
 
require "ubus"
require "uloop"
 
--[[
  A demo of ubus publisher binding. Should be run before subscriber.lua
--]]
 
 
uloop.init()
 
print("Connect")
local conn = ubus.connect()
if not conn then
        error("Failed to connect to ubus")
end
 
local ubus_objects = {
        ["com.broadcom.gpon_md"] = {
                hello = {
                        function(req, msg)
                                conn:reply(req, {message="foo"});
                                print("Call to function 'hello'")
                                for k, v in pairs(msg) do
                                        print("key=" .. k .. " value=" .. tostring(v))
                                end
                        end, {id = ubus.INT32, msg = ubus.STRING }
                },
        }, 
        test = {
                hello = {
                        function(req, msg)
                                conn:reply(req, {message="foo"});
                                print("Call to function 'hello'")
                                for k, v in pairs(msg) do
                                        print("key=" .. k .. " value=" .. tostring(v))
                                end
                        end, {id = ubus.INT32, msg = ubus.STRING }
                },
                hello1 = {
                        function(req)
                                conn:reply(req, {message="foo1"});
                                conn:reply(req, {message="foo2"});
                                print("Call to function 'hello1'")
                        end, {id = ubus.INT32, msg = ubus.STRING }
                },
                __subscriber_cb = function( subs )
                        print("total subs: ", subs )
                end
        }
}
 
print("Add objects")
conn:add( ubus_objects )
print("Objects added, starting loop")
 
-- start time
local timer
local counter = 0
function t()
        counter = counter + 1
        local params = {
                count = counter,
                text = "hello world"
        }
        conn:notify( ubus_objects.test.__ubusobj, "blabla", params )
        timer:set(1000)
end
timer = uloop.timer(t)
timer:set(1000)
 
print("Run loop")
uloop.run()