src/komodo_bitcoind.h

   1 /******************************************************************************
   2  * Copyright © 2014-2017 The SuperNET Developers.                             *
   3  *                                                                            *
   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.  *
   7  *                                                                            *
   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 *
  11  *                                                                            *
  12  * Removal or modification of this copyright notice is prohibited.            *
  13  *                                                                            *
  14  ******************************************************************************/
  15
  16 // komodo functions that interact with bitcoind C++
  17
  18 #ifdef _WIN32
  19 #include <curl/curl.h>
  20 #include <curl/easy.h>
  21 #else
  22 #include <curl/curl.h>
  23 #include <curl/easy.h>
  24 #endif
  25
  26 #include "komodo_defs.h"
  27
  28 int32_t komodo_notaries(uint8_t pubkeys[64][33],int32_t height,uint32_t timestamp);
  29 int32_t komodo_electednotary(int32_t *numnotariesp,uint8_t *pubkey33,int32_t height,uint32_t timestamp);
  30
  31 //#define issue_curl(cmdstr) bitcoind_RPC(0,(char *)"curl",(char *)"http://127.0.0.1:7776",0,0,(char *)(cmdstr))
  32
  33 struct MemoryStruct { char *memory; size_t size; };
  34 struct return_string { char *ptr; size_t len; };
  35
  36 // return data from the server
  37 #define CURL_GLOBAL_ALL (CURL_GLOBAL_SSL|CURL_GLOBAL_WIN32)
  38 #define CURL_GLOBAL_SSL (1<<0)
  39 #define CURL_GLOBAL_WIN32 (1<<1)
  40
  41
  42 /************************************************************************
  43  *
  44  * Initialize the string handler so that it is thread safe
  45  *
  46  ************************************************************************/
  47
  48 void init_string(struct return_string *s)
  49 {
  50     s->len = 0;
  51     s->ptr = (char *)calloc(1,s->len+1);
  52     if ( s->ptr == NULL )
  53     {
  54         fprintf(stderr,"init_string malloc() failed\n");
  55         exit(-1);
  56     }
  57     s->ptr[0] = '\0';
  58 }
  59
  60 /************************************************************************
  61  *
  62  * Use the "writer" to accumulate text until done
  63  *
  64  ************************************************************************/
  65
  66 size_t accumulatebytes(void *ptr,size_t size,size_t nmemb,struct return_string *s)
  67 {
  68     size_t new_len = s->len + size*nmemb;
  69     s->ptr = (char *)realloc(s->ptr,new_len+1);
  70     if ( s->ptr == NULL )
  71     {
  72         fprintf(stderr, "accumulate realloc() failed\n");
  73         exit(-1);
  74     }
  75     memcpy(s->ptr+s->len,ptr,size*nmemb);
  76     s->ptr[new_len] = '\0';
  77     s->len = new_len;
  78     return(size * nmemb);
  79 }
  80
  81 /************************************************************************
  82  *
  83  * return the current system time in milliseconds
  84  *
  85  ************************************************************************/
  86
  87 #define EXTRACT_BITCOIND_RESULT  // if defined, ensures error is null and returns the "result" field
  88 #ifdef EXTRACT_BITCOIND_RESULT
  89
  90 /************************************************************************
  91  *
  92  * perform post processing of the results
  93  *
  94  ************************************************************************/
  95
  96 char *post_process_bitcoind_RPC(char *debugstr,char *command,char *rpcstr,char *params)
  97 {
  98     long i,j,len; char *retstr = 0; cJSON *json,*result,*error;
  99     //printf("<<<<<<<<<<< bitcoind_RPC: %s post_process_bitcoind_RPC.%s.[%s]\n",debugstr,command,rpcstr);
 100     if ( command == 0 || rpcstr == 0 || rpcstr[0] == 0 )
 101     {
 102         if ( strcmp(command,"signrawtransaction") != 0 )
 103             printf("<<<<<<<<<<< bitcoind_RPC: %s post_process_bitcoind_RPC.%s.[%s]\n",debugstr,command,rpcstr);
 104         return(rpcstr);
 105     }
 106     json = cJSON_Parse(rpcstr);
 107     if ( json == 0 )
 108     {
 109         printf("<<<<<<<<<<< bitcoind_RPC: %s post_process_bitcoind_RPC.%s can't parse.(%s) params.(%s)\n",debugstr,command,rpcstr,params);
 110         free(rpcstr);
 111         return(0);
 112     }
 113     result = cJSON_GetObjectItem(json,"result");
 114     error = cJSON_GetObjectItem(json,"error");
 115     if ( error != 0 && result != 0 )
 116     {
 117         if ( (error->type&0xff) == cJSON_NULL && (result->type&0xff) != cJSON_NULL )
 118         {
 119             retstr = cJSON_Print(result);
 120             len = strlen(retstr);
 121             if ( retstr[0] == '"' && retstr[len-1] == '"' )
 122             {
 123                 for (i=1,j=0; i<len-1; i++,j++)
 124                     retstr[j] = retstr[i];
 125                 retstr[j] = 0;
 126             }
 127         }
 128         else if ( (error->type&0xff) != cJSON_NULL || (result->type&0xff) != cJSON_NULL )
 129         {
 130             if ( strcmp(command,"signrawtransaction") != 0 )
 131                 printf("<<<<<<<<<<< bitcoind_RPC: %s post_process_bitcoind_RPC (%s) error.%s\n",debugstr,command,rpcstr);
 132         }
 133         free(rpcstr);
 134     } else retstr = rpcstr;
 135     free_json(json);
 136     //fprintf(stderr,"<<<<<<<<<<< bitcoind_RPC: postprocess returns.(%s)\n",retstr);
 137     return(retstr);
 138 }
 139 #endif
 140
 141 /************************************************************************
 142  *
 143  * perform the query
 144  *
 145  ************************************************************************/
 146
 147 char *bitcoind_RPC(char **retstrp,char *debugstr,char *url,char *userpass,char *command,char *params)
 148 {
 149     static int didinit,count,count2; static double elapsedsum,elapsedsum2;
 150     struct curl_slist *headers = NULL; struct return_string s; CURLcode res; CURL *curl_handle;
 151     char *bracket0,*bracket1,*databuf = 0; long len; int32_t specialcase,numretries; double starttime;
 152     if ( didinit == 0 )
 153     {
 154         didinit = 1;
 155         curl_global_init(CURL_GLOBAL_ALL); //init the curl session
 156     }
 157     numretries = 0;
 158     if ( debugstr != 0 && strcmp(debugstr,"BTCD") == 0 && command != 0 && strcmp(command,"SuperNET") ==  0 )
 159         specialcase = 1;
 160     else specialcase = 0;
 161     if ( url[0] == 0 )
 162         strcpy(url,"http://127.0.0.1:7876/nxt");
 163     if ( specialcase != 0 && 0 )
 164         printf("<<<<<<<<<<< bitcoind_RPC: debug.(%s) url.(%s) command.(%s) params.(%s)\n",debugstr,url,command,params);
 165 try_again:
 166     if ( retstrp != 0 )
 167         *retstrp = 0;
 168     starttime = OS_milliseconds();
 169     curl_handle = curl_easy_init();
 170     init_string(&s);
 171     headers = curl_slist_append(0,"Expect:");
 172
 173         curl_easy_setopt(curl_handle,CURLOPT_USERAGENT,"mozilla/4.0");//"Mozilla/4.0 (compatible; )");
 174     curl_easy_setopt(curl_handle,CURLOPT_HTTPHEADER,    headers);
 175     curl_easy_setopt(curl_handle,CURLOPT_URL,           url);
 176     curl_easy_setopt(curl_handle,CURLOPT_WRITEFUNCTION, (void *)accumulatebytes);               // send all data to this function
 177     curl_easy_setopt(curl_handle,CURLOPT_WRITEDATA,             &s);                    // we pass our 's' struct to the callback
 178     curl_easy_setopt(curl_handle,CURLOPT_NOSIGNAL,              1L);                    // supposed to fix "Alarm clock" and long jump crash
 179         curl_easy_setopt(curl_handle,CURLOPT_NOPROGRESS,        1L);                    // no progress callback
 180     if ( strncmp(url,"https",5) == 0 )
 181     {
 182         curl_easy_setopt(curl_handle,CURLOPT_SSL_VERIFYPEER,0);
 183         curl_easy_setopt(curl_handle,CURLOPT_SSL_VERIFYHOST,0);
 184     }
 185     if ( userpass != 0 )
 186         curl_easy_setopt(curl_handle,CURLOPT_USERPWD,   userpass);
 187     databuf = 0;
 188     if ( params != 0 )
 189     {
 190         if ( command != 0 && specialcase == 0 )
 191         {
 192             len = strlen(params);
 193             if ( len > 0 && params[0] == '[' && params[len-1] == ']' ) {
 194                 bracket0 = bracket1 = (char *)"";
 195             }
 196             else
 197             {
 198                 bracket0 = (char *)"[";
 199                 bracket1 = (char *)"]";
 200             }
 201
 202             databuf = (char *)malloc(256 + strlen(command) + strlen(params));
 203             sprintf(databuf,"{\"id\":\"jl777\",\"method\":\"%s\",\"params\":%s%s%s}",command,bracket0,params,bracket1);
 204             //printf("url.(%s) userpass.(%s) databuf.(%s)\n",url,userpass,databuf);
 205             //
 206         } //else if ( specialcase != 0 ) fprintf(stderr,"databuf.(%s)\n",params);
 207         curl_easy_setopt(curl_handle,CURLOPT_POST,1L);
 208         if ( databuf != 0 )
 209             curl_easy_setopt(curl_handle,CURLOPT_POSTFIELDS,databuf);
 210         else curl_easy_setopt(curl_handle,CURLOPT_POSTFIELDS,params);
 211     }
 212     //laststart = milliseconds();
 213     res = curl_easy_perform(curl_handle);
 214     curl_slist_free_all(headers);
 215     curl_easy_cleanup(curl_handle);
 216     if ( databuf != 0 ) // clean up temporary buffer
 217     {
 218         free(databuf);
 219         databuf = 0;
 220     }
 221     if ( res != CURLE_OK )
 222     {
 223         numretries++;
 224         if ( specialcase != 0 )
 225         {
 226             printf("<<<<<<<<<<< bitcoind_RPC.(%s): BTCD.%s timeout params.(%s) s.ptr.(%s) err.%d\n",url,command,params,s.ptr,res);
 227             free(s.ptr);
 228             return(0);
 229         }
 230         else if ( numretries >= 1 )
 231         {
 232             //printf("Maximum number of retries exceeded!\n");
 233             free(s.ptr);
 234             return(0);
 235         }
 236         if ( (rand() % 1000) == 0 )
 237             printf( "curl_easy_perform() failed: %s %s.(%s %s), retries: %d\n",curl_easy_strerror(res),debugstr,url,command,numretries);
 238         free(s.ptr);
 239         sleep((1<<numretries));
 240         goto try_again;
 241
 242     }
 243     else
 244     {
 245         if ( command != 0 && specialcase == 0 )
 246         {
 247             count++;
 248             elapsedsum += (OS_milliseconds() - starttime);
 249             if ( (count % 1000000) == 0)
 250                 printf("%d: ave %9.6f | elapsed %.3f millis | bitcoind_RPC.(%s) url.(%s)\n",count,elapsedsum/count,(OS_milliseconds() - starttime),command,url);
 251             if ( retstrp != 0 )
 252             {
 253                 *retstrp = s.ptr;
 254                 return(s.ptr);
 255             }
 256             return(post_process_bitcoind_RPC(debugstr,command,s.ptr,params));
 257         }
 258         else
 259         {
 260             if ( 0 && specialcase != 0 )
 261                 fprintf(stderr,"<<<<<<<<<<< bitcoind_RPC: BTCD.(%s) -> (%s)\n",params,s.ptr);
 262             count2++;
 263             elapsedsum2 += (OS_milliseconds() - starttime);
 264             if ( (count2 % 10000) == 0)
 265                 printf("%d: ave %9.6f | elapsed %.3f millis | NXT calls.(%s) cmd.(%s)\n",count2,elapsedsum2/count2,(double)(OS_milliseconds() - starttime),url,command);
 266             return(s.ptr);
 267         }
 268     }
 269     printf("bitcoind_RPC: impossible case\n");
 270     free(s.ptr);
 271     return(0);
 272 }
 273
 274 static size_t WriteMemoryCallback(void *ptr,size_t size,size_t nmemb,void *data)
 275 {
 276     size_t realsize = (size * nmemb);
 277     struct MemoryStruct *mem = (struct MemoryStruct *)data;
 278     mem->memory = (char *)((ptr != 0) ? realloc(mem->memory,mem->size + realsize + 1) : malloc(mem->size + realsize + 1));
 279     if ( mem->memory != 0 )
 280     {
 281         if ( ptr != 0 )
 282             memcpy(&(mem->memory[mem->size]),ptr,realsize);
 283         mem->size += realsize;
 284         mem->memory[mem->size] = 0;
 285     }
 286     //printf("got %d bytes\n",(int32_t)(size*nmemb));
 287     return(realsize);
 288 }
 289
 290 char *curl_post(CURL **cHandlep,char *url,char *userpass,char *postfields,char *hdr0,char *hdr1,char *hdr2,char *hdr3)
 291 {
 292     struct MemoryStruct chunk; CURL *cHandle; long code; struct curl_slist *headers = 0;
 293     if ( (cHandle= *cHandlep) == NULL )
 294                 *cHandlep = cHandle = curl_easy_init();
 295     else curl_easy_reset(cHandle);
 296     //#ifdef DEBUG
 297         //curl_easy_setopt(cHandle,CURLOPT_VERBOSE, 1);
 298     //#endif
 299         curl_easy_setopt(cHandle,CURLOPT_USERAGENT,"mozilla/4.0");//"Mozilla/4.0 (compatible; )");
 300         curl_easy_setopt(cHandle,CURLOPT_SSL_VERIFYPEER,0);
 301         //curl_easy_setopt(cHandle,CURLOPT_SSLVERSION,1);
 302         curl_easy_setopt(cHandle,CURLOPT_URL,url);
 303         curl_easy_setopt(cHandle,CURLOPT_CONNECTTIMEOUT,10);
 304     if ( userpass != 0 && userpass[0] != 0 )
 305         curl_easy_setopt(cHandle,CURLOPT_USERPWD,userpass);
 306         if ( postfields != 0 && postfields[0] != 0 )
 307     {
 308         curl_easy_setopt(cHandle,CURLOPT_POST,1);
 309                 curl_easy_setopt(cHandle,CURLOPT_POSTFIELDS,postfields);
 310     }
 311     if ( hdr0 != NULL && hdr0[0] != 0 )
 312     {
 313         //printf("HDR0.(%s) HDR1.(%s) HDR2.(%s) HDR3.(%s)\n",hdr0!=0?hdr0:"",hdr1!=0?hdr1:"",hdr2!=0?hdr2:"",hdr3!=0?hdr3:"");
 314         headers = curl_slist_append(headers,hdr0);
 315         if ( hdr1 != 0 && hdr1[0] != 0 )
 316             headers = curl_slist_append(headers,hdr1);
 317         if ( hdr2 != 0 && hdr2[0] != 0 )
 318             headers = curl_slist_append(headers,hdr2);
 319         if ( hdr3 != 0 && hdr3[0] != 0 )
 320             headers = curl_slist_append(headers,hdr3);
 321     } //headers = curl_slist_append(0,"Expect:");
 322     if ( headers != 0 )
 323         curl_easy_setopt(cHandle,CURLOPT_HTTPHEADER,headers);
 324     //res = curl_easy_perform(cHandle);
 325     memset(&chunk,0,sizeof(chunk));
 326     curl_easy_setopt(cHandle,CURLOPT_WRITEFUNCTION,WriteMemoryCallback);
 327     curl_easy_setopt(cHandle,CURLOPT_WRITEDATA,(void *)&chunk);
 328     curl_easy_perform(cHandle);
 329     curl_easy_getinfo(cHandle,CURLINFO_RESPONSE_CODE,&code);
 330     if ( headers != 0 )
 331         curl_slist_free_all(headers);
 332     if ( code != 200 )
 333         printf("(%s) server responded with code %ld (%s)\n",url,code,chunk.memory);
 334     return(chunk.memory);
 335 }
 336
 337 char *komodo_issuemethod(char *userpass,char *method,char *params,uint16_t port)
 338 {
 339     //static void *cHandle;
 340     char url[512],*retstr=0,*retstr2=0,postdata[8192];
 341     if ( params == 0 || params[0] == 0 )
 342         params = (char *)"[]";
 343     if ( strlen(params) < sizeof(postdata)-128 )
 344     {
 345         sprintf(url,(char *)"http://127.0.0.1:%u",port);
 346         sprintf(postdata,"{\"method\":\"%s\",\"params\":%s}",method,params);
 347         //printf("[%s] (%s) postdata.(%s) params.(%s) USERPASS.(%s)\n",ASSETCHAINS_SYMBOL,url,postdata,params,KMDUSERPASS);
 348         retstr2 = bitcoind_RPC(&retstr,(char *)"debug",url,userpass,method,params);
 349         //retstr = curl_post(&cHandle,url,USERPASS,postdata,0,0,0,0);
 350     }
 351     return(retstr2);
 352 }
 353
 354 int32_t notarizedtxid_height(char *dest,char *txidstr,int32_t *kmdnotarized_heightp)
 355 {
 356     char *jsonstr,params[256],*userpass; uint16_t port; cJSON *json,*item; int32_t height = 0,txid_height = 0,txid_confirmations = 0;
 357     params[0] = 0;
 358     *kmdnotarized_heightp = 0;
 359     if ( strcmp(dest,"KMD") == 0 )
 360     {
 361         port = KMD_PORT;
 362         userpass = KMDUSERPASS;
 363     }
 364     else if ( strcmp(dest,"BTC") == 0 )
 365     {
 366         port = 8332;
 367         userpass = BTCUSERPASS;
 368     }
 369     else return(0);
 370     if ( userpass[0] != 0 )
 371     {
 372         if ( (jsonstr= komodo_issuemethod(userpass,(char *)"getinfo",params,port)) != 0 )
 373         {
 374             //printf("(%s)\n",jsonstr);
 375             if ( (json= cJSON_Parse(jsonstr)) != 0 )
 376             {
 377                 if ( (item= jobj(json,(char *)"result")) != 0 )
 378                 {
 379                     height = jint(item,(char *)"blocks");
 380                     *kmdnotarized_heightp = strcmp(dest,"KMD") == 0 ? jint(item,(char *)"notarized") : height;
 381                 }
 382                 free_json(json);
 383             }
 384             free(jsonstr);
 385         }
 386         sprintf(params,"[\"%s\", 1]",txidstr);
 387         if ( (jsonstr= komodo_issuemethod(userpass,(char *)"getrawtransaction",params,port)) != 0 )
 388         {
 389             //printf("(%s)\n",jsonstr);
 390             if ( (json= cJSON_Parse(jsonstr)) != 0 )
 391             {
 392                 if ( (item= jobj(json,(char *)"result")) != 0 )
 393                 {
 394                     txid_confirmations = jint(item,(char *)"confirmations");
 395                     if ( txid_confirmations > 0 && height > txid_confirmations )
 396                         txid_height = height - txid_confirmations;
 397                     else txid_height = height;
 398                     //printf("height.%d tconfs.%d txid_height.%d\n",height,txid_confirmations,txid_height);
 399                 }
 400                 free_json(json);
 401             }
 402             free(jsonstr);
 403         }
 404     }
 405     return(txid_height);
 406 }
 407
 408 int32_t komodo_verifynotarizedscript(int32_t height,uint8_t *script,int32_t len,uint256 NOTARIZED_HASH)
 409 {
 410     int32_t i; uint256 hash; char params[256];
 411     for (i=0; i<32; i++)
 412         ((uint8_t *)&hash)[i] = script[2+i];
 413     if ( hash == NOTARIZED_HASH )
 414         return(0);
 415     for (i=0; i<32; i++)
 416         printf("%02x",((uint8_t *)&NOTARIZED_HASH)[i]);
 417     printf(" notarized, ");
 418     for (i=0; i<32; i++)
 419         printf("%02x",((uint8_t *)&hash)[i]);
 420     printf(" opreturn from [%s] ht.%d MISMATCHED\n",ASSETCHAINS_SYMBOL,height);
 421     return(-1);
 422 }
 423
 424 int32_t komodo_verifynotarization(char *symbol,char *dest,int32_t height,int32_t NOTARIZED_HEIGHT,uint256 NOTARIZED_HASH,uint256 NOTARIZED_DESTTXID)
 425 {
 426     char params[256],*jsonstr,*hexstr; uint8_t *script,_script[8192]; int32_t n,len,retval = -1; cJSON *json,*txjson,*vouts,*vout,*skey;
 427     script = _script;
 428     /*params[0] = '[';
 429     params[1] = '"';
 430     for (i=0; i<32; i++)
 431         sprintf(&params[i*2 + 2],"%02x",((uint8_t *)&NOTARIZED_DESTTXID)[31-i]);
 432     strcat(params,"\", 1]");*/
 433     sprintf(params,"[\"%s\", 1]",NOTARIZED_DESTTXID.ToString().c_str());
 434     if ( strcmp(symbol,ASSETCHAINS_SYMBOL[0]==0?(char *)"KMD":ASSETCHAINS_SYMBOL) != 0 )
 435         return(0);
 436     if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 )
 437         printf("[%s] src.%s dest.%s params.[%s] ht.%d notarized.%d\n",ASSETCHAINS_SYMBOL,symbol,dest,params,height,NOTARIZED_HEIGHT);
 438     if ( strcmp(dest,"KMD") == 0 )
 439     {
 440         if ( KMDUSERPASS[0] != 0 )
 441         {
 442             if ( ASSETCHAINS_SYMBOL[0] != 0 )
 443             {
 444                 jsonstr = komodo_issuemethod(KMDUSERPASS,(char *)"getrawtransaction",params,KMD_PORT);
 445 //printf("userpass.(%s) got (%s)\n",KMDUSERPASS,jsonstr);
 446             }
 447         }//else jsonstr = _dex_getrawtransaction();
 448         else return(0); // need universal way to issue DEX* API, since notaries mine most blocks, this ok
 449     }
 450     else if ( strcmp(dest,"BTC") == 0 )
 451     {
 452         if ( BTCUSERPASS[0] != 0 )
 453         {
 454             //printf("BTCUSERPASS.(%s)\n",BTCUSERPASS);
 455             jsonstr = komodo_issuemethod(BTCUSERPASS,(char *)"getrawtransaction",params,8332);
 456         }
 457         //else jsonstr = _dex_getrawtransaction();
 458         else return(0);
 459     }
 460     else
 461     {
 462         printf("[%s] verifynotarization error unexpected dest.(%s)\n",ASSETCHAINS_SYMBOL,dest);
 463         return(-1);
 464     }
 465     if ( jsonstr != 0 )
 466     {
 467         if ( (json= cJSON_Parse(jsonstr)) != 0 )
 468         {
 469             if ( (txjson= jobj(json,(char *)"result")) != 0 && (vouts= jarray(&n,txjson,(char *)"vout")) > 0 )
 470             {
 471                 vout = jitem(vouts,n-1);
 472                 if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 )
 473                     printf("vout.(%s)\n",jprint(vout,0));
 474                 if ( (skey= jobj(vout,(char *)"scriptPubKey")) != 0 )
 475                 {
 476                     if ( (hexstr= jstr(skey,(char *)"hex")) != 0 )
 477                     {
 478                         //printf("HEX.(%s) vs hash.%s\n",hexstr,NOTARIZED_HASH.ToString().c_str());
 479                         len = strlen(hexstr) >> 1;
 480                         decode_hex(script,len,hexstr);
 481                         if ( script[1] == 0x4c )
 482                         {
 483                             script++;
 484                             len--;
 485                         }
 486                         else if ( script[1] == 0x4d )
 487                         {
 488                             script += 2;
 489                             len -= 2;
 490                         }
 491                         retval = komodo_verifynotarizedscript(height,script,len,NOTARIZED_HASH);
 492                     }
 493                 }
 494             }
 495             free_json(txjson);
 496         }
 497         free(jsonstr);
 498     }
 499     return(retval);
 500 }
 501
 502 /*uint256 komodo_getblockhash(int32_t height)
 503 {
 504     uint256 hash; char params[128],*hexstr,*jsonstr; cJSON *result; int32_t i; uint8_t revbuf[32];
 505     memset(&hash,0,sizeof(hash));
 506     sprintf(params,"[%d]",height);
 507     if ( (jsonstr= komodo_issuemethod(KMDUSERPASS,(char *)"getblockhash",params,BITCOIND_PORT)) != 0 )
 508     {
 509         if ( (result= cJSON_Parse(jsonstr)) != 0 )
 510         {
 511             if ( (hexstr= jstr(result,(char *)"result")) != 0 )
 512             {
 513                 if ( is_hexstr(hexstr,0) == 64 )
 514                 {
 515                     decode_hex(revbuf,32,hexstr);
 516                     for (i=0; i<32; i++)
 517                         ((uint8_t *)&hash)[i] = revbuf[31-i];
 518                 }
 519             }
 520             free_json(result);
 521         }
 522         printf("KMD hash.%d (%s) %x\n",height,jsonstr,*(uint32_t *)&hash);
 523         free(jsonstr);
 524     }
 525     return(hash);
 526 }
 527
 528 uint256 _komodo_getblockhash(int32_t height);*/
 529
 530 uint64_t komodo_seed(int32_t height)
 531 {
 532     uint64_t seed = 0;
 533     /*if ( 0 ) // problem during init time, seeds are needed for loading blockindex, so null seeds...
 534     {
 535         uint256 hash,zero; CBlockIndex *pindex;
 536         memset(&hash,0,sizeof(hash));
 537         memset(&zero,0,sizeof(zero));
 538         if ( height > 10 )
 539             height -= 10;
 540         if ( ASSETCHAINS_SYMBOL[0] == 0 )
 541             hash = _komodo_getblockhash(height);
 542         if ( memcmp(&hash,&zero,sizeof(hash)) == 0 )
 543             hash = komodo_getblockhash(height);
 544         int32_t i;
 545         for (i=0; i<32; i++)
 546             printf("%02x",((uint8_t *)&hash)[i]);
 547         printf(" seed.%d\n",height);
 548         seed = arith_uint256(hash.GetHex()).GetLow64();
 549     }
 550     else*/
 551     {
 552         seed = (height << 13) ^ (height << 2);
 553         seed <<= 21;
 554         seed |= (height & 0xffffffff);
 555         seed ^= (seed << 17) ^ (seed << 1);
 556     }
 557     return(seed);
 558 }
 559
 560 uint32_t komodo_txtime(uint256 hash)
 561 {
 562     CTransaction tx;
 563     uint256 hashBlock;
 564     if (!GetTransaction(hash, tx,
 565 #ifndef KOMODO_ZCASH
 566                         Params().GetConsensus(),
 567 #endif
 568                         hashBlock, true))
 569     {
 570         //printf("null GetTransaction\n");
 571         return(tx.nLockTime);
 572     }
 573     return(0);
 574 }
 575
 576 void komodo_disconnect(CBlockIndex *pindex,CBlock& block)
 577 {
 578     char symbol[KOMODO_ASSETCHAIN_MAXLEN],dest[KOMODO_ASSETCHAIN_MAXLEN]; struct komodo_state *sp;
 579     //fprintf(stderr,"disconnect ht.%d\n",pindex->nHeight);
 580     komodo_init(pindex->nHeight);
 581     if ( (sp= komodo_stateptr(symbol,dest)) != 0 )
 582     {
 583         //sp->rewinding = pindex->nHeight;
 584         //fprintf(stderr,"-%d ",pindex->nHeight);
 585     } else printf("komodo_disconnect: ht.%d cant get komodo_state.(%s)\n",pindex->nHeight,ASSETCHAINS_SYMBOL);
 586 }
 587
 588
 589 int32_t komodo_is_notarytx(const CTransaction& tx)
 590 {
 591     uint8_t *ptr; static uint8_t crypto777[33];
 592     if ( tx.vout.size() > 0 )
 593     {
 594 #ifdef KOMODO_ZCASH
 595         ptr = (uint8_t *)tx.vout[0].scriptPubKey.data();
 596 #else
 597         ptr = (uint8_t *)&tx.vout[0].scriptPubKey[0];
 598 #endif
 599         if ( ptr != 0 )
 600         {
 601             if ( crypto777[0] == 0 )
 602                 decode_hex(crypto777,33,(char *)CRYPTO777_PUBSECPSTR);
 603             if ( memcmp(ptr+1,crypto777,33) == 0 )
 604             {
 605                 //printf("found notarytx\n");
 606                 return(1);
 607             }
 608         }
 609     }
 610     return(0);
 611 }
 612
 613 int32_t komodo_block2height(CBlock *block)
 614 {
 615     int32_t i,n,height = 0; uint8_t *ptr;
 616     if ( block->vtx[0].vin.size() > 0 )
 617     {
 618 #ifdef KOMODO_ZCASH
 619         ptr = (uint8_t *)block->vtx[0].vin[0].scriptSig.data();
 620 #else
 621         ptr = (uint8_t *)&block->vtx[0].vin[0].scriptSig[0];
 622 #endif
 623         if ( ptr != 0 && block->vtx[0].vin[0].scriptSig.size() > 5 )
 624         {
 625             //for (i=0; i<6; i++)
 626             //    printf("%02x",ptr[i]);
 627             n = ptr[0];
 628             for (i=0; i<n; i++) // looks strange but this works
 629             {
 630                 //03bb81000101(bb 187) (81 48001) (00 12288256)  <- coinbase.6 ht.12288256
 631                 height += ((uint32_t)ptr[i+1] << (i*8));
 632                 //printf("(%02x %x %d) ",ptr[i+1],((uint32_t)ptr[i+1] << (i*8)),height);
 633             }
 634             //printf(" <- coinbase.%d ht.%d\n",(int32_t)block->vtx[0].vin[0].scriptSig.size(),height);
 635         }
 636         //komodo_init(height);
 637     }
 638     return(height);
 639 }
 640
 641 void komodo_block2pubkey33(uint8_t *pubkey33,CBlock& block)
 642 {
 643     int32_t n;
 644     memset(pubkey33,0,33);
 645     if ( block.vtx[0].vout.size() > 0 )
 646     {
 647 #ifdef KOMODO_ZCASH
 648         uint8_t *ptr = (uint8_t *)block.vtx[0].vout[0].scriptPubKey.data();
 649 #else
 650         uint8_t *ptr = (uint8_t *)&block.vtx[0].vout[0].scriptPubKey[0];
 651 #endif
 652         //komodo_init(0);
 653         n = block.vtx[0].vout[0].scriptPubKey.size();
 654         if ( n == 35 )
 655             memcpy(pubkey33,ptr+1,33);
 656     }
 657 }
 658
 659 int32_t komodo_blockload(CBlock& block,CBlockIndex *pindex)
 660 {
 661     block.SetNull();
 662     // Open history file to read
 663     CAutoFile filein(OpenBlockFile(pindex->GetBlockPos(),true),SER_DISK,CLIENT_VERSION);
 664     if (filein.IsNull())
 665         return(-1);
 666     // Read block
 667     try { filein >> block; }
 668     catch (const std::exception& e)
 669     {
 670         fprintf(stderr,"readblockfromdisk err B\n");
 671         return(-1);
 672     }
 673     return(0);
 674 }
 675
 676 uint32_t komodo_chainactive_timestamp()
 677 {
 678     if ( chainActive.Tip() != 0 )
 679         return((uint32_t)chainActive.Tip()->GetBlockTime());
 680     else return(0);
 681 }
 682
 683 CBlockIndex *komodo_chainactive(int32_t height)
 684 {
 685     if ( chainActive.Tip() != 0 )
 686     {
 687         if ( height <= chainActive.Tip()->nHeight )
 688             return(chainActive[height]);
 689         // else fprintf(stderr,"komodo_chainactive height %d > active.%d\n",height,chainActive.Tip()->nHeight);
 690     }
 691     //fprintf(stderr,"komodo_chainactive null chainActive.Tip() height %d\n",height);
 692     return(0);
 693 }
 694
 695 uint32_t komodo_heightstamp(int32_t height)
 696 {
 697     CBlockIndex *ptr;
 698     if ( height > 0 && (ptr= komodo_chainactive(height)) != 0 )
 699         return(ptr->nTime);
 700     //else fprintf(stderr,"komodo_heightstamp null ptr for block.%d\n",height);
 701     return(0);
 702 }
 703
 704 void komodo_index2pubkey33(uint8_t *pubkey33,CBlockIndex *pindex,int32_t height)
 705 {
 706     CBlock block; int32_t num,i; uint8_t pubkeys[64][33];
 707     //komodo_init(height);
 708     memset(pubkey33,0,33);
 709     if ( pindex != 0 )
 710     {
 711         if ( pindex->pubkey33[0] == 2 || pindex->pubkey33[0] == 3 )
 712         {
 713             memcpy(pubkey33,pindex->pubkey33,33);
 714             return;
 715         }
 716         if ( komodo_blockload(block,pindex) == 0 )
 717         {
 718             komodo_block2pubkey33(pubkey33,block);
 719             if ( pubkey33[0] == 2 || pubkey33[0] == 3 )
 720             {
 721                 memcpy(pindex->pubkey33,pubkey33,33);
 722                 if ( (num= komodo_notaries(pubkeys,(int32_t)pindex->nHeight,(uint32_t)pindex->nTime)) > 0 )
 723                 {
 724                     pindex->notaryid = -1;
 725                     for (i=0; i<num; i++)
 726                     {
 727                         if ( memcmp(pubkeys[i],pubkey33,33) == 0 )
 728                         {
 729                             pindex->notaryid = i;
 730                             break;
 731                         }
 732                     }
 733                 }
 734             } else pindex->notaryid = -1;
 735        }
 736     }
 737     else
 738     {
 739         // height -> pubkey33
 740         //printf("extending chaintip komodo_index2pubkey33 height.%d need to get pubkey33\n",height);
 741     }
 742 }
 743
 744 /*void komodo_connectpindex(CBlockIndex *pindex)
 745 {
 746     CBlock block;
 747     if ( komodo_blockload(block,pindex) == 0 )
 748         komodo_connectblock(pindex,block);
 749 }*/
 750
 751
 752 int8_t komodo_minerid(int32_t height,uint8_t *pubkey33)
 753 {
 754     int32_t num,i,numnotaries; CBlockIndex *pindex; uint32_t timestamp=0; uint8_t _pubkey33[33],pubkeys[64][33];
 755     if ( (pindex= chainActive[height]) != 0 )
 756     {
 757         if ( pindex->pubkey33[0] == 2 || pindex->pubkey33[0] == 3 )
 758         {
 759             if ( pubkey33 != 0 )
 760                 memcpy(pubkey33,pindex->pubkey33,33);
 761             return(pindex->notaryid);
 762         }
 763         if ( pubkey33 != 0 )
 764             komodo_index2pubkey33(pubkey33,pindex,height);
 765         timestamp = pindex->GetBlockTime();
 766         if ( (num= komodo_notaries(pubkeys,height,timestamp)) > 0 )
 767         {
 768             for (i=0; i<num; i++)
 769                 if ( memcmp(pubkeys[i],pubkey33,33) == 0 )
 770                     return(i);
 771         }
 772     }
 773     return(komodo_electednotary(&numnotaries,pubkey33,height,timestamp));
 774 }
 775
 776 int32_t komodo_eligiblenotary(uint8_t pubkeys[66][33],int32_t *mids,int32_t *nonzpkeysp,int32_t height)
 777 {
 778     int32_t i,j,duplicate; CBlockIndex *pindex; uint8_t pubkey33[33];
 779     memset(mids,-1,sizeof(*mids)*66);
 780     for (i=duplicate=0; i<66; i++)
 781     {
 782         if ( (pindex= komodo_chainactive(height-i)) != 0 )
 783         {
 784             if ( pindex->notaryid >= 0 && (pindex->pubkey33[0] == 2 || pindex->pubkey33[0] == 3) )
 785             {
 786                 memcpy(pubkeys[i],pindex->pubkey33,33);
 787                 mids[i] = pindex->notaryid;
 788                 (*nonzpkeysp)++;
 789             }
 790             else
 791             {
 792                 komodo_index2pubkey33(pubkey33,pindex,height-i);
 793                 memcpy(pubkeys[i],pubkey33,33);
 794                 if ( (mids[i]= komodo_minerid(height-i,pubkey33)) >= 0 )
 795                 {
 796                     //mids[i] = *(int32_t *)pubkey33;
 797                     (*nonzpkeysp)++;
 798                 }
 799             }
 800             if ( mids[0] >= 0 && i > 0 && mids[i] == mids[0] )
 801                 duplicate++;
 802         }
 803     }
 804     if ( i == 66 && duplicate == 0 && (height > 186233 || *nonzpkeysp > 0) )
 805         return(1);
 806     else return(0);
 807 }
 808
 809 int32_t komodo_minerids(uint8_t *minerids,int32_t height,int32_t width)
 810 {
 811     int32_t i,n=0;
 812     for (i=0; i<width; i++,n++)
 813     {
 814         if ( height-i <= 0 )
 815             break;
 816         minerids[i] = komodo_minerid(height - i,0);
 817     }
 818     return(n);
 819 }
 820
 821 int32_t komodo_is_special(int32_t height,uint8_t pubkey33[33],uint32_t timestamp)
 822 {
 823     int32_t i,notaryid=0,minerid,limit,nid; //uint8_t _pubkey33[33];
 824     if ( height >= 225000 )
 825         komodo_chosennotary(&notaryid,height,pubkey33,timestamp);
 826     if ( height >= 34000 && notaryid >= 0 )
 827     {
 828         if ( height < 79693 )
 829             limit = 64;
 830         else if ( height < 82000 )
 831             limit = 8;
 832         else limit = 66;
 833         for (i=1; i<limit; i++)
 834         {
 835             komodo_chosennotary(&nid,height-i,pubkey33,timestamp);
 836             if ( nid == notaryid ) //komodo_minerid(height-i,_pubkey33)
 837             {
 838                 if ( (0) && notaryid > 0 )
 839                     fprintf(stderr,"ht.%d notaryid.%d already mined -i.%d nid.%d\n",height,notaryid,i,nid);
 840                 if ( height > 225000 )
 841                     return(-1);
 842             }
 843         }
 844         //fprintf(stderr,"special notaryid.%d ht.%d limit.%d\n",notaryid,height,limit);
 845         return(1);
 846     }
 847     return(0);
 848 }
 849
 850 int32_t komodo_MoM(int32_t *notarized_heightp,uint256 *MoMp,uint256 *kmdtxidp,int32_t nHeight)
 851 {
 852     int32_t depth,notarized_ht; uint256 MoM,kmdtxid;
 853     depth = komodo_MoMdata(&notarized_ht,&MoM,&kmdtxid,nHeight);
 854     memset(MoMp,0,sizeof(*MoMp));
 855     memset(kmdtxidp,0,sizeof(*kmdtxidp));
 856     *notarized_heightp = 0;
 857     if ( depth > 0 && notarized_ht > 0 && nHeight > notarized_ht-depth && nHeight <= notarized_ht )
 858     {
 859         *MoMp = MoM;
 860         *notarized_heightp = notarized_ht;
 861         *kmdtxidp = kmdtxid;
 862     }
 863     return(depth);
 864 }
 865
 866 int32_t komodo_checkpoint(int32_t *notarized_heightp,int32_t nHeight,uint256 hash)
 867 {
 868     int32_t notarized_height,MoMdepth; uint256 MoM,notarized_hash,notarized_desttxid; CBlockIndex *notary; CBlockIndex *pindex;
 869     if ( (pindex= chainActive.Tip()) == 0 )
 870         return(-1);
 871     notarized_height = komodo_notarizeddata(pindex->nHeight,&notarized_hash,&notarized_desttxid);
 872     *notarized_heightp = notarized_height;
 873     if ( notarized_height >= 0 && notarized_height <= pindex->nHeight && (notary= mapBlockIndex[notarized_hash]) != 0 )
 874     {
 875         //printf("nHeight.%d -> (%d %s)\n",pindex->Tip()->nHeight,notarized_height,notarized_hash.ToString().c_str());
 876         if ( notary->nHeight == notarized_height ) // if notarized_hash not in chain, reorg
 877         {
 878             if ( nHeight < notarized_height )
 879             {
 880                 //fprintf(stderr,"[%s] nHeight.%d < NOTARIZED_HEIGHT.%d\n",ASSETCHAINS_SYMBOL,nHeight,notarized_height);
 881                 return(-1);
 882             }
 883             else if ( nHeight == notarized_height && memcmp(&hash,&notarized_hash,sizeof(hash)) != 0 )
 884             {
 885                 fprintf(stderr,"[%s] nHeight.%d == NOTARIZED_HEIGHT.%d, diff hash\n",ASSETCHAINS_SYMBOL,nHeight,notarized_height);
 886                 return(-1);
 887             }
 888         } else fprintf(stderr,"[%s] unexpected error notary_hash %s ht.%d at ht.%d\n",ASSETCHAINS_SYMBOL,notarized_hash.ToString().c_str(),notarized_height,notary->nHeight);
 889     }
 890     else if ( notarized_height > 0 && notarized_height != 73880 && notarized_height >= 170000 )
 891         fprintf(stderr,"[%s] couldnt find notarized.(%s %d) ht.%d\n",ASSETCHAINS_SYMBOL,notarized_hash.ToString().c_str(),notarized_height,pindex->nHeight);
 892     return(0);
 893 }
 894
 895 uint32_t komodo_interest_args(uint32_t *txheighttimep,int32_t *txheightp,uint32_t *tiptimep,uint64_t *valuep,uint256 hash,int32_t n)
 896 {
 897     LOCK(cs_main);
 898     CTransaction tx; uint256 hashBlock; CBlockIndex *pindex,*tipindex;
 899     *txheighttimep = *txheightp = *tiptimep = 0;
 900     *valuep = 0;
 901     if ( !GetTransaction(hash,tx,hashBlock,true) )
 902         return(0);
 903     uint32_t locktime = 0;
 904     if ( n < tx.vout.size() )
 905     {
 906         if ( (pindex= mapBlockIndex[hashBlock]) != 0 && (tipindex= chainActive.Tip()) != 0 )
 907         {
 908             *valuep = tx.vout[n].nValue;
 909             *txheightp = pindex->nHeight;
 910             *txheighttimep = pindex->nTime;
 911             *tiptimep = tipindex->nTime;
 912             locktime = tx.nLockTime;
 913             //fprintf(stderr,"tx locktime.%u %.8f height.%d | tiptime.%u\n",locktime,(double)*valuep/COIN,*txheightp,*tiptimep);
 914         }
 915     }
 916     return(locktime);
 917 }
 918
 919 uint64_t komodo_interest(int32_t txheight,uint64_t nValue,uint32_t nLockTime,uint32_t tiptime);
 920 uint64_t komodo_accrued_interest(int32_t *txheightp,uint32_t *locktimep,uint256 hash,int32_t n,int32_t checkheight,uint64_t checkvalue)
 921 {
 922     uint64_t value; uint32_t tiptime,txheighttimep;
 923     if ( (*locktimep= komodo_interest_args(&txheighttimep,txheightp,&tiptime,&value,hash,n)) != 0 )
 924     {
 925         if ( (checkvalue == 0 || value == checkvalue) && (checkheight == 0 || *txheightp == checkheight) )
 926             return(komodo_interest(*txheightp,value,*locktimep,tiptime));
 927         //fprintf(stderr,"nValue %llu lock.%u:%u nTime.%u -> %llu\n",(long long)coins.vout[n].nValue,coins.nLockTime,timestamp,pindex->nTime,(long long)interest);
 928         else fprintf(stderr,"komodo_accrued_interest value mismatch %llu vs %llu or height mismatch %d vs %d\n",(long long)value,(long long)checkvalue,*txheightp,checkheight);
 929     }
 930     return(0);
 931 }
 932
 933 int32_t komodo_isrealtime(int32_t *kmdheightp)
 934 {
 935     struct komodo_state *sp; CBlockIndex *pindex;
 936     if ( (sp= komodo_stateptrget((char *)"KMD")) != 0 )
 937         *kmdheightp = sp->CURRENT_HEIGHT;
 938     else *kmdheightp = 0;
 939     if ( (pindex= chainActive.Tip()) != 0 && pindex->nHeight >= (int32_t)komodo_longestchain() )
 940         return(1);
 941     else return(0);
 942 }
 943
 944 int32_t komodo_validate_interest(const CTransaction &tx,int32_t txheight,uint32_t nTime,int32_t dispflag)
 945 {
 946     uint32_t cmptime = nTime;
 947     if ( KOMODO_REWIND == 0 && ASSETCHAINS_SYMBOL[0] == 0 && (int64_t)tx.nLockTime >= LOCKTIME_THRESHOLD ) //1473793441 )
 948     {
 949         if ( txheight > 246748 )
 950         {
 951             if ( txheight < 247205 )
 952                 cmptime -= 16000;
 953             if ( (int64_t)tx.nLockTime < cmptime-3600 )
 954             {
 955                 if ( tx.nLockTime != 1477258935 || dispflag != 0 )
 956                 {
 957                     fprintf(stderr,"komodo_validate_interest.%d reject.%d [%d] locktime %u cmp2.%u\n",dispflag,txheight,(int32_t)(tx.nLockTime - (cmptime-3600)),(uint32_t)tx.nLockTime,cmptime);
 958                 }
 959                 return(-1);
 960             }
 961             if ( 0 && dispflag != 0 )
 962                 fprintf(stderr,"validateinterest.%d accept.%d [%d] locktime %u cmp2.%u\n",dispflag,(int32_t)txheight,(int32_t)(tx.nLockTime - (cmptime-3600)),(int32_t)tx.nLockTime,cmptime);
 963         }
 964     }
 965     return(0);
 966 }