20dfaa77f5
Bugfix for 790833 bug Performance improvements If your node crashed, you should be able to just pull and rebuild and it should startup. We are not seeing the need to resync on most nodes. If you are mining, this is a must update right away
807 lines
37 KiB
C
807 lines
37 KiB
C
/******************************************************************************
|
|
* Copyright © 2014-2017 The SuperNET Developers. *
|
|
* *
|
|
* See the AUTHORS, DEVELOPER-AGREEMENT and LICENSE files at *
|
|
* the top-level directory of this distribution for the individual copyright *
|
|
* holder information and the developer policies on copyright and licensing. *
|
|
* *
|
|
* Unless otherwise agreed in a custom licensing agreement, no part of the *
|
|
* SuperNET software, including this file may be copied, modified, propagated *
|
|
* or distributed except according to the terms contained in the LICENSE file *
|
|
* *
|
|
* Removal or modification of this copyright notice is prohibited. *
|
|
* *
|
|
******************************************************************************/
|
|
|
|
#ifndef H_KOMODO_H
|
|
#define H_KOMODO_H
|
|
#include "komodo_defs.h"
|
|
|
|
#ifdef _WIN32
|
|
#define printf(...)
|
|
#endif
|
|
|
|
// Todo:
|
|
// verify: reorgs
|
|
|
|
#define KOMODO_ASSETCHAINS_WAITNOTARIZE
|
|
#define KOMODO_PAXMAX (10000 * COIN)
|
|
|
|
#include <stdint.h>
|
|
#include <stdio.h>
|
|
#include <pthread.h>
|
|
#include <ctype.h>
|
|
#include "uthash.h"
|
|
#include "utlist.h"
|
|
|
|
int32_t gettxout_scriptPubKey(uint8_t *scriptPubkey,int32_t maxsize,uint256 txid,int32_t n);
|
|
void komodo_event_rewind(struct komodo_state *sp,char *symbol,int32_t height);
|
|
void komodo_connectblock(CBlockIndex *pindex,CBlock& block);
|
|
|
|
#include "komodo_structs.h"
|
|
#include "komodo_globals.h"
|
|
#include "komodo_utils.h"
|
|
#include "komodo_curve25519.h"
|
|
|
|
#include "komodo_cJSON.c"
|
|
#include "komodo_bitcoind.h"
|
|
#include "komodo_interest.h"
|
|
#include "komodo_pax.h"
|
|
#include "komodo_notary.h"
|
|
|
|
int32_t komodo_parsestatefile(struct komodo_state *sp,FILE *fp,char *symbol,char *dest);
|
|
#include "komodo_kv.h"
|
|
#include "komodo_jumblr.h"
|
|
#include "komodo_gateway.h"
|
|
#include "komodo_events.h"
|
|
|
|
void komodo_currentheight_set(int32_t height)
|
|
{
|
|
char symbol[KOMODO_ASSETCHAIN_MAXLEN],dest[KOMODO_ASSETCHAIN_MAXLEN]; struct komodo_state *sp;
|
|
if ( (sp= komodo_stateptr(symbol,dest)) != 0 )
|
|
sp->CURRENT_HEIGHT = height;
|
|
}
|
|
|
|
int32_t komodo_currentheight()
|
|
{
|
|
char symbol[KOMODO_ASSETCHAIN_MAXLEN],dest[KOMODO_ASSETCHAIN_MAXLEN]; struct komodo_state *sp;
|
|
if ( (sp= komodo_stateptr(symbol,dest)) != 0 )
|
|
return(sp->CURRENT_HEIGHT);
|
|
else return(0);
|
|
}
|
|
|
|
int32_t komodo_parsestatefile(struct komodo_state *sp,FILE *fp,char *symbol,char *dest)
|
|
{
|
|
static int32_t errs;
|
|
int32_t func,ht,notarized_height,num,matched=0; uint256 notarized_hash,notarized_desttxid; uint8_t pubkeys[64][33];
|
|
if ( (func= fgetc(fp)) != EOF )
|
|
{
|
|
if ( ASSETCHAINS_SYMBOL[0] == 0 && strcmp(symbol,"KMD") == 0 )
|
|
matched = 1;
|
|
else matched = (strcmp(symbol,ASSETCHAINS_SYMBOL) == 0);
|
|
if ( fread(&ht,1,sizeof(ht),fp) != sizeof(ht) )
|
|
errs++;
|
|
if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 && func != 'T' )
|
|
printf("[%s] matched.%d fpos.%ld func.(%d %c) ht.%d\n",ASSETCHAINS_SYMBOL,matched,ftell(fp),func,func,ht);
|
|
if ( func == 'P' )
|
|
{
|
|
if ( (num= fgetc(fp)) <= 64 )
|
|
{
|
|
if ( fread(pubkeys,33,num,fp) != num )
|
|
errs++;
|
|
else
|
|
{
|
|
//printf("updated %d pubkeys at %s ht.%d\n",num,symbol,ht);
|
|
if ( (KOMODO_EXTERNAL_NOTARIES != 0 && matched != 0) || (strcmp(symbol,"KMD") == 0 && KOMODO_EXTERNAL_NOTARIES == 0) )
|
|
komodo_eventadd_pubkeys(sp,symbol,ht,num,pubkeys);
|
|
}
|
|
} else printf("illegal num.%d\n",num);
|
|
}
|
|
else if ( func == 'N' )
|
|
{
|
|
if ( fread(¬arized_height,1,sizeof(notarized_height),fp) != sizeof(notarized_height) )
|
|
errs++;
|
|
if ( fread(¬arized_hash,1,sizeof(notarized_hash),fp) != sizeof(notarized_hash) )
|
|
errs++;
|
|
if ( fread(¬arized_desttxid,1,sizeof(notarized_desttxid),fp) != sizeof(notarized_desttxid) )
|
|
errs++;
|
|
if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 && sp != 0 )
|
|
printf("%s load[%s.%d -> %s] NOTARIZED %d %s\n",ASSETCHAINS_SYMBOL,symbol,sp->NUM_NPOINTS,dest,notarized_height,notarized_hash.ToString().c_str());
|
|
//if ( matched != 0 ) global independent states -> inside *sp
|
|
komodo_eventadd_notarized(sp,symbol,ht,dest,notarized_hash,notarized_desttxid,notarized_height);
|
|
}
|
|
else if ( func == 'U' ) // deprecated
|
|
{
|
|
uint8_t n,nid; uint256 hash; uint64_t mask;
|
|
n = fgetc(fp);
|
|
nid = fgetc(fp);
|
|
//printf("U %d %d\n",n,nid);
|
|
if ( fread(&mask,1,sizeof(mask),fp) != sizeof(mask) )
|
|
errs++;
|
|
if ( fread(&hash,1,sizeof(hash),fp) != sizeof(hash) )
|
|
errs++;
|
|
//if ( matched != 0 )
|
|
// komodo_eventadd_utxo(sp,symbol,ht,nid,hash,mask,n);
|
|
}
|
|
else if ( func == 'K' )
|
|
{
|
|
int32_t kheight;
|
|
if ( fread(&kheight,1,sizeof(kheight),fp) != sizeof(kheight) )
|
|
errs++;
|
|
//if ( matched != 0 ) global independent states -> inside *sp
|
|
//printf("%s.%d load[%s] ht.%d\n",ASSETCHAINS_SYMBOL,ht,symbol,kheight);
|
|
komodo_eventadd_kmdheight(sp,symbol,ht,kheight,0);
|
|
}
|
|
else if ( func == 'T' )
|
|
{
|
|
int32_t kheight,ktimestamp;
|
|
if ( fread(&kheight,1,sizeof(kheight),fp) != sizeof(kheight) )
|
|
errs++;
|
|
if ( fread(&ktimestamp,1,sizeof(ktimestamp),fp) != sizeof(ktimestamp) )
|
|
errs++;
|
|
//if ( matched != 0 ) global independent states -> inside *sp
|
|
//printf("%s.%d load[%s] ht.%d t.%u\n",ASSETCHAINS_SYMBOL,ht,symbol,kheight,ktimestamp);
|
|
komodo_eventadd_kmdheight(sp,symbol,ht,kheight,ktimestamp);
|
|
}
|
|
else if ( func == 'R' )
|
|
{
|
|
uint16_t olen,v; uint64_t ovalue; uint256 txid; uint8_t opret[16384];
|
|
if ( fread(&txid,1,sizeof(txid),fp) != sizeof(txid) )
|
|
errs++;
|
|
if ( fread(&v,1,sizeof(v),fp) != sizeof(v) )
|
|
errs++;
|
|
if ( fread(&ovalue,1,sizeof(ovalue),fp) != sizeof(ovalue) )
|
|
errs++;
|
|
if ( fread(&olen,1,sizeof(olen),fp) != sizeof(olen) )
|
|
errs++;
|
|
if ( olen < sizeof(opret) )
|
|
{
|
|
if ( fread(opret,1,olen,fp) != olen )
|
|
errs++;
|
|
if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 && matched != 0 )
|
|
{
|
|
int32_t i; for (i=0; i<olen; i++)
|
|
printf("%02x",opret[i]);
|
|
printf(" %s.%d load[%s] opret[%c] len.%d %.8f\n",ASSETCHAINS_SYMBOL,ht,symbol,opret[0],olen,(double)ovalue/COIN);
|
|
}
|
|
komodo_eventadd_opreturn(sp,symbol,ht,txid,ovalue,v,opret,olen); // global shared state -> global PAX
|
|
} else
|
|
{
|
|
int32_t i;
|
|
for (i=0; i<olen; i++)
|
|
fgetc(fp);
|
|
//printf("illegal olen.%u\n",olen);
|
|
}
|
|
}
|
|
else if ( func == 'D' )
|
|
{
|
|
printf("unexpected function D[%d]\n",ht);
|
|
}
|
|
else if ( func == 'V' )
|
|
{
|
|
int32_t numpvals; uint32_t pvals[128];
|
|
numpvals = fgetc(fp);
|
|
if ( numpvals*sizeof(uint32_t) <= sizeof(pvals) && fread(pvals,sizeof(uint32_t),numpvals,fp) == numpvals )
|
|
{
|
|
//if ( matched != 0 ) global shared state -> global PVALS
|
|
//printf("%s load[%s] prices %d\n",ASSETCHAINS_SYMBOL,symbol,ht);
|
|
komodo_eventadd_pricefeed(sp,symbol,ht,pvals,numpvals);
|
|
//printf("load pvals ht.%d numpvals.%d\n",ht,numpvals);
|
|
} else printf("error loading pvals[%d]\n",numpvals);
|
|
}
|
|
else printf("[%s] %s illegal func.(%d %c)\n",ASSETCHAINS_SYMBOL,symbol,func,func);
|
|
return(func);
|
|
} else return(-1);
|
|
}
|
|
|
|
int32_t memread(void *dest,int32_t size,uint8_t *filedata,long *fposp,long datalen)
|
|
{
|
|
if ( *fposp+size <= datalen )
|
|
{
|
|
memcpy(dest,&filedata[*fposp],size);
|
|
(*fposp) += size;
|
|
return(size);
|
|
}
|
|
return(-1);
|
|
}
|
|
|
|
int32_t komodo_parsestatefiledata(struct komodo_state *sp,uint8_t *filedata,long *fposp,long datalen,char *symbol,char *dest)
|
|
{
|
|
static int32_t errs;
|
|
int32_t func= -1,ht,notarized_height,num,matched=0; uint256 notarized_hash,notarized_desttxid; uint8_t pubkeys[64][33]; long fpos = *fposp;
|
|
if ( fpos < datalen )
|
|
{
|
|
func = filedata[fpos++];
|
|
if ( ASSETCHAINS_SYMBOL[0] == 0 && strcmp(symbol,"KMD") == 0 )
|
|
matched = 1;
|
|
else matched = (strcmp(symbol,ASSETCHAINS_SYMBOL) == 0);
|
|
if ( memread(&ht,sizeof(ht),filedata,&fpos,datalen) != sizeof(ht) )
|
|
errs++;
|
|
if ( func == 'P' )
|
|
{
|
|
if ( (num= filedata[fpos++]) <= 64 )
|
|
{
|
|
if ( memread(pubkeys,33*num,filedata,&fpos,datalen) != 33*num )
|
|
errs++;
|
|
else
|
|
{
|
|
//printf("updated %d pubkeys at %s ht.%d\n",num,symbol,ht);
|
|
if ( (KOMODO_EXTERNAL_NOTARIES != 0 && matched != 0) || (strcmp(symbol,"KMD") == 0 && KOMODO_EXTERNAL_NOTARIES == 0) )
|
|
komodo_eventadd_pubkeys(sp,symbol,ht,num,pubkeys);
|
|
}
|
|
} else printf("illegal num.%d\n",num);
|
|
}
|
|
else if ( func == 'N' )
|
|
{
|
|
if ( memread(¬arized_height,sizeof(notarized_height),filedata,&fpos,datalen) != sizeof(notarized_height) )
|
|
errs++;
|
|
if ( memread(¬arized_hash,sizeof(notarized_hash),filedata,&fpos,datalen) != sizeof(notarized_hash) )
|
|
errs++;
|
|
if ( memread(¬arized_desttxid,sizeof(notarized_desttxid),filedata,&fpos,datalen) != sizeof(notarized_desttxid) )
|
|
errs++;
|
|
if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 && sp != 0 )
|
|
printf("%s load[%s.%d -> %s] NOTARIZED %d %s\n",ASSETCHAINS_SYMBOL,symbol,sp->NUM_NPOINTS,dest,notarized_height,notarized_hash.ToString().c_str());
|
|
//if ( matched != 0 ) global independent states -> inside *sp
|
|
komodo_eventadd_notarized(sp,symbol,ht,dest,notarized_hash,notarized_desttxid,notarized_height);
|
|
}
|
|
else if ( func == 'U' ) // deprecated
|
|
{
|
|
uint8_t n,nid; uint256 hash; uint64_t mask;
|
|
n = filedata[fpos++];
|
|
nid = filedata[fpos++];
|
|
//printf("U %d %d\n",n,nid);
|
|
if ( memread(&mask,sizeof(mask),filedata,&fpos,datalen) != sizeof(mask) )
|
|
errs++;
|
|
if ( memread(&hash,sizeof(hash),filedata,&fpos,datalen) != sizeof(hash) )
|
|
errs++;
|
|
}
|
|
else if ( func == 'K' )
|
|
{
|
|
int32_t kheight;
|
|
if ( memread(&kheight,sizeof(kheight),filedata,&fpos,datalen) != sizeof(kheight) )
|
|
errs++;
|
|
komodo_eventadd_kmdheight(sp,symbol,ht,kheight,0);
|
|
}
|
|
else if ( func == 'T' )
|
|
{
|
|
int32_t kheight,ktimestamp;
|
|
if ( memread(&kheight,sizeof(kheight),filedata,&fpos,datalen) != sizeof(kheight) )
|
|
errs++;
|
|
if ( memread(&ktimestamp,sizeof(ktimestamp),filedata,&fpos,datalen) != sizeof(ktimestamp) )
|
|
errs++;
|
|
//if ( matched != 0 ) global independent states -> inside *sp
|
|
//printf("%s.%d load[%s] ht.%d t.%u\n",ASSETCHAINS_SYMBOL,ht,symbol,kheight,ktimestamp);
|
|
komodo_eventadd_kmdheight(sp,symbol,ht,kheight,ktimestamp);
|
|
}
|
|
else if ( func == 'R' )
|
|
{
|
|
uint16_t olen,v; uint64_t ovalue; uint256 txid; uint8_t opret[16384];
|
|
if ( memread(&txid,sizeof(txid),filedata,&fpos,datalen) != sizeof(txid) )
|
|
errs++;
|
|
if ( memread(&v,sizeof(v),filedata,&fpos,datalen) != sizeof(v) )
|
|
errs++;
|
|
if ( memread(&ovalue,sizeof(ovalue),filedata,&fpos,datalen) != sizeof(ovalue) )
|
|
errs++;
|
|
if ( memread(&olen,sizeof(olen),filedata,&fpos,datalen) != sizeof(olen) )
|
|
errs++;
|
|
if ( olen < sizeof(opret) )
|
|
{
|
|
if ( memread(opret,olen,filedata,&fpos,datalen) != olen )
|
|
errs++;
|
|
if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 && matched != 0 )
|
|
{
|
|
int32_t i; for (i=0; i<olen; i++)
|
|
printf("%02x",opret[i]);
|
|
printf(" %s.%d load[%s] opret[%c] len.%d %.8f\n",ASSETCHAINS_SYMBOL,ht,symbol,opret[0],olen,(double)ovalue/COIN);
|
|
}
|
|
komodo_eventadd_opreturn(sp,symbol,ht,txid,ovalue,v,opret,olen); // global shared state -> global PAX
|
|
} else
|
|
{
|
|
int32_t i;
|
|
for (i=0; i<olen; i++)
|
|
filedata[fpos++];
|
|
//printf("illegal olen.%u\n",olen);
|
|
}
|
|
}
|
|
else if ( func == 'D' )
|
|
{
|
|
printf("unexpected function D[%d]\n",ht);
|
|
}
|
|
else if ( func == 'V' )
|
|
{
|
|
int32_t numpvals; uint32_t pvals[128];
|
|
numpvals = filedata[fpos++];
|
|
if ( numpvals*sizeof(uint32_t) <= sizeof(pvals) && memread(pvals,(int32_t)(sizeof(uint32_t)*numpvals),filedata,&fpos,datalen) == numpvals*sizeof(uint32_t) )
|
|
{
|
|
//if ( matched != 0 ) global shared state -> global PVALS
|
|
//printf("%s load[%s] prices %d\n",ASSETCHAINS_SYMBOL,symbol,ht);
|
|
komodo_eventadd_pricefeed(sp,symbol,ht,pvals,numpvals);
|
|
//printf("load pvals ht.%d numpvals.%d\n",ht,numpvals);
|
|
} else printf("error loading pvals[%d]\n",numpvals);
|
|
}
|
|
else printf("[%s] %s illegal func.(%d %c)\n",ASSETCHAINS_SYMBOL,symbol,func,func);
|
|
*fposp = fpos;
|
|
return(func);
|
|
}
|
|
return(-1);
|
|
}
|
|
|
|
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)
|
|
{
|
|
static FILE *fp; static int32_t errs,didinit;
|
|
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];
|
|
if ( didinit == 0 )
|
|
{
|
|
portable_mutex_init(&KOMODO_KV_mutex);
|
|
didinit = 1;
|
|
}
|
|
if ( (sp= komodo_stateptr(symbol,dest)) == 0 )
|
|
{
|
|
KOMODO_INITDONE = (uint32_t)time(NULL);
|
|
printf("[%s] no komodo_stateptr\n",ASSETCHAINS_SYMBOL);
|
|
return;
|
|
}
|
|
//printf("[%s] (%s) -> (%s)\n",ASSETCHAINS_SYMBOL,symbol,dest);
|
|
if ( fp == 0 )
|
|
{
|
|
komodo_statefname(fname,ASSETCHAINS_SYMBOL,(char *)"komodostate");
|
|
if ( (fp= fopen(fname,"rb+")) != 0 )
|
|
{
|
|
if ( (retval= komodo_faststateinit(sp,fname,symbol,dest)) > 0 )
|
|
fseek(fp,0,SEEK_END);
|
|
else
|
|
{
|
|
fprintf(stderr,"komodo_faststateinit retval.%d\n",retval);
|
|
while ( komodo_parsestatefile(sp,fp,symbol,dest) >= 0 )
|
|
;
|
|
}
|
|
} else fp = fopen(fname,"wb+");
|
|
KOMODO_INITDONE = (uint32_t)time(NULL);
|
|
}
|
|
if ( height <= 0 )
|
|
{
|
|
//printf("early return: stateupdate height.%d\n",height);
|
|
return;
|
|
}
|
|
if ( fp != 0 ) // write out funcid, height, other fields, call side effect function
|
|
{
|
|
//printf("fpos.%ld ",ftell(fp));
|
|
if ( KMDheight != 0 )
|
|
{
|
|
if ( KMDtimestamp != 0 )
|
|
{
|
|
fputc('T',fp);
|
|
if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
|
|
errs++;
|
|
if ( fwrite(&KMDheight,1,sizeof(KMDheight),fp) != sizeof(KMDheight) )
|
|
errs++;
|
|
if ( fwrite(&KMDtimestamp,1,sizeof(KMDtimestamp),fp) != sizeof(KMDtimestamp) )
|
|
errs++;
|
|
}
|
|
else
|
|
{
|
|
fputc('K',fp);
|
|
if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
|
|
errs++;
|
|
if ( fwrite(&KMDheight,1,sizeof(KMDheight),fp) != sizeof(KMDheight) )
|
|
errs++;
|
|
}
|
|
komodo_eventadd_kmdheight(sp,symbol,height,KMDheight,KMDtimestamp);
|
|
}
|
|
else if ( opretbuf != 0 && opretlen > 0 )
|
|
{
|
|
uint16_t olen = opretlen;
|
|
fputc('R',fp);
|
|
if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
|
|
errs++;
|
|
if ( fwrite(&txhash,1,sizeof(txhash),fp) != sizeof(txhash) )
|
|
errs++;
|
|
if ( fwrite(&vout,1,sizeof(vout),fp) != sizeof(vout) )
|
|
errs++;
|
|
if ( fwrite(&opretvalue,1,sizeof(opretvalue),fp) != sizeof(opretvalue) )
|
|
errs++;
|
|
if ( fwrite(&olen,1,sizeof(olen),fp) != olen )
|
|
errs++;
|
|
if ( fwrite(opretbuf,1,olen,fp) != olen )
|
|
errs++;
|
|
//printf("ht.%d R opret[%d] sp.%p\n",height,olen,sp);
|
|
//komodo_opreturn(height,opretvalue,opretbuf,olen,txhash,vout);
|
|
komodo_eventadd_opreturn(sp,symbol,height,txhash,opretvalue,vout,opretbuf,olen);
|
|
}
|
|
else if ( notarypubs != 0 && numnotaries > 0 )
|
|
{
|
|
printf("ht.%d func P[%d] errs.%d\n",height,numnotaries,errs);
|
|
fputc('P',fp);
|
|
if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
|
|
errs++;
|
|
fputc(numnotaries,fp);
|
|
if ( fwrite(notarypubs,33,numnotaries,fp) != numnotaries )
|
|
errs++;
|
|
komodo_eventadd_pubkeys(sp,symbol,height,numnotaries,notarypubs);
|
|
}
|
|
else if ( voutmask != 0 && numvouts > 0 )
|
|
{
|
|
//printf("ht.%d func U %d %d errs.%d hashsize.%ld\n",height,numvouts,notaryid,errs,sizeof(txhash));
|
|
fputc('U',fp);
|
|
if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
|
|
errs++;
|
|
fputc(numvouts,fp);
|
|
fputc(notaryid,fp);
|
|
if ( fwrite(&voutmask,1,sizeof(voutmask),fp) != sizeof(voutmask) )
|
|
errs++;
|
|
if ( fwrite(&txhash,1,sizeof(txhash),fp) != sizeof(txhash) )
|
|
errs++;
|
|
//komodo_eventadd_utxo(sp,symbol,height,notaryid,txhash,voutmask,numvouts);
|
|
}
|
|
else if ( pvals != 0 && numpvals > 0 )
|
|
{
|
|
int32_t i,nonz = 0;
|
|
for (i=0; i<32; i++)
|
|
if ( pvals[i] != 0 )
|
|
nonz++;
|
|
if ( nonz >= 32 )
|
|
{
|
|
fputc('V',fp);
|
|
if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
|
|
errs++;
|
|
fputc(numpvals,fp);
|
|
if ( fwrite(pvals,sizeof(uint32_t),numpvals,fp) != numpvals )
|
|
errs++;
|
|
komodo_eventadd_pricefeed(sp,symbol,height,pvals,numpvals);
|
|
//printf("ht.%d V numpvals[%d]\n",height,numpvals);
|
|
}
|
|
//printf("save pvals height.%d numpvals.%d\n",height,numpvals);
|
|
}
|
|
else if ( height != 0 )
|
|
{
|
|
//printf("ht.%d func N ht.%d errs.%d\n",height,NOTARIZED_HEIGHT,errs);
|
|
if ( sp != 0 )
|
|
{
|
|
fputc('N',fp);
|
|
if ( fwrite(&height,1,sizeof(height),fp) != sizeof(height) )
|
|
errs++;
|
|
if ( fwrite(&sp->NOTARIZED_HEIGHT,1,sizeof(sp->NOTARIZED_HEIGHT),fp) != sizeof(sp->NOTARIZED_HEIGHT) )
|
|
errs++;
|
|
if ( fwrite(&sp->NOTARIZED_HASH,1,sizeof(sp->NOTARIZED_HASH),fp) != sizeof(sp->NOTARIZED_HASH) )
|
|
errs++;
|
|
if ( fwrite(&sp->NOTARIZED_DESTTXID,1,sizeof(sp->NOTARIZED_DESTTXID),fp) != sizeof(sp->NOTARIZED_DESTTXID) )
|
|
errs++;
|
|
komodo_eventadd_notarized(sp,symbol,height,dest,sp->NOTARIZED_HASH,sp->NOTARIZED_DESTTXID,sp->NOTARIZED_HEIGHT);
|
|
}
|
|
}
|
|
fflush(fp);
|
|
}
|
|
}
|
|
|
|
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)
|
|
{
|
|
static uint256 zero; static FILE *signedfp;
|
|
int32_t opretlen,nid,k,len = 0; uint256 kmdtxid,desttxid; uint8_t crypto777[33]; struct komodo_state *sp; char symbol[KOMODO_ASSETCHAIN_MAXLEN],dest[KOMODO_ASSETCHAIN_MAXLEN];
|
|
if ( (sp= komodo_stateptr(symbol,dest)) == 0 )
|
|
return(-1);
|
|
if ( scriptlen == 35 && scriptbuf[0] == 33 && scriptbuf[34] == 0xac )
|
|
{
|
|
if ( i == 0 && j == 0 && memcmp(NOTARY_PUBKEY33,scriptbuf+1,33) == 0 && NOTARY_PUBKEY33[0] != 0 )
|
|
{
|
|
printf("%s KOMODO_LASTMINED.%d -> %d\n",ASSETCHAINS_SYMBOL,KOMODO_LASTMINED,height);
|
|
prevKOMODO_LASTMINED = KOMODO_LASTMINED;
|
|
KOMODO_LASTMINED = height;
|
|
}
|
|
decode_hex(crypto777,33,(char *)CRYPTO777_PUBSECPSTR);
|
|
/*for (k=0; k<33; k++)
|
|
printf("%02x",crypto777[k]);
|
|
printf(" crypto777 ");
|
|
for (k=0; k<scriptlen; k++)
|
|
printf("%02x",scriptbuf[k]);
|
|
printf(" <- script ht.%d i.%d j.%d cmp.%d\n",height,i,j,memcmp(crypto777,scriptbuf+1,33));*/
|
|
if ( memcmp(crypto777,scriptbuf+1,33) == 0 )
|
|
{
|
|
*specialtxp = 1;
|
|
//printf(">>>>>>>> ");
|
|
}
|
|
else if ( komodo_chosennotary(&nid,height,scriptbuf + 1,timestamp) >= 0 )
|
|
{
|
|
//printf("found notary.k%d\n",k);
|
|
if ( notaryid < 64 )
|
|
{
|
|
if ( notaryid < 0 )
|
|
{
|
|
notaryid = nid;
|
|
*voutmaskp |= (1LL << j);
|
|
}
|
|
else if ( notaryid != nid )
|
|
{
|
|
//for (i=0; i<33; i++)
|
|
// printf("%02x",scriptbuf[i+1]);
|
|
//printf(" %s mismatch notaryid.%d k.%d\n",ASSETCHAINS_SYMBOL,notaryid,nid);
|
|
notaryid = 64;
|
|
*voutmaskp = 0;
|
|
}
|
|
else *voutmaskp |= (1LL << j);
|
|
}
|
|
}
|
|
}
|
|
if ( scriptbuf[len++] == 0x6a )
|
|
{
|
|
if ( (opretlen= scriptbuf[len++]) == 0x4c )
|
|
opretlen = scriptbuf[len++];
|
|
else if ( opretlen == 0x4d )
|
|
{
|
|
opretlen = scriptbuf[len++];
|
|
opretlen += (scriptbuf[len++] << 8);
|
|
}
|
|
if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 )
|
|
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]);
|
|
if ( j == 1 && opretlen >= 32*2+4 && strcmp(ASSETCHAINS_SYMBOL[0]==0?"KMD":ASSETCHAINS_SYMBOL,(char *)&scriptbuf[len+32*2+4]) == 0 )
|
|
{
|
|
len += iguana_rwbignum(0,&scriptbuf[len],32,(uint8_t *)&kmdtxid);
|
|
len += iguana_rwnum(0,&scriptbuf[len],sizeof(*notarizedheightp),(uint8_t *)notarizedheightp);
|
|
len += iguana_rwbignum(0,&scriptbuf[len],32,(uint8_t *)&desttxid);
|
|
if ( notarized != 0 && *notarizedheightp > sp->NOTARIZED_HEIGHT && *notarizedheightp < height && (height < sp->CURRENT_HEIGHT-1000 || komodo_verifynotarization(ASSETCHAINS_SYMBOL[0]==0?(char *)"KMD":ASSETCHAINS_SYMBOL,(char *)(ASSETCHAINS_SYMBOL[0] == 0 ? "BTC" : "KMD"),height,*notarizedheightp,kmdtxid,desttxid) == 0) )
|
|
{
|
|
sp->NOTARIZED_HEIGHT = *notarizedheightp;
|
|
sp->NOTARIZED_HASH = kmdtxid;
|
|
sp->NOTARIZED_DESTTXID = desttxid;
|
|
komodo_stateupdate(height,0,0,0,zero,0,0,0,0,0,0,0,0,0,0);
|
|
len += 4;
|
|
if ( ASSETCHAINS_SYMBOL[0] != 0 )
|
|
printf("[%s] ht.%d NOTARIZED.%d %s.%s %sTXID.%s lens.(%d %d)\n",ASSETCHAINS_SYMBOL,height,*notarizedheightp,ASSETCHAINS_SYMBOL[0]==0?"KMD":ASSETCHAINS_SYMBOL,kmdtxid.ToString().c_str(),ASSETCHAINS_SYMBOL[0]==0?"BTC":"KMD",desttxid.ToString().c_str(),opretlen,len);
|
|
if ( ASSETCHAINS_SYMBOL[0] == 0 )
|
|
{
|
|
if ( signedfp == 0 )
|
|
{
|
|
char fname[512];
|
|
komodo_statefname(fname,ASSETCHAINS_SYMBOL,(char *)"signedmasks");
|
|
if ( (signedfp= fopen(fname,"rb+")) == 0 )
|
|
signedfp = fopen(fname,"wb");
|
|
else fseek(signedfp,0,SEEK_END);
|
|
}
|
|
if ( signedfp != 0 )
|
|
{
|
|
fwrite(&height,1,sizeof(height),signedfp);
|
|
fwrite(&signedmask,1,sizeof(signedmask),signedfp);
|
|
fflush(signedfp);
|
|
}
|
|
if ( opretlen > len && scriptbuf[len] == 'A' )
|
|
{
|
|
//for (i=0; i<opretlen-len; i++)
|
|
// printf("%02x",scriptbuf[len+i]);
|
|
//printf(" Found extradata.[%d] %d - %d\n",opretlen-len,opretlen,len);
|
|
komodo_stateupdate(height,0,0,0,txhash,0,0,0,0,0,0,value,&scriptbuf[len],opretlen-len+4+3+(scriptbuf[1] == 0x4d),j);
|
|
}
|
|
}
|
|
} else if ( height >= KOMODO_MAINNET_START )
|
|
printf("notarized.%d %llx reject ht.%d NOTARIZED.%d prev.%d %s.%s DESTTXID.%s (%s)\n",notarized,(long long)signedmask,height,*notarizedheightp,sp->NOTARIZED_HEIGHT,ASSETCHAINS_SYMBOL[0]==0?"KMD":ASSETCHAINS_SYMBOL,kmdtxid.ToString().c_str(),desttxid.ToString().c_str(),(char *)&scriptbuf[len]);
|
|
}
|
|
else if ( i == 0 && j == 1 && opretlen == 149 )
|
|
{
|
|
if ( notaryid >= 0 && notaryid < 64 )
|
|
komodo_paxpricefeed(height,&scriptbuf[len],opretlen);
|
|
}
|
|
else
|
|
{
|
|
//int32_t k; for (k=0; k<scriptlen; k++)
|
|
// printf("%02x",scriptbuf[k]);
|
|
//printf(" <- script ht.%d i.%d j.%d value %.8f %s\n",height,i,j,dstr(value),ASSETCHAINS_SYMBOL);
|
|
if ( opretlen >= 32*2+4 && strcmp(ASSETCHAINS_SYMBOL[0]==0?"KMD":ASSETCHAINS_SYMBOL,(char *)&scriptbuf[len+32*2+4]) == 0 )
|
|
{
|
|
for (k=0; k<32; k++)
|
|
if ( scriptbuf[len+k] != 0 )
|
|
break;
|
|
if ( k == 32 )
|
|
{
|
|
*isratificationp = 1;
|
|
printf("ISRATIFICATION (%s)\n",(char *)&scriptbuf[len+32*2+4]);
|
|
}
|
|
}
|
|
|
|
if ( *isratificationp == 0 && (signedmask != 0 || (scriptbuf[len] != 'X' && scriptbuf[len] != 'A')) ) // && scriptbuf[len] != 'I')
|
|
komodo_stateupdate(height,0,0,0,txhash,0,0,0,0,0,0,value,&scriptbuf[len],opretlen,j);
|
|
}
|
|
}
|
|
return(notaryid);
|
|
}
|
|
|
|
/*int32_t komodo_isratify(int32_t isspecial,int32_t numvalid)
|
|
{
|
|
if ( isspecial != 0 && numvalid >= KOMODO_MINRATIFY )
|
|
return(1);
|
|
else return(0);
|
|
}*/
|
|
|
|
// Special tx have vout[0] -> CRYPTO777
|
|
// with more than KOMODO_MINRATIFY pay2pubkey outputs -> ratify
|
|
// if all outputs to notary -> notary utxo
|
|
// if txi == 0 && 2 outputs and 2nd OP_RETURN, len == 32*2+4 -> notarized, 1st byte 'P' -> pricefeed
|
|
// OP_RETURN: 'D' -> deposit, 'W' -> withdraw
|
|
|
|
int32_t gettxout_scriptPubKey(uint8_t *scriptPubKey,int32_t maxsize,uint256 txid,int32_t n);
|
|
|
|
int32_t komodo_notarycmp(uint8_t *scriptPubKey,int32_t scriptlen,uint8_t pubkeys[64][33],int32_t numnotaries,uint8_t rmd160[20])
|
|
{
|
|
int32_t i;
|
|
if ( scriptlen == 25 && memcmp(&scriptPubKey[3],rmd160,20) == 0 )
|
|
return(0);
|
|
else if ( scriptlen == 35 )
|
|
{
|
|
for (i=0; i<numnotaries; i++)
|
|
if ( memcmp(&scriptPubKey[1],pubkeys[i],33) == 0 )
|
|
return(i);
|
|
}
|
|
return(-1);
|
|
}
|
|
|
|
void komodo_connectblock(CBlockIndex *pindex,CBlock& block)
|
|
{
|
|
static int32_t hwmheight;
|
|
uint64_t signedmask,voutmask; char symbol[KOMODO_ASSETCHAIN_MAXLEN],dest[KOMODO_ASSETCHAIN_MAXLEN]; struct komodo_state *sp;
|
|
uint8_t scriptbuf[4096],pubkeys[64][33],rmd160[20],scriptPubKey[35]; uint256 kmdtxid,zero,btctxid,txhash;
|
|
int32_t i,j,k,numnotaries,notarized,scriptlen,isratification,nid,numvalid,specialtx,notarizedheight,notaryid,len,numvouts,numvins,height,txn_count;
|
|
memset(&zero,0,sizeof(zero));
|
|
komodo_init(pindex->nHeight);
|
|
KOMODO_INITDONE = (uint32_t)time(NULL);
|
|
if ( (sp= komodo_stateptr(symbol,dest)) == 0 )
|
|
{
|
|
fprintf(stderr,"unexpected null komodostateptr.[%s]\n",ASSETCHAINS_SYMBOL);
|
|
return;
|
|
}
|
|
//fprintf(stderr,"%s connect.%d\n",ASSETCHAINS_SYMBOL,pindex->nHeight);
|
|
numnotaries = komodo_notaries(pubkeys,pindex->nHeight,pindex->GetBlockTime());
|
|
calc_rmd160_sha256(rmd160,pubkeys[0],33);
|
|
if ( pindex->nHeight > hwmheight )
|
|
hwmheight = pindex->nHeight;
|
|
else
|
|
{
|
|
if ( pindex->nHeight != hwmheight )
|
|
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);
|
|
komodo_event_rewind(sp,symbol,pindex->nHeight);
|
|
komodo_stateupdate(pindex->nHeight,0,0,0,zero,0,0,0,0,-pindex->nHeight,pindex->nTime,0,0,0,0);
|
|
}
|
|
komodo_currentheight_set(chainActive.Tip()->nHeight);
|
|
if ( pindex != 0 )
|
|
{
|
|
height = pindex->nHeight;
|
|
txn_count = block.vtx.size();
|
|
for (i=0; i<txn_count; i++)
|
|
{
|
|
txhash = block.vtx[i].GetHash();
|
|
numvouts = block.vtx[i].vout.size();
|
|
notaryid = -1;
|
|
voutmask = specialtx = notarizedheight = isratification = notarized = 0;
|
|
signedmask = (height < 91400) ? 1 : 0;
|
|
numvins = block.vtx[i].vin.size();
|
|
for (j=0; j<numvins; j++)
|
|
{
|
|
if ( i == 0 && j == 0 )
|
|
continue;
|
|
if ( (scriptlen= gettxout_scriptPubKey(scriptPubKey,sizeof(scriptPubKey),block.vtx[i].vin[j].prevout.hash,block.vtx[i].vin[j].prevout.n)) > 0 )
|
|
{
|
|
if ( (k= komodo_notarycmp(scriptPubKey,scriptlen,pubkeys,numnotaries,rmd160)) >= 0 )
|
|
signedmask |= (1LL << k);
|
|
else if ( 0 && numvins >= 17 )
|
|
{
|
|
int32_t k;
|
|
for (k=0; k<scriptlen; k++)
|
|
printf("%02x",scriptPubKey[k]);
|
|
printf(" scriptPubKey doesnt match any notary vini.%d of %d\n",j,numvins);
|
|
}
|
|
} else printf("cant get scriptPubKey for ht.%d txi.%d vin.%d\n",height,i,j);
|
|
}
|
|
numvalid = bitweight(signedmask);
|
|
if ( (((height < 90000 || (signedmask & 1) != 0) && numvalid >= KOMODO_MINRATIFY) ||
|
|
(numvalid >= KOMODO_MINRATIFY && ASSETCHAINS_SYMBOL[0] != 0) ||
|
|
numvalid > (numnotaries/5)) )
|
|
{
|
|
if ( ASSETCHAINS_SYMBOL[0] != 0 )
|
|
{
|
|
static FILE *signedfp;
|
|
if ( signedfp == 0 )
|
|
{
|
|
char fname[512];
|
|
komodo_statefname(fname,ASSETCHAINS_SYMBOL,(char *)"signedmasks");
|
|
if ( (signedfp= fopen(fname,"rb+")) == 0 )
|
|
signedfp = fopen(fname,"wb");
|
|
else fseek(signedfp,0,SEEK_END);
|
|
}
|
|
if ( signedfp != 0 )
|
|
{
|
|
fwrite(&height,1,sizeof(height),signedfp);
|
|
fwrite(&signedmask,1,sizeof(signedmask),signedfp);
|
|
fflush(signedfp);
|
|
}
|
|
printf("[%s] ht.%d txi.%d signedmask.%llx numvins.%d numvouts.%d <<<<<<<<<<< notarized\n",ASSETCHAINS_SYMBOL,height,i,(long long)signedmask,numvins,numvouts);
|
|
}
|
|
notarized = 1;
|
|
}
|
|
if ( NOTARY_PUBKEY33[0] != 0 && ASSETCHAINS_SYMBOL[0] == 0 )
|
|
printf("(tx.%d: ",i);
|
|
for (j=0; j<numvouts; j++)
|
|
{
|
|
/*if ( i == 0 && j == 0 )
|
|
{
|
|
uint8_t *script = (uint8_t *)block.vtx[0].vout[numvouts-1].scriptPubKey.data();
|
|
if ( numvouts <= 2 || script[0] != 0x6a )
|
|
{
|
|
if ( numvouts == 2 && block.vtx[0].vout[1].nValue != 0 )
|
|
{
|
|
fprintf(stderr,"ht.%d numvouts.%d value %.8f\n",height,numvouts,dstr(block.vtx[0].vout[1].nValue));
|
|
if ( height >= 235300 && block.vtx[0].vout[1].nValue >= 100000*COIN )
|
|
block.vtx[0].vout[1].nValue = 0;
|
|
break;
|
|
}
|
|
}
|
|
}*/
|
|
if ( NOTARY_PUBKEY33[0] != 0 && ASSETCHAINS_SYMBOL[0] == 0 )
|
|
printf("%.8f ",dstr(block.vtx[i].vout[j].nValue));
|
|
len = block.vtx[i].vout[j].scriptPubKey.size();
|
|
if ( len >= sizeof(uint32_t) && len <= sizeof(scriptbuf) )
|
|
{
|
|
#ifdef KOMODO_ZCASH
|
|
memcpy(scriptbuf,block.vtx[i].vout[j].scriptPubKey.data(),len);
|
|
#else
|
|
memcpy(scriptbuf,(uint8_t *)&block.vtx[i].vout[j].scriptPubKey[0],len);
|
|
#endif
|
|
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());
|
|
if ( 0 && i > 0 )
|
|
{
|
|
for (k=0; k<len; k++)
|
|
printf("%02x",scriptbuf[k]);
|
|
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());
|
|
}
|
|
}
|
|
}
|
|
if ( NOTARY_PUBKEY33[0] != 0 && ASSETCHAINS_SYMBOL[0] == 0 )
|
|
printf(") ");
|
|
if ( 0 && ASSETCHAINS_SYMBOL[0] == 0 )
|
|
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);
|
|
if ( notarized != 0 && (notarizedheight != 0 || specialtx != 0) )
|
|
{
|
|
if ( isratification != 0 )
|
|
{
|
|
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);
|
|
printf("ht.%d specialtx.%d isratification.%d numvouts.%d signed.%llx numnotaries.%d\n",height,specialtx,isratification,numvouts,(long long)signedmask,numnotaries);
|
|
}
|
|
if ( specialtx != 0 && isratification != 0 && numvouts > 2 )
|
|
{
|
|
numvalid = 0;
|
|
memset(pubkeys,0,sizeof(pubkeys));
|
|
for (j=1; j<numvouts-1; j++)
|
|
{
|
|
len = block.vtx[i].vout[j].scriptPubKey.size();
|
|
if ( len >= sizeof(uint32_t) && len <= sizeof(scriptbuf) )
|
|
{
|
|
#ifdef KOMODO_ZCASH
|
|
memcpy(scriptbuf,block.vtx[i].vout[j].scriptPubKey.data(),len);
|
|
#else
|
|
memcpy(scriptbuf,(uint8_t *)&block.vtx[i].vout[j].scriptPubKey[0],len);
|
|
#endif
|
|
if ( len == 35 && scriptbuf[0] == 33 && scriptbuf[34] == 0xac )
|
|
{
|
|
memcpy(pubkeys[numvalid++],scriptbuf+1,33);
|
|
for (k=0; k<33; k++)
|
|
printf("%02x",scriptbuf[k+1]);
|
|
printf(" <- new notary.[%d]\n",j-1);
|
|
}
|
|
}
|
|
}
|
|
if ( ((signedmask & 1) != 0 && numvalid >= KOMODO_MINRATIFY) || bitweight(signedmask) > (numnotaries/3) )
|
|
{
|
|
memset(&txhash,0,sizeof(txhash));
|
|
komodo_stateupdate(height,pubkeys,numvalid,0,txhash,0,0,0,0,0,0,0,0,0,0);
|
|
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);
|
|
} else printf("signedmask.%llx numvalid.%d wt.%d numnotaries.%d\n",(long long)signedmask,numvalid,bitweight(signedmask),numnotaries);
|
|
}
|
|
}
|
|
}
|
|
if ( NOTARY_PUBKEY33[0] != 0 && ASSETCHAINS_SYMBOL[0] == 0 )
|
|
printf("%s ht.%d\n",ASSETCHAINS_SYMBOL[0] == 0 ? "KMD" : ASSETCHAINS_SYMBOL,height);
|
|
if ( pindex->nHeight == hwmheight )
|
|
komodo_stateupdate(height,0,0,0,zero,0,0,0,0,height,(uint32_t)pindex->nTime,0,0,0,0);
|
|
} else fprintf(stderr,"komodo_connectblock: unexpected null pindex\n");
|
|
//KOMODO_INITDONE = (uint32_t)time(NULL);
|
|
//fprintf(stderr,"%s end connect.%d\n",ASSETCHAINS_SYMBOL,pindex->nHeight);
|
|
}
|
|
|
|
|
|
#endif
|