diff --git a/modules/node-cli/dap_chain_node_cli_cmd_tx.c b/modules/node-cli/dap_chain_node_cli_cmd_tx.c
index 7f5f6b43232eddf894edde76aa070043c2ed5bb3..598d41fa3503a0975df30f08438b2cf0af80a381 100644
--- a/modules/node-cli/dap_chain_node_cli_cmd_tx.c
+++ b/modules/node-cli/dap_chain_node_cli_cmd_tx.c
@@ -1378,952 +1378,6 @@ int com_token(int a_argc, char ** a_argv, void **a_str_reply)
return -DAP_CHAIN_NODE_CLI_COM_TOKEN_UNKNOWN;
}
-static const char* s_json_get_text(struct json_object *a_json, const char *a_key)
-{
- if(!a_json || !a_key)
- return NULL;
- struct json_object *l_json = json_object_object_get(a_json, a_key);
- if(l_json && json_object_is_type(l_json, json_type_string)) {
- // Read text
- return json_object_get_string(l_json);
- }
- return NULL;
-}
-
-static bool s_json_get_int64(struct json_object *a_json, const char *a_key, int64_t *a_out)
-{
- if(!a_json || !a_key || !a_out)
- return false;
- struct json_object *l_json = json_object_object_get(a_json, a_key);
- if(l_json) {
- if(json_object_is_type(l_json, json_type_int)) {
- // Read number
- *a_out = json_object_get_int64(l_json);
- return true;
- }
- }
- return false;
-}
-
-static bool s_json_get_unit(struct json_object *a_json, const char *a_key, dap_chain_net_srv_price_unit_uid_t *a_out)
-{
- const char *l_unit_str = s_json_get_text(a_json, a_key);
- if(!l_unit_str || !a_out)
- return false;
- dap_chain_net_srv_price_unit_uid_t l_unit = dap_chain_net_srv_price_unit_uid_from_str(l_unit_str);
- if(l_unit.enm == SERV_UNIT_UNDEFINED)
- return false;
- a_out->enm = l_unit.enm;
- return true;
-}
-
-static bool s_json_get_uint256(struct json_object *a_json, const char *a_key, uint256_t *a_out)
-{
- const char *l_uint256_str = s_json_get_text(a_json, a_key);
- if(!a_out || !l_uint256_str)
- return false;
- uint256_t l_value = dap_chain_balance_scan(l_uint256_str);
- if(!IS_ZERO_256(l_value)) {
- memcpy(a_out, &l_value, sizeof(uint256_t));
- return true;
- }
- return false;
-}
-
-// service names: srv_stake, srv_vpn, srv_xchange
-static bool s_json_get_srv_uid(struct json_object *a_json, const char *a_key_service_id, const char *a_key_service, uint64_t *a_out)
-{
- uint64_t l_srv_id;
- if(!a_out)
- return false;
- // Read service id
- if(s_json_get_int64(a_json, a_key_service_id, (int64_t*) &l_srv_id)) {
- *a_out = l_srv_id;
- return true;
- }
- else {
- // Read service as name
- const char *l_service = s_json_get_text(a_json, a_key_service);
- if (l_service)
- *a_out = dap_chain_srv_get_uid_by_name(l_service).uint64;
- }
- return false;
-}
-
-static dap_chain_wallet_t* s_json_get_wallet(struct json_object *a_json, const char *a_key)
-{
- return dap_chain_wallet_open(s_json_get_text(a_json, a_key), dap_chain_wallet_get_path(g_config), NULL);
-}
-
-static const dap_cert_t* s_json_get_cert(struct json_object *a_json, const char *a_key)
-{
- return dap_cert_find_by_name(s_json_get_text(a_json, a_key));
-}
-
-// Read pkey from wallet or cert
-static dap_pkey_t* s_json_get_pkey(struct json_object *a_json)
-{
- dap_pkey_t *l_pub_key = NULL;
- // From wallet
- dap_chain_wallet_t *l_wallet = s_json_get_wallet(a_json, "wallet");
- if(l_wallet) {
- l_pub_key = dap_chain_wallet_get_pkey(l_wallet, 0);
- dap_chain_wallet_close(l_wallet);
- if(l_pub_key) {
- return l_pub_key;
- }
- }
- // From cert
- const dap_cert_t *l_cert = s_json_get_cert(a_json, "cert");
- if(l_cert) {
- l_pub_key = dap_pkey_from_enc_key(l_cert->enc_key);
- }
- return l_pub_key;
-}
-
-typedef enum s_com_tx_create_json_err {
- DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_OK = 0,
- DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_REQUIRE_PARAMETER_JSON = DAP_JSON_RPC_ERR_CODE_METHOD_ERR_START,
- DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_CAN_NOT_OPEN_JSON_FILE,
- DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_WRONG_JSON_FORMAT,
- DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_REQUIRE_PARAMETER_NET,
- DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_NOT_FOUNT_NET_BY_NAME,
- DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_NOT_FOUNT_CHAIN_BY_NAME,
- DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_NOT_FOUNT_ARRAY_ITEMS,
- DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_INVALID_ITEMS,
- DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_CAN_NOT_ADD_TRANSACTION_TO_MEMPOOL,
- DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_CAN_CHECK_TX_ADD_LEDGER,
- DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_CAN_NOT_ALLOC_MEMORY
-} s_com_tx_create_json_err_t;
-
-int s_json_rpc_tx_parse_json(dap_chain_net_t *a_net, dap_chain_t *a_chain, json_object *a_items,
- dap_chain_datum_tx_t **a_out_tx, size_t *a_out_items_ready, json_object **a_out_jobj_error) {
- size_t l_items_count = json_object_array_length(a_items);
- log_it(L_NOTICE, "Json TX: found %lu items", l_items_count);
- if (!l_items_count) {
- dap_json_rpc_error_add(*a_out_jobj_error, DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_NOT_FOUNT_ARRAY_ITEMS,
- "Wrong json format: not found array 'items' or array is empty");
- return DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_NOT_FOUNT_ARRAY_ITEMS;
- }
- const char *l_native_token = a_net->pub.native_ticker;
- const char *l_main_token = NULL;
- // Create transaction
- dap_chain_datum_tx_t *l_tx = DAP_NEW_Z(dap_chain_datum_tx_t);
- if(!l_tx) {
- dap_json_rpc_allocation_error(*a_out_jobj_error);
- return DAP_JSON_RPC_ERR_CODE_MEMORY_ALLOCATED;
- }
- l_tx->header.ts_created = time(NULL);
- size_t l_items_ready = 0;
- dap_list_t *l_sign_list = NULL;// list 'sing' items
- dap_list_t *l_in_list = NULL;// list 'in' items
- uint256_t l_value_need = { };// how many tokens are needed in the 'out' item
- uint256_t l_value_need_fee = {};
- json_object *l_jobj_errors = json_object_new_array();
- bool l_multichanel = false;
-
- // First iteration in input file. Check the tx will be multichannel or not
- for(size_t i = 0; i < l_items_count; ++i) {
- struct json_object *l_json_item_obj = json_object_array_get_idx(a_items, i);
- if(!l_json_item_obj || !json_object_is_type(l_json_item_obj, json_type_object)) {
- continue;
- }
- struct json_object *l_json_item_type = json_object_object_get(l_json_item_obj, "type");
- if(!l_json_item_type && json_object_is_type(l_json_item_type, json_type_string)) {
- log_it(L_WARNING, "Item %zu without type", i);
- continue;
- }
- const char *l_item_type_str = json_object_get_string(l_json_item_type);
- dap_chain_tx_item_type_t l_item_type = dap_chain_datum_tx_item_str_to_type(l_item_type_str);
- if(l_item_type == TX_ITEM_TYPE_UNKNOWN) {
- log_it(L_WARNING, "Item %zu has invalid type '%s'", i, l_item_type_str);
- continue;
- }
-
- switch (l_item_type) {
- case TX_ITEM_TYPE_IN: {
- const char *l_json_item_token = s_json_get_text(l_json_item_obj, "token");
- if (l_json_item_token && dap_strcmp(l_json_item_token, l_native_token)){
- l_multichanel = true;
- l_main_token = l_json_item_token;
- }
- }break;
- default: continue;
- }
- if(l_multichanel)
- break;
- }
-
- // Creating and adding items to the transaction
- for(size_t i = 0; i < l_items_count; ++i) {
- struct json_object *l_json_item_obj = json_object_array_get_idx(a_items, i);
- if(!l_json_item_obj || !json_object_is_type(l_json_item_obj, json_type_object)) {
- continue;
- }
- struct json_object *l_json_item_type = json_object_object_get(l_json_item_obj, "type");
- if(!l_json_item_type && json_object_is_type(l_json_item_type, json_type_string)) {
- log_it(L_WARNING, "Item %zu without type", i);
- continue;
- }
- const char *l_item_type_str = json_object_get_string(l_json_item_type);
- dap_chain_tx_item_type_t l_item_type = dap_chain_datum_tx_item_str_to_type(l_item_type_str);
- if(l_item_type == TX_ITEM_TYPE_UNKNOWN) {
- log_it(L_WARNING, "Item %zu has invalid type '%s'", i, l_item_type_str);
- continue;
- }
-
- log_it(L_DEBUG, "Json TX: process item %s", json_object_get_string(l_json_item_type));
- // Create an item depending on its type
- const uint8_t *l_item = NULL;
- switch (l_item_type) {
- case TX_ITEM_TYPE_IN: {
- // Save item obj for in
- l_in_list = dap_list_append(l_in_list, l_json_item_obj);
- // Read prev_hash and out_prev_idx
- const char *l_prev_hash_str = s_json_get_text(l_json_item_obj, "prev_hash");
- int64_t l_out_prev_idx;
- bool l_is_out_prev_idx = s_json_get_int64(l_json_item_obj, "out_prev_idx", &l_out_prev_idx);
- // If prev_hash and out_prev_idx were read
- if(l_prev_hash_str && l_is_out_prev_idx) {
- dap_chain_hash_fast_t l_tx_prev_hash;
- if(!dap_chain_hash_fast_from_str(l_prev_hash_str, &l_tx_prev_hash)) {
- // Create IN item
- dap_chain_tx_in_t *l_in_item = dap_chain_datum_tx_item_in_create(&l_tx_prev_hash, (uint32_t) l_out_prev_idx);
- if (!l_in_item) {
- json_object *l_jobj_err = json_object_new_string("Unable to create in for transaction.");
- json_object_array_add(l_jobj_errors, l_jobj_err);
- }
- l_item = (const uint8_t*) l_in_item;
- } else {
- log_it(L_WARNING, "Invalid 'in' item, bad prev_hash %s", l_prev_hash_str);
- char *l_str_err = dap_strdup_printf("Unable to create in for transaction. Invalid 'in' item, "
- "bad prev_hash %s", l_prev_hash_str);
- json_object *l_jobj_err = json_object_new_string(l_str_err);
- json_object_array_add(l_jobj_errors, l_jobj_err);
- }
- }
- // Read addr_from
- else {
- l_in_list = dap_list_append(l_in_list, l_json_item_obj);
- }
- }
- break;
-
- case TX_ITEM_TYPE_OUT:
- case TX_ITEM_TYPE_OUT_EXT: {
- // Read address and value
- uint256_t l_value = { };
- const char *l_json_item_addr_str = s_json_get_text(l_json_item_obj, "addr");
- bool l_is_value = s_json_get_uint256(l_json_item_obj, "value", &l_value);
- const char *l_token = s_json_get_text(l_json_item_obj, "token");
- if(l_is_value && l_json_item_addr_str) {
- dap_chain_addr_t *l_addr = dap_chain_addr_from_str(l_json_item_addr_str);
- if(l_addr && !IS_ZERO_256(l_value)) {
- if(l_item_type == TX_ITEM_TYPE_OUT) {
- // Create OUT item
- const uint8_t *l_out_item = NULL;
- if(l_multichanel)
- l_out_item = (const uint8_t *)dap_chain_datum_tx_item_out_ext_create(l_addr, l_value, l_token ? l_token : (l_main_token ? l_main_token : l_native_token));
- else
- l_out_item = (const uint8_t *)dap_chain_datum_tx_item_out_create(l_addr, l_value);
- if (!l_out_item) {
- json_object *l_jobj_err = json_object_new_string("Failed to create transaction out. "
- "There may not be enough funds in the wallet.");
- json_object_array_add(l_jobj_errors, l_jobj_err);
- }
- l_item = (const uint8_t*) l_out_item;
- if (l_item){
- if (l_multichanel && !dap_strcmp(((dap_chain_tx_out_ext_t*)l_out_item)->token, l_native_token))
- SUM_256_256(l_value_need_fee, l_value, &l_value_need_fee);
- else
- SUM_256_256(l_value_need, l_value, &l_value_need);
- }
-
- } else if(l_item_type == TX_ITEM_TYPE_OUT_EXT) {
- // Read address and value
- if(l_token) {
- // Create OUT_EXT item
- const uint8_t *l_out_item = NULL;
- if(l_multichanel)
- l_out_item = (const uint8_t *)dap_chain_datum_tx_item_out_ext_create(l_addr, l_value, l_token);
- else
- l_out_item = (const uint8_t *)dap_chain_datum_tx_item_out_create(l_addr, l_value);
- if (!l_out_item) {
- json_object *l_jobj_err = json_object_new_string("Failed to create a out ext"
- "for a transaction. There may not be enough funds "
- "on the wallet or the wrong ticker token "
- "is indicated.");
- json_object_array_add(l_jobj_errors, l_jobj_err);
- }
- l_item = (const uint8_t*) l_out_item;
- if (l_item){
- if (l_multichanel && !dap_strcmp(l_token, l_native_token))
- SUM_256_256(l_value_need_fee, l_value, &l_value_need_fee);
- else
- SUM_256_256(l_value_need, l_value, &l_value_need);
- }
- }
- else {
- log_it(L_WARNING, "Invalid 'out_ext' item %zu", i);
- continue;
- }
- }
- } else {
- if(l_item_type == TX_ITEM_TYPE_OUT) {
- log_it(L_WARNING, "Invalid 'out' item %zu", i);
- }
- else if(l_item_type == TX_ITEM_TYPE_OUT_EXT) {
- log_it(L_WARNING, "Invalid 'out_ext' item %zu", i);
- }
- char *l_str_err = dap_strdup_printf("For item %zu of type 'out' or 'out_ext' the "
- "string representation of the address could not be converted, "
- "or the size of the output sum is 0.", i);
- json_object *l_jobj_err = json_object_new_string(l_str_err);
- DAP_DELETE(l_str_err);
- json_object_array_add(l_jobj_errors, l_jobj_err);
- continue;
- }
- }
- }
- break;
- case TX_ITEM_TYPE_OUT_COND: {
- // Read subtype of item
- const char *l_subtype_str = s_json_get_text(l_json_item_obj, "subtype");
- dap_chain_tx_out_cond_subtype_t l_subtype = dap_chain_tx_out_cond_subtype_from_str(l_subtype_str);
- switch (l_subtype) {
-
- case DAP_CHAIN_TX_OUT_COND_SUBTYPE_SRV_PAY:{
- uint256_t l_value = { };
- bool l_is_value = s_json_get_uint256(l_json_item_obj, "value", &l_value);
- if(!l_is_value || IS_ZERO_256(l_value)) {
- log_it(L_ERROR, "Json TX: bad value in OUT_COND_SUBTYPE_SRV_PAY");
- break;
- }
- uint256_t l_value_max_per_unit = { };
- l_is_value = s_json_get_uint256(l_json_item_obj, "value_max_per_unit", &l_value_max_per_unit);
- if(!l_is_value || IS_ZERO_256(l_value_max_per_unit)) {
- log_it(L_ERROR, "Json TX: bad value_max_per_unit in OUT_COND_SUBTYPE_SRV_PAY");
- break;
- }
- dap_chain_net_srv_price_unit_uid_t l_price_unit;
- if(!s_json_get_unit(l_json_item_obj, "price_unit", &l_price_unit)) {
- log_it(L_ERROR, "Json TX: bad price_unit in OUT_COND_SUBTYPE_SRV_PAY");
- break;
- }
- // Default service DAP_CHAIN_NET_SRV_VPN_ID
- uint64_t l_64 = 0x0000000000000001;
- s_json_get_srv_uid(l_json_item_obj, "service_id", "service", &l_64);
- dap_chain_srv_uid_t l_srv_uid = { .uint64 = l_64};
- // From "wallet" or "cert"
- dap_pkey_t *l_pkey = s_json_get_pkey(l_json_item_obj);
- if(!l_pkey) {
- log_it(L_ERROR, "Json TX: bad pkey in OUT_COND_SUBTYPE_SRV_PAY");
- break;
- }
- const char *l_params_str = s_json_get_text(l_json_item_obj, "params");
- size_t l_params_size = dap_strlen(l_params_str);
- dap_chain_tx_out_cond_t *l_out_cond_item = dap_chain_datum_tx_item_out_cond_create_srv_pay(l_pkey, l_srv_uid, l_value, l_value_max_per_unit,
- l_price_unit, l_params_str, l_params_size);
- l_item = (const uint8_t*) l_out_cond_item;
- // Save value for using in In item
- if(l_item) {
- SUM_256_256(l_value_need, l_value, &l_value_need);
- } else {
- char *l_str_err = dap_strdup_printf("Unable to create conditional out for transaction "
- "can of type %s described in item %zu.\n", l_subtype_str, i);
- json_object *l_jobj_err = json_object_new_string(l_str_err);
- DAP_DELETE(l_str_err);
- json_object_array_add(l_jobj_errors, l_jobj_err);
- }
- DAP_DELETE(l_pkey);
- }
- break;
- case DAP_CHAIN_TX_OUT_COND_SUBTYPE_SRV_XCHANGE: {
- // Default service DAP_CHAIN_NET_SRV_XCHANGE_ID
- uint64_t l_64 = 0x0000000000000002;
- s_json_get_srv_uid(l_json_item_obj, "service_id", "service", &l_64);
- dap_chain_srv_uid_t l_srv_uid = { .uint64 = l_64};
- dap_chain_net_t *l_net = dap_chain_net_by_name(s_json_get_text(l_json_item_obj, "net"));
- if(!l_net) {
- log_it(L_ERROR, "Json TX: bad net in OUT_COND_SUBTYPE_SRV_XCHANGE");
- break;
- }
- const char *l_token = s_json_get_text(l_json_item_obj, "token");
- if(!l_token) {
- log_it(L_ERROR, "Json TX: bad token in OUT_COND_SUBTYPE_SRV_XCHANGE");
- break;
- }
- uint256_t l_value = { };
- if(!s_json_get_uint256(l_json_item_obj, "value", &l_value) || IS_ZERO_256(l_value)) {
- log_it(L_ERROR, "Json TX: bad value in OUT_COND_SUBTYPE_SRV_XCHANGE");
- break;
- }
- //const char *l_params_str = s_json_get_text(l_json_item_obj, "params");
- //size_t l_params_size = dap_strlen(l_params_str);
- dap_chain_tx_out_cond_t *l_out_cond_item = NULL; //dap_chain_datum_tx_item_out_cond_create_srv_xchange(l_srv_uid, l_net->pub.id, l_token, l_value, l_params_str, l_params_size);
- l_item = (const uint8_t*) l_out_cond_item;
- // Save value for using in In item
- if(l_item) {
- SUM_256_256(l_value_need, l_value, &l_value_need);
- } else {
- char *l_str_err = dap_strdup_printf("Unable to create conditional out for transaction "
- "can of type %s described in item %zu.", l_subtype_str, i);
- json_object *l_jobj_err = json_object_new_string(l_str_err);
- DAP_DELETE(l_str_err);
- json_object_array_add(l_jobj_errors, l_jobj_err);
- }
- }
- break;
- case DAP_CHAIN_TX_OUT_COND_SUBTYPE_SRV_STAKE_POS_DELEGATE:{
- // Default service DAP_CHAIN_NET_SRV_STAKE_ID
- uint64_t l_64 = 0x0000000000000013;
- s_json_get_srv_uid(l_json_item_obj, "service_id", "service", &l_64);
- dap_chain_srv_uid_t l_srv_uid = { .uint64 = l_64};
- uint256_t l_value = { };
- if(!s_json_get_uint256(l_json_item_obj, "value", &l_value) || IS_ZERO_256(l_value)) {
- log_it(L_ERROR, "Json TX: bad value in OUT_COND_SUBTYPE_SRV_STAKE_POS_DELEGATE");
- break;
- }
- uint256_t l_fee_value = { };
- if(!s_json_get_uint256(l_json_item_obj, "fee", &l_fee_value) || IS_ZERO_256(l_fee_value)) {
- break;
- }
- const char *l_signing_addr_str = s_json_get_text(l_json_item_obj, "signing_addr");
- dap_chain_addr_t *l_signing_addr = dap_chain_addr_from_str(l_signing_addr_str);
- if(!l_signing_addr) {
- {
- log_it(L_ERROR, "Json TX: bad signing_addr in OUT_COND_SUBTYPE_SRV_STAKE_POS_DELEGATE");
- break;
- }
- dap_chain_node_addr_t l_signer_node_addr;
- const char *l_node_addr_str = s_json_get_text(l_json_item_obj, "node_addr");
- if(!l_node_addr_str || dap_chain_node_addr_from_str(&l_signer_node_addr, l_node_addr_str)) {
- log_it(L_ERROR, "Json TX: bad node_addr in OUT_COND_SUBTYPE_SRV_STAKE_POS_DELEGATE");
- break;
- }
- // Maybe should get pkey and tronsform to dap_pkey_t
- dap_pkey_t *l_pkey = NULL;
- const char *l_pkey_full_str = s_json_get_text(l_json_item_obj, "pkey_full");
- if(l_pkey_full_str) {
- l_pkey = dap_pkey_get_from_str(l_pkey_full_str);
- debug_if(!l_pkey, L_ERROR, "Json TX: bad pkey in OUT_COND_SUBTYPE_SRV_STAKE_POS_DELEGATE");
- }
-
- dap_chain_tx_out_cond_t *l_out_cond_item = dap_chain_datum_tx_item_out_cond_create_srv_stake(l_srv_uid, l_value, l_signing_addr,
- &l_signer_node_addr, NULL, uint256_0, l_pkey);
- l_item = (const uint8_t*) l_out_cond_item;
- // Save value for using in In item
- if(l_item) {
- SUM_256_256(l_value_need, l_value, &l_value_need);
- } else {
- char *l_err_str = dap_strdup_printf("Unable to create conditional out for transaction "
- "can of type %s described in item %zu.", l_subtype_str, i);
- json_object *l_jobj_err = json_object_new_string(l_err_str);
- DAP_DELETE(l_err_str);
- json_object_array_add(l_jobj_errors, l_jobj_err);
- }
- }
- }
- break;
- case DAP_CHAIN_TX_OUT_COND_SUBTYPE_FEE: {
- uint256_t l_value = { };
- s_json_get_uint256(l_json_item_obj, "value", &l_value);
- if(!IS_ZERO_256(l_value)) {
- dap_chain_tx_out_cond_t *l_out_cond_item = dap_chain_datum_tx_item_out_cond_create_fee(l_value);
- l_item = (const uint8_t*) l_out_cond_item;
- // Save value for using in In item
- if(l_item) {
- SUM_256_256(l_value_need_fee, l_value, &l_value_need_fee);
- } else {
- char *l_str_err = dap_strdup_printf("Unable to create conditional out for transaction "
- "can of type %s described in item %zu.", l_subtype_str, i);
- json_object *l_jobj_err = json_object_new_string(l_str_err);
- json_object_array_add(l_jobj_errors, l_jobj_err);
- DAP_DELETE(l_str_err);
- }
- }
- else
- log_it(L_ERROR, "Json TX: zero value in OUT_COND_SUBTYPE_FEE");
- }
- break;
- case DAP_CHAIN_TX_OUT_COND_SUBTYPE_UNDEFINED:
- log_it(L_WARNING, "Undefined subtype: '%s' of 'out_cond' item %zu ", l_subtype_str, i);
- char *l_str_err = dap_strdup_printf("Specified unknown sub type %s of conditional out on item %zu.",
- l_subtype_str, i);
- json_object *l_jobj_err = json_object_new_string(l_str_err);
- DAP_DELETE(l_str_err);
- json_object_array_add(l_jobj_errors, l_jobj_err);
- break;
- }
- }
-
- break;
- case TX_ITEM_TYPE_SIG:{
- const char *l_sign_type_str = s_json_get_text(l_json_item_obj, "sig_type");
- if (l_sign_type_str) {
- int64_t l_pkey_size;
- int64_t l_sig_size;
- int64_t l_hash_type = 0;
- dap_sign_t *l_sign = NULL;
- dap_sign_type_t l_type = dap_sign_type_from_str(l_sign_type_str);
-
- s_json_get_int64(l_json_item_obj, "hash_type", &l_hash_type);
- s_json_get_int64(l_json_item_obj, "pub_key_size", &l_pkey_size);
- s_json_get_int64(l_json_item_obj, "sig_size", &l_sig_size);
- if (l_pkey_size == 0 || l_sig_size == 0){
- json_object *l_jobj_err = json_object_new_string("Can't get sign for transactions. Sign or pkey length is 0.");
- json_object_array_add(l_jobj_errors, l_jobj_err);
- log_it(L_ERROR, "Json TX: Can't get sign for transactions. Sign or pkey length is 0.");
- break;
- }
-
- l_sign = DAP_NEW_Z_SIZE(dap_sign_t, sizeof(dap_sign_t) + l_pkey_size + l_sig_size);
-
-
- json_object *l_jobj_sign = json_object_object_get(l_json_item_obj, "sig_b64");
- const char *l_sign_str = json_object_get_string(l_jobj_sign);
- void *l_sig_buf = DAP_NEW_SIZE(void,DAP_ENC_BASE64_ENCODE_SIZE(l_sig_size));
- size_t l_sign_decoded_size = dap_enc_base64_decode(l_sign_str, dap_strlen(l_sign_str), l_sig_buf, DAP_ENC_DATA_TYPE_B64_URLSAFE);
-
-
- json_object *l_jobj_pub_key = json_object_object_get(l_json_item_obj, "pub_key_b64");
- const char *l_pub_key_str = json_object_get_string(l_jobj_pub_key);
- void *l_pkey_buf = DAP_NEW_SIZE(void,DAP_ENC_BASE64_ENCODE_SIZE(l_pkey_size));
- size_t l_pkey_decoded_size = dap_enc_base64_decode(l_pub_key_str, strlen(l_pub_key_str), l_pkey_buf, DAP_ENC_DATA_TYPE_B64_URLSAFE);
-
- l_sign->header.sign_pkey_size = l_pkey_size;
- l_sign->header.sign_size = l_sig_size;
- l_sign->header.type = l_type;
- l_sign->header.hash_type = (uint8_t)l_hash_type;
- memcpy(l_sign->pkey_n_sign, l_pkey_buf, l_pkey_decoded_size);
- memcpy(l_sign->pkey_n_sign + l_pkey_decoded_size, l_sig_buf, l_sign_decoded_size);
- DAP_DELETE(l_pkey_buf);
- DAP_DELETE(l_sig_buf);
-
- size_t l_chain_sign_size = dap_sign_get_size(l_sign); // sign data
-
- dap_chain_tx_sig_t *l_tx_sig = DAP_NEW_Z_SIZE(dap_chain_tx_sig_t,
- sizeof(dap_chain_tx_sig_t) + l_chain_sign_size);
- l_tx_sig->header.type = TX_ITEM_TYPE_SIG;
- l_tx_sig->header.sig_size =(uint32_t) l_chain_sign_size;
- memcpy(l_tx_sig->sig, l_sign, l_chain_sign_size);
- // dap_chain_datum_tx_add_item(&l_tx, l_tx_sig);
- l_item = (const uint8_t*)l_tx_sig;
- DAP_DELETE(l_sign);
- break;
- }
- else
- l_sign_list = dap_list_append(l_sign_list,l_json_item_obj);
- }
- break;
- case TX_ITEM_TYPE_RECEIPT: {
- uint64_t l_64 = 0;
- if (!s_json_get_srv_uid(l_json_item_obj, "service_id", "service", &l_64)) {
- log_it(L_ERROR, "Json TX: bad service_id in TYPE_RECEIPT");
- break;
- }
- dap_chain_srv_uid_t l_srv_uid = { .uint64 = l_64 };
- dap_chain_net_srv_price_unit_uid_t l_price_unit;
- if(!s_json_get_unit(l_json_item_obj, "price_unit", &l_price_unit)) {
- log_it(L_ERROR, "Json TX: bad price_unit in TYPE_RECEIPT");
- break;
- }
- int64_t l_units;
- if(!s_json_get_int64(l_json_item_obj, "units", &l_units)) {
- log_it(L_ERROR, "Json TX: bad units in TYPE_RECEIPT");
- break;
- }
- uint256_t l_value = { };
- if(!s_json_get_uint256(l_json_item_obj, "value", &l_value) || IS_ZERO_256(l_value)) {
- log_it(L_ERROR, "Json TX: bad value in TYPE_RECEIPT");
- break;
- }
- const char *l_params_str = s_json_get_text(l_json_item_obj, "params");
- size_t l_params_size = dap_strlen(l_params_str);
- dap_chain_datum_tx_receipt_t *l_receipt = dap_chain_datum_tx_receipt_create(l_srv_uid, l_price_unit, l_units, l_value, l_params_str, l_params_size);
- l_item = (const uint8_t*) l_receipt;
- if (!l_item) {
- char *l_str_err = dap_strdup_printf("Unable to create receipt out for transaction "
- "described by item %zu.", i);
- json_object *l_jobj_err = json_object_new_string(l_str_err);
- DAP_DELETE(l_str_err);
- json_object_array_add(l_jobj_errors, l_jobj_err);
- }
- }
- break;
- case TX_ITEM_TYPE_TSD: {
- int64_t l_tsd_type;
- if(!s_json_get_int64(l_json_item_obj, "type_tsd", &l_tsd_type)) {
- log_it(L_ERROR, "Json TX: bad type_tsd in TYPE_TSD");
- break;
- }
- const char *l_tsd_data = s_json_get_text(l_json_item_obj, "data");
- if (!l_tsd_data) {
- log_it(L_ERROR, "Json TX: bad data in TYPE_TSD");
- break;
- }
- size_t l_data_size = dap_strlen(l_tsd_data);
- dap_chain_tx_tsd_t *l_tsd = dap_chain_datum_tx_item_tsd_create((void*)l_tsd_data, (int)l_tsd_type, l_data_size);
- l_item = (const uint8_t*) l_tsd;
- }
- break;
- //case TX_ITEM_TYPE_PKEY:
- //break;
- //case TX_ITEM_TYPE_IN_EMS:
- //break;
- //case TX_ITEM_TYPE_IN_EMS_EXT:
- //break;
- }
- // Add item to transaction
- if(l_item) {
- dap_chain_datum_tx_add_item(&l_tx, (const uint8_t*) l_item);
- l_items_ready++;
- DAP_DELETE(l_item);
- }
- }
-
- dap_list_t *l_list;
- // Add In items
- l_list = l_in_list;
- while(l_list) {
- struct json_object *l_json_item_obj = (struct json_object*) l_list->data;
- // Read prev_hash and out_prev_idx
- const char *l_json_item_addr_str = s_json_get_text(l_json_item_obj, "addr_from");
- const char *l_json_item_token = s_json_get_text(l_json_item_obj, "token");
- l_main_token = l_json_item_token;
- dap_chain_addr_t *l_addr_from = NULL;
- if(l_json_item_addr_str) {
- l_addr_from = dap_chain_addr_from_str(l_json_item_addr_str);
- if (!l_addr_from) {
- log_it(L_WARNING, "Invalid element 'in', unable to convert string representation of addr_from: '%s' "
- "to binary.", l_json_item_addr_str);
- char *l_str_err = dap_strdup_printf("Invalid element 'to', unable to convert string representation "
- "of addr_from: '%s' to binary.", l_json_item_addr_str);
- json_object *l_jobj_err = json_object_new_string(l_str_err);
- DAP_DELETE(l_str_err);
- json_object_array_add(l_jobj_errors, l_jobj_err);
- // Go to the next item
- l_list = dap_list_next(l_list);
- continue;
- }
- }
- else {
- log_it(L_WARNING, "Invalid 'in' item, incorrect addr_from: '%s'", l_json_item_addr_str ? l_json_item_addr_str : "[null]");
- char *l_str_err = dap_strdup_printf("Invalid 'in' item, incorrect addr_from: '%s'",
- l_json_item_addr_str ? l_json_item_addr_str : "[null]");
- json_object *l_jobj_err = json_object_new_string(l_str_err);
- DAP_DELETE(l_str_err);
- json_object_array_add(l_jobj_errors, l_jobj_err);
- // Go to the next item
- l_list = dap_list_next(l_list);
- continue;
- }
- if(!l_json_item_token) {
- log_it(L_WARNING, "Invalid 'in' item, not found token name");
- json_object *l_jobj_err = json_object_new_string("Invalid 'in' item, not found token name");
- json_object_array_add(l_jobj_errors, l_jobj_err);
- // Go to the next item
- l_list = dap_list_next(l_list);
- continue;
- }
- if(IS_ZERO_256(l_value_need)) {
- log_it(L_WARNING, "Invalid 'in' item, not found value in out items");
- json_object *l_jobj_err = json_object_new_string("Invalid 'in' item, not found value in out items");
- json_object_array_add(l_jobj_errors, l_jobj_err);
- // Go to the next item
- l_list = dap_list_next(l_list);
- continue;
- }
- if(l_addr_from)
- {
- // find the transactions from which to take away coins
- dap_list_t *l_list_used_out = NULL;
- dap_list_t *l_list_used_out_fee = NULL;
- uint256_t l_value_transfer = { }; // how many coins to transfer
- uint256_t l_value_transfer_fee = { }; // how many coins to transfer
- //SUM_256_256(a_value, a_value_fee, &l_value_need);
- uint256_t l_value_need_check = {};
- if (!dap_strcmp(l_native_token, l_main_token)) {
- SUM_256_256(l_value_need_check, l_value_need, &l_value_need_check);
- SUM_256_256(l_value_need_check, l_value_need_fee, &l_value_need_check);
- l_list_used_out = dap_chain_wallet_get_list_tx_outs_with_val(a_net->pub.ledger, l_json_item_token,
- l_addr_from, l_value_need_check, &l_value_transfer);
- if(!l_list_used_out) {
- log_it(L_WARNING, "Not enough funds in previous tx to transfer");
- json_object *l_jobj_err = json_object_new_string("Can't create in transaction. Not enough funds in previous tx "
- "to transfer");
- json_object_array_add(l_jobj_errors, l_jobj_err);
- // Go to the next item
- l_list = dap_list_next(l_list);
- continue;
- }
- } else {
- //CHECK value need
- l_list_used_out = dap_chain_wallet_get_list_tx_outs_with_val(a_net->pub.ledger, l_json_item_token,
- l_addr_from, l_value_need, &l_value_transfer);
- if(!l_list_used_out) {
- log_it(L_WARNING, "Not enough funds in previous tx to transfer");
- json_object *l_jobj_err = json_object_new_string("Can't create in transaction. Not enough funds "
- "in previous tx to transfer");
- json_object_array_add(l_jobj_errors, l_jobj_err);
- // Go to the next item
- l_list = dap_list_next(l_list);
- continue;
- }
- //CHECK value fee
- l_list_used_out_fee = dap_chain_wallet_get_list_tx_outs_with_val(a_net->pub.ledger, l_native_token,
- l_addr_from, l_value_need_fee, &l_value_transfer_fee);
- if(!l_list_used_out_fee) {
- log_it(L_WARNING, "Not enough funds in previous tx to transfer");
- json_object *l_jobj_err = json_object_new_string("Can't create in transaction. Not enough funds "
- "in previous tx to transfer");
- json_object_array_add(l_jobj_errors, l_jobj_err);
- // Go to the next item
- l_list = dap_list_next(l_list);
- continue;
- }
- }
- // add 'in' items
- uint256_t l_value_got = dap_chain_datum_tx_add_in_item_list(&l_tx, l_list_used_out);
- assert(EQUAL_256(l_value_got, l_value_transfer));
- if (l_list_used_out_fee) {
- uint256_t l_value_got_fee = dap_chain_datum_tx_add_in_item_list(&l_tx, l_list_used_out_fee);
- assert(EQUAL_256(l_value_got_fee, l_value_transfer_fee));
- dap_list_free_full(l_list_used_out_fee, free);
- // add 'out' item for coin fee back
- uint256_t l_value_back;
- SUBTRACT_256_256(l_value_got_fee, l_value_need_fee, &l_value_back);
- if (!IS_ZERO_256(l_value_back)) {
- dap_chain_datum_tx_add_out_ext_item(&l_tx, l_addr_from, l_value_back, l_native_token);
- }
- } else {
- SUM_256_256(l_value_need, l_value_need_fee, &l_value_need);
- }
- dap_list_free_full(l_list_used_out, free);
- if(!IS_ZERO_256(l_value_got)) {
- l_items_ready++;
-
- // add 'out' item for coin back
- uint256_t l_value_back;
- SUBTRACT_256_256(l_value_got, l_value_need, &l_value_back);
- if(!IS_ZERO_256(l_value_back)) {
- if (l_multichanel)
- dap_chain_datum_tx_add_out_ext_item(&l_tx, l_addr_from, l_value_back, l_main_token);
- else
- dap_chain_datum_tx_add_out_item(&l_tx, l_addr_from, l_value_back);
- }
- }
- }
- // Go to the next 'in' item
- l_list = dap_list_next(l_list);
- }
- dap_list_free(l_in_list);
-
- // Add signs
- l_list = l_sign_list;
- while(l_list) {
-
- struct json_object *l_json_item_obj = (struct json_object*) l_list->data;
-
- dap_enc_key_t * l_enc_key = NULL;
-
- //get wallet or cert
- dap_chain_wallet_t *l_wallet = s_json_get_wallet(l_json_item_obj, "wallet");
- const dap_cert_t *l_cert = s_json_get_cert(l_json_item_obj, "cert");
-
- const char *l_sign_type_str = s_json_get_text(l_json_item_obj, "sig_type");
- int64_t l_pkey_size, l_sig_size;
- uint8_t *l_pkey = NULL;
- dap_sign_t *l_sign = NULL;
- dap_enc_key_type_t l_type = dap_enc_key_type_find_by_name(l_sign_type_str);
- dap_enc_key_t * l_ret = dap_enc_key_new(l_type);
-
- //wallet goes first
- if (l_wallet)
- l_enc_key = dap_chain_wallet_get_key(l_wallet, 0);
- else if (l_cert && l_cert->enc_key)
- l_enc_key = l_cert->enc_key;
- else if (l_sign_type_str) {
-
- s_json_get_int64(l_json_item_obj, "pub_key_size", &l_pkey_size);
- s_json_get_int64(l_json_item_obj, "sig_size", &l_sig_size);
-
- json_object *l_jobj_sign = json_object_object_get(l_json_item_obj, "sig_b64");
- const char *l_sign_str = json_object_get_string(l_jobj_sign);
- dap_sign_t *l_sign = DAP_NEW_Z_SIZE_RET_VAL_IF_FAIL(dap_sign_t, DAP_ENC_BASE64_DECODE_SIZE(dap_strlen(l_sign_str)),
- DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_CAN_NOT_ALLOC_MEMORY, NULL);
- size_t l_sign_decree_size = dap_enc_base64_decode(l_sign_str, dap_strlen(l_sign_str), l_sign, DAP_ENC_DATA_TYPE_B64);
-
- json_object *l_jobj_pub_key = json_object_object_get(l_json_item_obj, "pub_key_b64");
- const char *l_pub_key_str = json_object_get_string(l_jobj_pub_key);
-
- byte_t *l_proc_buf = DAP_NEW_Z_SIZE_RET_VAL_IF_FAIL(byte_t, DAP_ENC_BASE64_DECODE_SIZE(l_pkey_size),
- DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_CAN_NOT_ALLOC_MEMORY, NULL);
- size_t l_proc_buf_size = dap_enc_base64_decode(l_pub_key_str, l_pkey_size, l_proc_buf, DAP_ENC_DATA_TYPE_B64);
- UNUSED(l_proc_buf_size);
- if (dap_enc_key_deserialize_pub_key(l_ret, l_proc_buf, l_pkey_size)) {
- log_it(L_ERROR, "Error in enc pub key deserialize");
- DAP_DEL_Z(l_ret);
- }
- } else{
- json_object *l_jobj_err = json_object_new_string("Can't create sign for transactions.");
- json_object_array_add(l_jobj_errors, l_jobj_err);
- log_it(L_ERROR, "Json TX: Item sign has no wallet or cert of they are invalid ");
- l_list = dap_list_next(l_list);
- continue;
- }
-
- if(l_enc_key && dap_chain_datum_tx_add_sign_item(&l_tx, l_enc_key) > 0) {
- l_items_ready++;
- } else {
- log_it(L_ERROR, "Json TX: Item sign has invalid enc_key.");
- l_list = dap_list_next(l_list);
- continue;
- }
- if (l_sign) {
- size_t l_chain_sign_size = dap_sign_get_size(l_sign); // sign data
-
- dap_chain_tx_sig_t *l_tx_sig = DAP_NEW_Z_SIZE_RET_VAL_IF_FAIL(dap_chain_tx_sig_t,
- sizeof(dap_chain_tx_sig_t) + l_chain_sign_size,
- DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_CAN_NOT_ALLOC_MEMORY,
- NULL);
- l_tx_sig->header.type = TX_ITEM_TYPE_SIG;
- l_tx_sig->header.sig_size =(uint32_t) l_chain_sign_size;
- memcpy(l_tx_sig->sig, l_sign, l_chain_sign_size);
- dap_chain_datum_tx_add_item(&l_tx, l_tx_sig);
- DAP_DELETE(l_sign);
- }
-
- if (l_wallet) {
- dap_chain_wallet_close(l_wallet);
- dap_enc_key_delete(l_enc_key);
- }
-
-
- l_list = dap_list_next(l_list);
- }
-
- dap_list_free(l_sign_list);
-
- *a_out_items_ready = l_items_ready;
-
- if(l_items_ready<l_items_count) {
- *a_out_jobj_error = l_jobj_errors;
- DAP_DELETE(l_tx);
- return DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_INVALID_ITEMS;
- }
- json_object_put(l_jobj_errors);
- *a_out_tx = l_tx;
-
- return 0;
-}
-
-/**
- * @breif Create transaction from json rpc request
- * @param a_param
- * @param a_reply
- */
-void json_rpc_tx_create(json_object *a_param, json_object *a_reply){
- const char *l_net_name = NULL;
- const char *l_chain_name = NULL;
- json_object *l_json_net = json_object_object_get(a_param, "net");
- if(l_json_net && json_object_is_type(l_json_net, json_type_string)) {
- l_net_name = json_object_get_string(l_json_net);
- }
- if(!l_net_name) {
- dap_json_rpc_error_add(a_reply, DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_REQUIRE_PARAMETER_NET,
- "Command requires parameter '-net' or set net in the json-rpc request");
- return;
- }
- json_object *l_json_chain = json_object_object_get(a_param, "chain");
- if(l_json_chain && json_object_is_type(l_json_chain, json_type_string)) {
- l_chain_name = json_object_get_string(l_json_chain);
- }
- dap_chain_net_t *l_net = dap_chain_net_by_name(l_net_name);
- if (!l_net) {
- dap_json_rpc_error_add(a_reply,
- DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_NOT_FOUNT_NET_BY_NAME,
- "Not found net by name '%s'", l_net_name);
- return;
- }
- dap_chain_t *l_chain = NULL;
- if (!l_chain_name) {
- l_chain = dap_chain_net_get_chain_by_chain_type(l_net, CHAIN_TYPE_TX);
- } else {
- l_chain = dap_chain_net_get_chain_by_name(l_net, l_chain_name);
- if (!l_chain){
- dap_json_rpc_error_add(a_reply, DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_NOT_FOUNT_CHAIN_BY_NAME,
- "Chain name '%s' not found, try use parameter '-chain' or set chain in the json-rpc request", l_chain_name);
- return;
- }
- }
- dap_chain_datum_tx_t *l_tx = NULL;
- json_object *l_jobj_items = json_object_object_get(a_param, "items");
- if (!l_jobj_items) {
- dap_json_rpc_error_add(a_reply, DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_NOT_FOUNT_ARRAY_ITEMS,
- "Items with description transaction not found in JSON.");
- return ;
- }
- size_t l_items_ready = 0;
- json_object *l_jobj_errors = NULL;
- int res = s_json_rpc_tx_parse_json(l_net, l_chain, l_jobj_items, &l_tx, &l_items_ready, &l_jobj_errors);
- if (res) {
- json_object *l_jobj_tx_create = json_object_new_boolean(false);
- json_object *l_jobj_items_ready = json_object_new_uint64(l_items_ready);
- json_object *l_jobj_total_items = json_object_new_uint64(json_object_array_length(l_jobj_items));
- json_object_object_add(a_reply, "tx_create", l_jobj_tx_create);
- json_object_object_add(a_reply, "ready_items", l_jobj_items_ready);
- json_object_object_add(a_reply, "total_items", l_jobj_total_items);
- json_object_object_add(a_reply, "errors", l_jobj_errors);
- return;
- }
-
- // Pack transaction into the datum
- size_t l_tx_size = dap_chain_datum_tx_get_size(l_tx);
- dap_chain_datum_t *l_datum_tx = dap_chain_datum_create(DAP_CHAIN_DATUM_TX, l_tx, l_tx_size);
- size_t l_datum_tx_size = dap_chain_datum_size(l_datum_tx);
- DAP_DELETE(l_tx);
-
- // Add transaction to mempool
- char *l_tx_hash_str = dap_get_data_hash_str(l_datum_tx->data, l_datum_tx->header.data_size).s;
- dap_chain_hash_fast_t l_hf_tx = {0};
- dap_chain_hash_fast_from_str(l_tx_hash_str, &l_hf_tx);
- int rc = -1;
- if ((rc = dap_ledger_tx_add_check(l_net->pub.ledger, (dap_chain_datum_tx_t*)l_datum_tx->data, l_tx_size, &l_hf_tx))) {
- json_object *l_jobj_tx_create = json_object_new_boolean(false);
- json_object *l_jobj_hash = json_object_new_string(l_tx_hash_str);
- json_object *l_jobj_total_items = json_object_new_uint64(json_object_array_length(l_jobj_items));
- json_object *l_jobj_ledger_ret_code = json_object_new_object();
- json_object_object_add(l_jobj_ledger_ret_code, "code", json_object_new_int(rc));
- json_object_object_add(l_jobj_ledger_ret_code, "message",
- json_object_new_string(dap_chain_net_verify_datum_err_code_to_str(l_datum_tx, rc)));
- json_object_object_add(a_reply, "tx_create", l_jobj_tx_create);
- json_object_object_add(a_reply, "hash", l_jobj_hash);
- json_object_object_add(a_reply, "ledger_code", l_jobj_ledger_ret_code);
- json_object_object_add(a_reply, "total_items", l_jobj_total_items);
- DAP_DELETE(l_datum_tx);
- return ;
- }
-
- char *l_gdb_group_mempool_base_tx = dap_chain_mempool_group_new(l_chain);// get group name for mempool
- bool l_placed = !dap_global_db_set(l_gdb_group_mempool_base_tx, l_tx_hash_str, l_datum_tx, l_datum_tx_size, false, NULL, NULL);
-
- DAP_DELETE(l_datum_tx);
- DAP_DELETE(l_gdb_group_mempool_base_tx);
- if(!l_placed) {
- dap_json_rpc_error_add(a_reply, DAP_CHAIN_NODE_CLI_COM_TX_CREATE_JSON_CAN_NOT_ADD_TRANSACTION_TO_MEMPOOL,
- "Can't add transaction to mempool");
- return ;
- }
- // Completed successfully
- json_object *l_jobj_tx_create = json_object_new_boolean(true);
- json_object *l_jobj_hash = json_object_new_string(l_tx_hash_str);
- json_object *l_jobj_total_items = json_object_new_uint64(json_object_array_length(l_jobj_items));
- json_object_object_add(a_reply, "tx_create", l_jobj_tx_create);
- json_object_object_add(a_reply, "hash", l_jobj_hash);
- json_object_object_add(a_reply, "total_items", l_jobj_total_items);
-}
-
/**
* @brief Create transaction from json file
* com_tx_create command