mirror of
https://dev.iopsys.eu/bbf/bbfdm.git
synced 2025-12-10 07:44:39 +01:00
f21814dd4e
* All core Data Model move to core micro-service * New bbfdmd daemon to use async call to optimize RPCs handling
100 lines
2.5 KiB
C
100 lines
2.5 KiB
C
/*
|
|
* set.c: Set handler for bbfdmd
|
|
*
|
|
* Copyright (C) 2023 IOPSYS Software Solutions AB. All rights reserved.
|
|
*
|
|
* Author: Vivek Dutta <vivek.dutta@iopsys.eu>
|
|
* Author: Amin Ben Romdhane <amin.benromdhane@iopsys.eu>
|
|
*
|
|
* See LICENSE file for license related information.
|
|
*/
|
|
|
|
#include "get_helper.h"
|
|
#include "set.h"
|
|
|
|
#include <libubus.h>
|
|
|
|
int bbfdm_set_value(bbfdm_data_t *data)
|
|
{
|
|
struct pvNode *pv = NULL;
|
|
int fault = 0;
|
|
|
|
void *array = blobmsg_open_array(&data->bb, "results");
|
|
|
|
list_for_each_entry(pv, data->plist, list) {
|
|
data->bbf_ctx.in_param = pv->param;
|
|
data->bbf_ctx.in_value = pv->val;
|
|
data->bbf_ctx.in_type = pv->type;
|
|
|
|
fault = bbfdm_cmd_exec(&data->bbf_ctx, BBF_SET_VALUE);
|
|
if (fault) {
|
|
fill_err_code_table(data, fault);
|
|
} else {
|
|
void *table = blobmsg_open_table(&data->bb, NULL);
|
|
bb_add_string(&data->bb, "path", data->bbf_ctx.in_param);
|
|
bb_add_string(&data->bb, "data", "1");
|
|
blobmsg_close_table(&data->bb, table);
|
|
}
|
|
}
|
|
|
|
blobmsg_close_array(&data->bb, array);
|
|
|
|
return fault;
|
|
}
|
|
|
|
int fill_pvlist_set(char *param_name, char *param_value, char *data_type, struct blob_attr *blob_table, struct list_head *pv_list)
|
|
{
|
|
size_t plen = DM_STRLEN(param_name);
|
|
if (plen == 0)
|
|
return USP_FAULT_INVALID_PATH;
|
|
|
|
if (!param_value)
|
|
goto blob__table;
|
|
|
|
if (param_name[plen - 1] == '.')
|
|
return USP_FAULT_INVALID_PATH;
|
|
|
|
add_pv_list(param_name, param_value, data_type, pv_list);
|
|
return 0;
|
|
|
|
blob__table:
|
|
|
|
if (!blob_table)
|
|
return 0;
|
|
|
|
struct blob_attr *attr;
|
|
struct blobmsg_hdr *hdr;
|
|
|
|
size_t tlen = (size_t)blobmsg_data_len(blob_table);
|
|
|
|
__blob_for_each_attr(attr, blobmsg_data(blob_table), tlen) {
|
|
char path[MAX_DM_PATH] = {0}, value[MAX_DM_VALUE] = {0};
|
|
hdr = blob_data(attr);
|
|
|
|
switch (blob_id(attr)) {
|
|
case BLOBMSG_TYPE_STRING:
|
|
snprintf(value, MAX_DM_VALUE, "%s", blobmsg_get_string(attr));
|
|
break;
|
|
case BLOBMSG_TYPE_INT8:
|
|
snprintf(value, MAX_DM_VALUE, "%d", blobmsg_get_u8(attr));
|
|
break;
|
|
case BLOBMSG_TYPE_INT16:
|
|
snprintf(value, MAX_DM_VALUE, "%d", blobmsg_get_u16(attr));
|
|
break;
|
|
case BLOBMSG_TYPE_INT32:
|
|
snprintf(value, MAX_DM_VALUE, "%u", blobmsg_get_u32(attr));
|
|
break;
|
|
case BLOBMSG_TYPE_INT64:
|
|
snprintf(value, MAX_DM_VALUE, "%"PRIu64"", blobmsg_get_u64(attr));
|
|
break;
|
|
default:
|
|
BBF_INFO("Unhandled set request type|%x|", blob_id(attr));
|
|
return USP_FAULT_INVALID_ARGUMENT;
|
|
}
|
|
|
|
snprintf(path, MAX_DM_PATH, "%s%s", param_name, (char *)hdr->name);
|
|
add_pv_list(path, value, NULL, pv_list);
|
|
}
|
|
|
|
return 0;
|
|
}
|