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