src/komodo.h

   1 /******************************************************************************
   2  * Copyright © 2014-2018 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 #ifndef H_KOMODO_H
  17 #define H_KOMODO_H
  18 #include "komodo_defs.h"
  19
  20 #ifdef _WIN32
  21 #define printf(...)
  22 #endif
  23
  24 // Todo:
  25 // verify: reorgs
  26
  27 #define KOMODO_ASSETCHAINS_WAITNOTARIZE
  28 #define KOMODO_PAXMAX (10000 * COIN)
  29
  30 #include <stdint.h>
  31 #include <stdio.h>
  32 #include <pthread.h>
  33 #include <ctype.h>
  34 #include "uthash.h"
  35 #include "utlist.h"
  36
  37 int32_t gettxout_scriptPubKey(uint8_t *scriptPubkey,int32_t maxsize,uint256 txid,int32_t n);
  38 void komodo_event_rewind(struct komodo_state *sp,char *symbol,int32_t height);
  39 void komodo_connectblock(CBlockIndex *pindex,CBlock& block);
  40
  41 #include "komodo_structs.h"
  42 #include "komodo_globals.h"
  43 #include "komodo_utils.h"
  44 #include "komodo_curve25519.h"
  45
  46 #include "komodo_cJSON.c"
  47 #include "komodo_bitcoind.h"
  48 #include "komodo_interest.h"
  49 #include "komodo_pax.h"
  50 #include "komodo_notary.h"
  51
  52 int32_t komodo_parsestatefile(struct komodo_state *sp,FILE *fp,char *symbol,char *dest);
  53 #include "komodo_kv.h"
  54 #include "komodo_jumblr.h"
  55 #include "komodo_gateway.h"
  56 #include "komodo_events.h"
  57 #include "komodo_ccdata.h"
  58
  59 void komodo_currentheight_set(int32_t height)
  60 {
  61     char symbol[KOMODO_ASSETCHAIN_MAXLEN],dest[KOMODO_ASSETCHAIN_MAXLEN]; struct komodo_state *sp;
  62     if ( (sp= komodo_stateptr(symbol,dest)) != 0 )
  63         sp->CURRENT_HEIGHT = height;
  64 }
  65
  66 int32_t komodo_currentheight()
  67 {
  68     char symbol[KOMODO_ASSETCHAIN_MAXLEN],dest[KOMODO_ASSETCHAIN_MAXLEN]; struct komodo_state *sp;
  69     if ( (sp= komodo_stateptr(symbol,dest)) != 0 )
  70         return(sp->CURRENT_HEIGHT);
  71     else return(0);
  72 }
  73
  74 int32_t komodo_parsestatefile(struct komodo_state *sp,FILE *fp,char *symbol,char *dest)
  75 {
  76     static int32_t errs;
  77     int32_t func,ht,notarized_height,num,matched=0,MoMdepth; uint256 MoM,notarized_hash,notarized_desttxid; uint8_t pubkeys[64][33];
  78     if ( (func= fgetc(fp)) != EOF )
  79     {
  80         if ( ASSETCHAINS_SYMBOL[0] == 0 && strcmp(symbol,"KMD") == 0 )
  81             matched = 1;
  82         else matched = (strcmp(symbol,ASSETCHAINS_SYMBOL) == 0);
  83         if ( fread(&ht,1,sizeof(ht),fp) != sizeof(ht) )
  84             errs++;
  85         if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 && func != 'T' )
  86             printf("[%s] matched.%d fpos.%ld func.(%d %c) ht.%d\n",ASSETCHAINS_SYMBOL,matched,ftell(fp),func,func,ht);
  87         if ( func == 'P' )
  88         {
  89             if ( (num= fgetc(fp)) <= 64 )
  90             {
  91                 if ( fread(pubkeys,33,num,fp) != num )
  92                     errs++;
  93                 else
  94                 {
  95                     //printf("updated %d pubkeys at %s ht.%d\n",num,symbol,ht);
  96                     if ( (KOMODO_EXTERNAL_NOTARIES != 0 && matched != 0) || (strcmp(symbol,"KMD") == 0 && KOMODO_EXTERNAL_NOTARIES == 0) )
  97                         komodo_eventadd_pubkeys(sp,symbol,ht,num,pubkeys);
  98                 }
  99             } else printf("illegal num.%d\n",num);
 100         }
 101         else if ( func == 'N' || func == 'M' )
 102         {
 103             if ( fread(&notarized_height,1,sizeof(notarized_height),fp) != sizeof(notarized_height) )
 104                 errs++;
 105             if ( fread(&notarized_hash,1,sizeof(notarized_hash),fp) != sizeof(notarized_hash) )
 106                 errs++;
 107             if ( fread(&notarized_desttxid,1,sizeof(notarized_desttxid),fp) != sizeof(notarized_desttxid) )
 108                 errs++;
 109             if ( func == 'M' )
 110             {
 111                 if ( fread(&MoM,1,sizeof(MoM),fp) != sizeof(MoM) )
 112                     errs++;
 113                 if ( fread(&MoMdepth,1,sizeof(MoMdepth),fp) != sizeof(MoMdepth) )
 114                     errs++;
 115                 if ( 1 && ASSETCHAINS_SYMBOL[0] != 0 && sp != 0 )
 116                     printf("%s load[%s.%d -> %s] NOTARIZED %d %s MoM.%s %d\n",ASSETCHAINS_SYMBOL,symbol,sp->NUM_NPOINTS,dest,notarized_height,notarized_hash.ToString().c_str(),MoM.ToString().c_str(),MoMdepth);
 117             }
 118             else
 119             {
 120                 memset(&MoM,0,sizeof(MoM));
 121                 MoMdepth = 0;
 122             }
 123             //if ( matched != 0 ) global independent states -> inside *sp
 124             komodo_eventadd_notarized(sp,symbol,ht,dest,notarized_hash,notarized_desttxid,notarized_height,MoM,MoMdepth);
 125         }
 126         else if ( func == 'U' ) // deprecated
 127         {
 128             uint8_t n,nid; uint256 hash; uint64_t mask;
 129             n = fgetc(fp);
 130             nid = fgetc(fp);
 131             //printf("U %d %d\n",n,nid);
 132             if ( fread(&mask,1,sizeof(mask),fp) != sizeof(mask) )
 133                 errs++;
 134             if ( fread(&hash,1,sizeof(hash),fp) != sizeof(hash) )
 135                 errs++;
 136             //if ( matched != 0 )
 137             //    komodo_eventadd_utxo(sp,symbol,ht,nid,hash,mask,n);
 138         }
 139         else if ( func == 'K' )
 140         {
 141             int32_t kheight;
 142             if ( fread(&kheight,1,sizeof(kheight),fp) != sizeof(kheight) )
 143                 errs++;
 144             //if ( matched != 0 ) global independent states -> inside *sp
 145             //printf("%s.%d load[%s] ht.%d\n",ASSETCHAINS_SYMBOL,ht,symbol,kheight);
 146             komodo_eventadd_kmdheight(sp,symbol,ht,kheight,0);
 147         }
 148         else if ( func == 'T' )
 149         {
 150             int32_t kheight,ktimestamp;
 151             if ( fread(&kheight,1,sizeof(kheight),fp) != sizeof(kheight) )
 152                 errs++;
 153             if ( fread(&ktimestamp,1,sizeof(ktimestamp),fp) != sizeof(ktimestamp) )
 154                 errs++;
 155             //if ( matched != 0 ) global independent states -> inside *sp
 156             //printf("%s.%d load[%s] ht.%d t.%u\n",ASSETCHAINS_SYMBOL,ht,symbol,kheight,ktimestamp);
 157             komodo_eventadd_kmdheight(sp,symbol,ht,kheight,ktimestamp);
 158         }
 159         else if ( func == 'R' )
 160         {
 161             uint16_t olen,v; uint64_t ovalue; uint256 txid; uint8_t opret[16384];
 162             if ( fread(&txid,1,sizeof(txid),fp) != sizeof(txid) )
 163                 errs++;
 164             if ( fread(&v,1,sizeof(v),fp) != sizeof(v) )
 165                 errs++;
 166             if ( fread(&ovalue,1,sizeof(ovalue),fp) != sizeof(ovalue) )
 167                 errs++;
 168             if ( fread(&olen,1,sizeof(olen),fp) != sizeof(olen) )
 169                 errs++;
 170             if ( olen < sizeof(opret) )
 171             {
 172                 if ( fread(opret,1,olen,fp) != olen )
 173                     errs++;
 174                 if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 && matched != 0 )
 175                 {
 176                     int32_t i;  for (i=0; i<olen; i++)
 177                         printf("%02x",opret[i]);
 178                     printf(" %s.%d load[%s] opret[%c] len.%d %.8f\n",ASSETCHAINS_SYMBOL,ht,symbol,opret[0],olen,(double)ovalue/COIN);
 179                 }
 180                 komodo_eventadd_opreturn(sp,symbol,ht,txid,ovalue,v,opret,olen); // global shared state -> global PAX
 181             } else
 182             {
 183                 int32_t i;
 184                 for (i=0; i<olen; i++)
 185                     fgetc(fp);
 186                 //printf("illegal olen.%u\n",olen);
 187             }
 188         }
 189         else if ( func == 'D' )
 190         {
 191             printf("unexpected function D[%d]\n",ht);
 192         }
 193         else if ( func == 'V' )
 194         {
 195             int32_t numpvals; uint32_t pvals[128];
 196             numpvals = fgetc(fp);
 197             if ( numpvals*sizeof(uint32_t) <= sizeof(pvals) && fread(pvals,sizeof(uint32_t),numpvals,fp) == numpvals )
 198             {
 199                 //if ( matched != 0 ) global shared state -> global PVALS
 200                 //printf("%s load[%s] prices %d\n",ASSETCHAINS_SYMBOL,symbol,ht);
 201                 komodo_eventadd_pricefeed(sp,symbol,ht,pvals,numpvals);
 202                 //printf("load pvals ht.%d numpvals.%d\n",ht,numpvals);
 203             } else printf("error loading pvals[%d]\n",numpvals);
 204         }
 205         else printf("[%s] %s illegal func.(%d %c)\n",ASSETCHAINS_SYMBOL,symbol,func,func);
 206         return(func);
 207     } else return(-1);
 208 }
 209
 210 int32_t memread(void *dest,int32_t size,uint8_t *filedata,long *fposp,long datalen)
 211 {
 212     if ( *fposp+size <= datalen )
 213     {
 214         memcpy(dest,&filedata[*fposp],size);
 215         (*fposp) += size;
 216         return(size);
 217     }
 218     return(-1);
 219 }
 220
 221 int32_t komodo_parsestatefiledata(struct komodo_state *sp,uint8_t *filedata,long *fposp,long datalen,char *symbol,char *dest)
 222 {
 223     static int32_t errs;
 224     int32_t func= -1,ht,notarized_height,MoMdepth,num,matched=0; uint256 MoM,notarized_hash,notarized_desttxid; uint8_t pubkeys[64][33]; long fpos = *fposp;
 225     if ( fpos < datalen )
 226     {
 227         func = filedata[fpos++];
 228         if ( ASSETCHAINS_SYMBOL[0] == 0 && strcmp(symbol,"KMD") == 0 )
 229             matched = 1;
 230         else matched = (strcmp(symbol,ASSETCHAINS_SYMBOL) == 0);
 231         if ( memread(&ht,sizeof(ht),filedata,&fpos,datalen) != sizeof(ht) )
 232             errs++;
 233         if ( func == 'P' )
 234         {
 235             if ( (num= filedata[fpos++]) <= 64 )
 236             {
 237                 if ( memread(pubkeys,33*num,filedata,&fpos,datalen) != 33*num )
 238                     errs++;
 239                 else
 240                 {
 241                     //printf("updated %d pubkeys at %s ht.%d\n",num,symbol,ht);
 242                     if ( (KOMODO_EXTERNAL_NOTARIES != 0 && matched != 0) || (strcmp(symbol,"KMD") == 0 && KOMODO_EXTERNAL_NOTARIES == 0) )
 243                         komodo_eventadd_pubkeys(sp,symbol,ht,num,pubkeys);
 244                 }
 245             } else printf("illegal num.%d\n",num);
 246         }
 247         else if ( func == 'N' || func == 'M' )
 248         {
 249             if ( memread(&notarized_height,sizeof(notarized_height),filedata,&fpos,datalen) != sizeof(notarized_height) )
 250                 errs++;
 251             if ( memread(&notarized_hash,sizeof(notarized_hash),filedata,&fpos,datalen) != sizeof(notarized_hash) )
 252                 errs++;
 253             if ( memread(&notarized_desttxid,sizeof(notarized_desttxid),filedata,&fpos,datalen) != sizeof(notarized_desttxid) )
 254                 errs++;
 255             if ( func == 'M' )
 256             {
 257                 if ( memread(&MoM,sizeof(MoM),filedata,&fpos,datalen) != sizeof(MoM) )
 258                     errs++;
 259                 if ( memread(&MoMdepth,sizeof(MoMdepth),filedata,&fpos,datalen) != sizeof(MoMdepth) )
 260                     errs++;
 261                 if ( 1 && ASSETCHAINS_SYMBOL[0] != 0 && sp != 0 )
 262                     printf("%s load[%s.%d -> %s] NOTARIZED %d %s MoM.%s %d\n",ASSETCHAINS_SYMBOL,symbol,sp->NUM_NPOINTS,dest,notarized_height,notarized_hash.ToString().c_str(),MoM.ToString().c_str(),MoMdepth);
 263             }
 264             else
 265             {
 266                 memset(&MoM,0,sizeof(MoM));
 267                 MoMdepth = 0;
 268             }
 269             komodo_eventadd_notarized(sp,symbol,ht,dest,notarized_hash,notarized_desttxid,notarized_height,MoM,MoMdepth);
 270         }
 271         else if ( func == 'U' ) // deprecated
 272         {
 273             uint8_t n,nid; uint256 hash; uint64_t mask;
 274             n = filedata[fpos++];
 275             nid = filedata[fpos++];
 276             //printf("U %d %d\n",n,nid);
 277             if ( memread(&mask,sizeof(mask),filedata,&fpos,datalen) != sizeof(mask) )
 278                 errs++;
 279             if ( memread(&hash,sizeof(hash),filedata,&fpos,datalen) != sizeof(hash) )
 280                 errs++;
 281         }
 282         else if ( func == 'K' )
 283         {
 284             int32_t kheight;
 285             if ( memread(&kheight,sizeof(kheight),filedata,&fpos,datalen) != sizeof(kheight) )
 286                 errs++;
 287              komodo_eventadd_kmdheight(sp,symbol,ht,kheight,0);
 288         }
 289         else if ( func == 'T' )
 290         {
 291             int32_t kheight,ktimestamp;
 292             if ( memread(&kheight,sizeof(kheight),filedata,&fpos,datalen) != sizeof(kheight) )
 293                 errs++;
 294             if ( memread(&ktimestamp,sizeof(ktimestamp),filedata,&fpos,datalen) != sizeof(ktimestamp) )
 295                 errs++;
 296             //if ( matched != 0 ) global independent states -> inside *sp
 297             //printf("%s.%d load[%s] ht.%d t.%u\n",ASSETCHAINS_SYMBOL,ht,symbol,kheight,ktimestamp);
 298             komodo_eventadd_kmdheight(sp,symbol,ht,kheight,ktimestamp);
 299         }
 300         else if ( func == 'R' )
 301         {
 302             uint16_t olen,v; uint64_t ovalue; uint256 txid; uint8_t opret[16384];
 303             if ( memread(&txid,sizeof(txid),filedata,&fpos,datalen) != sizeof(txid) )
 304                 errs++;
 305             if ( memread(&v,sizeof(v),filedata,&fpos,datalen) != sizeof(v) )
 306                 errs++;
 307             if ( memread(&ovalue,sizeof(ovalue),filedata,&fpos,datalen) != sizeof(ovalue) )
 308                 errs++;
 309             if ( memread(&olen,sizeof(olen),filedata,&fpos,datalen) != sizeof(olen) )
 310                 errs++;
 311             if ( olen < sizeof(opret) )
 312             {
 313                 if ( memread(opret,olen,filedata,&fpos,datalen) != olen )
 314                     errs++;
 315                 if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 && matched != 0 )
 316                 {
 317                     int32_t i;  for (i=0; i<olen; i++)
 318                         printf("%02x",opret[i]);
 319                     printf(" %s.%d load[%s] opret[%c] len.%d %.8f\n",ASSETCHAINS_SYMBOL,ht,symbol,opret[0],olen,(double)ovalue/COIN);
 320                 }
 321                 komodo_eventadd_opreturn(sp,symbol,ht,txid,ovalue,v,opret,olen); // global shared state -> global PAX
 322             } else
 323             {
 324                 int32_t i;
 325                 for (i=0; i<olen; i++)
 326                     filedata[fpos++];
 327                 //printf("illegal olen.%u\n",olen);
 328             }
 329         }
 330         else if ( func == 'D' )
 331         {
 332             printf("unexpected function D[%d]\n",ht);
 333         }
 334         else if ( func == 'V' )
 335         {
 336             int32_t numpvals; uint32_t pvals[128];
 337             numpvals = filedata[fpos++];
 338             if ( numpvals*sizeof(uint32_t) <= sizeof(pvals) && memread(pvals,(int32_t)(sizeof(uint32_t)*numpvals),filedata,&fpos,datalen) == numpvals*sizeof(uint32_t) )
 339             {
 340                 //if ( matched != 0 ) global shared state -> global PVALS
 341                 //printf("%s load[%s] prices %d\n",ASSETCHAINS_SYMBOL,symbol,ht);
 342                 komodo_eventadd_pricefeed(sp,symbol,ht,pvals,numpvals);
 343                 //printf("load pvals ht.%d numpvals.%d\n",ht,numpvals);
 344             } else printf("error loading pvals[%d]\n",numpvals);
 345         }
 346         else printf("[%s] %s illegal func.(%d %c)\n",ASSETCHAINS_SYMBOL,symbol,func,func);
 347         *fposp = fpos;
 348         return(func);
 349     }
 350     return(-1);
 351 }
 352
 353 void komodo_stateupdate(int32_t height,uint8_t notarypubs[][33],uint8_t numnotaries,uint8_t notaryid,uint256 txhash,uint64_t voutmask,uint8_t numvouts,uint32_t *pvals,uint8_t numpvals,int32_t KMDheight,uint32_t KMDtimestamp,uint64_t opretvalue,uint8_t *opretbuf,uint16_t opretlen,uint16_t vout,uint256 MoM,int32_t MoMdepth)
 354 {
 355     static FILE *fp; static int32_t errs,didinit; static uint256 zero;
 356     struct komodo_state *sp; char fname[512],symbol[KOMODO_ASSETCHAIN_MAXLEN],dest[KOMODO_ASSETCHAIN_MAXLEN]; int32_t retval,ht,func; uint8_t num,pubkeys[64][33];
 357     if ( didinit == 0 )
 358     {
 359         portable_mutex_init(&KOMODO_KV_mutex);
 360         portable_mutex_init(&KOMODO_CC_mutex);
 361         didinit = 1;
 362     }
 363     if ( (sp= komodo_stateptr(symbol,dest)) == 0 )
 364     {
 365         KOMODO_INITDONE = (uint32_t)time(NULL);
 366         printf("[%s] no komodo_stateptr\n",ASSETCHAINS_SYMBOL);
 367         return;
 368     }
 369     //printf("[%s] (%s) -> (%s)\n",ASSETCHAINS_SYMBOL,symbol,dest);
 370     if ( fp == 0 )
 371     {
 372         komodo_statefname(fname,ASSETCHAINS_SYMBOL,(char *)"komodostate");
 373         if ( (fp= fopen(fname,"rb+")) != 0 )
 374         {
 375             if ( (retval= komodo_faststateinit(sp,fname,symbol,dest)) > 0 )
 376                 fseek(fp,0,SEEK_END);
 377             else
 378             {
 379                 fprintf(stderr,"komodo_faststateinit retval.%d\n",retval);
 380                 while ( komodo_parsestatefile(sp,fp,symbol,dest) >= 0 )
 381                     ;
 382             }
 383         } else fp = fopen(fname,"wb+");
 384         KOMODO_INITDONE = (uint32_t)time(NULL);
 385     }
 386     if ( height <= 0 )
 387     {
 388         //printf("early return: stateupdate height.%d\n",height);
 389         return;
 390     }
 391     if ( fp != 0 ) // write out funcid, height, other fields, call side effect function
 392     {
 393         //printf("fpos.%ld ",ftell(fp));
 394         if ( KMDheight != 0 )
 395         {
 396             if ( KMDtimestamp != 0 )
 397             {
 398                 fputc('T',fp);
 399                 if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
 400                     errs++;
 401                 if ( fwrite(&KMDheight,1,sizeof(KMDheight),fp) != sizeof(KMDheight) )
 402                     errs++;
 403                 if ( fwrite(&KMDtimestamp,1,sizeof(KMDtimestamp),fp) != sizeof(KMDtimestamp) )
 404                     errs++;
 405             }
 406             else
 407             {
 408                 fputc('K',fp);
 409                 if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
 410                     errs++;
 411                 if ( fwrite(&KMDheight,1,sizeof(KMDheight),fp) != sizeof(KMDheight) )
 412                     errs++;
 413             }
 414             komodo_eventadd_kmdheight(sp,symbol,height,KMDheight,KMDtimestamp);
 415         }
 416         else if ( opretbuf != 0 && opretlen > 0 )
 417         {
 418             uint16_t olen = opretlen;
 419             fputc('R',fp);
 420             if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
 421                 errs++;
 422             if ( fwrite(&txhash,1,sizeof(txhash),fp) != sizeof(txhash) )
 423                 errs++;
 424             if ( fwrite(&vout,1,sizeof(vout),fp) != sizeof(vout) )
 425                 errs++;
 426             if ( fwrite(&opretvalue,1,sizeof(opretvalue),fp) != sizeof(opretvalue) )
 427                 errs++;
 428             if ( fwrite(&olen,1,sizeof(olen),fp) != olen )
 429                 errs++;
 430             if ( fwrite(opretbuf,1,olen,fp) != olen )
 431                 errs++;
 432 //printf("ht.%d R opret[%d] sp.%p\n",height,olen,sp);
 433             //komodo_opreturn(height,opretvalue,opretbuf,olen,txhash,vout);
 434             komodo_eventadd_opreturn(sp,symbol,height,txhash,opretvalue,vout,opretbuf,olen);
 435         }
 436         else if ( notarypubs != 0 && numnotaries > 0 )
 437         {
 438             printf("ht.%d func P[%d] errs.%d\n",height,numnotaries,errs);
 439             fputc('P',fp);
 440             if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
 441                 errs++;
 442             fputc(numnotaries,fp);
 443             if ( fwrite(notarypubs,33,numnotaries,fp) != numnotaries )
 444                 errs++;
 445             komodo_eventadd_pubkeys(sp,symbol,height,numnotaries,notarypubs);
 446         }
 447         else if ( voutmask != 0 && numvouts > 0 )
 448         {
 449             //printf("ht.%d func U %d %d errs.%d hashsize.%ld\n",height,numvouts,notaryid,errs,sizeof(txhash));
 450             fputc('U',fp);
 451             if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
 452                 errs++;
 453             fputc(numvouts,fp);
 454             fputc(notaryid,fp);
 455             if ( fwrite(&voutmask,1,sizeof(voutmask),fp) != sizeof(voutmask) )
 456                 errs++;
 457             if ( fwrite(&txhash,1,sizeof(txhash),fp) != sizeof(txhash) )
 458                 errs++;
 459             //komodo_eventadd_utxo(sp,symbol,height,notaryid,txhash,voutmask,numvouts);
 460         }
 461         else if ( pvals != 0 && numpvals > 0 )
 462         {
 463             int32_t i,nonz = 0;
 464             for (i=0; i<32; i++)
 465                 if ( pvals[i] != 0 )
 466                     nonz++;
 467             if ( nonz >= 32 )
 468             {
 469                 fputc('V',fp);
 470                 if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
 471                     errs++;
 472                 fputc(numpvals,fp);
 473                 if ( fwrite(pvals,sizeof(uint32_t),numpvals,fp) != numpvals )
 474                     errs++;
 475                 komodo_eventadd_pricefeed(sp,symbol,height,pvals,numpvals);
 476                 //printf("ht.%d V numpvals[%d]\n",height,numpvals);
 477             }
 478             //printf("save pvals height.%d numpvals.%d\n",height,numpvals);
 479         }
 480         else if ( height != 0 )
 481         {
 482             //printf("ht.%d func N ht.%d errs.%d\n",height,NOTARIZED_HEIGHT,errs);
 483             if ( sp != 0 )
 484             {
 485                 if ( sp->MoMdepth > 0 && sp->MoM != zero )
 486                     fputc('M',fp);
 487                 else fputc('N',fp);
 488                 if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
 489                     errs++;
 490                 if ( fwrite(&sp->NOTARIZED_HEIGHT,1,sizeof(sp->NOTARIZED_HEIGHT),fp) != sizeof(sp->NOTARIZED_HEIGHT) )
 491                     errs++;
 492                 if ( fwrite(&sp->NOTARIZED_HASH,1,sizeof(sp->NOTARIZED_HASH),fp) != sizeof(sp->NOTARIZED_HASH) )
 493                     errs++;
 494                 if ( fwrite(&sp->NOTARIZED_DESTTXID,1,sizeof(sp->NOTARIZED_DESTTXID),fp) != sizeof(sp->NOTARIZED_DESTTXID) )
 495                     errs++;
 496                 if ( sp->MoMdepth > 0 && sp->MoM != zero )
 497                 {
 498                     if ( fwrite(&sp->MoM,1,sizeof(sp->MoM),fp) != sizeof(sp->MoM) )
 499                         errs++;
 500                     if ( fwrite(&sp->MoMdepth,1,sizeof(sp->MoMdepth),fp) != sizeof(sp->MoMdepth) )
 501                         errs++;
 502                 }
 503                 komodo_eventadd_notarized(sp,symbol,height,dest,sp->NOTARIZED_HASH,sp->NOTARIZED_DESTTXID,sp->NOTARIZED_HEIGHT,sp->MoM,sp->MoMdepth);
 504             }
 505         }
 506         fflush(fp);
 507     }
 508 }
 509
 510 int32_t komodo_validate_chain(uint256 srchash,int32_t notarized_height)
 511 {
 512     static int32_t last_rewind; int32_t rewindtarget; CBlockIndex *pindex; struct komodo_state *sp; char symbol[KOMODO_ASSETCHAIN_MAXLEN],dest[KOMODO_ASSETCHAIN_MAXLEN];
 513     if ( (sp= komodo_stateptr(symbol,dest)) == 0 )
 514         return(0);
 515     if ( IsInitialBlockDownload() == 0 && ((pindex= mapBlockIndex[srchash]) == 0 || pindex->nHeight != notarized_height) )
 516     {
 517         if ( sp->NOTARIZED_HEIGHT > 0 && sp->NOTARIZED_HEIGHT < notarized_height )
 518             rewindtarget = sp->NOTARIZED_HEIGHT - 1;
 519         else if ( notarized_height > 101 )
 520             rewindtarget = notarized_height - 101;
 521         else rewindtarget = 0;
 522         if ( rewindtarget != 0 && rewindtarget > KOMODO_REWIND && rewindtarget > last_rewind )
 523         {
 524             if ( last_rewind != 0 )
 525             {
 526                 //KOMODO_REWIND = rewindtarget;
 527                 fprintf(stderr,"%s FORK detected. notarized.%d %s not in this chain! last notarization %d -> rewindtarget.%d\n",ASSETCHAINS_SYMBOL,notarized_height,srchash.ToString().c_str(),sp->NOTARIZED_HEIGHT,rewindtarget);
 528             }
 529             last_rewind = rewindtarget;
 530         }
 531         return(0);
 532     } else return(1);
 533 }
 534
 535 int32_t komodo_voutupdate(int32_t *isratificationp,int32_t notaryid,uint8_t *scriptbuf,int32_t scriptlen,int32_t height,uint256 txhash,int32_t i,int32_t j,uint64_t *voutmaskp,int32_t *specialtxp,int32_t *notarizedheightp,uint64_t value,int32_t notarized,uint64_t signedmask,uint32_t timestamp)
 536 {
 537     static uint256 zero; static FILE *signedfp;
 538     int32_t opretlen,nid,offset,k,MoMdepth,matched,len = 0; uint256 MoM,srchash,desttxid; uint8_t crypto777[33]; struct komodo_state *sp; char symbol[KOMODO_ASSETCHAIN_MAXLEN],dest[KOMODO_ASSETCHAIN_MAXLEN];
 539     if ( (sp= komodo_stateptr(symbol,dest)) == 0 )
 540         return(-1);
 541     if ( scriptlen == 35 && scriptbuf[0] == 33 && scriptbuf[34] == 0xac )
 542     {
 543         if ( i == 0 && j == 0 && memcmp(NOTARY_PUBKEY33,scriptbuf+1,33) == 0 && NOTARY_PUBKEY33[0] != 0 )
 544         {
 545             printf("%s KOMODO_LASTMINED.%d -> %d\n",ASSETCHAINS_SYMBOL,KOMODO_LASTMINED,height);
 546             prevKOMODO_LASTMINED = KOMODO_LASTMINED;
 547             KOMODO_LASTMINED = height;
 548         }
 549         decode_hex(crypto777,33,(char *)CRYPTO777_PUBSECPSTR);
 550         /*for (k=0; k<33; k++)
 551             printf("%02x",crypto777[k]);
 552         printf(" crypto777 ");
 553         for (k=0; k<scriptlen; k++)
 554             printf("%02x",scriptbuf[k]);
 555         printf(" <- script ht.%d i.%d j.%d cmp.%d\n",height,i,j,memcmp(crypto777,scriptbuf+1,33));*/
 556         if ( memcmp(crypto777,scriptbuf+1,33) == 0 )
 557         {
 558             *specialtxp = 1;
 559             //printf(">>>>>>>> ");
 560         }
 561         else if ( komodo_chosennotary(&nid,height,scriptbuf + 1,timestamp) >= 0 )
 562         {
 563             //printf("found notary.k%d\n",k);
 564             if ( notaryid < 64 )
 565             {
 566                 if ( notaryid < 0 )
 567                 {
 568                     notaryid = nid;
 569                     *voutmaskp |= (1LL << j);
 570                 }
 571                 else if ( notaryid != nid )
 572                 {
 573                     //for (i=0; i<33; i++)
 574                     //    printf("%02x",scriptbuf[i+1]);
 575                     //printf(" %s mismatch notaryid.%d k.%d\n",ASSETCHAINS_SYMBOL,notaryid,nid);
 576                     notaryid = 64;
 577                     *voutmaskp = 0;
 578                 }
 579                 else *voutmaskp |= (1LL << j);
 580             }
 581         }
 582     }
 583     if ( scriptbuf[len++] == 0x6a )
 584     {
 585         struct komodo_ccdata ccdata; struct komodo_ccdataMoMoM MoMoMdata;
 586         int32_t validated = 0,nameoffset,opoffset = 0;
 587         if ( (opretlen= scriptbuf[len++]) == 0x4c )
 588             opretlen = scriptbuf[len++];
 589         else if ( opretlen == 0x4d )
 590         {
 591             opretlen = scriptbuf[len++];
 592             opretlen += (scriptbuf[len++] << 8);
 593         }
 594         opoffset = len;
 595         matched = 0;
 596         if ( ASSETCHAINS_SYMBOL[0] == 0 )
 597         {
 598             if ( strcmp("KMD",(char *)&scriptbuf[len+32 * 2 + 4]) == 0 )
 599                 matched = 1;
 600         }
 601         else
 602         {
 603             if ( strcmp(ASSETCHAINS_SYMBOL,(char *)&scriptbuf[len+32*2+4]) == 0 )
 604                 matched = 1;
 605         }
 606         offset = 32 * (1 + matched) + 4;
 607         nameoffset = (int32_t)strlen((char *)&scriptbuf[len+offset]);
 608         if ( nameoffset == 2 )
 609             nameoffset += 2;
 610         else nameoffset++;
 611         memset(&ccdata,0,sizeof(ccdata));
 612         strncpy(ccdata.symbol,(char *)&scriptbuf[len+offset],sizeof(ccdata.symbol));
 613         if ( j == 1 && opretlen >= len+offset-opoffset )
 614         {
 615             memset(&MoMoMdata,0,sizeof(MoMoMdata));
 616             if ( matched == 0 && bitweight(signedmask) >= KOMODO_MINRATIFY )
 617                 notarized = 1;
 618             if ( strcmp("PIZZA",ccdata.symbol) == 0 )
 619                 notarized = 1;
 620             if ( 0 && opretlen != 149 )
 621                 printf("[%s].%d (%s) matched.%d i.%d j.%d notarized.%d %llx opretlen.%d len.%d offset.%d opoffset.%d\n",ASSETCHAINS_SYMBOL,height,ccdata.symbol,matched,i,j,notarized,(long long)signedmask,opretlen,len,offset,opoffset);
 622             len += iguana_rwbignum(0,&scriptbuf[len],32,(uint8_t *)&srchash);
 623             len += iguana_rwnum(0,&scriptbuf[len],sizeof(*notarizedheightp),(uint8_t *)notarizedheightp);
 624             if ( matched != 0 )
 625                 len += iguana_rwbignum(0,&scriptbuf[len],32,(uint8_t *)&desttxid);
 626             if ( matched != 0 )
 627                 validated = komodo_validate_chain(srchash,*notarizedheightp);
 628             else validated = 1;
 629             if ( notarized != 0 && validated != 0 )
 630             {
 631                 //sp->NOTARIZED_HEIGHT = *notarizedheightp;
 632                 //sp->NOTARIZED_HASH = srchash;
 633                 //sp->NOTARIZED_DESTTXID = desttxid;
 634                 memset(&MoM,0,sizeof(MoM));
 635                 MoMdepth = 0;
 636                 len += nameoffset;
 637                 ccdata.MoMdata.notarized_height = *notarizedheightp;
 638                 ccdata.MoMdata.height = height;
 639                 ccdata.MoMdata.txi = i;
 640                 //printf("nameoffset.%d len.%d + 36 %d vs opretlen.%d\n",nameoffset,len,len+36,opretlen);
 641                 if ( len+36-opoffset <= opretlen )
 642                 {
 643                     len += iguana_rwbignum(0,&scriptbuf[len],32,(uint8_t *)&MoM);
 644                     len += iguana_rwnum(0,&scriptbuf[len],sizeof(MoMdepth),(uint8_t *)&MoMdepth);
 645                     ccdata.MoMdata.MoM = MoM;
 646                     ccdata.MoMdata.MoMdepth = MoMdepth;
 647                     if ( len+sizeof(ccdata.CCid)-opoffset <= opretlen )
 648                     {
 649                         len += iguana_rwnum(0,&scriptbuf[len],sizeof(ccdata.CCid),(uint8_t *)&ccdata.CCid);
 650                         ccdata.len = sizeof(ccdata.CCid);
 651                         if ( ASSETCHAINS_SYMBOL[0] != 0 )
 652                         {
 653                             // MoMoM, depth, numpairs, (notarization ht, MoMoM offset)
 654                             if ( len+48-opoffset <= opretlen && strcmp(ccdata.symbol,ASSETCHAINS_SYMBOL) == 0 )
 655                             {
 656                                 len += iguana_rwnum(0,&scriptbuf[len],sizeof(uint32_t),(uint8_t *)&MoMoMdata.kmdstarti);
 657                                 len += iguana_rwnum(0,&scriptbuf[len],sizeof(uint32_t),(uint8_t *)&MoMoMdata.kmdendi);
 658                                 len += iguana_rwbignum(0,&scriptbuf[len],sizeof(MoMoMdata.MoMoM),(uint8_t *)&MoMoMdata.MoMoM);
 659                                 len += iguana_rwnum(0,&scriptbuf[len],sizeof(uint32_t),(uint8_t *)&MoMoMdata.MoMoMdepth);
 660                                 len += iguana_rwnum(0,&scriptbuf[len],sizeof(uint32_t),(uint8_t *)&MoMoMdata.numpairs);
 661                                 MoMoMdata.len += sizeof(MoMoMdata.MoMoM) + sizeof(uint32_t)*4;
 662                                 if ( len+MoMoMdata.numpairs*8-opoffset == opretlen )
 663                                 {
 664                                     MoMoMdata.pairs = (struct komodo_ccdatapair *)calloc(MoMoMdata.numpairs,sizeof(*MoMoMdata.pairs));
 665                                     for (k=0; k<MoMoMdata.numpairs; k++)
 666                                     {
 667                                         len += iguana_rwnum(0,&scriptbuf[len],sizeof(int32_t),(uint8_t *)&MoMoMdata.pairs[k].notarized_height);
 668                                         len += iguana_rwnum(0,&scriptbuf[len],sizeof(uint32_t),(uint8_t *)&MoMoMdata.pairs[k].MoMoMoffset);
 669                                         MoMoMdata.len += sizeof(uint32_t) * 2;
 670                                     }
 671                                 } else ccdata.len = MoMoMdata.len = 0;
 672                             } else ccdata.len = MoMoMdata.len = 0;
 673                         }
 674                     }
 675                     if ( MoM == zero || MoMdepth > 1440 || MoMdepth < 0 )
 676                     {
 677                         memset(&MoM,0,sizeof(MoM));
 678                         MoMdepth = 0;
 679                     }
 680                     else
 681                     {
 682                         komodo_rwccdata(ASSETCHAINS_SYMBOL,1,&ccdata,&MoMoMdata);
 683                         //printf("[%s] matched.%d VALID (%s) MoM.%s [%d]\n",ASSETCHAINS_SYMBOL,matched,ccdata.symbol,MoM.ToString().c_str(),MoMdepth);
 684                     }
 685                     if ( MoMoMdata.pairs != 0 )
 686                         free(MoMoMdata.pairs);
 687                     memset(&ccdata,0,sizeof(ccdata));
 688                     memset(&MoMoMdata,0,sizeof(MoMoMdata));
 689                 }
 690                 else if ( ASSETCHAINS_SYMBOL[0] == 0 && matched != 0 && notarized != 0 && validated != 0 )
 691                     komodo_rwccdata((char *)"KMD",1,&ccdata,0);
 692                 if ( matched != 0 && *notarizedheightp > sp->NOTARIZED_HEIGHT && *notarizedheightp < height )
 693                 {
 694                     sp->NOTARIZED_HEIGHT = *notarizedheightp;
 695                     sp->NOTARIZED_HASH = srchash;
 696                     sp->NOTARIZED_DESTTXID = desttxid;
 697                     sp->MoM = MoM;
 698                     sp->MoMdepth = MoMdepth;
 699                     komodo_stateupdate(height,0,0,0,zero,0,0,0,0,0,0,0,0,0,0,sp->MoM,sp->MoMdepth);
 700                     if ( ASSETCHAINS_SYMBOL[0] != 0 )
 701                         printf("[%s] ht.%d NOTARIZED.%d %s.%s %sTXID.%s lens.(%d %d) MoM.%s %d\n",ASSETCHAINS_SYMBOL,height,*notarizedheightp,ASSETCHAINS_SYMBOL[0]==0?"KMD":ASSETCHAINS_SYMBOL,srchash.ToString().c_str(),ASSETCHAINS_SYMBOL[0]==0?"BTC":"KMD",desttxid.ToString().c_str(),opretlen,len,sp->MoM.ToString().c_str(),sp->MoMdepth);
 702                     if ( ASSETCHAINS_SYMBOL[0] == 0 )
 703                     {
 704                         if ( signedfp == 0 )
 705                         {
 706                             char fname[512];
 707                             komodo_statefname(fname,ASSETCHAINS_SYMBOL,(char *)"signedmasks");
 708                             if ( (signedfp= fopen(fname,"rb+")) == 0 )
 709                                 signedfp = fopen(fname,"wb");
 710                             else fseek(signedfp,0,SEEK_END);
 711                         }
 712                         if ( signedfp != 0 )
 713                         {
 714                             fwrite(&height,1,sizeof(height),signedfp);
 715                             fwrite(&signedmask,1,sizeof(signedmask),signedfp);
 716                             fflush(signedfp);
 717                         }
 718                         if ( opretlen > len && scriptbuf[len] == 'A' )
 719                         {
 720                             //for (i=0; i<opretlen-len; i++)
 721                             //    printf("%02x",scriptbuf[len+i]);
 722                             //printf(" Found extradata.[%d] %d - %d\n",opretlen-len,opretlen,len);
 723                             komodo_stateupdate(height,0,0,0,txhash,0,0,0,0,0,0,value,&scriptbuf[len],opretlen-len+4+3+(scriptbuf[1] == 0x4d),j,zero,0);
 724                         }
 725                     }
 726                 }
 727             } else if ( opretlen != 149 && height > 600000 && matched != 0 )
 728                 printf("%s validated.%d notarized.%d %llx reject ht.%d NOTARIZED.%d prev.%d %s.%s DESTTXID.%s len.%d opretlen.%d\n",ccdata.symbol,validated,notarized,(long long)signedmask,height,*notarizedheightp,sp->NOTARIZED_HEIGHT,ASSETCHAINS_SYMBOL[0]==0?"KMD":ASSETCHAINS_SYMBOL,srchash.ToString().c_str(),desttxid.ToString().c_str(),len,opretlen);
 729         }
 730         else if ( matched != 0 && i == 0 && j == 1 && opretlen == 149 )
 731         {
 732             if ( notaryid >= 0 && notaryid < 64 )
 733                 komodo_paxpricefeed(height,&scriptbuf[len],opretlen);
 734         }
 735         else if ( matched != 0 )
 736         {
 737             //int32_t k; for (k=0; k<scriptlen; k++)
 738             //    printf("%02x",scriptbuf[k]);
 739             //printf(" <- script ht.%d i.%d j.%d value %.8f %s\n",height,i,j,dstr(value),ASSETCHAINS_SYMBOL);
 740             if ( opretlen >= 32*2+4 && strcmp(ASSETCHAINS_SYMBOL[0]==0?"KMD":ASSETCHAINS_SYMBOL,(char *)&scriptbuf[len+32*2+4]) == 0 )
 741             {
 742                 for (k=0; k<32; k++)
 743                     if ( scriptbuf[len+k] != 0 )
 744                         break;
 745                 if ( k == 32 )
 746                 {
 747                     *isratificationp = 1;
 748                     printf("ISRATIFICATION (%s)\n",(char *)&scriptbuf[len+32*2+4]);
 749                 }
 750             }
 751
 752             if ( *isratificationp == 0 && (signedmask != 0 || (scriptbuf[len] != 'X' && scriptbuf[len] != 'A')) ) // && scriptbuf[len] != 'I')
 753                 komodo_stateupdate(height,0,0,0,txhash,0,0,0,0,0,0,value,&scriptbuf[len],opretlen,j,zero,0);
 754         }
 755     }
 756     return(notaryid);
 757 }
 758
 759 /*int32_t komodo_isratify(int32_t isspecial,int32_t numvalid)
 760 {
 761     if ( isspecial != 0 && numvalid >= KOMODO_MINRATIFY )
 762         return(1);
 763     else return(0);
 764 }*/
 765
 766 // Special tx have vout[0] -> CRYPTO777
 767 // with more than KOMODO_MINRATIFY pay2pubkey outputs -> ratify
 768 // if all outputs to notary -> notary utxo
 769 // if txi == 0 && 2 outputs and 2nd OP_RETURN, len == 32*2+4 -> notarized, 1st byte 'P' -> pricefeed
 770 // OP_RETURN: 'D' -> deposit, 'W' -> withdraw
 771
 772 int32_t gettxout_scriptPubKey(uint8_t *scriptPubKey,int32_t maxsize,uint256 txid,int32_t n);
 773
 774 int32_t komodo_notarycmp(uint8_t *scriptPubKey,int32_t scriptlen,uint8_t pubkeys[64][33],int32_t numnotaries,uint8_t rmd160[20])
 775 {
 776     int32_t i;
 777     if ( scriptlen == 25 && memcmp(&scriptPubKey[3],rmd160,20) == 0 )
 778         return(0);
 779     else if ( scriptlen == 35 )
 780     {
 781         for (i=0; i<numnotaries; i++)
 782             if ( memcmp(&scriptPubKey[1],pubkeys[i],33) == 0 )
 783                 return(i);
 784     }
 785     return(-1);
 786 }
 787
 788 void komodo_connectblock(CBlockIndex *pindex,CBlock& block)
 789 {
 790     static int32_t hwmheight;
 791     uint64_t signedmask,voutmask; char symbol[KOMODO_ASSETCHAIN_MAXLEN],dest[KOMODO_ASSETCHAIN_MAXLEN]; struct komodo_state *sp;
 792     uint8_t scriptbuf[10001],pubkeys[64][33],rmd160[20],scriptPubKey[35]; uint256 zero,btctxid,txhash;
 793     int32_t i,j,k,numnotaries,notarized,scriptlen,isratification,nid,numvalid,specialtx,notarizedheight,notaryid,len,numvouts,numvins,height,txn_count;
 794     memset(&zero,0,sizeof(zero));
 795     komodo_init(pindex->nHeight);
 796     KOMODO_INITDONE = (uint32_t)time(NULL);
 797     if ( (sp= komodo_stateptr(symbol,dest)) == 0 )
 798     {
 799         fprintf(stderr,"unexpected null komodostateptr.[%s]\n",ASSETCHAINS_SYMBOL);
 800         return;
 801     }
 802     //fprintf(stderr,"%s connect.%d\n",ASSETCHAINS_SYMBOL,pindex->nHeight);
 803     numnotaries = komodo_notaries(pubkeys,pindex->nHeight,pindex->GetBlockTime());
 804     calc_rmd160_sha256(rmd160,pubkeys[0],33);
 805     if ( pindex->nHeight > hwmheight )
 806         hwmheight = pindex->nHeight;
 807     else
 808     {
 809         if ( pindex->nHeight != hwmheight )
 810         {
 811             printf("%s hwmheight.%d vs pindex->nHeight.%d t.%u reorg.%d\n",ASSETCHAINS_SYMBOL,hwmheight,pindex->nHeight,(uint32_t)pindex->nTime,hwmheight-pindex->nHeight);
 812             komodo_purge_ccdata((int32_t)pindex->nHeight);
 813             hwmheight = pindex->nHeight;
 814         }
 815         komodo_event_rewind(sp,symbol,pindex->nHeight);
 816         komodo_stateupdate(pindex->nHeight,0,0,0,zero,0,0,0,0,-pindex->nHeight,pindex->nTime,0,0,0,0,zero,0);
 817     }
 818     komodo_currentheight_set(chainActive.Tip()->nHeight);
 819     if ( pindex != 0 )
 820     {
 821         height = pindex->nHeight;
 822         txn_count = block.vtx.size();
 823         for (i=0; i<txn_count; i++)
 824         {
 825             txhash = block.vtx[i].GetHash();
 826             numvouts = block.vtx[i].vout.size();
 827             notaryid = -1;
 828             voutmask = specialtx = notarizedheight = isratification = notarized = 0;
 829             signedmask = (height < 91400) ? 1 : 0;
 830             numvins = block.vtx[i].vin.size();
 831             for (j=0; j<numvins; j++)
 832             {
 833                 if ( i == 0 && j == 0 )
 834                     continue;
 835                 if ( (scriptlen= gettxout_scriptPubKey(scriptPubKey,sizeof(scriptPubKey),block.vtx[i].vin[j].prevout.hash,block.vtx[i].vin[j].prevout.n)) > 0 )
 836                 {
 837                     if ( (k= komodo_notarycmp(scriptPubKey,scriptlen,pubkeys,numnotaries,rmd160)) >= 0 )
 838                         signedmask |= (1LL << k);
 839                     else if ( 0 && numvins >= 17 )
 840                     {
 841                         int32_t k;
 842                         for (k=0; k<scriptlen; k++)
 843                             printf("%02x",scriptPubKey[k]);
 844                         printf(" scriptPubKey doesnt match any notary vini.%d of %d\n",j,numvins);
 845                     }
 846                 } else printf("cant get scriptPubKey for ht.%d txi.%d vin.%d\n",height,i,j);
 847             }
 848             numvalid = bitweight(signedmask);
 849             if ( (((height < 90000 || (signedmask & 1) != 0) && numvalid >= KOMODO_MINRATIFY) ||
 850                   (numvalid >= KOMODO_MINRATIFY && ASSETCHAINS_SYMBOL[0] != 0) ||
 851                   numvalid > (numnotaries/5)) )
 852             {
 853                 if ( ASSETCHAINS_SYMBOL[0] != 0 )
 854                 {
 855                     static FILE *signedfp;
 856                     if ( signedfp == 0 )
 857                     {
 858                         char fname[512];
 859                         komodo_statefname(fname,ASSETCHAINS_SYMBOL,(char *)"signedmasks");
 860                         if ( (signedfp= fopen(fname,"rb+")) == 0 )
 861                             signedfp = fopen(fname,"wb");
 862                         else fseek(signedfp,0,SEEK_END);
 863                     }
 864                     if ( signedfp != 0 )
 865                     {
 866                         fwrite(&height,1,sizeof(height),signedfp);
 867                         fwrite(&signedmask,1,sizeof(signedmask),signedfp);
 868                         fflush(signedfp);
 869                     }
 870                      printf("[%s] ht.%d txi.%d signedmask.%llx numvins.%d numvouts.%d <<<<<<<<<<<  notarized\n",ASSETCHAINS_SYMBOL,height,i,(long long)signedmask,numvins,numvouts);
 871                 }
 872                 notarized = 1;
 873             }
 874             if ( NOTARY_PUBKEY33[0] != 0 && ASSETCHAINS_SYMBOL[0] == 0 )
 875                 printf("(tx.%d: ",i);
 876             for (j=0; j<numvouts; j++)
 877             {
 878                 /*if ( i == 0 && j == 0 )
 879                 {
 880                     uint8_t *script = (uint8_t *)block.vtx[0].vout[numvouts-1].scriptPubKey.data();
 881                     if ( numvouts <= 2 || script[0] != 0x6a )
 882                     {
 883                         if ( numvouts == 2 && block.vtx[0].vout[1].nValue != 0 )
 884                         {
 885                             fprintf(stderr,"ht.%d numvouts.%d value %.8f\n",height,numvouts,dstr(block.vtx[0].vout[1].nValue));
 886                             if ( height >= 235300 && block.vtx[0].vout[1].nValue >= 100000*COIN )
 887                                 block.vtx[0].vout[1].nValue = 0;
 888                             break;
 889                         }
 890                     }
 891                 }*/
 892                 if ( NOTARY_PUBKEY33[0] != 0 && ASSETCHAINS_SYMBOL[0] == 0 )
 893                     printf("%.8f ",dstr(block.vtx[i].vout[j].nValue));
 894                 len = block.vtx[i].vout[j].scriptPubKey.size();
 895                 if ( len >= sizeof(uint32_t) && len <= sizeof(scriptbuf) )
 896                 {
 897 #ifdef KOMODO_ZCASH
 898                     memcpy(scriptbuf,block.vtx[i].vout[j].scriptPubKey.data(),len);
 899 #else
 900                     memcpy(scriptbuf,(uint8_t *)&block.vtx[i].vout[j].scriptPubKey[0],len);
 901 #endif
 902                     notaryid = komodo_voutupdate(&isratification,notaryid,scriptbuf,len,height,txhash,i,j,&voutmask,&specialtx,&notarizedheight,(uint64_t)block.vtx[i].vout[j].nValue,notarized,signedmask,(uint32_t)chainActive.Tip()->GetBlockTime());
 903                     if ( 0 && i > 0 )
 904                     {
 905                         for (k=0; k<len; k++)
 906                             printf("%02x",scriptbuf[k]);
 907                         printf(" <- notaryid.%d ht.%d i.%d j.%d numvouts.%d numvins.%d voutmask.%llx txid.(%s)\n",notaryid,height,i,j,numvouts,numvins,(long long)voutmask,txhash.ToString().c_str());
 908                     }
 909                 }
 910             }
 911             if ( NOTARY_PUBKEY33[0] != 0 && ASSETCHAINS_SYMBOL[0] == 0 )
 912                 printf(") ");
 913             if ( 0 && ASSETCHAINS_SYMBOL[0] == 0 )
 914                 printf("[%s] ht.%d txi.%d signedmask.%llx numvins.%d numvouts.%d notarized.%d special.%d isratification.%d\n",ASSETCHAINS_SYMBOL,height,i,(long long)signedmask,numvins,numvouts,notarized,specialtx,isratification);
 915             if ( notarized != 0 && (notarizedheight != 0 || specialtx != 0) )
 916             {
 917                 if ( isratification != 0 )
 918                 {
 919                     printf("%s NOTARY SIGNED.%llx numvins.%d ht.%d txi.%d notaryht.%d specialtx.%d\n",ASSETCHAINS_SYMBOL,(long long)signedmask,numvins,height,i,notarizedheight,specialtx);
 920                     printf("ht.%d specialtx.%d isratification.%d numvouts.%d signed.%llx numnotaries.%d\n",height,specialtx,isratification,numvouts,(long long)signedmask,numnotaries);
 921                 }
 922                 if ( specialtx != 0 && isratification != 0 && numvouts > 2 )
 923                 {
 924                     numvalid = 0;
 925                     memset(pubkeys,0,sizeof(pubkeys));
 926                     for (j=1; j<numvouts-1; j++)
 927                     {
 928                         len = block.vtx[i].vout[j].scriptPubKey.size();
 929                         if ( len >= sizeof(uint32_t) && len <= sizeof(scriptbuf) )
 930                         {
 931 #ifdef KOMODO_ZCASH
 932                             memcpy(scriptbuf,block.vtx[i].vout[j].scriptPubKey.data(),len);
 933 #else
 934                             memcpy(scriptbuf,(uint8_t *)&block.vtx[i].vout[j].scriptPubKey[0],len);
 935 #endif
 936                             if ( len == 35 && scriptbuf[0] == 33 && scriptbuf[34] == 0xac )
 937                             {
 938                                 memcpy(pubkeys[numvalid++],scriptbuf+1,33);
 939                                 for (k=0; k<33; k++)
 940                                     printf("%02x",scriptbuf[k+1]);
 941                                 printf(" <- new notary.[%d]\n",j-1);
 942                             }
 943                         }
 944                     }
 945                     if ( ((signedmask & 1) != 0 && numvalid >= KOMODO_MINRATIFY) || bitweight(signedmask) > (numnotaries/3) )
 946                     {
 947                         memset(&txhash,0,sizeof(txhash));
 948                         komodo_stateupdate(height,pubkeys,numvalid,0,txhash,0,0,0,0,0,0,0,0,0,0,zero,0);
 949                         printf("RATIFIED! >>>>>>>>>> new notaries.%d newheight.%d from height.%d\n",numvalid,(((height+KOMODO_ELECTION_GAP/2)/KOMODO_ELECTION_GAP)+1)*KOMODO_ELECTION_GAP,height);
 950                     } else printf("signedmask.%llx numvalid.%d wt.%d numnotaries.%d\n",(long long)signedmask,numvalid,bitweight(signedmask),numnotaries);
 951                 }
 952             }
 953         }
 954         if ( NOTARY_PUBKEY33[0] != 0 && ASSETCHAINS_SYMBOL[0] == 0 )
 955             printf("%s ht.%d\n",ASSETCHAINS_SYMBOL[0] == 0 ? "KMD" : ASSETCHAINS_SYMBOL,height);
 956         if ( pindex->nHeight == hwmheight )
 957             komodo_stateupdate(height,0,0,0,zero,0,0,0,0,height,(uint32_t)pindex->nTime,0,0,0,0,zero,0);
 958     } else fprintf(stderr,"komodo_connectblock: unexpected null pindex\n");
 959     //KOMODO_INITDONE = (uint32_t)time(NULL);
 960     //fprintf(stderr,"%s end connect.%d\n",ASSETCHAINS_SYMBOL,pindex->nHeight);
 961 }
 962
 963
 964 #endif