X-Git-Url: https://git.archive.openwrt.org/?p=project%2Fubus.git;a=blobdiff_plain;f=cli.c;h=e6b127884c20217df7e593537cb2b1a3b550fa27;hp=bc884cd2b346eb68d40d215e2a2e0d2097b196fd;hb=c55408c4d023b67f6156f330e3442169bd53da16;hpb=8321f8c523c9bf5f476f9c5b06c955d0ce3a0f80 diff --git a/cli.c b/cli.c index bc884cd..e6b1278 100644 --- a/cli.c +++ b/cli.c @@ -2,6 +2,7 @@ static struct blob_buf b; static struct ubus_context *ctx; +static uint32_t objid; static void receive_lookup(struct ubus_request *req, int type, struct blob_attr *msg) { @@ -27,6 +28,31 @@ static void receive_lookup(struct ubus_request *req, int type, struct blob_attr } } +static void store_objid(struct ubus_request *req, int type, struct blob_attr *msg) +{ + struct blob_attr **attr; + + attr = ubus_parse_msg(msg); + if (!attr[UBUS_ATTR_OBJID]) + return; + + objid = blob_get_int32(attr[UBUS_ATTR_OBJID]); +} + +static uint32_t get_object(const char *name) +{ + struct ubus_request req; + + blob_buf_init(&b, 0); + blob_put_string(&b, UBUS_ATTR_OBJPATH, name); + ubus_start_request(ctx, &req, b.head, UBUS_MSG_LOOKUP, 0); + req.data_cb = store_objid; + if (ubus_complete_request(ctx, &req)) + return 0; + + return objid; +} + static int usage(char *prog) { fprintf(stderr, @@ -54,9 +80,9 @@ int main(int argc, char **argv) if (argc < 2) return usage(argv[0]); - blob_buf_init(&b, 0); - if (!strcmp(cmd, "list")) { + blob_buf_init(&b, 0); + if (argc == 3) blob_put_string(&b, UBUS_ATTR_OBJPATH, argv[2]); @@ -66,9 +92,15 @@ int main(int argc, char **argv) if (argc < 4 || argc > 5) return usage(argv[0]); - blob_put_string(&b, UBUS_ATTR_OBJPATH, argv[2]); + if (get_object(argv[2]) == 0) { + fprintf(stderr, "Object not found\n"); + return 1; + } + + blob_buf_init(&b, 0); + blob_put_int32(&b, UBUS_ATTR_OBJID, objid); blob_put_string(&b, UBUS_ATTR_METHOD, argv[3]); - ubus_start_request(ctx, &req, b.head, UBUS_MSG_INVOKE, 0); + ubus_start_request(ctx, &req, b.head, UBUS_MSG_INVOKE, objid); } else { return usage(argv[0]); }