1 /******************************************************************************
2 * Copyright © 2014-2017 The SuperNET Developers. *
4 * See the AUTHORS, DEVELOPER-AGREEMENT and LICENSE files at *
5 * the top-level directory of this distribution for the individual copyright *
6 * holder information and the developer policies on copyright and licensing. *
8 * Unless otherwise agreed in a custom licensing agreement, no part of the *
9 * SuperNET software, including this file may be copied, modified, propagated *
10 * or distributed except according to the terms contained in the LICENSE file *
12 * Removal or modification of this copyright notice is prohibited. *
14 ******************************************************************************/
18 #include "komodo_defs.h"
27 #define KOMODO_ASSETCHAINS_WAITNOTARIZE
28 #define KOMODO_PAXMAX (10000 * COIN)
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);
41 #include "komodo_structs.h"
42 #include "komodo_globals.h"
43 #include "komodo_utils.h"
44 #include "komodo_curve25519.h"
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"
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"
58 void komodo_currentheight_set(int32_t height)
60 char symbol[KOMODO_ASSETCHAIN_MAXLEN],dest[KOMODO_ASSETCHAIN_MAXLEN]; struct komodo_state *sp;
61 if ( (sp= komodo_stateptr(symbol,dest)) != 0 )
62 sp->CURRENT_HEIGHT = height;
65 int32_t komodo_currentheight()
67 char symbol[KOMODO_ASSETCHAIN_MAXLEN],dest[KOMODO_ASSETCHAIN_MAXLEN]; struct komodo_state *sp;
68 if ( (sp= komodo_stateptr(symbol,dest)) != 0 )
69 return(sp->CURRENT_HEIGHT);
73 int32_t komodo_parsestatefile(struct komodo_state *sp,FILE *fp,char *symbol,char *dest)
76 int32_t func,ht,notarized_height,num,matched=0,MoMdepth; uint256 MoM,notarized_hash,notarized_desttxid; uint8_t pubkeys[64][33];
77 if ( (func= fgetc(fp)) != EOF )
79 if ( ASSETCHAINS_SYMBOL[0] == 0 && strcmp(symbol,"KMD") == 0 )
81 else matched = (strcmp(symbol,ASSETCHAINS_SYMBOL) == 0);
82 if ( fread(&ht,1,sizeof(ht),fp) != sizeof(ht) )
84 if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 && func != 'T' )
85 printf("[%s] matched.%d fpos.%ld func.(%d %c) ht.%d\n",ASSETCHAINS_SYMBOL,matched,ftell(fp),func,func,ht);
88 if ( (num= fgetc(fp)) <= 64 )
90 if ( fread(pubkeys,33,num,fp) != num )
94 //printf("updated %d pubkeys at %s ht.%d\n",num,symbol,ht);
95 if ( (KOMODO_EXTERNAL_NOTARIES != 0 && matched != 0) || (strcmp(symbol,"KMD") == 0 && KOMODO_EXTERNAL_NOTARIES == 0) )
96 komodo_eventadd_pubkeys(sp,symbol,ht,num,pubkeys);
98 } else printf("illegal num.%d\n",num);
100 else if ( func == 'N' || func == 'M' )
102 if ( fread(¬arized_height,1,sizeof(notarized_height),fp) != sizeof(notarized_height) )
104 if ( fread(¬arized_hash,1,sizeof(notarized_hash),fp) != sizeof(notarized_hash) )
106 if ( fread(¬arized_desttxid,1,sizeof(notarized_desttxid),fp) != sizeof(notarized_desttxid) )
110 if ( fread(&MoM,1,sizeof(MoM),fp) != sizeof(MoM) )
112 if ( fread(&MoMdepth,1,sizeof(MoMdepth),fp) != sizeof(MoMdepth) )
114 if ( 1 && ASSETCHAINS_SYMBOL[0] != 0 && sp != 0 )
115 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);
119 memset(&MoM,0,sizeof(MoM));
122 //if ( matched != 0 ) global independent states -> inside *sp
123 komodo_eventadd_notarized(sp,symbol,ht,dest,notarized_hash,notarized_desttxid,notarized_height,MoM,MoMdepth);
125 else if ( func == 'U' ) // deprecated
127 uint8_t n,nid; uint256 hash; uint64_t mask;
130 //printf("U %d %d\n",n,nid);
131 if ( fread(&mask,1,sizeof(mask),fp) != sizeof(mask) )
133 if ( fread(&hash,1,sizeof(hash),fp) != sizeof(hash) )
135 //if ( matched != 0 )
136 // komodo_eventadd_utxo(sp,symbol,ht,nid,hash,mask,n);
138 else if ( func == 'K' )
141 if ( fread(&kheight,1,sizeof(kheight),fp) != sizeof(kheight) )
143 //if ( matched != 0 ) global independent states -> inside *sp
144 //printf("%s.%d load[%s] ht.%d\n",ASSETCHAINS_SYMBOL,ht,symbol,kheight);
145 komodo_eventadd_kmdheight(sp,symbol,ht,kheight,0);
147 else if ( func == 'T' )
149 int32_t kheight,ktimestamp;
150 if ( fread(&kheight,1,sizeof(kheight),fp) != sizeof(kheight) )
152 if ( fread(&ktimestamp,1,sizeof(ktimestamp),fp) != sizeof(ktimestamp) )
154 //if ( matched != 0 ) global independent states -> inside *sp
155 //printf("%s.%d load[%s] ht.%d t.%u\n",ASSETCHAINS_SYMBOL,ht,symbol,kheight,ktimestamp);
156 komodo_eventadd_kmdheight(sp,symbol,ht,kheight,ktimestamp);
158 else if ( func == 'R' )
160 uint16_t olen,v; uint64_t ovalue; uint256 txid; uint8_t opret[16384];
161 if ( fread(&txid,1,sizeof(txid),fp) != sizeof(txid) )
163 if ( fread(&v,1,sizeof(v),fp) != sizeof(v) )
165 if ( fread(&ovalue,1,sizeof(ovalue),fp) != sizeof(ovalue) )
167 if ( fread(&olen,1,sizeof(olen),fp) != sizeof(olen) )
169 if ( olen < sizeof(opret) )
171 if ( fread(opret,1,olen,fp) != olen )
173 if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 && matched != 0 )
175 int32_t i; for (i=0; i<olen; i++)
176 printf("%02x",opret[i]);
177 printf(" %s.%d load[%s] opret[%c] len.%d %.8f\n",ASSETCHAINS_SYMBOL,ht,symbol,opret[0],olen,(double)ovalue/COIN);
179 komodo_eventadd_opreturn(sp,symbol,ht,txid,ovalue,v,opret,olen); // global shared state -> global PAX
183 for (i=0; i<olen; i++)
185 //printf("illegal olen.%u\n",olen);
188 else if ( func == 'D' )
190 printf("unexpected function D[%d]\n",ht);
192 else if ( func == 'V' )
194 int32_t numpvals; uint32_t pvals[128];
195 numpvals = fgetc(fp);
196 if ( numpvals*sizeof(uint32_t) <= sizeof(pvals) && fread(pvals,sizeof(uint32_t),numpvals,fp) == numpvals )
198 //if ( matched != 0 ) global shared state -> global PVALS
199 //printf("%s load[%s] prices %d\n",ASSETCHAINS_SYMBOL,symbol,ht);
200 komodo_eventadd_pricefeed(sp,symbol,ht,pvals,numpvals);
201 //printf("load pvals ht.%d numpvals.%d\n",ht,numpvals);
202 } else printf("error loading pvals[%d]\n",numpvals);
204 else printf("[%s] %s illegal func.(%d %c)\n",ASSETCHAINS_SYMBOL,symbol,func,func);
209 int32_t memread(void *dest,int32_t size,uint8_t *filedata,long *fposp,long datalen)
211 if ( *fposp+size <= datalen )
213 memcpy(dest,&filedata[*fposp],size);
220 int32_t komodo_parsestatefiledata(struct komodo_state *sp,uint8_t *filedata,long *fposp,long datalen,char *symbol,char *dest)
223 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;
224 if ( fpos < datalen )
226 func = filedata[fpos++];
227 if ( ASSETCHAINS_SYMBOL[0] == 0 && strcmp(symbol,"KMD") == 0 )
229 else matched = (strcmp(symbol,ASSETCHAINS_SYMBOL) == 0);
230 if ( memread(&ht,sizeof(ht),filedata,&fpos,datalen) != sizeof(ht) )
234 if ( (num= filedata[fpos++]) <= 64 )
236 if ( memread(pubkeys,33*num,filedata,&fpos,datalen) != 33*num )
240 //printf("updated %d pubkeys at %s ht.%d\n",num,symbol,ht);
241 if ( (KOMODO_EXTERNAL_NOTARIES != 0 && matched != 0) || (strcmp(symbol,"KMD") == 0 && KOMODO_EXTERNAL_NOTARIES == 0) )
242 komodo_eventadd_pubkeys(sp,symbol,ht,num,pubkeys);
244 } else printf("illegal num.%d\n",num);
246 else if ( func == 'N' || func == 'M' )
248 if ( memread(¬arized_height,sizeof(notarized_height),filedata,&fpos,datalen) != sizeof(notarized_height) )
250 if ( memread(¬arized_hash,sizeof(notarized_hash),filedata,&fpos,datalen) != sizeof(notarized_hash) )
252 if ( memread(¬arized_desttxid,sizeof(notarized_desttxid),filedata,&fpos,datalen) != sizeof(notarized_desttxid) )
256 if ( memread(&MoM,sizeof(MoM),filedata,&fpos,datalen) != sizeof(MoM) )
258 if ( memread(&MoMdepth,sizeof(MoMdepth),filedata,&fpos,datalen) != sizeof(MoMdepth) )
260 if ( 1 && ASSETCHAINS_SYMBOL[0] != 0 && sp != 0 )
261 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);
265 memset(&MoM,0,sizeof(MoM));
268 komodo_eventadd_notarized(sp,symbol,ht,dest,notarized_hash,notarized_desttxid,notarized_height,MoM,MoMdepth);
270 else if ( func == 'U' ) // deprecated
272 uint8_t n,nid; uint256 hash; uint64_t mask;
273 n = filedata[fpos++];
274 nid = filedata[fpos++];
275 //printf("U %d %d\n",n,nid);
276 if ( memread(&mask,sizeof(mask),filedata,&fpos,datalen) != sizeof(mask) )
278 if ( memread(&hash,sizeof(hash),filedata,&fpos,datalen) != sizeof(hash) )
281 else if ( func == 'K' )
284 if ( memread(&kheight,sizeof(kheight),filedata,&fpos,datalen) != sizeof(kheight) )
286 komodo_eventadd_kmdheight(sp,symbol,ht,kheight,0);
288 else if ( func == 'T' )
290 int32_t kheight,ktimestamp;
291 if ( memread(&kheight,sizeof(kheight),filedata,&fpos,datalen) != sizeof(kheight) )
293 if ( memread(&ktimestamp,sizeof(ktimestamp),filedata,&fpos,datalen) != sizeof(ktimestamp) )
295 //if ( matched != 0 ) global independent states -> inside *sp
296 //printf("%s.%d load[%s] ht.%d t.%u\n",ASSETCHAINS_SYMBOL,ht,symbol,kheight,ktimestamp);
297 komodo_eventadd_kmdheight(sp,symbol,ht,kheight,ktimestamp);
299 else if ( func == 'R' )
301 uint16_t olen,v; uint64_t ovalue; uint256 txid; uint8_t opret[16384];
302 if ( memread(&txid,sizeof(txid),filedata,&fpos,datalen) != sizeof(txid) )
304 if ( memread(&v,sizeof(v),filedata,&fpos,datalen) != sizeof(v) )
306 if ( memread(&ovalue,sizeof(ovalue),filedata,&fpos,datalen) != sizeof(ovalue) )
308 if ( memread(&olen,sizeof(olen),filedata,&fpos,datalen) != sizeof(olen) )
310 if ( olen < sizeof(opret) )
312 if ( memread(opret,olen,filedata,&fpos,datalen) != olen )
314 if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 && matched != 0 )
316 int32_t i; for (i=0; i<olen; i++)
317 printf("%02x",opret[i]);
318 printf(" %s.%d load[%s] opret[%c] len.%d %.8f\n",ASSETCHAINS_SYMBOL,ht,symbol,opret[0],olen,(double)ovalue/COIN);
320 komodo_eventadd_opreturn(sp,symbol,ht,txid,ovalue,v,opret,olen); // global shared state -> global PAX
324 for (i=0; i<olen; i++)
326 //printf("illegal olen.%u\n",olen);
329 else if ( func == 'D' )
331 printf("unexpected function D[%d]\n",ht);
333 else if ( func == 'V' )
335 int32_t numpvals; uint32_t pvals[128];
336 numpvals = filedata[fpos++];
337 if ( numpvals*sizeof(uint32_t) <= sizeof(pvals) && memread(pvals,(int32_t)(sizeof(uint32_t)*numpvals),filedata,&fpos,datalen) == numpvals*sizeof(uint32_t) )
339 //if ( matched != 0 ) global shared state -> global PVALS
340 //printf("%s load[%s] prices %d\n",ASSETCHAINS_SYMBOL,symbol,ht);
341 komodo_eventadd_pricefeed(sp,symbol,ht,pvals,numpvals);
342 //printf("load pvals ht.%d numpvals.%d\n",ht,numpvals);
343 } else printf("error loading pvals[%d]\n",numpvals);
345 else printf("[%s] %s illegal func.(%d %c)\n",ASSETCHAINS_SYMBOL,symbol,func,func);
352 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 static FILE *fp; static int32_t errs,didinit; static uint256 zero;
355 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];
358 portable_mutex_init(&KOMODO_KV_mutex);
361 if ( (sp= komodo_stateptr(symbol,dest)) == 0 )
363 KOMODO_INITDONE = (uint32_t)time(NULL);
364 printf("[%s] no komodo_stateptr\n",ASSETCHAINS_SYMBOL);
367 //printf("[%s] (%s) -> (%s)\n",ASSETCHAINS_SYMBOL,symbol,dest);
370 komodo_statefname(fname,ASSETCHAINS_SYMBOL,(char *)"komodostate");
371 if ( (fp= fopen(fname,"rb+")) != 0 )
373 if ( (retval= komodo_faststateinit(sp,fname,symbol,dest)) > 0 )
374 fseek(fp,0,SEEK_END);
377 fprintf(stderr,"komodo_faststateinit retval.%d\n",retval);
378 while ( komodo_parsestatefile(sp,fp,symbol,dest) >= 0 )
381 } else fp = fopen(fname,"wb+");
382 KOMODO_INITDONE = (uint32_t)time(NULL);
386 //printf("early return: stateupdate height.%d\n",height);
389 if ( fp != 0 ) // write out funcid, height, other fields, call side effect function
391 //printf("fpos.%ld ",ftell(fp));
392 if ( KMDheight != 0 )
394 if ( KMDtimestamp != 0 )
397 if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
399 if ( fwrite(&KMDheight,1,sizeof(KMDheight),fp) != sizeof(KMDheight) )
401 if ( fwrite(&KMDtimestamp,1,sizeof(KMDtimestamp),fp) != sizeof(KMDtimestamp) )
407 if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
409 if ( fwrite(&KMDheight,1,sizeof(KMDheight),fp) != sizeof(KMDheight) )
412 komodo_eventadd_kmdheight(sp,symbol,height,KMDheight,KMDtimestamp);
414 else if ( opretbuf != 0 && opretlen > 0 )
416 uint16_t olen = opretlen;
418 if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
420 if ( fwrite(&txhash,1,sizeof(txhash),fp) != sizeof(txhash) )
422 if ( fwrite(&vout,1,sizeof(vout),fp) != sizeof(vout) )
424 if ( fwrite(&opretvalue,1,sizeof(opretvalue),fp) != sizeof(opretvalue) )
426 if ( fwrite(&olen,1,sizeof(olen),fp) != olen )
428 if ( fwrite(opretbuf,1,olen,fp) != olen )
430 //printf("ht.%d R opret[%d] sp.%p\n",height,olen,sp);
431 //komodo_opreturn(height,opretvalue,opretbuf,olen,txhash,vout);
432 komodo_eventadd_opreturn(sp,symbol,height,txhash,opretvalue,vout,opretbuf,olen);
434 else if ( notarypubs != 0 && numnotaries > 0 )
436 printf("ht.%d func P[%d] errs.%d\n",height,numnotaries,errs);
438 if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
440 fputc(numnotaries,fp);
441 if ( fwrite(notarypubs,33,numnotaries,fp) != numnotaries )
443 komodo_eventadd_pubkeys(sp,symbol,height,numnotaries,notarypubs);
445 else if ( voutmask != 0 && numvouts > 0 )
447 //printf("ht.%d func U %d %d errs.%d hashsize.%ld\n",height,numvouts,notaryid,errs,sizeof(txhash));
449 if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
453 if ( fwrite(&voutmask,1,sizeof(voutmask),fp) != sizeof(voutmask) )
455 if ( fwrite(&txhash,1,sizeof(txhash),fp) != sizeof(txhash) )
457 //komodo_eventadd_utxo(sp,symbol,height,notaryid,txhash,voutmask,numvouts);
459 else if ( pvals != 0 && numpvals > 0 )
468 if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
471 if ( fwrite(pvals,sizeof(uint32_t),numpvals,fp) != numpvals )
473 komodo_eventadd_pricefeed(sp,symbol,height,pvals,numpvals);
474 //printf("ht.%d V numpvals[%d]\n",height,numpvals);
476 //printf("save pvals height.%d numpvals.%d\n",height,numpvals);
478 else if ( height != 0 )
480 //printf("ht.%d func N ht.%d errs.%d\n",height,NOTARIZED_HEIGHT,errs);
483 if ( sp->MoMdepth > 0 && sp->MoM != zero )
486 if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
488 if ( fwrite(&sp->NOTARIZED_HEIGHT,1,sizeof(sp->NOTARIZED_HEIGHT),fp) != sizeof(sp->NOTARIZED_HEIGHT) )
490 if ( fwrite(&sp->NOTARIZED_HASH,1,sizeof(sp->NOTARIZED_HASH),fp) != sizeof(sp->NOTARIZED_HASH) )
492 if ( fwrite(&sp->NOTARIZED_DESTTXID,1,sizeof(sp->NOTARIZED_DESTTXID),fp) != sizeof(sp->NOTARIZED_DESTTXID) )
494 if ( sp->MoMdepth > 0 && sp->MoM != zero )
496 if ( fwrite(&sp->MoM,1,sizeof(sp->MoM),fp) != sizeof(sp->MoM) )
498 if ( fwrite(&sp->MoMdepth,1,sizeof(sp->MoMdepth),fp) != sizeof(sp->MoMdepth) )
501 komodo_eventadd_notarized(sp,symbol,height,dest,sp->NOTARIZED_HASH,sp->NOTARIZED_DESTTXID,sp->NOTARIZED_HEIGHT,sp->MoM,sp->MoMdepth);
508 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)
510 static uint256 zero; static FILE *signedfp;
511 int32_t opretlen,nid,k,len = 0; uint256 srchash,desttxid; uint8_t crypto777[33]; struct komodo_state *sp; char symbol[KOMODO_ASSETCHAIN_MAXLEN],dest[KOMODO_ASSETCHAIN_MAXLEN];
512 if ( (sp= komodo_stateptr(symbol,dest)) == 0 )
514 if ( scriptlen == 35 && scriptbuf[0] == 33 && scriptbuf[34] == 0xac )
516 if ( i == 0 && j == 0 && memcmp(NOTARY_PUBKEY33,scriptbuf+1,33) == 0 && NOTARY_PUBKEY33[0] != 0 )
518 printf("%s KOMODO_LASTMINED.%d -> %d\n",ASSETCHAINS_SYMBOL,KOMODO_LASTMINED,height);
519 prevKOMODO_LASTMINED = KOMODO_LASTMINED;
520 KOMODO_LASTMINED = height;
522 decode_hex(crypto777,33,(char *)CRYPTO777_PUBSECPSTR);
523 /*for (k=0; k<33; k++)
524 printf("%02x",crypto777[k]);
525 printf(" crypto777 ");
526 for (k=0; k<scriptlen; k++)
527 printf("%02x",scriptbuf[k]);
528 printf(" <- script ht.%d i.%d j.%d cmp.%d\n",height,i,j,memcmp(crypto777,scriptbuf+1,33));*/
529 if ( memcmp(crypto777,scriptbuf+1,33) == 0 )
532 //printf(">>>>>>>> ");
534 else if ( komodo_chosennotary(&nid,height,scriptbuf + 1,timestamp) >= 0 )
536 //printf("found notary.k%d\n",k);
542 *voutmaskp |= (1LL << j);
544 else if ( notaryid != nid )
546 //for (i=0; i<33; i++)
547 // printf("%02x",scriptbuf[i+1]);
548 //printf(" %s mismatch notaryid.%d k.%d\n",ASSETCHAINS_SYMBOL,notaryid,nid);
552 else *voutmaskp |= (1LL << j);
556 if ( scriptbuf[len++] == 0x6a )
558 if ( (opretlen= scriptbuf[len++]) == 0x4c )
559 opretlen = scriptbuf[len++];
560 else if ( opretlen == 0x4d )
562 opretlen = scriptbuf[len++];
563 opretlen += (scriptbuf[len++] << 8);
565 if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 )
566 printf("[%s] notarized.%d notarizedht.%d sp.Nht %d sp.ht %d opretlen.%d (%c %c %c)\n",ASSETCHAINS_SYMBOL,notarized,*notarizedheightp,sp->NOTARIZED_HEIGHT,sp->CURRENT_HEIGHT,opretlen,scriptbuf[len+32*2+4],scriptbuf[len+32*2+4+1],scriptbuf[len+32*2+4+2]);
567 if ( j == 1 && opretlen >= 32*2+4 && strcmp(ASSETCHAINS_SYMBOL[0]==0?"KMD":ASSETCHAINS_SYMBOL,(char *)&scriptbuf[len+32*2+4]) == 0 )
569 len += iguana_rwbignum(0,&scriptbuf[len],32,(uint8_t *)&srchash);
570 len += iguana_rwnum(0,&scriptbuf[len],sizeof(*notarizedheightp),(uint8_t *)notarizedheightp);
571 len += iguana_rwbignum(0,&scriptbuf[len],32,(uint8_t *)&desttxid);
572 if ( strcmp("PIZZA",ASSETCHAINS_SYMBOL) == 0 && opretlen == 110 )
576 static int32_t last_rewind;
577 int32_t rewindtarget,validated = 0;
578 CBlockIndex *pindex;//
579 if ( IsInitialBlockDownload() == 0 && ((pindex= mapBlockIndex[srchash]) == 0 || pindex->nHeight != *notarizedheightp) )
581 if ( sp->NOTARIZED_HEIGHT > 0 && sp->NOTARIZED_HEIGHT < *notarizedheightp )
582 rewindtarget = sp->NOTARIZED_HEIGHT - 1;
583 else if ( *notarizedheightp > 101 )
584 rewindtarget = *notarizedheightp - 101;
585 else rewindtarget = 0;
586 if ( rewindtarget != 0 && rewindtarget > KOMODO_REWIND && rewindtarget > last_rewind )
588 if ( last_rewind != 0 )
590 KOMODO_REWIND = rewindtarget;
591 fprintf(stderr,"%s FORK detected. notarized.%d %s not in this chain! last notarization %d -> rewindtarget.%d\n",ASSETCHAINS_SYMBOL,*notarizedheightp,srchash.ToString().c_str(),sp->NOTARIZED_HEIGHT,rewindtarget);
593 last_rewind = rewindtarget;
595 } else validated = 1;
596 if ( notarized != 0 && *notarizedheightp > sp->NOTARIZED_HEIGHT && *notarizedheightp < height && validated != 0 )
598 int32_t nameoffset = (int32_t)strlen(ASSETCHAINS_SYMBOL) + 1;
599 sp->NOTARIZED_HEIGHT = *notarizedheightp;
600 sp->NOTARIZED_HASH = srchash;
601 sp->NOTARIZED_DESTTXID = desttxid;
602 memset(&sp->MoM,0,sizeof(sp->MoM));
604 if ( len+36 <= opretlen )
606 len += iguana_rwbignum(0,&scriptbuf[len+nameoffset],32,(uint8_t *)&sp->MoM);
607 len += iguana_rwnum(0,&scriptbuf[len+nameoffset],sizeof(sp->MoMdepth),(uint8_t *)&sp->MoMdepth);
608 if ( sp->MoM == zero || sp->MoMdepth > 1440 || sp->MoMdepth < 0 )
610 memset(&sp->MoM,0,sizeof(sp->MoM));
615 //printf("VALID %s MoM.%s [%d]\n",ASSETCHAINS_SYMBOL,sp->MoM.ToString().c_str(),sp->MoMdepth);
618 komodo_stateupdate(height,0,0,0,zero,0,0,0,0,0,0,0,0,0,0,sp->MoM,sp->MoMdepth);
620 if ( ASSETCHAINS_SYMBOL[0] != 0 )
621 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);
622 if ( ASSETCHAINS_SYMBOL[0] == 0 )
627 komodo_statefname(fname,ASSETCHAINS_SYMBOL,(char *)"signedmasks");
628 if ( (signedfp= fopen(fname,"rb+")) == 0 )
629 signedfp = fopen(fname,"wb");
630 else fseek(signedfp,0,SEEK_END);
634 fwrite(&height,1,sizeof(height),signedfp);
635 fwrite(&signedmask,1,sizeof(signedmask),signedfp);
638 if ( opretlen > len && scriptbuf[len] == 'A' )
640 //for (i=0; i<opretlen-len; i++)
641 // printf("%02x",scriptbuf[len+i]);
642 //printf(" Found extradata.[%d] %d - %d\n",opretlen-len,opretlen,len);
643 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);
646 } else if ( *notarizedheightp != sp->NOTARIZED_HEIGHT )
647 printf("validated.%d notarized.%d %llx reject ht.%d NOTARIZED.%d prev.%d %s.%s DESTTXID.%s (%s) len.%d opretlen.%d\n",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(),(char *)&scriptbuf[len],len,opretlen);
649 else if ( i == 0 && j == 1 && opretlen == 149 )
651 if ( notaryid >= 0 && notaryid < 64 )
652 komodo_paxpricefeed(height,&scriptbuf[len],opretlen);
656 //int32_t k; for (k=0; k<scriptlen; k++)
657 // printf("%02x",scriptbuf[k]);
658 //printf(" <- script ht.%d i.%d j.%d value %.8f %s\n",height,i,j,dstr(value),ASSETCHAINS_SYMBOL);
659 if ( opretlen >= 32*2+4 && strcmp(ASSETCHAINS_SYMBOL[0]==0?"KMD":ASSETCHAINS_SYMBOL,(char *)&scriptbuf[len+32*2+4]) == 0 )
662 if ( scriptbuf[len+k] != 0 )
666 *isratificationp = 1;
667 printf("ISRATIFICATION (%s)\n",(char *)&scriptbuf[len+32*2+4]);
671 if ( *isratificationp == 0 && (signedmask != 0 || (scriptbuf[len] != 'X' && scriptbuf[len] != 'A')) ) // && scriptbuf[len] != 'I')
672 komodo_stateupdate(height,0,0,0,txhash,0,0,0,0,0,0,value,&scriptbuf[len],opretlen,j,zero,0);
678 /*int32_t komodo_isratify(int32_t isspecial,int32_t numvalid)
680 if ( isspecial != 0 && numvalid >= KOMODO_MINRATIFY )
685 // Special tx have vout[0] -> CRYPTO777
686 // with more than KOMODO_MINRATIFY pay2pubkey outputs -> ratify
687 // if all outputs to notary -> notary utxo
688 // if txi == 0 && 2 outputs and 2nd OP_RETURN, len == 32*2+4 -> notarized, 1st byte 'P' -> pricefeed
689 // OP_RETURN: 'D' -> deposit, 'W' -> withdraw
691 int32_t gettxout_scriptPubKey(uint8_t *scriptPubKey,int32_t maxsize,uint256 txid,int32_t n);
693 int32_t komodo_notarycmp(uint8_t *scriptPubKey,int32_t scriptlen,uint8_t pubkeys[64][33],int32_t numnotaries,uint8_t rmd160[20])
696 if ( scriptlen == 25 && memcmp(&scriptPubKey[3],rmd160,20) == 0 )
698 else if ( scriptlen == 35 )
700 for (i=0; i<numnotaries; i++)
701 if ( memcmp(&scriptPubKey[1],pubkeys[i],33) == 0 )
707 void komodo_connectblock(CBlockIndex *pindex,CBlock& block)
709 static int32_t hwmheight;
710 uint64_t signedmask,voutmask; char symbol[KOMODO_ASSETCHAIN_MAXLEN],dest[KOMODO_ASSETCHAIN_MAXLEN]; struct komodo_state *sp;
711 uint8_t scriptbuf[10001],pubkeys[64][33],rmd160[20],scriptPubKey[35]; uint256 zero,btctxid,txhash;
712 int32_t i,j,k,numnotaries,notarized,scriptlen,isratification,nid,numvalid,specialtx,notarizedheight,notaryid,len,numvouts,numvins,height,txn_count;
713 memset(&zero,0,sizeof(zero));
714 komodo_init(pindex->nHeight);
715 KOMODO_INITDONE = (uint32_t)time(NULL);
716 if ( (sp= komodo_stateptr(symbol,dest)) == 0 )
718 fprintf(stderr,"unexpected null komodostateptr.[%s]\n",ASSETCHAINS_SYMBOL);
721 //fprintf(stderr,"%s connect.%d\n",ASSETCHAINS_SYMBOL,pindex->nHeight);
722 numnotaries = komodo_notaries(pubkeys,pindex->nHeight,pindex->GetBlockTime());
723 calc_rmd160_sha256(rmd160,pubkeys[0],33);
724 if ( pindex->nHeight > hwmheight )
725 hwmheight = pindex->nHeight;
728 if ( pindex->nHeight != hwmheight )
729 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);
730 komodo_event_rewind(sp,symbol,pindex->nHeight);
731 komodo_stateupdate(pindex->nHeight,0,0,0,zero,0,0,0,0,-pindex->nHeight,pindex->nTime,0,0,0,0,zero,0);
733 komodo_currentheight_set(chainActive.Tip()->nHeight);
736 height = pindex->nHeight;
737 txn_count = block.vtx.size();
738 for (i=0; i<txn_count; i++)
740 txhash = block.vtx[i].GetHash();
741 numvouts = block.vtx[i].vout.size();
743 voutmask = specialtx = notarizedheight = isratification = notarized = 0;
744 signedmask = (height < 91400) ? 1 : 0;
745 numvins = block.vtx[i].vin.size();
746 for (j=0; j<numvins; j++)
748 if ( i == 0 && j == 0 )
750 if ( (scriptlen= gettxout_scriptPubKey(scriptPubKey,sizeof(scriptPubKey),block.vtx[i].vin[j].prevout.hash,block.vtx[i].vin[j].prevout.n)) > 0 )
752 if ( (k= komodo_notarycmp(scriptPubKey,scriptlen,pubkeys,numnotaries,rmd160)) >= 0 )
753 signedmask |= (1LL << k);
754 else if ( 0 && numvins >= 17 )
757 for (k=0; k<scriptlen; k++)
758 printf("%02x",scriptPubKey[k]);
759 printf(" scriptPubKey doesnt match any notary vini.%d of %d\n",j,numvins);
761 } else printf("cant get scriptPubKey for ht.%d txi.%d vin.%d\n",height,i,j);
763 numvalid = bitweight(signedmask);
764 if ( (((height < 90000 || (signedmask & 1) != 0) && numvalid >= KOMODO_MINRATIFY) ||
765 (numvalid >= KOMODO_MINRATIFY && ASSETCHAINS_SYMBOL[0] != 0) ||
766 numvalid > (numnotaries/5)) )
768 if ( ASSETCHAINS_SYMBOL[0] != 0 )
770 static FILE *signedfp;
774 komodo_statefname(fname,ASSETCHAINS_SYMBOL,(char *)"signedmasks");
775 if ( (signedfp= fopen(fname,"rb+")) == 0 )
776 signedfp = fopen(fname,"wb");
777 else fseek(signedfp,0,SEEK_END);
781 fwrite(&height,1,sizeof(height),signedfp);
782 fwrite(&signedmask,1,sizeof(signedmask),signedfp);
785 printf("[%s] ht.%d txi.%d signedmask.%llx numvins.%d numvouts.%d <<<<<<<<<<< notarized\n",ASSETCHAINS_SYMBOL,height,i,(long long)signedmask,numvins,numvouts);
789 if ( NOTARY_PUBKEY33[0] != 0 && ASSETCHAINS_SYMBOL[0] == 0 )
790 printf("(tx.%d: ",i);
791 for (j=0; j<numvouts; j++)
793 /*if ( i == 0 && j == 0 )
795 uint8_t *script = (uint8_t *)block.vtx[0].vout[numvouts-1].scriptPubKey.data();
796 if ( numvouts <= 2 || script[0] != 0x6a )
798 if ( numvouts == 2 && block.vtx[0].vout[1].nValue != 0 )
800 fprintf(stderr,"ht.%d numvouts.%d value %.8f\n",height,numvouts,dstr(block.vtx[0].vout[1].nValue));
801 if ( height >= 235300 && block.vtx[0].vout[1].nValue >= 100000*COIN )
802 block.vtx[0].vout[1].nValue = 0;
807 if ( NOTARY_PUBKEY33[0] != 0 && ASSETCHAINS_SYMBOL[0] == 0 )
808 printf("%.8f ",dstr(block.vtx[i].vout[j].nValue));
809 len = block.vtx[i].vout[j].scriptPubKey.size();
810 if ( len >= sizeof(uint32_t) && len <= sizeof(scriptbuf) )
813 memcpy(scriptbuf,block.vtx[i].vout[j].scriptPubKey.data(),len);
815 memcpy(scriptbuf,(uint8_t *)&block.vtx[i].vout[j].scriptPubKey[0],len);
817 notaryid = komodo_voutupdate(&isratification,notaryid,scriptbuf,len,height,txhash,i,j,&voutmask,&specialtx,¬arizedheight,(uint64_t)block.vtx[i].vout[j].nValue,notarized,signedmask,(uint32_t)chainActive.Tip()->GetBlockTime());
820 for (k=0; k<len; k++)
821 printf("%02x",scriptbuf[k]);
822 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());
826 if ( NOTARY_PUBKEY33[0] != 0 && ASSETCHAINS_SYMBOL[0] == 0 )
828 if ( 0 && ASSETCHAINS_SYMBOL[0] == 0 )
829 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);
830 if ( notarized != 0 && (notarizedheight != 0 || specialtx != 0) )
832 if ( isratification != 0 )
834 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);
835 printf("ht.%d specialtx.%d isratification.%d numvouts.%d signed.%llx numnotaries.%d\n",height,specialtx,isratification,numvouts,(long long)signedmask,numnotaries);
837 if ( specialtx != 0 && isratification != 0 && numvouts > 2 )
840 memset(pubkeys,0,sizeof(pubkeys));
841 for (j=1; j<numvouts-1; j++)
843 len = block.vtx[i].vout[j].scriptPubKey.size();
844 if ( len >= sizeof(uint32_t) && len <= sizeof(scriptbuf) )
847 memcpy(scriptbuf,block.vtx[i].vout[j].scriptPubKey.data(),len);
849 memcpy(scriptbuf,(uint8_t *)&block.vtx[i].vout[j].scriptPubKey[0],len);
851 if ( len == 35 && scriptbuf[0] == 33 && scriptbuf[34] == 0xac )
853 memcpy(pubkeys[numvalid++],scriptbuf+1,33);
855 printf("%02x",scriptbuf[k+1]);
856 printf(" <- new notary.[%d]\n",j-1);
860 if ( ((signedmask & 1) != 0 && numvalid >= KOMODO_MINRATIFY) || bitweight(signedmask) > (numnotaries/3) )
862 memset(&txhash,0,sizeof(txhash));
863 komodo_stateupdate(height,pubkeys,numvalid,0,txhash,0,0,0,0,0,0,0,0,0,0,zero,0);
864 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);
865 } else printf("signedmask.%llx numvalid.%d wt.%d numnotaries.%d\n",(long long)signedmask,numvalid,bitweight(signedmask),numnotaries);
869 if ( NOTARY_PUBKEY33[0] != 0 && ASSETCHAINS_SYMBOL[0] == 0 )
870 printf("%s ht.%d\n",ASSETCHAINS_SYMBOL[0] == 0 ? "KMD" : ASSETCHAINS_SYMBOL,height);
871 if ( pindex->nHeight == hwmheight )
872 komodo_stateupdate(height,0,0,0,zero,0,0,0,0,height,(uint32_t)pindex->nTime,0,0,0,0,zero,0);
873 } else fprintf(stderr,"komodo_connectblock: unexpected null pindex\n");
874 //KOMODO_INITDONE = (uint32_t)time(NULL);
875 //fprintf(stderr,"%s end connect.%d\n",ASSETCHAINS_SYMBOL,pindex->nHeight);