Initial import

1 files changed, 167 insertions, 0 deletions

diff --git a/ubus.c b/ubus.c
new file mode 100644
index 0000000..30db080
--- /dev/null
+++ b/ubus.c
@@ -0,0 +1,167 @@
+#include <string.h>
+
+#include "netifd.h"
+#include "ubus.h"
+
+static struct ubus_context *ctx = NULL;
+
+/* global object */
+
+static const struct ubus_signature main_object_sig[] = {
+	UBUS_METHOD_START("add_device"),
+	UBUS_FIELD(STRING, "name"),
+	UBUS_METHOD_END(),
+
+	UBUS_METHOD_START("del_device"),
+	UBUS_FIELD(STRING, "name"),
+	UBUS_METHOD_END(),
+};
+
+static struct ubus_object_type main_object_type =
+	UBUS_OBJECT_TYPE("netifd", main_object_sig);
+
+enum {
+	DEV_NAME,
+	DEV_FORCE,
+	DEV_LAST,
+};
+
+static const struct blobmsg_policy dev_policy[] = {
+	[DEV_NAME] = { .name = "name", .type = BLOBMSG_TYPE_STRING },
+	[DEV_FORCE] = { .name = "force", .type = BLOBMSG_TYPE_INT8 },
+};
+
+static int netifd_handle_device(struct ubus_context *ctx, struct ubus_object *obj,
+				struct ubus_request_data *req, const char *method,
+				struct blob_attr *msg)
+{
+	struct device *dev;
+	struct blob_attr *tb[DEV_LAST];
+	bool add = !strncmp(method, "add", 3);
+
+	blobmsg_parse(dev_policy, ARRAY_SIZE(dev_policy), tb, blob_data(msg), blob_len(msg));
+
+	if (!tb[DEV_NAME])
+		return UBUS_STATUS_INVALID_ARGUMENT;
+
+	dev = get_device(blobmsg_data(tb[DEV_NAME]), false);
+	if (!dev)
+		return UBUS_STATUS_NOT_FOUND;
+
+	if (!add || (tb[DEV_FORCE] && blobmsg_get_u8(tb[DEV_FORCE])))
+		set_device_present(dev, add);
+	else
+		check_device_state(dev);
+
+	return 0;
+}
+
+static struct ubus_method main_object_methods[] = {
+	{ .name = "add_device", .handler = netifd_handle_device },
+	{ .name = "del_device", .handler = netifd_handle_device },
+};
+
+static struct ubus_object main_object = {
+	.name = "network.interface",
+	.type = &main_object_type,
+	.methods = main_object_methods,
+	.n_methods = ARRAY_SIZE(main_object_methods),
+};
+
+int netifd_ubus_init(const char *path)
+{
+	int ret;
+
+	ctx = ubus_connect(path);
+	if (!ctx)
+		return -EIO;
+
+	DPRINTF("connected as %08x\n", ctx->local_id);
+	uloop_init();
+	ubus_add_uloop(ctx);
+
+	ret = ubus_add_object(ctx, &main_object);
+	if (ret != 0)
+		fprintf(stderr, "Failed to publish object: %s\n", ubus_strerror(ret));
+
+	return 0;
+}
+
+void netifd_ubus_done(void)
+{
+	ubus_free(ctx);
+}
+
+
+/* per-interface object */
+static const struct ubus_signature iface_object_sig[] = {
+	UBUS_METHOD_START("up"),
+	UBUS_METHOD_END(),
+
+	UBUS_METHOD_START("down"),
+	UBUS_METHOD_END(),
+};
+
+static struct ubus_object_type iface_object_type =
+	UBUS_OBJECT_TYPE("netifd", iface_object_sig);
+
+
+static int netifd_handle_up(struct ubus_context *ctx, struct ubus_object *obj,
+			    struct ubus_request_data *req, const char *method,
+			    struct blob_attr *msg)
+{
+	struct interface *iface;
+
+	iface = container_of(obj, struct interface, ubus);
+	set_interface_up(iface);
+
+	return 0;
+}
+
+static int netifd_handle_down(struct ubus_context *ctx, struct ubus_object *obj,
+			      struct ubus_request_data *req, const char *method,
+			      struct blob_attr *msg)
+{
+	struct interface *iface;
+
+	iface = container_of(obj, struct interface, ubus);
+	set_interface_down(iface);
+
+	return 0;
+}
+
+static struct ubus_method iface_object_methods[] = {
+	{ .name = "up", .handler = netifd_handle_up },
+	{ .name = "down", .handler = netifd_handle_down },
+};
+
+
+void netifd_ubus_add_interface(struct interface *iface)
+{
+	struct ubus_object *obj = &iface->ubus;
+	char *name;
+
+	name = malloc(strlen(main_object.name) + strlen(iface->name) + 2);
+	if (!name)
+		return;
+
+	sprintf(name, "%s.%s", main_object.name, iface->name);
+	obj->name = name;
+	obj->type = &iface_object_type;
+	obj->methods = iface_object_methods;
+	obj->n_methods = ARRAY_SIZE(iface_object_methods);
+	if (ubus_add_object(ctx, &iface->ubus)) {
+		DPRINTF("failed to publish ubus object for interface '%s'\n", iface->name);
+		free(name);
+		obj->name = NULL;
+	}
+}
+
+void netifd_ubus_remove_interface(struct interface *iface)
+{
+	if (!iface->ubus.name)
+		return;
+
+	ubus_remove_object(ctx, &iface->ubus);
+	free((void *) iface->ubus.name);
+}