return UBUS_STATUS_OK;
}
+enum {
+ CFG_INTERFACES,
+ CFG_KEEP,
+ CFG_MAX
+};
+
static const struct blobmsg_policy config_policy[] = {
- { "interfaces", BLOBMSG_TYPE_ARRAY },
+ [CFG_INTERFACES] = { "interfaces", BLOBMSG_TYPE_ARRAY },
+ [CFG_KEEP] = { "keep", BLOBMSG_TYPE_BOOL },
};
static int
struct ubus_request_data *req, const char *method,
struct blob_attr *msg)
{
- struct blob_attr *data, *cur;
- int rem;
+ struct blob_attr *data[CFG_MAX], *cur;
+ int rem, keep = false;
- blobmsg_parse(config_policy, 1, &data, blob_data(msg), blob_len(msg));
- if (!data)
+ blobmsg_parse(config_policy, CFG_MAX, data, blob_data(msg), blob_len(msg));
+ if (!data[CFG_INTERFACES])
return UBUS_STATUS_INVALID_ARGUMENT;
- if (!blobmsg_check_attr_list(data, BLOBMSG_TYPE_STRING))
+ if (!blobmsg_check_attr_list(data[CFG_INTERFACES], BLOBMSG_TYPE_STRING))
return UBUS_STATUS_INVALID_ARGUMENT;
- vlist_update(&interfaces);
- blobmsg_for_each_attr(cur, data, rem)
+ keep = data[CFG_KEEP] && blobmsg_get_bool(data[CFG_KEEP]);
+ if (!keep) {
+ vlist_update(&interfaces);
+ ubus_notify(ctx, obj, "set_config", NULL, 1000);
+ }
+
+ blobmsg_for_each_attr(cur, data[CFG_INTERFACES], rem)
interface_add(blobmsg_data(cur));
- vlist_flush(&interfaces);
+
+ if (!keep)
+ vlist_flush(&interfaces);
return 0;
}
if (!iface_v4 && !iface_v6)
return UBUS_STATUS_NOT_FOUND;
- if (iface_v4)
- dns_send_question(iface_v4, question, type, 0);
-
- if (iface_v6)
- dns_send_question(iface_v6, question, type, 0);
-
- return UBUS_STATUS_OK;
+ if (!strcmp(method, "query")) {
+ if (iface_v4)
+ dns_send_question(iface_v4, question, type, 0);
+
+ if (iface_v6)
+ dns_send_question(iface_v6, question, type, 0);
+
+ return UBUS_STATUS_OK;
+ } else if (!strcmp(method, "fetch")) {
+ blob_buf_init(&b, 0);
+ void *k = blobmsg_open_array(&b, "records");
+ cache_dump_recursive(&b, question, type, iface_v4 ? iface_v4 : iface_v6);
+ blobmsg_close_array(&b, k);
+ ubus_send_reply(ctx, req, b.head);
+ return UBUS_STATUS_OK;
+ } else {
+ return UBUS_STATUS_INVALID_ARGUMENT;
+ }
}
static const struct ubus_method mdns_methods[] = {
UBUS_METHOD("set_config", mdns_set_config, config_policy),
UBUS_METHOD("query", mdns_query, query_policy),
+ UBUS_METHOD("fetch", mdns_query, query_policy),
UBUS_METHOD_NOARG("scan", mdns_scan),
UBUS_METHOD_NOARG("browse", mdns_browse),
UBUS_METHOD_NOARG("hosts", mdns_hosts),