]> Git Repo - VerusCoin.git/blame - src/komodo_pax.h
test
[VerusCoin.git] / src / komodo_pax.h
CommitLineData
1e81ccb7 1
2
3int32_t NUM_PRICES; uint32_t *PVALS;
4
41a4a4db 5#define USD 0
6
1e81ccb7 7#define MAX_CURRENCIES 32
8char 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 12uint64_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
17uint32_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
1910*MIND,
1e81ccb7 20};
21
ab6984e9 22uint64_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 43void 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 58int32_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
93double 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
101void 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
129int32_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 142uint64_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 172uint64_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 187int32_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 199int32_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],&timestamp,&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}
This page took 0.046985 seconds and 4 git commands to generate.