diff --git a/modules/chain/dap_chain_common.c b/modules/chain/dap_chain_common.c
index dbb610c4f4ad0065bb5fa85226b8e46f46e81e9f..e6ff3354a04fbdbe054957b63737651670986224 100644
--- a/modules/chain/dap_chain_common.c
+++ b/modules/chain/dap_chain_common.c
@@ -216,12 +216,12 @@ void dap_chain_set_offset_limit_json(json_object * a_json_obj_out, size_t *a_sta
json_object* json_obj_lim = json_object_new_object();
if (a_offset > 0) {
*a_start = a_offset;
- json_object_object_add(json_obj_lim, "offset", json_object_new_int(*a_start));
+ json_object_object_add(json_obj_lim, "offset", json_object_new_uint64(*a_start));
}
*a_and = a_and_count;
if (a_limit > 0) {
*a_and = *a_start + a_limit;
- json_object_object_add(json_obj_lim, "limit", json_object_new_int(*a_and - *a_start));
+ json_object_object_add(json_obj_lim, "limit", json_object_new_uint64(*a_and - *a_start));
}
else
json_object_object_add(json_obj_lim, "limit", json_object_new_string("unlimit"));
diff --git a/modules/service/xchange/dap_chain_net_srv_xchange.c b/modules/service/xchange/dap_chain_net_srv_xchange.c
index ed2ce1a4e71a052ddb0295f76ffdcf32db0160ea..de364a9717de02c291008974decebfed4809e218 100644
--- a/modules/service/xchange/dap_chain_net_srv_xchange.c
+++ b/modules/service/xchange/dap_chain_net_srv_xchange.c
@@ -115,6 +115,10 @@ static bool s_string_append_tx_cond_info( dap_string_t * a_reply_str, dap_chain_
dap_chain_addr_t *a_owner_addr, dap_chain_addr_t *a_buyer_addr, dap_chain_datum_tx_t * a_tx,
dap_hash_fast_t *a_tx_hash, tx_opt_status_t a_filter_by_status, bool a_append_prev_hash,
bool a_print_status,bool a_print_ts);
+static bool s_string_append_tx_cond_info_json( json_object * a_json_out, dap_chain_net_t * a_net,
+ dap_chain_addr_t *a_owner_addr, dap_chain_addr_t *a_buyer_addr, dap_chain_datum_tx_t * a_tx,
+ tx_opt_status_t a_filter_by_status, bool a_print_prev_hash, bool a_print_status, bool a_print_ts);
+
dap_chain_net_srv_xchange_price_t *s_xchange_price_from_order(dap_chain_net_t *a_net, dap_chain_datum_tx_t *a_order,
dap_hash_fast_t *a_order_hash, uint256_t *a_fee, bool a_ret_is_invalid);
static void s_ledger_tx_add_notify(dap_ledger_t *a_ledger, dap_chain_datum_tx_t *a_tx_in,
@@ -235,7 +239,7 @@ int dap_chain_net_srv_xchange_init()
"srv_xchange token_pair -net <net_name> list all [-limit <limit>] [-offset <offset>]\n"
"\tList of all token pairs\n"
- "srv_xchange token_pair -net <net_name> rate average -token_from <token_ticker> -token_to <token_ticker>\n"
+ "srv_xchange token_pair -net <net_name> rate average [-time_from <From_time>] [-time_to <To_time>]\n"
"\tGet average rate for token pair <token from>:<token to> from <From time> to <To time> \n"
"srv_xchange token_pair -net <net_name> rate history -token_from <token_ticker> -token_to <token_ticker> [-time_from <From_time>] [-time_to <To_time>] [-limit <limit>] [-offset <offset>]\n"
"\tPrint rate history for token pair <token from>:<token to> from <From time> to <To time>\n"
@@ -1238,7 +1242,7 @@ dap_chain_net_srv_xchange_price_t *s_xchange_price_from_order(dap_chain_net_t *a
* @param a_str_reply
* @return
*/
-static int s_cli_srv_xchange_order(int a_argc, char **a_argv, int a_arg_index, void **a_str_reply)
+static int s_cli_srv_xchange_order(int a_argc, char **a_argv, int a_arg_index, json_object **a_json_arr_reply)
{
enum {
CMD_NONE, CMD_CREATE, CMD_REMOVE, CMD_UPDATE, CMD_HISTORY, CMD_STATUS
@@ -1265,63 +1269,72 @@ static int s_cli_srv_xchange_order(int a_argc, char **a_argv, int a_arg_index, v
case CMD_CREATE: {
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-net", &l_net_str);
if (!l_net_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'order create' requires parameter -net");
- return -2;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_REQ_PARAM_NET_ERR, "Command 'order create' requires parameter -net");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_REQ_PARAM_NET_ERR;
}
l_net = dap_chain_net_by_name(l_net_str);
if (!l_net) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Network %s not found", l_net_str);
- return -3;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_NET_NOT_FOUND_ERR, "Command 'order create' requires parameter -net");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_NET_NOT_FOUND_ERR;
}
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-token_sell", &l_token_sell_str);
if (!l_token_sell_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'order create' requires parameter -token_sell");
- return -5;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_PARAM_TOKEN_SELL_ERR,
+ "Command 'order create' requires parameter -token_sell");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_PARAM_TOKEN_SELL_ERR;
}
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-token_buy", &l_token_buy_str);
if (!l_token_buy_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'order create' requires parameter -token_buy");
- return -5;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_PARAM_TOKEN_BUY_ERR,
+ "Command 'order create' requires parameter -token_buy");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_PARAM_TOKEN_BUY_ERR;
}
if (!dap_ledger_token_ticker_check(l_net->pub.ledger, l_token_buy_str)) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Token ticker %s not found", l_token_buy_str);
- return -6;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_PARAM_TICKR_NOTF_ERR,
+ "Token ticker %s not found", l_token_buy_str);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_PARAM_TICKR_NOTF_ERR;
}
if (!strcmp(l_token_sell_str, l_token_buy_str)){
- dap_cli_server_cmd_set_reply_text(a_str_reply, "token_buy and token_sell must be different!");
- return -7;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_TOKEN_EQUAL_ERR,
+ "token_buy and token_sell must be different!");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_TOKEN_EQUAL_ERR;
}
const char *l_val_sell_str = NULL, *l_val_rate_str = NULL;
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-value", &l_val_sell_str);
if (!l_val_sell_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'order create' requires parameter -value");
- return -8;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CRTE_REQ_PARAM_VALUE_ERR,
+ "Command 'order create' requires parameter -value");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CRTE_REQ_PARAM_VALUE_ERR;
}
uint256_t l_datoshi_sell = dap_chain_balance_scan(l_val_sell_str);
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-rate", &l_val_rate_str);
if (!l_val_rate_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'order create' requires parameter -rate");
- return -8;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CRTE_REQ_PARAM_RATE_ERR,
+ "Command 'order create' requires parameter -rate");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CRTE_REQ_PARAM_RATE_ERR;
}
uint256_t l_rate = dap_chain_balance_coins_scan(l_val_rate_str);
const char *l_fee_str = NULL;
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-fee", &l_fee_str);
if (!l_fee_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'order create' requires parameter -fee");
- return -20;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CRTE_REQ_PARAM_FEE_ERR,
+ "Command 'order create' requires parameter -fee");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CRTE_REQ_PARAM_FEE_ERR;
}
uint256_t l_fee = dap_chain_balance_scan(l_fee_str);
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-w", &l_wallet_str);
if (!l_wallet_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'order create' requires parameter -w");
- return -10;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CRTE_REQ_PARAM_W_ERR,
+ "Command 'order create' requires parameter -w");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CRTE_REQ_PARAM_W_ERR;
}
dap_chain_wallet_t *l_wallet = dap_chain_wallet_open(l_wallet_str, dap_chain_wallet_get_path(g_config), NULL);
if (!l_wallet) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Specified wallet not found");
- return -11;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CRTE_WALLET_NOT_FOUND_ERR,
+ "Specified wallet not found");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CRTE_WALLET_NOT_FOUND_ERR;
}
const char* l_sign_str = dap_chain_wallet_check_sign(l_wallet);
char *l_hash_ret = NULL;
@@ -1329,72 +1342,91 @@ static int s_cli_srv_xchange_order(int a_argc, char **a_argv, int a_arg_index, v
dap_chain_wallet_close(l_wallet);
switch (ret_code) {
case XCHANGE_CREATE_ERROR_OK: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "%s\nSuccessfully created order %s", l_sign_str, l_hash_ret);
+ json_object* json_obj_order = json_object_new_object();
+ json_object_object_add(json_obj_order, "status", json_object_new_string("Successfully created"));
+ json_object_object_add(json_obj_order, "sign", json_object_new_string(l_sign_str));
+ json_object_object_add(json_obj_order, "hash", json_object_new_string(l_hash_ret));
+ json_object_array_add(*a_json_arr_reply, json_obj_order);
DAP_DELETE(l_hash_ret);
- return 0;
+ return DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_OK;
}
case XCHANGE_CREATE_ERROR_INVALID_ARGUMENT: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Some parameters could not be set during a function call");
- return -24;
+ dap_json_rpc_error_add(*a_json_arr_reply, XCHANGE_CREATE_ERROR_INVALID_ARGUMENT,
+ "Some parameters could not be set during a function call");
+ return -XCHANGE_CREATE_ERROR_INVALID_ARGUMENT;
}
case XCHANGE_CREATE_ERROR_TOKEN_TICKER_SELL_IS_NOT_FOUND_LEDGER: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Token ticker %s not found", l_token_sell_str);
- return -6;
+ dap_json_rpc_error_add(*a_json_arr_reply, XCHANGE_CREATE_ERROR_TOKEN_TICKER_SELL_IS_NOT_FOUND_LEDGER,
+ "Token ticker %s not found", l_token_sell_str);
+ return -XCHANGE_CREATE_ERROR_TOKEN_TICKER_SELL_IS_NOT_FOUND_LEDGER;
}
case XCHANGE_CREATE_ERROR_TOKEN_TICKER_BUY_IS_NOT_FOUND_LEDGER: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Token ticker %s not found", l_token_buy_str);
- return -6;
+ dap_json_rpc_error_add(*a_json_arr_reply, XCHANGE_CREATE_ERROR_TOKEN_TICKER_BUY_IS_NOT_FOUND_LEDGER,
+ "Token ticker %s not found", l_token_buy_str);
+ return -XCHANGE_CREATE_ERROR_TOKEN_TICKER_BUY_IS_NOT_FOUND_LEDGER;
}
case XCHANGE_CREATE_ERROR_RATE_IS_ZERO: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Format -rate n.n = buy / sell (eg: 1.0, 1.135)");
- return -9;
+ dap_json_rpc_error_add(*a_json_arr_reply, XCHANGE_CREATE_ERROR_RATE_IS_ZERO,
+ "Format -rate n.n = buy / sell (eg: 1.0, 1.135)");
+ return -XCHANGE_CREATE_ERROR_RATE_IS_ZERO;
}
case XCHANGE_CREATE_ERROR_FEE_IS_ZERO: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Format -value <unsigned integer 256>");
- return -21;
+ dap_json_rpc_error_add(*a_json_arr_reply, XCHANGE_CREATE_ERROR_FEE_IS_ZERO,
+ "Format -value <unsigned integer 256>");
+ return -XCHANGE_CREATE_ERROR_FEE_IS_ZERO;
}
case XCHANGE_CREATE_ERROR_VALUE_SELL_IS_ZERO: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Format -value <unsigned integer 256>");
- return -9;
+ dap_json_rpc_error_add(*a_json_arr_reply, XCHANGE_CREATE_ERROR_VALUE_SELL_IS_ZERO,
+ "Format -value <unsigned integer 256>");
+ return -XCHANGE_CREATE_ERROR_VALUE_SELL_IS_ZERO;
}
case XCHANGE_CREATE_ERROR_INTEGER_OVERFLOW_WITH_SUM_OF_VALUE_AND_FEE: {
log_it(L_ERROR, "Integer overflow with sum of value and fee");
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Integer overflow with sum of value and fee");
- return -22;
+ dap_json_rpc_error_add(*a_json_arr_reply, XCHANGE_CREATE_ERROR_INTEGER_OVERFLOW_WITH_SUM_OF_VALUE_AND_FEE,
+ "Integer overflow with sum of value and fee");
+ return -XCHANGE_CREATE_ERROR_INTEGER_OVERFLOW_WITH_SUM_OF_VALUE_AND_FEE;
}
case XCHANGE_CREATE_ERROR_NOT_ENOUGH_CASH_FOR_FEE_IN_SPECIFIED_WALLET: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "%s\nNot enough cash for fee in specified wallet", l_sign_str);
- return -23;
+ dap_json_rpc_error_add(*a_json_arr_reply, XCHANGE_CREATE_ERROR_NOT_ENOUGH_CASH_FOR_FEE_IN_SPECIFIED_WALLET,
+ "%s\nNot enough cash for fee in specified wallet", l_sign_str);
+ return -XCHANGE_CREATE_ERROR_NOT_ENOUGH_CASH_FOR_FEE_IN_SPECIFIED_WALLET;
}
case XCHANGE_CREATE_ERROR_NOT_ENOUGH_CASH_IN_SPECIFIED_WALLET: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "%s\nNot enough cash in specified wallet", l_sign_str);
- return -12;
+ dap_json_rpc_error_add(*a_json_arr_reply, XCHANGE_CREATE_ERROR_NOT_ENOUGH_CASH_IN_SPECIFIED_WALLET,
+ "%s\nNot enough cash in specified wallet", l_sign_str);
+ return -XCHANGE_CREATE_ERROR_NOT_ENOUGH_CASH_IN_SPECIFIED_WALLET;
}
case XCHANGE_CREATE_ERROR_MEMORY_ALLOCATED: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Out of memory");
- return -1;
+ dap_json_rpc_error_add(*a_json_arr_reply, XCHANGE_CREATE_ERROR_MEMORY_ALLOCATED,
+ "Out of memory");
+ return -XCHANGE_CREATE_ERROR_MEMORY_ALLOCATED;
}
case XCHANGE_CREATE_ERROR_CAN_NOT_COMPOSE_THE_CONDITIONAL_TRANSACTION: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "%s\nCan't compose the conditional transaction", l_sign_str);
- return -14;
+ dap_json_rpc_error_add(*a_json_arr_reply, XCHANGE_CREATE_ERROR_CAN_NOT_COMPOSE_THE_CONDITIONAL_TRANSACTION,
+ "%s\nCan't compose the conditional transaction", l_sign_str);
+ return -XCHANGE_CREATE_ERROR_CAN_NOT_COMPOSE_THE_CONDITIONAL_TRANSACTION;
}
case XCHANGE_CREATE_ERROR_CAN_NOT_PUT_TRANSACTION_TO_MEMPOOL: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "%s\nCan't compose the conditional transaction", l_sign_str);
- return -15;
+ dap_json_rpc_error_add(*a_json_arr_reply, XCHANGE_CREATE_ERROR_CAN_NOT_PUT_TRANSACTION_TO_MEMPOOL,
+ "%s\nCan't compose the conditional transaction", l_sign_str);
+ return -XCHANGE_CREATE_ERROR_CAN_NOT_PUT_TRANSACTION_TO_MEMPOOL;
}
}
} break;
case CMD_HISTORY:{
+ json_object* l_json_obj_order = NULL;
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-net", &l_net_str);
if (!l_net_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'order history' requires parameter -net");
- return -2;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_REQ_PARAM_NET_ERR,
+ "Command 'order history' requires parameter -net");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_REQ_PARAM_NET_ERR;
}
l_net = dap_chain_net_by_name(l_net_str);
if (!l_net) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Network %s not found", l_net_str);
- return -3;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_NET_NOT_FOUND_ERR,
+ "Network %s not found", l_net_str);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_NET_NOT_FOUND_ERR;
}
const char * l_order_hash_str = NULL;
@@ -1404,45 +1436,46 @@ static int s_cli_srv_xchange_order(int a_argc, char **a_argv, int a_arg_index, v
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-addr", &l_addr_hash_str);
if (!l_order_hash_str && ! l_addr_hash_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'order history' requires parameter -order or -addr" );
- return -12;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_REQ_PARAM_ORDER_ADDR_ERR,
+ "Command 'order history' requires parameter -order or -addr" );
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_REQ_PARAM_ORDER_ADDR_ERR;
}
if(l_addr_hash_str){
dap_chain_addr_t *l_addr = dap_chain_addr_from_str(l_addr_hash_str);
if (!l_addr) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Cannot convert "
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_CAN_NOT_CONVERT_ERR, "Cannot convert "
"string '%s' to binary address.", l_addr_hash_str);
- return -14;
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_CAN_NOT_CONVERT_ERR;
}
if (dap_chain_addr_check_sum(l_addr) != 0 ) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Incorrect address wallet");
- return -15;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_INCORRECT_ADDR_ERR, "Incorrect address wallet");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_INCORRECT_ADDR_ERR;
}
if (l_addr->net_id.uint64 != l_net->pub.id.uint64) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Address %s does not belong to the %s network.",
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_DOES_NOT_BELONG_ERR, "Address %s does not belong to the %s network.",
l_addr_hash_str, l_net->pub.name);
- return -16;
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_DOES_NOT_BELONG_ERR;
}
dap_list_t *l_tx_list = dap_chain_net_get_tx_cond_all_for_addr(l_net,l_addr, c_dap_chain_net_srv_xchange_uid );
- dap_string_t * l_str_reply = dap_string_new("");
dap_hash_fast_t l_hash_curr ={};
bool l_from_wallet_cache = dap_chain_wallet_cache_tx_find(l_addr, NULL, NULL, &l_hash_curr, NULL) == 0 ? true : false;
l_hash_curr = (dap_hash_fast_t){0};
size_t l_total = 0;
- if(l_from_wallet_cache){
- dap_string_t * l_str_reply = dap_string_new("");
+ if(l_from_wallet_cache){
xchange_orders_cache_net_t* l_cache = NULL;
if(s_xchange_cache_state == XCHANGE_CACHE_ENABLED){
l_cache = s_get_xchange_cache_by_net_id(l_net->pub.id);
if(!l_cache){
- dap_cli_server_cmd_set_reply_text(a_str_reply, "No history");
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_DOES_NO_HISTORY_ERR, "No history");
break;
}
}
+ l_json_obj_order = json_object_new_object();
+ json_object* l_json_order_arr = json_object_new_array();
dap_chain_wallet_cache_iter_t *l_iter = dap_chain_wallet_cache_iter_create(*l_addr);
for(dap_chain_datum_tx_t *l_datum_tx = dap_chain_wallet_cache_iter_get(l_iter, DAP_CHAIN_WALLET_CACHE_GET_FIRST);
l_datum_tx; l_datum_tx = dap_chain_wallet_cache_iter_get(l_iter, DAP_CHAIN_WALLET_CACHE_GET_NEXT))
@@ -1455,45 +1488,55 @@ static int s_cli_srv_xchange_order(int a_argc, char **a_argv, int a_arg_index, v
HASH_FIND(hh, l_cache->cache, l_iter->cur_hash, sizeof(dap_hash_fast_t), l_item);
if (!l_item)
continue;
-
- if (s_string_append_tx_cond_info(l_str_reply, l_net, &l_item->seller_addr,
+ json_object* l_json_order = json_object_new_object();
+ if (s_string_append_tx_cond_info_json(l_json_order, l_net, &l_item->seller_addr,
l_item->tx_type == TX_TYPE_EXCHANGE ? &l_item->tx_info.exchange_info.buyer_addr : NULL,
- l_datum_tx, l_iter->cur_hash, TX_STATUS_ALL, true, true, false))
+ l_datum_tx, TX_STATUS_ALL, true, true, false)) {
l_total++;
} else {
- if (s_string_append_tx_cond_info(l_str_reply, l_net, NULL, NULL, l_datum_tx, l_iter->cur_hash, TX_STATUS_ALL, true, true, false))
+ if (s_string_append_tx_cond_info_json(l_json_order, l_net, NULL, NULL, l_datum_tx, TX_STATUS_ALL, true, true, false))
l_total++;
+ }
+ json_object_array_add(l_json_order_arr, l_json_order);
}
}
dap_chain_wallet_cache_iter_delete(l_iter);
-
+ json_object_object_add(l_json_obj_order, "orders", l_json_order_arr);
if(!l_total)
- dap_cli_server_cmd_set_reply_text(a_str_reply, "No history");
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_DOES_NO_HISTORY_ERR, "No history");
else {
- dap_string_append_printf(l_str_reply, "Found %"DAP_UINT64_FORMAT_U, l_total);
- *a_str_reply = dap_string_free(l_str_reply, false);
+ char *l_orders = dap_strdup_printf("Found %"DAP_UINT64_FORMAT_U, l_total);
+ json_object_object_add(l_json_obj_order, "number of orders", json_object_new_string(l_orders));
+ DAP_DELETE(l_orders);
}
+
} else {
dap_list_t *l_tx_list = dap_chain_net_get_tx_cond_all_for_addr(l_net,l_addr, c_dap_chain_net_srv_xchange_uid );
- dap_string_t * l_str_reply = dap_string_new("");
if (l_tx_list){
dap_list_t *l_tx_list_temp = l_tx_list;
- dap_string_append_printf(l_str_reply, "Wallet %s history:\n\n", l_addr_hash_str);
+ l_json_obj_order = json_object_new_object();
+ json_object* l_json_order_arr = json_object_new_array();
+ json_object_object_add(l_json_obj_order, "Wallet %s history:\n\n", json_object_new_string(l_addr_hash_str));
+
while(l_tx_list_temp ){
dap_chain_datum_tx_t * l_tx_cur = (dap_chain_datum_tx_t*) l_tx_list_temp->data;
dap_hash_fast_t l_hash = {};
dap_hash_fast(l_tx_cur, dap_chain_datum_tx_get_size(l_tx_cur), &l_hash);
- if (s_string_append_tx_cond_info(l_str_reply, l_net, NULL, NULL, l_tx_cur, &l_hash, TX_STATUS_ALL, true, true, false))
+ json_object* l_json_order = json_object_new_object();
+ if (s_string_append_tx_cond_info_json(l_json_order, l_net, NULL, NULL, l_tx_cur, TX_STATUS_ALL, true, true, false))
l_total++;
l_tx_list_temp = l_tx_list_temp->next;
+ json_object_array_add(l_json_order_arr, l_json_order);
}
+ json_object_object_add(l_json_obj_order, "orders", l_json_order_arr);
dap_list_free(l_tx_list);
- dap_string_append_printf(l_str_reply, "Found %"DAP_UINT64_FORMAT_U, l_total);
- *a_str_reply = dap_string_free(l_str_reply, false);
+ char *l_orders = dap_strdup_printf("Found %"DAP_UINT64_FORMAT_U, l_total);
+ json_object_object_add(l_json_obj_order, "number of orders", json_object_new_string(l_orders));
+ DAP_DELETE(l_orders);
}else{
- dap_cli_server_cmd_set_reply_text(a_str_reply, "No history");
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_DOES_NO_HISTORY_ERR, "No history");
}
}
DAP_DELETE(l_addr);
@@ -1503,51 +1546,58 @@ static int s_cli_srv_xchange_order(int a_argc, char **a_argv, int a_arg_index, v
if(l_order_hash_str){
dap_hash_fast_t l_order_tx_hash = {};
dap_chain_hash_fast_from_str(l_order_hash_str, &l_order_tx_hash);
+ l_json_obj_order = json_object_new_object();
if(s_xchange_cache_state == XCHANGE_CACHE_DISABLED){
dap_chain_datum_tx_t * l_tx = dap_chain_net_get_tx_by_hash(l_net, &l_order_tx_hash, TX_SEARCH_TYPE_NET);
if( l_tx){
xchange_tx_type_t l_tx_type = dap_chain_net_srv_xchange_tx_get_type(l_net->pub.ledger, l_tx, NULL, NULL, NULL);
char *l_tx_hash = dap_chain_hash_fast_to_str_new(&l_order_tx_hash);
if(l_tx_type != TX_TYPE_ORDER){
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Datum with hash %s is not order. Check hash.", l_tx_hash);
+ json_object_object_add(l_json_obj_order, "datum status", json_object_new_string("is not order"));
+ json_object_object_add(l_json_obj_order, "datum hash", json_object_new_string(l_tx_hash));
} else {
dap_chain_net_srv_xchange_order_status_t l_rc = s_tx_check_for_open_close(l_net,l_tx);
if(l_rc == XCHANGE_ORDER_STATUS_UNKNOWN){
- dap_cli_server_cmd_set_reply_text(a_str_reply, "WRONG TX %s", l_tx_hash);
+ json_object_object_add(l_json_obj_order, "WRONG TX", json_object_new_string(l_tx_hash));
}else{
- dap_string_t * l_str_reply = dap_string_new("");
- dap_string_append_printf(l_str_reply, "Order %s history:\n\n", l_order_hash_str);
+ json_object_object_add(l_json_obj_order, "history for order", json_object_new_string(l_order_hash_str));
dap_list_t *l_tx_list = dap_chain_net_get_tx_cond_chain(l_net, &l_order_tx_hash, c_dap_chain_net_srv_xchange_uid );
dap_list_t *l_tx_list_temp = l_tx_list;
+ json_object* l_json_order_arr = json_object_new_array();
while(l_tx_list_temp ){
+ json_object* l_json_order = json_object_new_object();
dap_chain_datum_tx_t * l_tx_cur = (dap_chain_datum_tx_t*) l_tx_list_temp->data;
dap_hash_fast_t l_hash = {};
dap_hash_fast(l_tx_cur, dap_chain_datum_tx_get_size(l_tx_cur), &l_hash);
- s_string_append_tx_cond_info(l_str_reply, l_net, NULL, NULL, l_tx_cur, &l_hash, TX_STATUS_ALL, true, true, false);
+ s_string_append_tx_cond_info_json(l_json_order, l_net, NULL, NULL, l_tx_cur, TX_STATUS_ALL, true, true, false);
l_tx_list_temp = l_tx_list_temp->next;
+ json_object_array_add(l_json_order_arr, l_json_order);
}
dap_list_free(l_tx_list);
- *a_str_reply = dap_string_free(l_str_reply, false);
+ json_object_object_add(l_json_obj_order, "orders", l_json_order_arr);
}
}
}else
- dap_cli_server_cmd_set_reply_text(a_str_reply, "No history");
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_DOES_NO_HISTORY_ERR, "No history");
} else {
- dap_string_t * l_str_reply = dap_string_new("");
+
xchange_orders_cache_net_t* l_cache = NULL;
dap_list_t *l_tx_cache_list = NULL;
l_cache = s_get_xchange_cache_by_net_id(l_net->pub.id);
xchange_tx_cache_t* l_item = NULL;
- dap_hash_fast_t l_cur_hash = l_order_tx_hash;
+ dap_hash_fast_t l_cur_hash = l_order_tx_hash;
HASH_FIND(hh, l_cache->cache, &l_cur_hash, sizeof(dap_hash_fast_t), l_item);
if (!l_item){
- dap_cli_server_cmd_set_reply_text(a_str_reply, "No history");
- return -18;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_DOES_NO_HISTORY_ERR, "No history");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_DOES_NO_HISTORY_ERR;
}
+ json_object* l_json_order_arr = json_object_new_array();
while(l_item){
- s_string_append_tx_cond_info(l_str_reply, l_net, &l_item->seller_addr,
+ json_object* l_json_order = json_object_new_object();
+ s_string_append_tx_cond_info_json(l_json_order, l_net, &l_item->seller_addr,
l_item->tx_type == TX_TYPE_EXCHANGE ? &l_item->tx_info.exchange_info.buyer_addr : NULL,
- l_item->tx, &l_item->hash, TX_STATUS_ALL, true, true, false);
+ l_item->tx, TX_STATUS_ALL, true, true, false);
+ json_object_array_add(l_json_order_arr, l_json_order);
switch(l_item->tx_type){
case TX_TYPE_ORDER:{
l_cur_hash = l_item->tx_info.order_info.next_hash;
@@ -1564,9 +1614,10 @@ static int s_cli_srv_xchange_order(int a_argc, char **a_argv, int a_arg_index, v
break;
HASH_FIND(hh, l_cache->cache, &l_cur_hash, sizeof(dap_hash_fast_t), l_item);
}
- *a_str_reply = dap_string_free(l_str_reply, false);
+ json_object_object_add(l_json_obj_order, "orders", l_json_order_arr);
}
}
+ json_object_array_add(*a_json_arr_reply, l_json_obj_order);
} break;
case CMD_REMOVE:
@@ -1575,68 +1626,77 @@ static int s_cli_srv_xchange_order(int a_argc, char **a_argv, int a_arg_index, v
const char * l_fee_str = NULL;
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-net", &l_net_str);
if (!l_net_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'order %s' requires parameter -net",
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_REQ_PARAM_NET_ERR, "Command 'order %s' requires parameter -net",
l_cmd_num == CMD_REMOVE ? "remove" : "update");
- return -2;
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_REQ_PARAM_NET_ERR;
}
dap_chain_net_t *l_net = dap_chain_net_by_name(l_net_str);
if (!l_net) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Network %s not found", l_net_str);
- return -3;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_NET_NOT_FOUND_ERR,
+ "Network %s not found", l_net_str);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_NET_NOT_FOUND_ERR;
}
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-w", &l_wallet_str);
if (!l_wallet_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'order %s' requires parameter -w",
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_REQ_PARAM_W_ERR,
+ "Command 'order %s' requires parameter -w",
l_cmd_num == CMD_REMOVE ? "remove" : "update");
- return -10;
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_REQ_PARAM_W_ERR;
}
dap_chain_wallet_t *l_wallet = dap_chain_wallet_open(l_wallet_str, dap_chain_wallet_get_path(g_config), NULL);
if (!l_wallet) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Specified wallet not found");
- return -11;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_WALLET_NOT_FOUND_ERR,
+ "Specified wallet not found");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_WALLET_NOT_FOUND_ERR;
}
const char* l_sign_str = dap_chain_wallet_check_sign(l_wallet);
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-order", &l_order_hash_str);
if (!l_order_hash_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'order %s' requires parameter -order",
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_REQ_PARAM_ORDER_ADDR_ERR,
+ "Command 'order %s' requires parameter -order",
l_cmd_num == CMD_REMOVE ? "remove" : "update");
- return -12;
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_REQ_PARAM_ORDER_ADDR_ERR;
}
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-fee", &l_fee_str);
if (!l_fee_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'order %s' requires parameter -fee",
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_REQ_PARAM_FEE_ERR,
+ "Command 'order %s' requires parameter -fee",
l_cmd_num == CMD_REMOVE ? "remove" : "update");
- return -12;
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_REQ_PARAM_FEE_ERR;
}
uint256_t l_fee = dap_chain_balance_scan(l_fee_str);
dap_hash_fast_t l_tx_hash = {};
dap_chain_hash_fast_from_str(l_order_hash_str, &l_tx_hash);
char *l_tx_hash_ret = NULL;
int l_ret_code = dap_chain_net_srv_xchange_remove(l_net, &l_tx_hash, l_fee, l_wallet, &l_tx_hash_ret);
+ json_object* json_obj_order = NULL;
dap_chain_wallet_close(l_wallet);
switch (l_ret_code) {
case XCHANGE_REMOVE_ERROR_OK:
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Order successfully removed. Created inactivate tx with hash %s", l_tx_hash_ret);
+ json_obj_order = json_object_new_object();
+ json_object_object_add(json_obj_order, "status", json_object_new_string("Order successfully removed"));
+ json_object_object_add(json_obj_order, "Created inactivate tx with hash", json_object_new_string(l_tx_hash_ret));
+ json_object_array_add(*a_json_arr_reply, json_obj_order);
DAP_DELETE(l_tx_hash_ret);
break;
case XCHANGE_REMOVE_ERROR_CAN_NOT_FIND_TX:
- dap_cli_server_cmd_set_reply_text(a_str_reply, "%s\nSpecified order not found", l_sign_str);
+ dap_json_rpc_error_add(*a_json_arr_reply, XCHANGE_REMOVE_ERROR_CAN_NOT_FIND_TX, "%s\nSpecified order not found", l_sign_str);
break;
case XCHANGE_REMOVE_ERROR_CAN_NOT_CREATE_PRICE:
- dap_cli_server_cmd_set_reply_text(a_str_reply, "%s\nCan't create price object from order", l_sign_str);
+ dap_json_rpc_error_add(*a_json_arr_reply, XCHANGE_REMOVE_ERROR_CAN_NOT_CREATE_PRICE, "%s\nCan't create price object from order", l_sign_str);
break;
case XCHANGE_REMOVE_ERROR_FEE_IS_ZERO:
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Can't get fee value.");
+ dap_json_rpc_error_add(*a_json_arr_reply, XCHANGE_REMOVE_ERROR_FEE_IS_ZERO, "Can't get fee value.");
break;
case XCHANGE_REMOVE_ERROR_CAN_NOT_INVALIDATE_TX: {
dap_chain_datum_tx_t *l_cond_tx = dap_ledger_tx_find_by_hash(l_net->pub.ledger, &l_tx_hash);
dap_chain_net_srv_xchange_price_t *l_price = s_xchange_price_from_order(l_net, l_cond_tx, &l_tx_hash, &l_fee, false);
const char *l_final_tx_hash_str = dap_chain_hash_fast_to_str_static(&l_price->tx_hash);
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Can't create invalidate transaction from: %s\n", l_final_tx_hash_str);
+ dap_json_rpc_error_add(*a_json_arr_reply, XCHANGE_REMOVE_ERROR_CAN_NOT_INVALIDATE_TX, "Can't create invalidate transaction from: %s\n", l_final_tx_hash_str);
DAP_DELETE(l_price);
} break;
default:
- dap_cli_server_cmd_set_reply_text(a_str_reply, "An error occurred with an unknown code: %d.", l_ret_code);
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_UNKNOWN_ERR, "An error occurred with an unknown code: %d.", l_ret_code);
break;
}
return l_ret_code;
@@ -1645,19 +1705,22 @@ static int s_cli_srv_xchange_order(int a_argc, char **a_argv, int a_arg_index, v
case CMD_STATUS: {
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-net", &l_net_str);
if (!l_net_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'order status' requires parameter -net");
- return -2;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_REQ_PARAM_NET_ERR,
+ "Command 'order status' requires parameter -net");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_REQ_PARAM_NET_ERR;
}
l_net = dap_chain_net_by_name(l_net_str);
if (!l_net) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Network %s not found", l_net_str);
- return -3;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_NET_NOT_FOUND_ERR,
+ "Network %s not found", l_net_str);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_NET_NOT_FOUND_ERR;
}
const char * l_order_hash_str = NULL;
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-order", &l_order_hash_str);
if (!l_order_hash_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'order history' requires parameter -order or -addr" );
- return -12;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_REQ_PARAM_ORDER_ADDR_ERR,
+ "Command 'order status' requires parameter -order or -addr" );
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_REQ_PARAM_ORDER_ADDR_ERR;
}
dap_hash_fast_t l_order_tx_hash = {};
dap_chain_hash_fast_from_str(l_order_hash_str, &l_order_tx_hash);
@@ -1681,8 +1744,9 @@ static int s_cli_srv_xchange_order(int a_argc, char **a_argv, int a_arg_index, v
HASH_FIND(hh, l_cache->cache, &l_order_tx_hash, sizeof(dap_hash_fast_t), l_item);
l_tx = l_item ? l_item->tx : NULL;
if (!l_tx){
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Can't find order %s", l_order_hash_str);
- return -18;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_CANT_FIND_ORDER_ERR,
+ "Can't find order %s", l_order_hash_str);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_CANT_FIND_ORDER_ERR;
}
switch (l_item->tx_info.order_info.order_status)
@@ -1717,8 +1781,9 @@ static int s_cli_srv_xchange_order(int a_argc, char **a_argv, int a_arg_index, v
} else {
l_tx = dap_ledger_tx_find_by_hash(l_net->pub.ledger, &l_order_tx_hash);
if (!l_tx){
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Can't find order %s", l_order_hash_str);
- return -18;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_CANT_FIND_ORDER_ERR,
+ "Can't find order %s", l_order_hash_str);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_CANT_FIND_ORDER_ERR;
}
// Find SRV_XCHANGE in_cond item
@@ -1730,37 +1795,42 @@ static int s_cli_srv_xchange_order(int a_argc, char **a_argv, int a_arg_index, v
dap_chain_tx_out_cond_t *l_out_prev_cond_item = l_prev_tx ? dap_chain_datum_tx_out_cond_get(l_prev_tx, DAP_CHAIN_TX_OUT_COND_SUBTYPE_SRV_XCHANGE,
&l_prev_cond_idx) : NULL;
if(l_out_prev_cond_item){
- dap_cli_server_cmd_set_reply_text(a_str_reply, "It's not an order");
- return -18;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_ITS_NOT_ORDER_ERR,
+ "It's not an order");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_ITS_NOT_ORDER_ERR;
}
dap_chain_tx_out_cond_t *l_out_cond = dap_chain_datum_tx_out_cond_get(l_tx, DAP_CHAIN_TX_OUT_COND_SUBTYPE_SRV_XCHANGE , NULL);
if (!l_out_cond || l_out_cond->header.srv_uid.uint64 != DAP_CHAIN_NET_SRV_XCHANGE_ID){
- dap_cli_server_cmd_set_reply_text(a_str_reply, "It's not an order");
- return -18;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_ITS_NOT_ORDER_ERR,
+ "It's not an order");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_ITS_NOT_ORDER_ERR;
}
// TODO add filters to list (tokens, network, etc.)
dap_chain_net_srv_xchange_price_t *l_price = s_xchange_price_from_order(l_net, l_tx, &l_order_tx_hash, NULL, true);
if( !l_price ){
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Can't get price from order");
- return -18;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_CANT_GET_PRICE_ERR,
+ "Can't get price from order");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_CANT_GET_PRICE_ERR;
}
dap_ledger_t * l_ledger = dap_ledger_by_net_name(l_net->pub.name);
dap_hash_fast_t l_last_tx_hash = dap_ledger_get_final_chain_tx_hash(l_ledger, DAP_CHAIN_TX_OUT_COND_SUBTYPE_SRV_XCHANGE, &l_price->tx_hash, false);
if( dap_hash_fast_is_blank(&l_last_tx_hash) ){
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Can't get last tx cond hash from order");
- return -18;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_CANT_GET_LAST_TX_ERR,
+ "Can't get last tx cond hash from order");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_CANT_GET_LAST_TX_ERR;
}
dap_chain_datum_tx_t * l_last_tx = dap_ledger_tx_find_by_hash(l_ledger, &l_last_tx_hash);
log_it(L_INFO, "Last tx hash %s", dap_hash_fast_to_str_static(&l_last_tx_hash));
if (!l_last_tx){
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Can't find last tx");
- return -18;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_CANT_FIND_LAST_TX_ERR,
+ "Can't find last tx");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_CANT_FIND_LAST_TX_ERR;
}
dap_chain_tx_out_cond_t *l_out_cond_last_tx = dap_chain_datum_tx_out_cond_get(l_last_tx, DAP_CHAIN_TX_OUT_COND_SUBTYPE_SRV_XCHANGE , NULL);
@@ -1799,19 +1869,25 @@ static int s_cli_srv_xchange_order(int a_argc, char **a_argv, int a_arg_index, v
l_proposed_datoshi_str = dap_uint256_uninteger_to_char(l_proposed);
l_cp_rate = dap_chain_balance_coins_print(l_rate);
- dap_cli_server_cmd_set_reply_text(a_str_reply, "orderHash: %s\n ts_created: %s\n Status: %s, proposed: %s(%s) %s, amount: %s (%s) %s, filled: %lu%%, rate (%s/%s): %s, net: %s\n\n"
- "owner addr: %s\n\n", l_order_hash_str,
- l_tmp_buf, l_status_order,
- l_proposed_coins_str ? l_proposed_coins_str : "0.0",
- l_proposed_datoshi_str ? l_proposed_datoshi_str : "0.0",
- l_token_sell,
- l_amount_coins_str ? l_amount_coins_str : "0.0",
- l_amount_datoshi_str ? l_amount_datoshi_str : "0",
- l_token_sell, l_percent_completed,
- l_token_buy, l_token_sell,
- l_cp_rate,
- l_net->pub.name, l_owner_addr ? l_owner_addr : "unknown" );
-
+ json_object* json_obj_order = json_object_new_object();
+
+ json_object_object_add(json_obj_order, "orderHash", json_object_new_string(l_order_hash_str));
+ json_object_object_add(json_obj_order, "ts_created", json_object_new_string(l_tmp_buf));
+ json_object_object_add(json_obj_order, "status", json_object_new_string(l_status_order));
+ json_object_object_add(json_obj_order, "amount coins", l_amount_coins_str ? json_object_new_string(l_amount_coins_str)
+ : json_object_new_string("0.0"));
+ json_object_object_add(json_obj_order, "amount datoshi", l_amount_datoshi_str ? json_object_new_string(l_amount_datoshi_str)
+ : json_object_new_string("0"));
+ json_object_object_add(json_obj_order, "token", json_object_new_string(l_token_sell));
+ char *l_filled = dap_strdup_printf("%lu%%", l_percent_completed);
+ json_object_object_add(json_obj_order, "filled", json_object_new_string(l_filled));
+ DAP_DELETE(l_filled);
+ json_object_object_add(json_obj_order, "token buy", json_object_new_string(l_token_buy));
+ json_object_object_add(json_obj_order, "token sell", json_object_new_string(l_token_sell));
+ json_object_object_add(json_obj_order, "rate", json_object_new_string(l_cp_rate));
+ json_object_object_add(json_obj_order, "net", json_object_new_string(l_net->pub.name));
+ json_object_object_add(json_obj_order, "owner addr", json_object_new_string(l_owner_addr ? l_owner_addr : "unknown"));
+ json_object_array_add(*a_json_arr_reply, json_obj_order);
DAP_DEL_Z(l_cp_rate);
DAP_DEL_Z(l_amount_coins_str);
@@ -1821,8 +1897,9 @@ static int s_cli_srv_xchange_order(int a_argc, char **a_argv, int a_arg_index, v
} break;
default: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Subcommand %s not recognized", a_argv[a_arg_index]);
- return -4;
+ dap_json_rpc_error_add(*a_json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_SUB_NOT_FOUND_ERR,
+ "Subcommand %s not recognized", a_argv[a_arg_index]);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_SUB_NOT_FOUND_ERR;
}
}
return 0;
@@ -2163,15 +2240,238 @@ static bool s_string_append_tx_cond_info( dap_string_t * a_reply_str, dap_chain
return true;
}
+/**
+ * @brief Append tx info to the reply string
+ * @param a_json_out
+ * @param a_net
+ * @param a_tx
+ */
+static bool s_string_append_tx_cond_info_json( json_object * a_json_out,
+ dap_chain_net_t * a_net,
+ dap_chain_addr_t *a_owner_addr,
+ dap_chain_addr_t *a_buyer_addr,
+ dap_chain_datum_tx_t * a_tx,
+ tx_opt_status_t a_filter_by_status,
+ bool a_print_prev_hash, bool a_print_status, bool a_print_ts)
+{
+ size_t l_tx_size = dap_chain_datum_tx_get_size(a_tx);
+
+ dap_hash_fast_t l_tx_hash = {0};
+
+ dap_hash_fast(a_tx, l_tx_size, &l_tx_hash);
+ const char *l_tx_hash_str = dap_chain_hash_fast_to_str_static(&l_tx_hash);
+
+ // Get input token ticker
+ const char * l_tx_input_ticker = dap_ledger_tx_get_token_ticker_by_hash(
+ a_net->pub.ledger, &l_tx_hash);
+ if(!l_tx_input_ticker){
+ log_it(L_WARNING, "Can't get ticker from tx");
+ return false;
+ }
+ dap_chain_tx_out_cond_t *l_out_prev_cond_item = NULL;
+ dap_chain_tx_out_cond_t *l_out_cond_item = NULL;
+ int l_cond_idx = 0;
+
+ xchange_tx_type_t l_tx_type = dap_chain_net_srv_xchange_tx_get_type(a_net->pub.ledger, a_tx, &l_out_cond_item, &l_cond_idx, &l_out_prev_cond_item);
+
+ bool l_is_closed = dap_ledger_tx_hash_is_used_out_item(a_net->pub.ledger, &l_tx_hash, l_cond_idx, NULL);
+ if ((a_filter_by_status == TX_STATUS_ACTIVE && l_is_closed) || (a_filter_by_status == TX_STATUS_INACTIVE && !l_is_closed)
+ || (a_filter_by_status == TX_STATUS_ACTIVE && l_tx_type == TX_TYPE_INVALIDATE))
+ return false;
+
+ if(l_out_prev_cond_item && l_out_prev_cond_item->header.subtype != DAP_CHAIN_TX_OUT_COND_SUBTYPE_SRV_XCHANGE)
+ return false;
-static int s_cli_srv_xchange_tx_list_addr(dap_chain_net_t *a_net, dap_time_t a_after, dap_time_t a_before,
- dap_chain_addr_t *a_addr, int a_opt_status, void **a_str_reply)
+ switch(l_tx_type){
+ case TX_TYPE_ORDER:{
+ if (!l_out_cond_item) {
+ log_it(L_ERROR, "Can't find conditional output");
+ return false;
+ }
+ char *l_rate_str = dap_chain_balance_coins_print(l_out_cond_item->subtype.srv_xchange.rate);
+ const char *l_amount_str, *l_amount_datoshi_str = dap_uint256_to_char(l_out_cond_item->header.value, &l_amount_str);
+
+ json_object_object_add(a_json_out, "hash", json_object_new_string(l_tx_hash_str));
+ if(a_print_ts){
+ char l_tmp_buf[DAP_TIME_STR_SIZE];
+ dap_time_to_str_rfc822(l_tmp_buf, DAP_TIME_STR_SIZE, a_tx->header.ts_created);
+ json_object_object_add(a_json_out, "ts_created", json_object_new_string(l_tmp_buf));
+ }
+ if( a_print_status)
+ json_object_object_add(a_json_out, "status", l_is_closed ? json_object_new_string("inactive")
+ : json_object_new_string("active"));
+ json_object_object_add(a_json_out, "proposed price", json_object_new_string(l_amount_str));
+ json_object_object_add(a_json_out, "proposed datoshi", json_object_new_string(l_amount_datoshi_str));
+ json_object_object_add(a_json_out, "ticker", json_object_new_string(l_tx_input_ticker));
+ json_object_object_add(a_json_out, "buy token", json_object_new_string(l_out_cond_item->subtype.srv_xchange.buy_token));
+ json_object_object_add(a_json_out, "rate", json_object_new_string(l_rate_str));
+ json_object_object_add(a_json_out, "net", json_object_new_string(a_net->pub.name));
+ dap_chain_addr_t l_owner_addr = {};
+ if (!a_owner_addr){
+ l_owner_addr = l_out_cond_item ? l_out_cond_item->subtype.srv_xchange.seller_addr : (l_out_prev_cond_item ? l_out_prev_cond_item->subtype.srv_xchange.seller_addr : (dap_chain_addr_t){0});
+ } else {
+ l_owner_addr = *a_owner_addr;
+ }
+ json_object_object_add(a_json_out, "nowner addr", json_object_new_string(dap_chain_addr_to_str_static(&l_owner_addr)));
+ DAP_DELETE(l_rate_str);
+ } break;
+ case TX_TYPE_EXCHANGE:{
+ dap_chain_tx_in_cond_t *l_in_cond
+ = (dap_chain_tx_in_cond_t*)dap_chain_datum_tx_item_get(a_tx, NULL, NULL, TX_ITEM_TYPE_IN_COND , NULL);
+ char l_tx_prev_cond_hash_str[DAP_CHAIN_HASH_FAST_STR_SIZE];
+ dap_hash_fast_to_str(&l_in_cond->header.tx_prev_hash, l_tx_prev_cond_hash_str, sizeof(l_tx_prev_cond_hash_str));
+
+ if (!l_out_prev_cond_item) {
+ log_it(L_ERROR, "Can't find previous transaction");
+ return false;
+ }
+
+ uint256_t l_rate = l_out_cond_item
+ ? l_out_cond_item->subtype.srv_xchange.rate
+ : l_out_prev_cond_item->subtype.srv_xchange.rate,
+ l_value_from = {}, l_value_to = {};
+
+ if (l_out_cond_item)
+ SUBTRACT_256_256(l_out_prev_cond_item->header.value, l_out_cond_item->header.value, &l_value_from);
+ else
+ l_value_from = l_out_prev_cond_item->header.value;
+ MULT_256_COIN(l_value_from, l_rate, &l_value_to);
+
+ char *l_buy_ticker = l_out_cond_item
+ ? l_out_cond_item->subtype.srv_xchange.buy_token
+ : l_out_prev_cond_item->subtype.srv_xchange.buy_token;
+
+ json_object_object_add(a_json_out, "hash", json_object_new_string(l_tx_hash_str));
+ if(a_print_ts){
+ char l_tmp_buf[DAP_TIME_STR_SIZE];
+ dap_time_to_str_rfc822(l_tmp_buf, DAP_TIME_STR_SIZE, a_tx->header.ts_created);
+ json_object_object_add(a_json_out, "ts_created", json_object_new_string(l_tmp_buf));
+ }
+ if(a_print_status)
+ json_object_object_add(a_json_out, "status", l_is_closed ? json_object_new_string("inactive")
+ : json_object_new_string("active"));
+
+ const char *l_value_from_str, *l_value_from_datoshi_str = dap_uint256_to_char(l_value_from, &l_value_from_str);
+ json_object_object_add(a_json_out, "changed", json_object_new_string(l_value_from_str));
+ json_object_object_add(a_json_out, "changed datoshi", json_object_new_string(l_value_from_datoshi_str));
+ json_object_object_add(a_json_out, "ticker", json_object_new_string(l_tx_input_ticker));
+
+ const char *l_value_to_str, *l_value_to_datoshi_str = dap_uint256_to_char(l_value_to, &l_value_to_str);
+
+ json_object_object_add(a_json_out, "for", json_object_new_string(l_value_to_str));
+ json_object_object_add(a_json_out, "for datoshi", json_object_new_string(l_value_to_datoshi_str));
+ json_object_object_add(a_json_out, "ticker", json_object_new_string(l_buy_ticker));
+
+ const char *l_rate_str; dap_uint256_to_char(l_rate, &l_rate_str);
+ json_object_object_add(a_json_out, "rate", json_object_new_string(l_rate_str));
+
+ const char *l_amount_str = NULL,
+ *l_amount_datoshi_str = l_out_cond_item ? dap_uint256_to_char(l_out_cond_item->header.value, &l_amount_str) : "0";
+ json_object_object_add(a_json_out, "remain amount", l_amount_str ? json_object_new_string(l_amount_str)
+ : json_object_new_string("0.0"));
+ json_object_object_add(a_json_out, "remain amount datoshi", json_object_new_string(l_amount_datoshi_str));
+ json_object_object_add(a_json_out, "ticker", json_object_new_string(l_tx_input_ticker));
+ json_object_object_add(a_json_out, "net", json_object_new_string(a_net->pub.name));
+ if (a_print_prev_hash)
+ json_object_object_add(a_json_out, "Prev cond", json_object_new_string(l_tx_prev_cond_hash_str));
+ dap_chain_tx_out_cond_subtype_t l_cond_type = l_out_cond_item ? l_out_cond_item->header.subtype : l_out_prev_cond_item->header.subtype;
+ dap_hash_fast_t l_order_hash = dap_ledger_get_first_chain_tx_hash(a_net->pub.ledger, l_cond_type, &l_tx_hash);
+ if ( dap_hash_fast_is_blank(&l_order_hash) )
+ l_order_hash = l_in_cond->header.tx_prev_hash;
+ char l_order_hash_str[DAP_CHAIN_HASH_FAST_STR_SIZE];
+ dap_hash_fast_to_str(&l_order_hash, l_order_hash_str, sizeof(l_order_hash_str));
+ json_object_object_add(a_json_out, "norder hash", json_object_new_string(l_order_hash_str));
+
+ dap_chain_addr_t l_owner_addr = {};
+ if (!a_owner_addr){
+ l_owner_addr = l_out_cond_item ? l_out_cond_item->subtype.srv_xchange.seller_addr : (l_out_prev_cond_item ? l_out_prev_cond_item->subtype.srv_xchange.seller_addr : (dap_chain_addr_t){0});
+ } else {
+ l_owner_addr = *a_owner_addr;
+ }
+ json_object_object_add(a_json_out, "owner addr", json_object_new_string(dap_chain_addr_to_str_static(&l_owner_addr)));
+
+ dap_chain_addr_t l_buyer_addr = {};
+ if(!a_buyer_addr){
+ dap_chain_tx_sig_t *l_tx_sig = (dap_chain_tx_sig_t *)dap_chain_datum_tx_item_get(a_tx, NULL, NULL, TX_ITEM_TYPE_SIG, NULL);
+ dap_sign_t *l_sign = dap_chain_datum_tx_item_sign_get_sig((dap_chain_tx_sig_t *)l_tx_sig);
+ dap_enc_key_t *l_key_buyer = dap_sign_to_enc_key(l_sign);
+ dap_chain_addr_fill_from_key(&l_buyer_addr, l_key_buyer, a_net->pub.id);
+ dap_enc_key_delete(l_key_buyer);
+ } else
+ l_buyer_addr = *a_buyer_addr;
+ json_object_object_add(a_json_out, "buyer addr", json_object_new_string(dap_chain_addr_to_str_static(&l_buyer_addr)));
+ } break;
+ case TX_TYPE_INVALIDATE:{
+ dap_chain_tx_in_cond_t * l_in_cond = (dap_chain_tx_in_cond_t *)dap_chain_datum_tx_item_get(a_tx, NULL, NULL, TX_ITEM_TYPE_IN_COND , NULL);
+ char l_tx_prev_cond_hash_str[DAP_CHAIN_HASH_FAST_STR_SIZE];
+ dap_hash_fast_to_str(&l_in_cond->header.tx_prev_hash,l_tx_prev_cond_hash_str, sizeof(l_tx_prev_cond_hash_str));
+
+ if (!l_out_prev_cond_item) {
+ log_it(L_ERROR, "Can't find previous transaction");
+ return false;
+ }
+
+ dap_chain_datum_tx_t *l_prev_tx = dap_ledger_tx_find_by_hash(a_net->pub.ledger, &l_in_cond->header.tx_prev_hash);
+ if (!l_prev_tx)
+ return false;
+
+ int l_out_num = l_in_cond->header.tx_out_prev_idx;
+ dap_chain_tx_out_cond_t *l_out_cond = dap_chain_datum_tx_out_cond_get(l_prev_tx, DAP_CHAIN_TX_OUT_COND_SUBTYPE_SRV_XCHANGE, &l_out_num);
+ if (!l_out_cond) {
+ log_it(L_ERROR, "Can't find datum tx");
+ return false;
+ }
+ dap_hash_fast_t l_order_hash = dap_ledger_get_first_chain_tx_hash(a_net->pub.ledger, DAP_CHAIN_TX_OUT_COND_SUBTYPE_SRV_XCHANGE, &l_in_cond->header.tx_prev_hash);
+ if ( dap_hash_fast_is_blank(&l_order_hash) )
+ l_order_hash = l_in_cond->header.tx_prev_hash;
+
+ char *l_value_from_str = dap_chain_balance_coins_print(l_out_prev_cond_item->header.value);
+ char *l_value_from_datoshi_str = dap_chain_balance_datoshi_print(l_out_prev_cond_item->header.value);
+
+ json_object_object_add(a_json_out, "hash", json_object_new_string(l_tx_hash_str));
+ if(a_print_ts){
+ char l_tmp_buf[DAP_TIME_STR_SIZE];
+ dap_time_to_str_rfc822(l_tmp_buf, DAP_TIME_STR_SIZE, a_tx->header.ts_created);
+ json_object_object_add(a_json_out, "ts_created", json_object_new_string(l_tmp_buf));
+ }
+ if (a_print_status)
+ json_object_object_add(a_json_out, "status", json_object_new_string("inactive"));
+
+ char l_order_hash_str[DAP_CHAIN_HASH_FAST_STR_SIZE];
+ dap_hash_fast_to_str(&l_order_hash, l_order_hash_str, sizeof(l_order_hash_str));
+ json_object_object_add(a_json_out, "returned from", json_object_new_string(l_value_from_str));
+ json_object_object_add(a_json_out, "returned datoshi", json_object_new_string(l_value_from_datoshi_str));
+ json_object_object_add(a_json_out, "ticker", json_object_new_string(l_tx_input_ticker));
+ json_object_object_add(a_json_out, "order hash", json_object_new_string(l_order_hash_str));
+ if(a_print_prev_hash)
+ json_object_object_add(a_json_out, "prev cond hash", json_object_new_string(l_tx_prev_cond_hash_str));
+
+ dap_chain_addr_t l_owner_addr = {};
+ if (!a_owner_addr){
+ l_owner_addr = l_out_cond_item ? l_out_cond_item->subtype.srv_xchange.seller_addr : (l_out_prev_cond_item ? l_out_prev_cond_item->subtype.srv_xchange.seller_addr : (dap_chain_addr_t){0});
+ } else {
+ l_owner_addr = *a_owner_addr;
+ }
+ json_object_object_add(a_json_out, "owner addr", json_object_new_string(dap_chain_addr_to_str_static(&l_owner_addr)));
+
+ DAP_DELETE(l_value_from_str);
+ DAP_DELETE(l_value_from_datoshi_str);
+ } break;
+ default: return false;
+ }
+ return true;
+}
+
+
+
+static int s_cli_srv_xchange_tx_list_addr_json(dap_chain_net_t *a_net, dap_time_t a_after, dap_time_t a_before,
+ dap_chain_addr_t *a_addr, int a_opt_status, json_object* json_obj_out)
{
- dap_string_t *l_reply_str;
+ dap_chain_hash_fast_t l_tx_first_hash = {0};
size_t l_tx_total;
- if ( !(l_reply_str = dap_string_new("")) )
- return log_it(L_CRITICAL, "%s", c_error_memory_alloc), -ENOMEM;
+ memset(&l_tx_first_hash, 0, sizeof(dap_chain_hash_fast_t)); /* Initial hash == zero */
+ json_object* json_arr_datum_out = json_object_new_array();
size_t l_tx_count = 0;
dap_hash_fast_t l_hash_curr = {};
@@ -2191,8 +2491,11 @@ static int s_cli_srv_xchange_tx_list_addr(dap_chain_net_t *a_net, dap_time_t a_a
if ( a_before && (l_datum_tx->header.ts_created > a_before) )
continue;
- if (s_string_append_tx_cond_info(l_reply_str, a_net, NULL, NULL, l_datum_tx, &l_hash_curr, a_opt_status, false, true, true))
+ json_object* json_obj_tx = json_object_new_object();
+ if (s_string_append_tx_cond_info_json(json_obj_tx, a_net, NULL, NULL, l_datum_tx, a_opt_status, false, true, false)) {
+ json_object_array_add(json_arr_datum_out, json_obj_tx);
l_tx_count++;
+ }
}
} else {
int l_ret_code = 0;
@@ -2213,14 +2516,19 @@ static int s_cli_srv_xchange_tx_list_addr(dap_chain_net_t *a_net, dap_time_t a_a
if ( a_before && (l_datum_tx->header.ts_created > a_before) )
continue;
- if (s_string_append_tx_cond_info(l_reply_str, a_net, NULL, NULL, l_datum_tx, &l_hash_curr, a_opt_status, false, true, true))
+ json_object* json_obj_tx = json_object_new_object();
+ if (s_string_append_tx_cond_info_json(json_obj_tx, a_net, NULL, NULL, l_datum_tx, a_opt_status, false, true, false)) {
+ json_object_array_add(json_arr_datum_out, json_obj_tx);
l_tx_count++;
+ }
}
dap_chain_wallet_cache_iter_delete(l_iter);
}
- dap_string_append_printf(l_reply_str, "\nFound %"DAP_UINT64_FORMAT_U" transactions", l_tx_count);
- *a_str_reply = dap_string_free(l_reply_str, false); /* Free string descriptor, but keep ASCIZ buffer itself */
+ json_object_object_add(json_obj_out, "transactions", json_arr_datum_out);
+ char *l_transactions = dap_strdup_printf("\nFound %"DAP_UINT64_FORMAT_U" transactions", l_tx_count);
+ json_object_object_add(json_obj_out, "number of transactions", json_object_new_string(l_transactions));
+ DAP_DELETE(l_transactions); /* Free string descriptor, but keep ASCIZ buffer itself */
return 0;
}
@@ -2239,6 +2547,8 @@ void s_tx_is_order_check(UNUSED_ARG dap_chain_net_t* a_net, dap_chain_datum_tx_t
static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
{
+ json_object **json_arr_reply = (json_object **)a_str_reply;
+
enum {CMD_NONE = 0, CMD_ORDER, CMD_ORDERS, CMD_PURCHASE, CMD_TX_LIST, CMD_TOKEN_PAIR };
int l_arg_index = 1, l_cmd_num = CMD_NONE;
@@ -2260,23 +2570,24 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
switch (l_cmd_num) {
- case CMD_ORDER:
- return s_cli_srv_xchange_order(a_argc, a_argv, l_arg_index + 1, a_str_reply);
+ case CMD_ORDER:{
+ int res = s_cli_srv_xchange_order(a_argc, a_argv, l_arg_index + 1, json_arr_reply);
+ return res;
+ }
case CMD_ORDERS: {
const char *l_net_str = NULL;
const char *l_status_str = NULL;
l_arg_index++;
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-net", &l_net_str);
if (!l_net_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'orders' requires parameter -net");
- return -2;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_REQ_PARAM_NET_ERR, "Command 'orders' requires parameter -net");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_REQ_PARAM_NET_ERR;
}
dap_chain_net_t *l_net = dap_chain_net_by_name(l_net_str);
if (!l_net) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Network %s not found", l_net_str);
- return -3;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_NET_NOT_FOUND_ERR, "Network %s not found", l_net_str);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_NET_NOT_FOUND_ERR;
}
- dap_string_t *l_reply_str = dap_string_new("");
dap_list_t *l_list = NULL;
if (s_xchange_cache_state == XCHANGE_CACHE_ENABLED){
xchange_orders_cache_net_t* l_cache = NULL;
@@ -2309,8 +2620,8 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
else if ( dap_strcmp (l_status_str, "all") == 0 )
l_opt_status = 0;
else {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Unrecognized '-status %s'", l_status_str);
- return -3;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_UNREC_STATUS_ERR, "Unrecognized '-status %s'", l_status_str);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_UNREC_STATUS_ERR;
}
}
@@ -2320,8 +2631,9 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
if(l_token_from_str){
dap_chain_datum_token_t * l_token_from_datum = dap_ledger_token_ticker_check( l_net->pub.ledger, l_token_from_str);
if(!l_token_from_datum){
- dap_cli_server_cmd_set_reply_text(a_str_reply,"Can't find \"%s\" token in network \"%s\" for argument '-token_from' ", l_token_from_str, l_net->pub.name);
- return -6;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CANT_FIND_TOKEN_FROM_ERR,
+ "Can't find \"%s\" token in network \"%s\" for argument '-token_from' ", l_token_from_str, l_net->pub.name);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CANT_FIND_TOKEN_FROM_ERR;
}
}
@@ -2335,8 +2647,9 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
if(l_token_to_str){
dap_chain_datum_token_t * l_token_to_datum = dap_ledger_token_ticker_check( l_net->pub.ledger, l_token_to_str);
if(!l_token_to_datum){
- dap_cli_server_cmd_set_reply_text(a_str_reply,"Can't find \"%s\" token in network \"%s\" for argument '-token_to' ", l_token_to_str, l_net->pub.name);
- return -6;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CANT_FIND_TOKEN_TO_ERR,
+ "Can't find \"%s\" token in network \"%s\" for argument '-token_to' ", l_token_to_str, l_net->pub.name);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CANT_FIND_TOKEN_TO_ERR;
}
}
@@ -2349,18 +2662,9 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
size_t l_offset = l_offset_str ? strtoul(l_offset_str, NULL, 10) : 0;
size_t l_arr_start = 0;
size_t l_arr_end = dap_list_length(l_list);
- size_t l_total_orders = l_arr_end;
- if (l_offset > 0) {
- l_arr_start = l_offset;
- dap_string_append_printf(l_reply_str, "offset: %lu\n", l_arr_start);
- }
- if (l_limit) {
- dap_string_append_printf(l_reply_str, "limit: %lu\n", l_limit);
- l_arr_end = l_arr_start + l_limit;
- if (l_arr_end > dap_list_length(l_list)) {
- l_arr_end = dap_list_length(l_list);
- }
- }
+ json_object* json_obj_order = json_object_new_object();
+ json_object* json_arr_orders_out = json_object_new_array();
+ dap_chain_set_offset_limit_json(json_arr_orders_out, &l_arr_start, &l_arr_end, l_limit, l_offset, dap_list_length(l_list));
size_t i_tmp = 0;
// Print all txs
for (dap_list_t *it = l_list; it; it = it->next) {
@@ -2487,19 +2791,25 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
l_amount_coins_str = dap_uint256_decimal_to_char(l_amount);
l_proposed_coins_str = dap_uint256_decimal_to_char(l_proposed);
l_proposed_datoshi_str = dap_uint256_uninteger_to_char(l_proposed);
-
- dap_string_append_printf(l_reply_str, "orderHash: %s\n ts_created: %s\n Status: %s, proposed: %s(%s) %s, amount: %s (%s) %s, filled: %lu%%, rate (%s/%s): %s, net: %s\n\n"
- "owner addr: %s\n\n", l_tx_hash_str,
- l_tmp_buf, l_status_order_str,
- l_proposed_coins_str ? l_proposed_coins_str : "0.0",
- l_proposed_datoshi_str ? l_proposed_datoshi_str : "0",
- l_sell_token,
- l_amount_coins_str ? l_amount_coins_str : "0.0",
- l_amount_datoshi_str ? l_amount_datoshi_str : "0",
- l_sell_token, l_percent_completed,
- l_buy_token, l_sell_token,
- l_cp_rate,
- l_net->pub.name, l_owner_addr ? l_owner_addr : "unknown");
+
+ json_object* json_obj_orders = json_object_new_object();
+ json_object_object_add(json_obj_orders, "orderHash", json_object_new_string(l_tx_hash_str));
+ json_object_object_add(json_obj_orders, "ts_created", json_object_new_string(l_tmp_buf));
+ json_object_object_add(json_obj_orders, "status", json_object_new_string(l_status_order_str));
+ json_object_object_add(json_obj_orders, "amount coins", l_amount_coins_str ?
+ json_object_new_string(l_amount_coins_str) :
+ json_object_new_string("0.0"));
+ json_object_object_add(json_obj_orders, "amount datoshi", l_amount_datoshi_str ?
+ json_object_new_string(l_amount_datoshi_str) :
+ json_object_new_string("0"));
+ json_object_object_add(json_obj_orders, "token sell", json_object_new_string(l_sell_token));
+ json_object_object_add(json_obj_orders, "filled", json_object_new_uint64(l_percent_completed));
+ json_object_object_add(json_obj_orders, "token buy", json_object_new_string(l_buy_token));
+ json_object_object_add(json_obj_orders, "token sell", json_object_new_string(l_sell_token));
+ json_object_object_add(json_obj_orders, "balance rate", json_object_new_string(l_cp_rate));
+ json_object_object_add(json_obj_orders, "net name", json_object_new_string(l_net->pub.name));
+ json_object_object_add(json_obj_orders, "owner addr", json_object_new_string(l_owner_addr ? l_owner_addr : "unknown"));
+ json_object_array_add(json_arr_orders_out, json_obj_orders);
l_printed_orders_count++;
DAP_DEL_Z(l_cp_rate);
DAP_DEL_Z(l_amount_datoshi_str);
@@ -2507,16 +2817,20 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
DAP_DEL_Z(l_proposed_coins_str);
DAP_DEL_Z(l_proposed_datoshi_str);
}
+ json_object_object_add(json_obj_order, "ORDERS", json_arr_orders_out);
+ json_object_array_add(*json_arr_reply, json_obj_order);
if (s_xchange_cache_state == XCHANGE_CACHE_ENABLED){
dap_list_free(l_list);
} else {
dap_list_free_full(l_list, NULL);
}
- dap_string_append_printf(l_reply_str, "Total %"DAP_UINT64_FORMAT_U" orders.\n\r", i_tmp);
- if (!l_reply_str->len) {
- dap_string_append(l_reply_str, "No orders found");
+ char *l_total = dap_strdup_printf("Total %"DAP_UINT64_FORMAT_U" orders.\n\r", i_tmp);
+ json_object_object_add(json_obj_order, "number of transactions", json_object_new_string(l_total));
+ DAP_DELETE(l_total);
+
+ if (!json_object_array_length(json_arr_orders_out)) {
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_UNREC_STATUS_ERR, "No orders found");
}
- *a_str_reply = dap_string_free(l_reply_str, false);
} break;
@@ -2525,39 +2839,42 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
l_arg_index++;
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-net", &l_net_str);
if (!l_net_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'purchase' requires parameter -net");
- return -2;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_REQ_PARAM_NET_ERR, "Command 'purchase' requires parameter -net");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_REQ_PARAM_NET_ERR;
}
dap_chain_net_t *l_net = dap_chain_net_by_name(l_net_str);
if (!l_net) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Network %s not found", l_net_str);
- return -3;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_NET_NOT_FOUND_ERR, "Network %s not found", l_net_str);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_NET_NOT_FOUND_ERR;
}
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-w", &l_wallet_str);
if (!l_wallet_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'purchase' requires parameter -w");
- return -10;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_REQ_PARAM_W_ERR, "Command 'purchase' requires parameter -w");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_REQ_PARAM_W_ERR;
}
dap_chain_wallet_t *l_wallet = dap_chain_wallet_open(l_wallet_str, dap_chain_wallet_get_path(g_config), NULL);
if (!l_wallet) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Specified wallet not found");
- return -11;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_WALLET_NOT_FOUND_ERR, "Specified wallet not found");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_WALLET_NOT_FOUND_ERR;
}
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-order", &l_order_hash_str);
if (!l_order_hash_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'purchase' requires parameter -order");
- return -12;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_REQ_PARAM_ORDER_ERR,
+ "Command 'purchase' requires parameter -order");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_REQ_PARAM_ORDER_ERR;
}
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-value", &l_val_buy_str);
if (!l_val_buy_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'purchase' requires parameter -value");
- return -8;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_REQ_PARAM_VALUE_ERR,
+ "Command 'purchase' requires parameter -value");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_REQ_PARAM_VALUE_ERR;
}
uint256_t l_datoshi_buy = dap_chain_balance_scan(l_val_buy_str);
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-fee", &l_val_fee_str);
if (!l_val_fee_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'purchase' requires parameter -fee");
- return -8;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_REQ_PARAM_FEE_ERR,
+ "Command 'purchase' requires parameter -fee");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_REQ_PARAM_FEE_ERR;
}
uint256_t l_datoshi_fee = dap_chain_balance_scan(l_val_fee_str);
dap_hash_fast_t l_tx_hash = {};
@@ -2567,25 +2884,29 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
l_wallet, &l_str_ret_hash);
switch (l_ret_code) {
case XCHANGE_PURCHASE_ERROR_OK: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Exchange transaction has done. tx hash: %s", l_str_ret_hash);
+ json_object* json_obj_orders = json_object_new_object();
+ json_object_object_add(json_obj_orders, "status", json_object_new_string("Exchange transaction has done"));
+ json_object_object_add(json_obj_orders, "hash", json_object_new_string(l_str_ret_hash));
+ json_object_array_add(*json_arr_reply, json_obj_orders);
DAP_DELETE(l_str_ret_hash);
return 0;
}
case XCHANGE_PURCHASE_ERROR_SPECIFIED_ORDER_NOT_FOUND: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Specified order not found");
- return -13;
+ dap_json_rpc_error_add(*json_arr_reply, XCHANGE_PURCHASE_ERROR_SPECIFIED_ORDER_NOT_FOUND,"Specified order not found");
+ return -XCHANGE_PURCHASE_ERROR_SPECIFIED_ORDER_NOT_FOUND;
}
case XCHANGE_PURCHASE_ERROR_CAN_NOT_CREATE_PRICE: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Can't create price from order");
- return -13;
+ dap_json_rpc_error_add(*json_arr_reply, XCHANGE_PURCHASE_ERROR_CAN_NOT_CREATE_PRICE, "Can't create price from order");
+ return -XCHANGE_PURCHASE_ERROR_CAN_NOT_CREATE_PRICE;
}
case XCHANGE_PURCHASE_ERROR_CAN_NOT_CREATE_EXCHANGE_TX: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Exchange transaction error");
- return -13;
+ dap_json_rpc_error_add(*json_arr_reply, XCHANGE_PURCHASE_ERROR_CAN_NOT_CREATE_EXCHANGE_TX, "Exchange transaction error");
+ return -XCHANGE_PURCHASE_ERROR_CAN_NOT_CREATE_EXCHANGE_TX;
}
default: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "An error occurred with an unknown code: %d.", l_ret_code);
- return -14;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_UNKNOWN_ERR,
+ "An error occurred with an unknown code: %d.", l_ret_code);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_UNKNOWN_ERR;
}
}
} break;
@@ -2622,20 +2943,22 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
else if ( dap_strcmp (l_status_str, "all") == 0 )
l_opt_status = TX_STATUS_ALL;
else {
-
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Unrecognized '-status %s'", l_status_str);
- return -3;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_LIST_UNREC_STATUS_ERR,
+ "Unrecognized '-status %s'", l_status_str);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_LIST_UNREC_STATUS_ERR;
}
}
if(!l_net_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'tx_list' requires parameter -net");
- return -3;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_LIST_REQ_PARAM_NET_ERR,
+ "Command 'tx_list' requires parameter -net");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_LIST_REQ_PARAM_NET_ERR;
}
dap_chain_net_t *l_net = dap_chain_net_by_name(l_net_str);
if(!l_net) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Network %s not found", l_net_str);
- return -4;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_LIST_NET_NOT_FOUND_ERR,
+ "Network %s not found", l_net_str);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_LIST_NET_NOT_FOUND_ERR;
}
dap_time_t l_time[2];
@@ -2645,19 +2968,22 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
/* Dispatch request processing to ... */
if ( l_addr_str )
{
- if ( !(l_addr = dap_chain_addr_from_str(l_addr_str)) )
- return dap_cli_server_cmd_set_reply_text(a_str_reply, "Cannot convert -addr '%s' to internal representative", l_addr_str), -EINVAL;
-
- return s_cli_srv_xchange_tx_list_addr (l_net, l_time[0], l_time[1], l_addr, l_opt_status, a_str_reply);
+ if ( !(l_addr = dap_chain_addr_from_str(l_addr_str)) ) {
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_LIST_CAN_NOT_CONVERT_ERR,
+ "Cannot convert -addr '%s' to internal representative", l_addr_str);
+ return -EINVAL;
+ }
+ json_object* json_obj_order = json_object_new_object();
+ s_cli_srv_xchange_tx_list_addr_json(l_net, l_time[0], l_time[1], l_addr, l_opt_status, json_obj_order);
+ json_object_array_add(*json_arr_reply, json_obj_order);
+ return 0;
}
- // Prepare output string
- dap_string_t *l_reply_str = dap_string_new("");
-
// Find transactions using filter function s_filter_tx_list()
if (s_xchange_cache_state == XCHANGE_CACHE_ENABLED){
xchange_orders_cache_net_t* l_cache = NULL;
dap_list_t *l_tx_cache_list = NULL;
+ json_object* json_arr_bl_out = json_object_new_array();
l_cache = s_get_xchange_cache_by_net_id(l_net->pub.id);
xchange_tx_cache_t* l_temp, *l_item;
HASH_ITER(hh, l_cache->cache, l_item, l_temp){
@@ -2666,16 +2992,21 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
if (l_time[1] && l_item->tx->header.ts_created > l_time[1])
break;
-
- if (s_string_append_tx_cond_info(l_reply_str, l_net, &l_item->seller_addr,
+ json_object* json_obj_order = json_object_new_object();
+ if (s_string_append_tx_cond_info_json(json_obj_order, l_net, &l_item->seller_addr,
l_item->tx_type == TX_TYPE_EXCHANGE ? &l_item->tx_info.exchange_info.buyer_addr : NULL,
- l_item->tx, &l_item->hash, l_opt_status, false, true, true))
+ l_item->tx, l_opt_status, false, true, true)) {
+ json_object_array_add(json_arr_bl_out, json_obj_order);
l_show_tx_nr++;
+ }
}
+ json_object* json_obj_xchange = json_object_new_object();
+ json_object_object_add(json_obj_xchange, "orders", json_arr_bl_out);
+ json_object_array_add(*json_arr_reply, json_obj_xchange);
} else {
dap_list_t *l_datum_list0 = dap_chain_datum_list(l_net, NULL, s_filter_tx_list, l_time);
size_t l_datum_num = dap_list_length(l_datum_list0);
-
+ json_object* json_arr_bl_out = json_object_new_array();
if (l_datum_num > 0) {
dap_list_t *l_datum_list = l_datum_list0;
while(l_datum_list) {
@@ -2685,23 +3016,28 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
if (l_time[1] && l_datum_tx->header.ts_created > l_time[1])
break;
-
+ json_object* json_obj_order = json_object_new_object();
dap_hash_fast_t l_hash = {};
dap_hash_fast(l_datum_tx, dap_chain_datum_tx_get_size(l_datum_tx), &l_hash);
- if (s_string_append_tx_cond_info(l_reply_str, l_net, NULL, NULL, l_datum_tx, &l_hash, l_opt_status, false, true, true))
+ if (s_string_append_tx_cond_info_json(json_obj_order, l_net, NULL, NULL, l_datum_tx, l_opt_status, false, true, true)) {
+ json_object_array_add(json_arr_bl_out, json_obj_order);
l_show_tx_nr++;
+ }
l_datum_list = dap_list_next(l_datum_list);
- }
+ }
+ json_object* json_obj_xchange = json_object_new_object();
+ json_object_object_add(json_obj_xchange, "orders", json_arr_bl_out);
+ json_object_array_add(*json_arr_reply, json_obj_xchange);
}
dap_list_free_full(l_datum_list0, NULL);
}
+ json_object* json_obj_orders = json_object_new_object();
if(l_show_tx_nr)
- dap_string_append_printf(l_reply_str, "Found %d transactions", l_show_tx_nr);
+ json_object_object_add(json_obj_orders, "number of transactions", json_object_new_int(l_show_tx_nr));
else
- dap_string_append(l_reply_str, "Transactions not found");
-
- *a_str_reply = dap_string_free(l_reply_str, false);
+ json_object_object_add(json_obj_orders, "number of transactions", json_object_new_string("Transactions not found"));
+ json_object_array_add(*json_arr_reply, json_obj_orders);
} break;
// Token pair control
case CMD_TOKEN_PAIR: {
@@ -2710,13 +3046,15 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
const char *l_net_str = NULL;
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-net", &l_net_str);
if(!l_net_str) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command 'token_pair' requires parameter -net");
- return -3;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_REQ_PARAM_NET_ERR,
+ "Command 'token_pair' requires parameter -net");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_REQ_PARAM_NET_ERR;
}
dap_chain_net_t *l_net = dap_chain_net_by_name(l_net_str);
if(!l_net) {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Network %s not found", l_net_str);
- return -4;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_NET_NOT_FOUND_ERR,
+ "Network %s not found", l_net_str);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_NET_NOT_FOUND_ERR;
}
// Select subcommands
@@ -2729,26 +3067,30 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
const char * l_token_from_str = NULL;
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-token_from", &l_token_from_str);
if(!l_token_from_str){
- dap_cli_server_cmd_set_reply_text(a_str_reply,"No argument '-token_from'");
- return -5;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_TOKEN_FROM_ARG_ERR,
+ "No argument '-token_from'");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_TOKEN_FROM_ARG_ERR;
}
dap_chain_datum_token_t * l_token_from_datum = dap_ledger_token_ticker_check( l_net->pub.ledger, l_token_from_str);
if(!l_token_from_datum){
- dap_cli_server_cmd_set_reply_text(a_str_reply,"Can't find \"%s\" token in network \"%s\" for argument '-token_from' ", l_token_from_str, l_net->pub.name);
- return -6;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_TOKEN_FROM_ERR,
+ "Can't find \"%s\" token in network \"%s\" for argument '-token_from' ", l_token_from_str, l_net->pub.name);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_TOKEN_FROM_ERR;
}
// Check for token_to
const char * l_token_to_str = NULL;
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-token_to", &l_token_to_str);
if(!l_token_to_str){
- dap_cli_server_cmd_set_reply_text(a_str_reply,"No argument '-token_to'");
- return -5;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_TOKEN_TO_ERR,
+ "No argument '-token_to'");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_TOKEN_TO_ERR;
}
dap_chain_datum_token_t * l_token_to_datum = dap_ledger_token_ticker_check( l_net->pub.ledger, l_token_to_str);
if(!l_token_to_datum){
- dap_cli_server_cmd_set_reply_text(a_str_reply,"Can't find \"%s\" token in network \"%s\" for argument '-token_to' ", l_token_to_str, l_net->pub.name);
- return -6;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_CANT_FIND_TOKEN_ERR,
+ "Can't find \"%s\" token in network \"%s\" for argument '-token_to' ", l_token_to_str, l_net->pub.name);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_CANT_FIND_TOKEN_ERR;
}
// Read time_from
@@ -2765,7 +3107,6 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
// Check for price subcommand
if (strcmp(l_price_subcommand,"average") == 0){
- dap_string_t *l_reply_str = dap_string_new("");
dap_list_t *l_list = NULL;
if (s_xchange_cache_state == XCHANGE_CACHE_ENABLED){
@@ -2850,7 +3191,8 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
dap_list_free(l_list);
if (IS_ZERO_256(l_total_rates) || IS_ZERO_256(l_rate) || !l_last_rate_time){
- dap_string_append_printf(l_reply_str,"Can't find orders for specified token pair\n");
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_CANT_FIND_ORDER_ERR,
+ "Can't find orders for specified token pair\n");
} else {
uint256_t l_rate_average = {0};
if (!IS_ZERO_256(l_total_rates_count))
@@ -2859,12 +3201,13 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
char l_tmp_buf[DAP_TIME_STR_SIZE];
dap_time_to_str_rfc822(l_tmp_buf, DAP_TIME_STR_SIZE, l_last_rate_time);
const char *l_rate_average_str; dap_uint256_to_char(l_rate_average, &l_rate_average_str);
- dap_string_append_printf(l_reply_str,"Average rate: %s\n", l_rate_average_str);
+ json_object* json_obj_order = json_object_new_object();
+ json_object_object_add(json_obj_order, "Average rate", json_object_new_string(l_rate_average_str));
const char *l_last_rate_str; dap_uint256_to_char(l_rate, &l_last_rate_str);
- dap_string_append_printf(l_reply_str, "Last rate: %s Last rate time: %s",
- l_last_rate_str, l_tmp_buf);
+ json_object_object_add(json_obj_order, "Last rate", json_object_new_string(l_last_rate_str));
+ json_object_object_add(json_obj_order, "Last rate time", json_object_new_string(l_tmp_buf));
+ json_object_array_add(*json_arr_reply, json_obj_order);
}
- *a_str_reply = dap_string_free(l_reply_str, false);
break;
}else if (strcmp(l_price_subcommand,"history") == 0){
const char *l_limit_str = NULL, *l_offset_str = NULL;
@@ -2875,7 +3218,6 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
uint256_t l_token_from_value = {}, l_token_to_value = {};
- dap_string_t *l_reply_str = dap_string_new("");
dap_list_t *l_list = NULL;
dap_time_t l_time[2];
l_time[0] = l_time_from;
@@ -2902,16 +3244,15 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
}
size_t l_datum_num = dap_list_length(l_list);
- size_t l_arr_start = 0;
- size_t l_arr_end = l_datum_num;
- if (l_offset > 0) {
- l_arr_start = l_offset;
- dap_string_append_printf(l_reply_str, "offset: %lu\n", l_arr_start);
- }
- if (l_limit) {
- l_arr_end = l_arr_start + l_limit;
- dap_string_append_printf(l_reply_str, "limit: %lu\n", l_limit);
+ if (l_datum_num == 0){
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_CANT_FIND_TX_ERR,
+ "Can't find transactions");
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_CANT_FIND_TX_ERR;
}
+ json_object* json_arr_bl_cache_out = json_object_new_array();
+ size_t l_arr_start = 0;
+ size_t l_arr_end = 0;
+ dap_chain_set_offset_limit_json(json_arr_bl_cache_out, &l_arr_start, &l_arr_end, l_limit, l_offset, l_datum_num);
size_t i_tmp = 0;
size_t l_total = 0;
@@ -2982,19 +3323,25 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
if (i_tmp >= l_arr_end)
break;
- i_tmp++;
+ i_tmp++;
- if(s_string_append_tx_cond_info(l_reply_str, l_net, NULL, NULL, l_tx, &l_tx_hash, TX_STATUS_ALL, false, false, true)){
+ json_object* json_obj_out = json_object_new_object();
+ if(s_string_append_tx_cond_info_json(json_obj_out, l_net, NULL, NULL, l_tx, TX_STATUS_ALL, false, false, true)){
l_total++;
SUM_256_256(l_token_to_value, l_token_curr_to_value, &l_token_to_value);
SUM_256_256(l_token_from_value, l_token_curr_from_value, &l_token_from_value);
+ json_object_array_add(json_arr_bl_cache_out, json_obj_out);
}
l_cur = dap_list_next(l_cur);
}
+ json_object_array_add(*json_arr_reply, json_arr_bl_cache_out);
dap_list_free(l_list);
- dap_string_append_printf(l_reply_str, "Found %"DAP_UINT64_FORMAT_U" transactions\n", l_total);
+ json_object* json_obj_order = json_object_new_object();
+ char *l_total_str = dap_strdup_printf("Found %"DAP_UINT64_FORMAT_U" transactions\n", l_total);
+ json_object_object_add(json_obj_order, "number of transactions", json_object_new_string(l_total_str));
+ DAP_DELETE(l_total_str);
const char *l_token_from_value_coins_str = NULL, *l_token_from_value_datoshi_str = NULL,
*l_token_to_value_coins_str = NULL, *l_token_to_value_datoshi_str = NULL;
@@ -3004,21 +3351,26 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
l_token_to_value_datoshi_str = dap_chain_balance_datoshi_print(l_token_to_value);
l_token_to_value_coins_str = dap_chain_balance_coins_print(l_token_to_value);
- dap_string_append_printf(l_reply_str, "Traiding value:\n\t%s (%s) %s\n\t%s (%s) %s\n", l_token_from_value_coins_str, l_token_from_value_datoshi_str, l_token_from_str,
- l_token_to_value_coins_str, l_token_to_value_datoshi_str, l_token_to_str);
+ json_object_object_add(json_obj_order, "trading from coins", json_object_new_string(l_token_from_value_coins_str));
+ json_object_object_add(json_obj_order, "trading from datoshi", json_object_new_string(l_token_from_value_datoshi_str));
+ json_object_object_add(json_obj_order, "trading from token", json_object_new_string(l_token_from_str));
+
+ json_object_object_add(json_obj_order, "trading to coins", json_object_new_string(l_token_to_value_coins_str));
+ json_object_object_add(json_obj_order, "trading to datoshi", json_object_new_string(l_token_to_value_datoshi_str));
+ json_object_object_add(json_obj_order, "trading to token", json_object_new_string(l_token_to_str));
DAP_DEL_Z(l_token_from_value_datoshi_str);
DAP_DEL_Z(l_token_from_value_coins_str);
DAP_DEL_Z(l_token_to_value_datoshi_str);
DAP_DEL_Z(l_token_to_value_coins_str);
- *a_str_reply = dap_string_free(l_reply_str, false);
+ json_object_array_add(*json_arr_reply, json_obj_order);
break;
} else {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Unrecognized subcommand '%s'",
- l_price_subcommand);
- return -38;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_UNKNOWN_ERR,
+ "Unrecognized subcommand '%s'", l_price_subcommand);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_UNKNOWN_ERR;
}
}
@@ -3031,18 +3383,16 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
dap_cli_server_cmd_find_option_val(a_argv, l_arg_index, a_argc, "-offset", &l_offset_str);
size_t l_offset = l_offset_str ? strtoul(l_offset_str, NULL, 10) : 0;
size_t l_limit = l_limit_str ? strtoul(l_limit_str, NULL, 10) : 0;
- dap_string_t *l_reply_str = dap_string_new("");
char ** l_tickers = NULL;
size_t l_tickers_count = 0;
dap_ledger_addr_get_token_ticker_all( l_net->pub.ledger,NULL,&l_tickers,&l_tickers_count);
-
+ json_object* json_obj_out = json_object_new_object();
size_t l_pairs_count = 0;
if(l_tickers){
- size_t l_arr_start = l_offset;
+ size_t l_arr_start = 0;
size_t l_arr_end = 0;
- if (l_limit) {
- l_arr_end = l_arr_start + l_limit - 1;
- }
+ json_object* json_arr_bl_cache_out = json_object_new_array();
+ dap_chain_set_offset_limit_json(json_arr_bl_cache_out, &l_arr_start, &l_arr_end, l_limit, l_offset, l_tickers_count);
size_t i_tmp = 0;
for(size_t i = 0; i< l_tickers_count; i++){
for(size_t j = i+1; j< l_tickers_count; j++){
@@ -3053,12 +3403,16 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
continue;
}
i_tmp++;
- dap_string_append_printf(l_reply_str,"%s:%s ", l_tickers[i], l_tickers[j]);
+ json_object* json_obj_bl = json_object_new_object();
+ json_object_object_add(json_obj_bl, "ticker_1",json_object_new_string(l_tickers[i]));
+ json_object_object_add(json_obj_bl, "ticker_2",json_object_new_string(l_tickers[j]));
+ json_object_array_add(json_arr_bl_cache_out, json_obj_bl);
l_pairs_count++;
}
}
}
+ json_object_object_add(json_obj_out, "TICKERS PAIR", json_arr_bl_cache_out);
// Free tickers array
for(size_t i = 0; i< l_tickers_count; i++){
@@ -3066,20 +3420,25 @@ static int s_cli_srv_xchange(int a_argc, char **a_argv, void **a_str_reply)
}
DAP_DELETE(l_tickers);
}
- dap_string_prepend_printf( l_reply_str,"Tokens count pair: %zd\n", l_pairs_count);
- *a_str_reply = dap_string_free(l_reply_str, false);
+ json_object_object_add(json_obj_out, "pair count", json_object_new_uint64(l_pairs_count));
+ json_object_array_add(*json_arr_reply, json_obj_out);
break;
}
}
// No subcommand selected
- dap_cli_server_cmd_set_reply_text(a_str_reply,"Command 'token pair' requires proper subcommand, please read its manual with command 'help srv_xchange'");
+ json_object* json_obj_out = json_object_new_object();
+ json_object_object_add(json_obj_out, "token pair status", json_object_new_string("Command 'token pair' requires proper subcommand,"
+ "please read its manual with command 'help srv_xchange'"));
+ json_object_array_add(*json_arr_reply, json_obj_out);
} break;
default: {
- dap_cli_server_cmd_set_reply_text(a_str_reply, "Command %s not recognized", a_argv[l_arg_index]);
- return -1;
+ dap_json_rpc_error_add(*json_arr_reply, DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_UNKNOWN_COMMAND_ERR,
+ "Command %s not recognized", a_argv[l_arg_index]);
+ return -DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_UNKNOWN_COMMAND_ERR;
+
}
}
return 0;
diff --git a/modules/service/xchange/include/dap_chain_net_srv_xchange.h b/modules/service/xchange/include/dap_chain_net_srv_xchange.h
index a5d27328816fb75e6867517d24399556c6bed705..0acf602a2703549dd2d13636689db62888f6295f 100644
--- a/modules/service/xchange/include/dap_chain_net_srv_xchange.h
+++ b/modules/service/xchange/include/dap_chain_net_srv_xchange.h
@@ -58,6 +58,76 @@ void dap_chain_net_srv_xchange_deinit();
json_object *dap_chain_net_srv_xchange_print_fee_json(dap_chain_net_t *a_net);
void dap_chain_net_srv_xchange_print_fee(dap_chain_net_t *a_net, dap_string_t *a_string_ret);
+typedef enum s_com_net_srv_xchange_err{
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_OK = 0,
+
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_REQ_PARAM_NET_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_NET_NOT_FOUND_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_UNREC_STATUS_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CANT_FIND_TOKEN_TO_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CANT_FIND_TOKEN_FROM_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_PARAM_TOKEN_SELL_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_PARAM_TOKEN_BUY_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_PARAM_TICKR_NOTF_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_TOKEN_EQUAL_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CRTE_REQ_PARAM_VALUE_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CRTE_REQ_PARAM_RATE_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CRTE_REQ_PARAM_FEE_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CRTE_REQ_PARAM_W_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_CRTE_WALLET_NOT_FOUND_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_REQ_PARAM_NET_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_NET_NOT_FOUND_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_REQ_PARAM_ORDER_ADDR_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_CAN_NOT_CONVERT_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_INCORRECT_ADDR_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_DOES_NOT_BELONG_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_HIST_DOES_NO_HISTORY_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_REQ_PARAM_NET_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_NET_NOT_FOUND_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_REQ_PARAM_W_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_WALLET_NOT_FOUND_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_REQ_PARAM_ORDER_ADDR_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_REQ_PARAM_FEE_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_RMOVE_UNKNOWN_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_REQ_PARAM_NET_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_NET_NOT_FOUND_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_NET_NOT_FOUN_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_REQ_PARAM_ORDER_ADDR_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_CANT_FIND_ORDER_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_ITS_NOT_ORDER_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_CANT_GET_PRICE_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_CANT_GET_LAST_TX_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_STATUS_CANT_FIND_LAST_TX_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_SUB_NOT_FOUND_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_ORDRS_LIST_CAN_NOT_CONVERT_ERR,
+
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_REQ_PARAM_NET_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_NET_NOT_FOUND_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_REQ_PARAM_W_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_WALLET_NOT_FOUND_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_REQ_PARAM_ORDER_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_REQ_PARAM_VALUE_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_REQ_PARAM_FEE_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PURCHASE_UNKNOWN_ERR,
+
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_LIST_UNREC_STATUS_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_LIST_REQ_PARAM_NET_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_LIST_NET_NOT_FOUND_ERR,
+
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_REQ_PARAM_NET_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_NET_NOT_FOUND_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_TOKEN_FROM_ARG_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_TOKEN_FROM_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_TOKEN_TO_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_CANT_FIND_TOKEN_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_CANT_FIND_ORDER_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_CANT_FIND_TX_ERR,
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_PAIR_UNKNOWN_ERR,
+
+ DAP_CHAIN_NODE_CLI_COM_NET_SRV_XCNGE_UNKNOWN_COMMAND_ERR
+
+} s_com_net_srv_xchange_err_t;
+
typedef enum dap_chain_net_srv_xchange_order_status{
XCHANGE_ORDER_STATUS_OPENED = 0,
XCHANGE_ORDER_STATUS_CLOSED,
@@ -84,7 +154,7 @@ typedef enum dap_chain_net_srv_xchange_create_error_list{
XCHANGE_CREATE_ERROR_NOT_ENOUGH_CASH_IN_SPECIFIED_WALLET,
XCHANGE_CREATE_ERROR_MEMORY_ALLOCATED,
XCHANGE_CREATE_ERROR_CAN_NOT_COMPOSE_THE_CONDITIONAL_TRANSACTION,
- XCHANGE_CREATE_ERROR_CAN_NOT_PUT_TRANSACTION_TO_MEMPOOL,
+ XCHANGE_CREATE_ERROR_CAN_NOT_PUT_TRANSACTION_TO_MEMPOOL
} dap_chain_net_srv_xchange_create_error_t;
dap_chain_net_srv_xchange_create_error_t dap_chain_net_srv_xchange_create(dap_chain_net_t *a_net, const char *a_token_buy,
const char *a_token_sell, uint256_t a_datoshi_sell,