2 * Copyright (C) 2012 Jo-Philipp Wich <jow@openwrt.org>
3 * Copyright (C) 2012 John Crispin <blogic@openwrt.org>
4 * Copyright (C) 2016 Iain Fraser <iainf@netduma.com>
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU Lesser General Public License version 2.1
8 * as published by the Free Software Foundation
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
18 #include <libubox/blobmsg.h>
19 #include <libubox/blobmsg_json.h>
23 #define MODNAME "ubus"
24 #define METANAME MODNAME ".meta"
26 static lua_State
*state
;
28 struct ubus_lua_connection
{
31 struct ubus_context
*ctx
;
34 struct ubus_lua_object
{
40 struct ubus_lua_event
{
41 struct ubus_event_handler e
;
45 struct ubus_lua_subscriber
{
46 struct ubus_subscriber s
;
52 ubus_lua_parse_blob(lua_State
*L
, struct blob_attr
*attr
, bool table
);
55 ubus_lua_parse_blob_array(lua_State
*L
, struct blob_attr
*attr
, size_t len
, bool table
)
60 struct blob_attr
*pos
;
64 __blob_for_each_attr(pos
, attr
, rem
)
66 rv
= ubus_lua_parse_blob(L
, pos
, table
);
71 lua_rawseti(L
, -2, idx
++);
78 ubus_lua_parse_blob(lua_State
*L
, struct blob_attr
*attr
, bool table
)
84 if (!blobmsg_check_attr(attr
, false))
87 if (table
&& blobmsg_name(attr
)[0])
89 lua_pushstring(L
, blobmsg_name(attr
));
93 data
= blobmsg_data(attr
);
94 len
= blobmsg_data_len(attr
);
96 switch (blob_id(attr
))
98 case BLOBMSG_TYPE_BOOL
:
99 lua_pushboolean(L
, *(uint8_t *)data
);
102 case BLOBMSG_TYPE_INT16
:
103 lua_pushinteger(L
, be16_to_cpu(*(uint16_t *)data
));
106 case BLOBMSG_TYPE_INT32
:
107 lua_pushinteger(L
, be32_to_cpu(*(uint32_t *)data
));
110 case BLOBMSG_TYPE_INT64
:
111 lua_pushnumber(L
, (double) be64_to_cpu(*(uint64_t *)data
));
114 case BLOBMSG_TYPE_DOUBLE
:
120 v
.u64
= be64_to_cpu(*(uint64_t *)data
);
121 lua_pushnumber(L
, v
.d
);
125 case BLOBMSG_TYPE_STRING
:
126 lua_pushstring(L
, data
);
129 case BLOBMSG_TYPE_ARRAY
:
130 ubus_lua_parse_blob_array(L
, data
, len
, false);
133 case BLOBMSG_TYPE_TABLE
:
134 ubus_lua_parse_blob_array(L
, data
, len
, true);
147 ubus_lua_format_blob_is_array(lua_State
*L
)
152 /* Find out whether table is array-like */
153 for (lua_pushnil(L
); lua_next(L
, -2); lua_pop(L
, 1))
156 if (lua_type(L
, -2) != LUA_TNUMBER
&& lua_type(L
, -2) != LUA_TINT
)
158 if (lua_type(L
, -2) != LUA_TNUMBER
)
165 cur
= lua_tointeger(L
, -2);
167 if ((cur
- 1) != prv
)
180 ubus_lua_format_blob_array(lua_State
*L
, struct blob_buf
*b
, bool table
);
183 ubus_lua_format_blob(lua_State
*L
, struct blob_buf
*b
, bool table
)
187 const char *key
= table
? lua_tostring(L
, -2) : NULL
;
189 switch (lua_type(L
, -1))
192 blobmsg_add_u8(b
, key
, (uint8_t)lua_toboolean(L
, -1));
199 if ((uint64_t)lua_tonumber(L
, -1) > INT_MAX
)
200 blobmsg_add_u64(b
, key
, (uint64_t)lua_tonumber(L
, -1));
202 blobmsg_add_u32(b
, key
, (uint32_t)lua_tointeger(L
, -1));
207 case LUA_TLIGHTUSERDATA
:
208 blobmsg_add_string(b
, key
, lua_tostring(L
, -1));
212 if (ubus_lua_format_blob_is_array(L
))
214 c
= blobmsg_open_array(b
, key
);
215 rv
= ubus_lua_format_blob_array(L
, b
, false);
216 blobmsg_close_array(b
, c
);
220 c
= blobmsg_open_table(b
, key
);
221 rv
= ubus_lua_format_blob_array(L
, b
, true);
222 blobmsg_close_table(b
, c
);
235 ubus_lua_format_blob_array(lua_State
*L
, struct blob_buf
*b
, bool table
)
237 for (lua_pushnil(L
); lua_next(L
, -2); lua_pop(L
, 1))
239 if (!ubus_lua_format_blob(L
, b
, table
))
251 ubus_lua_connect(lua_State
*L
)
253 struct ubus_lua_connection
*c
;
254 const char *sockpath
= luaL_optstring(L
, 1, NULL
);
255 int timeout
= luaL_optint(L
, 2, 30);
257 if ((c
= lua_newuserdata(L
, sizeof(*c
))) != NULL
&&
258 (c
->ctx
= ubus_connect(sockpath
)) != NULL
)
260 ubus_add_uloop(c
->ctx
);
261 c
->timeout
= timeout
;
262 memset(&c
->buf
, 0, sizeof(c
->buf
));
263 luaL_getmetatable(L
, METANAME
);
264 lua_setmetatable(L
, -2);
268 /* NB: no errors from ubus_connect() yet */
270 lua_pushinteger(L
, UBUS_STATUS_UNKNOWN_ERROR
);
276 ubus_lua_objects_cb(struct ubus_context
*c
, struct ubus_object_data
*o
, void *p
)
278 lua_State
*L
= (lua_State
*)p
;
280 lua_pushstring(L
, o
->path
);
281 lua_rawseti(L
, -2, lua_objlen(L
, -2) + 1);
285 ubus_lua_objects(lua_State
*L
)
288 struct ubus_lua_connection
*c
= luaL_checkudata(L
, 1, METANAME
);
289 const char *path
= (lua_gettop(L
) >= 2) ? luaL_checkstring(L
, 2) : NULL
;
292 rv
= ubus_lookup(c
->ctx
, path
, ubus_lua_objects_cb
, L
);
294 if (rv
!= UBUS_STATUS_OK
)
298 lua_pushinteger(L
, rv
);
306 ubus_method_handler(struct ubus_context
*ctx
, struct ubus_object
*obj
,
307 struct ubus_request_data
*req
, const char *method
,
308 struct blob_attr
*msg
)
310 struct ubus_lua_object
*o
= container_of(obj
, struct ubus_lua_object
, o
);
313 lua_getglobal(state
, "__ubus_cb");
314 lua_rawgeti(state
, -1, o
->r
);
315 lua_getfield(state
, -1, method
);
316 lua_remove(state
, -2);
317 lua_remove(state
, -2);
319 if (lua_isfunction(state
, -1)) {
320 lua_pushlightuserdata(state
, req
);
324 ubus_lua_parse_blob_array(state
, blob_data(msg
), blob_len(msg
), true);
325 lua_call(state
, 2, 1);
326 if (lua_isnumber(state
, -1))
327 rv
= lua_tonumber(state
, -1);
335 static int lua_gettablelen(lua_State
*L
, int index
)
341 while (lua_next(L
, index
) != 0) {
349 static int ubus_lua_reply(lua_State
*L
)
351 struct ubus_lua_connection
*c
= luaL_checkudata(L
, 1, METANAME
);
352 struct ubus_request_data
*req
;
354 luaL_checktype(L
, 3, LUA_TTABLE
);
355 blob_buf_init(&c
->buf
, 0);
357 if (!ubus_lua_format_blob_array(L
, &c
->buf
, true))
360 lua_pushinteger(L
, UBUS_STATUS_INVALID_ARGUMENT
);
364 req
= lua_touserdata(L
, 2);
365 ubus_send_reply(c
->ctx
, req
, c
->buf
.head
);
370 static int ubus_lua_defer_request(lua_State
*L
)
372 struct ubus_lua_connection
*c
= luaL_checkudata(L
, 1, METANAME
);
373 struct ubus_request_data
*req
= lua_touserdata(L
, 2);
374 struct ubus_request_data
*new_req
= lua_newuserdata(L
, sizeof(struct ubus_request_data
));
375 ubus_defer_request(c
->ctx
, req
, new_req
);
380 static int ubus_lua_complete_deferred_request(lua_State
*L
)
382 struct ubus_lua_connection
*c
= luaL_checkudata(L
, 1, METANAME
);
383 struct ubus_request_data
*req
= lua_touserdata(L
, 2);
384 int ret
= luaL_checkinteger(L
, 3);
385 ubus_complete_deferred_request(c
->ctx
, req
, ret
);
390 static int ubus_lua_load_methods(lua_State
*L
, struct ubus_method
*m
)
392 struct blobmsg_policy
*p
;
396 /* get the function pointer */
397 lua_pushinteger(L
, 1);
400 /* get the policy table */
401 lua_pushinteger(L
, 2);
404 /* check if the method table is valid */
405 if ((lua_type(L
, -2) != LUA_TFUNCTION
) ||
406 (lua_type(L
, -1) != LUA_TTABLE
) ||
412 /* store function pointer */
413 lua_pushvalue(L
, -2);
414 lua_setfield(L
, -6, lua_tostring(L
, -5));
416 m
->name
= lua_tostring(L
, -4);
417 m
->handler
= ubus_method_handler
;
419 plen
= lua_gettablelen(L
, -1);
421 /* exit if policy table is empty */
427 /* setup the policy pointers */
428 p
= calloc(plen
, sizeof(struct blobmsg_policy
));
434 while (lua_next(L
, -2) != 0) {
435 int val
= lua_tointeger(L
, -1);
437 /* check if the policy is valid */
438 if ((lua_type(L
, -2) != LUA_TSTRING
) ||
439 (lua_type(L
, -1) != LUA_TNUMBER
) ||
441 (val
> BLOBMSG_TYPE_LAST
)) {
445 p
[pidx
].name
= lua_tostring(L
, -2);
458 ubus_new_sub_cb(struct ubus_context
*ctx
, struct ubus_object
*obj
)
460 struct ubus_lua_object
*luobj
;
462 luobj
= container_of(obj
, struct ubus_lua_object
, o
);
464 lua_getglobal(state
, "__ubus_cb_publisher");
465 lua_rawgeti(state
, -1, luobj
->rsubscriber
);
466 lua_remove(state
, -2);
468 if (lua_isfunction(state
, -1)) {
469 lua_pushnumber(state
, luobj
->o
.has_subscribers
);
470 lua_call(state
, 1, 0);
477 ubus_lua_load_newsub_cb( lua_State
*L
, struct ubus_lua_object
*obj
)
479 /* keep ref to func */
480 lua_getglobal(L
, "__ubus_cb_publisher");
481 lua_pushvalue(L
, -2);
482 obj
->rsubscriber
= luaL_ref(L
, -2);
486 obj
->o
.subscribe_cb
= ubus_new_sub_cb
;
490 static struct ubus_object
* ubus_lua_load_object(lua_State
*L
)
492 struct ubus_lua_object
*obj
= NULL
;
493 int mlen
= lua_gettablelen(L
, -1);
494 struct ubus_method
*m
;
497 /* setup object pointers */
498 obj
= calloc(1, sizeof(struct ubus_lua_object
));
502 obj
->o
.name
= lua_tostring(L
, -2);
504 /* setup method pointers */
505 m
= calloc(mlen
, sizeof(struct ubus_method
));
508 /* setup type pointers */
509 obj
->o
.type
= calloc(1, sizeof(struct ubus_object_type
));
515 obj
->o
.type
->name
= lua_tostring(L
, -2);
517 obj
->o
.type
->methods
= obj
->o
.methods
;
519 /* create the callback lookup table */
520 lua_createtable(L
, 1, 0);
521 lua_getglobal(L
, "__ubus_cb");
522 lua_pushvalue(L
, -2);
523 obj
->r
= luaL_ref(L
, -2);
526 /* scan each method */
528 while (lua_next(L
, -3) != 0) {
529 /* check if its the subscriber notification callback */
530 if( lua_type( L
, -2 ) == LUA_TSTRING
&&
531 lua_type( L
, -1 ) == LUA_TFUNCTION
){
532 if( !strcmp( lua_tostring( L
, -2 ), "__subscriber_cb" ) )
533 ubus_lua_load_newsub_cb( L
, obj
);
536 /* check if it looks like a method */
537 if ((lua_type(L
, -2) != LUA_TSTRING
) ||
538 (lua_type(L
, -1) != LUA_TTABLE
) ||
539 !lua_objlen(L
, -1)) {
544 if (!ubus_lua_load_methods(L
, &m
[midx
]))
549 obj
->o
.type
->n_methods
= obj
->o
.n_methods
= midx
;
551 /* pop the callback table */
557 static int ubus_lua_add(lua_State
*L
)
559 struct ubus_lua_connection
*c
= luaL_checkudata(L
, 1, METANAME
);
561 /* verify top level object */
562 if (lua_istable(L
, 1)) {
563 lua_pushstring(L
, "you need to pass a table");
567 /* scan each object */
569 while (lua_next(L
, -2) != 0) {
570 struct ubus_object
*obj
= NULL
;
572 /* check if the object has a table of methods */
573 if ((lua_type(L
, -2) == LUA_TSTRING
) && (lua_type(L
, -1) == LUA_TTABLE
)) {
574 obj
= ubus_lua_load_object(L
);
577 ubus_add_object(c
->ctx
, obj
);
579 /* allow future reference of ubus obj */
580 lua_pushstring(state
,"__ubusobj");
581 lua_pushlightuserdata(state
, obj
);
582 lua_settable(state
,-3);
592 ubus_lua_notify( lua_State
*L
)
594 struct ubus_lua_connection
*c
;
595 struct ubus_object
*obj
;
598 c
= luaL_checkudata(L
, 1, METANAME
);
599 method
= luaL_checkstring(L
, 3);
600 luaL_checktype(L
, 4, LUA_TTABLE
);
602 if( !lua_islightuserdata( L
, 2 ) ){
603 lua_pushfstring( L
, "Invald 2nd parameter, expected ubus obj ref" );
604 return lua_error( L
);
606 obj
= lua_touserdata( L
, 2 );
608 /* create parameters from table */
609 blob_buf_init(&c
->buf
, 0);
610 if( !ubus_lua_format_blob_array( L
, &c
->buf
, true ) ){
611 lua_pushfstring( L
, "Invalid 4th parameter, expected table of arguments" );
612 return lua_error( L
);
615 ubus_notify( c
->ctx
, obj
, method
, c
->buf
.head
, -1 );
620 ubus_lua_signatures_cb(struct ubus_context
*c
, struct ubus_object_data
*o
, void *p
)
622 lua_State
*L
= (lua_State
*)p
;
627 ubus_lua_parse_blob_array(L
, blob_data(o
->signature
), blob_len(o
->signature
), true);
631 ubus_lua_signatures(lua_State
*L
)
634 struct ubus_lua_connection
*c
= luaL_checkudata(L
, 1, METANAME
);
635 const char *path
= luaL_checkstring(L
, 2);
637 rv
= ubus_lookup(c
->ctx
, path
, ubus_lua_signatures_cb
, L
);
639 if (rv
!= UBUS_STATUS_OK
)
643 lua_pushinteger(L
, rv
);
652 ubus_lua_call_cb(struct ubus_request
*req
, int type
, struct blob_attr
*msg
)
654 lua_State
*L
= (lua_State
*)req
->priv
;
660 ubus_lua_parse_blob_array(L
, blob_data(msg
), blob_len(msg
), true);
664 ubus_lua_call(lua_State
*L
)
668 struct ubus_lua_connection
*c
= luaL_checkudata(L
, 1, METANAME
);
669 const char *path
= luaL_checkstring(L
, 2);
670 const char *func
= luaL_checkstring(L
, 3);
672 luaL_checktype(L
, 4, LUA_TTABLE
);
673 blob_buf_init(&c
->buf
, 0);
675 if (!ubus_lua_format_blob_array(L
, &c
->buf
, true))
678 lua_pushinteger(L
, UBUS_STATUS_INVALID_ARGUMENT
);
682 rv
= ubus_lookup_id(c
->ctx
, path
, &id
);
687 lua_pushinteger(L
, rv
);
692 rv
= ubus_invoke(c
->ctx
, id
, func
, c
->buf
.head
, ubus_lua_call_cb
, L
, c
->timeout
* 1000);
694 if (rv
!= UBUS_STATUS_OK
)
698 lua_pushinteger(L
, rv
);
702 return lua_gettop(L
) - top
;
706 ubus_event_handler(struct ubus_context
*ctx
, struct ubus_event_handler
*ev
,
707 const char *type
, struct blob_attr
*msg
)
709 struct ubus_lua_event
*listener
= container_of(ev
, struct ubus_lua_event
, e
);
711 lua_getglobal(state
, "__ubus_cb_event");
712 lua_rawgeti(state
, -1, listener
->r
);
713 lua_remove(state
, -2);
715 if (lua_isfunction(state
, -1)) {
716 ubus_lua_parse_blob_array(state
, blob_data(msg
), blob_len(msg
), true);
717 lua_call(state
, 1, 0);
723 static struct ubus_event_handler
*
724 ubus_lua_load_event(lua_State
*L
)
726 struct ubus_lua_event
* event
= NULL
;
728 event
= calloc(1, sizeof(struct ubus_lua_event
));
732 event
->e
.cb
= ubus_event_handler
;
734 /* update the he callback lookup table */
735 lua_getglobal(L
, "__ubus_cb_event");
736 lua_pushvalue(L
, -2);
737 event
->r
= luaL_ref(L
, -2);
738 lua_setfield(L
, -1, lua_tostring(L
, -3));
744 ubus_lua_listen(lua_State
*L
) {
745 struct ubus_lua_connection
*c
= luaL_checkudata(L
, 1, METANAME
);
747 /* verify top level object */
748 luaL_checktype(L
, 2, LUA_TTABLE
);
750 /* scan each object */
752 while (lua_next(L
, -2) != 0) {
753 struct ubus_event_handler
*listener
;
755 /* check if the key is a string and the value is a method */
756 if ((lua_type(L
, -2) == LUA_TSTRING
) && (lua_type(L
, -1) == LUA_TFUNCTION
)) {
757 listener
= ubus_lua_load_event(L
);
758 if(listener
!= NULL
) {
759 ubus_register_event_handler(c
->ctx
, listener
, lua_tostring(L
, -2));
768 ubus_sub_remove_handler(struct ubus_context
*ctx
, struct ubus_subscriber
*s
,
771 struct ubus_lua_subscriber
*sub
;
773 sub
= container_of(s
, struct ubus_lua_subscriber
, s
);
775 lua_getglobal(state
, "__ubus_cb_subscribe");
776 lua_rawgeti(state
, -1, sub
->rremove
);
777 lua_remove(state
, -2);
779 if (lua_isfunction(state
, -1)) {
780 lua_call(state
, 0, 0);
787 ubus_sub_notify_handler(struct ubus_context
*ctx
, struct ubus_object
*obj
,
788 struct ubus_request_data
*req
, const char *method
,
789 struct blob_attr
*msg
)
791 struct ubus_subscriber
*s
;
792 struct ubus_lua_subscriber
*sub
;
794 s
= container_of(obj
, struct ubus_subscriber
, obj
);
795 sub
= container_of(s
, struct ubus_lua_subscriber
, s
);
797 lua_getglobal(state
, "__ubus_cb_subscribe");
798 lua_rawgeti(state
, -1, sub
->rnotify
);
799 lua_remove(state
, -2);
801 if (lua_isfunction(state
, -1)) {
803 ubus_lua_parse_blob_array(state
, blob_data(msg
), blob_len(msg
), true);
807 lua_pushstring(state
, method
);
808 lua_call(state
, 2, 0);
819 ubus_lua_do_subscribe( struct ubus_context
*ctx
, lua_State
*L
, const char* target
,
820 int idxnotify
, int idxremove
)
824 struct ubus_lua_subscriber
*sub
;
826 if( ( status
= ubus_lookup_id( ctx
, target
, &id
) ) ){
827 lua_pushfstring( L
, "Unable find target, status=%d", status
);
828 return lua_error( L
);
831 sub
= calloc( 1, sizeof( struct ubus_lua_subscriber
) );
833 lua_pushstring( L
, "Out of memory" );
834 return lua_error( L
);
838 lua_getglobal(L
, "__ubus_cb_subscribe");
839 lua_pushvalue(L
, idxnotify
);
840 sub
->rnotify
= luaL_ref(L
, -2);
842 sub
->s
.cb
= ubus_sub_notify_handler
;
846 lua_getglobal(L
, "__ubus_cb_subscribe");
847 lua_pushvalue(L
, idxremove
);
848 sub
->rremove
= luaL_ref(L
, -2);
850 sub
->s
.remove_cb
= ubus_sub_remove_handler
;
853 if( ( status
= ubus_register_subscriber( ctx
, &sub
->s
) ) ){
854 lua_pushfstring( L
, "Failed to register subscriber, status=%d", status
);
855 return lua_error( L
);
858 if( ( status
= ubus_subscribe( ctx
, &sub
->s
, id
) ) ){
859 lua_pushfstring( L
, "Failed to register subscriber, status=%d", status
);
860 return lua_error( L
);
867 ubus_lua_subscribe(lua_State
*L
) {
868 int idxnotify
, idxremove
, stackstart
;
869 struct ubus_lua_connection
*c
;
872 idxnotify
= idxremove
= 0;
873 stackstart
= lua_gettop( L
);
876 c
= luaL_checkudata(L
, 1, METANAME
);
877 target
= luaL_checkstring(L
, 2);
878 luaL_checktype(L
, 3, LUA_TTABLE
);
881 lua_pushstring( L
, "notify");
882 lua_gettable( L
, 3 );
883 if( lua_type( L
, -1 ) == LUA_TFUNCTION
){
884 idxnotify
= lua_gettop( L
);
889 lua_pushstring( L
, "remove");
890 lua_gettable( L
, 3 );
891 if( lua_type( L
, -1 ) == LUA_TFUNCTION
){
892 idxremove
= lua_gettop( L
);
898 ubus_lua_do_subscribe( c
->ctx
, L
, target
, idxnotify
, idxremove
);
900 if( lua_gettop( L
) > stackstart
)
901 lua_pop( L
, lua_gettop( L
) - stackstart
);
907 ubus_lua_send(lua_State
*L
)
909 struct ubus_lua_connection
*c
= luaL_checkudata(L
, 1, METANAME
);
910 const char *event
= luaL_checkstring(L
, 2);
913 return luaL_argerror(L
, 2, "no event name");
915 // Event content convert to ubus form
916 luaL_checktype(L
, 3, LUA_TTABLE
);
917 blob_buf_init(&c
->buf
, 0);
919 if (!ubus_lua_format_blob_array(L
, &c
->buf
, true)) {
921 lua_pushinteger(L
, UBUS_STATUS_INVALID_ARGUMENT
);
926 ubus_send_event(c
->ctx
, event
, c
->buf
.head
);
934 ubus_lua__gc(lua_State
*L
)
936 struct ubus_lua_connection
*c
= luaL_checkudata(L
, 1, METANAME
);
938 blob_buf_free(&c
->buf
);
942 memset(c
, 0, sizeof(*c
));
948 static const luaL_Reg ubus
[] = {
949 { "connect", ubus_lua_connect
},
950 { "objects", ubus_lua_objects
},
951 { "add", ubus_lua_add
},
952 { "notify", ubus_lua_notify
},
953 { "reply", ubus_lua_reply
},
954 { "defer_request", ubus_lua_defer_request
},
955 { "complete_deferred_request", ubus_lua_complete_deferred_request
},
956 { "signatures", ubus_lua_signatures
},
957 { "call", ubus_lua_call
},
958 { "close", ubus_lua__gc
},
959 { "listen", ubus_lua_listen
},
960 { "send", ubus_lua_send
},
961 { "subscribe", ubus_lua_subscribe
},
962 { "__gc", ubus_lua__gc
},
966 /* avoid missing prototype warning */
967 int luaopen_ubus(lua_State
*L
);
970 luaopen_ubus(lua_State
*L
)
972 /* create metatable */
973 luaL_newmetatable(L
, METANAME
);
975 /* metatable.__index = metatable */
976 lua_pushvalue(L
, -1);
977 lua_setfield(L
, -2, "__index");
980 luaL_register(L
, NULL
, ubus
);
984 luaL_register(L
, MODNAME
, ubus
);
986 /* set some enum defines */
987 lua_pushinteger(L
, BLOBMSG_TYPE_ARRAY
);
988 lua_setfield(L
, -2, "ARRAY");
989 lua_pushinteger(L
, BLOBMSG_TYPE_TABLE
);
990 lua_setfield(L
, -2, "TABLE");
991 lua_pushinteger(L
, BLOBMSG_TYPE_STRING
);
992 lua_setfield(L
, -2, "STRING");
993 lua_pushinteger(L
, BLOBMSG_TYPE_INT64
);
994 lua_setfield(L
, -2, "INT64");
995 lua_pushinteger(L
, BLOBMSG_TYPE_INT32
);
996 lua_setfield(L
, -2, "INT32");
997 lua_pushinteger(L
, BLOBMSG_TYPE_INT16
);
998 lua_setfield(L
, -2, "INT16");
999 lua_pushinteger(L
, BLOBMSG_TYPE_INT8
);
1000 lua_setfield(L
, -2, "INT8");
1001 lua_pushinteger(L
, BLOBMSG_TYPE_DOUBLE
);
1002 lua_setfield(L
, -2, "DOUBLE");
1003 lua_pushinteger(L
, BLOBMSG_TYPE_BOOL
);
1004 lua_setfield(L
, -2, "BOOLEAN");
1006 /* used in our callbacks */
1009 /* create the callback table */
1010 lua_createtable(L
, 1, 0);
1011 lua_setglobal(L
, "__ubus_cb");
1013 /* create the event table */
1014 lua_createtable(L
, 1, 0);
1015 lua_setglobal(L
, "__ubus_cb_event");
1017 /* create the subscriber table */
1018 lua_createtable(L
, 1, 0);
1019 lua_setglobal(L
, "__ubus_cb_subscribe");
1021 /* create the publisher table - notifications of new subs */
1022 lua_createtable(L
, 1, 0);
1023 lua_setglobal(L
, "__ubus_cb_publisher");