diff options
| -rw-r--r-- | test/CMakeLists.txt | 38 | ||||
| -rw-r--r-- | test/TEST-README.md | 30 | ||||
| -rw-r--r-- | test/afb-test/CMakeLists.txt | 21 | ||||
| -rw-r--r-- | test/afb-test/etc/CMakeLists.txt | 32 | ||||
| -rw-r--r-- | test/afb-test/etc/aft-agl-network.json | 22 | ||||
| -rw-r--r-- | test/afb-test/tests/CMakeLists.txt | 31 | ||||
| -rw-r--r-- | test/afb-test/tests/network.lua | 52 | ||||
| -rw-r--r-- | test/agl-service-network-ctl.c | 872 |
8 files changed, 885 insertions, 213 deletions
diff --git a/test/CMakeLists.txt b/test/CMakeLists.txt index 2499cba..79065a4 100644 --- a/test/CMakeLists.txt +++ b/test/CMakeLists.txt @@ -1,28 +1,16 @@ -########################################################################### -# Copyright 2019 Konsulko Group -# -# Author: Stoyan Bogdanov <stoyan.bogdanov@konsulko.com> -# -# Licensed under the Apache License, Version 2.0 (the "License"); -# you may not use this file except in compliance with the License. -# You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. -########################################################################### +########################################### +# build and install afb-client-demo +########################################### +PKG_CHECK_MODULES(libsystemd libsystemd>=222) +PKG_CHECK_MODULES(libafbwsc libafbwsc>=5.99) +ADD_EXECUTABLE(agl-service-network-ctl agl-service-network-ctl.c) -# Include any directory not starting with _ -# ----------------------------------------------------- -PROJECT_SUBDIRS_ADD(${PROJECT_SRC_DIR_PATTERN}) - -ADD_TEST(NAME AGL_SERVICE_GPS_TESTS - WORKING_DIRECTORY ${CMAKE_CURRENT_SOURCE_DIR} - COMMAND afb-test.sh "${CMAKE_BINARY_DIR}/package" "${CMAKE_BINARY_DIR}/package-test" SERVICE - ) +TARGET_LINK_LIBRARIES(agl-service-network-ctl + ${link_libraries} + ${libsystemd_LDFLAGS} + ${libafbwsc_LDFLAGS} +) +INSTALL(TARGETS agl-service-network-ctl + RUNTIME DESTINATION ${CMAKE_INSTALL_BINDIR}) diff --git a/test/TEST-README.md b/test/TEST-README.md deleted file mode 100644 index b2475ae..0000000 --- a/test/TEST-README.md +++ /dev/null @@ -1,30 +0,0 @@ -## Building the test widgets -1. Source the SDK environment script -2. Create a build directory -3. Configure and build the project - -``` -mkdir build -cd build -cmake .. -DBUILD_TEST_WGT=TRUE -make -make widget - -``` -Note: If you omit the -DBUILD_TEST_WGT=TRUE parameter for cmake, -you'll have to type `make test_widget` to compile the test widget. - -This should produce two _.wgt_ files - one with the service -and one with the tests within the build directory. - -Run the tests: -``` -scp *.wgt root@<board-ip>:~ -ssh root@<board-ip> -afm-test $(ls *test.wgt) - -``` - -network.lua is testing just part of the verbs presented in the agl-service-network. -Proper testing of wifi, bluetooth and ethernet require known enviroment, -this is the reason why some of the vers are not tested. diff --git a/test/afb-test/CMakeLists.txt b/test/afb-test/CMakeLists.txt deleted file mode 100644 index 44bfeac..0000000 --- a/test/afb-test/CMakeLists.txt +++ /dev/null @@ -1,21 +0,0 @@ -########################################################################### -# Copyright 2019 Konsulko Group -# -# Author: Stoyan Bogdanov <stoyan.bogdanov@konsulko.com> -# -# Licensed under the Apache License, Version 2.0 (the "License"); -# you may not use this file except in compliance with the License. -# You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. -########################################################################### - -# Include any directory not starting with _ -# ----------------------------------------------------- -PROJECT_SUBDIRS_ADD(${PROJECT_SRC_DIR_PATTERN}) diff --git a/test/afb-test/etc/CMakeLists.txt b/test/afb-test/etc/CMakeLists.txt deleted file mode 100644 index eb0fdb8..0000000 --- a/test/afb-test/etc/CMakeLists.txt +++ /dev/null @@ -1,32 +0,0 @@ -########################################################################### -# Copyright 2019 Konsulko Group -# -# Author: Stoyan Bogdanov <stoyan.bogdanov@konsulko.com> -# -# Licensed under the Apache License, Version 2.0 (the "License"); -# you may not use this file except in compliance with the License. -# You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. -########################################################################### - -################################################## -# network test configuration files -################################################## -PROJECT_TARGET_ADD(afb-test-config) - - file(GLOB CONF_FILES "*.json") - - add_input_files("${CONF_FILES}") - - SET_TARGET_PROPERTIES(${TARGET_NAME} PROPERTIES - LABELS "TEST-CONFIG" - OUTPUT_NAME ${TARGET_NAME} - ) - diff --git a/test/afb-test/etc/aft-agl-network.json b/test/afb-test/etc/aft-agl-network.json deleted file mode 100644 index 495249a..0000000 --- a/test/afb-test/etc/aft-agl-network.json +++ /dev/null @@ -1,22 +0,0 @@ -{ - "id": "http://iot.bzh/download/public/schema/json/ctl-schema.json#", - "": "http://iot.bzh/download/public/schema/json/ctl-schema.json#", - "metadata": { - "uid": "Test", - "version": "1.0", - "api": "aft-network", - "info": "AFB-test binding configuration file to test network api.", - "require": [ - "network-manager" - ] - }, - "testVerb": { - "uid": "launch_all_tests", - "info": "Launch all the tests", - "action": "lua://AFT#_launch_test", - "args": { - "trace": "network", - "files": ["network.lua"] - } - } -} diff --git a/test/afb-test/tests/CMakeLists.txt b/test/afb-test/tests/CMakeLists.txt deleted file mode 100644 index b867d34..0000000 --- a/test/afb-test/tests/CMakeLists.txt +++ /dev/null @@ -1,31 +0,0 @@ -########################################################################### -# Copyright 2019 Konsulko Group -# -# Author: Stoyan Bogdanov <stoyan.bogdanov@konsulko.com> -# -# Licensed under the Apache License, Version 2.0 (the "License"); -# you may not use this file except in compliance with the License. -# You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. -########################################################################### - -################################################## -# network Lua Scripts -################################################## -PROJECT_TARGET_ADD(test-files) - - file(GLOB LUA_FILES "*.lua" "*.sh") - add_input_files("${LUA_FILES}") - - SET_TARGET_PROPERTIES(${TARGET_NAME} PROPERTIES - LABELS "TEST-DATA" - OUTPUT_NAME ${TARGET_NAME} - ) - diff --git a/test/afb-test/tests/network.lua b/test/afb-test/tests/network.lua deleted file mode 100644 index 2aebe23..0000000 --- a/test/afb-test/tests/network.lua +++ /dev/null @@ -1,52 +0,0 @@ ---[[ - Copyright 2019 Konsulko Group - - author:Stoyan Bogdanov <stoyan.bogdanov@konsulko.com> - - Licensed under the Apache License, Version 2.0 (the "License"); - you may not use this file except in compliance with the License. - You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. ---]] - - --- Test subscribe [working ok] -_AFT.testVerbStatusSuccess('testSubscribeASuccess','network-manager','subscribe', {value="global_state"}) -_AFT.testVerbStatusSuccess('testSubscribeBSuccess','network-manager','subscribe', {value="technologies"}) -_AFT.testVerbStatusSuccess('testSubscribeCSuccess','network-manager','subscribe', {value="technology_properties"}) -_AFT.testVerbStatusSuccess('testSubscribeDSuccess','network-manager','subscribe', {value="services"}) -_AFT.testVerbStatusSuccess('testSubscribeESuccess','network-manager','subscribe', {value="service_properties"}) -_AFT.testVerbStatusSuccess('testSubscribeFSuccess','network-manager','subscribe', {value="agent"}) - --- Test unsubscribe -_AFT.testVerbStatusSuccess('testUnsubscribeASuccess','network-manager','unsubscribe', {value="global_state"}) -_AFT.testVerbStatusSuccess('testUnsubscribeBSuccess','network-manager','unsubscribe', {value="technologies"}) -_AFT.testVerbStatusSuccess('testUnsubscribeCSuccess','network-manager','unsubscribe', {value="technology_properties"}) -_AFT.testVerbStatusSuccess('testUnsubscribeDSuccess','network-manager','unsubscribe', {value="services"}) -_AFT.testVerbStatusSuccess('testUnsubscribeESuccess','network-manager','unsubscribe', {value="service_properties"}) -_AFT.testVerbStatusSuccess('testUnsubscribeFSuccess','network-manager','unsubscribe', {value="agent"}) - -_AFT.testVerbStatusSuccess('testStateSuccess','network-manager','state', {}) -_AFT.testVerbStatusSuccess('testOfflineSuccess','network-manager','offline', {}) -_AFT.testVerbStatusSuccess('testTechnologiesSuccess','network-manager','technologies', {}) -_AFT.testVerbStatusSuccess('testServicesSuccess','network-manager','services', {}) - -_AFT.testVerbStatusSuccess('testDisableTechnologySuccess','network-manager','disable_technology', {technology="ethernet"}) -_AFT.testVerbStatusSuccess('testEnableTechnologySuccess','network-manager', 'enable_technology', {technology="ethernet"}) - -_AFT.testVerbStatusSuccess('testDisableTechnologySuccess','network-manager','disable_technology', {technology="wifi"}) -_AFT.testVerbStatusSuccess('testEnableTechnologySuccess','network-manager', 'enable_technology', {technology="wifi"}) - -_AFT.testVerbStatusSuccess('testDisableTechnologySuccess','network-manager','disable_technology', {technology="bluetooth"}) -_AFT.testVerbStatusSuccess('testEnableTechnologySuccess','network-manager', 'enable_technology', {technology="bluetooth"}) - -_AFT.testVerbStatusSuccess('testgetpropertySuccess','network-manager','get_property', {technology="wifi"}) -_AFT.testVerbStatusSuccess('testgetpropertySuccess','network-manager','get_property', {technology="ethernet"}) -_AFT.testVerbStatusSuccess('testgetpropertySuccess','network-manager','get_property', {technology="bluetooth"}) diff --git a/test/agl-service-network-ctl.c b/test/agl-service-network-ctl.c new file mode 100644 index 0000000..6808b8d --- /dev/null +++ b/test/agl-service-network-ctl.c @@ -0,0 +1,872 @@ +/* + * Copyright (C) 2018 Konsulko Group + * Author Pantelis Antoniou <pantelis.antoniou@konsulko.com> + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#define _GNU_SOURCE + +#include <stdlib.h> +#include <stdio.h> +#include <stdint.h> +#include <string.h> +#include <unistd.h> +#include <fcntl.h> +#include <sys/stat.h> +#include <sys/types.h> +#include <errno.h> +#include <getopt.h> +#include <stdbool.h> +#include <pthread.h> +#include <ctype.h> +#include <alloca.h> +#include <assert.h> + +#include <systemd/sd-event.h> +#include <json-c/json.h> + +#include <afb/afb-wsj1.h> +#include <afb/afb-ws-client.h> +#include <afb/afb-proto-ws.h> + +struct state { + const char *url; + int port; + const char *token; + const char *api; + char *uri; + bool interactive; + bool debug; + bool noexit; + + sd_event *loop; + struct afb_wsj1 *wsj1; + const char *proto; + bool hangup; +}; + +struct cmd { + const char *verb; + int (*call)(struct state *s, const struct cmd *c, int argc, char *argv[]); + void (*reply)(void *closure, struct afb_wsj1_msg *msg); +}; + +/* print usage of the program */ +/* declaration of functions */ +static void on_wsj1_hangup(void *closure, struct afb_wsj1 *wsj1); +static void on_wsj1_call(void *closure, const char *api, const char *verb, struct afb_wsj1_msg *msg); +static void on_wsj1_event(void *closure, const char *event, struct afb_wsj1_msg *msg); + +/* the callback interface for wsj1 */ +static struct afb_wsj1_itf wsj1_itf = { + .on_hangup = on_wsj1_hangup, + .on_call = on_wsj1_call, + .on_event = on_wsj1_event +}; + +static void on_reply(struct state *s, const char *verb, struct afb_wsj1_msg *msg) +{ + printf("ON-REPLY %s: %s: %s\n%s\n", + s->api, + verb, + afb_wsj1_msg_is_reply_ok(msg) ? "OK" : "ERROR", + json_object_to_json_string_ext(afb_wsj1_msg_object_j(msg), + JSON_C_TO_STRING_PRETTY)); + fflush(stdout); + + /* if non interactive terminate */ + if (!s->interactive) { + if (!s->noexit) + sd_event_exit(s->loop, + afb_wsj1_msg_is_reply_ok(msg) ? 0 : EXIT_FAILURE); + else + printf("Ctrl-C to exit\n"); + } + +} + +static int do_call(struct state *s, const struct cmd *c, json_object *jparams) +{ + printf("CALL %s(%s)\n", c->verb, + jparams ? json_object_to_json_string(jparams) : ""); + + return afb_wsj1_call_j(s->wsj1, s->api, c->verb, jparams, c->reply, s); +} + +static int call_void(struct state *s, const struct cmd *c, int argc, char *argv[]) +{ + return do_call(s, c, NULL); +} + +static void on_ping_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "ping", msg); +} + +static void on_subscribe_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "subscribe", msg); +} + +static void on_unsubscribe_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "unsubscribe", msg); +} + +static int call_subscribe_unsubscribe(struct state *s, const struct cmd *c, int argc, char *argv[]) +{ + json_object *jobj; + + /* must give event name */ + if (argc < 1) + return -1; + jobj = json_object_new_object(); + json_object_object_add(jobj, "value", json_object_new_string(argv[0])); + + return do_call(s, c, jobj); +} + +static void on_state_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "state", msg); +} + +static void on_technologies_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "technologies", msg); +} + +static void on_services_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "services", msg); +} + +static void on_enable_technology_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "enable_technology", msg); +} + +static void on_disable_technology_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "disable_technology", msg); +} + +static int call_technology_arg(struct state *s, const struct cmd *c, int argc, char *argv[]) +{ + json_object *jobj; + + if (argc < 1) + return -1; + + jobj = json_object_new_object(); + json_object_object_add(jobj, "technology", json_object_new_string(argv[0])); + + return do_call(s, c, jobj); +} + +static void on_scan_services_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "scan_services", msg); +} + +static void on_offline_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "offline", msg); +} + +static int call_offline(struct state *s, const struct cmd *c, int argc, char *argv[]) +{ + json_object *jobj; + + /* with no arguments it's a getter */ + if (argc >= 1) { + jobj = json_object_new_object(); + json_object_object_add(jobj, "value", json_object_new_string(argv[0])); + } else + jobj = NULL; + + return do_call(s, c, jobj); +} + +static void on_connect_service_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "connect_service", msg); +} + +static int call_service_arg(struct state *s, const struct cmd *c, int argc, char *argv[]) +{ + json_object *jobj; + + if (argc < 1) + return -1; + + jobj = json_object_new_object(); + json_object_object_add(jobj, "service", json_object_new_string(argv[0])); + + return do_call(s, c, jobj); +} + +static void on_disconnect_service_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "disconnect_service", msg); +} + +static void on_remove_service_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "remove_service", msg); +} + +static void on_move_service_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "move_service", msg); +} + +static int call_move_service(struct state *s, const struct cmd *c, int argc, char *argv[]) +{ + json_object *jobj; + + /* 3 arguments and the middle must be before or after */ + if (argc < 3 || (strcmp(argv[1], "before") && strcmp(argv[1], "after"))) + return -1; + + jobj = json_object_new_object(); + json_object_object_add(jobj, "service", json_object_new_string(argv[0])); + json_object_object_add(jobj, + !strcmp(argv[1], "before") ? "before_service" : "after_service", + json_object_new_string(argv[2])); + + return do_call(s, c, jobj); +} + +static void on_set_property_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "set_property", msg); +} + +static void on_get_property_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "get_property", msg); +} + +static bool get_property_obj(json_object *jparent, int argc, char *argv[]) +{ + json_object *jobj, *jobj2; + int i, j, nest; + + for (i = 0; i < argc; i++) { + + if ((i < (argc - 1) && !strcmp(argv[i+1], "{"))) { + nest = 1; + for (j = i + 2; j < argc; j++) { + if (!strcmp(argv[j], "{")) + nest++; + else if (!strcmp(argv[j], "}")) + nest--; + + if (!nest) + break; + } + if (j >= argc) + return false; + + jobj = json_object_new_object(); + + jobj2 = json_object_new_array(); + get_property_obj(jobj2, j - i - 2, argv + i + 2); + json_object_object_add(jobj, argv[i], jobj2); + i = j; + } else + jobj = json_object_new_string(argv[i]); + + json_object_array_add(jparent, jobj); + + } + + return true; +} + +struct json_object *get_property_value(const char *str) +{ + char *le, *de; + long long ll; + double d; + + if (!strcmp(str, "null")) + return NULL; + if (!strcmp(str, "true")) + return json_object_new_boolean(true); + if (!strcmp(str, "false")) + return json_object_new_boolean(false); + + /* try both double and long and see which one is furthest */ + ll = strtoll(str, &le, 0); + d = strtod(str, &de); + + if (de > le) { + while (isspace(*de)) + de++; + if (!*de) + return json_object_new_double(d); + } else { + while (isspace(*le)) + le++; + if (!*le) + return json_object_new_int64((int64_t)ll); + } + + /* everything else is a string */ + return json_object_new_string(str); +} + +/* how many args is a single json object value */ +static int next_span(int pos, int argc, char *argv[]) +{ + const char *left, *right; + int j, nest; + + if (pos >= argc) + return 0; + + if (!strcmp(argv[pos], "{") || !strcmp(argv[pos], "[")) { + + if (!strcmp(argv[pos], "{")) { + left = "{"; + right = "}"; + } else { + left = "["; + right = "]"; + } + nest = 1; + for (j = pos + 1; nest > 0 && j < argc; j++) { + if (!strcmp(argv[j], left)) + nest++; + else if (!strcmp(argv[j], right)) + nest--; + } + if (nest && j >= argc) { + fprintf(stderr, "nesting error\n"); + return -1; + } + + return j - pos; + } + return 1; +} + +bool add_property_value(json_object *jparent, const char *key, int argc, char *argv[]) +{ + json_object *jobj; + const char *key2; + int i, span; + + if (!strcmp(argv[0], "[")) { + assert(!strcmp(argv[argc - 1], "]")); + + argc -= 2; + argv++; + + jobj = json_object_new_array(); + + for (i = 0; i < argc; ) { + span = next_span(i, argc, argv); + if (span < 0) { + fprintf(stderr, "bad nesting\n"); + return NULL; + } + + if (!add_property_value(jobj, NULL, span, argv + i)) { + fprintf(stderr, "error adding array\n"); + return false; + } + i += span; + + } + } else if (!strcmp(argv[0], "{")) { + assert(!strcmp(argv[argc - 1], "}")); + + argc -= 2; + argv++; + + jobj = json_object_new_object(); + + for (i = 0; i < argc; ) { + key2 = argv[i]; + + span = next_span(i + 1, argc, argv); + if (span < 0) { + fprintf(stderr, "bad nesting\n"); + return NULL; + } + + if (!add_property_value(jobj, key2, span, argv + i + 1)) { + fprintf(stderr, "error adding object\n"); + return false; + } + i += 1 + span; + } + } else { + jobj = get_property_value(argv[0]); + } + + if (key) + json_object_object_add(jparent, key, jobj); + else + json_object_array_add(jparent, jobj); + + return true; +} + +bool set_property_obj(json_object *jparent, int argc, char *argv[]) +{ + int i, span; + const char *key; + + for (i = 0; i < argc; ) { + + key = argv[i]; + if (!strcmp(key, "{") || !strcmp(key, "[")) { + fprintf(stderr, "Bad object start {\n"); + return false; + } + i++; + + if (i > (argc - 1)) { + fprintf(stderr, "out of arguments on key %s\n", key); + return false; + } + + span = next_span(i, argc, argv); + if (span < 0) { + fprintf(stderr, "bad nesting\n"); + return false; + } + + if (!add_property_value(jparent, key, span, argv + i)) { + fprintf(stderr, "error adding property\n"); + return false; + } + i += span; + } + + return true; +} + +static int call_get_set_property(struct state *s, const struct cmd *c, int argc, char *argv[]) +{ + json_object *jobj, *jprop = NULL; + const char *type; + int min_argc; + + if (argc < 1) + return -1; + + type = argv[0]; + /* global or technology or service */ + if (strcmp(type, "global") && strcmp(type, "technology") && + strcmp(type, "service")) { + fprintf(stderr, "unknown property type %s\n", type); + return -1; + } + + /* minimum is get global */ + min_argc = 1; + + /* technology or service have extra argument */ + if (!strcmp(type, "technology") || !strcmp(type, "service")) + min_argc++; + + /* set property must have an argument */ + min_argc += !strcmp(c->verb, "set_property") ? 2 : 0; + + if (argc < min_argc) { + fprintf(stderr, "not enough arguments\n"); + return -1; + } + + jobj = json_object_new_object(); + + argc--; + argv++; + + if (!strcmp(type, "technology")) { + json_object_object_add(jobj, "technology", + json_object_new_string(argv[0])); + argc--; + argv++; + } else if (!strcmp(type, "service")) { + json_object_object_add(jobj, "service", + json_object_new_string(argv[0])); + argc--; + argv++; + } + + /* get is array, set is object */ + if (!strcmp(c->verb, "get_property")) { + if (argc > 0) { + jprop = json_object_new_array(); + get_property_obj(jprop, argc, argv); + } + } else { + jprop = json_object_new_object(); + set_property_obj(jprop, argc, argv); + } + + if (jprop) + json_object_object_add(jobj, "properties", jprop); + + return do_call(s, c, jobj); +} + +static void on_agent_response_reply(void *closure, struct afb_wsj1_msg *msg) +{ + on_reply(closure, "agent_response", msg); +} + +static int call_agent_response(struct state *s, const struct cmd *c, int argc, char *argv[]) +{ + json_object *jresp = NULL, *jprop = NULL; + const char *method; + const char *propname; + int id; + + if (argc < 3) + return -1; + + method = *argv++; + argc--; + + id = (int)strtol(*argv++, NULL, 10); + argc--; + + if (id <= 0) { + fprintf(stderr, "bad agent response id %d\n", id); + return -1; + } + + propname = NULL; + if (!strcmp(method, "request-input")) { + propname = "fields"; + } else { + fprintf(stderr, "unknown agent response method '%s'\n", + method); + return -1; + } + + jresp = json_object_new_object(); + json_object_object_add(jresp, "method", + json_object_new_string(method)); + json_object_object_add(jresp, "id", + json_object_new_int(id)); + + if (argc > 0) { + jprop = json_object_new_object(); + set_property_obj(jprop, argc, argv); + json_object_object_add(jresp, propname, jprop); + } + + return do_call(s, c, jresp); +} + + +static const struct cmd cmds[] = { + { + .verb = "ping", + .call = call_void, + .reply = on_ping_reply, + }, { + .verb = "subscribe", + .call = call_subscribe_unsubscribe, + .reply = on_subscribe_reply, + }, { + .verb = "unsubscribe", + .call = call_subscribe_unsubscribe, + .reply = on_unsubscribe_reply, + }, { + .verb = "state", + .call = call_void, + .reply = on_state_reply, + }, { + .verb = "technologies", + .call = call_void, + .reply = on_technologies_reply, + }, { + .verb = "services", + .call = call_void, + .reply = on_services_reply, + }, { + .verb = "enable_technology", + .call = call_technology_arg, + .reply = on_enable_technology_reply, + }, { + .verb = "disable_technology", + .call = call_technology_arg, + .reply = on_disable_technology_reply, + }, { + .verb = "scan_services", + .call = call_technology_arg, + .reply = on_scan_services_reply, + }, { + .verb = "offline", + .call = call_offline, + .reply = on_offline_reply, + }, { + .verb = "connect_service", + .call = call_service_arg, + .reply = on_connect_service_reply, + }, { + .verb = "disconnect_service", + .call = call_service_arg, + .reply = on_disconnect_service_reply, + }, { + .verb = "remove_service", + .call = call_service_arg, + .reply = on_remove_service_reply, + }, { + .verb = "move_service", + .call = call_move_service, + .reply = on_move_service_reply, + }, { + .verb = "set_property", + .call = call_get_set_property, + .reply = on_set_property_reply, + }, { + .verb = "get_property", + .call = call_get_set_property, + .reply = on_get_property_reply, + }, { + .verb = "agent_response", + .call = call_agent_response, + .reply = on_agent_response_reply, + }, + { } +}; + +static int call_cmd(struct state *s, int argc, char *argv[]) +{ + const struct cmd *c; + const char *verb; + + /* first argument is verb */ + if (argc < 1 || !argv[0]) { + if (!s->interactive) + fprintf(stderr, "No verb given\n"); + goto out_err; + } + verb = argv[0]; + argv++; + argc--; + + for (c = cmds; c->verb; c++) { + if (!strcmp(verb, c->verb)) + return c->call(s, c, argc, argv); + } + + if (!s->interactive) + fprintf(stderr, "Unknown API verb \"%s\"\n", verb); +out_err: + + if (!s->interactive) + sd_event_exit(s->loop, EXIT_FAILURE); + + return -1; +} + +static struct option opts[] = { + { "url", required_argument, 0, 'u' }, + { "port", required_argument, 0, 'p' }, + { "token", required_argument, 0, 't' }, + { "api", required_argument, 0, 'a' }, + { "noexit", no_argument, 0, 'x' }, + { "debug", no_argument, 0, 'd' }, + { "help", no_argument, 0, 'h' }, + { } +}; + +#define DEFAULT_URL "ws://localhost" +#define DEFAULT_PORT 1234 +#define DEFAULT_TOKEN "HELLO" +#define DEFAULT_API "network-manager" +#define DEFAULT_DEBUG true + +static void usage(int status, const char *arg0) + __attribute__((__noreturn__)); + +static void usage(int status, const char *arg0) +{ + const char *name = strrchr(arg0, '/'); + FILE *outf = status ? stderr : stdout; + + name = name ? name + 1 : arg0; + + fprintf(outf, "usage: %s <options> [arguments]\n", name); + fprintf(outf, " options are:\n"); + fprintf(outf, " -u, --url=X URL to connect to (default %s)\n", DEFAULT_URL); + fprintf(outf, " -p, --port=X Port to use for connection (default %d)\n", DEFAULT_PORT); + fprintf(outf, " -t, --token=X Token to use (default %s)\n", DEFAULT_TOKEN); + fprintf(outf, " -a, --api=X API to use (default %s)\n", DEFAULT_API); + fprintf(outf, " -x, --noexit Do not exit in non-interactive mode (events)\n"); + fprintf(outf, " -d, --debug Enable debug printouts\n"); + fprintf(outf, " -h, -?, --help Display this help\n"); + + exit(status); +} + +/* entry function */ +int main(int argc, char **argv) +{ + int rc, ret, cc = 0, option_index; + const char *name; + struct state state, *s = &state; + + memset(s, 0, sizeof(*s)); + s->url = DEFAULT_URL; + s->port = DEFAULT_PORT; + s->token = DEFAULT_TOKEN; + s->api = DEFAULT_API; + s->debug = DEFAULT_DEBUG; + + s->interactive = false; + s->noexit = false; + + while ((cc = getopt_long(argc, argv, "u:p:t:a:xdh?", opts, + &option_index)) != -1) { + + if (cc == 0 && option_index >= 0) { + name = opts[option_index].name; + if (!name) + continue; + /* we don't have long options without short ones */ + usage(EXIT_FAILURE, argv[0]); + } + + switch (cc) { + case 'u': + s->url = optarg; + break; + case 'p': + s->port = atoi(optarg); + break; + case 't': + s->token = optarg; + break; + case 'a': + s->api = optarg; + break; + case 'x': + s->noexit = true; + break; + case 'd': + s->debug = true; + break; + case 'h': + case '?': + usage(0, argv[0]); + break; + } + } + + /* no arguments left, interactive mode */ + if (optind >= argc) { + printf("optind=%d\n", optind); + printf("argc=%d\n", argc); + s->interactive = true; + } + + ret = EXIT_FAILURE; + + rc = asprintf(&s->uri, "%s:%d/api?token=%s", s->url, s->port, s->token); + if (rc < 0) { + fprintf(stderr, "Unable to build URI\n"); + goto out; + } + + if (s->debug) { + fprintf(stderr, "URI: \"%s\"\n", s->uri); + fprintf(stderr, "API: \"%s\"\n", s->api); + fprintf(stderr, "interactive: %s\n", s->interactive ? "true" : "false"); + fprintf(stderr, "noexit: %s\n", s->noexit ? "true" : "false"); + } + + /* get the default event loop */ + rc = sd_event_default(&s->loop); + if (rc < 0) { + fprintf(stderr, "connection to default event loop failed: %s\n", strerror(-rc)); + goto out_no_event; + } + + /* connect the websocket wsj1 to the uri given by the first argument */ + s->wsj1 = afb_ws_client_connect_wsj1(s->loop, s->uri, &wsj1_itf, s); + if (s->wsj1 == NULL) { + fprintf(stderr, "connection to %s failed: %m\n", argv[1]); + goto out_no_wsj1; + } + + if (!s->interactive) { + ret = call_cmd(s, argc - optind, argv + optind); + if (ret < 0) { + fprintf(stderr, "command failed\n"); + sd_event_exit(s->loop, EXIT_FAILURE); + } + } else { + fprintf(stderr, "interactive mode not yet supported\n"); + sd_event_exit(s->loop, EXIT_FAILURE); + } + + ret = sd_event_loop(s->loop); + + /* cleanup */ + + afb_wsj1_unref(s->wsj1); +out_no_wsj1: + sd_event_unref(s->loop); +out_no_event: + free(s->uri); +out: + return ret; +} + +/* called when wsj1 hangsup */ +static void on_wsj1_hangup(void *closure, struct afb_wsj1 *wsj1) +{ + struct state *s = closure; + + printf("ON-HANGUP\n"); + fflush(stdout); + + s->hangup = true; + sd_event_exit(s->loop, 0); +} + +/* called when wsj1 receives a method invocation */ +static void on_wsj1_call(void *closure, const char *api, const char *verb, struct afb_wsj1_msg *msg) +{ + int rc; + + printf("ON-CALL %s/%s:\n%s\n", api, verb, + json_object_to_json_string_ext(afb_wsj1_msg_object_j(msg), + JSON_C_TO_STRING_PRETTY)); + fflush(stdout); + rc = afb_wsj1_reply_error_s(msg, "\"unimplemented\"", NULL); + if (rc < 0) + fprintf(stderr, "replying failed: %m\n"); +} + +/* called when wsj1 receives an event */ +static void on_wsj1_event(void *closure, const char *event, struct afb_wsj1_msg *msg) +{ + printf("ON-EVENT %s:\n%s\n", event, + json_object_to_json_string_ext(afb_wsj1_msg_object_j(msg), + JSON_C_TO_STRING_PRETTY)); + fflush(stdout); +} |