/******************************************************************************
* Copyright © 2014 - 2017 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 . *
* *
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
//
// LP_ordermatch.c
// marketmaker
//
uint64_t LP_txfeecalc ( struct iguana_info * coin , uint64_t txfee , int32_t txlen )
{
if ( coin ! = 0 )
{
if ( strcmp ( coin - > symbol , " BTC " ) = = 0 )
{
if ( txlen = = 0 )
txlen = LP_AVETXSIZE ;
coin - > rate = LP_getestimatedrate ( coin ) ;
if ( ( txfee = SATOSHIDEN * coin - > rate * txlen ) < = LP_MIN_TXFEE )
{
coin - > rate = - 1. ;
coin - > rate = _LP_getestimatedrate ( coin ) ;
if ( ( txfee = SATOSHIDEN * coin - > rate * txlen ) < = LP_MIN_TXFEE )
txfee = LP_MIN_TXFEE ;
}
} else txfee = coin - > txfee ;
if ( txfee < LP_MIN_TXFEE )
txfee = LP_MIN_TXFEE ;
}
return ( txfee ) ;
}
double LP_qprice_calc ( int64_t * destsatoshisp , int64_t * satoshisp , double price , uint64_t b_satoshis , uint64_t txfee , uint64_t a_value , uint64_t maxdestsatoshis , uint64_t desttxfee )
{
uint64_t destsatoshis , satoshis ;
a_value - = ( desttxfee + 1 ) ;
destsatoshis = ( ( b_satoshis - txfee ) * price ) ;
if ( destsatoshis > a_value )
destsatoshis = a_value ;
if ( maxdestsatoshis ! = 0 & & destsatoshis > maxdestsatoshis - desttxfee - 1 )
destsatoshis = maxdestsatoshis - desttxfee - 1 ;
satoshis = ( destsatoshis / price + 0.49 ) - txfee ;
* destsatoshisp = destsatoshis ;
* satoshisp = satoshis ;
if ( satoshis > 0 )
return ( ( double ) destsatoshis / satoshis ) ;
else return ( 0. ) ;
}
int32_t LP_quote_checkmempool ( struct LP_quoteinfo * qp , struct LP_utxoinfo * autxo , struct LP_utxoinfo * butxo )
{
int32_t selector , spendvini ; bits256 spendtxid ;
if ( butxo ! = 0 & & ( selector = LP_mempool_vinscan ( & spendtxid , & spendvini , qp - > srccoin , qp - > coinaddr , qp - > txid , qp - > vout , qp - > txid2 , qp - > vout2 ) ) > = 0 )
{
char str [ 65 ] ; printf ( " LP_tradecommand selector.%d in mempool %s vini.%d " , selector , bits256_str ( str , spendtxid ) , spendvini ) ;
return ( - 1 ) ;
}
if ( autxo ! = 0 & & ( selector = LP_mempool_vinscan ( & spendtxid , & spendvini , qp - > destcoin , qp - > destaddr , qp - > desttxid , qp - > destvout , qp - > feetxid , qp - > feevout ) ) > = 0 )
{
char str [ 65 ] ; printf ( " LP_tradecommand dest selector.%d in mempool %s vini.%d " , selector , bits256_str ( str , spendtxid ) , spendvini ) ;
return ( - 1 ) ;
}
return ( 0 ) ;
}
double LP_quote_validate ( struct LP_utxoinfo * autxo , struct LP_utxoinfo * butxo , struct LP_quoteinfo * qp , int32_t iambob )
{
double qprice = 0. ; uint64_t txfee , desttxfee , srcvalue = 0 , srcvalue2 = 0 , destvalue = 0 , destvalue2 = 0 ;
printf ( " >>>>>>> quote satoshis.(%.8f %.8f) %s %.8f -> %s %.8f \n " , dstr ( qp - > satoshis ) , dstr ( qp - > destsatoshis ) , qp - > srccoin , dstr ( qp - > satoshis ) , qp - > destcoin , dstr ( qp - > destsatoshis ) ) ;
if ( butxo ! = 0 )
{
if ( LP_iseligible ( & srcvalue , & srcvalue2 , 1 , qp - > srccoin , qp - > txid , qp - > vout , qp - > satoshis , qp - > txid2 , qp - > vout2 ) = = 0 )
{
printf ( " bob not eligible %s \n " , jprint ( LP_quotejson ( qp ) , 1 ) ) ;
return ( - 2 ) ;
}
if ( bits256_cmp ( butxo - > deposit . txid , qp - > txid2 ) ! = 0 | | butxo - > deposit . vout ! = qp - > vout2 )
{
char str [ 65 ] , str2 [ 65 ] ; printf ( " %s != %s v%d != %d \n " , bits256_str ( str , butxo - > deposit . txid ) , bits256_str ( str2 , qp - > txid2 ) , butxo - > deposit . vout , qp - > vout2 ) ;
return ( - 6 ) ;
}
if ( strcmp ( butxo - > coinaddr , qp - > coinaddr ) ! = 0 )
{
printf ( " (%s) != (%s) \n " , butxo - > coinaddr , qp - > coinaddr ) ;
return ( - 7 ) ;
}
}
if ( autxo ! = 0 & & LP_iseligible ( & destvalue , & destvalue2 , 0 , qp - > destcoin , qp - > desttxid , qp - > destvout , qp - > destsatoshis , qp - > feetxid , qp - > feevout ) = = 0 )
{
char str [ 65 ] ; printf ( " alice not eligible (%.8f %.8f) %s/v%d \n " , dstr ( destvalue ) , dstr ( destvalue2 ) , bits256_str ( str , qp - > feetxid ) , qp - > feevout ) ;
return ( - 3 ) ;
}
if ( LP_quote_checkmempool ( qp , autxo , butxo ) < 0 )
return ( - 4 ) ;
//if ( iambob != 0 && (*butxop= LP_utxofind(1,qp->txid,qp->vout)) == 0 )
// return(-5);
if ( iambob = = 0 & & autxo ! = 0 )
{
//if ( (*autxop= LP_utxofind(0,qp->desttxid,qp->destvout)) == 0 )
// return(-8);
if ( bits256_cmp ( autxo - > fee . txid , qp - > feetxid ) ! = 0 | | autxo - > fee . vout ! = qp - > feevout )
return ( - 9 ) ;
if ( strcmp ( autxo - > coinaddr , qp - > destaddr ) ! = 0 )
return ( - 10 ) ;
}
if ( autxo ! = 0 & & destvalue < 2 * qp - > desttxfee + qp - > destsatoshis )
{
printf ( " destvalue %.8f destsatoshis %.8f is too small txfee %.8f? \n " , dstr ( destvalue ) , dstr ( qp - > destsatoshis ) , dstr ( qp - > desttxfee ) ) ;
return ( - 11 ) ;
}
if ( butxo ! = 0 & & srcvalue < 2 * qp - > txfee + qp - > satoshis )
{
printf ( " srcvalue %.8f [%.8f] satoshis %.8f is too small txfee %.8f? \n " , dstr ( srcvalue ) , dstr ( srcvalue ) - dstr ( qp - > txfee + qp - > satoshis ) , dstr ( qp - > satoshis ) , dstr ( qp - > txfee ) ) ;
return ( - 33 ) ;
}
if ( qp - > satoshis ! = 0 )
qprice = ( ( double ) qp - > destsatoshis / ( qp - > satoshis - qp - > txfee ) ) ;
LP_txfees ( & txfee , & desttxfee , qp - > srccoin , qp - > destcoin ) ;
if ( txfee < qp - > txfee )
txfee = qp - > txfee ;
if ( desttxfee < qp - > desttxfee )
desttxfee = qp - > desttxfee ;
printf ( " qprice %.8f <- %.8f/%.8f txfees.(%.8f %.8f) vs (%.8f %.8f) \n " , qprice , dstr ( qp - > destsatoshis ) , dstr ( qp - > satoshis ) , dstr ( qp - > txfee ) , dstr ( qp - > desttxfee ) , dstr ( txfee ) , dstr ( desttxfee ) ) ;
if ( qp - > txfee < LP_REQUIRED_TXFEE * txfee | | qp - > desttxfee < LP_REQUIRED_TXFEE * desttxfee )
return ( - 14 ) ;
if ( butxo ! = 0 )
{
if ( qp - > satoshis < ( srcvalue / LP_MINVOL ) | | srcvalue < qp - > txfee * LP_MINSIZE_TXFEEMULT )
{
printf ( " utxo payment %.8f is less than %f covered by Q %.8f or <10x txfee %.8f [%d %d] \n " , dstr ( srcvalue ) , 1. / LP_MINVOL , dstr ( qp - > satoshis ) , dstr ( qp - > txfee ) , qp - > satoshis < ( srcvalue / LP_MINVOL ) , srcvalue < qp - > txfee * LP_MINSIZE_TXFEEMULT ) ;
return ( - 12 ) ;
}
}
if ( autxo ! = 0 )
{
if ( qp - > destsatoshis < ( destvalue / LP_MINCLIENTVOL ) | | destvalue < qp - > desttxfee * LP_MINSIZE_TXFEEMULT )
{
printf ( " destsatoshis %.8f is less than %f of value %.8f or < 10x txfee %.8f \n " , dstr ( qp - > destsatoshis ) , 1. / LP_MINCLIENTVOL , dstr ( destvalue ) , dstr ( qp - > desttxfee ) ) ;
return ( - 13 ) ;
}
}
return ( qprice ) ;
}
int32_t LP_arrayfind ( cJSON * array , bits256 txid , int32_t vout )
{
int32_t i , n = cJSON_GetArraySize ( array ) ; cJSON * item ;
for ( i = 0 ; i < n ; i + + )
{
item = jitem ( array , i ) ;
if ( vout = = jint ( item , " vout " ) & & bits256_cmp ( txid , jbits256 ( item , " txid " ) ) = = 0 )
return ( i ) ;
}
return ( - 1 ) ;
}
int32_t LP_nanobind ( void * ctx , char * pairstr )
{
int32_t i , r , pairsock = - 1 ; uint16_t mypullport ; char bindaddr [ 128 ] ;
if ( LP_canbind ! = 0 )
{
if ( ( pairsock = nn_socket ( AF_SP , NN_PAIR ) ) < 0 )
printf ( " error creating utxo->pair \n " ) ;
else
{
for ( i = 0 ; i < 10 ; i + + )
{
r = ( 10000 + ( rand ( ) % 50000 ) ) & 0xffff ;
if ( LP_fixed_pairport ! = 0 )
r = LP_fixed_pairport ;
nanomsg_transportname ( 0 , pairstr , LP_myipaddr , r ) ;
nanomsg_transportname ( 1 , bindaddr , LP_myipaddr , r ) ;
if ( nn_bind ( pairsock , bindaddr ) > = 0 )
{
//timeout = 1;
//nn_setsockopt(pairsock,NN_SOL_SOCKET,NN_SNDTIMEO,&timeout,sizeof(timeout));
//nn_setsockopt(pairsock,NN_SOL_SOCKET,NN_RCVTIMEO,&timeout,sizeof(timeout));
printf ( " nanobind %s to %d \n " , pairstr , pairsock ) ;
return ( pairsock ) ;
} else printf ( " error binding to %s for %s \n " , bindaddr , pairstr ) ;
if ( LP_fixed_pairport ! = 0 )
break ;
}
}
} else pairsock = LP_initpublicaddr ( ctx , & mypullport , pairstr , " 127.0.0.1 " , 0 , 1 ) ;
return ( pairsock ) ;
}
int32_t LP_nearest_utxovalue ( struct iguana_info * coin , char * coinaddr , struct LP_address_utxo * * utxos , int32_t n , uint64_t targetval )
{
int32_t i , mini = - 1 ; struct LP_address_utxo * up ; struct electrum_info * backupep = 0 , * ep ; int64_t dist ; uint64_t mindist = ( 1LL < < 60 ) ;
if ( ( ep = coin - > electrum ) ! = 0 )
{
if ( ( backupep = ep - > prev ) = = 0 )
backupep = ep ;
}
//printf("LP_nearest_utxovalue %s utxos[%d] target %.8f\n",coin->symbol,n,dstr(targetval));
for ( i = 0 ; i < n ; i + + )
{
if ( ( up = utxos [ i ] ) ! = 0 )
{
dist = ( up - > U . value - targetval ) ;
//printf("nearest i.%d target %.8f val %.8f dist %.8f mindist %.8f mini.%d spent.%d\n",i,dstr(targetval),dstr(up->U.value),dstr(dist),dstr(mindist),mini,up->spendheight);
if ( up - > spendheight < = 0 )
{
if ( ( coin - > electrum = = 0 | | up - > SPV > 0 ) & & dist > = 0 & & dist < mindist )
{
//printf("(%.8f %.8f %.8f).%d ",dstr(up->U.value),dstr(dist),dstr(mindist),mini);
mini = i ;
mindist = dist ;
}
}
}
}
//printf("return mini.%d\n",mini);
return ( mini ) ;
}
uint64_t LP_basesatoshis ( double relvolume , double price , uint64_t txfee , uint64_t desttxfee )
{
//printf("basesatoshis %.8f (rel %.8f / price %.8f)\n",dstr(SATOSHIDEN * ((relvolume) / price) + 2*txfee),relvolume,price);
if ( relvolume > dstr ( desttxfee ) & & price > SMALLVAL )
return ( SATOSHIDEN * ( relvolume / price ) + 2 * txfee ) ;
else return ( 0 ) ;
}
struct LP_utxoinfo * LP_address_utxopair ( int32_t iambob , struct LP_address_utxo * * utxos , int32_t max , struct iguana_info * coin , char * coinaddr , uint64_t txfee , double relvolume , double price , uint64_t desttxfee )
{
struct LP_address * ap ; uint64_t targetval , targetval2 ; int32_t m , mini ; struct LP_address_utxo * up , * up2 ; struct LP_utxoinfo * utxo = 0 ;
if ( coin ! = 0 & & ( ap = LP_addressfind ( coin , coinaddr ) ) ! = 0 )
{
if ( ( m = LP_address_utxo_ptrs ( iambob , utxos , max , ap , coinaddr ) ) > 1 )
{
targetval = LP_basesatoshis ( relvolume , price , txfee , desttxfee ) ;
if ( 0 )
{
int32_t i ;
for ( i = 0 ; i < m ; i + + )
printf ( " %.8f " , dstr ( utxos [ i ] - > U . value ) ) ;
printf ( " targetval %.8f vol %.8f price %.8f txfee %.8f %s \n " , dstr ( targetval ) , relvolume , price , dstr ( txfee ) , coinaddr ) ;
}
mini = - 1 ;
if ( targetval ! = 0 & & ( mini = LP_nearest_utxovalue ( coin , coinaddr , utxos , m , targetval ) ) > = 0 )
{
up = utxos [ mini ] ;
utxos [ mini ] = 0 ;
targetval2 = ( targetval / 8 ) * 9 + 2 * txfee ;
//printf("found mini.%d %.8f for targetval %.8f -> targetval2 %.8f, ratio %.2f\n",mini,dstr(up->U.value),dstr(targetval),dstr(targetval2),(double)up->U.value/targetval);
if ( ( double ) up - > U . value / targetval < LP_MINVOL - 1 )
{
if ( ( mini = LP_nearest_utxovalue ( coin , coinaddr , utxos , m , targetval2 * 1.01 ) ) > = 0 )
{
if ( up ! = 0 & & ( up2 = utxos [ mini ] ) ! = 0 )
{
if ( ( utxo = LP_utxoadd ( 1 , coin - > symbol , up - > U . txid , up - > U . vout , up - > U . value , up2 - > U . txid , up2 - > U . vout , up2 - > U . value , coinaddr , ap - > pubkey , G . gui , 0 ) ) ! = 0 )
{
utxo - > S . satoshis = targetval ;
char str [ 65 ] , str2 [ 65 ] ; printf ( " butxo.%p targetval %.8f, found val %.8f %s | targetval2 %.8f val2 %.8f %s \n " , utxo , dstr ( targetval ) , dstr ( up - > U . value ) , bits256_str ( str , utxo - > payment . txid ) , dstr ( targetval2 ) , dstr ( up2 - > U . value ) , bits256_str ( str2 , utxo - > deposit . txid ) ) ;
return ( utxo ) ;
}
}
} //else printf("cant find targetval2 %.8f\n",dstr(targetval2));
} else printf ( " failed ratio test %.8f \n " , ( double ) up - > U . value / targetval ) ;
} else if ( targetval ! = 0 & & mini > = 0 )
printf ( " targetval %.8f mini.%d \n " , dstr ( targetval ) , mini ) ;
} //else printf("no %s utxos pass LP_address_utxo_ptrs filter\n",coinaddr);
} else printf ( " couldnt find %s %s \n " , coin - > symbol , coinaddr ) ;
return ( 0 ) ;
}
void LP_abutxo_set ( struct LP_utxoinfo * autxo , struct LP_utxoinfo * butxo , struct LP_quoteinfo * qp )
{
if ( butxo ! = 0 )
{
memset ( butxo , 0 , sizeof ( * butxo ) ) ;
butxo - > pubkey = qp - > srchash ;
safecopy ( butxo - > coin , qp - > srccoin , sizeof ( butxo - > coin ) ) ;
safecopy ( butxo - > coinaddr , qp - > coinaddr , sizeof ( butxo - > coinaddr ) ) ;
butxo - > payment . txid = qp - > txid ;
butxo - > payment . vout = qp - > vout ;
//butxo->payment.value = qp->value;
butxo - > iambob = 1 ;
butxo - > deposit . txid = qp - > txid2 ;
butxo - > deposit . vout = qp - > vout2 ;
//butxo->deposit.value = up2->U.value;
butxo - > S . satoshis = qp - > satoshis ;
}
if ( autxo ! = 0 )
{
memset ( autxo , 0 , sizeof ( * autxo ) ) ;
autxo - > pubkey = qp - > desthash ;
safecopy ( autxo - > coin , qp - > destcoin , sizeof ( autxo - > coin ) ) ;
safecopy ( autxo - > coinaddr , qp - > destaddr , sizeof ( autxo - > coinaddr ) ) ;
autxo - > payment . txid = qp - > desttxid ;
autxo - > payment . vout = qp - > destvout ;
//autxo->payment.value = qp->value;
autxo - > iambob = 0 ;
autxo - > fee . txid = qp - > feetxid ;
autxo - > fee . vout = qp - > feevout ;
//autxo->deposit.value = up2->U.value;
autxo - > S . satoshis = qp - > destsatoshis ;
}
}
int32_t LP_connectstartbob ( void * ctx , int32_t pubsock , struct LP_utxoinfo * utxo , cJSON * argjson , char * base , char * rel , double price , struct LP_quoteinfo * qp )
{
char pairstr [ 512 ] ; cJSON * retjson ; bits256 privkey ; int32_t pair = - 1 , retval = - 1 , DEXselector = 0 ; struct basilisk_swap * swap ; struct iguana_info * coin ;
printf ( " LP_connectstartbob.(%s) with.(%s) %s \n " , LP_myipaddr , jprint ( argjson , 0 ) , LP_myipaddr ) ;
qp - > quotetime = ( uint32_t ) time ( NULL ) ;
if ( ( coin = LP_coinfind ( utxo - > coin ) ) = = 0 )
{
printf ( " cant find coin.%s \n " , utxo - > coin ) ;
return ( - 1 ) ;
}
privkey = LP_privkey ( utxo - > coinaddr , coin - > taddr ) ;
if ( bits256_nonz ( privkey ) ! = 0 & & bits256_cmp ( G . LP_mypub25519 , qp - > srchash ) = = 0 ) //qp->quotetime >= qp->timestamp-3 && qp->quotetime <= utxo->T.swappending &&
{
if ( ( pair = LP_nanobind ( ctx , pairstr ) ) > = 0 )
{
LP_requestinit ( & qp - > R , qp - > srchash , qp - > desthash , base , qp - > satoshis - 2 * qp - > txfee , rel , qp - > destsatoshis - 2 * qp - > desttxfee , qp - > timestamp , qp - > quotetime , DEXselector ) ;
swap = LP_swapinit ( 1 , 0 , privkey , & qp - > R , qp ) ;
swap - > N . pair = pair ;
utxo - > S . swap = swap ;
swap - > utxo = utxo ;
if ( OS_thread_create ( malloc ( sizeof ( pthread_t ) ) , NULL , ( void * ) LP_bobloop , ( void * ) swap ) = = 0 )
{
retjson = LP_quotejson ( qp ) ;
jaddstr ( retjson , " method " , " connected " ) ;
jaddstr ( retjson , " pair " , pairstr ) ;
jaddnum ( retjson , " requestid " , qp - > R . requestid ) ;
jaddnum ( retjson , " quoteid " , qp - > R . quoteid ) ;
// LP_addsig
char str [ 65 ] ; printf ( " BOB pubsock.%d binds to %d (%s) \n " , pubsock , pair , bits256_str ( str , utxo - > S . otherpubkey ) ) ;
LP_reserved_msg ( base , rel , utxo - > S . otherpubkey , jprint ( retjson , 0 ) ) ;
LP_broadcast_message ( LP_mypubsock , qp - > srccoin , qp - > destcoin , qp - > desthash , jprint ( retjson , 0 ) ) ;
free_json ( retjson ) ;
retval = 0 ;
} else printf ( " error launching swaploop \n " ) ;
} else printf ( " couldnt bind to any port %s \n " , pairstr ) ;
}
else
{
printf ( " dest %.8f vs required %.8f (%d %d %d %d %d) \n " , dstr ( qp - > destsatoshis ) , dstr ( price * ( utxo - > S . satoshis - qp - > txfee ) ) , bits256_nonz ( privkey ) ! = 0 , qp - > timestamp = = utxo - > T . swappending - LP_RESERVETIME , qp - > quotetime > = qp - > timestamp - 3 , qp - > quotetime < utxo - > T . swappending , bits256_cmp ( G . LP_mypub25519 , qp - > srchash ) = = 0 ) ;
}
if ( retval < 0 )
{
if ( pair > = 0 )
nn_close ( pair ) ;
LP_availableset ( utxo ) ;
} else LP_unavailableset ( utxo , utxo - > S . otherpubkey ) ;
//LP_butxo_swapfields(utxo);
return ( retval ) ;
}
struct LP_quoteinfo LP_Alicequery ;
double LP_Alicemaxprice ;
uint32_t Alice_expiration ;
char * LP_trade ( void * ctx , char * myipaddr , int32_t mypubsock , struct LP_quoteinfo * qp , double maxprice , int32_t timeout , int32_t duration )
{
struct LP_utxoinfo * aliceutxo ; double price ; //cJSON *bestitem=0; int32_t DEXselector=0; uint32_t expiration; double price; struct LP_pubkeyinfo *pubp; struct basilisk_swap *swap;
if ( ( aliceutxo = LP_utxopairfind ( 0 , qp - > desttxid , qp - > destvout , qp - > feetxid , qp - > feevout ) ) = = 0 )
{
char str [ 65 ] , str2 [ 65 ] ; printf ( " dest.(%s)/v%d fee.(%s)/v%d \n " , bits256_str ( str , qp - > desttxid ) , qp - > destvout , bits256_str ( str2 , qp - > feetxid ) , qp - > feevout ) ;
return ( clonestr ( " { \" error \" : \" cant find alice utxopair \" } " ) ) ;
}
price = 0. ;
LP_query ( ctx , myipaddr , mypubsock , " request " , qp ) ;
LP_Alicequery = * qp , LP_Alicemaxprice = maxprice , Alice_expiration = qp - > timestamp + timeout ;
return ( clonestr ( " { \" result \" : \" success \" } " ) ) ;
}
int32_t LP_quotecmp ( struct LP_quoteinfo * qp , struct LP_quoteinfo * qp2 )
{
if ( bits256_cmp ( qp - > srchash , qp2 - > srchash ) = = 0 & & bits256_cmp ( qp - > desthash , qp2 - > desthash ) = = 0 & & strcmp ( qp - > srccoin , qp2 - > srccoin ) = = 0 & & strcmp ( qp - > destcoin , qp2 - > destcoin ) = = 0 & & bits256_cmp ( qp - > desttxid , qp2 - > desttxid ) = = 0 & & qp - > destvout = = qp2 - > destvout & & bits256_cmp ( qp - > feetxid , qp2 - > feetxid ) = = 0 & & qp - > feevout = = qp2 - > feevout & & qp - > destsatoshis = = qp2 - > destsatoshis & & qp - > txfee > = qp2 - > txfee & & qp - > desttxfee = = qp2 - > desttxfee )
return ( 0 ) ;
else return ( - 1 ) ;
}
int32_t LP_alice_eligible ( )
{
if ( Alice_expiration ! = 0 & & time ( NULL ) > Alice_expiration )
{
printf ( " time expired for Alice_request \n " ) ;
memset ( & LP_Alicequery , 0 , sizeof ( LP_Alicequery ) ) ;
LP_Alicemaxprice = 0. ;
Alice_expiration = 0 ;
}
return ( Alice_expiration = = 0 | | time ( NULL ) < Alice_expiration ) ;
}
void LP_reserved ( void * ctx , char * myipaddr , int32_t mypubsock , struct LP_quoteinfo * qp )
{
double price = 0. , maxprice = LP_Alicemaxprice ;
if ( LP_alice_eligible ( ) > 0 & & LP_quotecmp ( qp , & LP_Alicequery ) = = 0 )
{
price = LP_pricecache ( qp , qp - > srccoin , qp - > destcoin , qp - > txid , qp - > vout ) ;
if ( LP_pricevalid ( price ) > 0 & & maxprice > SMALLVAL & & price < = maxprice )
{
memset ( & LP_Alicequery , 0 , sizeof ( LP_Alicequery ) ) ;
LP_Alicemaxprice = 0. ;
Alice_expiration = 0 ;
LP_query ( ctx , myipaddr , mypubsock , " connect " , qp ) ;
}
} else printf ( " reject reserved due to not eligible.%d or mismatched quote price %.8f vs maxprice %.8f \n " , LP_alice_eligible ( ) , price , maxprice ) ;
}
char * LP_connectedalice ( cJSON * argjson ) // alice
{
cJSON * retjson ; double bid , ask , price , qprice ; int32_t pairsock = - 1 ; char * pairstr ; int32_t DEXselector = 0 ; struct LP_utxoinfo * autxo , B , * butxo ; struct LP_quoteinfo Q ; struct basilisk_swap * swap ; struct iguana_info * coin ; //uint64_t value,value2;
if ( LP_quoteparse ( & Q , argjson ) < 0 )
clonestr ( " { \" error \" : \" cant parse quote \" } " ) ;
if ( bits256_cmp ( Q . desthash , G . LP_mypub25519 ) ! = 0 )
return ( clonestr ( " { \" result \" , \" update stats \" } " ) ) ;
printf ( " CONNECTED.(%s) numpending.%d \n " , jprint ( argjson , 0 ) , G . LP_pendingswaps ) ;
/*if ( LP_alice_eligible() == 0 || LP_quotecmp(&Q,&LP_Alicequery) != 0 )
{
printf ( " reject mismatched alice query \n " ) ;
return ( clonestr ( " { \" error \" , \" mismatched alice query \" } " ) ) ;
}
memset ( & LP_Alicequery , 0 , sizeof ( LP_Alicequery ) ) ;
LP_Alicemaxprice = 0. ;
Alice_expiration = 0 ; */
if ( ( autxo = LP_utxopairfind ( 0 , Q . desttxid , Q . destvout , Q . feetxid , Q . feevout ) ) = = 0 )
{
printf ( " cant find autxo \n " ) ;
return ( clonestr ( " { \" error \" : \" cant find autxo \" } " ) ) ;
}
if ( autxo - > S . swap ! = 0 )
return ( clonestr ( " { \" error \" : \" ignore duplicate swap \" } " ) ) ;
butxo = & B ;
memset ( butxo , 0 , sizeof ( * butxo ) ) ;
LP_abutxo_set ( 0 , butxo , & Q ) ;
/*if ( (butxo= LP_utxopairfind(1,Q.txid,Q.vout,Q.txid2,Q.vout2)) == 0 )
{
value = LP_txvalue ( Q . coinaddr , Q . srccoin , Q . txid , Q . vout ) ;
value2 = LP_txvalue ( Q . coinaddr , Q . srccoin , Q . txid2 , Q . vout2 ) ;
if ( value = = 0 | | value2 = = 0 )
{
printf ( " zero value %.8f or value2 %.8f \n " , dstr ( value ) , dstr ( value2 ) ) ;
return ( clonestr ( " { \" error \" : \" spent txid or txid2 for bob? \" } " ) ) ;
}
if ( ( butxo = LP_utxoadd ( 1 , Q . srccoin , Q . txid , Q . vout , value , Q . txid2 , Q . vout2 , value2 , Q . coinaddr , Q . srchash , LP_gui , 0 ) ) = = 0 )
{
printf ( " cant find or create butxo \n " ) ;
return ( clonestr ( " { \" error \" : \" cant find or create butxo \" } " ) ) ;
}
if ( value < Q . satoshis )
{
printf ( " butxo value %.8f less satoshis %.8f \n " , dstr ( value ) , dstr ( Q . satoshis ) ) ;
return ( clonestr ( " { \" error \" : \" butxo value less than satoshis \" } " ) ) ;
}
} */
if ( ( qprice = LP_quote_validate ( autxo , butxo , & Q , 0 ) ) < = SMALLVAL )
{
LP_availableset ( autxo ) ;
printf ( " quote validate error %.0f \n " , qprice ) ;
return ( clonestr ( " { \" error \" : \" quote validation error \" } " ) ) ;
}
if ( LP_myprice ( & bid , & ask , Q . srccoin , Q . destcoin ) < = SMALLVAL | | bid < = SMALLVAL )
{
printf ( " this node has no price for %s/%s (%.8f %.8f) \n " , Q . destcoin , Q . srccoin , bid , ask ) ;
LP_availableset ( autxo ) ;
return ( clonestr ( " { \" error \" : \" no price set \" } " ) ) ;
}
printf ( " %s/%s bid %.8f ask %.8f values %.8f %.8f \n " , Q . srccoin , Q . destcoin , bid , ask , dstr ( butxo - > payment . value ) , dstr ( butxo - > deposit . value ) ) ;
price = bid ;
if ( ( coin = LP_coinfind ( Q . destcoin ) ) = = 0 )
return ( clonestr ( " { \" error \" : \" cant get alicecoin \" } " ) ) ;
Q . privkey = LP_privkey ( Q . destaddr , coin - > taddr ) ;
if ( bits256_nonz ( Q . privkey ) ! = 0 ) //&& Q.quotetime >= Q.timestamp-3 )
{
retjson = cJSON_CreateObject ( ) ;
if ( ( pairstr = jstr ( argjson , " pair " ) ) = = 0 | | ( pairsock = nn_socket ( AF_SP , NN_PAIR ) ) < 0 )
jaddstr ( retjson , " error " , " couldnt create pairsock " ) ;
else if ( nn_connect ( pairsock , pairstr ) > = 0 )
{
//timeout = 1;
//nn_setsockopt(pairsock,NN_SOL_SOCKET,NN_SNDTIMEO,&timeout,sizeof(timeout));
//nn_setsockopt(pairsock,NN_SOL_SOCKET,NN_RCVTIMEO,&timeout,sizeof(timeout));
LP_requestinit ( & Q . R , Q . srchash , Q . desthash , Q . srccoin , Q . satoshis - 2 * Q . txfee , Q . destcoin , Q . destsatoshis - 2 * Q . desttxfee , Q . timestamp , Q . quotetime , DEXselector ) ;
swap = LP_swapinit ( 0 , 0 , Q . privkey , & Q . R , & Q ) ;
swap - > N . pair = pairsock ;
autxo - > S . swap = swap ;
swap - > utxo = autxo ;
printf ( " alice pairstr.(%s) pairsock.%d \n " , pairstr , pairsock ) ;
if ( OS_thread_create ( malloc ( sizeof ( pthread_t ) ) , NULL , ( void * ) LP_aliceloop , ( void * ) swap ) = = 0 )
{
jaddstr ( retjson , " result " , " success " ) ;
jadd ( retjson , " trade " , LP_quotejson ( & Q ) ) ;
jaddnum ( retjson , " requestid " , Q . R . requestid ) ;
jaddnum ( retjson , " quoteid " , Q . R . quoteid ) ;
} else jaddstr ( retjson , " error " , " couldnt aliceloop " ) ;
} else printf ( " connect error %s \n " , nn_strerror ( nn_errno ( ) ) ) ;
printf ( " connected result.(%s) \n " , jprint ( retjson , 0 ) ) ;
if ( jobj ( retjson , " error " ) ! = 0 )
LP_availableset ( autxo ) ;
return ( jprint ( retjson , 1 ) ) ;
}
else
{
LP_availableset ( autxo ) ;
printf ( " no privkey found coin.%s %s taddr.%u \n " , Q . destcoin , Q . destaddr , coin - > taddr ) ;
return ( clonestr ( " { \" error \" , \" no privkey \" } " ) ) ;
}
}
int32_t LP_listunspent_both ( char * symbol , char * coinaddr , int32_t fullflag )
{
int32_t i , v , height , n = 0 ; uint64_t value ; bits256 txid ; char buf [ 512 ] ; cJSON * array , * item ; struct iguana_info * coin = LP_coinfind ( symbol ) ;
if ( coin ! = 0 ) //&& (IAMLP != 0 || coin->inactive == 0) )
{
if ( coin - > electrum ! = 0 | | LP_address_ismine ( symbol , coinaddr ) < = 0 )
{
//printf("issue path electrum.%p\n",coin->electrum);
//if ( coin->electrum != 0 && (array= electrum_address_gethistory(symbol,coin->electrum,&array,coinaddr)) != 0 )
// free_json(array);
n = LP_listunspent_issue ( symbol , coinaddr , fullflag ) ;
}
else
{
//printf("my coin electrum.%p\n",coin->electrum);
sprintf ( buf , " [1, 99999999, [ \" %s \" ]] " , coinaddr ) ;
if ( ( array = bitcoin_json ( coin , " listunspent " , buf ) ) ! = 0 )
{
if ( ( n = cJSON_GetArraySize ( array ) ) > 0 )
{
for ( i = 0 ; i < n ; i + + )
{
item = jitem ( array , i ) ;
txid = jbits256 ( item , " txid " ) ;
v = jint ( item , " vout " ) ;
value = LP_value_extract ( item , 0 ) ;
height = LP_txheight ( coin , txid ) ;
//char str[65]; printf("LP_listunspent_both: %s/v%d ht.%d %.8f\n",bits256_str(str,txid),v,height,dstr(value));
LP_address_utxoadd ( coin , coinaddr , txid , v , value , height , - 1 ) ;
}
}
}
}
} //else printf("%s coin.%p inactive.%d\n",symbol,coin,coin!=0?coin->inactive:-1);
return ( n ) ;
}
char * LP_bestfit ( char * rel , double relvolume )
{
struct LP_utxoinfo * autxo ;
if ( relvolume < = 0. | | LP_priceinfofind ( rel ) = = 0 )
return ( clonestr ( " { \" error \" : \" invalid parameter \" } " ) ) ;
if ( ( autxo = LP_utxo_bestfit ( rel , SATOSHIDEN * relvolume ) ) = = 0 )
return ( clonestr ( " { \" error \" : \" cant find utxo that is big enough \" } " ) ) ;
return ( jprint ( LP_utxojson ( autxo ) , 1 ) ) ;
}
int32_t LP_aliceonly ( char * symbol )
{
if ( strcmp ( symbol , " GAME " ) = = 0 )
return ( 1 ) ;
else return ( 0 ) ;
}
int32_t LP_tradecommand ( void * ctx , char * myipaddr , int32_t pubsock , cJSON * argjson , uint8_t * data , int32_t datalen )
{
char * method , * msg , * retstr , str [ 65 ] ; int32_t DEXselector = 0 ; uint64_t value , value2 ; cJSON * retjson ; double qprice , price , bid , ask ; struct LP_utxoinfo A , B , * autxo , * butxo ; struct iguana_info * coin ; struct LP_address_utxo * utxos [ 1000 ] ; struct LP_quoteinfo Q ; int32_t retval = - 1 , max = ( int32_t ) ( sizeof ( utxos ) / sizeof ( * utxos ) ) ;
if ( ( method = jstr ( argjson , " method " ) ) ! = 0 & & ( strcmp ( method , " reserved " ) = = 0 | | strcmp ( method , " connected " ) = = 0 | | strcmp ( method , " request " ) = = 0 | | strcmp ( method , " connect " ) = = 0 ) )
{
// LP_checksig
LP_quoteparse ( & Q , argjson ) ;
LP_requestinit ( & Q . R , Q . srchash , Q . desthash , Q . srccoin , Q . satoshis - 2 * Q . txfee , Q . destcoin , Q . destsatoshis - 2 * Q . desttxfee , Q . timestamp , Q . quotetime , DEXselector ) ;
LP_tradecommand_log ( argjson ) ;
printf ( " LP_tradecommand: check received method %s \n " , method ) ;
retval = 1 ;
if ( strcmp ( method , " reserved " ) = = 0 )
{
if ( bits256_cmp ( G . LP_mypub25519 , Q . desthash ) = = 0 & & bits256_cmp ( G . LP_mypub25519 , Q . srchash ) ! = 0 & & LP_alice_eligible ( ) > 0 )
{
printf ( " alice %s received RESERVED.(%s) \n " , bits256_str ( str , G . LP_mypub25519 ) , jprint ( argjson , 0 ) ) ;
if ( ( retstr = LP_quotereceived ( argjson ) ) ! = 0 )
free ( retstr ) ;
LP_reserved ( ctx , myipaddr , pubsock , & Q ) ;
}
return ( retval ) ;
}
else if ( strcmp ( method , " connected " ) = = 0 )
{
if ( bits256_cmp ( G . LP_mypub25519 , Q . desthash ) = = 0 & & bits256_cmp ( G . LP_mypub25519 , Q . srchash ) ! = 0 )
{
printf ( " alice %s received CONNECTED.(%s) \n " , bits256_str ( str , G . LP_mypub25519 ) , jprint ( argjson , 0 ) ) ;
if ( ( retstr = LP_connectedalice ( argjson ) ) ! = 0 )
free ( retstr ) ;
}
return ( retval ) ;
}
if ( bits256_cmp ( G . LP_mypub25519 , Q . srchash ) = = 0 & & bits256_cmp ( G . LP_mypub25519 , Q . desthash ) ! = 0 )
{
if ( ( coin = LP_coinfind ( Q . srccoin ) ) = = 0 | | ( price = LP_myprice ( & bid , & ask , Q . srccoin , Q . destcoin ) ) < = SMALLVAL | | ask < = SMALLVAL )
{
printf ( " this node has no price for %s/%s \n " , Q . srccoin , Q . destcoin ) ;
return ( retval ) ;
}
if ( coin - > electrum ! = 0 )
{
printf ( " electrum can only be for alice \n " ) ;
return ( retval ) ;
}
if ( LP_aliceonly ( Q . srccoin ) > 0 )
{
printf ( " { \" error \" : \" GAME can only be alice coin \" } \n " ) ;
return ( retval ) ;
}
price = ask ;
autxo = & A ;
butxo = & B ;
memset ( autxo , 0 , sizeof ( * autxo ) ) ;
memset ( butxo , 0 , sizeof ( * butxo ) ) ;
LP_abutxo_set ( autxo , butxo , & Q ) ;
printf ( " utxopairfind \n " ) ;
if ( ( butxo = LP_utxopairfind ( 1 , Q . txid , Q . vout , Q . txid2 , Q . vout2 ) ) = = 0 )
butxo = & B ;
//LP_butxo_swapfields(butxo);
if ( strcmp ( method , " request " ) = = 0 )
{
char str [ 65 ] , str2 [ 65 ] ;
printf ( " request.(%s) \n " , jprint ( argjson , 0 ) ) ;
if ( 1 ) //LP_allocated(butxo->payment.txid,butxo->payment.vout) != 0 || LP_allocated(butxo->deposit.txid,butxo->deposit.vout) != 0 || (qprice= LP_quote_validate(autxo,butxo,&Q,1)) <= SMALLVAL )
{
printf ( " butxo.%p replace path %p %s, %p %s, %.8f \n " , butxo , LP_allocated ( butxo - > payment . txid , butxo - > payment . vout ) , bits256_str ( str , butxo - > payment . txid ) , LP_allocated ( butxo - > deposit . txid , butxo - > deposit . vout ) , bits256_str ( str2 , butxo - > deposit . txid ) , LP_quote_validate ( autxo , butxo , & Q , 1 ) ) ;
LP_listunspent_both ( Q . srccoin , Q . coinaddr , 0 ) ;
if ( ( butxo = LP_address_utxopair ( 1 , utxos , max , LP_coinfind ( Q . srccoin ) , Q . coinaddr , Q . txfee , dstr ( Q . destsatoshis ) , price , Q . desttxfee ) ) ! = 0 )
{
Q . txid = butxo - > payment . txid ;
Q . vout = butxo - > payment . vout ;
Q . txid2 = butxo - > deposit . txid ;
Q . vout2 = butxo - > deposit . vout ;
printf ( " set butxo.%p %s/v%d %s/v%d %.8f %.8f -> bsat %.8f asat %.8f \n " , butxo , bits256_str ( str , butxo - > payment . txid ) , butxo - > payment . vout , bits256_str ( str2 , butxo - > deposit . txid ) , butxo - > deposit . vout , dstr ( butxo - > payment . value ) , dstr ( butxo - > deposit . value ) , dstr ( butxo - > S . satoshis ) , dstr ( autxo - > S . satoshis ) ) ;
} else printf ( " cant find utxopair \n " ) ;
//LP_abutxo_set(0,butxo,&Q);
//LP_butxo_swapfields(butxo);
}
else
{
printf ( " other path %p %p %.8f \n " , LP_allocated ( butxo - > payment . txid , butxo - > payment . vout ) , LP_allocated ( butxo - > deposit . txid , butxo - > deposit . vout ) , LP_quote_validate ( autxo , butxo , & Q , 1 ) ) ;
value = LP_txvalue ( Q . coinaddr , Q . srccoin , Q . txid , Q . vout ) ;
value2 = LP_txvalue ( Q . coinaddr , Q . srccoin , Q . txid2 , Q . vout2 ) ;
if ( ( butxo = LP_utxoadd ( 1 , coin - > symbol , Q . txid , Q . vout , value , Q . txid2 , Q . vout2 , value2 , Q . coinaddr , G . LP_mypub25519 , G . gui , 0 ) ) = = 0 )
printf ( " couldnt create bob's utxopair \n " ) ;
else printf ( " created butxo.(%s %s) \ n " ,bits256_str(str,butxo->payment.txid),bits256_str(str2,butxo->deposit.txid)) ;
}
}
if ( butxo = = 0 | | butxo = = & B )
butxo = LP_utxopairfind ( 1 , Q . txid , Q . vout , Q . txid2 , Q . vout2 ) ;
if ( butxo = = 0 | | bits256_cmp ( Q . txid , butxo - > payment . txid ) ! = 0 | | bits256_cmp ( Q . txid2 , butxo - > deposit . txid ) ! = 0 )
{
printf ( " null butxo.%p case \n " , butxo ) ;
value = LP_txvalue ( Q . coinaddr , Q . srccoin , Q . txid , Q . vout ) ;
value2 = LP_txvalue ( Q . coinaddr , Q . srccoin , Q . txid2 , Q . vout2 ) ;
butxo = LP_utxoadd ( 1 , Q . srccoin , Q . txid , Q . vout , value , Q . txid2 , Q . vout2 , value2 , Q . coinaddr , Q . srchash , LP_gui , 0 ) ;
}
char str [ 65 ] , str2 [ 65 ] ; printf ( " butxo.%p (%s %s) TRADECOMMAND.(%s) \n " , butxo , butxo ! = 0 ? bits256_str ( str , butxo - > payment . txid ) : " " , butxo ! = 0 ? bits256_str ( str2 , butxo - > deposit . txid ) : " " , jprint ( argjson , 0 ) ) ;
if ( butxo = = 0 | | bits256_nonz ( butxo - > payment . txid ) = = 0 | | bits256_nonz ( butxo - > deposit . txid ) = = 0 | | butxo - > payment . vout < 0 | | butxo - > deposit . vout < 0 )
{
char str [ 65 ] , str2 [ 65 ] ; printf ( " couldnt find bob utxos for autxo %s/v%d %s/v%d %.8f -> %.8f \n " , bits256_str ( str , Q . txid ) , Q . vout , bits256_str ( str2 , Q . txid2 ) , Q . vout2 , dstr ( Q . satoshis ) , dstr ( Q . destsatoshis ) ) ;
return ( retval ) ;
}
if ( ( qprice = LP_quote_validate ( autxo , butxo , & Q , 1 ) ) < = SMALLVAL )
{
printf ( " quote validate error %.0f \n " , qprice ) ;
return ( - 3 ) ;
}
if ( qprice < ( price - 0.00000001 ) * 0.9999 )
{
printf ( " (%.8f %.8f) quote price %.8f too low vs %.8f for %s/%s \n " , bid , ask , qprice , price , Q . srccoin , Q . destcoin ) ;
return ( - 4 ) ;
}
if ( butxo - > S . swap = = 0 & & time ( NULL ) > butxo - > T . swappending )
butxo - > T . swappending = 0 ;
if ( strcmp ( method , " request " ) = = 0 ) // bob needs apayment + fee tx's
{
if ( LP_isavailable ( butxo ) > 0 )
{
autxo - > T . swappending = butxo - > T . swappending = Q . timestamp + LP_RESERVETIME ;
retjson = LP_quotejson ( & Q ) ;
butxo - > S . otherpubkey = jbits256 ( argjson , " desthash " ) ;
LP_unavailableset ( butxo , butxo - > S . otherpubkey ) ;
jaddnum ( retjson , " quotetime " , juint ( argjson , " quotetime " ) ) ;
jaddnum ( retjson , " pending " , butxo - > T . swappending ) ;
jaddbits256 ( retjson , " desthash " , butxo - > S . otherpubkey ) ;
jaddbits256 ( retjson , " pubkey " , butxo - > S . otherpubkey ) ;
jaddstr ( retjson , " method " , " reserved " ) ;
msg = jprint ( retjson , 0 ) ;
butxo - > T . lasttime = ( uint32_t ) time ( NULL ) ;
printf ( " return after queued RESERVED: set swappending.%u accept qprice %.8f, min %.8f \n (%s) \n " , butxo - > T . swappending , qprice , price , msg ) ;
// LP_addsig
//msg2 = clonestr(msg);
LP_reserved_msg ( Q . srccoin , Q . destcoin , butxo - > S . otherpubkey , msg ) ;
LP_broadcast_message ( LP_mypubsock , Q . srccoin , Q . destcoin , Q . desthash , jprint ( retjson , 0 ) ) ;
free_json ( retjson ) ;
return ( retval ) ;
} else printf ( " warning swappending.%u swap.%p \n " , butxo - > T . swappending , butxo - > S . swap ) ;
}
else if ( strcmp ( method , " connect " ) = = 0 ) // bob
{
retval = 4 ;
if ( butxo - > S . swap = = 0 & & butxo - > T . swappending ! = 0 )
{
// validate SPV alice
LP_connectstartbob ( ctx , pubsock , butxo , argjson , Q . srccoin , Q . destcoin , qprice , & Q ) ;
//LP_butxo_swapfields_set(butxo);
return ( retval ) ;
}
else printf ( " pend.%u swap %p when connect came in (%s) \ n " ,butxo->T.swappending,butxo->S.swap,jprint(argjson,0)) ;
}
//LP_butxo_swapfields_set(butxo);
}
}
return ( retval ) ;
}
struct LP_utxoinfo * LP_ordermatch_iter ( struct LP_address_utxo * * utxos , int32_t max , double * ordermatchpricep , int64_t * bestsatoshisp , int64_t * bestdestsatoshisp , struct iguana_info * basecoin , char * coinaddr , uint64_t asatoshis , double price , uint64_t txfee , uint64_t desttxfee , bits256 pubkey , char * gui )
{
uint64_t basesatoshis ; struct LP_utxoinfo * bestutxo ;
basesatoshis = LP_basesatoshis ( dstr ( asatoshis ) , price , txfee , desttxfee ) ;
if ( basesatoshis ! = 0 & & ( bestutxo = LP_address_utxopair ( 0 , utxos , max , basecoin , coinaddr , txfee , dstr ( basesatoshis ) * price , price , desttxfee ) ) ! = 0 )
{
bestutxo - > pubkey = pubkey ;
safecopy ( bestutxo - > gui , gui , sizeof ( bestutxo - > gui ) ) ;
* bestsatoshisp = basesatoshis ;
* ordermatchpricep = price ;
* bestdestsatoshisp = asatoshis ;
return ( bestutxo ) ;
}
return ( 0 ) ;
}
struct LP_utxoinfo * LP_buyutxo ( double * ordermatchpricep , int64_t * bestsatoshisp , int64_t * bestdestsatoshisp , struct LP_utxoinfo * autxo , char * base , double maxprice , int32_t duration , uint64_t txfee , uint64_t desttxfee , char * gui , bits256 * avoids , int32_t numavoids )
{
bits256 pubkey ; char * obookstr , coinaddr [ 64 ] ; cJSON * orderbook , * asks , * item ; int32_t maxiters , i , j , numasks , max = 10000 ; struct LP_address_utxo * * utxos ; double price ; struct LP_pubkeyinfo * pubp ; uint64_t asatoshis ; struct iguana_info * basecoin ; struct LP_utxoinfo * bestutxo = 0 ;
maxiters = 100 ;
* ordermatchpricep = 0. ;
* bestsatoshisp = * bestdestsatoshisp = 0 ;
basecoin = LP_coinfind ( base ) ;
if ( duration < = 0 )
duration = LP_ORDERBOOK_DURATION ;
if ( maxprice < = 0. | | LP_priceinfofind ( base ) = = 0 | | basecoin = = 0 )
return ( 0 ) ;
utxos = calloc ( max , sizeof ( * utxos ) ) ;
LP_txfees ( & txfee , & desttxfee , base , autxo - > coin ) ;
printf ( " LP_buyutxo maxprice %.8f relvol %.8f %s/%s %.8f %.8f \n " , maxprice , dstr ( autxo - > S . satoshis ) , base , autxo - > coin , dstr ( txfee ) , dstr ( desttxfee ) ) ;
if ( ( obookstr = LP_orderbook ( base , autxo - > coin , duration ) ) ! = 0 )
{
if ( ( orderbook = cJSON_Parse ( obookstr ) ) ! = 0 )
{
if ( ( asks = jarray ( & numasks , orderbook , " asks " ) ) ! = 0 )
{
for ( i = 0 ; i < numasks ; i + + )
{
item = jitem ( asks , i ) ;
price = jdouble ( item , " price " ) ;
price * = 1.005 ;
pubkey = jbits256 ( item , " pubkey " ) ;
//printf("[%d/%d] %s pubcmp %d price %.8f vs maxprice %.8f\n",i,numasks,jprint(item,0),bits256_cmp(pubkey,G.LP_mypub25519),price,maxprice);
if ( LP_pricevalid ( price ) > 0 & & price < = maxprice )
{
for ( j = 0 ; j < numavoids ; j + + )
if ( bits256_cmp ( pubkey , avoids [ j ] ) = = 0 )
break ;
if ( j ! = numavoids )
continue ;
if ( bits256_cmp ( pubkey , G . LP_mypub25519 ) ! = 0 & & ( pubp = LP_pubkeyadd ( pubkey ) ) ! = 0 )
{
bitcoin_address ( coinaddr , basecoin - > taddr , basecoin - > pubtype , pubp - > rmd160 , sizeof ( pubp - > rmd160 ) ) ;
asatoshis = autxo - > S . satoshis ;
/*if ( basecoin->electrum != 0 )
{
price * = 1.01 ;
* ordermatchpricep = price ;
* bestsatoshisp = LP_basesatoshis ( dstr ( asatoshis ) , price , txfee , desttxfee ) ;
* bestdestsatoshisp = asatoshis ;
}
else */
{
LP_listunspent_query ( base , coinaddr ) ;
LP_listunspent_both ( base , coinaddr , 1 ) ;
for ( j = 0 ; j < maxiters ; j + + )
{
if ( ( bestutxo = LP_ordermatch_iter ( utxos , max , ordermatchpricep , bestsatoshisp , bestdestsatoshisp , basecoin , coinaddr , asatoshis , price , txfee , desttxfee , pubp - > pubkey , gui ) ) ! = 0 )
{
printf ( " j.%d/%d ordermatch %.8f best satoshis %.8f destsatoshis %.8f txfees (%.8f %.8f) \n " , j , maxiters , price , dstr ( * bestsatoshisp ) , dstr ( * bestdestsatoshisp ) , dstr ( txfee ) , dstr ( desttxfee ) ) ;
break ;
}
asatoshis = ( asatoshis / 64 ) * 63 ;
}
if ( j < maxiters )
break ;
}
} else printf ( " self trading or blacklisted peer \n " ) ;
}
else
{
if ( i = = 0 )
printf ( " too expensive maxprice %.8f vs %.8f \n " , maxprice , price ) ;
break ;
}
}
}
free_json ( orderbook ) ;
}
free ( obookstr ) ;
}
free ( utxos ) ;
if ( * ordermatchpricep = = 0. | | * bestdestsatoshisp = = 0 )
return ( 0 ) ;
int32_t changed ;
LP_mypriceset ( & changed , autxo - > coin , base , 1. / * ordermatchpricep ) ;
return ( bestutxo ) ;
}
char * LP_autobuy ( void * ctx , char * myipaddr , int32_t mypubsock , char * base , char * rel , double maxprice , double relvolume , int32_t timeout , int32_t duration , char * gui , uint32_t nonce )
{
uint64_t desttxfee , txfee ; uint32_t lastnonce ; int32_t i , maxiters , numpubs = 0 ; int64_t bestsatoshis = 0 , destsatoshis , bestdestsatoshis = 0 ; struct iguana_info * basecoin , * relcoin ; struct LP_utxoinfo * autxo , * bestutxo = 0 ; double qprice , ordermatchprice = 0. ; struct LP_quoteinfo Q ; bits256 pubkeys [ 100 ] ;
basecoin = LP_coinfind ( base ) ;
relcoin = LP_coinfind ( rel ) ;
if ( basecoin = = 0 | | basecoin - > inactive ! = 0 | | relcoin = = 0 | | relcoin - > inactive ! = 0 )
return ( clonestr ( " { \" error \" : \" base or rel not found or inactive \" } " ) ) ;
if ( LP_aliceonly ( base ) > 0 )
return ( clonestr ( " { \" error \" : \" GAME can only be alice coin \" } " ) ) ;
printf ( " LP_autobuy %s/%s price %.8f vol %.8f nonce %u \n " , base , rel , maxprice , relvolume , nonce ) ;
if ( ( lastnonce = LP_lastnonce ) ! = 0 & & nonce < = lastnonce )
{
printf ( " nonce.%u not bigger than lastnonce.%u \n " , nonce , lastnonce ) ;
return ( clonestr ( " { \" error \" : \" invalid nonce \" } " ) ) ;
}
LP_lastnonce = nonce ;
if ( duration < = 0 )
duration = LP_ORDERBOOK_DURATION ;
if ( timeout < = 0 )
timeout = LP_AUTOTRADE_TIMEOUT ;
if ( basecoin - > electrum ! = 0 & & relcoin - > electrum ! = 0 )
{
if ( timeout < 3 * LP_AUTOTRADE_TIMEOUT )
timeout = 3 * LP_AUTOTRADE_TIMEOUT ;
}
else if ( basecoin - > electrum ! = 0 | | relcoin - > electrum ! = 0 )
{
if ( timeout < 2 * LP_AUTOTRADE_TIMEOUT )
timeout = 2 * LP_AUTOTRADE_TIMEOUT ;
}
if ( time ( NULL ) < Alice_expiration )
return ( clonestr ( " { \" error \" : \" only one pending request at a time \" } " ) ) ;
else
{
Alice_expiration = 0 ;
memset ( & LP_Alicequery , 0 , sizeof ( LP_Alicequery ) ) ;
LP_Alicemaxprice = 0. ;
}
if ( maxprice < = 0. | | relvolume < = 0. | | LP_priceinfofind ( base ) = = 0 | | LP_priceinfofind ( rel ) = = 0 )
return ( clonestr ( " { \" error \" : \" invalid parameter \" } " ) ) ;
if ( strcmp ( " BTC " , rel ) = = 0 )
maxprice * = 1.01 ;
else maxprice * = 1.001 ;
memset ( pubkeys , 0 , sizeof ( pubkeys ) ) ;
LP_txfees ( & txfee , & desttxfee , base , rel ) ;
destsatoshis = SATOSHIDEN * relvolume + 2 * desttxfee ;
if ( ( autxo = LP_utxo_bestfit ( rel , destsatoshis ) ) = = 0 )
return ( clonestr ( " { \" error \" : \" cant find alice utxo that is big enough \" } " ) ) ;
if ( destsatoshis < autxo - > S . satoshis )
autxo - > S . satoshis = destsatoshis ;
while ( 1 )
{
if ( ( bestutxo = LP_buyutxo ( & ordermatchprice , & bestsatoshis , & bestdestsatoshis , autxo , base , maxprice , duration , txfee , desttxfee , gui , pubkeys , numpubs ) ) = = 0 | | ordermatchprice = = 0. | | bestdestsatoshis = = 0 )
{
printf ( " bestutxo.%p ordermatchprice %.8f bestdestsatoshis %.8f \n " , bestutxo , ordermatchprice , dstr ( bestdestsatoshis ) ) ;
return ( clonestr ( " { \" error \" : \" cant find ordermatch utxo, need to change relvolume to be closer to available \" } " ) ) ;
}
pubkeys [ numpubs + + ] = bestutxo - > pubkey ;
if ( LP_quoteinfoinit ( & Q , bestutxo , rel , ordermatchprice , bestsatoshis , bestdestsatoshis ) < 0 )
return ( clonestr ( " { \" error \" : \" cant set ordermatch quote \" } " ) ) ;
if ( LP_quotedestinfo ( & Q , autxo - > payment . txid , autxo - > payment . vout , autxo - > fee . txid , autxo - > fee . vout , G . LP_mypub25519 , autxo - > coinaddr ) < 0 )
return ( clonestr ( " { \" error \" : \" cant set ordermatch quote info \" } " ) ) ;
maxiters = 200 ;
qprice = 1. / SMALLVAL ;
for ( i = 0 ; i < maxiters ; i + + )
{
if ( ( qprice = LP_quote_validate ( autxo , 0 , & Q , 0 ) ) < = SMALLVAL )
{
printf ( " quote validate error %.0f \n " , qprice ) ;
return ( clonestr ( " { \" error \" : \" quote validate error \" } " ) ) ;
}
if ( qprice / ordermatchprice < 1. + SMALLVAL )
{
printf ( " i.%d/%d qprice %.8f < ordermatchprice %.8f \n " , i , maxiters , qprice , ordermatchprice ) ;
if ( strcmp ( " BTC " , Q . destcoin ) = = 0 | | strcmp ( " BTC " , Q . srccoin ) = = 0 )
Q . satoshis * = 0.999 ;
else Q . satoshis * = 0.9999 ;
} else break ;
}
if ( i = = maxiters | | qprice > maxprice )
{
printf ( " i.%d maxiters.%d qprice %.8f vs maxprice %.8f, no acceptable quote for this pubkey \n " , i , maxiters , dstr ( qprice ) , dstr ( maxprice ) ) ;
continue ;
}
break ;
}
//printf("do quote.(%s)\n",jprint(LP_quotejson(&Q),1));
return ( LP_trade ( ctx , myipaddr , mypubsock , & Q , maxprice , timeout , duration ) ) ;
}