src/komodo_notary.h

   1 /******************************************************************************
   2  * Copyright © 2014-2016 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 const char *Notaries_genesis[][2] =
  17 {
  18     { "jl777_testA", "03b7621b44118017a16043f19b30cc8a4cfe068ac4e42417bae16ba460c80f3828" },
  19     { "jl777_testB", "02ebfc784a4ba768aad88d44d1045d240d47b26e248cafaf1c5169a42d7a61d344" },
  20     { "pondsea_SH", "02209073bc0943451498de57f802650311b1f12aa6deffcd893da198a544c04f36" },
  21     { "crackers_EU", "0340c66cf2c41c41efb420af57867baa765e8468c12aa996bfd816e1e07e410728" },
  22     { "pondsea_EU", "0225aa6f6f19e543180b31153d9e6d55d41bc7ec2ba191fd29f19a2f973544e29d" },
  23     { "locomb_EU", "025c6d26649b9d397e63323d96db42a9d3caad82e1d6076970efe5056c00c0779b" },
  24     { "fullmoon_AE", "0204a908350b8142698fdb6fabefc97fe0e04f537adc7522ba7a1e8f3bec003d4a" },
  25     { "movecrypto_EU", "021ab53bc6cf2c46b8a5456759f9d608966eff87384c2b52c0ac4cc8dd51e9cc42" },
  26     { "badass_EU", "0209d48554768dd8dada988b98aca23405057ac4b5b46838a9378b95c3e79b9b9e" },
  27     { "crackers_NA", "029e1c01131974f4cd3f564cc0c00eb87a0f9721043fbc1ca60f9bd0a1f73f64a1" },
  28     { "proto_EU", "03681ffdf17c8f4f0008cefb7fa0779c5e888339cdf932f0974483787a4d6747c1" },
  29     { "jeezy_EU", "023cb3e593fb85c5659688528e9a4f1c4c7f19206edc7e517d20f794ba686fd6d6" },
  30     { "farl4web_EU", "035caa40684ace968677dca3f09098aa02b70e533da32390a7654c626e0cf908e1" },
  31     { "nxtswe_EU", "032fb104e5eaa704a38a52c126af8f67e870d70f82977e5b2f093d5c1c21ae5899" },
  32     { "traderbill_EU", "03196e8de3e2e5d872f31d79d6a859c8704a2198baf0af9c7b21e29656a7eb455f" },
  33     { "vanbreuk_EU", "024f3cad7601d2399c131fd070e797d9cd8533868685ddbe515daa53c2e26004c3" },
  34     { "titomane_EU", "03517fcac101fed480ae4f2caf775560065957930d8c1facc83e30077e45bdd199" },
  35     { "supernet_AE", "029d93ef78197dc93892d2a30e5a54865f41e0ca3ab7eb8e3dcbc59c8756b6e355" },
  36     { "supernet_EU", "02061c6278b91fd4ac5cab4401100ffa3b2d5a277e8f71db23401cc071b3665546" },
  37     { "supernet_NA", "033c073366152b6b01535e15dd966a3a8039169584d06e27d92a69889b720d44e1" },
  38     { "yassin_EU", "033fb7231bb66484081952890d9a03f91164fb27d392d9152ec41336b71b15fbd0" },
  39     { "durerus_EU", "02bcbd287670bdca2c31e5d50130adb5dea1b53198f18abeec7211825f47485d57" },
  40     { "badass_SH", "026b49dd3923b78a592c1b475f208e23698d3f085c4c3b4906a59faf659fd9530b" },
  41     { "badass_NA", "02afa1a9f948e1634a29dc718d218e9d150c531cfa852843a1643a02184a63c1a7" },
  42     { "pondsea_NA", "031bcfdbb62268e2ff8dfffeb9ddff7fe95fca46778c77eebff9c3829dfa1bb411" },
  43     { "rnr_EU", "0287aa4b73988ba26cf6565d815786caf0d2c4af704d7883d163ee89cd9977edec" },
  44     { "crackers_SH", "02313d72f9a16055737e14cfc528dcd5d0ef094cfce23d0348fe974b6b1a32e5f0" },
  45     { "grewal_SH", "03212a73f5d38a675ee3cdc6e82542a96c38c3d1c79d25a1ed2e42fcf6a8be4e68" },
  46     { "polycryptoblock_NA", "02708dcda7c45fb54b78469673c2587bfdd126e381654819c4c23df0e00b679622" },
  47     { "titomane_NA", "0387046d9745414fb58a0fa3599078af5073e10347e4657ef7259a99cb4f10ad47" },
  48     { "titomane_AE", "03cda6ca5c2d02db201488a54a548dbfc10533bdc275d5ea11928e8d6ab33c2185" },
  49     { "kolo_EU", "03f5c08dadffa0ffcafb8dd7ffc38c22887bd02702a6c9ac3440deddcf2837692b" },
  50     { "artik_NA", "0224e31f93eff0cc30eaf0b2389fbc591085c0e122c4d11862c1729d090106c842" },
  51     { "eclips_EU", "0339369c1f5a2028d44be7be6f8ec3b907fdec814f87d2dead97cab4edb71a42e9" },
  52     { "titomane_SH", "035f49d7a308dd9a209e894321f010d21b7793461b0c89d6d9231a3fe5f68d9960" },
  53 };
  54
  55 #define KOMODO_ELECTION_GAP 1000
  56 #define KOMODO_PUBKEYS_HEIGHT(height) ((int32_t)(((((height)+KOMODO_ELECTION_GAP*.5)/KOMODO_ELECTION_GAP) + 1) * KOMODO_ELECTION_GAP))
  57
  58 struct nutxo_entry { UT_hash_handle hh; uint256 txhash; uint64_t voutmask; int32_t notaryid,height; } *NUTXOS;
  59 struct knotary_entry { UT_hash_handle hh; uint8_t pubkey[33],notaryid; };
  60 struct knotaries_entry { int32_t height,numnotaries; struct knotary_entry *Notaries; } Pubkeys[10000];
  61 struct notarized_checkpoint { uint256 notarized_hash,notarized_desttxid; int32_t nHeight,notarized_height; } *NPOINTS; int32_t NUM_NPOINTS;
  62
  63 void komodo_nutxoadd(int32_t height,int32_t notaryid,uint256 txhash,uint64_t voutmask,int32_t numvouts)
  64 {
  65     struct nutxo_entry *np;
  66     if ( numvouts > 1 && notaryid < 64 )
  67     {
  68         pthread_mutex_lock(&komodo_mutex);
  69         np = (struct nutxo_entry *)calloc(1,sizeof(*np));
  70         np->height = height;
  71         np->txhash = txhash;
  72         np->voutmask = voutmask;
  73         np->notaryid = notaryid;
  74         HASH_ADD_KEYPTR(hh,NUTXOS,&np->txhash,sizeof(np->txhash),np);
  75         //printf("Add NUTXO[%d] <- %s notaryid.%d t%u %s %llx\n",Num_nutxos,Notaries[notaryid][0],notaryid,komodo_txtime(txhash),txhash.ToString().c_str(),(long long)voutmask);
  76         Num_nutxos++;
  77         pthread_mutex_unlock(&komodo_mutex);
  78     }
  79 }
  80
  81 int32_t komodo_nutxofind(int32_t height,uint256 txhash,int32_t vout)
  82 {
  83     struct nutxo_entry *np;
  84     pthread_mutex_lock(&komodo_mutex);
  85     HASH_FIND(hh,NUTXOS,&txhash,sizeof(txhash),np);
  86     pthread_mutex_unlock(&komodo_mutex);
  87     if ( np != 0 && ((1LL << vout) & np->voutmask) != 0 )
  88         return(np->notaryid);
  89     return(-1);
  90 }
  91
  92 int32_t komodo_ratify_threshold(int32_t height,uint64_t signedmask)
  93 {
  94     int32_t htind,numnotaries,i,wt = 0;
  95     if ( (htind= KOMODO_PUBKEYS_HEIGHT(height) / KOMODO_ELECTION_GAP) == 1 )
  96         htind = 0;
  97     numnotaries = Pubkeys[htind].numnotaries;
  98     for (i=0; i<numnotaries; i++)
  99         if ( ((1LL << i) & signedmask) != 0 )
 100             wt++;
 101     if ( wt > (numnotaries >> 1) || (wt > 7 && (signedmask & 3) != 0) )
 102         return(1);
 103     else return(0);
 104 }
 105
 106 int32_t komodo_notaries(uint8_t pubkeys[64][33],int32_t height)
 107 {
 108     int32_t i,htind,n; uint64_t mask = 0; struct knotary_entry *kp,*tmp;
 109     if ( (htind= KOMODO_PUBKEYS_HEIGHT(height) / KOMODO_ELECTION_GAP) == 1 )
 110         htind = 0;
 111     pthread_mutex_lock(&komodo_mutex);
 112     n = Pubkeys[htind].numnotaries;
 113     HASH_ITER(hh,Pubkeys[htind].Notaries,kp,tmp)
 114     {
 115         if ( kp->notaryid < n )
 116         {
 117             mask |= (1LL << kp->notaryid);
 118             memcpy(pubkeys[kp->notaryid],kp->pubkey,33);
 119         } else printf("illegal notaryid.%d vs n.%d\n",kp->notaryid,n);
 120     }
 121     pthread_mutex_unlock(&komodo_mutex);
 122     if ( mask == ((1LL << n)-1) )
 123         return(n);
 124     printf("error retrieving notaries ht.%d got mask.%llx for n.%d\n",height,(long long)mask,n);
 125     return(-1);
 126 }
 127
 128 void komodo_notarysinit(int32_t height,uint8_t pubkeys[64][33],int32_t num)
 129 {
 130     int32_t k,i,htind; struct knotary_entry *kp; struct knotaries_entry N;
 131     memset(&N,0,sizeof(N));
 132     pthread_mutex_lock(&komodo_mutex);
 133     for (k=0; k<num; k++)
 134     {
 135         kp = (struct knotary_entry *)calloc(1,sizeof(*kp));
 136         memcpy(kp->pubkey,pubkeys[k],33);
 137         kp->notaryid = k;
 138         HASH_ADD_KEYPTR(hh,N.Notaries,kp->pubkey,33,kp);
 139         if ( height > 10000 )
 140         {
 141             for (i=0; i<33; i++)
 142                 printf("%02x",pubkeys[k][i]);
 143             printf(" notarypubs.[%d]\n",k);
 144         }
 145     }
 146     N.numnotaries = num;
 147     if ( (htind= KOMODO_PUBKEYS_HEIGHT(height) / KOMODO_ELECTION_GAP) == 1 )
 148         htind = 0;
 149     for (i=htind; i<sizeof(Pubkeys)/sizeof(*Pubkeys); i++)
 150     {
 151         Pubkeys[i] = N;
 152         Pubkeys[i].height = i * KOMODO_ELECTION_GAP;
 153     }
 154     pthread_mutex_unlock(&komodo_mutex);
 155 }
 156
 157 int32_t komodo_chosennotary(int32_t *notaryidp,int32_t height,uint8_t *pubkey33)
 158 {
 159     // -1 if not notary, 0 if notary, 1 if special notary
 160     struct knotary_entry *kp; int32_t numnotaries,htind,modval = -1;
 161     *notaryidp = -1;
 162     if ( height < 0 || height/KOMODO_ELECTION_GAP >= sizeof(Pubkeys)/sizeof(*Pubkeys) )
 163         return(-1);
 164     if ( (htind= KOMODO_PUBKEYS_HEIGHT(height) / KOMODO_ELECTION_GAP) == 1 )
 165         htind = 0;
 166     pthread_mutex_lock(&komodo_mutex);
 167     HASH_FIND(hh,Pubkeys[htind].Notaries,pubkey33,33,kp);
 168     pthread_mutex_unlock(&komodo_mutex);
 169     if ( kp != 0 )
 170     {
 171         if ( (numnotaries= Pubkeys[htind].numnotaries) > 0 )
 172         {
 173             *notaryidp = kp->notaryid;
 174             modval = ((height % numnotaries) == kp->notaryid);
 175             //printf("found notary.%d ht.%d modval.%d\n",kp->notaryid,height,modval);
 176         } else printf("unexpected zero notaries at height.%d\n",height);
 177     }
 178     //int32_t i; for (i=0; i<33; i++)
 179     //    printf("%02x",pubkey33[i]);
 180     //printf(" ht.%d notary.%d special.%d\n",height,*notaryidp,modval);
 181     return(modval);
 182 }
 183
 184 void komodo_notarized_update(int32_t nHeight,int32_t notarized_height,uint256 notarized_hash,uint256 notarized_desttxid)
 185 {
 186     struct notarized_checkpoint *np;
 187     if ( notarized_height > nHeight )
 188     {
 189         printf("komodo_notarized_update REJECT notarized_height %d > %d nHeight\n",notarized_height,nHeight);
 190         return;
 191     }
 192     NPOINTS = (struct notarized_checkpoint *)realloc(NPOINTS,(NUM_NPOINTS+1) * sizeof(*NPOINTS));
 193     np = &NPOINTS[NUM_NPOINTS++];
 194     memset(np,0,sizeof(*np));
 195     np->nHeight = nHeight;
 196     np->notarized_height = notarized_height;
 197     np->notarized_hash = notarized_hash;
 198     np->notarized_desttxid = notarized_desttxid;
 199 }
 200
 201 int32_t komodo_notarizeddata(int32_t nHeight,uint256 *notarized_hashp,uint256 *notarized_desttxidp)
 202 {
 203     struct notarized_checkpoint *np = 0; int32_t i;
 204     if ( NUM_NPOINTS > 0 )
 205     {
 206         for (i=0; i<NUM_NPOINTS; i++)
 207         {
 208             if ( NPOINTS[i].nHeight >= nHeight )
 209                 break;
 210             np = &NPOINTS[i];
 211         }
 212     }
 213     if ( np != 0 )
 214     {
 215         *notarized_hashp = np->notarized_hash;
 216         *notarized_desttxidp = np->notarized_desttxid;
 217         return(np->notarized_height);
 218     }
 219     memset(notarized_hashp,0,sizeof(*notarized_hashp));
 220     return(0);
 221 }
 222
 223 void komodo_init()
 224 {
 225     static int didinit; uint256 zero; int32_t k,n; uint8_t pubkeys[64][33];
 226     if ( didinit == 0 )
 227     {
 228         didinit = 1;
 229         iguana_initQ(&DepositsQ,(char *)"Deposits");
 230         iguana_initQ(&PendingsQ,(char *)"Pendings");
 231         pthread_mutex_init(&komodo_mutex,NULL);
 232         decode_hex(NOTARY_PUBKEY33,33,(char *)NOTARY_PUBKEY.c_str());
 233         n = (int32_t)(sizeof(Notaries_genesis)/sizeof(*Notaries_genesis));
 234         for (k=0; k<n; k++)
 235         {
 236             if ( Notaries_genesis[k][0] == 0 || Notaries_genesis[k][1] == 0 || Notaries_genesis[k][0][0] == 0 || Notaries_genesis[k][1][0] == 0 )
 237                 break;
 238             decode_hex(pubkeys[k],33,(char *)Notaries_genesis[k][1]);
 239         }
 240         komodo_notarysinit(0,pubkeys,k);
 241         memset(&zero,0,sizeof(zero));
 242         komodo_stateupdate(0,0,0,0,zero,0,0,0,0,0,0,0,0,0);
 243     }
 244 }