]>
Commit | Line | Data |
---|---|---|
9b0e1808 | 1 | /****************************************************************************** |
37fed603 | 2 | * Copyright © 2014-2017 The SuperNET Developers. * |
9b0e1808 | 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 | ||
f38345e9 | 16 | // paxdeposit equivalent in reverse makes opreturn and KMD does the same in reverse |
f38345e9 | 17 | |
aa114a60 | 18 | int32_t pax_fiatstatus(uint64_t *available,uint64_t *deposited,uint64_t *issued,uint64_t *withdrawn,uint64_t *approved,uint64_t *redeemed,char *base) |
3cbfd2b4 | 19 | { |
aa114a60 | 20 | int32_t baseid; struct komodo_state *sp; int64_t netliability,maxallowed; |
21 | *available = *deposited = *issued = *withdrawn = *approved = *redeemed = 0; | |
3cbfd2b4 | 22 | if ( (baseid= komodo_baseid(base)) >= 0 ) |
23 | { | |
24 | if ( (sp= komodo_stateptrget(base)) != 0 ) | |
25 | { | |
26 | *deposited = sp->deposited; | |
27 | *issued = sp->issued; | |
28 | *withdrawn = sp->withdrawn; | |
29 | *approved = sp->approved; | |
30 | *redeemed = sp->redeemed; | |
aa114a60 | 31 | netliability = (sp->deposited - sp->withdrawn) - sp->shorted; |
32 | maxallowed = komodo_maxallowed(baseid); | |
33 | if ( netliability < maxallowed ) | |
34 | *available = (maxallowed - netliability); | |
35 | //printf("%p %s %.8f %.8f %.8f %.8f %.8f\n",sp,base,dstr(*deposited),dstr(*issued),dstr(*withdrawn),dstr(*approved),dstr(*redeemed)); | |
3cbfd2b4 | 36 | return(0); |
ee5e5744 | 37 | } else printf("pax_fiatstatus cant get basesp.%s\n",base); |
106a1d04 | 38 | } // else printf("pax_fiatstatus illegal base.%s\n",base); |
3cbfd2b4 | 39 | return(-1); |
40 | } | |
41 | ||
51e5d952 | 42 | void pax_keyset(uint8_t *buf,uint256 txid,uint16_t vout,uint8_t type) |
6210f328 | 43 | { |
51e5d952 | 44 | memcpy(buf,&txid,32); |
45 | memcpy(&buf[32],&vout,2); | |
46 | buf[34] = type; | |
47 | } | |
48 | ||
49 | struct pax_transaction *komodo_paxfind(uint256 txid,uint16_t vout,uint8_t type) | |
50 | { | |
51 | struct pax_transaction *pax; uint8_t buf[35]; | |
6210f328 | 52 | pthread_mutex_lock(&komodo_mutex); |
51e5d952 | 53 | pax_keyset(buf,txid,vout,type); |
54 | HASH_FIND(hh,PAX,buf,sizeof(buf),pax); | |
6210f328 | 55 | pthread_mutex_unlock(&komodo_mutex); |
56 | return(pax); | |
57 | } | |
58 | ||
c5c0e527 | 59 | struct pax_transaction *komodo_paxfinds(uint256 txid,uint16_t vout) |
60 | { | |
2aba5e49 | 61 | struct pax_transaction *pax; int32_t i; uint8_t types[] = { 'I', 'D', 'X', 'A', 'W' }; |
095dce58 | 62 | for (i=0; i<sizeof(types)/sizeof(*types); i++) |
c5c0e527 | 63 | if ( (pax= komodo_paxfind(txid,vout,types[i])) != 0 ) |
64 | return(pax); | |
65 | return(0); | |
66 | } | |
67 | ||
51e5d952 | 68 | struct pax_transaction *komodo_paxmark(int32_t height,uint256 txid,uint16_t vout,uint8_t type,int32_t mark) |
6210f328 | 69 | { |
51e5d952 | 70 | struct pax_transaction *pax; uint8_t buf[35]; |
6210f328 | 71 | pthread_mutex_lock(&komodo_mutex); |
51e5d952 | 72 | pax_keyset(buf,txid,vout,type); |
73 | HASH_FIND(hh,PAX,buf,sizeof(buf),pax); | |
2ab43fd2 | 74 | if ( pax == 0 ) |
75 | { | |
76 | pax = (struct pax_transaction *)calloc(1,sizeof(*pax)); | |
77 | pax->txid = txid; | |
78 | pax->vout = vout; | |
51e5d952 | 79 | pax->type = type; |
80 | memcpy(pax->buf,buf,sizeof(pax->buf)); | |
81 | HASH_ADD_KEYPTR(hh,PAX,pax->buf,sizeof(pax->buf),pax); | |
32d525eb | 82 | //printf("ht.%d create pax.%p mark.%d\n",height,pax,mark); |
2ab43fd2 | 83 | } |
6210f328 | 84 | if ( pax != 0 ) |
6210f328 | 85 | pax->marked = mark; |
6210f328 | 86 | pthread_mutex_unlock(&komodo_mutex); |
87 | return(pax); | |
88 | } | |
429dabb5 | 89 | |
57f349cb | 90 | void komodo_paxdelete(struct pax_transaction *pax) |
91 | { | |
5720de88 | 92 | return; // breaks when out of order |
57f349cb | 93 | pthread_mutex_lock(&komodo_mutex); |
94 | HASH_DELETE(hh,PAX,pax); | |
95 | pthread_mutex_unlock(&komodo_mutex); | |
96 | } | |
97 | ||
51e5d952 | 98 | void komodo_gateway_deposit(char *coinaddr,uint64_t value,char *symbol,uint64_t fiatoshis,uint8_t *rmd160,uint256 txid,uint16_t vout,uint8_t type,int32_t height,int32_t otherheight,char *source,int32_t approved) // assetchain context |
d43c7a93 | 99 | { |
51e5d952 | 100 | struct pax_transaction *pax; uint8_t buf[35]; int32_t addflag = 0; struct komodo_state *sp; char str[16],dest[16],*s; |
6cd01056 | 101 | if ( KOMODO_PAX == 0 ) |
102 | return; | |
bffa91b2 | 103 | sp = komodo_stateptr(str,dest); |
d43c7a93 | 104 | pthread_mutex_lock(&komodo_mutex); |
51e5d952 | 105 | pax_keyset(buf,txid,vout,type); |
106 | HASH_FIND(hh,PAX,buf,sizeof(buf),pax); | |
d43c7a93 | 107 | if ( pax == 0 ) |
b2d64a0f | 108 | { |
d43c7a93 | 109 | pax = (struct pax_transaction *)calloc(1,sizeof(*pax)); |
8d52488f | 110 | pax->txid = txid; |
111 | pax->vout = vout; | |
51e5d952 | 112 | pax->type = type; |
113 | memcpy(pax->buf,buf,sizeof(pax->buf)); | |
114 | HASH_ADD_KEYPTR(hh,PAX,pax->buf,sizeof(pax->buf),pax); | |
7961668b | 115 | addflag = 1; |
bff51d67 | 116 | if ( 0 && ASSETCHAINS_SYMBOL[0] == 0 ) |
1fc75a27 | 117 | { |
118 | int32_t i; for (i=0; i<32; i++) | |
119 | printf("%02x",((uint8_t *)&txid)[i]); | |
5ce8bf22 | 120 | printf(" v.%d [%s] kht.%d ht.%d create pax.%p symbol.%s source.%s\n",vout,ASSETCHAINS_SYMBOL,height,otherheight,pax,symbol,source); |
1fc75a27 | 121 | } |
b2d64a0f | 122 | } |
8d52488f | 123 | pthread_mutex_unlock(&komodo_mutex); |
d43c7a93 | 124 | if ( coinaddr != 0 ) |
125 | { | |
126 | strcpy(pax->coinaddr,coinaddr); | |
9ccd3f33 | 127 | if ( value != 0 ) |
128 | pax->komodoshis = value; | |
129 | if ( symbol != 0 ) | |
130 | strcpy(pax->symbol,symbol); | |
cd26c1f3 | 131 | if ( source != 0 ) |
132 | strcpy(pax->source,source); | |
9ccd3f33 | 133 | if ( fiatoshis != 0 ) |
134 | pax->fiatoshis = fiatoshis; | |
135 | if ( rmd160 != 0 ) | |
136 | memcpy(pax->rmd160,rmd160,20); | |
137 | if ( height != 0 ) | |
138 | pax->height = height; | |
139 | if ( otherheight != 0 ) | |
140 | pax->otherheight = otherheight; | |
d43c7a93 | 141 | } |
142 | else | |
143 | { | |
144 | pax->marked = height; | |
bff51d67 | 145 | //printf("pax.%p MARK DEPOSIT ht.%d other.%d\n",pax,height,otherheight); |
d43c7a93 | 146 | } |
d43c7a93 | 147 | } |
148 | ||
7cc6844b | 149 | int32_t komodo_rwapproval(int32_t rwflag,uint8_t *opretbuf,struct pax_transaction *pax) |
150 | { | |
151 | int32_t i,len = 0; | |
ddf827b2 | 152 | if ( rwflag == 1 ) |
153 | { | |
154 | for (i=0; i<32; i++) | |
155 | opretbuf[len++] = ((uint8_t *)&pax->txid)[i]; | |
156 | opretbuf[len++] = pax->vout & 0xff; | |
157 | opretbuf[len++] = (pax->vout >> 8) & 0xff; | |
158 | } | |
159 | else | |
160 | { | |
161 | for (i=0; i<32; i++) | |
a6972662 | 162 | ((uint8_t *)&pax->txid)[i] = opretbuf[len++]; |
bff51d67 | 163 | //for (i=0; i<32; i++) |
164 | // printf("%02x",((uint8_t *)&pax->txid)[31-i]); | |
ddf827b2 | 165 | pax->vout = opretbuf[len++]; |
166 | pax->vout += ((uint32_t)opretbuf[len++] << 8); | |
bff51d67 | 167 | //printf(" txid v.%d\n",pax->vout); |
ddf827b2 | 168 | } |
ad66994d | 169 | len += iguana_rwnum(rwflag,&opretbuf[len],sizeof(pax->komodoshis),&pax->komodoshis); |
ddf827b2 | 170 | len += iguana_rwnum(rwflag,&opretbuf[len],sizeof(pax->fiatoshis),&pax->fiatoshis); |
171 | len += iguana_rwnum(rwflag,&opretbuf[len],sizeof(pax->height),&pax->height); | |
172 | len += iguana_rwnum(rwflag,&opretbuf[len],sizeof(pax->otherheight),&pax->otherheight); | |
173 | if ( rwflag != 0 ) | |
174 | { | |
175 | memcpy(&opretbuf[len],pax->rmd160,20), len += 20; | |
176 | for (i=0; i<4; i++) | |
177 | opretbuf[len++] = pax->source[i]; | |
178 | } | |
179 | else | |
180 | { | |
181 | memcpy(pax->rmd160,&opretbuf[len],20), len += 20; | |
182 | for (i=0; i<4; i++) | |
183 | pax->source[i] = opretbuf[len++]; | |
184 | } | |
7cc6844b | 185 | return(len); |
186 | } | |
187 | ||
b89ab77c | 188 | int32_t komodo_issued_opreturn(char *base,uint256 *txids,uint16_t *vouts,int64_t *values,int64_t *srcvalues,int32_t *kmdheights,int32_t *otherheights,int8_t *baseids,uint8_t *rmd160s,uint8_t *opretbuf,int32_t opretlen,int32_t iskomodo) |
63b289ad | 189 | { |
54661780 | 190 | struct pax_transaction p,*pax; int32_t i,n=0,j,len=0,incr,height,otherheight; uint8_t type,rmd160[20]; uint64_t fiatoshis; char symbol[16]; |
6cd01056 | 191 | if ( KOMODO_PAX == 0 ) |
192 | return(0); | |
c83633f8 | 193 | incr = 34 + (iskomodo * (2*sizeof(fiatoshis) + 2*sizeof(height) + 20 + 4)); |
085c4ee4 | 194 | //41e77b91cb68dc2aa02fa88550eae6b6d44db676a7e935337b6d1392d9718f03cb0200305c90660400000000fbcbeb1f000000bde801006201000058e7945ad08ddba1eac9c9b6c8e1e97e8016a2d152 |
8b4d7f27 | 195 | |
196 | // 41e94d736ec69d88c08b5d238abeeca609c02357a8317e0d56c328bcb1c259be5d0200485bc80200000000404b4c000000000059470200b80b000061f22ba7d19fe29ac3baebd839af8b7127d1f9075553440046bb4cc7a3b5cd39dffe7206507a3482a00780e617f68b273cce9817ed69298d02001069ca1b0000000080f0fa02000000005b470200b90b000061f22ba7d19fe29ac3baebd839af8b7127d1f90755 | |
197 | ||
40f3d9cc | 198 | //for (i=0; i<opretlen; i++) |
199 | // printf("%02x",opretbuf[i]); | |
b3183e3e | 200 | //printf(" opretlen.%d (%s)\n",opretlen,base); |
40f3d9cc | 201 | //printf(" opretlen.%d vs %d incr.%d (%d)\n",opretlen,(int32_t)(2*sizeof(fiatoshis) + 2*sizeof(height) + 20 + 2),incr,opretlen/incr); |
c3152c23 | 202 | //if ( ASSETCHAINS_SYMBOL[0] == 0 || strncmp(ASSETCHAINS_SYMBOL,base,strlen(base)) == 0 ) |
63b289ad | 203 | { |
947d956f | 204 | type = opretbuf[0]; |
63b289ad | 205 | opretbuf++, opretlen--; |
e8433f7a | 206 | for (n=0; n<opretlen/incr; n++) |
63b289ad | 207 | { |
05d91eb2 | 208 | if ( iskomodo != 0 ) |
209 | { | |
e8433f7a | 210 | memset(&p,0,sizeof(p)); |
ffec138e | 211 | len += komodo_rwapproval(0,&opretbuf[len],&p); |
b89ab77c | 212 | if ( values != 0 && srcvalues != 0 && kmdheights != 0 && otherheights != 0 && baseids != 0 && rmd160s != 0 ) |
1ed46112 | 213 | { |
63342b19 | 214 | txids[n] = p.txid; |
215 | vouts[n] = p.vout; | |
c65d0868 | 216 | values[n] = (strcmp("KMD",base) == 0) ? p.komodoshis : p.fiatoshis; |
217 | srcvalues[n] = (strcmp("KMD",base) == 0) ? p.fiatoshis : p.komodoshis; | |
a3f1fb69 | 218 | kmdheights[n] = p.height; |
219 | otherheights[n] = p.otherheight; | |
7cc6844b | 220 | memcpy(&rmd160s[n * 20],p.rmd160,20); |
1dbea872 | 221 | baseids[n] = komodo_baseid(p.source); |
109afe64 | 222 | if ( 0 ) |
71c9af7c | 223 | { |
224 | char coinaddr[64]; | |
225 | bitcoin_address(coinaddr,60,&rmd160s[n * 20],20); | |
947d956f | 226 | printf(">>>>>>> %s: (%s) fiat %.8f kmdheight.%d other.%d -> %s %.8f\n",type=='A'?"approvedA":"issuedX",baseids[n]>=0?CURRENCIES[baseids[n]]:"???",dstr(p.fiatoshis),kmdheights[n],otherheights[n],coinaddr,dstr(values[n])); |
71c9af7c | 227 | } |
52e87248 | 228 | } |
05d91eb2 | 229 | } |
7cc6844b | 230 | else |
231 | { | |
5cb9312f | 232 | for (i=0; i<4; i++) |
233 | base[i] = opretbuf[opretlen-4+i]; | |
7cc6844b | 234 | for (j=0; j<32; j++) |
235 | { | |
236 | ((uint8_t *)&txids[n])[j] = opretbuf[len++]; | |
237 | //printf("%02x",((uint8_t *)&txids[n])[j]); | |
238 | } | |
239 | vouts[n] = opretbuf[len++]; | |
240 | vouts[n] = (opretbuf[len++] << 8) | vouts[n]; | |
cb3bf8df | 241 | baseids[n] = komodo_baseid(base); |
c5c0e527 | 242 | if ( (pax= komodo_paxfinds(txids[n],vouts[n])) != 0 ) |
54661780 | 243 | { |
c3152c23 | 244 | values[n] = (strcmp("KMD",base) == 0) ? pax->komodoshis : pax->fiatoshis; |
245 | srcvalues[n] = (strcmp("KMD",base) == 0) ? pax->fiatoshis : pax->komodoshis; | |
54661780 | 246 | kmdheights[n] = pax->height; |
247 | otherheights[n] = pax->otherheight; | |
248 | memcpy(&rmd160s[n * 20],pax->rmd160,20); | |
249 | } | |
7cc6844b | 250 | } |
6d898f42 | 251 | //printf(" komodo_issued_opreturn issuedtxid v%d i.%d opretlen.%d\n",vouts[n],n,opretlen); |
63b289ad | 252 | } |
253 | } | |
254 | return(n); | |
255 | } | |
256 | ||
865bd972 | 257 | int32_t komodo_paxcmp(char *symbol,int32_t kmdheight,uint64_t value,uint64_t checkvalue,uint64_t seed) |
258 | { | |
259 | int32_t ratio; | |
260 | if ( seed == 0 && checkvalue != 0 ) | |
261 | { | |
262 | ratio = ((value << 6) / checkvalue); | |
263 | if ( ratio >= 63 && ratio <= 65 ) | |
264 | return(0); | |
265 | else | |
266 | { | |
267 | if ( kmdheight >= 86150 ) | |
268 | printf("ht.%d ignore mismatched %s value %lld vs checkvalue %lld -> ratio.%d\n",kmdheight,symbol,(long long)value,(long long)checkvalue,ratio); | |
269 | return(-1); | |
270 | } | |
271 | } | |
272 | else if ( checkvalue != 0 ) | |
273 | { | |
274 | ratio = ((value << 10) / checkvalue); | |
275 | if ( ratio >= 1023 && ratio <= 1025 ) | |
276 | return(0); | |
277 | } | |
278 | return(value != checkvalue); | |
279 | } | |
280 | ||
f1db88ea | 281 | uint64_t komodo_paxtotal() |
282 | { | |
a73709a3 | 283 | struct pax_transaction *pax,*pax2,*tmp,*tmp2; char symbol[16],dest[16],*str; int32_t i,ht; int64_t checktoshis; uint64_t seed,total = 0; struct komodo_state *basesp; |
6cd01056 | 284 | if ( KOMODO_PAX == 0 ) |
285 | return(0); | |
48a3cd18 | 286 | if ( komodo_isrealtime(&ht) == 0 ) |
f1db88ea | 287 | return(0); |
ca75995d | 288 | else |
289 | { | |
290 | HASH_ITER(hh,PAX,pax,tmp) | |
291 | { | |
5ccb222a | 292 | if ( pax->marked != 0 ) |
293 | continue; | |
85779087 | 294 | if ( pax->type == 'A' || pax->type == 'D' || pax->type == 'X' ) |
295 | str = pax->symbol; | |
296 | else str = pax->source; | |
297 | basesp = komodo_stateptrget(str); | |
115e6a5c | 298 | if ( basesp != 0 && pax->didstats == 0 ) |
ca75995d | 299 | { |
6e458bf3 | 300 | if ( pax->type == 'I' && (pax2= komodo_paxfind(pax->txid,pax->vout,'D')) != 0 ) |
ca75995d | 301 | { |
3cfd4837 | 302 | if ( pax2->fiatoshis != 0 ) |
303 | { | |
304 | pax->komodoshis = pax2->komodoshis; | |
305 | pax->fiatoshis = pax2->fiatoshis; | |
306 | basesp->issued += pax->fiatoshis; | |
307 | pax->didstats = 1; | |
54f87e10 | 308 | if ( strcmp(str,ASSETCHAINS_SYMBOL) == 0 ) |
309 | printf("########### %p issued %s += %.8f kmdheight.%d %.8f other.%d\n",basesp,str,dstr(pax->fiatoshis),pax->height,dstr(pax->komodoshis),pax->otherheight); | |
c3111e7b | 310 | pax2->marked = pax->height; |
54f87e10 | 311 | pax->marked = pax->height; |
3cfd4837 | 312 | } |
fa81b5ae | 313 | } |
115e6a5c | 314 | else if ( pax->type == 'W' ) |
315 | { | |
431af13e | 316 | //bitcoin_address(coinaddr,addrtype,rmd160,20); |
1bc5fdf8 | 317 | if ( (checktoshis= komodo_paxprice(&seed,pax->height,pax->source,(char *)"KMD",(uint64_t)pax->fiatoshis)) != 0 ) |
318 | { | |
db7becdc | 319 | if ( komodo_paxcmp(pax->source,pax->height,pax->komodoshis,checktoshis,seed) != 0 ) |
772c13de | 320 | { |
1bc5fdf8 | 321 | pax->marked = pax->height; |
60cd57df | 322 | //printf("WITHDRAW.%s mark <- %d %.8f != %.8f\n",pax->source,pax->height,dstr(checktoshis),dstr(pax->komodoshis)); |
772c13de | 323 | } |
1bc5fdf8 | 324 | else if ( pax->validated == 0 ) |
325 | { | |
d4003105 | 326 | pax->validated = pax->komodoshis = checktoshis; |
109afe64 | 327 | //int32_t j; for (j=0; j<32; j++) |
328 | // printf("%02x",((uint8_t *)&pax->txid)[j]); | |
2405bc66 | 329 | //if ( strcmp(str,ASSETCHAINS_SYMBOL) == 0 ) |
109afe64 | 330 | // printf(" v%d %p got WITHDRAW.%s kmd.%d ht.%d %.8f -> %.8f/%.8f\n",pax->vout,pax,pax->source,pax->height,pax->otherheight,dstr(pax->fiatoshis),dstr(pax->komodoshis),dstr(checktoshis)); |
1bc5fdf8 | 331 | } |
332 | } | |
115e6a5c | 333 | } |
ca75995d | 334 | } |
335 | } | |
336 | } | |
ede04b12 | 337 | komodo_stateptr(symbol,dest); |
f1db88ea | 338 | HASH_ITER(hh,PAX,pax,tmp) |
339 | { | |
115e6a5c | 340 | pax->ready = 0; |
cfa1fdda | 341 | if ( 0 && pax->type == 'A' ) |
1eb7220f | 342 | printf("%p pax.%s <- %s marked.%d %.8f -> %.8f validated.%d approved.%d\n",pax,pax->symbol,pax->source,pax->marked,dstr(pax->komodoshis),dstr(pax->fiatoshis),pax->validated != 0,pax->approved != 0); |
5ccb222a | 343 | if ( pax->marked != 0 ) |
344 | continue; | |
cfa1fdda | 345 | if ( strcmp(symbol,pax->symbol) == 0 || pax->type == 'A' ) |
f1db88ea | 346 | { |
ede04b12 | 347 | if ( pax->marked == 0 ) |
348 | { | |
349 | if ( komodo_is_issuer() != 0 ) | |
1bc5fdf8 | 350 | { |
0449e3f0 | 351 | if ( pax->validated != 0 && pax->type == 'D' ) |
1bc5fdf8 | 352 | { |
353 | total += pax->fiatoshis; | |
354 | pax->ready = 1; | |
355 | } | |
356 | } | |
371a9c87 | 357 | else if ( pax->approved != 0 && pax->type == 'A' ) |
992c3be5 | 358 | { |
359 | if ( pax->validated != 0 ) | |
02c36c15 | 360 | { |
992c3be5 | 361 | total += pax->komodoshis; |
02c36c15 | 362 | pax->ready = 1; |
363 | } | |
992c3be5 | 364 | else |
365 | { | |
366 | seed = 0; | |
f186b8a1 | 367 | checktoshis = komodo_paxprice(&seed,pax->height,pax->source,(char *)"KMD",(uint64_t)pax->fiatoshis); |
8b249d56 | 368 | //printf("paxtotal PAX_fiatdest ht.%d price %s %.8f -> KMD %.8f vs %.8f\n",pax->height,pax->symbol,(double)pax->fiatoshis/COIN,(double)pax->komodoshis/COIN,(double)checktoshis/COIN); |
0fa85cc3 | 369 | //printf(" v%d %.8f k.%d ht.%d\n",pax->vout,dstr(pax->komodoshis),pax->height,pax->otherheight); |
6e458bf3 | 370 | if ( seed != 0 && checktoshis != 0 ) |
992c3be5 | 371 | { |
115e6a5c | 372 | if ( checktoshis == pax->komodoshis ) |
992c3be5 | 373 | { |
374 | total += pax->komodoshis; | |
375 | pax->validated = pax->komodoshis; | |
115e6a5c | 376 | pax->ready = 1; |
992c3be5 | 377 | } else pax->marked = pax->height; |
378 | } | |
379 | } | |
380 | } | |
fc40c343 | 381 | if ( 0 && pax->ready != 0 ) |
cfa1fdda | 382 | printf("%p (%c) pax.%s marked.%d %.8f -> %.8f validated.%d approved.%d\n",pax,pax->type,pax->symbol,pax->marked,dstr(pax->komodoshis),dstr(pax->fiatoshis),pax->validated != 0,pax->approved != 0); |
ede04b12 | 383 | } |
f1db88ea | 384 | } |
385 | } | |
5481c677 | 386 | //printf("paxtotal %.8f\n",dstr(total)); |
f1db88ea | 387 | return(total); |
388 | } | |
389 | ||
fa1a55cd | 390 | static int _paxorder(const void *a,const void *b) |
f360ea0a | 391 | { |
fa1a55cd | 392 | #define pax_a (*(struct pax_transaction **)a) |
393 | #define pax_b (*(struct pax_transaction **)b) | |
394 | uint64_t aval,bval; | |
d936b97f | 395 | aval = pax_a->fiatoshis + pax_a->komodoshis + pax_a->height; |
396 | bval = pax_b->fiatoshis + pax_b->komodoshis + pax_b->height; | |
fa1a55cd | 397 | if ( bval > aval ) |
398 | return(-1); | |
399 | else if ( bval < aval ) | |
400 | return(1); | |
401 | return(0); | |
402 | #undef pax_a | |
403 | #undef pax_b | |
404 | } | |
405 | ||
406 | int32_t komodo_pending_withdraws(char *opretstr) // todo: enforce deterministic order | |
407 | { | |
6b3eb2c4 | 408 | struct pax_transaction *pax,*pax2,*tmp,*paxes[64]; uint8_t opretbuf[16384]; int32_t i,n,ht,len=0; uint64_t total = 0; |
6cd01056 | 409 | if ( KOMODO_PAX == 0 ) |
410 | return(0); | |
f360ea0a | 411 | if ( komodo_isrealtime(&ht) == 0 || ASSETCHAINS_SYMBOL[0] != 0 ) |
412 | return(0); | |
fa1a55cd | 413 | n = 0; |
f360ea0a | 414 | HASH_ITER(hh,PAX,pax,tmp) |
415 | { | |
f1e6a937 | 416 | if ( pax->type == 'W' ) |
f360ea0a | 417 | { |
6b3eb2c4 | 418 | if ( (pax2= komodo_paxfind(pax->txid,pax->vout,'A')) != 0 ) |
419 | { | |
420 | if ( pax2->approved != 0 ) | |
421 | pax->approved = pax2->approved; | |
422 | } | |
423 | else if ( (pax2= komodo_paxfind(pax->txid,pax->vout,'X')) != 0 ) | |
0b262b65 | 424 | pax->approved = pax->height; |
01d3b36a | 425 | //printf("pending_withdraw: pax %s marked.%u approved.%u validated.%llu\n",pax->symbol,pax->marked,pax->approved,(long long)pax->validated); |
7d121b40 | 426 | if ( pax->marked == 0 && pax->approved == 0 && pax->validated != 0 ) //strcmp((char *)"KMD",pax->symbol) == 0 && |
f1e6a937 | 427 | { |
fa1a55cd | 428 | if ( n < sizeof(paxes)/sizeof(*paxes) ) |
ac4eb454 | 429 | { |
fa1a55cd | 430 | paxes[n++] = pax; |
2e575216 | 431 | //int32_t j; for (j=0; j<32; j++) |
432 | // printf("%02x",((uint8_t *)&pax->txid)[j]); | |
433 | //printf(" %s.(kmdht.%d ht.%d marked.%u approved.%d validated %.8f) %.8f\n",pax->source,pax->height,pax->otherheight,pax->marked,pax->approved,dstr(pax->validated),dstr(pax->komodoshis)); | |
ac4eb454 | 434 | } |
f1e6a937 | 435 | } |
f360ea0a | 436 | } |
437 | } | |
fa1a55cd | 438 | opretstr[0] = 0; |
439 | if ( n > 0 ) | |
440 | { | |
441 | opretbuf[len++] = 'A'; | |
442 | qsort(paxes,n,sizeof(*paxes),_paxorder); | |
443 | for (i=0; i<n; i++) | |
444 | { | |
445 | if ( len < (sizeof(opretbuf)>>3)*7 ) | |
446 | len += komodo_rwapproval(1,&opretbuf[len],paxes[i]); | |
447 | } | |
448 | if ( len > 0 ) | |
449 | init_hexbytes_noT(opretstr,opretbuf,len); | |
450 | } | |
132aea8c | 451 | //fprintf(stderr,"komodo_pending_withdraws len.%d PAXTOTAL %.8f\n",len,dstr(komodo_paxtotal())); |
f360ea0a | 452 | return(len); |
453 | } | |
a4c67285 | 454 | |
635dd34d | 455 | int32_t komodo_gateway_deposits(CMutableTransaction *txNew,char *base,int32_t tokomodo) |
429dabb5 | 456 | { |
1c05f0b5 | 457 | struct pax_transaction *pax,*tmp; char symbol[16],dest[16]; uint8_t *script,opcode,opret[16384],data[16384]; int32_t i,baseid,ht,len=0,opretlen=0,numvouts=1; struct komodo_state *sp; uint64_t available,deposited,issued,withdrawn,approved,redeemed,mask; |
6cd01056 | 458 | if ( KOMODO_PAX == 0 ) |
459 | return(0); | |
76d59c1d | 460 | struct komodo_state *kmdsp = komodo_stateptrget((char *)"KMD"); |
635dd34d | 461 | sp = komodo_stateptr(symbol,dest); |
27bf3c5e | 462 | strcpy(symbol,base); |
b27b2877 | 463 | if ( ASSETCHAINS_SYMBOL[0] != 0 && komodo_baseid(ASSETCHAINS_SYMBOL) < 0 ) |
716fb382 | 464 | return(0); |
429dabb5 | 465 | PENDING_KOMODO_TX = 0; |
a3f23ee2 | 466 | if ( tokomodo == 0 ) |
48e96ba1 | 467 | { |
77be6cd9 | 468 | opcode = 'I'; |
ba37a6b9 | 469 | for (i=0; i<3; i++) |
5c92f750 | 470 | { |
471 | if ( komodo_isrealtime(&ht) != 0 ) | |
472 | break; | |
473 | sleep(1); | |
474 | } | |
ba37a6b9 | 475 | if ( i == 3 ) |
fe9dc3b8 | 476 | { |
477 | printf("%s not realtime ht.%d\n",ASSETCHAINS_SYMBOL,ht); | |
478 | return(0); | |
479 | } | |
57f349cb | 480 | } |
481 | else | |
482 | { | |
483 | opcode = 'X'; | |
57f349cb | 484 | if ( komodo_paxtotal() == 0 ) |
485 | return(0); | |
486 | } | |
c169f64b | 487 | HASH_ITER(hh,PAX,pax,tmp) |
429dabb5 | 488 | { |
8b4d7f27 | 489 | if ( pax->type != 'D' && pax->type != 'A' ) |
490 | continue; | |
aa114a60 | 491 | { |
492 | #ifdef KOMODO_ASSETCHAINS_WAITNOTARIZE | |
26ac06c4 | 493 | if ( kmdsp != 0 && (kmdsp->NOTARIZED_HEIGHT >= pax->height || kmdsp->CURRENT_HEIGHT > pax->height+30) ) // assumes same chain as notarize |
8bd946ce | 494 | pax->validated = pax->komodoshis; //kmdsp->NOTARIZED_HEIGHT; |
fc40c343 | 495 | else pax->validated = pax->ready = 0; |
13c01d29 | 496 | #else |
497 | pax->validated = pax->komodoshis; | |
aa114a60 | 498 | #endif |
499 | } | |
25d878f4 | 500 | if ( ASSETCHAINS_SYMBOL[0] != 0 && (pax_fiatstatus(&available,&deposited,&issued,&withdrawn,&approved,&redeemed,symbol) != 0 || available < pax->fiatoshis) ) |
1c05f0b5 | 501 | { |
7ad9ed4d | 502 | if ( strcmp(ASSETCHAINS_SYMBOL,symbol) == 0 ) |
056bd9be | 503 | printf("miner.[%s]: skip %s %.8f when avail %.8f deposited %.8f, issued %.8f withdrawn %.8f approved %.8f redeemed %.8f\n",ASSETCHAINS_SYMBOL,symbol,dstr(pax->fiatoshis),dstr(available),dstr(deposited),dstr(issued),dstr(withdrawn),dstr(approved),dstr(redeemed)); |
1c05f0b5 | 504 | continue; |
505 | } | |
274dd7a5 | 506 | /*printf("pax.%s marked.%d %.8f -> %.8f ready.%d validated.%d\n",pax->symbol,pax->marked,dstr(pax->komodoshis),dstr(pax->fiatoshis),pax->ready!=0,pax->validated!=0); |
02c36c15 | 507 | if ( pax->marked != 0 || (pax->type != 'D' && pax->type != 'A') || pax->ready == 0 ) |
a06196fe | 508 | { |
509 | printf("reject 2\n"); | |
e5430f52 | 510 | continue; |
274dd7a5 | 511 | }*/ |
512 | if ( ASSETCHAINS_SYMBOL[0] != 0 && (strcmp(pax->symbol,symbol) != 0 || pax->validated == 0) ) | |
8bd946ce | 513 | { |
5fc94d71 | 514 | //printf("pax->symbol.%s != %s or null pax->validated %.8f\n",pax->symbol,symbol,dstr(pax->validated)); |
8bd946ce | 515 | continue; |
516 | } | |
fc40c343 | 517 | if ( pax->ready == 0 ) |
518 | continue; | |
582c6afe | 519 | if ( pax->type == 'A' && ASSETCHAINS_SYMBOL[0] == 0 ) |
520 | { | |
76d59c1d | 521 | if ( kmdsp != 0 ) |
582c6afe | 522 | { |
523 | if ( (baseid= komodo_baseid(pax->symbol)) < 0 || ((1LL << baseid) & sp->RTmask) == 0 ) | |
524 | { | |
525 | printf("not RT for (%s) %llx baseid.%d %llx\n",pax->symbol,(long long)sp->RTmask,baseid,(long long)(1LL<<baseid)); | |
526 | continue; | |
527 | } | |
76d59c1d | 528 | } else continue; |
582c6afe | 529 | } |
530 | ||
5481c677 | 531 | //printf("redeem.%d? (%c) %p pax.%s marked.%d %.8f -> %.8f ready.%d validated.%d approved.%d\n",tokomodo,pax->type,pax,pax->symbol,pax->marked,dstr(pax->komodoshis),dstr(pax->fiatoshis),pax->ready!=0,pax->validated!=0,pax->approved!=0); |
49058e97 | 532 | if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 ) |
635dd34d | 533 | printf("pax.%s marked.%d %.8f -> %.8f\n",ASSETCHAINS_SYMBOL,pax->marked,dstr(pax->komodoshis),dstr(pax->fiatoshis)); |
e5430f52 | 534 | txNew->vout.resize(numvouts+1); |
1fc75a27 | 535 | txNew->vout[numvouts].nValue = (opcode == 'I') ? pax->fiatoshis : pax->komodoshis; |
e5430f52 | 536 | txNew->vout[numvouts].scriptPubKey.resize(25); |
537 | script = (uint8_t *)&txNew->vout[numvouts].scriptPubKey[0]; | |
538 | *script++ = 0x76; | |
539 | *script++ = 0xa9; | |
540 | *script++ = 20; | |
541 | memcpy(script,pax->rmd160,20), script += 20; | |
542 | *script++ = 0x88; | |
543 | *script++ = 0xac; | |
a3f23ee2 | 544 | if ( tokomodo == 0 ) |
16bed6ac | 545 | { |
546 | for (i=0; i<32; i++) | |
16bed6ac | 547 | data[len++] = ((uint8_t *)&pax->txid)[i]; |
16bed6ac | 548 | data[len++] = pax->vout & 0xff; |
549 | data[len++] = (pax->vout >> 8) & 0xff; | |
e5430f52 | 550 | PENDING_KOMODO_TX += pax->fiatoshis; |
16bed6ac | 551 | } |
fbc4209b | 552 | else |
553 | { | |
e0357628 | 554 | len += komodo_rwapproval(1,&data[len],pax); |
fbc4209b | 555 | PENDING_KOMODO_TX += pax->komodoshis; |
1eaffd74 | 556 | printf(" len.%d vout.%u DEPOSIT %.8f <- pax.%s pending ht %d %d %.8f | ",len,pax->vout,(double)txNew->vout[numvouts].nValue/COIN,symbol,pax->height,pax->otherheight,dstr(PENDING_KOMODO_TX)); |
fbc4209b | 557 | } |
e5430f52 | 558 | if ( numvouts++ >= 64 ) |
559 | break; | |
429dabb5 | 560 | } |
561 | if ( numvouts > 1 ) | |
562 | { | |
0e3472c1 | 563 | if ( tokomodo != 0 ) |
27bf3c5e | 564 | strcpy(symbol,(char *)"KMD"); |
9ef47e29 | 565 | for (i=0; symbol[i]!=0; i++) |
566 | data[len++] = symbol[i]; | |
a5ad8f02 | 567 | data[len++] = 0; |
8b4d7f27 | 568 | for (i=0; i<len; i++) |
569 | printf("%02x",data[i]); | |
570 | printf(" <- data[%d]\n",len); | |
77be6cd9 | 571 | opretlen = komodo_opreturnscript(opret,opcode,data,len); |
50824530 | 572 | txNew->vout.resize(numvouts+1); |
573 | txNew->vout[numvouts].nValue = 0; | |
574 | txNew->vout[numvouts].scriptPubKey.resize(opretlen); | |
575 | script = (uint8_t *)&txNew->vout[numvouts].scriptPubKey[0]; | |
429dabb5 | 576 | memcpy(script,opret,opretlen); |
8b4d7f27 | 577 | for (i=0; i<8; i++) |
578 | printf("%02x",opret[i]); | |
e03bcdd6 | 579 | printf(" <- opret, MINER deposits.%d (%s) vouts.%d %.8f opretlen.%d\n",tokomodo,ASSETCHAINS_SYMBOL,numvouts,dstr(PENDING_KOMODO_TX),opretlen); |
d9a9d562 | 580 | return(1); |
9ef47e29 | 581 | } |
d9a9d562 | 582 | return(0); |
429dabb5 | 583 | } |
584 | ||
8f64a3a9 | 585 | int32_t komodo_check_deposit(int32_t height,const CBlock& block) // verify above block is valid pax pricing |
557d9a23 | 586 | { |
e4bef239 | 587 | int32_t i,j,n,ht,num,opretlen,offset=1,errs=0,matched=0,kmdheights[64],otherheights[64]; uint256 hash,txids[64]; char symbol[16],base[16]; uint16_t vouts[64]; int8_t baseids[64]; uint8_t *script,opcode,rmd160s[64*20]; uint64_t available,deposited,issued,withdrawn,approved,redeemed; int64_t values[64],srcvalues[64]; struct pax_transaction *pax; |
2d3c928f | 588 | if ( KOMODO_PAX == 0 || komodo_isrealtime(&ht) == 0 ) |
6cd01056 | 589 | return(0); |
1ed46112 | 590 | memset(baseids,0xff,sizeof(baseids)); |
591 | memset(values,0,sizeof(values)); | |
b89ab77c | 592 | memset(srcvalues,0,sizeof(srcvalues)); |
f360ea0a | 593 | memset(rmd160s,0,sizeof(rmd160s)); |
1ed46112 | 594 | memset(kmdheights,0,sizeof(kmdheights)); |
595 | memset(otherheights,0,sizeof(otherheights)); | |
557d9a23 | 596 | n = block.vtx[0].vout.size(); |
597 | script = (uint8_t *)block.vtx[0].vout[n-1].scriptPubKey.data(); | |
12d47153 | 598 | if ( n <= 2 || script[0] != 0x6a ) |
599 | return(0); | |
600 | offset += komodo_scriptitemlen(&opretlen,&script[offset]); | |
77be6cd9 | 601 | if ( ASSETCHAINS_SYMBOL[0] == 0 ) |
602 | { | |
85de2861 | 603 | //for (i=0; i<opretlen; i++) |
604 | // printf("%02x",script[i]); | |
605 | //printf(" height.%d checkdeposit n.%d [%02x] [%c] %d vs %d\n",height,n,script[0],script[offset],script[offset],'X'); | |
77be6cd9 | 606 | opcode = 'X'; |
09a235e1 | 607 | strcpy(symbol,(char *)"KMD"); |
77be6cd9 | 608 | } |
609 | else | |
610 | { | |
611 | strcpy(symbol,ASSETCHAINS_SYMBOL); | |
612 | opcode = 'I'; | |
716fb382 | 613 | if ( komodo_baseid(symbol) < 0 ) |
614 | { | |
615 | if ( block.vtx[0].vout.size() != 1 ) | |
616 | { | |
617 | printf("%s has more than one coinbase?\n",symbol); | |
618 | return(-1); | |
619 | } | |
620 | return(0); | |
621 | } | |
77be6cd9 | 622 | } |
623 | if ( script[offset] == opcode && opretlen < block.vtx[0].vout[n-1].scriptPubKey.size() ) | |
557d9a23 | 624 | { |
b89ab77c | 625 | if ( (num= komodo_issued_opreturn(base,txids,vouts,values,srcvalues,kmdheights,otherheights,baseids,rmd160s,&script[offset],opretlen,opcode == 'X')) > 0 ) |
557d9a23 | 626 | { |
627 | for (i=1; i<n-1; i++) | |
628 | { | |
1bc5fdf8 | 629 | if ( (pax= komodo_paxfinds(txids[i-1],vouts[i-1])) != 0 ) // finds... make sure right one |
5a2c5b6f | 630 | { |
ca75995d | 631 | pax->type = opcode; |
d5894ea8 | 632 | if ( opcode == 'I' && (pax_fiatstatus(&available,&deposited,&issued,&withdrawn,&approved,&redeemed,symbol) != 0 || available < pax->fiatoshis) ) |
1c05f0b5 | 633 | { |
507fbc47 | 634 | printf("checkdeposit.[%s]: skip %s %.8f when avail %.8f deposited %.8f, issued %.8f withdrawn %.8f approved %.8f redeemed %.8f\n",ASSETCHAINS_SYMBOL,symbol,dstr(pax->fiatoshis),dstr(available),dstr(deposited),dstr(issued),dstr(withdrawn),dstr(approved),dstr(redeemed)); |
1c05f0b5 | 635 | continue; |
636 | } | |
784c0112 | 637 | if ( ((opcode == 'I' && (pax->fiatoshis == 0 || pax->fiatoshis == block.vtx[0].vout[i].nValue)) || (opcode == 'X' && (pax->komodoshis == 0 || pax->komodoshis == block.vtx[0].vout[i].nValue))) ) |
f10b8e2e | 638 | { |
02c36c15 | 639 | if ( pax->marked != 0 && height >= 80820 ) |
73585700 | 640 | { |
76cf8058 | 641 | printf(">>>>>>>>>>> %c errs.%d i.%d match %.8f vs %.8f paxmarked.%d kht.%d ht.%d\n",opcode,errs,i,dstr(opcode == 'I' ? pax->fiatoshis : pax->komodoshis),dstr(block.vtx[0].vout[i].nValue),pax->marked,pax->height,pax->otherheight); |
8b4d7f27 | 642 | if ( pax->komodoshis != 0 || pax->fiatoshis != 0 ) |
643 | errs++; | |
e03bcdd6 | 644 | else matched++; // onetime init bypass |
4eb7c730 | 645 | } |
646 | else | |
647 | { | |
2d3c928f | 648 | if ( opcode == 'X' && strcmp(ASSETCHAINS_SYMBOL,CURRENCIES[baseids[i]]) == 0 ) |
4eb7c730 | 649 | printf("check deposit validates %s %.8f -> %.8f\n",CURRENCIES[baseids[i]],dstr(srcvalues[i]),dstr(values[i])); |
650 | matched++; | |
651 | } | |
f10b8e2e | 652 | } |
653 | else | |
654 | { | |
1c05f0b5 | 655 | for (j=0; j<32; j++) |
656 | printf("%02x",((uint8_t *)&txids[i-1])[j]); | |
657 | printf(" cant paxfind %c txid\n",opcode); | |
1bc5fdf8 | 658 | printf(">>>>>>>>>>> %c errs.%d i.%d match %.8f vs %.8f pax.%p\n",opcode,errs,i,dstr(opcode == 'I' ? pax->fiatoshis : pax->komodoshis),dstr(block.vtx[0].vout[i].nValue),pax); |
f10b8e2e | 659 | } |
5a2c5b6f | 660 | } |
6813c8d5 | 661 | else if ( kmdheights[i-1] > 0 && otherheights[i-1] > 0 ) |
cb040aa1 | 662 | { |
1c05f0b5 | 663 | hash = block.GetHash(); |
664 | for (j=0; j<32; j++) | |
665 | printf("%02x",((uint8_t *)&hash)[j]); | |
7ee875e8 | 666 | printf(" kht.%d ht.%d %.8f %.8f blockhash couldnt find vout.[%d]\n",kmdheights[i-1],otherheights[i-1],dstr(values[i-1]),dstr(srcvalues[i]),i); |
cb040aa1 | 667 | } |
557d9a23 | 668 | } |
283168fd | 669 | if ( ASSETCHAINS_SYMBOL[0] == 0 ) |
81041ab2 | 670 | { |
283168fd | 671 | if ( height > 0 && (height < chainActive.Tip()->nHeight || (height >= chainActive.Tip()->nHeight && komodo_isrealtime(&ht) != 0)) && matched != num ) |
52b2e68d | 672 | { |
5641c3d2 | 673 | printf("WOULD REJECT %s: ht.%d (%c) matched.%d vs num.%d tip.%d isRT.%d\n",symbol,height,opcode,matched,num,(int32_t)chainActive.Tip()->nHeight,komodo_isrealtime(&ht)); |
674 | // can easily happen depending on order of loading | |
675 | if ( height > 200000 ) | |
676 | { | |
677 | printf("REJECT: ht.%d (%c) matched.%d vs num.%d\n",height,opcode,matched,num); | |
678 | return(-1); | |
679 | } | |
680 | } | |
681 | } | |
682 | else | |
683 | { | |
4df419cd | 684 | if ( height > 0 && (height < chainActive.Tip()->nHeight || (height >= chainActive.Tip()->nHeight && komodo_isrealtime(&ht) != 0)) && matched != num ) |
5641c3d2 | 685 | { |
686 | printf("REJECT %s: ht.%d (%c) matched.%d vs num.%d tip.%d isRT.%d\n",symbol,height,opcode,matched,num,(int32_t)chainActive.Tip()->nHeight,komodo_isrealtime(&ht)); | |
52b2e68d | 687 | return(-1); |
688 | } | |
81041ab2 | 689 | } |
557d9a23 | 690 | } |
b98053e2 | 691 | //printf("opretlen.%d num.%d\n",opretlen,num); |
557d9a23 | 692 | } |
693 | return(0); | |
694 | } | |
695 | ||
cd26c1f3 | 696 | const char *komodo_opreturn(int32_t height,uint64_t value,uint8_t *opretbuf,int32_t opretlen,uint256 txid,uint16_t vout,char *source) |
429dabb5 | 697 | { |
6b5cfbb4 | 698 | uint8_t rmd160[20],rmd160s[64*20],addrtype,shortflag,pubkey33[33]; int32_t didstats,i,j,n,kvheight,len,tokomodo,kmdheight,otherheights[64],kmdheights[64]; int8_t baseids[64]; char base[4],coinaddr[64],destaddr[64]; uint256 txids[64]; uint16_t vouts[64]; uint64_t convtoshis,seed; int64_t fee,fiatoshis,komodoshis,checktoshis,values[64],srcvalues[64]; struct pax_transaction *pax,*pax2; struct komodo_state *basesp; double diff; |
1ed46112 | 699 | const char *typestr = "unknown"; |
088b1fa8 | 700 | if ( ASSETCHAINS_SYMBOL[0] != 0 && komodo_baseid(ASSETCHAINS_SYMBOL) < 0 && opretbuf[0] != 'K' ) |
894c570b | 701 | { |
b27b2877 | 702 | //printf("komodo_opreturn skip %s\n",ASSETCHAINS_SYMBOL); |
716fb382 | 703 | return("assetchain"); |
894c570b | 704 | } |
46222318 | 705 | //else if ( KOMODO_PAX == 0 ) |
706 | // return("nopax"); | |
1ed46112 | 707 | memset(baseids,0xff,sizeof(baseids)); |
708 | memset(values,0,sizeof(values)); | |
06cfcf31 | 709 | memset(srcvalues,0,sizeof(srcvalues)); |
f360ea0a | 710 | memset(rmd160s,0,sizeof(rmd160s)); |
1ed46112 | 711 | memset(kmdheights,0,sizeof(kmdheights)); |
712 | memset(otherheights,0,sizeof(otherheights)); | |
9596e284 | 713 | tokomodo = (komodo_is_issuer() == 0); |
ab6e81ec | 714 | if ( opretbuf[0] == 'K' && opretlen != 40 ) |
15d0fbd4 | 715 | { |
6b5cfbb4 | 716 | komodo_kvupdate(opretbuf,opretlen,value); |
15d0fbd4 | 717 | } |
718 | else if ( opretbuf[0] == 'D' ) | |
64bb0834 | 719 | { |
9596e284 | 720 | tokomodo = 0; |
05a37d87 | 721 | if ( opretlen == 38 ) // any KMD tx |
64bb0834 | 722 | { |
05a37d87 | 723 | iguana_rwnum(0,&opretbuf[34],sizeof(kmdheight),&kmdheight); |
abdd8672 | 724 | memset(base,0,sizeof(base)); |
725 | PAX_pubkey(0,&opretbuf[1],&addrtype,rmd160,base,&shortflag,&fiatoshis); | |
abdd8672 | 726 | bitcoin_address(coinaddr,addrtype,rmd160,20); |
727 | checktoshis = PAX_fiatdest(&seed,tokomodo,destaddr,pubkey33,coinaddr,kmdheight,base,fiatoshis); | |
728 | typestr = "deposit"; | |
bd041a51 | 729 | if ( kmdheight > 195000 || kmdheight <= height ) |
6e576848 | 730 | { |
f5e3cdfa | 731 | didstats = 0; |
c0d7dda6 | 732 | if ( 0 && strcmp(base,ASSETCHAINS_SYMBOL) == 0 ) |
8f261c33 | 733 | { |
734 | printf("(%s) (%s) kmdheight.%d vs height.%d check %.8f vs %.8f tokomodo.%d %d seed.%llx\n",ASSETCHAINS_SYMBOL,base,kmdheight,height,dstr(checktoshis),dstr(value),komodo_is_issuer(),strncmp(ASSETCHAINS_SYMBOL,base,strlen(base)) == 0,(long long)seed); | |
735 | for (i=0; i<32; i++) | |
736 | printf("%02x",((uint8_t *)&txid)[i]); | |
737 | printf(" <- txid.v%u ",vout); | |
738 | for (i=0; i<33; i++) | |
739 | printf("%02x",pubkey33[i]); | |
740 | printf(" checkpubkey check %.8f v %.8f dest.(%s) kmdheight.%d height.%d\n",dstr(checktoshis),dstr(value),destaddr,kmdheight,height); | |
741 | } | |
331a6188 | 742 | if ( komodo_paxcmp(base,kmdheight,value,checktoshis,seed) == 0 ) |
05a37d87 | 743 | { |
b915be35 | 744 | if ( (pax= komodo_paxfind(txid,vout,'D')) == 0 ) |
05a37d87 | 745 | { |
c98b3a08 | 746 | if ( (basesp= komodo_stateptrget(base)) != 0 ) |
05a37d87 | 747 | { |
c98b3a08 | 748 | basesp->deposited += fiatoshis; |
22a31d52 | 749 | didstats = 1; |
072efb59 | 750 | if ( 0 && strcmp(base,ASSETCHAINS_SYMBOL) == 0 ) |
0398360f | 751 | printf("########### %p deposited %s += %.8f kmdheight.%d %.8f\n",basesp,base,dstr(fiatoshis),kmdheight,dstr(value)); |
c72ee808 | 752 | } else printf("cant get stateptr.(%s)\n",base); |
4d4194d3 | 753 | komodo_gateway_deposit(coinaddr,value,base,fiatoshis,rmd160,txid,vout,'D',kmdheight,height,(char *)"KMD",0); |
3f9cad6d | 754 | } |
51e5d952 | 755 | if ( (pax= komodo_paxfind(txid,vout,'D')) != 0 ) |
3f9cad6d | 756 | { |
8bd946ce | 757 | pax->height = kmdheight; |
758 | pax->validated = value; | |
88dff0d3 | 759 | pax->komodoshis = value; |
760 | pax->fiatoshis = fiatoshis; | |
22a31d52 | 761 | if ( didstats == 0 && pax->didstats == 0 ) |
3f9cad6d | 762 | { |
ca75995d | 763 | if ( (basesp= komodo_stateptrget(base)) != 0 ) |
764 | { | |
765 | basesp->deposited += fiatoshis; | |
22a31d52 | 766 | didstats = 1; |
072efb59 | 767 | if ( 0 && strcmp(base,ASSETCHAINS_SYMBOL) == 0 ) |
c0d7dda6 | 768 | printf("########### %p depositedB %s += %.8f/%.8f kmdheight.%d/%d %.8f/%.8f\n",basesp,base,dstr(fiatoshis),dstr(pax->fiatoshis),kmdheight,pax->height,dstr(value),dstr(pax->komodoshis)); |
ca75995d | 769 | } |
3f9cad6d | 770 | } |
51e5d952 | 771 | if ( didstats != 0 ) |
772 | pax->didstats = 1; | |
7ddc4ef7 | 773 | if ( (pax2= komodo_paxfind(txid,vout,'I')) != 0 ) |
774 | { | |
775 | pax2->fiatoshis = pax->fiatoshis; | |
776 | pax2->komodoshis = pax->komodoshis; | |
7ddc4ef7 | 777 | pax->marked = pax2->marked = pax->height; |
da02b3be | 778 | pax2->height = pax->height = height; |
25623352 | 779 | if ( pax2->didstats == 0 ) |
780 | { | |
bde7e5ef | 781 | if ( (basesp= komodo_stateptrget(base)) != 0 ) |
782 | { | |
783 | basesp->issued += pax2->fiatoshis; | |
784 | pax2->didstats = 1; | |
8b4d7f27 | 785 | if ( 0 && strcmp(base,ASSETCHAINS_SYMBOL) == 0 ) |
36b8ed99 | 786 | printf("########### %p issueda %s += %.8f kmdheight.%d %.8f other.%d\n",basesp,base,dstr(pax2->fiatoshis),pax2->height,dstr(pax2->komodoshis),pax2->otherheight); |
bde7e5ef | 787 | } |
25623352 | 788 | } |
7ddc4ef7 | 789 | } |
3f9cad6d | 790 | } |
eb928486 | 791 | } |
acb18059 | 792 | else if ( seed != 0 && kmdheight > 182000 && strcmp(base,ASSETCHAINS_SYMBOL) == 0 ) |
0a31d015 | 793 | printf("pax %s deposit %.8f rejected kmdheight.%d %.8f KMD check %.8f seed.%llu\n",base,dstr(fiatoshis),kmdheight,dstr(value),dstr(checktoshis),(long long)seed); |
182dcdec | 794 | } //else printf("paxdeposit height.%d vs kmdheight.%d\n",height,kmdheight); |
64bb0834 | 795 | } |
796 | } | |
36b8ed99 | 797 | else if ( opretbuf[0] == 'I' ) |
798 | { | |
799 | tokomodo = 0; | |
800 | if ( strncmp((char *)"KMD",(char *)&opretbuf[opretlen-4],3) != 0 ) | |
801 | { | |
802 | if ( (n= komodo_issued_opreturn(base,txids,vouts,values,srcvalues,kmdheights,otherheights,baseids,rmd160s,opretbuf,opretlen,0)) > 0 ) | |
803 | { | |
804 | for (i=0; i<n; i++) | |
805 | { | |
806 | if ( baseids[i] < 0 ) | |
807 | { | |
808 | printf("%d of %d illegal baseid.%d\n",i,n,baseids[i]); | |
809 | continue; | |
810 | } | |
811 | bitcoin_address(coinaddr,60,&rmd160s[i*20],20); | |
812 | komodo_gateway_deposit(coinaddr,0,0,0,0,txids[i],vouts[i],'I',height,0,CURRENCIES[baseids[i]],0); | |
813 | komodo_paxmark(height,txids[i],vouts[i],'I',height); | |
814 | if ( (pax= komodo_paxfind(txids[i],vouts[i],'I')) != 0 ) | |
815 | { | |
816 | pax->type = opretbuf[0]; | |
817 | strcpy(pax->source,(char *)&opretbuf[opretlen-4]); | |
a6a33512 | 818 | if ( (pax2= komodo_paxfind(txids[i],vouts[i],'D')) != 0 && pax2->fiatoshis != 0 && pax2->komodoshis != 0 ) |
36b8ed99 | 819 | { |
820 | // realtime path? | |
821 | pax->fiatoshis = pax2->fiatoshis; | |
822 | pax->komodoshis = pax2->komodoshis; | |
823 | pax->marked = pax2->marked = pax2->height; | |
824 | if ( pax->didstats == 0 ) | |
825 | { | |
826 | if ( (basesp= komodo_stateptrget(CURRENCIES[baseids[i]])) != 0 ) | |
827 | { | |
828 | basesp->issued += pax->fiatoshis; | |
829 | pax->didstats = 1; | |
39863e30 | 830 | pax->height = pax2->height; |
831 | pax->otherheight = height; | |
8b4d7f27 | 832 | if ( 0 && strcmp(CURRENCIES[baseids[i]],ASSETCHAINS_SYMBOL) == 0 ) |
36b8ed99 | 833 | printf("########### %p issuedb %s += %.8f kmdheight.%d %.8f other.%d\n",basesp,CURRENCIES[baseids[i]],dstr(pax->fiatoshis),pax->height,dstr(pax->komodoshis),pax->otherheight); |
834 | } | |
835 | } | |
836 | } | |
837 | } | |
57f349cb | 838 | if ( (pax= komodo_paxmark(height,txids[i],vouts[i],'I',height)) != 0 ) |
839 | komodo_paxdelete(pax); | |
840 | if ( (pax= komodo_paxmark(height,txids[i],vouts[i],'D',height)) != 0 ) | |
841 | komodo_paxdelete(pax); | |
36b8ed99 | 842 | } |
174cae41 | 843 | } //else printf("opreturn none issued?\n"); |
36b8ed99 | 844 | } |
36b8ed99 | 845 | } |
a3608c89 | 846 | else if ( opretbuf[0] == 'W' )//&& opretlen >= 38 ) |
01d9ed2f | 847 | { |
bc653eee | 848 | if ( komodo_baseid((char *)&opretbuf[opretlen-4]) >= 0 && strcmp(ASSETCHAINS_SYMBOL,(char *)&opretbuf[opretlen-4]) == 0 ) |
8b4d7f27 | 849 | { |
850 | for (i=0; i<opretlen; i++) | |
851 | printf("%02x",opretbuf[i]); | |
d594eaa4 | 852 | printf(" [%s] reject obsolete withdraw request.%s\n",ASSETCHAINS_SYMBOL,(char *)&opretbuf[opretlen-4]); |
217eb34f | 853 | return(typestr); |
8b4d7f27 | 854 | } |
9596e284 | 855 | tokomodo = 1; |
01d9ed2f | 856 | iguana_rwnum(0,&opretbuf[34],sizeof(kmdheight),&kmdheight); |
857 | memset(base,0,sizeof(base)); | |
c3d94aec | 858 | PAX_pubkey(0,&opretbuf[1],&addrtype,rmd160,base,&shortflag,&komodoshis); |
01d9ed2f | 859 | bitcoin_address(coinaddr,addrtype,rmd160,20); |
c3d94aec | 860 | checktoshis = PAX_fiatdest(&seed,tokomodo,destaddr,pubkey33,coinaddr,kmdheight,base,value); |
01d9ed2f | 861 | typestr = "withdraw"; |
8b4d7f27 | 862 | //printf(" [%s] WITHDRAW %s.height.%d vs height.%d check %.8f/%.8f vs %.8f tokomodo.%d %d seed.%llx -> (%s) len.%d\n",ASSETCHAINS_SYMBOL,base,kmdheight,height,dstr(checktoshis),dstr(komodoshis),dstr(value),komodo_is_issuer(),strncmp(ASSETCHAINS_SYMBOL,base,strlen(base)) == 0,(long long)seed,coinaddr,opretlen); |
f5e3cdfa | 863 | didstats = 0; |
a39d7b21 | 864 | //if ( komodo_paxcmp(base,kmdheight,komodoshis,checktoshis,seed) == 0 ) |
01d9ed2f | 865 | { |
51e5d952 | 866 | if ( value != 0 && ((pax= komodo_paxfind(txid,vout,'W')) == 0 || pax->didstats == 0) ) |
0b556992 | 867 | { |
0126d891 | 868 | if ( (basesp= komodo_stateptrget(base)) != 0 ) |
869 | { | |
870 | basesp->withdrawn += value; | |
871 | didstats = 1; | |
2405bc66 | 872 | if ( strcmp(base,ASSETCHAINS_SYMBOL) == 0 ) |
5b489b55 | 873 | printf("########### %p withdrawn %s += %.8f check %.8f\n",basesp,base,dstr(value),dstr(checktoshis)); |
0126d891 | 874 | } |
57f349cb | 875 | if ( 0 && strcmp(base,"RUB") == 0 && (pax == 0 || pax->approved == 0) ) |
4718923d | 876 | printf("notarize %s %.8f -> %.8f kmd.%d other.%d\n",ASSETCHAINS_SYMBOL,dstr(value),dstr(komodoshis),kmdheight,height); |
ea365a71 | 877 | } |
115e6a5c | 878 | komodo_gateway_deposit(coinaddr,0,(char *)"KMD",value,rmd160,txid,vout,'W',kmdheight,height,source,0); |
51e5d952 | 879 | if ( (pax= komodo_paxfind(txid,vout,'W')) != 0 ) |
daeecf95 | 880 | { |
881 | pax->type = opretbuf[0]; | |
1ac3f9ef | 882 | strcpy(pax->source,base); |
883 | strcpy(pax->symbol,"KMD"); | |
daeecf95 | 884 | pax->height = kmdheight; |
885 | pax->otherheight = height; | |
1e22f865 | 886 | pax->komodoshis = komodoshis; |
daeecf95 | 887 | } |
a39d7b21 | 888 | } // else printf("withdraw %s paxcmp ht.%d %d error value %.8f -> %.8f vs %.8f\n",base,kmdheight,height,dstr(value),dstr(komodoshis),dstr(checktoshis)); |
889 | // need to allocate pax | |
a4c67285 | 890 | } |
891 | else if ( tokomodo != 0 && opretbuf[0] == 'A' ) | |
892 | { | |
9596e284 | 893 | tokomodo = 1; |
109afe64 | 894 | if ( 0 && ASSETCHAINS_SYMBOL[0] != 0 ) |
826bfe51 | 895 | { |
896 | for (i=0; i<opretlen; i++) | |
897 | printf("%02x",opretbuf[i]); | |
40f3d9cc | 898 | printf(" opret[%c] else path tokomodo.%d ht.%d before %.8f opretlen.%d\n",opretbuf[0],tokomodo,height,dstr(komodo_paxtotal()),opretlen); |
826bfe51 | 899 | } |
b89ab77c | 900 | if ( (n= komodo_issued_opreturn(base,txids,vouts,values,srcvalues,kmdheights,otherheights,baseids,rmd160s,opretbuf,opretlen,1)) > 0 ) |
a4c67285 | 901 | { |
902 | for (i=0; i<n; i++) | |
903 | { | |
885643be | 904 | //for (j=0; j<32; j++) |
905 | // printf("%02x",((uint8_t *)&txids[i])[j]); | |
906 | //printf(" v%d %.8f %.8f k.%d ht.%d base.%d\n",vouts[i],dstr(values[i]),dstr(srcvalues[i]),kmdheights[i],otherheights[i],baseids[i]); | |
b89ab77c | 907 | if ( baseids[i] < 0 ) |
8e7b40d9 | 908 | { |
afdb28f3 | 909 | for (i=0; i<opretlen; i++) |
910 | printf("%02x",opretbuf[i]); | |
911 | printf(" opret[%c] else path tokomodo.%d ht.%d before %.8f opretlen.%d\n",opretbuf[0],tokomodo,height,dstr(komodo_paxtotal()),opretlen); | |
8952ee9d | 912 | //printf("baseids[%d] %d\n",i,baseids[i]); |
afdb28f3 | 913 | if ( (pax= komodo_paxfind(txids[i],vouts[i],'W')) != 0 || (pax= komodo_paxfind(txids[i],vouts[i],'X')) != 0 ) |
51752631 | 914 | { |
915 | baseids[i] = komodo_baseid(pax->symbol); | |
916 | printf("override neg1 with (%s)\n",pax->symbol); | |
917 | } | |
918 | if ( baseids[i] < 0 ) | |
919 | continue; | |
8e7b40d9 | 920 | } |
f5e3cdfa | 921 | didstats = 0; |
0cc6ad81 | 922 | seed = 0; |
d515094d | 923 | checktoshis = komodo_paxprice(&seed,kmdheights[i],CURRENCIES[baseids[i]],(char *)"KMD",(uint64_t)values[i]); |
8b4d7f27 | 924 | //printf("PAX_fiatdest ht.%d price %s %.8f -> KMD %.8f vs %.8f\n",kmdheights[i],CURRENCIES[baseids[i]],(double)values[i]/COIN,(double)srcvalues[i]/COIN,(double)checktoshis/COIN); |
371a9c87 | 925 | if ( srcvalues[i] == checktoshis ) |
a4c67285 | 926 | { |
36a4e92c | 927 | if ( (pax= komodo_paxfind(txids[i],vouts[i],'A')) == 0 ) |
0fa85cc3 | 928 | { |
371a9c87 | 929 | bitcoin_address(coinaddr,60,&rmd160s[i*20],20); |
5481c677 | 930 | komodo_gateway_deposit(coinaddr,srcvalues[i],CURRENCIES[baseids[i]],values[i],&rmd160s[i*20],txids[i],vouts[i],'A',kmdheights[i],otherheights[i],CURRENCIES[baseids[i]],kmdheights[i]); |
371a9c87 | 931 | if ( (pax= komodo_paxfind(txids[i],vouts[i],'A')) == 0 ) |
932 | printf("unexpected null pax for approve\n"); | |
933 | else pax->validated = checktoshis; | |
934 | if ( (pax2= komodo_paxfind(txids[i],vouts[i],'W')) != 0 ) | |
935 | pax2->approved = kmdheights[i]; | |
7aadf9a9 | 936 | komodo_paxmark(height,txids[i],vouts[i],'W',height); |
371a9c87 | 937 | //komodo_paxmark(height,txids[i],vouts[i],'A',height); |
bca09689 | 938 | if ( values[i] != 0 && (basesp= komodo_stateptrget(CURRENCIES[baseids[i]])) != 0 ) |
371a9c87 | 939 | { |
5481c677 | 940 | basesp->approved += values[i]; |
371a9c87 | 941 | didstats = 1; |
5a544e6a | 942 | printf("pax.%p ########### %p approved %s += %.8f -> %.8f/%.8f kht.%d %d\n",pax,basesp,CURRENCIES[baseids[i]],dstr(values[i]),dstr(srcvalues[i]),dstr(checktoshis),kmdheights[i],otherheights[i]); |
371a9c87 | 943 | } |
944 | //printf(" i.%d (%s) <- %.8f ADDFLAG APPROVED\n",i,coinaddr,dstr(values[i])); | |
0fa85cc3 | 945 | } |
371a9c87 | 946 | else if ( pax->didstats == 0 && srcvalues[i] != 0 ) |
3f9cad6d | 947 | { |
371a9c87 | 948 | if ( (basesp= komodo_stateptrget(CURRENCIES[baseids[i]])) != 0 ) |
949 | { | |
5481c677 | 950 | basesp->approved += values[i]; |
371a9c87 | 951 | didstats = 1; |
5a544e6a | 952 | printf("pax.%p ########### %p approved %s += %.8f -> %.8f/%.8f kht.%d %d\n",pax,basesp,CURRENCIES[baseids[i]],dstr(values[i]),dstr(srcvalues[i]),dstr(checktoshis),kmdheights[i],otherheights[i]); |
371a9c87 | 953 | } |
954 | } //else printf(" i.%d of n.%d pax.%p baseids[] %d\n",i,n,pax,baseids[i]); | |
955 | if ( (pax= komodo_paxfind(txids[i],vouts[i],'A')) != 0 ) | |
956 | { | |
957 | pax->type = opretbuf[0]; | |
958 | pax->approved = kmdheights[i]; | |
959 | pax->validated = checktoshis; | |
960 | if ( didstats != 0 ) | |
961 | pax->didstats = 1; | |
7ad9ed4d | 962 | //if ( strcmp(CURRENCIES[baseids[i]],ASSETCHAINS_SYMBOL) == 0 ) |
5481c677 | 963 | //printf(" i.%d approved.%d <<<<<<<<<<<<< APPROVED %p\n",i,kmdheights[i],pax); |
371a9c87 | 964 | } |
06d1a655 | 965 | } |
ea365a71 | 966 | } |
dd278be2 | 967 | } //else printf("n.%d from opreturns\n",n); |
bff51d67 | 968 | //printf("extra.[%d] after %.8f\n",n,dstr(komodo_paxtotal())); |
01d9ed2f | 969 | } |
ca3c6549 | 970 | else if ( opretbuf[0] == 'X' ) |
971 | { | |
9596e284 | 972 | tokomodo = 1; |
c65d0868 | 973 | if ( (n= komodo_issued_opreturn(base,txids,vouts,values,srcvalues,kmdheights,otherheights,baseids,rmd160s,opretbuf,opretlen,1)) > 0 ) |
4c58b338 | 974 | { |
975 | for (i=0; i<n; i++) | |
976 | { | |
3f9cad6d | 977 | if ( baseids[i] < 0 ) |
978 | continue; | |
4c58b338 | 979 | bitcoin_address(coinaddr,60,&rmd160s[i*20],20); |
51e5d952 | 980 | komodo_gateway_deposit(coinaddr,0,0,0,0,txids[i],vouts[i],'X',height,0,(char *)"KMD",0); |
aa114a60 | 981 | komodo_paxmark(height,txids[i],vouts[i],'W',height); |
982 | komodo_paxmark(height,txids[i],vouts[i],'A',height); | |
983 | komodo_paxmark(height,txids[i],vouts[i],'X',height); | |
51e5d952 | 984 | if ( (pax= komodo_paxfind(txids[i],vouts[i],'X')) != 0 ) |
ca75995d | 985 | { |
986 | pax->type = opretbuf[0]; | |
6276f755 | 987 | if ( height < 121842 ) // fields got switched around due to legacy issues and approves |
2ee39fae | 988 | value = srcvalues[i]; |
989 | else value = values[i]; | |
990 | if ( baseids[i] >= 0 && value != 0 && (basesp= komodo_stateptrget(CURRENCIES[baseids[i]])) != 0 ) | |
c6eca157 | 991 | { |
2ee39fae | 992 | basesp->redeemed += value; |
546672f5 | 993 | pax->didstats = 1; |
dff9ec91 | 994 | if ( strcmp(CURRENCIES[baseids[i]],ASSETCHAINS_SYMBOL) == 0 ) |
e62f7114 | 995 | printf("ht.%d %.8f ########### %p redeemed %s += %.8f %.8f kht.%d ht.%d\n",height,dstr(value),basesp,CURRENCIES[baseids[i]],dstr(value),dstr(srcvalues[i]),kmdheights[i],otherheights[i]); |
c6eca157 | 996 | } |
ca75995d | 997 | } |
57f349cb | 998 | if ( (pax= komodo_paxmark(height,txids[i],vouts[i],'W',height)) != 0 ) |
999 | komodo_paxdelete(pax); | |
1000 | if ( (pax= komodo_paxmark(height,txids[i],vouts[i],'A',height)) != 0 ) | |
1001 | komodo_paxdelete(pax); | |
1002 | if ( (pax= komodo_paxmark(height,txids[i],vouts[i],'X',height)) != 0 ) | |
1003 | komodo_paxdelete(pax); | |
4c58b338 | 1004 | } |
dff4ef45 | 1005 | } //else printf("komodo_issued_opreturn returned %d\n",n); |
ca3c6549 | 1006 | } |
64bb0834 | 1007 | return(typestr); |
1008 | } | |
1009 | ||
30d79208 | 1010 | void komodo_passport_iteration() |
ab918767 | 1011 | { |
588bc897 | 1012 | static long lastpos[34]; static char userpass[33][1024]; int32_t maxseconds = 7; |
8d4fe133 | 1013 | FILE *fp; int32_t baseid,n,ht,isrealtime,refid,blocks,longest; struct komodo_state *sp,*refsp; char *retstr,fname[512],*base,symbol[16],dest[16]; uint32_t buf[3],starttime; cJSON *infoobj,*result; uint64_t RTmask = 0; |
2a15e8ea | 1014 | //printf("PASSPORT.(%s)\n",ASSETCHAINS_SYMBOL); |
17899df4 | 1015 | while ( KOMODO_INITDONE == 0 ) |
1016 | { | |
e40060c2 | 1017 | fprintf(stderr,"[%s] PASSPORT iteration waiting for KOMODO_INITDONE\n",ASSETCHAINS_SYMBOL); |
17899df4 | 1018 | sleep(3); |
1019 | } | |
635dd34d | 1020 | refsp = komodo_stateptr(symbol,dest); |
ab918767 | 1021 | if ( ASSETCHAINS_SYMBOL[0] == 0 ) |
67cd296f | 1022 | refid = 33; |
b307682f | 1023 | else |
716fb382 | 1024 | { |
b307682f | 1025 | refid = komodo_baseid(ASSETCHAINS_SYMBOL)+1; // illegal base -> baseid.-1 -> 0 |
1026 | if ( refid == 0 ) | |
1027 | { | |
1028 | KOMODO_PASSPORT_INITDONE = 1; | |
1029 | return; | |
1030 | } | |
716fb382 | 1031 | } |
6cd01056 | 1032 | if ( KOMODO_PAX == 0 ) |
1033 | { | |
1034 | KOMODO_PASSPORT_INITDONE = 1; | |
1035 | return; | |
1036 | } | |
ba37a6b9 | 1037 | starttime = (uint32_t)time(NULL); |
49058e97 | 1038 | //printf("PASSPORT %s refid.%d\n",ASSETCHAINS_SYMBOL,refid); |
959782f9 | 1039 | for (baseid=32; baseid>=0; baseid--) |
508b0d3c | 1040 | { |
e22dcc1e | 1041 | if ( time(NULL) >= starttime+maxseconds ) |
588bc897 | 1042 | break; |
ecf6256c | 1043 | sp = 0; |
1044 | isrealtime = 0; | |
f789edde | 1045 | base = (char *)CURRENCIES[baseid]; |
95a6016d | 1046 | if ( baseid+1 != refid ) |
ab918767 | 1047 | { |
055db9b6 | 1048 | komodo_statefname(fname,baseid<32?base:(char *)"",(char *)"komodostate"); |
52f1d788 | 1049 | komodo_nameset(symbol,dest,base); |
22b09834 | 1050 | sp = komodo_stateptrget(symbol); |
ba37a6b9 | 1051 | n = 0; |
22b09834 | 1052 | if ( (fp= fopen(fname,"rb")) != 0 && sp != 0 ) |
ab918767 | 1053 | { |
52f1d788 | 1054 | fseek(fp,0,SEEK_END); |
1055 | if ( ftell(fp) > lastpos[baseid] ) | |
ab918767 | 1056 | { |
894c570b | 1057 | if ( 0 && lastpos[baseid] == 0 && strcmp(symbol,"KMD") == 0 ) |
9a6744f2 | 1058 | printf("passport refid.%d %s fname.(%s) base.%s\n",refid,symbol,fname,base); |
52f1d788 | 1059 | fseek(fp,lastpos[baseid],SEEK_SET); |
ba37a6b9 | 1060 | while ( komodo_parsestatefile(sp,fp,symbol,dest) >= 0 && n < 1000 ) |
1061 | { | |
1062 | if ( n == 999 ) | |
1063 | { | |
588bc897 | 1064 | if ( time(NULL) < starttime+maxseconds ) |
ba37a6b9 | 1065 | n = 0; |
5254630a | 1066 | else printf("expire passport loop %s -> %s at %ld\n",ASSETCHAINS_SYMBOL,base,lastpos[baseid]); |
ba37a6b9 | 1067 | } |
1068 | n++; | |
1069 | } | |
52f1d788 | 1070 | lastpos[baseid] = ftell(fp); |
588bc897 | 1071 | if ( lastpos[baseid] == 0 && strcmp(symbol,"KMD") == 0 ) |
8d4fe133 | 1072 | printf("from.(%s) lastpos[%s] %ld isrt.%d\n",ASSETCHAINS_SYMBOL,CURRENCIES[baseid],lastpos[baseid],komodo_isrealtime(&ht)); |
49058e97 | 1073 | } //else fprintf(stderr,"%s.%ld ",CURRENCIES[baseid],ftell(fp)); |
52f1d788 | 1074 | fclose(fp); |
14e3fb45 | 1075 | } else printf("error.(%s) %p\n",fname,sp); |
a7ef556c | 1076 | komodo_statefname(fname,baseid<32?base:(char *)"",(char *)"realtime"); |
1077 | if ( (fp= fopen(fname,"rb")) != 0 ) | |
1078 | { | |
1079 | if ( fread(buf,1,sizeof(buf),fp) == sizeof(buf) ) | |
1080 | { | |
f1db88ea | 1081 | sp->CURRENT_HEIGHT = buf[0]; |
43d45898 | 1082 | if ( buf[0] != 0 && buf[0] >= buf[1] && buf[2] > time(NULL)-300 ) |
6eb41a2f | 1083 | { |
a7ef556c | 1084 | isrealtime = 1; |
6eb41a2f | 1085 | RTmask |= (1LL << baseid); |
635dd34d | 1086 | memcpy(refsp->RTbufs[baseid+1],buf,sizeof(refsp->RTbufs[baseid+1])); |
8e484443 | 1087 | } else if ( (time(NULL)-buf[2]) > 1200 ) |
1088 | fprintf(stderr,"[%s]: %s not RT %u %u %d\n",ASSETCHAINS_SYMBOL,base,buf[0],buf[1],(int32_t)(time(NULL)-buf[2])); | |
bffa91b2 | 1089 | } //else fprintf(stderr,"%s size error RT\n",base); |
a7ef556c | 1090 | fclose(fp); |
bff51d67 | 1091 | } //else fprintf(stderr,"%s open error RT\n",base); |
a7ef556c | 1092 | } |
6238a204 | 1093 | else |
a7ef556c | 1094 | { |
1095 | komodo_statefname(fname,baseid<32?base:(char *)"",(char *)"realtime"); | |
1096 | if ( (fp= fopen(fname,"wb")) != 0 ) | |
1097 | { | |
30376a70 | 1098 | buf[0] = (uint32_t)chainActive.Tip()->nHeight; |
a7ef556c | 1099 | buf[1] = (uint32_t)komodo_longestchain(); |
1100 | if ( buf[0] != 0 && buf[0] == buf[1] ) | |
6eb41a2f | 1101 | { |
a7ef556c | 1102 | buf[2] = (uint32_t)time(NULL); |
582c6afe | 1103 | RTmask |= (1LL << baseid); |
635dd34d | 1104 | memcpy(refsp->RTbufs[baseid+1],buf,sizeof(refsp->RTbufs[baseid+1])); |
1105 | if ( refid != 0 ) | |
1106 | memcpy(refsp->RTbufs[0],buf,sizeof(refsp->RTbufs[0])); | |
6eb41a2f | 1107 | } |
a7ef556c | 1108 | if ( fwrite(buf,1,sizeof(buf),fp) != sizeof(buf) ) |
1109 | fprintf(stderr,"[%s] %s error writing realtime\n",ASSETCHAINS_SYMBOL,base); | |
1110 | fclose(fp); | |
f789edde | 1111 | } else fprintf(stderr,"%s create error RT\n",base); |
ecf6256c | 1112 | } |
f1db88ea | 1113 | if ( sp != 0 && isrealtime == 0 ) |
1114 | refsp->RTbufs[0][2] = 0; | |
52f1d788 | 1115 | } |
6238a204 | 1116 | komodo_paxtotal(); |
635dd34d | 1117 | refsp->RTmask = RTmask; |
4767f1fc | 1118 | KOMODO_PASSPORT_INITDONE = 1; |
2a15e8ea | 1119 | //printf("done PASSPORT %s refid.%d\n",ASSETCHAINS_SYMBOL,refid); |
ab918767 | 1120 | } |
ab918767 | 1121 |