jl777
8 years ago
9 changed files with 5136 additions and 2 deletions
@ -0,0 +1,369 @@ |
|||
/******************************************************************************
|
|||
* Copyright © 2014-2017 The SuperNET Developers. * |
|||
* * |
|||
* See the AUTHORS, DEVELOPER-AGREEMENT and LICENSE files at * |
|||
* the top-level directory of this distribution for the individual copyright * |
|||
* holder information and the developer policies on copyright and licensing. * |
|||
* * |
|||
* Unless otherwise agreed in a custom licensing agreement, no part of the * |
|||
* SuperNET software, including this file may be copied, modified, propagated * |
|||
* or distributed except according to the terms contained in the LICENSE file * |
|||
* * |
|||
* Removal or modification of this copyright notice is prohibited. * |
|||
* * |
|||
******************************************************************************/ |
|||
|
|||
// included from basilisk.c
|
|||
// connect DEX to jumblr-core
|
|||
|
|||
/*
|
|||
z_exportkey "zaddr" |
|||
z_exportwallet "filename" |
|||
z_getoperationstatus (["operationid", ... ]) |
|||
z_gettotalbalance ( minconf ) |
|||
z_importkey "zkey" ( rescan ) |
|||
z_importwallet "filename" |
|||
z_listaddresses |
|||
z_sendmany "fromaddress" [{"address":... ,"amount":..., "memo":"<hex>"},...] ( minconf ) ( fee ) |
|||
*/ |
|||
|
|||
#define JUMBLR_INCR 99 |
|||
#define JUMBLR_TXFEE 0.01 |
|||
#define JUMBLR_ADDR "RGhxXpXSSBTBm9EvNsXnTQczthMCxHX91t" |
|||
#define JUMBLR_BTCADDR "18RmTJe9qMech8siuhYfMtHo8RtcN1obC6" |
|||
#define JUMBLR_FEE 0.001 |
|||
#define JUMBLR_DEPOSITPREFIX "deposit " |
|||
|
|||
struct jumblr_item *jumblr_opidfind(struct supernet_info *myinfo,char *opid) |
|||
{ |
|||
struct jumblr_item *ptr; |
|||
HASH_FIND(hh,myinfo->jumblrs,opid,(int32_t)strlen(opid),ptr); |
|||
return(ptr); |
|||
} |
|||
|
|||
struct jumblr_item *jumblr_opidadd(struct supernet_info *myinfo,struct iguana_info *coin,char *opid) |
|||
{ |
|||
struct jumblr_item *ptr; |
|||
if ( (ptr= jumblr_opidfind(myinfo,opid)) == 0 ) |
|||
{ |
|||
ptr = calloc(1,sizeof(*ptr)); |
|||
safecopy(ptr->opid,opid,sizeof(ptr->opid)); |
|||
HASH_ADD_KEYPTR(hh,myinfo->jumblrs,ptr->opid,(int32_t)strlen(ptr->opid),ptr); |
|||
if ( ptr != jumblr_opidfind(myinfo,opid) ) |
|||
printf("jumblr_opidadd.(%s) ERROR, couldnt find after add\n",opid); |
|||
} |
|||
return(ptr); |
|||
} |
|||
|
|||
char *jumblr_zgetnewaddress(struct supernet_info *myinfo,struct iguana_info *coin) |
|||
{ |
|||
return(bitcoind_passthru(coin->symbol,coin->chain->serverport,coin->chain->userpass,"z_getnewaddress","")); |
|||
} |
|||
|
|||
char *jumblr_zlistoperationids(struct supernet_info *myinfo,struct iguana_info *coin) |
|||
{ |
|||
return(bitcoind_passthru(coin->symbol,coin->chain->serverport,coin->chain->userpass,"z_listoperationids","")); |
|||
} |
|||
|
|||
char *jumblr_zgetoperationresult(struct supernet_info *myinfo,struct iguana_info *coin,char *opid) |
|||
{ |
|||
char params[1024]; |
|||
sprintf(params,"[\"%s\"]",opid); |
|||
return(bitcoind_passthru(coin->symbol,coin->chain->serverport,coin->chain->userpass,"z_getoperationresult",params)); |
|||
} |
|||
|
|||
char *jumblr_sendt_to_z(struct supernet_info *myinfo,struct iguana_info *coin,char *taddr,char *zaddr,double amount) |
|||
{ |
|||
char params[1024]; double fee = (amount-3*JUMBLR_TXFEE) * JUMBLR_FEE; |
|||
sprintf(params,"[\"%s\", [{\"%s\":%.8f}, {\"%s\":%.8f}]], 1, %.8f",taddr,zaddr,amount-fee-JUMBLR_TXFEE,JUMBLR_ADDR,fee,JUMBLR_TXFEE); |
|||
return(bitcoind_passthru(coin->symbol,coin->chain->serverport,coin->chain->userpass,"z_sendmany",params)); |
|||
} |
|||
|
|||
char *jumblr_sendz_to_z(struct supernet_info *myinfo,struct iguana_info *coin,char *zaddrS,char *zaddrD,double amount) |
|||
{ |
|||
char params[1024]; double fee = (amount-2*JUMBLR_TXFEE) * JUMBLR_FEE; |
|||
sprintf(params,"[\"%s\", [{\"%s\":%.8f}, {\"%s\":%.8f}], 1, %.8f]",zaddrS,zaddrD,amount-fee-JUMBLR_TXFEE,JUMBLR_ADDR,fee,JUMBLR_TXFEE); |
|||
return(bitcoind_passthru(coin->symbol,coin->chain->serverport,coin->chain->userpass,"z_sendmany",params)); |
|||
} |
|||
|
|||
char *jumblr_sendz_to_t(struct supernet_info *myinfo,struct iguana_info *coin,char *zaddr,char *taddr,double amount) |
|||
{ |
|||
char params[1024]; double fee = (amount-JUMBLR_TXFEE) * JUMBLR_FEE; |
|||
sprintf(params,"[\"%s\", [{\"%s\":%.8f}, {\"%s\":%.8f}], 1, %.8f]",zaddr,taddr,amount-fee-JUMBLR_TXFEE,JUMBLR_ADDR,fee,JUMBLR_TXFEE); |
|||
return(bitcoind_passthru(coin->symbol,coin->chain->serverport,coin->chain->userpass,"z_sendmany",params)); |
|||
} |
|||
|
|||
char *jumblr_zlistreceivedbyaddress(struct supernet_info *myinfo,struct iguana_info *coin,char *addr) |
|||
{ |
|||
char params[1024]; |
|||
sprintf(params,"[\"%s\", 1]",addr); |
|||
return(bitcoind_passthru(coin->symbol,coin->chain->serverport,coin->chain->userpass,"z_listreceivedbyaddress",params)); |
|||
} |
|||
|
|||
char *jumblr_zgetbalance(struct supernet_info *myinfo,struct iguana_info *coin,char *addr) |
|||
{ |
|||
char params[1024]; |
|||
sprintf(params,"[\"%s\", 1]",addr); |
|||
return(bitcoind_passthru(coin->symbol,coin->chain->serverport,coin->chain->userpass,"z_getbalance",params)); |
|||
} |
|||
|
|||
int64_t jumblr_receivedby(struct supernet_info *myinfo,struct iguana_info *coin,char *addr) |
|||
{ |
|||
char *retstr; cJSON *retjson,*item; int32_t i,n; int64_t total = 0; |
|||
if ( (retstr= jumblr_zlistreceivedbyaddress(myinfo,coin,addr)) != 0 ) |
|||
{ |
|||
printf("z_listreceivedbyaddress.(%s) -> (%s)\n",addr,retstr); |
|||
if ( (retjson= cJSON_Parse(retstr)) != 0 ) |
|||
{ |
|||
if ( (n= cJSON_GetArraySize(retjson)) > 0 ) |
|||
{ |
|||
for (i=0; i<n; i++) |
|||
{ |
|||
item = jitem(retjson,i); |
|||
total += jdouble(item,"amount") * SATOSHIDEN; |
|||
} |
|||
} |
|||
free_json(retjson); |
|||
} |
|||
free(retstr); |
|||
} |
|||
return(total); |
|||
} |
|||
|
|||
int64_t jumblr_balance(struct supernet_info *myinfo,struct iguana_info *coin,char *addr) |
|||
{ |
|||
char *retstr; double val; int64_t balance = 0; |
|||
if ( (retstr= jumblr_zgetbalance(myinfo,coin,addr)) != 0 ) |
|||
{ |
|||
if ( (val= atof(retstr)) > SMALLVAL ) |
|||
balance = val * SATOSHIDEN; |
|||
free(retstr); |
|||
} |
|||
return(balance); |
|||
} |
|||
|
|||
void jumblr_itemset(struct jumblr_item *ptr,cJSON *item,char *status) |
|||
{ |
|||
cJSON *params,*amounts,*dest; char *from,*addr; int32_t i,n; int64_t amount; |
|||
/*"params" : {
|
|||
"fromaddress" : "RDhEGYScNQYetCyG75Kf8Fg61UWPdwc1C5", |
|||
"amounts" : [ |
|||
{ |
|||
"address" : "zc9s3UdkDFTnnwHrMCr1vYy2WmkjhmTxXNiqC42s7BjeKBVUwk766TTSsrRPKfnX31Bbu8wbrTqnjDqskYGwx48FZMPHvft", |
|||
"amount" : 3.00000000 |
|||
} |
|||
], |
|||
"minconf" : 1, |
|||
"fee" : 0.00010000 |
|||
}*/ |
|||
if ( (params= jobj(item,"params")) != 0 ) |
|||
{ |
|||
if ( (from= jstr(params,"fromaddress")) != 0 ) |
|||
safecopy(ptr->src,from,sizeof(ptr->src)); |
|||
if ( (amounts= jarray(&n,params,"amounts")) != 0 ) |
|||
{ |
|||
for (i=0; i<n; i++) |
|||
{ |
|||
dest = jitem(amounts,i); |
|||
if ( (addr= jstr(dest,"address")) != 0 && (amount= jdouble(dest,"amount")*SATOSHIDEN) > 0 ) |
|||
{ |
|||
if ( strcmp(addr,JUMBLR_ADDR) == 0 ) |
|||
ptr->fee = amount; |
|||
else |
|||
{ |
|||
ptr->amount = amount; |
|||
safecopy(ptr->dest,addr,sizeof(ptr->dest)); |
|||
} |
|||
} |
|||
} |
|||
} |
|||
ptr->txfee = jdouble(params,"fee") * SATOSHIDEN; |
|||
} |
|||
} |
|||
|
|||
void jumblr_opidupdate(struct supernet_info *myinfo,struct iguana_info *coin,struct jumblr_item *ptr) |
|||
{ |
|||
char *retstr,*status; cJSON *retjson; |
|||
if ( ptr->status == 0 ) |
|||
{ |
|||
if ( (retstr= jumblr_zgetoperationresult(myinfo,coin,ptr->opid)) != 0 ) |
|||
{ |
|||
if ( (retjson= cJSON_Parse(retstr)) != 0 ) |
|||
{ |
|||
if ( (status= jstr(retjson,"status")) != 0 && strcmp(status,"pending") != 0 ) |
|||
jumblr_itemset(ptr,retjson,status); |
|||
free_json(retjson); |
|||
} |
|||
free(retstr); |
|||
} |
|||
} |
|||
} |
|||
|
|||
void jumblr_opidsupdate(struct supernet_info *myinfo,struct iguana_info *coin) |
|||
{ |
|||
char *retstr; cJSON *array; int32_t i,n; struct jumblr_item *ptr; |
|||
if ( (retstr= jumblr_zlistoperationids(myinfo,coin)) != 0 ) |
|||
{ |
|||
if ( (array= cJSON_Parse(retstr)) != 0 ) |
|||
{ |
|||
if ( (n= cJSON_GetArraySize(array)) > 0 ) |
|||
{ |
|||
for (i=0; i<n; i++) |
|||
if ( (ptr= jumblr_opidadd(myinfo,coin,jstri(array,i))) != 0 && ptr->status == 0 ) |
|||
jumblr_opidupdate(myinfo,coin,ptr); |
|||
} |
|||
free_json(array); |
|||
} |
|||
free(retstr); |
|||
} |
|||
} |
|||
|
|||
bits256 jumblr_privkey(struct supernet_info *myinfo,char *BTCaddr,char *KMDaddr,char *prefix) |
|||
{ |
|||
bits256 privkey,pubkey; uint8_t pubkey33[33]; char passphrase[sizeof(myinfo->jumblr_passphrase) + 64]; |
|||
sprintf(passphrase,"%s%s",prefix,myinfo->jumblr_passphrase); |
|||
conv_NXTpassword(privkey.bytes,pubkey.bytes,(uint8_t *)passphrase,(int32_t)strlen(passphrase)); |
|||
bitcoin_pubkey33(myinfo->ctx,pubkey33,privkey); |
|||
bitcoin_address(BTCaddr,0,pubkey33,33); |
|||
bitcoin_address(KMDaddr,60,pubkey33,33); |
|||
return(privkey); |
|||
} |
|||
|
|||
void jumblr_iteration(struct supernet_info *myinfo,struct iguana_info *coin,int32_t selector,int32_t modval) |
|||
{ |
|||
char BTCaddr[64],KMDaddr[64],*zaddr,*retstr; bits256 priv0; uint64_t amount=0,total=0; double fee; struct jumblr_item *ptr,*tmp; uint8_t r; |
|||
// if BTC has arrived in deposit address, invoke DEX -> KMD
|
|||
// if BTC has arrived in destination address, invoke DEX -> BTC
|
|||
fee = JUMBLR_INCR * JUMBLR_FEE; |
|||
OS_randombytes(&r,sizeof(r)); |
|||
if ( strcmp(coin->symbol,"KMD") == 0 && coin->FULLNODE < 0 ) |
|||
{ |
|||
switch ( selector ) |
|||
{ |
|||
case 0: // public -> z
|
|||
priv0 = jumblr_privkey(myinfo,BTCaddr,KMDaddr,JUMBLR_DEPOSITPREFIX); |
|||
if ( (total= jumblr_balance(myinfo,coin,KMDaddr)) >= (JUMBLR_INCR + 3*(fee+JUMBLR_TXFEE))*SATOSHIDEN ) |
|||
{ |
|||
if ( (r & 7) == 0 ) |
|||
{ |
|||
if ( (zaddr= jumblr_zgetnewaddress(myinfo,coin)) != 0 ) |
|||
{ |
|||
if ( total >= SATOSHIDEN * ((JUMBLR_INCR + 3*fee)*100 + 3*JUMBLR_TXFEE) ) |
|||
amount = SATOSHIDEN * ((JUMBLR_INCR + 3*fee)*100 + 3*JUMBLR_TXFEE); |
|||
else if ( total >= SATOSHIDEN * ((JUMBLR_INCR + 3*fee)*10 + 3*JUMBLR_TXFEE) ) |
|||
amount = SATOSHIDEN * ((JUMBLR_INCR + 3*fee)*10 + 3*JUMBLR_TXFEE); |
|||
else amount = SATOSHIDEN * ((JUMBLR_INCR + 3*fee) + 3*JUMBLR_TXFEE); |
|||
if ( (retstr= jumblr_sendt_to_z(myinfo,coin,KMDaddr,zaddr,dstr(amount))) != 0 ) |
|||
{ |
|||
printf("sendt_to_z.(%s)\n",retstr); |
|||
free(retstr); |
|||
} |
|||
free(zaddr); |
|||
} |
|||
} |
|||
} |
|||
break; |
|||
case 1: // z -> z
|
|||
jumblr_opidsupdate(myinfo,coin); |
|||
HASH_ITER(hh,myinfo->jumblrs,ptr,tmp) |
|||
{ |
|||
if ( strlen(ptr->src) < 40 ) |
|||
{ |
|||
if ( (r & 7) == 0 && ptr->spent == 0 && (total= jumblr_balance(myinfo,coin,ptr->dest)) >= (fee + JUMBLR_FEE)*SATOSHIDEN ) |
|||
{ |
|||
if ( (zaddr= jumblr_zgetnewaddress(myinfo,coin)) != 0 ) |
|||
{ |
|||
if ( (retstr= jumblr_sendz_to_z(myinfo,coin,ptr->dest,zaddr,dstr(total))) != 0 ) |
|||
{ |
|||
printf("sendz_to_z.(%s)\n",retstr); |
|||
free(retstr); |
|||
} |
|||
ptr->spent = (uint32_t)time(NULL); |
|||
free(zaddr); |
|||
break; |
|||
} |
|||
} |
|||
} |
|||
} |
|||
break; |
|||
case 2: // z -> public
|
|||
jumblr_opidsupdate(myinfo,coin); |
|||
HASH_ITER(hh,myinfo->jumblrs,ptr,tmp) |
|||
{ |
|||
if ( strlen(ptr->src) >= 40 ) |
|||
{ |
|||
if ( (r & 7) == 0 && ptr->spent == 0 && (total= jumblr_balance(myinfo,coin,ptr->dest)) >= (fee + JUMBLR_FEE)*SATOSHIDEN ) |
|||
{ |
|||
priv0 = jumblr_privkey(myinfo,BTCaddr,KMDaddr,""); |
|||
if ( (retstr= jumblr_sendz_to_t(myinfo,coin,ptr->dest,KMDaddr,dstr(total))) != 0 ) |
|||
{ |
|||
printf("sendz_to_t.(%s)\n",retstr); |
|||
free(retstr); |
|||
} |
|||
ptr->spent = (uint32_t)time(NULL); |
|||
break; |
|||
} |
|||
} |
|||
} |
|||
break; |
|||
} |
|||
} |
|||
} |
|||
|
|||
#include "../includes/iguana_apidefs.h" |
|||
#include "../includes/iguana_apideclares.h" |
|||
|
|||
STRING_ARG(jumblr,setpassphrase,passphrase) |
|||
{ |
|||
cJSON *retjson; char KMDaddr[64],BTCaddr[64]; |
|||
if ( passphrase == 0 || passphrase[0] == 0 || (coin= iguana_coinfind("KMD")) == 0 || coin->FULLNODE >= 0 ) |
|||
return(clonestr("{\"error\":\"no passphrase or no native komodod\"}")); |
|||
else |
|||
{ |
|||
safecopy(myinfo->jumblr_passphrase,passphrase,sizeof(myinfo->jumblr_passphrase)); |
|||
retjson = cJSON_CreateObject(); |
|||
jaddstr(retjson,"result","success"); |
|||
jumblr_privkey(myinfo,BTCaddr,KMDaddr,JUMBLR_DEPOSITPREFIX); |
|||
jaddstr(retjson,"BTCdeposit","notyet"); |
|||
jaddstr(retjson,"KMDdeposit",KMDaddr); |
|||
jumblr_privkey(myinfo,BTCaddr,KMDaddr,""); |
|||
jaddstr(retjson,"BTCjumblr","notyet"); |
|||
jaddstr(retjson,"KMDjumblr",KMDaddr); |
|||
return(clonestr("{\"result\":\"success\"}")); |
|||
} |
|||
} |
|||
|
|||
ZERO_ARGS(jumblr,status) |
|||
{ |
|||
cJSON *retjson; char KMDaddr[64],BTCaddr[64]; struct jumblr_item *ptr,*tmp; int64_t deposited,step_t2z,step_z2z,step_z2t,finished; |
|||
if ( strcmp(coin->symbol,"KMD") == 0 && coin->FULLNODE < 0 && myinfo->jumblr_passphrase[0] != 0 ) |
|||
{ |
|||
jumblr_opidsupdate(myinfo,coin); |
|||
retjson = cJSON_CreateObject(); |
|||
step_t2z = step_z2z = step_z2t = deposited = finished = 0; |
|||
jumblr_privkey(myinfo,BTCaddr,KMDaddr,JUMBLR_DEPOSITPREFIX); |
|||
deposited = jumblr_receivedby(myinfo,coin,KMDaddr); |
|||
jumblr_privkey(myinfo,BTCaddr,KMDaddr,""); |
|||
finished = jumblr_receivedby(myinfo,coin,KMDaddr); |
|||
HASH_ITER(hh,myinfo->jumblrs,ptr,tmp) |
|||
{ |
|||
if ( strlen(ptr->src) >= 40 ) |
|||
{ |
|||
if ( strlen(ptr->dest) >= 40 ) |
|||
step_z2z += ptr->amount; |
|||
else step_z2t += ptr->amount; |
|||
} |
|||
else step_t2z += ptr->amount; |
|||
} |
|||
jaddstr(retjson,"result","success"); |
|||
jaddnum(retjson,"deposited",dstr(deposited)); |
|||
jaddnum(retjson,"t_to_z",dstr(step_t2z)); |
|||
jaddnum(retjson,"z_to_z",dstr(step_z2z)); |
|||
jaddnum(retjson,"z_to_t",dstr(step_z2t)); |
|||
jaddnum(retjson,"finished",dstr(finished)); |
|||
jaddnum(retjson,"pending",dstr(deposited) - dstr(finished)); |
|||
return(jprint(retjson,1)); |
|||
} else return(clonestr("{\"error\":\"no passphrase or no native komodod\"}")); |
|||
} |
|||
|
|||
#include "../includes/iguana_apiundefs.h" |
|||
File diff suppressed because it is too large
Loading…
Reference in new issue