diff --git a/mesh/cfgmod-server.c b/mesh/cfgmod-server.c
index 239ea88..2e5da86 100644
--- a/mesh/cfgmod-server.c
+++ b/mesh/cfgmod-server.c
if (n)
mesh_model_send(node, dst, src, APP_IDX_DEV_LOCAL, net_idx,
- DEFAULT_TTL, false, msg, n);
+ DEFAULT_TTL, false, n, msg);
return true;
}
diff --git a/mesh/model.c b/mesh/model.c
index bb5d300..7bbc9cc 100644
--- a/mesh/model.c
+++ b/mesh/model.c
}
int mesh_model_publish(struct mesh_node *node, uint32_t id, uint16_t src,
- const void *msg, uint16_t msg_len)
+ bool segmented, uint16_t msg_len, const void *msg)
{
struct mesh_net *net = node_get_net(node);
struct mesh_model *mod;
result = msg_send(node, mod->pub->credential != 0, src, mod->pub->addr,
mod->pub->idx, net_idx, label, mod->pub->ttl,
mod->pub->rtx.cnt, mod->pub->rtx.interval,
- false, msg, msg_len);
+ segmented, msg, msg_len);
return result ? MESH_ERROR_NONE : MESH_ERROR_FAILED;
}
bool mesh_model_send(struct mesh_node *node, uint16_t src, uint16_t dst,
uint16_t app_idx, uint16_t net_idx,
uint8_t ttl, bool segmented,
- const void *msg, uint16_t msg_len)
+ uint16_t msg_len, const void *msg)
{
struct mesh_net *net = node_get_net(node);
uint8_t cnt;
diff --git a/mesh/model.h b/mesh/model.h
index a1afedd..fe0648d 100644
--- a/mesh/model.h
+++ b/mesh/model.h
uint8_t *buf, uint16_t buf_size, uint16_t *size);
uint16_t mesh_model_cfg_blk(uint8_t *pkt);
bool mesh_model_send(struct mesh_node *node, uint16_t src, uint16_t dst,
- uint16_t app_idx, uint16_t net_idx,
- uint8_t ttl, bool segmented,
- const void *msg, uint16_t msg_len);
+ uint16_t app_idx, uint16_t net_idx, uint8_t ttl,
+ bool segmented, uint16_t len, const void *data);
int mesh_model_publish(struct mesh_node *node, uint32_t id, uint16_t src,
- const void *msg, uint16_t msg_len);
+ bool segmented, uint16_t len, const void *data);
bool mesh_model_rx(struct mesh_node *node, bool szmict, uint32_t seq0,
uint32_t seq, uint32_t iv_index, uint16_t net_idx,
uint16_t src, uint16_t dst, uint8_t key_aid,
const uint8_t *data, uint16_t size);
-void mesh_model_app_key_generate_new(struct mesh_node *node, uint16_t net_idx);
void mesh_model_app_key_delete(struct mesh_node *node, uint16_t ele_idx,
struct l_queue *models, uint16_t app_idx);
-struct l_queue *mesh_model_get_appkeys(struct mesh_node *node);
uint16_t mesh_model_opcode_set(uint32_t opcode, uint8_t *buf);
bool mesh_model_opcode_get(const uint8_t *buf, uint16_t size, uint32_t *opcode,
uint16_t *n);
diff --git a/mesh/node.c b/mesh/node.c
index a6e9cee..c564bdb 100644
--- a/mesh/node.c
+++ b/mesh/node.c
};
};
+struct send_options {
+ bool segmented;
+ uint16_t vendor_id;
+};
+
static struct l_queue *nodes;
static bool match_device_uuid(const void *a, const void *b)
l_dbus_message_builder_destroy(builder);
}
+static bool parse_send_options(struct l_dbus_message_iter *itr,
+ struct send_options *opts)
+{
+ const char *key;
+ struct l_dbus_message_iter var;
+
+ opts->segmented = false;
+ opts->vendor_id = SIG_VENDOR;
+
+ while (l_dbus_message_iter_next_entry(itr, &key, &var)) {
+ if (!strcmp(key, "ForceSegmented")) {
+ if (!l_dbus_message_iter_get_variant(&var, "b",
+ &opts->segmented))
+ return false;
+ }
+
+ if (!strcmp(key, "Vendor")) {
+ if (!l_dbus_message_iter_get_variant(&var, "q",
+ &opts->vendor_id))
+ return false;
+ }
+ }
+
+ return true;
+}
+
static struct l_dbus_message *send_call(struct l_dbus *dbus,
struct l_dbus_message *msg,
void *user_data)
{
struct mesh_node *node = user_data;
const char *sender, *ele_path;
- struct l_dbus_message_iter iter_data;
+ struct l_dbus_message_iter dict, iter_data;
+ struct send_options opts;
struct node_element *ele;
uint16_t dst, app_idx, net_idx, src;
uint8_t *data;
if (strcmp(sender, node->owner))
return dbus_error(msg, MESH_ERROR_NOT_AUTHORIZED, NULL);
- if (!l_dbus_message_get_arguments(msg, "oqqay", &ele_path, &dst,
- &app_idx, &iter_data))
+ if (!l_dbus_message_get_arguments(msg, "oqqa{sv}ay", &ele_path, &dst,
+ &app_idx, &dict, &iter_data))
return dbus_error(msg, MESH_ERROR_INVALID_ARGS, NULL);
ele = l_queue_find(node->elements, match_element_path, ele_path);
return dbus_error(msg, MESH_ERROR_NOT_FOUND,
"Element not found");
+ if (!parse_send_options(&dict, &opts))
+ return dbus_error(msg, MESH_ERROR_INVALID_ARGS, NULL);
+
src = node_get_primary(node) + ele->idx;
if (!l_dbus_message_iter_get_fixed_array(&iter_data, &data, &len) ||
"Key not found");
if (!mesh_model_send(node, src, dst, app_idx, net_idx, DEFAULT_TTL,
- false, data, len))
+ opts.segmented, len, data))
return dbus_error(msg, MESH_ERROR_FAILED, NULL);
return l_dbus_message_new_method_return(msg);
{
struct mesh_node *node = user_data;
const char *sender, *ele_path;
- struct l_dbus_message_iter iter_data;
+ struct l_dbus_message_iter iter_data, dict;
+ struct send_options opts;
struct node_element *ele;
uint16_t dst, app_idx, net_idx, src;
bool remote;
if (strcmp(sender, node->owner))
return dbus_error(msg, MESH_ERROR_NOT_AUTHORIZED, NULL);
- if (!l_dbus_message_get_arguments(msg, "oqbqay", &ele_path, &dst,
- &remote, &net_idx, &iter_data))
+ if (!l_dbus_message_get_arguments(msg, "oqbqa{sv}ay", &ele_path, &dst,
+ &remote, &net_idx, &dict, &iter_data))
return dbus_error(msg, MESH_ERROR_INVALID_ARGS, NULL);
/* Loopbacks to local servers must use *remote* addressing */
return dbus_error(msg, MESH_ERROR_NOT_FOUND,
"Element not found");
+ if (!parse_send_options(&dict, &opts))
+ return dbus_error(msg, MESH_ERROR_INVALID_ARGS, NULL);
+
src = node_get_primary(node) + ele->idx;
if (!l_dbus_message_iter_get_fixed_array(&iter_data, &data, &len) ||
app_idx = remote ? APP_IDX_DEV_REMOTE : APP_IDX_DEV_LOCAL;
if (!mesh_model_send(node, src, dst, app_idx, net_idx, DEFAULT_TTL,
- false, data, len))
+ opts.segmented, len, data))
return dbus_error(msg, MESH_ERROR_NOT_FOUND, NULL);
return l_dbus_message_new_method_return(msg);
l_put_le16(sub_idx, &data[2]);
if (!mesh_model_send(node, src, dst, APP_IDX_DEV_REMOTE, net_idx,
- DEFAULT_TTL, false, data, 20))
+ DEFAULT_TTL, false, 20, data))
return dbus_error(msg, MESH_ERROR_NOT_FOUND, NULL);
return l_dbus_message_new_method_return(msg);
data[3] = app_idx >> 4;
if (!mesh_model_send(node, src, dst, APP_IDX_DEV_REMOTE, net_idx,
- DEFAULT_TTL, false, data, 20))
+ DEFAULT_TTL, false, 20, data))
return dbus_error(msg, MESH_ERROR_NOT_FOUND, NULL);
return l_dbus_message_new_method_return(msg);
{
struct mesh_node *node = user_data;
const char *sender, *ele_path;
- struct l_dbus_message_iter iter_data;
+ struct l_dbus_message_iter iter_data, dict;
uint16_t mod_id, src;
+ struct send_options opts;
struct node_element *ele;
uint8_t *data;
uint32_t len, id;
if (strcmp(sender, node->owner))
return dbus_error(msg, MESH_ERROR_NOT_AUTHORIZED, NULL);
- if (!l_dbus_message_get_arguments(msg, "oqay", &ele_path, &mod_id,
- &iter_data))
+ if (!l_dbus_message_get_arguments(msg, "oqa{sv}ay", &ele_path, &mod_id,
+ &dict, &iter_data))
return dbus_error(msg, MESH_ERROR_INVALID_ARGS, NULL);
ele = l_queue_find(node->elements, match_element_path, ele_path);
return dbus_error(msg, MESH_ERROR_NOT_FOUND,
"Element not found");
- src = node_get_primary(node) + ele->idx;
-
- if (!l_dbus_message_iter_get_fixed_array(&iter_data, &data, &len) ||
- !len || len > MAX_MSG_LEN)
- return dbus_error(msg, MESH_ERROR_INVALID_ARGS,
- "Incorrect data");
-
- id = SET_ID(SIG_VENDOR, mod_id);
- result = mesh_model_publish(node, id, src, data, len);
-
- if (result != MESH_ERROR_NONE)
- return dbus_error(msg, result, NULL);
-
- return l_dbus_message_new_method_return(msg);
-}
-
-static struct l_dbus_message *vendor_publish_call(struct l_dbus *dbus,
- struct l_dbus_message *msg,
- void *user_data)
-{
- struct mesh_node *node = user_data;
- const char *sender, *ele_path;
- struct l_dbus_message_iter iter_data;
- uint16_t src, mod_id, vendor_id;
- struct node_element *ele;
- uint8_t *data = NULL;
- uint32_t len;
- int result;
-
- l_debug("Publish");
-
- sender = l_dbus_message_get_sender(msg);
-
- if (strcmp(sender, node->owner))
- return dbus_error(msg, MESH_ERROR_NOT_AUTHORIZED, NULL);
-
- if (!l_dbus_message_get_arguments(msg, "oqqay", &ele_path, &vendor_id,
- &mod_id, &iter_data))
+ if (!parse_send_options(&dict, &opts))
return dbus_error(msg, MESH_ERROR_INVALID_ARGS, NULL);
- ele = l_queue_find(node->elements, match_element_path, ele_path);
- if (!ele)
- return dbus_error(msg, MESH_ERROR_NOT_FOUND,
- "Element not found");
-
src = node_get_primary(node) + ele->idx;
if (!l_dbus_message_iter_get_fixed_array(&iter_data, &data, &len) ||
return dbus_error(msg, MESH_ERROR_INVALID_ARGS,
"Incorrect data");
- result = mesh_model_publish(node, SET_ID(vendor_id, mod_id), src,
- data, len);
+ id = SET_ID(opts.vendor_id, mod_id);
+
+ result = mesh_model_publish(node, id, src, opts.segmented, len, data);
if (result != MESH_ERROR_NONE)
return dbus_error(msg, result, NULL);
- return l_dbus_message_new_method_return(msg);
+ return l_dbus_message_new_method_return(msg);
}
static bool features_getter(struct l_dbus *dbus, struct l_dbus_message *msg,
static void setup_node_interface(struct l_dbus_interface *iface)
{
- l_dbus_interface_method(iface, "Send", 0, send_call, "", "oqqay",
+ l_dbus_interface_method(iface, "Send", 0, send_call, "", "oqqa{sv}ay",
"element_path", "destination",
- "key_index", "data");
- l_dbus_interface_method(iface, "DevKeySend", 0, dev_key_send_call,
- "", "oqbqay", "element_path",
+ "key_index", "options", "data");
+ l_dbus_interface_method(iface, "DevKeySend", 0, dev_key_send_call, "",
+ "oqbqa{sv}ay", "element_path",
"destination", "remote",
- "net_index", "data");
+ "net_index", "options", "data");
l_dbus_interface_method(iface, "AddNetKey", 0, add_netkey_call, "",
"oqqqb", "element_path", "destination",
"subnet_index", "net_index", "update");
l_dbus_interface_method(iface, "AddAppKey", 0, add_appkey_call, "",
"oqqqb", "element_path", "destination",
"app_index", "net_index", "update");
- l_dbus_interface_method(iface, "Publish", 0, publish_call, "", "oqay",
- "element_path", "model_id", "data");
- l_dbus_interface_method(iface, "VendorPublish", 0, vendor_publish_call,
- "", "oqqay", "element_path",
- "vendor", "model_id", "data");
-
- l_dbus_interface_property(iface, "Features", 0, "a{sv}", features_getter,
- NULL);
+ l_dbus_interface_method(iface, "Publish", 0, publish_call, "",
+ "oqa{sv}ay", "element_path", "model_id",
+ "options", "data");
+ l_dbus_interface_property(iface, "Features", 0, "a{sv}",
+ features_getter, NULL);
l_dbus_interface_property(iface, "Beacon", 0, "b", beacon_getter, NULL);
l_dbus_interface_property(iface, "IvUpdate", 0, "b", ivupdate_getter,
NULL);