1 /******************************************************************************
2 * Copyright © 2014-2017 The SuperNET Developers. *
4 * See the AUTHORS, DEVELOPER-AGREEMENT and LICENSE files at *
5 * the top-level directory of this distribution for the individual copyright *
6 * holder information and the developer policies on copyright and licensing. *
8 * Unless otherwise agreed in a custom licensing agreement, no part of the *
9 * SuperNET software, including this file may be copied, modified, propagated *
10 * or distributed except according to the terms contained in the LICENSE file *
12 * Removal or modification of this copyright notice is prohibited. *
14 ******************************************************************************/
18 z_exportwallet "filename"
19 z_getoperationstatus (["operationid", ... ])
20 z_gettotalbalance ( minconf )
21 z_importkey "zkey" ( rescan )
22 z_importwallet "filename"
24 z_sendmany "fromaddress" [{"address":... ,"amount":..., "memo":"<hex>"},...] ( minconf ) ( fee )
27 #define JUMBLR_ADDR "RGhxXpXSSBTBm9EvNsXnTQczthMCxHX91t"
28 #define JUMBLR_BTCADDR "18RmTJe9qMech8siuhYfMtHo8RtcN1obC6"
29 #define JUMBLR_MAXSECRETADDRS 777
30 #define JUMBLR_SYNCHRONIZED_BLOCKS 2 // 60
31 #define JUMBLR_INCR (99.65 / 100)
32 #define JUMBLR_FEE 0.001
33 #define JUMBLR_TXFEE 0.01
34 #define SMALLVAL 0.000000000000001
36 #define JUMBLR_ERROR_DUPLICATEDEPOSIT -1
37 #define JUMBLR_ERROR_SECRETCANTBEDEPOSIT -2
38 #define JUMBLR_ERROR_TOOMANYSECRETS -3
39 #define JUMBLR_ERROR_NOTINWALLET -4
44 int64_t amount,fee,txfee;
46 char opid[64],src[128],dest[128],status;
49 char Jumblr_secretaddrs[JUMBLR_MAXSECRETADDRS][64],Jumblr_deposit[64];
50 int32_t Jumblr_numsecretaddrs; // if 0 -> run silent mode
52 char *jumblr_issuemethod(char *userpass,char *method,char *params,uint16_t port)
54 cJSON *retjson,*resjson = 0; char *retstr;
55 if ( (retstr= komodo_issuemethod(userpass,method,params,port)) != 0 )
57 if ( (retjson= cJSON_Parse(retstr)) != 0 )
59 if ( jobj(retjson,(char *)"result") != 0 )
60 resjson = jduplicate(jobj(retjson,(char *)"result"));
61 else if ( jobj(retjson,(char *)"error") != 0 )
62 resjson = jduplicate(jobj(retjson,(char *)"error"));
65 resjson = cJSON_CreateObject();
66 jaddstr(resjson,(char *)"error",(char *)"cant parse return");
73 return(jprint(resjson,1));
74 else return(clonestr((char *)"{\"error\":\"unknown error\"}"));
77 char *jumblr_importaddress(char *address)
80 sprintf(params,"[\"%s\", \"%s\", false]",address,address);
81 return(jumblr_issuemethod(KMDUSERPASS,(char *)"importaddress",params,7771));
84 char *jumblr_validateaddress(char *addr)
87 sprintf(params,"[\"%s\"]",addr);
88 return(jumblr_issuemethod(KMDUSERPASS,(char *)"validateaddress",params,7771));
91 int32_t Jumblr_secretaddrfind(char *searchaddr)
94 for (i=0; i<Jumblr_numsecretaddrs; i++)
96 if ( strcmp(searchaddr,Jumblr_secretaddrs[i]) == 0 )
102 int32_t Jumblr_secretaddradd(char *secretaddr) // external
105 if ( secretaddr != 0 && secretaddr[0] != 0 )
107 if ( Jumblr_numsecretaddrs < JUMBLR_MAXSECRETADDRS )
109 if ( strcmp(Jumblr_deposit,secretaddr) != 0 )
111 if ( (ind= Jumblr_secretaddrfind(secretaddr)) < 0 )
113 safecopy(Jumblr_secretaddrs[Jumblr_numsecretaddrs],secretaddr,64);
114 Jumblr_numsecretaddrs++;
116 } else return(JUMBLR_ERROR_SECRETCANTBEDEPOSIT);
117 } else return(JUMBLR_ERROR_TOOMANYSECRETS);
121 memset(Jumblr_secretaddrs,0,sizeof(Jumblr_secretaddrs));
122 Jumblr_numsecretaddrs = 0;
124 return(Jumblr_numsecretaddrs);
127 int32_t Jumblr_depositaddradd(char *depositaddr) // external
129 int32_t ind,retval = JUMBLR_ERROR_DUPLICATEDEPOSIT; char *retstr; cJSON *retjson,*ismine;
130 if ( depositaddr == 0 )
131 depositaddr = (char *)"";
132 if ( (ind= Jumblr_secretaddrfind(depositaddr)) < 0 )
134 safecopy(Jumblr_deposit,depositaddr,sizeof(Jumblr_deposit));
135 if ( (retstr= jumblr_validateaddress(depositaddr)) != 0 )
137 if ( (retjson= cJSON_Parse(retstr)) != 0 )
139 if ( (ismine= jobj(retjson,(char *)"ismine")) != 0 && is_cJSON_True(ismine) != 0 )
141 else retval = JUMBLR_ERROR_NOTINWALLET;
150 int32_t Jumblr_secretaddr(char *secretaddr)
153 if ( Jumblr_numsecretaddrs > 0 )
155 OS_randombytes((uint8_t *)&r,sizeof(r));
156 r %= Jumblr_numsecretaddrs;
157 safecopy(secretaddr,Jumblr_secretaddrs[r],64);
162 int32_t jumblr_addresstype(char *addr)
164 if ( addr[0] == '"' && addr[strlen(addr)-1] == '"' )
166 addr[strlen(addr)-1] = 0;
169 if ( addr[0] == 'z' && addr[1] == 'c' && strlen(addr) >= 40 )
171 else if ( strlen(addr) < 40 )
173 printf("strange.(%s)\n",addr);
177 struct jumblr_item *jumblr_opidfind(char *opid)
179 struct jumblr_item *ptr;
180 HASH_FIND(hh,Jumblrs,opid,(int32_t)strlen(opid),ptr);
184 struct jumblr_item *jumblr_opidadd(char *opid)
186 struct jumblr_item *ptr = 0;
187 if ( opid != 0 && (ptr= jumblr_opidfind(opid)) == 0 )
189 ptr = (struct jumblr_item *)calloc(1,sizeof(*ptr));
190 safecopy(ptr->opid,opid,sizeof(ptr->opid));
191 HASH_ADD_KEYPTR(hh,Jumblrs,ptr->opid,(int32_t)strlen(ptr->opid),ptr);
192 if ( ptr != jumblr_opidfind(opid) )
193 printf("jumblr_opidadd.(%s) ERROR, couldnt find after add\n",opid);
198 char *jumblr_zgetnewaddress()
201 sprintf(params,"[]");
202 return(jumblr_issuemethod(KMDUSERPASS,(char *)"z_getnewaddress",params,7771));
205 char *jumblr_zlistoperationids()
208 sprintf(params,"[]");
209 return(jumblr_issuemethod(KMDUSERPASS,(char *)"z_listoperationids",params,7771));
212 char *jumblr_zgetoperationresult(char *opid)
215 sprintf(params,"[[\"%s\"]]",opid);
216 return(jumblr_issuemethod(KMDUSERPASS,(char *)"z_getoperationresult",params,7771));
219 char *jumblr_zgetoperationstatus(char *opid)
222 sprintf(params,"[[\"%s\"]]",opid);
223 return(jumblr_issuemethod(KMDUSERPASS,(char *)"z_getoperationstatus",params,7771));
226 char *jumblr_sendt_to_z(char *taddr,char *zaddr,double amount)
228 char params[1024]; double fee = (amount-3*JUMBLR_TXFEE) * JUMBLR_FEE;
229 if ( jumblr_addresstype(zaddr) != 'z' || jumblr_addresstype(taddr) != 't' )
230 return(clonestr((char *)"{\"error\":\"illegal address in t to z\"}"));
231 sprintf(params,"[\"%s\", [{\"address\":\"%s\",\"amount\":%.8f}, {\"address\":\"%s\",\"amount\":%.8f}], 1, %.8f]",taddr,zaddr,amount-fee-JUMBLR_TXFEE,JUMBLR_ADDR,fee,JUMBLR_TXFEE);
232 printf("t -> z: %s\n",params);
233 return(jumblr_issuemethod(KMDUSERPASS,(char *)"z_sendmany",params,7771));
236 char *jumblr_sendz_to_z(char *zaddrS,char *zaddrD,double amount)
238 char params[1024]; double fee = (amount-2*JUMBLR_TXFEE) * JUMBLR_FEE;
239 if ( jumblr_addresstype(zaddrS) != 'z' || jumblr_addresstype(zaddrD) != 'z' )
240 return(clonestr((char *)"{\"error\":\"illegal address in z to z\"}"));
241 sprintf(params,"[\"%s\", [{\"address\":\"%s\",\"amount\":%.8f}, {\"address\":\"%s\",\"amount\":%.8f}], 1, %.8f]",zaddrS,zaddrD,amount-fee-JUMBLR_TXFEE,JUMBLR_ADDR,fee,JUMBLR_TXFEE);
242 printf("z -> z: %s\n",params);
243 return(jumblr_issuemethod(KMDUSERPASS,(char *)"z_sendmany",params,7771));
246 char *jumblr_sendz_to_t(char *zaddr,char *taddr,double amount)
248 char params[1024]; double fee = (amount-JUMBLR_TXFEE) * JUMBLR_FEE;
249 if ( jumblr_addresstype(zaddr) != 'z' || jumblr_addresstype(taddr) != 't' )
250 return(clonestr((char *)"{\"error\":\"illegal address in z to t\"}"));
251 sprintf(params,"[\"%s\", [{\"address\":\"%s\",\"amount\":%.8f}, {\"address\":\"%s\",\"amount\":%.8f}], 1, %.8f]",zaddr,taddr,amount-fee-JUMBLR_TXFEE,JUMBLR_ADDR,fee,JUMBLR_TXFEE);
252 printf("z -> t: %s\n",params);
253 return(jumblr_issuemethod(KMDUSERPASS,(char *)"z_sendmany",params,7771));
256 char *jumblr_zlistreceivedbyaddress(char *addr)
259 sprintf(params,"[\"%s\", 1]",addr);
260 return(jumblr_issuemethod(KMDUSERPASS,(char *)"z_listreceivedbyaddress",params,7771));
263 char *jumblr_getreceivedbyaddress(char *addr)
266 sprintf(params,"[\"%s\", 1]",addr);
267 return(jumblr_issuemethod(KMDUSERPASS,(char *)"getreceivedbyaddress",params,7771));
270 char *jumblr_importprivkey(char *wifstr)
273 sprintf(params,"[\"%s\", \"\", false]",wifstr);
274 return(jumblr_issuemethod(KMDUSERPASS,(char *)"importprivkey",params,7771));
277 char *jumblr_zgetbalance(char *addr)
280 sprintf(params,"[\"%s\", 1]",addr);
281 return(jumblr_issuemethod(KMDUSERPASS,(char *)"z_getbalance",params,7771));
284 char *jumblr_listunspent(char *coinaddr)
287 sprintf(params,"[1, 99999999, [\"%s\"]]",coinaddr);
288 return(jumblr_issuemethod(KMDUSERPASS,(char *)"listunspent",params,7771));
291 int64_t jumblr_receivedby(char *addr)
293 char *retstr; int64_t total = 0;
294 if ( (retstr= jumblr_getreceivedbyaddress(addr)) != 0 )
296 total = atof(retstr) * SATOSHIDEN;
302 int64_t jumblr_balance(char *addr)
304 char *retstr; double val; cJSON *retjson; int32_t i,n; int64_t balance = 0;
305 if ( jumblr_addresstype(addr) == 't' )
307 if ( (retstr= jumblr_listunspent(addr)) != 0 )
309 //printf("jumblr.[%s].(%s)\n","KMD",retstr);
310 if ( (retjson= cJSON_Parse(retstr)) != 0 )
312 if ( (n= cJSON_GetArraySize(retjson)) > 0 && is_cJSON_Array(retjson) != 0 )
314 balance += SATOSHIDEN * jdouble(jitem(retjson,i),(char *)"amount");
320 else if ( (retstr= jumblr_zgetbalance(addr)) != 0 )
322 if ( (val= atof(retstr)) > SMALLVAL )
323 balance = val * SATOSHIDEN;
329 int32_t jumblr_itemset(struct jumblr_item *ptr,cJSON *item,char *status)
331 cJSON *params,*amounts,*dest; char *from,*addr; int32_t i,n; int64_t amount;
333 "fromaddress" : "RDhEGYScNQYetCyG75Kf8Fg61UWPdwc1C5",
336 "address" : "zc9s3UdkDFTnnwHrMCr1vYy2WmkjhmTxXNiqC42s7BjeKBVUwk766TTSsrRPKfnX31Bbu8wbrTqnjDqskYGwx48FZMPHvft",
337 "amount" : 3.00000000
343 if ( (params= jobj(item,(char *)"params")) != 0 )
345 //printf("params.(%s)\n",jprint(params,0));
346 if ( (from= jstr(params,(char *)"fromaddress")) != 0 )
348 safecopy(ptr->src,from,sizeof(ptr->src));
350 if ( (amounts= jarray(&n,params,(char *)"amounts")) != 0 )
354 dest = jitem(amounts,i);
355 //printf("%s ",jprint(dest,0));
356 if ( (addr= jstr(dest,(char *)"address")) != 0 && (amount= jdouble(dest,(char *)"amount")*SATOSHIDEN) > 0 )
358 if ( strcmp(addr,JUMBLR_ADDR) == 0 )
362 ptr->amount = amount;
363 safecopy(ptr->dest,addr,sizeof(ptr->dest));
368 ptr->txfee = jdouble(params,(char *)"fee") * SATOSHIDEN;
373 void jumblr_opidupdate(struct jumblr_item *ptr)
375 char *retstr,*status; cJSON *retjson,*item;
376 if ( ptr->status == 0 )
378 if ( (retstr= jumblr_zgetoperationstatus(ptr->opid)) != 0 )
380 if ( (retjson= cJSON_Parse(retstr)) != 0 )
382 if ( cJSON_GetArraySize(retjson) == 1 && is_cJSON_Array(retjson) != 0 )
384 item = jitem(retjson,0);
385 //printf("%s\n",jprint(item,0));
386 if ( (status= jstr(item,(char *)"status")) != 0 )
388 if ( strcmp(status,(char *)"success") == 0 )
390 ptr->status = jumblr_itemset(ptr,item,status);
391 if ( (jumblr_addresstype(ptr->src) == 't' && jumblr_addresstype(ptr->src) == 'z' && strcmp(ptr->src,Jumblr_deposit) != 0) || (jumblr_addresstype(ptr->src) == 'z' && jumblr_addresstype(ptr->src) == 't' && Jumblr_secretaddrfind(ptr->dest) < 0) )
393 printf("a non-jumblr t->z pruned\n");
394 free(jumblr_zgetoperationresult(ptr->opid));
399 else if ( strcmp(status,(char *)"failed") == 0 )
401 printf("jumblr_opidupdate %s failed\n",ptr->opid);
402 free(jumblr_zgetoperationresult(ptr->opid));
414 void jumblr_prune(struct jumblr_item *ptr)
416 struct jumblr_item *tmp; char oldsrc[128]; int32_t flag = 1;
417 printf("jumblr_prune %s\n",ptr->opid);
418 strcpy(oldsrc,ptr->src);
419 free(jumblr_zgetoperationresult(ptr->opid));
423 HASH_ITER(hh,Jumblrs,ptr,tmp)
425 if ( strcmp(oldsrc,ptr->dest) == 0 )
427 printf("jumblr_prune %s (%s -> %s) matched oldsrc\n",ptr->opid,ptr->src,ptr->dest);
428 free(jumblr_zgetoperationresult(ptr->opid));
429 strcpy(oldsrc,ptr->src);
437 void jumblr_opidsupdate()
439 char *retstr; cJSON *array; int32_t i,n; struct jumblr_item *ptr;
440 if ( (retstr= jumblr_zlistoperationids()) != 0 )
442 if ( (array= cJSON_Parse(retstr)) != 0 )
444 if ( (n= cJSON_GetArraySize(array)) > 0 && is_cJSON_Array(array) != 0 )
446 printf("%s -> n%d\n",retstr,n);
449 if ( (ptr= jumblr_opidadd(jstri(array,i))) != 0 )
451 if ( ptr->status == 0 )
452 jumblr_opidupdate(ptr);
453 //printf("%d: %s -> %s %.8f\n",ptr->status,ptr->src,ptr->dest,dstr(ptr->amount));
454 if ( jumblr_addresstype(ptr->src) == 'z' && jumblr_addresstype(ptr->dest) == 't' )
465 void jumblr_iteration()
467 static int32_t lastheight;
468 char *zaddr,*retstr,secretaddr[64]; int32_t iter,height,counter,chosen_one,n; uint64_t amount=0,total=0; double fee; struct jumblr_item *ptr,*tmp; uint8_t r,s;
469 height = (int32_t)chainActive.Tip()->nHeight;
470 if ( lastheight == height )
472 if ( (height % JUMBLR_SYNCHRONIZED_BLOCKS) != 0 )
474 fee = JUMBLR_INCR * JUMBLR_FEE;
475 OS_randombytes(&r,sizeof(r));
479 case 0: // public -> z, need to importprivkey
480 if ( Jumblr_deposit[0] != 0 && (total= jumblr_balance(Jumblr_deposit)) >= (JUMBLR_INCR + 3*(fee+JUMBLR_TXFEE))*SATOSHIDEN )
482 if ( (zaddr= jumblr_zgetnewaddress()) != 0 )
485 if ( (height % (JUMBLR_SYNCHRONIZED_BLOCKS*JUMBLR_SYNCHRONIZED_BLOCKS)) == 0 && total >= SATOSHIDEN * ((JUMBLR_INCR + 3*fee)*100 + 3*JUMBLR_TXFEE) )
486 amount = SATOSHIDEN * ((JUMBLR_INCR + 3*fee)*100 + 3*JUMBLR_TXFEE);
487 else if ( (r & 3) == 0 && total >= SATOSHIDEN * ((JUMBLR_INCR + 3*fee)*10 + 3*JUMBLR_TXFEE) )
488 amount = SATOSHIDEN * ((JUMBLR_INCR + 3*fee)*10 + 3*JUMBLR_TXFEE);
489 else amount = SATOSHIDEN * ((JUMBLR_INCR + 3*fee) + 3*JUMBLR_TXFEE);
490 if ( amount > 0 && (retstr= jumblr_sendt_to_z(Jumblr_deposit,zaddr,dstr(amount))) != 0 )
492 printf("sendt_to_z.(%s)\n",retstr);
496 } else printf("no zaddr from jumblr_zgetnewaddress\n");
498 else if ( Jumblr_deposit[0] != 0 )
499 printf("%s total %.8f vs %.8f\n",Jumblr_deposit,dstr(total),(JUMBLR_INCR + 3*(fee+JUMBLR_TXFEE)));
502 jumblr_opidsupdate();
504 for (iter=counter=0; iter<2; iter++)
507 HASH_ITER(hh,Jumblrs,ptr,tmp)
509 if ( jumblr_addresstype(ptr->src) == 't' && jumblr_addresstype(ptr->dest) == 'z' )
511 if ( ptr->spent == 0 && (total= jumblr_balance(ptr->dest)) >= (fee + JUMBLR_FEE)*SATOSHIDEN )
513 if ( iter == 1 && counter == chosen_one )
515 if ( (zaddr= jumblr_zgetnewaddress()) != 0 )
517 if ( (retstr= jumblr_sendz_to_z(ptr->dest,zaddr,dstr(total))) != 0 )
519 printf("n.%d counter.%d chosen_one.%d sendz_to_z.(%s)\n",n,counter,chosen_one,retstr);
522 ptr->spent = (uint32_t)time(NULL);
536 OS_randombytes((uint8_t *)&chosen_one,sizeof(chosen_one));
537 if ( chosen_one < 0 )
538 chosen_one = -chosen_one;
539 chosen_one %= counter;
540 printf("jumblr z->z chosen_one.%d of %d, from %d\n",chosen_one,counter,n);
544 case 2: // z -> public
545 if ( Jumblr_numsecretaddrs > 0 )
547 jumblr_opidsupdate();
549 for (iter=0; iter<2; iter++)
552 HASH_ITER(hh,Jumblrs,ptr,tmp)
554 if ( jumblr_addresstype(ptr->src) == 'z' && jumblr_addresstype(ptr->dest) == 'z' )
556 if ( ptr->spent == 0 && (total= jumblr_balance(ptr->dest)) >= (fee + JUMBLR_FEE)*SATOSHIDEN )
558 if ( iter == 1 && n == chosen_one )
560 Jumblr_secretaddr(secretaddr);
561 if ( (retstr= jumblr_sendz_to_t(ptr->dest,secretaddr,dstr(total))) != 0 )
563 printf("sendz_to_t.(%s)\n",retstr);
566 ptr->spent = (uint32_t)time(NULL);
578 OS_randombytes((uint8_t *)&chosen_one,sizeof(chosen_one));
579 if ( chosen_one < 0 )
580 chosen_one = -chosen_one;
581 chosen_one %= counter;
582 printf("jumblr z->t chosen_one.%d of %d, from %d\n",chosen_one,counter,n);