You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
210 lines
8.3 KiB
210 lines
8.3 KiB
/******************************************************************************
|
|
* Copyright © 2014-2016 The SuperNET Developers. *
|
|
* *
|
|
* See the AUTHORS, DEVELOPER-AGREEMENT and LICENSE files at *
|
|
* the top-level directory of this distribution for the individual copyright *
|
|
* holder information and the developer policies on copyright and licensing. *
|
|
* *
|
|
* Unless otherwise agreed in a custom licensing agreement, no part of the *
|
|
* SuperNET software, including this file may be copied, modified, propagated *
|
|
* or distributed except according to the terms contained in the LICENSE file *
|
|
* *
|
|
* Removal or modification of this copyright notice is prohibited. *
|
|
* *
|
|
******************************************************************************/
|
|
|
|
// included from basilisk.c
|
|
|
|
uint32_t basilisk_requestid(struct basilisk_request *rp)
|
|
{
|
|
struct basilisk_request R;
|
|
R = *rp;
|
|
R.requestid = R.quoteid = R.quotetime = 0;
|
|
R.destamount = 0;
|
|
//R.relaybits = 0;
|
|
memset(R.desthash.bytes,0,sizeof(R.desthash.bytes));
|
|
if ( 0 )
|
|
{
|
|
int32_t i;
|
|
for (i=0; i<sizeof(R); i++)
|
|
printf("%02x",((uint8_t *)&R)[i]);
|
|
printf(" <- crc.%u\n",calc_crc32(0,(void *)&R,sizeof(R)));
|
|
char str[65],str2[65]; printf("B REQUESTID: t.%u r.%u q.%u %s %.8f %s -> %s %.8f %s crc.%u\n",R.timestamp,R.requestid,R.quoteid,R.src,dstr(R.srcamount),bits256_str(str,R.srchash),R.dest,dstr(R.destamount),bits256_str(str2,R.desthash),calc_crc32(0,(void *)&R,sizeof(R)));
|
|
}
|
|
return(calc_crc32(0,(void *)&R,sizeof(R)));
|
|
}
|
|
|
|
uint32_t basilisk_quoteid(struct basilisk_request *rp)
|
|
{
|
|
struct basilisk_request R;
|
|
R = *rp;
|
|
R.requestid = R.quoteid = 0; //R.relaybits =
|
|
return(calc_crc32(0,(void *)&R,sizeof(R)));
|
|
}
|
|
|
|
struct basilisk_request *basilisk_parsejson(struct basilisk_request *rp,cJSON *reqjson)
|
|
{
|
|
uint32_t requestid,quoteid;
|
|
memset(rp,0,sizeof(*rp));
|
|
rp->srchash = jbits256(reqjson,"srchash");
|
|
rp->desthash = jbits256(reqjson,"desthash");
|
|
rp->srcamount = j64bits(reqjson,"srcamount");
|
|
rp->minamount = j64bits(reqjson,"minamount");
|
|
rp->destamount = j64bits(reqjson,"destamount");
|
|
requestid = juint(reqjson,"requestid");
|
|
quoteid = juint(reqjson,"quoteid");
|
|
//if ( jstr(reqjson,"relay") != 0 )
|
|
// rp->relaybits = (uint32_t)calc_ipbits(jstr(reqjson,"relay"));
|
|
rp->timestamp = juint(reqjson,"timestamp");
|
|
rp->quotetime = juint(reqjson,"quotetime");
|
|
safecopy(rp->src,jstr(reqjson,"src"),sizeof(rp->src));
|
|
safecopy(rp->dest,jstr(reqjson,"dest"),sizeof(rp->dest));
|
|
if ( quoteid != 0 )
|
|
{
|
|
rp->quoteid = basilisk_quoteid(rp);
|
|
if ( quoteid != rp->quoteid )
|
|
printf("basilisk_parsejson quoteid.%u != %u error\n",quoteid,rp->quoteid);
|
|
}
|
|
rp->requestid = basilisk_requestid(rp);
|
|
if ( requestid != rp->requestid )
|
|
{
|
|
int32_t i; for (i=0; i<sizeof(*rp); i++)
|
|
printf("%02x",((uint8_t *)rp)[i]);
|
|
printf(" basilisk_parsejson.(%s) requestid.%u != %u error\n",jprint(reqjson,0),requestid,rp->requestid);
|
|
}
|
|
return(rp);
|
|
}
|
|
|
|
void basilisk_swap_balancingtrade(struct supernet_info *myinfo,struct basilisk_swap *swap,int32_t iambob)
|
|
{
|
|
// update balance, compare to target balance, issue balancing trade via central exchanges, if needed
|
|
if ( iambob != 0 )
|
|
{
|
|
|
|
}
|
|
else
|
|
{
|
|
|
|
}
|
|
}
|
|
|
|
|
|
struct basilisk_swap *basilisk_request_started(struct supernet_info *myinfo,uint32_t requestid)
|
|
{
|
|
int32_t i; struct basilisk_swap *active = 0;
|
|
portable_mutex_lock(&myinfo->DEX_swapmutex);
|
|
for (i=0; i<myinfo->numswaps; i++)
|
|
if ( myinfo->swaps[i]->req.requestid == requestid )
|
|
{
|
|
//printf("REQUEST STARTED.[%d] <- req.%u\n",i,requestid);
|
|
active = myinfo->swaps[i];
|
|
break;
|
|
}
|
|
portable_mutex_unlock(&myinfo->DEX_swapmutex);
|
|
return(active);
|
|
}
|
|
|
|
int32_t basilisk_request_cmpref(struct basilisk_request *ref,struct basilisk_request *rp)
|
|
{
|
|
if ( bits256_cmp(rp->srchash,ref->srchash) != 0 || memcmp(rp->src,ref->src,sizeof(ref->src)) != 0 || memcmp(rp->dest,ref->dest,sizeof(ref->dest)) != 0 || rp->srcamount != ref->srcamount || rp->timestamp != ref->timestamp )
|
|
{
|
|
printf("basilisk_request_listprocess mismatched hash\n");
|
|
return(-1);
|
|
} else return(0);
|
|
}
|
|
|
|
void tradebot_liquidity_command(struct supernet_info *myinfo,char *base,bits256 hash,cJSON *vals)
|
|
{
|
|
struct liquidity_info li,refli; int32_t i;
|
|
memset(&li,0,sizeof(li));
|
|
strcpy(li.base,base), strcpy(li.rel,"BTC");
|
|
li.profit = jdouble(vals,"profit");
|
|
li.refprice = jdouble(vals,"refprice");
|
|
for (i=0; i<sizeof(myinfo->linfos)/sizeof(*myinfo->linfos); i++)
|
|
{
|
|
refli = myinfo->linfos[i];
|
|
if ( strcmp(li.rel,refli.base) == 0 && strcmp(li.base,refli.rel) == 0 )
|
|
{
|
|
strcpy(li.base,refli.base);
|
|
strcpy(li.rel,refli.rel);
|
|
li.refprice = (1. / li.refprice);
|
|
printf("Set rev linfo[%d] (%s/%s) %.6f %.8f\n",i,li.base,li.rel,li.profit,li.refprice);
|
|
myinfo->linfos[i] = li;
|
|
return;
|
|
}
|
|
else if ( refli.base[0] == 0 || (strcmp(li.base,refli.base) == 0 && strcmp(li.rel,refli.rel) == 0) )
|
|
{
|
|
myinfo->linfos[i] = li;
|
|
printf("Set linfo[%d] (%s/%s) %.6f %.8f\n",i,li.base,li.rel,li.profit,li.refprice);
|
|
return;
|
|
}
|
|
}
|
|
printf("ERROR: too many linfos %d\n",i);
|
|
}
|
|
|
|
double tradebot_liquidity_active(struct supernet_info *myinfo,double *refpricep,char *base,char *rel)
|
|
{
|
|
int32_t i; struct liquidity_info refli;
|
|
*refpricep = 0.;
|
|
for (i=0; i<sizeof(myinfo->linfos)/sizeof(*myinfo->linfos); i++)
|
|
{
|
|
refli = myinfo->linfos[i];
|
|
if ( (strcmp(base,refli.base) == 0 && strcmp(rel,refli.rel) == 0) || (strcmp(rel,refli.base) == 0 && strcmp(base,refli.rel) == 0 ))
|
|
{
|
|
*refpricep = refli.refprice;
|
|
return(refli.profit);
|
|
}
|
|
}
|
|
return(0.);
|
|
}
|
|
|
|
double basilisk_process_results(struct supernet_info *myinfo,struct basilisk_request *issueR,cJSON *retjson,double hwm)
|
|
{
|
|
cJSON *array,*item; uint8_t *hexdata,*allocptr,hexspace[8192]; char *hexstr; int32_t i,hexlen,n,m,nonz; struct basilisk_request tmpR,R,refR,list[BASILISK_MAXRELAYS]; double metric=0.;
|
|
memset(&refR,0,sizeof(refR));
|
|
//printf("process.(%s)\n",jprint(retjson,0));
|
|
if ( (array= jarray(&n,retjson,"messages")) != 0 )
|
|
{
|
|
for (i=nonz=m=0; i<n; i++)
|
|
{
|
|
item = jitem(array,i);
|
|
if ( jobj(item,"error") == 0 )
|
|
{
|
|
if ( (hexstr= jstr(item,"data")) != 0 )
|
|
{
|
|
if ( (hexdata= get_dataptr(0,&allocptr,&hexlen,hexspace,sizeof(hexspace),hexstr)) != 0 )
|
|
{
|
|
basilisk_rwDEXquote(0,hexdata,&R);
|
|
//printf("[%d].(%s)\n",i,jprint(basilisk_requestjson(&R),1));
|
|
}
|
|
} else basilisk_parsejson(&R,item);
|
|
if ( nonz != 0 )
|
|
{
|
|
if ( refR.requestid == R.requestid )
|
|
list[m++] = R;
|
|
else
|
|
{
|
|
if ( (metric= basilisk_request_listprocess(myinfo,&tmpR,list,m)) > hwm )
|
|
{
|
|
*issueR = tmpR;
|
|
hwm = metric;
|
|
refR = tmpR;
|
|
}
|
|
m = 0;
|
|
}
|
|
}
|
|
nonz++;
|
|
if ( m < sizeof(list)/sizeof(*list) )
|
|
{
|
|
//basilisk_parsejson(&list[m++],item);
|
|
list[m++] = R;
|
|
}
|
|
}
|
|
}
|
|
//printf("process_results n.%d m.%d nonz.%d\n",n,m,nonz);
|
|
if ( m > 0 && m < sizeof(list)/sizeof(*list) )
|
|
if ( (metric= basilisk_request_listprocess(myinfo,&tmpR,list,m)) > hwm )
|
|
*issueR = tmpR, hwm = metric;
|
|
}
|
|
return(hwm);
|
|
}
|
|
|