]>
Commit | Line | Data |
---|---|---|
1e81ccb7 | 1 | |
2 | ||
3 | int32_t NUM_PRICES; uint32_t *PVALS; | |
4 | ||
41a4a4db | 5 | #define USD 0 |
6 | ||
1e81ccb7 | 7 | #define MAX_CURRENCIES 32 |
8 | char CURRENCIES[][8] = { "USD", "EUR", "JPY", "GBP", "AUD", "CAD", "CHF", "NZD", // major currencies | |
9 | "CNY", "RUB", "MXN", "BRL", "INR", "HKD", "TRY", "ZAR", "PLN", "NOK", "SEK", "DKK", "CZK", "HUF", "ILS", "KRW", "MYR", "PHP", "RON", "SGD", "THB", "BGN", "IDR", "HRK", | |
10 | "KMD" }; | |
11 | ||
a4ebaad7 | 12 | uint64_t M1SUPPLY[] = { 3317900000000, 6991604000000, 667780000000000, 1616854000000, 331000000000, 861909000000, 584629000000, 46530000000, // major currencies |
13 | 45434000000000, 16827000000, 3473357229000, 306435000000, 27139000000000, 2150641000000, 347724099000, 1469583000000, 749543000000, 1826110000000, 2400434000000, 1123925000000, 3125276000000, 13975000000000, 317657000000, 759706000000000, 354902000000, 2797061000000, 162189000000, 163745000000, 1712000000000, 39093000000, 1135490000000000, 80317000000, | |
14 | 100000000 }; | |
15 | ||
16 | #define MIND 1000 | |
17 | uint32_t MINDENOMS[] = { MIND, MIND, 100*MIND, MIND, MIND, MIND, MIND, MIND, // major currencies | |
18 | 10*MIND, 100*MIND, 10*MIND, MIND, 100*MIND, 10*MIND, MIND, 10*MIND, MIND, 10*MIND, 10*MIND, 10*MIND, 10*MIND, 100*MIND, MIND, 1000*MIND, MIND, 10*MIND, MIND, MIND, 10*MIND, MIND, 10000*MIND, 10*MIND, // end of currencies | |
19 | 10*MIND, | |
1e81ccb7 | 20 | }; |
21 | ||
ab6984e9 | 22 | uint64_t komodo_paxvol(uint64_t volume,uint64_t price) |
23 | { | |
24 | if ( volume < 10000000000 ) | |
25 | return((volume * price) / 1000000000); | |
26 | else if ( volume < (uint64_t)10 * 10000000000 ) | |
27 | return((volume * (price / 10)) / 100000000); | |
28 | else if ( volume < (uint64_t)100 * 10000000000 ) | |
29 | return(((volume / 10) * (price / 10)) / 10000000); | |
30 | else if ( volume < (uint64_t)1000 * 10000000000 ) | |
31 | return(((volume / 10) * (price / 100)) / 1000000); | |
32 | else if ( volume < (uint64_t)10000 * 10000000000 ) | |
33 | return(((volume / 100) * (price / 100)) / 100000); | |
34 | else if ( volume < (uint64_t)100000 * 10000000000 ) | |
35 | return(((volume / 100) * (price / 1000)) / 10000); | |
36 | else if ( volume < (uint64_t)1000000 * 10000000000 ) | |
37 | return(((volume / 1000) * (price / 1000)) / 1000); | |
38 | else if ( volume < (uint64_t)10000000 * 10000000000 ) | |
39 | return(((volume / 1000) * (price / 10000)) / 100); | |
40 | else return(((volume / 10000) * (price / 10000)) / 10); | |
41 | } | |
42 | ||
a4ebaad7 | 43 | void pax_rank(uint64_t *ranked,uint32_t *pvals) |
44 | { | |
45 | int32_t i; uint64_t vals[32],sum = 0; | |
46 | for (i=0; i<32; i++) | |
47 | { | |
48 | vals[i] = komodo_paxvol(M1SUPPLY[i] / MINDENOMS[i],pvals[i]); | |
49 | sum += vals[i]; | |
50 | } | |
51 | for (i=0; i<32; i++) | |
52 | { | |
53 | ranked[i] = (vals[i] * 1000000000) / sum; | |
54 | printf("%.6f ",(double)ranked[i]/1000000000.); | |
55 | } | |
56 | }; | |
57 | ||
1e81ccb7 | 58 | int32_t dpow_readprices(uint8_t *data,uint32_t *timestampp,double *KMDBTCp,double *BTCUSDp,double *CNYUSDp,uint32_t *pvals) |
59 | { | |
60 | uint32_t kmdbtc,btcusd,cnyusd; int32_t i,n,len = 0; | |
61 | len += iguana_rwnum(0,&data[len],sizeof(uint32_t),(void *)timestampp); | |
62 | len += iguana_rwnum(0,&data[len],sizeof(uint32_t),(void *)&n); | |
63 | len += iguana_rwnum(0,&data[len],sizeof(uint32_t),(void *)&kmdbtc); // /= 1000 | |
64 | len += iguana_rwnum(0,&data[len],sizeof(uint32_t),(void *)&btcusd); // *= 1000 | |
65 | len += iguana_rwnum(0,&data[len],sizeof(uint32_t),(void *)&cnyusd); | |
66 | *KMDBTCp = ((double)kmdbtc / (1000000000. * 1000.)); | |
67 | *BTCUSDp = ((double)btcusd / (1000000000. / 1000.)); | |
68 | *CNYUSDp = ((double)cnyusd / 1000000000.); | |
69 | for (i=0; i<n-3; i++) | |
70 | { | |
71 | len += iguana_rwnum(0,&data[len],sizeof(uint32_t),(void *)&pvals[i]); | |
72 | //printf("%u ",pvals[i]); | |
73 | } | |
74 | pvals[i++] = kmdbtc; | |
75 | pvals[i++] = btcusd; | |
76 | pvals[i++] = cnyusd; | |
77 | //printf("OP_RETURN prices\n"); | |
78 | return(n); | |
79 | } | |
80 | ||
81 | /*uint32_t PAX_val32(double val) | |
82 | { | |
83 | uint32_t val32 = 0; struct price_resolution price; | |
84 | if ( (price.Pval= val*1000000000) != 0 ) | |
85 | { | |
86 | if ( price.Pval > 0xffffffff ) | |
87 | printf("Pval overflow error %lld\n",(long long)price.Pval); | |
88 | else val32 = (uint32_t)price.Pval; | |
89 | } | |
90 | return(val32); | |
91 | }*/ | |
92 | ||
93 | double PAX_val(uint32_t pval,int32_t baseid) | |
94 | { | |
95 | //printf("PAX_val baseid.%d pval.%u\n",baseid,pval); | |
96 | if ( baseid >= 0 && baseid < MAX_CURRENCIES ) | |
97 | return(((double)pval / 1000000000.) / MINDENOMS[baseid]); | |
98 | return(0.); | |
99 | } | |
100 | ||
101 | void komodo_pvals(int32_t height,uint32_t *pvals,uint8_t numpvals) | |
102 | { | |
103 | int32_t i,nonz; double KMDBTC,BTCUSD,CNYUSD; uint32_t kmdbtc,btcusd,cnyusd; | |
104 | if ( numpvals >= 35 ) | |
105 | { | |
106 | for (nonz=i=0; i<32; i++) | |
107 | { | |
108 | if ( pvals[i] != 0 ) | |
109 | nonz++; | |
110 | //printf("%u ",pvals[i]); | |
111 | } | |
112 | if ( nonz == 32 ) | |
113 | { | |
114 | kmdbtc = pvals[i++]; | |
115 | btcusd = pvals[i++]; | |
116 | cnyusd = pvals[i++]; | |
117 | KMDBTC = ((double)kmdbtc / (1000000000. * 1000.)); | |
118 | BTCUSD = ((double)btcusd / (1000000000. / 1000.)); | |
119 | CNYUSD = ((double)cnyusd / 1000000000.); | |
120 | PVALS = (uint32_t *)realloc(PVALS,(NUM_PRICES+1) * sizeof(*PVALS) * 36); | |
121 | PVALS[36 * NUM_PRICES] = height; | |
122 | memcpy(&PVALS[36 * NUM_PRICES + 1],pvals,sizeof(*pvals) * 35); | |
123 | NUM_PRICES++; | |
124 | //printf("OP_RETURN.%d KMD %.8f BTC %.6f CNY %.6f NUM_PRICES.%d\n",height,KMDBTC,BTCUSD,CNYUSD,NUM_PRICES); | |
125 | } | |
126 | } | |
127 | } | |
128 | ||
129 | int32_t komodo_baseid(char *origbase) | |
130 | { | |
131 | int32_t i; char base[64]; | |
132 | for (i=0; origbase[i]!=0&&i<sizeof(base); i++) | |
133 | base[i] = toupper((int32_t)(origbase[i] & 0xff)); | |
134 | base[i] = 0; | |
135 | for (i=0; i<=MAX_CURRENCIES; i++) | |
136 | if ( strcmp(CURRENCIES[i],base) == 0 ) | |
137 | return(i); | |
138 | printf("illegal base.(%s) %s\n",origbase,base); | |
139 | return(-1); | |
140 | } | |
141 | ||
a4ebaad7 | 142 | uint64_t komodo_paxcalc(uint32_t *pvals,int32_t baseid,int32_t relid,uint64_t volume) |
143 | { | |
41a4a4db | 144 | uint32_t pvalb,pvalr,kmdbtc,btcusd; uint64_t baseusd,kmdusd,sum,ranked[32]; int32_t i; |
a4ebaad7 | 145 | if ( (pvalb= pvals[baseid]) != 0 ) |
146 | { | |
147 | if ( relid == MAX_CURRENCIES ) | |
148 | { | |
149 | kmdbtc = pvals[MAX_CURRENCIES]; | |
150 | btcusd = pvals[MAX_CURRENCIES + 1]; | |
151 | if ( pvals[USD] != 0 && kmdbtc != 0 && btcusd != 0 ) | |
152 | { | |
153 | baseusd = ((uint64_t)pvalb * 1000000000) / pvals[USD]; | |
154 | kmdusd = ((uint64_t)kmdbtc * 1000000000) / btcusd; | |
155 | //printf("base -> USD %llu, BTC %llu KMDUSD %llu\n",(long long)baseusd,(long long)btcusd,(long long)kmdusd); | |
156 | return(volume * ((baseusd * 1000000000) / kmdusd)); | |
157 | } | |
158 | } | |
159 | else if ( baseid == relid ) | |
160 | { | |
161 | pax_rank(ranked,pvals); | |
162 | ||
163 | } | |
164 | else if ( (pvalr= pvals[relid]) != 0 ) | |
165 | { | |
166 | baserel = ((uint64_t)pvalb * 1000000000) / pvalr; | |
167 | return(komodo_paxvol(volume,baserel)); | |
168 | } | |
169 | } | |
170 | } | |
171 | ||
1e81ccb7 | 172 | uint64_t komodo_paxprice(int32_t height,char *base,char *rel,uint64_t volume) |
173 | { | |
70ef4d12 | 174 | int32_t baseid=-1,relid=-1,i,ht; uint32_t kmdbtc,btcusd,pvalb,pvalr,*ptr; uint64_t baserel,baseusd,kmdusd; |
1e81ccb7 | 175 | if ( (baseid= komodo_baseid(base)) >= 0 && (relid= komodo_baseid(rel)) >= 0 ) |
176 | { | |
177 | for (i=NUM_PRICES-1; i>=0; i--) | |
178 | { | |
179 | ptr = &PVALS[36 * i]; | |
180 | if ( *ptr < height ) | |
a4ebaad7 | 181 | return(komodo_paxcalc(&ptr[1],baseid,relid,volume)); |
1e81ccb7 | 182 | } |
183 | } else printf("paxprice invalid base.%s %d, rel.%s %d\n",base,baseid,rel,relid); | |
184 | return(0); | |
185 | } | |
186 | ||
a4ebaad7 | 187 | int32_t komodo_paxprices(uint32_t *timestamps,uint64_t *prices,int32_t max,int32_t width,char *base,char *rel) |
188 | { | |
189 | int32_t baseid=-1,relid=-1,i,ht; uint32_t kmdbtc,btcusd,pvalb,pvalr,*ptr; uint64_t baserel,baseusd,kmdusd; | |
190 | if ( (baseid= komodo_baseid(base)) >= 0 && (relid= komodo_baseid(rel)) >= 0 ) | |
191 | { | |
192 | for (i=NUM_PRICES-1; i>=0; i--) | |
193 | { | |
194 | ptr = &PVALS[36 * i]; | |
195 | } | |
196 | } | |
197 | } | |
198 | ||
1e81ccb7 | 199 | int32_t komodo_pax_opreturn(uint8_t *opret,int32_t maxsize) |
200 | { | |
201 | static uint32_t lastcrc; | |
202 | FILE *fp; char fname[512]; uint32_t crc32,check,timestamp; int32_t i,n,retval,fsize,len=0; uint8_t data[8192]; | |
203 | #ifdef WIN32 | |
204 | sprintf(fname,"%s\\%s",GetDataDir(false).string().c_str(),(char *)"komodofeed"); | |
205 | #else | |
206 | sprintf(fname,"%s/%s",GetDataDir(false).string().c_str(),(char *)"komodofeed"); | |
207 | #endif | |
208 | if ( (fp= fopen(fname,"rb")) != 0 ) | |
209 | { | |
210 | fseek(fp,0,SEEK_END); | |
211 | fsize = (int32_t)ftell(fp); | |
212 | rewind(fp); | |
213 | if ( fsize <= maxsize-4 && fsize <= sizeof(data) && fsize > sizeof(crc32) ) | |
214 | { | |
215 | if ( (retval= (int32_t)fread(data,1,fsize,fp)) == fsize ) | |
216 | { | |
217 | len = iguana_rwnum(0,data,sizeof(crc32),(void *)&crc32); | |
218 | check = calc_crc32(0,data+sizeof(crc32),(int32_t)(fsize-sizeof(crc32))); | |
219 | if ( check == crc32 ) | |
220 | { | |
221 | double KMDBTC,BTCUSD,CNYUSD; uint32_t pvals[128]; | |
222 | dpow_readprices(&data[len],×tamp,&KMDBTC,&BTCUSD,&CNYUSD,pvals); | |
223 | if ( 0 && lastcrc != crc32 ) | |
224 | { | |
225 | for (i=0; i<32; i++) | |
226 | printf("%u ",pvals[i]); | |
227 | printf("t%u n.%d KMD %f BTC %f CNY %f (%f)\n",timestamp,n,KMDBTC,BTCUSD,CNYUSD,CNYUSD!=0?1./CNYUSD:0); | |
228 | } | |
229 | if ( timestamp > time(NULL)-600 ) | |
230 | { | |
231 | n = komodo_opreturnscript(opret,'P',data+sizeof(crc32),(int32_t)(fsize-sizeof(crc32))); | |
232 | if ( 0 && lastcrc != crc32 ) | |
233 | { | |
234 | for (i=0; i<n; i++) | |
235 | printf("%02x",opret[i]); | |
236 | printf(" coinbase opret[%d] crc32.%u:%u\n",n,crc32,check); | |
237 | } | |
238 | } else printf("t%u too old for %u\n",timestamp,(uint32_t)time(NULL)); | |
239 | lastcrc = crc32; | |
240 | } else printf("crc32 %u mismatch %u\n",crc32,check); | |
241 | } else printf("fread.%d error != fsize.%d\n",retval,fsize); | |
242 | } else printf("fsize.%d > maxsize.%d or data[%d]\n",fsize,maxsize,(int32_t)sizeof(data)); | |
243 | fclose(fp); | |
244 | } | |
245 | return(n); | |
246 | } |