/******************************************************************************
* 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_remember.c
// marketmaker
//
void basilisk_dontforget_userdata ( char * userdataname , FILE * fp , uint8_t * script , int32_t scriptlen )
{
int32_t i ; char scriptstr [ 513 ] ;
if ( scriptlen ! = 0 )
{
for ( i = 0 ; i < scriptlen ; i + + )
sprintf ( & scriptstr [ i < < 1 ] , " %02x " , script [ i ] ) ;
scriptstr [ i < < 1 ] = 0 ;
fprintf ( fp , " \" , \" %s \" : \" %s \" " , userdataname , scriptstr ) ;
}
}
void basilisk_dontforget ( struct basilisk_swap * swap , struct basilisk_rawtx * rawtx , int32_t locktime , bits256 triggertxid )
{
char zeroes [ 32 ] , fname [ 512 ] , str [ 65 ] , coinaddr [ 64 ] , secretAmstr [ 41 ] , secretAm256str [ 65 ] , secretBnstr [ 41 ] , secretBn256str [ 65 ] ; FILE * fp ; int32_t i , len ; uint8_t redeemscript [ 256 ] , script [ 256 ] ;
sprintf ( fname , " %s/SWAPS/%u-%u.%s " , GLOBAL_DBDIR , swap - > I . req . requestid , swap - > I . req . quoteid , rawtx - > name ) , OS_compatible_path ( fname ) ;
coinaddr [ 0 ] = secretAmstr [ 0 ] = secretAm256str [ 0 ] = secretBnstr [ 0 ] = secretBn256str [ 0 ] = 0 ;
memset ( zeroes , 0 , sizeof ( zeroes ) ) ;
if ( rawtx ! = 0 & & ( fp = fopen ( fname , " wb " ) ) ! = 0 )
{
fprintf ( fp , " { \" name \" : \" %s \" , \" coin \" : \" %s \" " , rawtx - > name , rawtx - > coin - > symbol ) ;
if ( rawtx - > I . datalen > 0 )
{
fprintf ( fp , " , \" tx \" : \" " ) ;
for ( i = 0 ; i < rawtx - > I . datalen ; i + + )
fprintf ( fp , " %02x " , rawtx - > txbytes [ i ] ) ;
fprintf ( fp , " \" , \" txid \" : \" %s \" " , bits256_str ( str , bits256_doublesha256 ( 0 , rawtx - > txbytes , rawtx - > I . datalen ) ) ) ;
if ( rawtx = = & swap - > bobdeposit | | rawtx = = & swap - > bobpayment )
{
LP_swap_coinaddr ( & swap - > bobcoin , coinaddr , 0 , rawtx - > txbytes , rawtx - > I . datalen , 0 ) ;
if ( coinaddr [ 0 ] ! = 0 )
{
LP_importaddress ( swap - > bobcoin . symbol , coinaddr ) ;
if ( rawtx = = & swap - > bobdeposit )
safecopy ( swap - > Bdeposit , coinaddr , sizeof ( swap - > Bdeposit ) ) ;
else safecopy ( swap - > Bpayment , coinaddr , sizeof ( swap - > Bpayment ) ) ;
}
}
}
if ( swap - > Bdeposit [ 0 ] ! = 0 )
fprintf ( fp , " , \" %s \" : \" %s \" " , " Bdeposit " , swap - > Bdeposit ) ;
if ( swap - > Bpayment [ 0 ] ! = 0 )
fprintf ( fp , " , \" %s \" : \" %s \" " , " Bpayment " , swap - > Bpayment ) ;
fprintf ( fp , " , \" expiration \" :%u " , swap - > I . expiration ) ;
fprintf ( fp , " , \" iambob \" :%d " , swap - > I . iambob ) ;
fprintf ( fp , " , \" bobcoin \" : \" %s \" " , swap - > bobcoin . symbol ) ;
fprintf ( fp , " , \" alicecoin \" : \" %s \" " , swap - > alicecoin . symbol ) ;
fprintf ( fp , " , \" lock \" :%u " , locktime ) ;
fprintf ( fp , " , \" amount \" :%.8f " , dstr ( rawtx - > I . amount ) ) ;
if ( bits256_nonz ( triggertxid ) ! = 0 )
fprintf ( fp , " , \" trigger \" : \" %s \" " , bits256_str ( str , triggertxid ) ) ;
if ( bits256_nonz ( swap - > I . pubAm ) ! = 0 & & bits256_nonz ( swap - > I . pubBn ) ! = 0 )
{
basilisk_alicescript ( redeemscript , & len , script , 0 , coinaddr , swap - > alicecoin . taddr , swap - > alicecoin . p2shtype , swap - > I . pubAm , swap - > I . pubBn ) ;
LP_importaddress ( swap - > alicecoin . symbol , coinaddr ) ;
fprintf ( fp , " , \" Apayment \" : \" %s \" " , coinaddr ) ;
}
if ( rawtx - > I . redeemlen > 0 )
{
char scriptstr [ 2049 ] ;
init_hexbytes_noT ( scriptstr , rawtx - > redeemscript , rawtx - > I . redeemlen ) ;
fprintf ( fp , " , \" redeem \" : \" %s \" " , scriptstr ) ;
}
/*basilisk_dontforget_userdata("Aclaim",fp,swap->I.userdata_aliceclaim,swap->I.userdata_aliceclaimlen);
basilisk_dontforget_userdata ( " Areclaim " , fp , swap - > I . userdata_alicereclaim , swap - > I . userdata_alicereclaimlen ) ;
basilisk_dontforget_userdata ( " Aspend " , fp , swap - > I . userdata_alicespend , swap - > I . userdata_alicespendlen ) ;
basilisk_dontforget_userdata ( " Bspend " , fp , swap - > I . userdata_bobspend , swap - > I . userdata_bobspendlen ) ;
basilisk_dontforget_userdata ( " Breclaim " , fp , swap - > I . userdata_bobreclaim , swap - > I . userdata_bobreclaimlen ) ;
basilisk_dontforget_userdata ( " Brefund " , fp , swap - > I . userdata_bobrefund , swap - > I . userdata_bobrefundlen ) ; */
fprintf ( fp , " } \n " ) ;
fclose ( fp ) ;
}
sprintf ( fname , " %s/SWAPS/%u-%u " , GLOBAL_DBDIR , swap - > I . req . requestid , swap - > I . req . quoteid ) , OS_compatible_path ( fname ) ;
if ( ( fp = fopen ( fname , " wb " ) ) ! = 0 )
{
fprintf ( fp , " { \" src \" : \" %s \" , \" srcamount \" :%.8f, \" dest \" : \" %s \" , \" destamount \" :%.8f, \" requestid \" :%u, \" quoteid \" :%u, \" iambob \" :%d, \" state \" :%u, \" otherstate \" :%u, \" expiration \" :%u, \" dlocktime \" :%u, \" plocktime \" :%u, \" Atxfee \" :%llu, \" Btxfee \" :%llu " , swap - > I . req . src , dstr ( swap - > I . req . srcamount ) , swap - > I . req . dest , dstr ( swap - > I . req . destamount ) , swap - > I . req . requestid , swap - > I . req . quoteid , swap - > I . iambob , swap - > I . statebits , swap - > I . otherstatebits , swap - > I . expiration , swap - > bobdeposit . I . locktime , swap - > bobpayment . I . locktime , ( long long ) swap - > I . Atxfee , ( long long ) swap - > I . Btxfee ) ;
if ( memcmp ( zeroes , swap - > I . secretAm , 20 ) ! = 0 )
{
init_hexbytes_noT ( secretAmstr , swap - > I . secretAm , 20 ) ;
fprintf ( fp , " , \" secretAm \" : \" %s \" " , secretAmstr ) ;
}
if ( memcmp ( zeroes , swap - > I . secretAm256 , 32 ) ! = 0 )
{
init_hexbytes_noT ( secretAm256str , swap - > I . secretAm256 , 32 ) ;
fprintf ( fp , " , \" secretAm256 \" : \" %s \" " , secretAm256str ) ;
}
if ( memcmp ( zeroes , swap - > I . secretBn , 20 ) ! = 0 )
{
init_hexbytes_noT ( secretBnstr , swap - > I . secretBn , 20 ) ;
fprintf ( fp , " , \" secretBn \" : \" %s \" " , secretBnstr ) ;
}
if ( memcmp ( zeroes , swap - > I . secretBn256 , 32 ) ! = 0 )
{
init_hexbytes_noT ( secretBn256str , swap - > I . secretBn256 , 32 ) ;
fprintf ( fp , " , \" secretBn256 \" : \" %s \" " , secretBn256str ) ;
}
for ( i = 0 ; i < 2 ; i + + )
if ( bits256_nonz ( swap - > I . myprivs [ i ] ) ! = 0 )
fprintf ( fp , " , \" myprivs%d \" : \" %s \" " , i , bits256_str ( str , swap - > I . myprivs [ i ] ) ) ;
if ( bits256_nonz ( swap - > I . privAm ) ! = 0 )
fprintf ( fp , " , \" privAm \" : \" %s \" " , bits256_str ( str , swap - > I . privAm ) ) ;
if ( bits256_nonz ( swap - > I . privBn ) ! = 0 )
fprintf ( fp , " , \" privBn \" : \" %s \" " , bits256_str ( str , swap - > I . privBn ) ) ;
if ( bits256_nonz ( swap - > I . pubA0 ) ! = 0 )
fprintf ( fp , " , \" pubA0 \" : \" %s \" " , bits256_str ( str , swap - > I . pubA0 ) ) ;
if ( bits256_nonz ( swap - > I . pubB0 ) ! = 0 )
fprintf ( fp , " , \" pubB0 \" : \" %s \" " , bits256_str ( str , swap - > I . pubB0 ) ) ;
if ( bits256_nonz ( swap - > I . pubB1 ) ! = 0 )
fprintf ( fp , " , \" pubB1 \" : \" %s \" " , bits256_str ( str , swap - > I . pubB1 ) ) ;
if ( bits256_nonz ( swap - > bobdeposit . I . actualtxid ) ! = 0 )
fprintf ( fp , " , \" Bdeposit \" : \" %s \" " , bits256_str ( str , swap - > bobdeposit . I . actualtxid ) ) ;
if ( bits256_nonz ( swap - > bobrefund . I . actualtxid ) ! = 0 )
fprintf ( fp , " , \" Brefund \" : \" %s \" " , bits256_str ( str , swap - > bobrefund . I . actualtxid ) ) ;
if ( bits256_nonz ( swap - > aliceclaim . I . actualtxid ) ! = 0 )
fprintf ( fp , " , \" Aclaim \" : \" %s \" " , bits256_str ( str , swap - > aliceclaim . I . actualtxid ) ) ;
if ( bits256_nonz ( swap - > bobpayment . I . actualtxid ) ! = 0 )
fprintf ( fp , " , \" Bpayment \" : \" %s \" " , bits256_str ( str , swap - > bobpayment . I . actualtxid ) ) ;
if ( bits256_nonz ( swap - > alicespend . I . actualtxid ) ! = 0 )
fprintf ( fp , " , \" Aspend \" : \" %s \" " , bits256_str ( str , swap - > alicespend . I . actualtxid ) ) ;
if ( bits256_nonz ( swap - > bobreclaim . I . actualtxid ) ! = 0 )
fprintf ( fp , " , \" Breclaim \" : \" %s \" " , bits256_str ( str , swap - > bobreclaim . I . actualtxid ) ) ;
if ( bits256_nonz ( swap - > alicepayment . I . actualtxid ) ! = 0 )
fprintf ( fp , " , \" Apayment \" : \" %s \" " , bits256_str ( str , swap - > alicepayment . I . actualtxid ) ) ;
if ( bits256_nonz ( swap - > bobspend . I . actualtxid ) ! = 0 )
fprintf ( fp , " , \" Bspend \" : \" %s \" " , bits256_str ( str , swap - > bobspend . I . actualtxid ) ) ;
if ( bits256_nonz ( swap - > alicereclaim . I . actualtxid ) ! = 0 )
fprintf ( fp , " , \" Areclaim \" : \" %s \" " , bits256_str ( str , swap - > alicereclaim . I . actualtxid ) ) ;
if ( bits256_nonz ( swap - > otherfee . I . actualtxid ) ! = 0 )
fprintf ( fp , " , \" otherfee \" : \" %s \" " , bits256_str ( str , swap - > otherfee . I . actualtxid ) ) ;
if ( bits256_nonz ( swap - > myfee . I . actualtxid ) ! = 0 )
fprintf ( fp , " , \" myfee \" : \" %s \" " , bits256_str ( str , swap - > myfee . I . actualtxid ) ) ;
fprintf ( fp , " , \" other33 \" : \" " ) ;
for ( i = 0 ; i < 33 ; i + + )
fprintf ( fp , " %02x " , swap - > persistent_other33 [ i ] ) ;
fprintf ( fp , " \" , \" dest33 \" : \" " ) ;
for ( i = 0 ; i < 33 ; i + + )
fprintf ( fp , " %02x " , swap - > persistent_pubkey33 [ i ] ) ;
fprintf ( fp , " \" } \n " ) ;
fclose ( fp ) ;
}
}
void basilisk_dontforget_update ( struct basilisk_swap * swap , struct basilisk_rawtx * rawtx )
{
bits256 triggertxid ;
memset ( triggertxid . bytes , 0 , sizeof ( triggertxid ) ) ;
if ( rawtx = = 0 )
{
basilisk_dontforget ( swap , 0 , 0 , triggertxid ) ;
return ;
}
if ( rawtx = = & swap - > myfee )
basilisk_dontforget ( swap , & swap - > myfee , 0 , triggertxid ) ;
else if ( rawtx = = & swap - > otherfee )
basilisk_dontforget ( swap , & swap - > otherfee , 0 , triggertxid ) ;
else if ( rawtx = = & swap - > bobdeposit )
{
basilisk_dontforget ( swap , & swap - > bobdeposit , 0 , triggertxid ) ;
basilisk_dontforget ( swap , & swap - > bobrefund , swap - > bobdeposit . I . locktime , triggertxid ) ;
}
else if ( rawtx = = & swap - > bobrefund )
basilisk_dontforget ( swap , & swap - > bobrefund , swap - > bobdeposit . I . locktime , triggertxid ) ;
else if ( rawtx = = & swap - > aliceclaim )
{
basilisk_dontforget ( swap , & swap - > bobrefund , 0 , triggertxid ) ;
basilisk_dontforget ( swap , & swap - > aliceclaim , 0 , swap - > bobrefund . I . actualtxid ) ;
}
else if ( rawtx = = & swap - > alicepayment )
{
basilisk_dontforget ( swap , & swap - > alicepayment , 0 , swap - > bobdeposit . I . actualtxid ) ;
}
else if ( rawtx = = & swap - > bobspend )
{
basilisk_dontforget ( swap , & swap - > alicepayment , 0 , swap - > bobdeposit . I . actualtxid ) ;
basilisk_dontforget ( swap , & swap - > bobspend , 0 , swap - > alicepayment . I . actualtxid ) ;
}
else if ( rawtx = = & swap - > alicereclaim )
{
basilisk_dontforget ( swap , & swap - > alicepayment , 0 , swap - > bobdeposit . I . actualtxid ) ;
basilisk_dontforget ( swap , & swap - > alicereclaim , 0 , swap - > bobrefund . I . actualtxid ) ;
}
else if ( rawtx = = & swap - > bobpayment )
{
basilisk_dontforget ( swap , & swap - > bobpayment , 0 , triggertxid ) ;
basilisk_dontforget ( swap , & swap - > bobreclaim , swap - > bobpayment . I . locktime , triggertxid ) ;
}
else if ( rawtx = = & swap - > alicespend )
{
basilisk_dontforget ( swap , & swap - > bobpayment , 0 , triggertxid ) ;
basilisk_dontforget ( swap , & swap - > alicespend , 0 , triggertxid ) ;
}
else if ( rawtx = = & swap - > bobreclaim )
basilisk_dontforget ( swap , & swap - > bobreclaim , swap - > bobpayment . I . locktime , triggertxid ) ;
}
bits256 basilisk_swap_privbob_extract ( char * symbol , bits256 spendtxid , int32_t vini , int32_t revflag )
{
bits256 privkey ; int32_t i , scriptlen , siglen ; uint8_t script [ 1024 ] ; // from Bob refund of Bob deposit
memset ( & privkey , 0 , sizeof ( privkey ) ) ;
if ( ( scriptlen = basilisk_swap_getsigscript ( symbol , script , ( int32_t ) sizeof ( script ) , spendtxid , vini ) ) > 0 )
{
siglen = script [ 0 ] ;
for ( i = 0 ; i < 32 ; i + + )
{
if ( revflag ! = 0 )
privkey . bytes [ 31 - i ] = script [ siglen + 2 + i ] ;
else privkey . bytes [ i ] = script [ siglen + 2 + i ] ;
}
char str [ 65 ] ; printf ( " extracted privbob.(%s) \n " , bits256_str ( str , privkey ) ) ;
}
return ( privkey ) ;
}
bits256 basilisk_swap_privBn_extract ( bits256 * bobrefundp , char * bobcoin , bits256 bobdeposit , bits256 privBn )
{
char destaddr [ 64 ] ;
if ( bits256_nonz ( privBn ) = = 0 )
{
if ( bits256_nonz ( bobdeposit ) ! = 0 )
* bobrefundp = LP_swap_spendtxid ( bobcoin , destaddr , bobdeposit , 0 ) ;
if ( bits256_nonz ( * bobrefundp ) ! = 0 )
privBn = basilisk_swap_privbob_extract ( bobcoin , * bobrefundp , 0 , 0 ) ;
}
return ( privBn ) ;
}
bits256 basilisk_swap_spendupdate ( int32_t iambob , char * symbol , char * spentaddr , int32_t * sentflags , bits256 * txids , int32_t utxoind , int32_t alicespent , int32_t bobspent , int32_t vout , char * aliceaddr , char * bobaddr , char * Adest , char * dest )
{
bits256 spendtxid , txid ; char destaddr [ 64 ] , str [ 65 ] ; struct iguana_info * coin ; cJSON * histobj ;
if ( ( coin = LP_coinfind ( symbol ) ) ! = 0 & & coin - > electrum ! = 0 )
{
if ( ( histobj = electrum_address_gethistory ( symbol , coin - > electrum , & histobj , spentaddr ) ) ! = 0 )
{
//printf("processed history.(%s)\n",jprint(histobj,0));
free_json ( histobj ) ;
}
}
txid = txids [ utxoind ] ;
memset ( & spendtxid , 0 , sizeof ( spendtxid ) ) ;
if ( bits256_nonz ( txid ) ! = 0 )
{
destaddr [ 0 ] = 0 ;
spendtxid = LP_swap_spendtxid ( symbol , destaddr , txid , vout ) ;
if ( bits256_nonz ( spendtxid ) ! = 0 )
{
sentflags [ utxoind ] = 1 ;
printf ( " utxoind.%d Alice.(%s %s) Bob.(%s %s) vs destaddr.(%s) \n " , utxoind , aliceaddr , Adest , bobaddr , dest , destaddr ) ;
if ( aliceaddr ! = 0 & & ( strcmp ( destaddr , aliceaddr ) = = 0 | | strcmp ( Adest , destaddr ) = = 0 ) )
{
printf ( " ALICE spent.(%s) -> %s \n " , bits256_str ( str , txid ) , destaddr ) ;
sentflags [ alicespent ] = 1 ;
sentflags [ bobspent ] = 0 ;
txids [ alicespent ] = spendtxid ;
}
else if ( bobaddr ! = 0 & & ( strcmp ( destaddr , bobaddr ) = = 0 | | strcmp ( dest , destaddr ) = = 0 ) )
{
printf ( " BOB spent.(%s) -> %s \n " , bits256_str ( str , txid ) , destaddr ) ;
sentflags [ bobspent ] = 1 ;
sentflags [ alicespent ] = 0 ;
txids [ bobspent ] = spendtxid ;
}
else
{
printf ( " OTHER dest spent.(%s) -> %s \n " , bits256_str ( str , txid ) , destaddr ) ;
if ( iambob = = 0 )
{
sentflags [ bobspent ] = 1 ;
sentflags [ alicespent ] = 0 ;
txids [ bobspent ] = spendtxid ;
}
else
{
sentflags [ alicespent ] = 1 ;
sentflags [ bobspent ] = 0 ;
txids [ alicespent ] = spendtxid ;
}
}
} else printf ( " no spend of %s/v%d detected \n " , bits256_str ( str , txid ) , vout ) ;
} else printf ( " utxoind.%d null txid \n " , utxoind ) ;
return ( spendtxid ) ;
}
# define BASILISK_ALICESPEND 0
# define BASILISK_BOBSPEND 1
# define BASILISK_BOBPAYMENT 2
# define BASILISK_ALICEPAYMENT 3
# define BASILISK_BOBDEPOSIT 4
# define BASILISK_OTHERFEE 5
# define BASILISK_MYFEE 6
# define BASILISK_BOBREFUND 7
# define BASILISK_BOBRECLAIM 8
# define BASILISK_ALICERECLAIM 9
# define BASILISK_ALICECLAIM 10
//0, 0, 1, 1, 1, 0, 1, 1, 1, 0, 0
char * txnames [ ] = { " alicespend " , " bobspend " , " bobpayment " , " alicepayment " , " bobdeposit " , " otherfee " , " myfee " , " bobrefund " , " bobreclaim " , " alicereclaim " , " aliceclaim " } ;
int32_t basilisk_isbobcoin ( int32_t iambob , int32_t ind )
{
switch ( ind )
{
case BASILISK_MYFEE : return ( iambob ) ; break ;
case BASILISK_OTHERFEE : return ( ! iambob ) ; break ;
case BASILISK_BOBSPEND :
case BASILISK_ALICEPAYMENT :
case BASILISK_ALICERECLAIM :
case BASILISK_ALICECLAIM : return ( 0 ) ;
break ;
case BASILISK_BOBDEPOSIT :
case BASILISK_ALICESPEND :
case BASILISK_BOBPAYMENT :
case BASILISK_BOBREFUND :
case BASILISK_BOBRECLAIM : return ( 1 ) ;
break ;
default : return ( - 1 ) ; break ;
}
}
int32_t basilisk_swap_isfinished ( int32_t iambob , bits256 * txids , int32_t * sentflags , bits256 paymentspent , bits256 Apaymentspent , bits256 depositspent )
{
int32_t i , n = 0 ;
for ( i = 0 ; i < sizeof ( txnames ) / sizeof ( * txnames ) ; i + + )
if ( i ! = BASILISK_OTHERFEE & & i ! = BASILISK_MYFEE & & sentflags [ i ] ! = 0 )
n + + ;
if ( n = = 0 )
{
//printf("if nothing sent, it is finished\n");
return ( 1 ) ;
}
if ( iambob ! = 0 )
{
if ( bits256_nonz ( txids [ BASILISK_BOBDEPOSIT ] ) = = 0 & & sentflags [ BASILISK_BOBDEPOSIT ] = = 0 )
return ( 1 ) ;
else if ( bits256_nonz ( txids [ BASILISK_BOBPAYMENT ] ) = = 0 & & sentflags [ BASILISK_BOBPAYMENT ] = = 0 )
{
if ( bits256_nonz ( depositspent ) ! = 0 )
return ( 1 ) ;
}
else if ( bits256_nonz ( Apaymentspent ) ! = 0 )
return ( 1 ) ;
}
else
{
if ( bits256_nonz ( txids [ BASILISK_ALICEPAYMENT ] ) = = 0 & & sentflags [ BASILISK_ALICEPAYMENT ] = = 0 )
return ( 1 ) ;
else
{
if ( sentflags [ BASILISK_ALICERECLAIM ] ! = 0 | | sentflags [ BASILISK_ALICESPEND ] ! = 0 )
return ( 1 ) ;
else if ( sentflags [ BASILISK_BOBSPEND ] ! = 0 ) // without ALICECLAIM this is loss due to inactivity
return ( 1 ) ;
}
}
return ( 0 ) ;
}
uint32_t LP_extract ( uint32_t requestid , uint32_t quoteid , char * rootfname , char * field )
{
char fname [ 1024 ] , * filestr , * redeemstr ; long fsize ; int32_t len ; uint32_t t = 0 ; cJSON * json ; uint8_t redeem [ 1024 ] ;
if ( strcmp ( field , " dlocktime " ) = = 0 )
sprintf ( fname , " %s.bobdeposit " , rootfname ) ;
else if ( strcmp ( field , " plocktime " ) = = 0 )
sprintf ( fname , " %s.bobpayment " , rootfname ) ;
if ( ( filestr = OS_filestr ( & fsize , fname ) ) ! = 0 )
{
if ( ( json = cJSON_Parse ( filestr ) ) ! = 0 )
{
if ( ( redeemstr = jstr ( json , " redeem " ) ) ! = 0 & & ( len = ( int32_t ) strlen ( redeemstr ) ) < = sizeof ( redeem ) * 2 )
{
len > > = 1 ;
decode_hex ( redeem , len , redeemstr ) ;
t = redeem [ 5 ] ;
t = ( t < < 8 ) | redeem [ 4 ] ;
t = ( t < < 8 ) | redeem [ 3 ] ;
t = ( t < < 8 ) | redeem [ 2 ] ;
//printf("extracted timestamp.%u\n",t);
}
}
free ( filestr ) ;
}
return ( t ) ;
}
void LP_totals_update ( int32_t iambob , char * alicecoin , char * bobcoin , int64_t * KMDtotals , int64_t * BTCtotals , int32_t * sentflags , int64_t * values ) // update to handle all coins
{
values [ BASILISK_OTHERFEE ] = 0 ;
if ( iambob = = 0 )
{
if ( strcmp ( alicecoin , " BTC " ) = = 0 )
{
BTCtotals [ BASILISK_ALICEPAYMENT ] - = values [ BASILISK_ALICEPAYMENT ] * sentflags [ BASILISK_ALICEPAYMENT ] ;
BTCtotals [ BASILISK_ALICERECLAIM ] + = values [ BASILISK_ALICEPAYMENT ] * sentflags [ BASILISK_ALICERECLAIM ] ;
BTCtotals [ BASILISK_MYFEE ] - = values [ BASILISK_MYFEE ] * sentflags [ BASILISK_MYFEE ] ;
}
else if ( strcmp ( alicecoin , " KMD " ) = = 0 )
{
KMDtotals [ BASILISK_ALICEPAYMENT ] - = values [ BASILISK_ALICEPAYMENT ] * sentflags [ BASILISK_ALICEPAYMENT ] ;
KMDtotals [ BASILISK_ALICERECLAIM ] + = values [ BASILISK_ALICEPAYMENT ] * sentflags [ BASILISK_ALICERECLAIM ] ;
KMDtotals [ BASILISK_MYFEE ] - = values [ BASILISK_MYFEE ] * sentflags [ BASILISK_MYFEE ] ;
}
if ( strcmp ( bobcoin , " KMD " ) = = 0 )
{
KMDtotals [ BASILISK_ALICESPEND ] + = values [ BASILISK_BOBPAYMENT ] * sentflags [ BASILISK_ALICESPEND ] ;
KMDtotals [ BASILISK_ALICECLAIM ] + = values [ BASILISK_BOBDEPOSIT ] * sentflags [ BASILISK_ALICECLAIM ] ;
}
else if ( strcmp ( bobcoin , " BTC " ) = = 0 )
{
BTCtotals [ BASILISK_ALICESPEND ] + = values [ BASILISK_BOBPAYMENT ] * sentflags [ BASILISK_ALICESPEND ] ;
BTCtotals [ BASILISK_ALICECLAIM ] + = values [ BASILISK_BOBDEPOSIT ] * sentflags [ BASILISK_ALICECLAIM ] ;
}
}
else
{
if ( strcmp ( bobcoin , " BTC " ) = = 0 )
{
BTCtotals [ BASILISK_BOBPAYMENT ] - = values [ BASILISK_BOBPAYMENT ] * sentflags [ BASILISK_BOBPAYMENT ] ;
BTCtotals [ BASILISK_BOBDEPOSIT ] - = values [ BASILISK_BOBDEPOSIT ] * sentflags [ BASILISK_BOBDEPOSIT ] ;
BTCtotals [ BASILISK_BOBREFUND ] + = values [ BASILISK_BOBREFUND ] * sentflags [ BASILISK_BOBREFUND ] ;
BTCtotals [ BASILISK_BOBRECLAIM ] + = values [ BASILISK_BOBRECLAIM ] * sentflags [ BASILISK_BOBRECLAIM ] ;
BTCtotals [ BASILISK_MYFEE ] - = values [ BASILISK_MYFEE ] * sentflags [ BASILISK_MYFEE ] ;
}
else if ( strcmp ( bobcoin , " KMD " ) = = 0 )
{
KMDtotals [ BASILISK_BOBPAYMENT ] - = values [ BASILISK_BOBPAYMENT ] * sentflags [ BASILISK_BOBPAYMENT ] ;
KMDtotals [ BASILISK_BOBDEPOSIT ] - = values [ BASILISK_BOBDEPOSIT ] * sentflags [ BASILISK_BOBDEPOSIT ] ;
KMDtotals [ BASILISK_BOBREFUND ] + = values [ BASILISK_BOBDEPOSIT ] * sentflags [ BASILISK_BOBREFUND ] ;
KMDtotals [ BASILISK_BOBRECLAIM ] + = values [ BASILISK_BOBPAYMENT ] * sentflags [ BASILISK_BOBRECLAIM ] ;
KMDtotals [ BASILISK_MYFEE ] - = values [ BASILISK_MYFEE ] * sentflags [ BASILISK_MYFEE ] ;
}
if ( strcmp ( alicecoin , " KMD " ) = = 0 )
{
KMDtotals [ BASILISK_BOBSPEND ] + = values [ BASILISK_BOBSPEND ] * sentflags [ BASILISK_BOBSPEND ] ;
}
else if ( strcmp ( alicecoin , " BTC " ) = = 0 )
{
BTCtotals [ BASILISK_BOBSPEND ] + = values [ BASILISK_ALICEPAYMENT ] * sentflags [ BASILISK_BOBSPEND ] ;
}
}
}
struct LP_swap_remember
{
bits256 pubA0 , pubB0 , pubB1 , privAm , privBn , paymentspent , Apaymentspent , depositspent , myprivs [ 2 ] , txids [ sizeof ( txnames ) / sizeof ( * txnames ) ] ;
uint64_t Atxfee , Btxfee , srcamount , destamount ; int64_t values [ sizeof ( txnames ) / sizeof ( * txnames ) ] ;
uint32_t requestid , quoteid , plocktime , dlocktime , expiration , state , otherstate ;
int32_t iambob , finishedflag , origfinishedflag , Predeemlen , Dredeemlen , sentflags [ sizeof ( txnames ) / sizeof ( * txnames ) ] ;
uint8_t secretAm [ 20 ] , secretAm256 [ 32 ] , secretBn [ 20 ] , secretBn256 [ 32 ] , Predeemscript [ 1024 ] , Dredeemscript [ 1024 ] , pubkey33 [ 33 ] , other33 [ 33 ] ;
char src [ 64 ] , dest [ 64 ] , destaddr [ 64 ] , Adestaddr [ 64 ] , Sdestaddr [ 64 ] , alicepaymentaddr [ 64 ] , bobpaymentaddr [ 64 ] , bobdepositaddr [ 64 ] , alicecoin [ 64 ] , bobcoin [ 64 ] , * txbytes [ sizeof ( txnames ) / sizeof ( * txnames ) ] ;
} ;
cJSON * LP_swap_json ( struct LP_swap_remember * rswap )
{
cJSON * item , * array ; int32_t i ;
item = cJSON_CreateObject ( ) ;
jaddnum ( item , " requestid " , rswap - > requestid ) ;
jaddnum ( item , " quoteid " , rswap - > quoteid ) ;
jaddnum ( item , " iambob " , rswap - > iambob ) ;
jaddstr ( item , " bob " , rswap - > src ) ;
jaddnum ( item , " srcamount " , dstr ( rswap - > srcamount ) ) ;
jaddnum ( item , " bobtxfee " , dstr ( rswap - > Btxfee ) ) ;
jaddstr ( item , " alice " , rswap - > dest ) ;
jaddnum ( item , " destamount " , dstr ( rswap - > destamount ) ) ;
jaddnum ( item , " alicetxfee " , dstr ( rswap - > Atxfee ) ) ;
array = cJSON_CreateArray ( ) ;
for ( i = 0 ; i < sizeof ( txnames ) / sizeof ( * txnames ) ; i + + )
{
if ( rswap - > sentflags [ i ] ! = 0 )
jaddistr ( array , txnames [ i ] ) ;
if ( rswap - > txbytes [ i ] ! = 0 )
free ( rswap - > txbytes [ i ] ) ;
}
jadd ( item , " sentflags " , array ) ;
array = cJSON_CreateArray ( ) ;
for ( i = 0 ; i < sizeof ( txnames ) / sizeof ( * txnames ) ; i + + )
jaddinum ( array , dstr ( rswap - > values [ i ] ) ) ;
jadd ( item , " values " , array ) ;
jaddstr ( item , " result " , " success " ) ;
if ( rswap - > finishedflag ! = 0 )
jaddstr ( item , " status " , " finished " ) ;
else jaddstr ( item , " status " , " pending " ) ;
jaddbits256 ( item , " bobdeposit " , rswap - > txids [ BASILISK_BOBDEPOSIT ] ) ;
jaddbits256 ( item , " alicepayment " , rswap - > txids [ BASILISK_ALICEPAYMENT ] ) ;
jaddbits256 ( item , " bobpayment " , rswap - > txids [ BASILISK_BOBPAYMENT ] ) ;
jaddbits256 ( item , " paymentspent " , rswap - > paymentspent ) ;
jaddbits256 ( item , " Apaymentspent " , rswap - > Apaymentspent ) ;
jaddbits256 ( item , " depositspent " , rswap - > depositspent ) ;
return ( item ) ;
}
int32_t LP_rswap_init ( struct LP_swap_remember * rswap , uint32_t requestid , uint32_t quoteid )
{
char fname [ 1024 ] , * fstr , * secretstr , * srcstr , * deststr , * dest33 , * txname ; long fsize ; cJSON * item , * txobj , * array ; bits256 privkey ; struct iguana_info * coin ; uint32_t r , q ; int32_t i , j , n ; uint8_t other33 [ 33 ] ;
memset ( rswap , 0 , sizeof ( * rswap ) ) ;
rswap - > requestid = requestid ;
rswap - > quoteid = quoteid ;
sprintf ( fname , " %s/SWAPS/%u-%u " , GLOBAL_DBDIR , requestid , quoteid ) , OS_compatible_path ( fname ) ;
if ( ( fstr = OS_filestr ( & fsize , fname ) ) ! = 0 )
{
if ( ( item = cJSON_Parse ( fstr ) ) ! = 0 )
{
rswap - > iambob = jint ( item , " iambob " ) ;
if ( ( secretstr = jstr ( item , " secretAm " ) ) ! = 0 & & strlen ( secretstr ) = = 40 )
decode_hex ( rswap - > secretAm , 20 , secretstr ) ;
if ( ( secretstr = jstr ( item , " secretAm256 " ) ) ! = 0 & & strlen ( secretstr ) = = 64 )
decode_hex ( rswap - > secretAm256 , 32 , secretstr ) ;
if ( ( secretstr = jstr ( item , " secretBn " ) ) ! = 0 & & strlen ( secretstr ) = = 40 )
decode_hex ( rswap - > secretBn , 20 , secretstr ) ;
if ( ( secretstr = jstr ( item , " secretBn256 " ) ) ! = 0 & & strlen ( secretstr ) = = 64 )
decode_hex ( rswap - > secretBn256 , 32 , secretstr ) ;
if ( ( srcstr = jstr ( item , " src " ) ) ! = 0 )
safecopy ( rswap - > src , srcstr , sizeof ( rswap - > src ) ) ;
if ( ( deststr = jstr ( item , " dest " ) ) ! = 0 )
safecopy ( rswap - > dest , deststr , sizeof ( rswap - > dest ) ) ;
if ( ( dest33 = jstr ( item , " dest33 " ) ) ! = 0 & & strlen ( dest33 ) = = 66 )
{
decode_hex ( rswap - > pubkey33 , 33 , dest33 ) ;
if ( rswap - > iambob ! = 0 & & ( coin = LP_coinfind ( rswap - > src ) ) ! = 0 )
bitcoin_address ( rswap - > destaddr , coin - > taddr , coin - > pubtype , rswap - > pubkey33 , 33 ) ;
else if ( rswap - > iambob = = 0 & & ( coin = LP_coinfind ( rswap - > dest ) ) ! = 0 )
bitcoin_address ( rswap - > Adestaddr , coin - > taddr , coin - > pubtype , rswap - > pubkey33 , 33 ) ;
//for (i=0; i<33; i++)
// printf("%02x",pubkey33[i]);
//printf(" <- %s dest33\n",dest33);
}
if ( ( dest33 = jstr ( item , " other33 " ) ) ! = 0 & & strlen ( dest33 ) = = 66 )
{
decode_hex ( other33 , 33 , dest33 ) ;
for ( i = 0 ; i < 33 ; i + + )
if ( other33 [ i ] ! = 0 )
break ;
if ( i < 33 )
memcpy ( rswap - > other33 , other33 , 33 ) ;
if ( rswap - > iambob ! = 0 & & ( coin = LP_coinfind ( rswap - > dest ) ) ! = 0 )
bitcoin_address ( rswap - > Adestaddr , coin - > taddr , coin - > pubtype , rswap - > other33 , 33 ) ;
else if ( rswap - > iambob = = 0 & & ( coin = LP_coinfind ( rswap - > src ) ) ! = 0 )
bitcoin_address ( rswap - > destaddr , coin - > taddr , coin - > pubtype , rswap - > other33 , 33 ) ;
//printf("(%s, %s) <- %s other33\n",rswap->destaddr,rswap->Adestaddr,dest33);
}
if ( ( rswap - > plocktime = juint ( item , " plocktime " ) ) = = 0 )
rswap - > plocktime = LP_extract ( requestid , quoteid , fname , " plocktime " ) ;
if ( ( rswap - > dlocktime = juint ( item , " dlocktime " ) ) = = 0 )
rswap - > dlocktime = LP_extract ( requestid , quoteid , fname , " dlocktime " ) ;
r = juint ( item , " requestid " ) ;
q = juint ( item , " quoteid " ) ;
rswap - > Atxfee = j64bits ( item , " Atxfee " ) ;
rswap - > Btxfee = j64bits ( item , " Btxfee " ) ;
rswap - > pubA0 = jbits256 ( item , " pubA0 " ) ;
rswap - > pubB0 = jbits256 ( item , " pubB0 " ) ;
rswap - > pubB1 = jbits256 ( item , " pubB1 " ) ;
privkey = jbits256 ( item , " myprivs0 " ) ;
if ( bits256_nonz ( privkey ) ! = 0 )
rswap - > myprivs [ 0 ] = privkey ;
privkey = jbits256 ( item , " myprivs1 " ) ;
if ( bits256_nonz ( privkey ) ! = 0 )
rswap - > myprivs [ 1 ] = privkey ;
privkey = jbits256 ( item , " privAm " ) ;
if ( bits256_nonz ( privkey ) ! = 0 )
{
rswap - > privAm = privkey ;
//printf("set privAm <- %s\n",bits256_str(str,privAm));
}
privkey = jbits256 ( item , " privBn " ) ;
if ( bits256_nonz ( privkey ) ! = 0 )
{
rswap - > privBn = privkey ;
//printf("set privBn <- %s\n",bits256_str(str,privBn));
}
rswap - > expiration = juint ( item , " expiration " ) ;
rswap - > state = jint ( item , " state " ) ;
rswap - > otherstate = jint ( item , " otherstate " ) ;
rswap - > srcamount = SATOSHIDEN * jdouble ( item , " srcamount " ) ;
rswap - > destamount = SATOSHIDEN * jdouble ( item , " destamount " ) ;
rswap - > txids [ BASILISK_BOBDEPOSIT ] = jbits256 ( item , " Bdeposit " ) ;
rswap - > txids [ BASILISK_BOBREFUND ] = jbits256 ( item , " Brefund " ) ;
rswap - > txids [ BASILISK_ALICECLAIM ] = jbits256 ( item , " Aclaim " ) ;
rswap - > txids [ BASILISK_BOBPAYMENT ] = jbits256 ( item , " Bpayment " ) ;
rswap - > txids [ BASILISK_ALICESPEND ] = jbits256 ( item , " Aspend " ) ;
rswap - > txids [ BASILISK_BOBRECLAIM ] = jbits256 ( item , " Breclaim " ) ;
rswap - > txids [ BASILISK_ALICEPAYMENT ] = jbits256 ( item , " Apayment " ) ;
rswap - > txids [ BASILISK_BOBSPEND ] = jbits256 ( item , " Bspend " ) ;
rswap - > txids [ BASILISK_ALICERECLAIM ] = jbits256 ( item , " Areclaim " ) ;
rswap - > txids [ BASILISK_MYFEE ] = jbits256 ( item , " myfee " ) ;
rswap - > txids [ BASILISK_OTHERFEE ] = jbits256 ( item , " otherfee " ) ;
free_json ( item ) ;
}
free ( fstr ) ;
}
sprintf ( fname , " %s/SWAPS/%u-%u.finished " , GLOBAL_DBDIR , requestid , quoteid ) , OS_compatible_path ( fname ) ;
if ( ( fstr = OS_filestr ( & fsize , fname ) ) ! = 0 )
{
//printf("%s -> (%s)\n",fname,fstr);
if ( ( txobj = cJSON_Parse ( fstr ) ) ! = 0 )
{
rswap - > paymentspent = jbits256 ( txobj , " paymentspent " ) ;
rswap - > Apaymentspent = jbits256 ( txobj , " Apaymentspent " ) ;
rswap - > depositspent = jbits256 ( txobj , " depositspent " ) ;
if ( ( array = jarray ( & n , txobj , " values " ) ) ! = 0 )
for ( i = 0 ; i < n & & i < sizeof ( txnames ) / sizeof ( * txnames ) ; i + + )
rswap - > values [ i ] = SATOSHIDEN * jdouble ( jitem ( array , i ) , 0 ) ;
if ( ( array = jarray ( & n , txobj , " sentflags " ) ) ! = 0 )
{
for ( i = 0 ; i < n ; i + + )
{
if ( ( txname = jstri ( array , i ) ) ! = 0 )
{
for ( j = 0 ; j < sizeof ( txnames ) / sizeof ( * txnames ) ; j + + )
if ( strcmp ( txname , txnames [ j ] ) = = 0 )
{
rswap - > sentflags [ j ] = 1 ;
//printf("finished.%s\n",txnames[j]);
break ;
}
}
}
}
}
rswap - > origfinishedflag = basilisk_swap_isfinished ( rswap - > iambob , rswap - > txids , rswap - > sentflags , rswap - > paymentspent , rswap - > Apaymentspent , rswap - > depositspent ) ;
rswap - > finishedflag = rswap - > origfinishedflag ;
free ( fstr ) ;
}
return ( rswap - > iambob ) ;
}
int32_t _LP_refht_update ( struct iguana_info * coin , bits256 txid , int32_t refht )
{
refht - = 9 ;
if ( refht > 10 & & ( coin - > firstrefht = = 0 | | refht < coin - > firstrefht ) )
{
char str [ 65 ] ; printf ( " >>>>>>>>. 1st refht %s %s <- %d, scan %d %d \n " , coin - > symbol , bits256_str ( str , txid ) , refht , coin - > firstscanht , coin - > lastscanht ) ;
if ( coin - > firstscanht = = 0 | | refht < coin - > firstscanht )
coin - > firstscanht = coin - > lastscanht = refht ;
coin - > firstrefht = refht ;
return ( 1 ) ;
}
return ( 0 ) ;
}
int32_t LP_refht_update ( char * symbol , bits256 txid )
{
int32_t refht ; struct iguana_info * coin ;
if ( ( coin = LP_coinfind ( symbol ) ) ! = 0 & & coin - > electrum = = 0 )
{
if ( ( refht = LP_txheight ( coin , txid ) ) > 0 & & refht > 0 )
return ( _LP_refht_update ( coin , txid , refht ) ) ;
}
return ( 0 ) ;
}
int32_t LP_swap_load ( struct LP_swap_remember * rswap )
{
int32_t i , needflag , addflag ; long fsize ; char fname [ 1024 ] , str [ 65 ] , * fstr , * symbol , * rstr ; cJSON * txobj , * sentobj , * fileobj ; bits256 txid , checktxid ; uint64_t value ;
rswap - > iambob = - 1 ;
sprintf ( fname , " %s/SWAPS/%u-%u.finished " , GLOBAL_DBDIR , rswap - > requestid , rswap - > quoteid ) , OS_compatible_path ( fname ) ;
if ( ( fstr = OS_filestr ( & fsize , fname ) ) ! = 0 )
{
if ( ( fileobj = cJSON_Parse ( fstr ) ) ! = 0 )
{
rswap - > origfinishedflag = rswap - > finishedflag = 1 ;
free_json ( fileobj ) ;
}
free ( fstr ) ;
}
for ( i = 0 ; i < sizeof ( txnames ) / sizeof ( * txnames ) ; i + + )
{
needflag = addflag = 0 ;
sprintf ( fname , " %s/SWAPS/%u-%u.%s " , GLOBAL_DBDIR , rswap - > requestid , rswap - > quoteid , txnames [ i ] ) , OS_compatible_path ( fname ) ;
if ( ( fstr = OS_filestr ( & fsize , fname ) ) ! = 0 )
{
if ( 0 & & rswap - > finishedflag = = 0 )
printf ( " %s \n " , fname ) ;
//printf("%s -> (%s)\n",fname,fstr);
if ( ( txobj = cJSON_Parse ( fstr ) ) ! = 0 )
{
//printf("TXOBJ.(%s)\n",jprint(txobj,0));
if ( jobj ( txobj , " iambob " ) ! = 0 )
rswap - > iambob = jint ( txobj , " iambob " ) ;
txid = jbits256 ( txobj , " txid " ) ;
if ( bits256_nonz ( txid ) = = 0 )
continue ;
rswap - > txids [ i ] = txid ;
if ( jstr ( txobj , " Apayment " ) ! = 0 )
safecopy ( rswap - > alicepaymentaddr , jstr ( txobj , " Apayment " ) , sizeof ( rswap - > alicepaymentaddr ) ) ;
if ( jstr ( txobj , " Bpayment " ) ! = 0 )
safecopy ( rswap - > bobpaymentaddr , jstr ( txobj , " Bpayment " ) , sizeof ( rswap - > bobpaymentaddr ) ) ;
if ( jstr ( txobj , " Bdeposit " ) ! = 0 )
safecopy ( rswap - > bobdepositaddr , jstr ( txobj , " Bdeposit " ) , sizeof ( rswap - > bobdepositaddr ) ) ;
if ( jobj ( txobj , " tx " ) ! = 0 )
{
rswap - > txbytes [ i ] = clonestr ( jstr ( txobj , " tx " ) ) ;
//printf("[%s] TX.(%s)\n",txnames[i],txbytes[i]);
}
if ( strcmp ( txnames [ i ] , " bobpayment " ) = = 0 & & ( rstr = jstr ( txobj , " redeem " ) ) ! = 0 & & ( rswap - > Predeemlen = is_hexstr ( rstr , 0 ) ) > 0 )
{
rswap - > Predeemlen > > = 1 ;
decode_hex ( rswap - > Predeemscript , rswap - > Predeemlen , rstr ) ;
}
else if ( strcmp ( txnames [ i ] , " bobdeposit " ) = = 0 & & ( rstr = jstr ( txobj , " redeem " ) ) ! = 0 & & ( rswap - > Dredeemlen = is_hexstr ( rstr , 0 ) ) > 0 )
{
rswap - > Dredeemlen > > = 1 ;
decode_hex ( rswap - > Dredeemscript , rswap - > Dredeemlen , rstr ) ;
}
rswap - > values [ i ] = value = LP_value_extract ( txobj , 1 ) ;
if ( ( symbol = jstr ( txobj , " src " ) ) ! = 0 )
{
safecopy ( rswap - > src , symbol , sizeof ( rswap - > src ) ) ;
if ( rswap - > iambob > = 0 )
{
if ( rswap - > iambob > 0 )
safecopy ( rswap - > bobcoin , symbol , sizeof ( rswap - > bobcoin ) ) ;
else safecopy ( rswap - > alicecoin , symbol , sizeof ( rswap - > alicecoin ) ) ;
}
}
if ( ( symbol = jstr ( txobj , " dest " ) ) ! = 0 )
{
safecopy ( rswap - > dest , symbol , sizeof ( rswap - > dest ) ) ;
if ( rswap - > iambob > = 0 )
{
if ( rswap - > iambob = = 0 )
safecopy ( rswap - > bobcoin , symbol , sizeof ( rswap - > bobcoin ) ) ;
else safecopy ( rswap - > alicecoin , symbol , sizeof ( rswap - > alicecoin ) ) ;
}
}
if ( ( symbol = jstr ( txobj , " coin " ) ) ! = 0 )
{
if ( i = = BASILISK_ALICESPEND | | i = = BASILISK_BOBPAYMENT | | i = = BASILISK_BOBDEPOSIT | | i = = BASILISK_BOBREFUND | | i = = BASILISK_BOBRECLAIM | | i = = BASILISK_ALICECLAIM )
safecopy ( rswap - > bobcoin , symbol , sizeof ( rswap - > bobcoin ) ) ;
else if ( i = = BASILISK_BOBSPEND | | i = = BASILISK_ALICEPAYMENT | | i = = BASILISK_ALICERECLAIM )
safecopy ( rswap - > alicecoin , symbol , sizeof ( rswap - > alicecoin ) ) ;
if ( rswap - > finishedflag = = 0 )
{
if ( ( sentobj = LP_gettx ( symbol , txid ) ) = = 0 )
{
char str2 [ 65 ] ; printf ( " %s %s ready to broadcast \n " , symbol , bits256_str ( str2 , txid ) ) ;
}
else
{
checktxid = jbits256 ( sentobj , " txid " ) ;
if ( bits256_nonz ( checktxid ) = = 0 )
checktxid = jbits256 ( sentobj , " hash " ) ;
LP_refht_update ( symbol , txid ) ;
if ( bits256_cmp ( checktxid , txid ) = = 0 )
{
//printf(">>>>>> %s txid %s\n",jprint(sentobj,0),bits256_str(str,txid));
rswap - > sentflags [ i ] = 1 ;
}
free_json ( sentobj ) ;
}
printf ( " %s %s %.8f \n " , txnames [ i ] , bits256_str ( str , txid ) , dstr ( value ) ) ;
}
}
} //else printf("no symbol\n");
free ( fstr ) ;
} else if ( 0 & & rswap - > finishedflag = = 0 )
printf ( " %s not finished \n " , fname ) ;
}
if ( rswap - > bobcoin [ 0 ] = = 0 )
strcpy ( rswap - > bobcoin , rswap - > src ) ;
if ( rswap - > alicecoin [ 0 ] = = 0 )
strcpy ( rswap - > alicecoin , rswap - > dest ) ;
if ( rswap - > src [ 0 ] = = 0 )
strcpy ( rswap - > src , rswap - > bobcoin ) ;
if ( rswap - > dest [ 0 ] = = 0 )
strcpy ( rswap - > dest , rswap - > alicecoin ) ;
return ( rswap - > finishedflag ) ;
}
void LP_txbytes_update ( char * name , char * symbol , char * txbytes , bits256 * txidp , bits256 * ptr , int32_t * flagp )
{
bits256 zero ;
memset ( zero . bytes , 0 , sizeof ( zero ) ) ;
if ( txbytes ! = 0 )
{
* txidp = LP_broadcast ( name , symbol , txbytes , zero ) ;
if ( bits256_nonz ( * txidp ) ! = 0 )
{
* flagp = 1 ;
if ( ptr ! = 0 )
* ptr = * txidp ;
}
}
}
int32_t LP_rswap_checktx ( struct LP_swap_remember * rswap , char * symbol , int32_t txi )
{
struct LP_transaction * tx ; struct iguana_info * coin ; char str [ 65 ] ;
if ( rswap - > sentflags [ txi ] = = 0 & & bits256_nonz ( rswap - > txids [ txi ] ) ! = 0 )
{
coin = LP_coinfind ( symbol ) ;
printf ( " [%s] %s txbytes.%p %s \n " , txnames [ txi ] , txnames [ txi ] , rswap - > txbytes [ txi ] , bits256_str ( str , rswap - > txids [ txi ] ) ) ;
if ( coin ! = 0 & & ( tx = LP_transactionfind ( coin , rswap - > txids [ txi ] ) ) ! = 0 & & tx - > height > 0 )
{
rswap - > sentflags [ txi ] = 1 ;
_LP_refht_update ( coin , rswap - > txids [ txi ] , tx - > height ) ;
} else LP_refht_update ( symbol , rswap - > txids [ txi ] ) ;
}
return ( 0 ) ;
}
int32_t LP_spends_set ( struct LP_swap_remember * rswap )
{
int32_t numspent = 0 ;
if ( bits256_nonz ( rswap - > paymentspent ) = = 0 )
{
if ( bits256_nonz ( rswap - > txids [ BASILISK_ALICESPEND ] ) ! = 0 )
rswap - > paymentspent = rswap - > txids [ BASILISK_ALICESPEND ] ;
else rswap - > paymentspent = rswap - > txids [ BASILISK_BOBRECLAIM ] ;
} else numspent + + ;
if ( bits256_nonz ( rswap - > depositspent ) = = 0 )
{
if ( bits256_nonz ( rswap - > txids [ BASILISK_BOBREFUND ] ) ! = 0 )
rswap - > depositspent = rswap - > txids [ BASILISK_BOBREFUND ] ;
else rswap - > depositspent = rswap - > txids [ BASILISK_ALICECLAIM ] ;
} else numspent + + ;
if ( bits256_nonz ( rswap - > Apaymentspent ) = = 0 )
{
if ( bits256_nonz ( rswap - > txids [ BASILISK_BOBSPEND ] ) ! = 0 )
rswap - > Apaymentspent = rswap - > txids [ BASILISK_BOBSPEND ] ;
else rswap - > Apaymentspent = rswap - > txids [ BASILISK_ALICERECLAIM ] ;
} else numspent + + ;
return ( numspent ) ;
}
cJSON * basilisk_remember ( int64_t * KMDtotals , int64_t * BTCtotals , uint32_t requestid , uint32_t quoteid )
{
static void * ctx ;
struct LP_swap_remember rswap ; int32_t i , j , numspent , len , secretstart , redeemlen ; char str [ 65 ] , * srcAdest , * srcBdest , * destAdest , * destBdest , otheraddr [ 64 ] ; cJSON * item ; bits256 rev , signedtxid , zero ; struct iguana_info * bob = 0 , * alice = 0 ; uint8_t redeemscript [ 1024 ] , userdata [ 1024 ] ;
if ( ctx = = 0 )
ctx = bitcoin_ctx ( ) ;
if ( ( rswap . iambob = LP_rswap_init ( & rswap , requestid , quoteid ) ) < 0 )
return ( cJSON_Parse ( " { \" error \" : \" couldnt initialize rswap, are all coins active? \" } " ) ) ;
LP_swap_load ( & rswap ) ;
memset ( zero . bytes , 0 , sizeof ( zero ) ) ;
otheraddr [ 0 ] = 0 ;
srcAdest = srcBdest = destAdest = destBdest = 0 ;
if ( rswap . bobcoin [ 0 ] = = 0 | | rswap . alicecoin [ 0 ] = = 0 | | strcmp ( rswap . bobcoin , rswap . src ) ! = 0 | | strcmp ( rswap . alicecoin , rswap . dest ) ! = 0 )
{
printf ( " legacy DB SWAPS files BOB.(%s) Alice.(%s) src.(%s) dest.(%s) \n " , rswap . bobcoin , rswap . alicecoin , rswap . src , rswap . dest ) ;
return ( cJSON_Parse ( " { \" error \" : \" mismatched bob/alice vs src/dest coins?? \" } " ) ) ;
}
alice = LP_coinfind ( rswap . alicecoin ) ;
bob = LP_coinfind ( rswap . bobcoin ) ;
rswap . Atxfee = LP_txfeecalc ( alice , rswap . Atxfee , 0 ) ;
rswap . Btxfee = LP_txfeecalc ( bob , rswap . Btxfee , 0 ) ;
if ( rswap . iambob = = 0 )
{
if ( alice ! = 0 )
{
bitcoin_address ( otheraddr , alice - > taddr , alice - > pubtype , rswap . other33 , 33 ) ;
destBdest = otheraddr ;
destAdest = rswap . Adestaddr ;
}
if ( ( bob = LP_coinfind ( rswap . bobcoin ) ) ! = 0 )
{
bitcoin_address ( rswap . Sdestaddr , bob - > taddr , bob - > pubtype , rswap . pubkey33 , 33 ) ;
srcAdest = rswap . Sdestaddr ;
}
srcBdest = rswap . destaddr ;
}
else
{
if ( bob ! = 0 )
{
bitcoin_address ( otheraddr , bob - > taddr , bob - > pubtype , rswap . other33 , 33 ) ;
srcAdest = otheraddr ;
srcBdest = rswap . destaddr ;
}
if ( ( alice = LP_coinfind ( rswap . alicecoin ) ) ! = 0 )
{
bitcoin_address ( rswap . Sdestaddr , alice - > taddr , alice - > pubtype , rswap . pubkey33 , 33 ) ;
destBdest = rswap . Sdestaddr ;
}
destAdest = rswap . Adestaddr ;
}
if ( bob = = 0 | | alice = = 0 )
{
printf ( " Bob.%p is null or Alice.%p is null \n " , bob , alice ) ;
return ( cJSON_Parse ( " { \" error \" : \" null bob or alice coin \" } " ) ) ;
}
//printf("src.(Adest %s, Bdest %s), dest.(Adest %s, Bdest %s)\n",srcAdest,srcBdest,destAdest,destBdest);
//printf("iambob.%d finishedflag.%d %s %.8f txfee, %s %.8f txfee\n",rswap.iambob,rswap.finishedflag,rswap.alicecoin,dstr(rswap.Atxfee),rswap.bobcoin,dstr(rswap.Btxfee));
//printf("privAm.(%s) %p/%p\n",bits256_str(str,rswap.privAm),Adest,AAdest);
//printf("privBn.(%s) %p/%p\n",bits256_str(str,rswap.privBn),Bdest,ABdest);
if ( rswap . finishedflag = = 0 & & rswap . bobcoin [ 0 ] ! = 0 & & rswap . alicecoin [ 0 ] ! = 0 )
{
//printf("ALICE.(%s) 1st refht %s <- %d, scan %d %d\n",rswap.Adestaddr,alice->symbol,alice->firstrefht,alice->firstscanht,alice->lastscanht);
//printf("BOB.(%s) 1st refht %s <- %d, scan %d %d\n",rswap.destaddr,bob->symbol,bob->firstrefht,bob->firstscanht,bob->lastscanht);
if ( alice - > inactive ! = 0 | | bob - > inactive ! = 0 )
{
printf ( " Alice.%s inactive.%u or Bob.%s inactive.%u \n " , rswap . alicecoin , alice - > inactive , rswap . bobcoin , bob - > inactive ) ;
return ( cJSON_Parse ( " { \" error \" : \" inactive bob or alice coin \" } " ) ) ;
}
LP_rswap_checktx ( & rswap , rswap . alicecoin , BASILISK_ALICEPAYMENT ) ;
LP_rswap_checktx ( & rswap , rswap . bobcoin , BASILISK_BOBPAYMENT ) ;
LP_rswap_checktx ( & rswap , rswap . bobcoin , BASILISK_BOBDEPOSIT ) ;
rswap . paymentspent = basilisk_swap_spendupdate ( rswap . iambob , rswap . bobcoin , rswap . bobpaymentaddr , rswap . sentflags , rswap . txids , BASILISK_BOBPAYMENT , BASILISK_ALICESPEND , BASILISK_BOBRECLAIM , 0 , srcAdest , srcBdest , rswap . Adestaddr , rswap . destaddr ) ;
rswap . Apaymentspent = basilisk_swap_spendupdate ( rswap . iambob , rswap . alicecoin , rswap . alicepaymentaddr , rswap . sentflags , rswap . txids , BASILISK_ALICEPAYMENT , BASILISK_ALICERECLAIM , BASILISK_BOBSPEND , 0 , destAdest , destBdest , rswap . Adestaddr , rswap . destaddr ) ;
rswap . depositspent = basilisk_swap_spendupdate ( rswap . iambob , rswap . bobcoin , rswap . bobdepositaddr , rswap . sentflags , rswap . txids , BASILISK_BOBDEPOSIT , BASILISK_ALICECLAIM , BASILISK_BOBREFUND , 0 , srcAdest , srcBdest , rswap . Adestaddr , rswap . destaddr ) ;
rswap . finishedflag = basilisk_swap_isfinished ( rswap . iambob , rswap . txids , rswap . sentflags , rswap . paymentspent , rswap . Apaymentspent , rswap . depositspent ) ;
LP_spends_set ( & rswap ) ;
if ( rswap . iambob = = 0 )
{
if ( rswap . sentflags [ BASILISK_ALICESPEND ] = = 0 )
{
if ( rswap . sentflags [ BASILISK_BOBPAYMENT ] ! = 0 & & bits256_nonz ( rswap . paymentspent ) = = 0 )
{
//if ( txbytes[BASILISK_ALICESPEND] == 0 )
{
if ( bits256_nonz ( rswap . txids [ BASILISK_BOBPAYMENT ] ) ! = 0 )
{
// alicespend
memset ( rev . bytes , 0 , sizeof ( rev ) ) ;
for ( j = 0 ; j < 32 ; j + + )
rev . bytes [ j ] = rswap . privAm . bytes [ 31 - j ] ;
//revcalc_rmd160_sha256(secretAm,rev);//privAm);
//vcalc_sha256(0,secretAm256,rev.bytes,sizeof(rev));
if ( rswap . Predeemlen ! = 0 )
redeemlen = rswap . Predeemlen , memcpy ( redeemscript , rswap . Predeemscript , rswap . Predeemlen ) ;
else redeemlen = basilisk_swap_bobredeemscript ( 0 , & secretstart , redeemscript , rswap . plocktime , rswap . pubA0 , rswap . pubB0 , rswap . pubB1 , rev , rswap . privBn , rswap . secretAm , rswap . secretAm256 , rswap . secretBn , rswap . secretBn256 ) ;
len = basilisk_swapuserdata ( userdata , rev , 0 , rswap . myprivs [ 0 ] , redeemscript , redeemlen ) ;
{
char privaddr [ 64 ] ; uint8_t privpub33 [ 33 ] ;
bitcoin_pubkey33 ( ctx , privpub33 , rswap . myprivs [ 0 ] ) ;
bitcoin_address ( privaddr , 0 , 60 , privpub33 , 33 ) ;
printf ( " alicespend len.%d redeemlen.%d priv0addr.(%s) priv0.(%s) \n " , len , redeemlen , privaddr , bits256_str ( str , rswap . myprivs [ 0 ] ) ) ;
}
for ( j = 0 ; j < 32 ; j + + )
rev . bytes [ j ] = rswap . myprivs [ 0 ] . bytes [ 31 - j ] ;
if ( ( rswap . txbytes [ BASILISK_ALICESPEND ] = basilisk_swap_bobtxspend ( & signedtxid , rswap . Btxfee , " alicespend " , rswap . bobcoin , bob - > wiftaddr , bob - > taddr , bob - > pubtype , bob - > p2shtype , bob - > isPoS , bob - > wiftype , ctx , rswap . myprivs [ 0 ] , 0 , redeemscript , redeemlen , userdata , len , rswap . txids [ BASILISK_BOBPAYMENT ] , 0 , 0 , rswap . pubkey33 , 1 , rswap . expiration , & rswap . values [ BASILISK_ALICESPEND ] , 0 , 0 , rswap . bobpaymentaddr , 1 ) ) ! = 0 )
printf ( " alicespend.(%s) \n " , rswap . txbytes [ BASILISK_ALICESPEND ] ) ;
}
}
LP_txbytes_update ( " alicespend " , rswap . bobcoin , rswap . txbytes [ BASILISK_ALICESPEND ] , & rswap . txids [ BASILISK_ALICESPEND ] , & rswap . paymentspent , & rswap . sentflags [ BASILISK_ALICESPEND ] ) ;
}
}
if ( rswap . sentflags [ BASILISK_ALICECLAIM ] = = 0 & & rswap . sentflags [ BASILISK_BOBDEPOSIT ] ! = 0 & & bits256_nonz ( rswap . txids [ BASILISK_BOBDEPOSIT ] ) ! = 0 & & bits256_nonz ( rswap . depositspent ) = = 0 )
{
if ( time ( NULL ) > rswap . expiration )
{
//if ( txbytes[BASILISK_ALICECLAIM] == 0 )
{
if ( rswap . Dredeemlen ! = 0 )
redeemlen = rswap . Dredeemlen , memcpy ( redeemscript , rswap . Dredeemscript , rswap . Dredeemlen ) ;
else redeemlen = basilisk_swap_bobredeemscript ( 1 , & secretstart , redeemscript , rswap . dlocktime , rswap . pubA0 , rswap . pubB0 , rswap . pubB1 , rswap . privAm , zero , rswap . secretAm , rswap . secretAm256 , rswap . secretBn , rswap . secretBn256 ) ;
if ( redeemlen > 0 )
{
if ( bits256_nonz ( rswap . privBn ) = = 0 )
rswap . privBn = basilisk_swap_privBn_extract ( & rswap . txids [ BASILISK_BOBREFUND ] , rswap . bobcoin , rswap . txids [ BASILISK_BOBDEPOSIT ] , rswap . privBn ) ;
if ( bits256_nonz ( rswap . privBn ) ! = 0 )
{
len = basilisk_swapuserdata ( userdata , zero , 1 , rswap . myprivs [ 0 ] , redeemscript , redeemlen ) ;
if ( ( rswap . txbytes [ BASILISK_ALICECLAIM ] = basilisk_swap_bobtxspend ( & signedtxid , rswap . Btxfee , " aliceclaim " , rswap . bobcoin , bob - > wiftaddr , bob - > taddr , bob - > pubtype , bob - > p2shtype , bob - > isPoS , bob - > wiftype , ctx , rswap . myprivs [ 0 ] , 0 , redeemscript , redeemlen , userdata , len , rswap . txids [ BASILISK_BOBDEPOSIT ] , 0 , 0 , rswap . pubkey33 , 0 , rswap . expiration , & rswap . values [ BASILISK_ALICECLAIM ] , 0 , 0 , rswap . bobdepositaddr , 1 ) ) ! = 0 )
printf ( " privBn.(%s) aliceclaim.(%s) \n " , bits256_str ( str , rswap . privBn ) , rswap . txbytes [ BASILISK_ALICECLAIM ] ) ;
}
}
}
LP_txbytes_update ( " aliceclaim " , rswap . bobcoin , rswap . txbytes [ BASILISK_ALICECLAIM ] , & rswap . txids [ BASILISK_ALICECLAIM ] , & rswap . depositspent , & rswap . sentflags [ BASILISK_ALICECLAIM ] ) ;
} else printf ( " now %u before expiration %u \n " , ( uint32_t ) time ( NULL ) , rswap . expiration ) ;
}
if ( rswap . sentflags [ BASILISK_ALICEPAYMENT ] ! = 0 & & bits256_nonz ( rswap . Apaymentspent ) = = 0 & & rswap . sentflags [ BASILISK_ALICECLAIM ] = = 0 )
{
//if ( txbytes[BASILISK_ALICERECLAIM] == 0 )
{
rswap . privBn = basilisk_swap_privBn_extract ( & rswap . txids [ BASILISK_BOBREFUND ] , rswap . bobcoin , rswap . txids [ BASILISK_BOBDEPOSIT ] , rswap . privBn ) ;
if ( bits256_nonz ( rswap . txids [ BASILISK_ALICEPAYMENT ] ) ! = 0 & & bits256_nonz ( rswap . privAm ) ! = 0 & & bits256_nonz ( rswap . privBn ) ! = 0 )
{
if ( ( rswap . txbytes [ BASILISK_ALICERECLAIM ] = basilisk_swap_Aspend ( " alicereclaim " , rswap . alicecoin , rswap . Atxfee , alice - > wiftaddr , alice - > taddr , alice - > pubtype , alice - > p2shtype , alice - > isPoS , alice - > wiftype , ctx , rswap . privAm , rswap . privBn , rswap . txids [ BASILISK_ALICEPAYMENT ] , 0 , rswap . pubkey33 , rswap . expiration , & rswap . values [ BASILISK_ALICERECLAIM ] , rswap . alicepaymentaddr ) ) ! = 0 )
printf ( " privBn.(%s) alicereclaim.(%s) \n " , bits256_str ( str , rswap . privBn ) , rswap . txbytes [ BASILISK_ALICERECLAIM ] ) ;
}
}
LP_txbytes_update ( " alicereclaim " , rswap . alicecoin , rswap . txbytes [ BASILISK_ALICERECLAIM ] , & rswap . txids [ BASILISK_ALICERECLAIM ] , & rswap . Apaymentspent , & rswap . sentflags [ BASILISK_ALICERECLAIM ] ) ;
}
}
else if ( rswap . iambob = = 1 )
{
if ( rswap . sentflags [ BASILISK_BOBSPEND ] = = 0 & & bits256_nonz ( rswap . Apaymentspent ) = = 0 )
{
printf ( " try to bobspend aspend.%s have privAm.%d \n " , bits256_str ( str , rswap . txids [ BASILISK_ALICESPEND ] ) , bits256_nonz ( rswap . privAm ) ) ;
if ( bits256_nonz ( rswap . txids [ BASILISK_ALICESPEND ] ) ! = 0 | | bits256_nonz ( rswap . privAm ) ! = 0 )
{
//if ( txbytes[BASILISK_BOBSPEND] == 0 )
{
if ( bits256_nonz ( rswap . privAm ) = = 0 )
{
rswap . privAm = basilisk_swap_privbob_extract ( rswap . bobcoin , rswap . txids [ BASILISK_ALICESPEND ] , 0 , 1 ) ;
printf ( " try to bobspend aspend.%s have privAm.%d \n " , bits256_str ( str , rswap . txids [ BASILISK_ALICESPEND ] ) , bits256_nonz ( rswap . privAm ) ) ;
}
if ( bits256_nonz ( rswap . privAm ) ! = 0 & & bits256_nonz ( rswap . privBn ) ! = 0 )
{
if ( ( rswap . txbytes [ BASILISK_BOBSPEND ] = basilisk_swap_Aspend ( " bobspend " , rswap . alicecoin , rswap . Atxfee , alice - > wiftaddr , alice - > taddr , alice - > pubtype , alice - > p2shtype , alice - > isPoS , alice - > wiftype , ctx , rswap . privAm , rswap . privBn , rswap . txids [ BASILISK_ALICEPAYMENT ] , 0 , rswap . pubkey33 , rswap . expiration , & rswap . values [ BASILISK_BOBSPEND ] , rswap . alicepaymentaddr ) ) ! = 0 )
printf ( " bobspend.(%s) \n " , rswap . txbytes [ BASILISK_BOBSPEND ] ) ;
}
}
LP_txbytes_update ( " bobspend " , rswap . alicecoin , rswap . txbytes [ BASILISK_BOBSPEND ] , & rswap . txids [ BASILISK_BOBSPEND ] , & rswap . Apaymentspent , & rswap . sentflags [ BASILISK_BOBSPEND ] ) ;
}
}
if ( rswap . sentflags [ BASILISK_BOBRECLAIM ] = = 0 & & rswap . sentflags [ BASILISK_BOBPAYMENT ] ! = 0 & & bits256_nonz ( rswap . txids [ BASILISK_BOBPAYMENT ] ) ! = 0 & & time ( NULL ) > rswap . expiration & & bits256_nonz ( rswap . paymentspent ) = = 0 )
{
//if ( txbytes[BASILISK_BOBRECLAIM] == 0 )
{
// bobreclaim
redeemlen = basilisk_swap_bobredeemscript ( 0 , & secretstart , redeemscript , rswap . plocktime , rswap . pubA0 , rswap . pubB0 , rswap . pubB1 , zero , rswap . privBn , rswap . secretAm , rswap . secretAm256 , rswap . secretBn , rswap . secretBn256 ) ;
if ( redeemlen > 0 )
{
len = basilisk_swapuserdata ( userdata , zero , 1 , rswap . myprivs [ 1 ] , redeemscript , redeemlen ) ;
if ( ( rswap . txbytes [ BASILISK_BOBRECLAIM ] = basilisk_swap_bobtxspend ( & signedtxid , rswap . Btxfee , " bobrefund " , rswap . bobcoin , bob - > wiftaddr , bob - > taddr , bob - > pubtype , bob - > p2shtype , bob - > isPoS , bob - > wiftype , ctx , rswap . myprivs [ 1 ] , 0 , redeemscript , redeemlen , userdata , len , rswap . txids [ BASILISK_BOBPAYMENT ] , 0 , 0 , rswap . pubkey33 , 0 , rswap . expiration , & rswap . values [ BASILISK_BOBRECLAIM ] , 0 , 0 , rswap . bobpaymentaddr , 1 ) ) ! = 0 )
{
int32_t z ;
for ( z = 0 ; z < 20 ; z + + )
printf ( " %02x " , rswap . secretAm [ z ] ) ;
printf ( " secretAm, myprivs[1].(%s) bobreclaim.(%s) \n " , bits256_str ( str , rswap . myprivs [ 1 ] ) , rswap . txbytes [ BASILISK_BOBRECLAIM ] ) ;
}
}
}
LP_txbytes_update ( " bobreclaim " , rswap . bobcoin , rswap . txbytes [ BASILISK_BOBRECLAIM ] , & rswap . txids [ BASILISK_BOBRECLAIM ] , & rswap . paymentspent , & rswap . sentflags [ BASILISK_BOBRECLAIM ] ) ;
}
if ( rswap . sentflags [ BASILISK_BOBREFUND ] = = 0 & & rswap . sentflags [ BASILISK_BOBDEPOSIT ] ! = 0 & & bits256_nonz ( rswap . txids [ BASILISK_BOBDEPOSIT ] ) ! = 0 & & bits256_nonz ( rswap . depositspent ) = = 0 )
{
if ( bits256_nonz ( rswap . Apaymentspent ) ! = 0 | | time ( NULL ) > rswap . expiration )
{
printf ( " do the refund! paymentspent.%s now.%u vs expiration.%u \n " , bits256_str ( str , rswap . paymentspent ) , ( uint32_t ) time ( NULL ) , rswap . expiration ) ;
//if ( txbytes[BASILISK_BOBREFUND] == 0 )
{
revcalc_rmd160_sha256 ( rswap . secretBn , rswap . privBn ) ;
vcalc_sha256 ( 0 , rswap . secretBn256 , rswap . privBn . bytes , sizeof ( rswap . privBn ) ) ;
redeemlen = basilisk_swap_bobredeemscript ( 1 , & secretstart , redeemscript , rswap . dlocktime , rswap . pubA0 , rswap . pubB0 , rswap . pubB1 , rswap . privAm , rswap . privBn , rswap . secretAm , rswap . secretAm256 , rswap . secretBn , rswap . secretBn256 ) ;
len = basilisk_swapuserdata ( userdata , rswap . privBn , 0 , rswap . myprivs [ 0 ] , redeemscript , redeemlen ) ;
if ( ( rswap . txbytes [ BASILISK_BOBREFUND ] = basilisk_swap_bobtxspend ( & signedtxid , rswap . Btxfee , " bobrefund " , rswap . bobcoin , bob - > wiftaddr , bob - > taddr , bob - > pubtype , bob - > p2shtype , bob - > isPoS , bob - > wiftype , ctx , rswap . myprivs [ 0 ] , 0 , redeemscript , redeemlen , userdata , len , rswap . txids [ BASILISK_BOBDEPOSIT ] , 0 , 0 , rswap . pubkey33 , 1 , rswap . expiration , & rswap . values [ BASILISK_BOBREFUND ] , 0 , 0 , rswap . bobdepositaddr , 1 ) ) ! = 0 )
printf ( " pubB1.(%s) bobrefund.(%s) \n " , bits256_str ( str , rswap . pubB1 ) , rswap . txbytes [ BASILISK_BOBREFUND ] ) ;
}
LP_txbytes_update ( " bobrefund " , rswap . bobcoin , rswap . txbytes [ BASILISK_BOBREFUND ] , & rswap . txids [ BASILISK_BOBREFUND ] , & rswap . depositspent , & rswap . sentflags [ BASILISK_BOBREFUND ] ) ;
} else printf ( " bobrefund's time %u vs expiration %u \n " , ( uint32_t ) time ( NULL ) , rswap . expiration ) ;
}
}
}
//printf("finish.%d iambob.%d REFUND %d %d %d %d\n",finishedflag,iambob,sentflags[BASILISK_BOBREFUND] == 0,sentflags[BASILISK_BOBDEPOSIT] != 0,bits256_nonz(txids[BASILISK_BOBDEPOSIT]) != 0,bits256_nonz(depositspent) == 0);
if ( rswap . sentflags [ BASILISK_ALICESPEND ] ! = 0 | | rswap . sentflags [ BASILISK_BOBRECLAIM ] ! = 0 )
rswap . sentflags [ BASILISK_BOBPAYMENT ] = 1 ;
if ( rswap . sentflags [ BASILISK_ALICERECLAIM ] ! = 0 | | rswap . sentflags [ BASILISK_BOBSPEND ] ! = 0 )
rswap . sentflags [ BASILISK_ALICEPAYMENT ] = 1 ;
if ( rswap . sentflags [ BASILISK_ALICECLAIM ] ! = 0 | | rswap . sentflags [ BASILISK_BOBREFUND ] ! = 0 )
rswap . sentflags [ BASILISK_BOBDEPOSIT ] = 1 ;
for ( i = 0 ; i < sizeof ( txnames ) / sizeof ( * txnames ) ; i + + )
if ( bits256_nonz ( rswap . txids [ i ] ) ! = 0 & & rswap . values [ i ] = = 0 )
rswap . values [ i ] = basilisk_txvalue ( basilisk_isbobcoin ( rswap . iambob , i ) ? rswap . bobcoin : rswap . alicecoin , rswap . txids [ i ] , 0 ) ;
if ( rswap . origfinishedflag = = 0 )
{
printf ( " iambob.%d Apaymentspent.(%s) alice.%d bob.%d %s %.8f \n " , rswap . iambob , bits256_str ( str , rswap . Apaymentspent ) , rswap . sentflags [ BASILISK_ALICERECLAIM ] , rswap . sentflags [ BASILISK_BOBSPEND ] , rswap . alicecoin , dstr ( rswap . values [ BASILISK_ALICEPAYMENT ] ) ) ;
printf ( " paymentspent.(%s) alice.%d bob.%d %s %.8f \n " , bits256_str ( str , rswap . paymentspent ) , rswap . sentflags [ BASILISK_ALICESPEND ] , rswap . sentflags [ BASILISK_BOBRECLAIM ] , rswap . bobcoin , dstr ( rswap . values [ BASILISK_BOBPAYMENT ] ) ) ;
printf ( " depositspent.(%s) alice.%d bob.%d %s %.8f \n " , bits256_str ( str , rswap . depositspent ) , rswap . sentflags [ BASILISK_ALICECLAIM ] , rswap . sentflags [ BASILISK_BOBREFUND ] , rswap . bobcoin , dstr ( rswap . values [ BASILISK_BOBDEPOSIT ] ) ) ;
}
LP_totals_update ( rswap . iambob , rswap . alicecoin , rswap . bobcoin , KMDtotals , BTCtotals , rswap . sentflags , rswap . values ) ;
if ( ( numspent = LP_spends_set ( & rswap ) ) = = 3 )
rswap . finishedflag = 1 ;
else rswap . finishedflag = basilisk_swap_isfinished ( rswap . iambob , rswap . txids , rswap . sentflags , rswap . paymentspent , rswap . Apaymentspent , rswap . depositspent ) ;
item = LP_swap_json ( & rswap ) ;
if ( rswap . origfinishedflag = = 0 & & rswap . finishedflag ! = 0 )
{
char fname [ 1024 ] , * itemstr ; FILE * fp ;
printf ( " SWAP %u-%u finished! \n " , requestid , quoteid ) ;
sprintf ( fname , " %s/SWAPS/%u-%u.finished " , GLOBAL_DBDIR , rswap . requestid , rswap . quoteid ) , OS_compatible_path ( fname ) ;
if ( ( fp = fopen ( fname , " wb " ) ) ! = 0 )
{
itemstr = jprint ( item , 0 ) ;
fprintf ( fp , " %s \n " , itemstr ) ;
free ( itemstr ) ;
fclose ( fp ) ;
}
}
return ( item ) ;
}
char * basilisk_swaplist ( uint32_t origrequestid , uint32_t origquoteid )
{
char fname [ 512 ] ; FILE * fp ; cJSON * item , * retjson , * array , * totalsobj ; uint32_t r , q , quoteid , requestid ; int64_t KMDtotals [ 16 ] , BTCtotals [ 16 ] , Btotal , Ktotal ; int32_t i ;
portable_mutex_lock ( & LP_swaplistmutex ) ;
memset ( KMDtotals , 0 , sizeof ( KMDtotals ) ) ;
memset ( BTCtotals , 0 , sizeof ( BTCtotals ) ) ;
//,statebits; int32_t optionduration; struct basilisk_request R; bits256 privkey;
retjson = cJSON_CreateObject ( ) ;
array = cJSON_CreateArray ( ) ;
if ( origrequestid ! = 0 & & origquoteid ! = 0 )
{
//printf("orig req.%u q.%u\n",origrequestid,origquoteid);
if ( ( item = basilisk_remember ( KMDtotals , BTCtotals , origrequestid , origquoteid ) ) ! = 0 )
jaddi ( array , item ) ;
//printf("got.(%s)\n",jprint(item,0));
}
else
{
sprintf ( fname , " %s/SWAPS/list " , GLOBAL_DBDIR ) , OS_compatible_path ( fname ) ;
if ( ( fp = fopen ( fname , " rb " ) ) ! = 0 )
{
//struct basilisk_swap *swap;
int32_t flag = 0 ;
while ( fread ( & requestid , 1 , sizeof ( requestid ) , fp ) = = sizeof ( requestid ) & & fread ( & quoteid , 1 , sizeof ( quoteid ) , fp ) = = sizeof ( quoteid ) )
{
flag = 0 ;
for ( i = 0 ; i < G . LP_numskips ; i + + )
{
r = ( uint32_t ) ( G . LP_skipstatus [ i ] > > 32 ) ;
q = ( uint32_t ) G . LP_skipstatus [ i ] ;
if ( r = = requestid & & q = = quoteid )
{
item = cJSON_CreateObject ( ) ;
jaddstr ( item , " status " , " realtime " ) ;
jaddnum ( item , " requestid " , r ) ;
jaddnum ( item , " quoteid " , q ) ;
jaddi ( array , item ) ;
flag = 1 ;
break ;
}
}
if ( flag = = 0 )
{
if ( ( item = basilisk_remember ( KMDtotals , BTCtotals , requestid , quoteid ) ) ! = 0 )
jaddi ( array , item ) ;
}
}
fclose ( fp ) ;
}
}
jaddstr ( retjson , " result " , " success " ) ;
jadd ( retjson , " swaps " , array ) ;
if ( 0 & & cJSON_GetArraySize ( array ) > 0 )
{
totalsobj = cJSON_CreateObject ( ) ;
for ( Btotal = i = 0 ; i < sizeof ( txnames ) / sizeof ( * txnames ) ; i + + )
if ( BTCtotals [ i ] ! = 0 )
jaddnum ( totalsobj , txnames [ i ] , dstr ( BTCtotals [ i ] ) ) , Btotal + = BTCtotals [ i ] ;
jadd ( retjson , " BTCtotals " , totalsobj ) ;
totalsobj = cJSON_CreateObject ( ) ;
for ( Ktotal = i = 0 ; i < sizeof ( txnames ) / sizeof ( * txnames ) ; i + + )
if ( KMDtotals [ i ] ! = 0 )
jaddnum ( totalsobj , txnames [ i ] , dstr ( KMDtotals [ i ] ) ) , Ktotal + = KMDtotals [ i ] ;
jadd ( retjson , " KMDtotals " , totalsobj ) ;
jaddnum ( retjson , " KMDtotal " , dstr ( Ktotal ) ) ;
jaddnum ( retjson , " BTCtotal " , dstr ( Btotal ) ) ;
if ( Ktotal > 0 & & Btotal < 0 )
jaddnum ( retjson , " avebuy " , ( double ) - Btotal / Ktotal ) ;
else if ( Ktotal < 0 & & Btotal > 0 )
jaddnum ( retjson , " avesell " , ( double ) - Btotal / Ktotal ) ;
}
/*array = cJSON_CreateArray();
for ( i = 0 ; i < sizeof ( myinfo - > linfos ) / sizeof ( * myinfo - > linfos ) ; i + + )
{
if ( myinfo - > linfos [ i ] . base [ 0 ] ! = 0 & & myinfo - > linfos [ i ] . rel [ 0 ] ! = 0 )
jaddi ( array , linfo_json ( & myinfo - > linfos [ i ] ) ) ;
}
jadd ( retjson , " quotes " , array ) ; */
portable_mutex_unlock ( & LP_swaplistmutex ) ;
return ( jprint ( retjson , 1 ) ) ;
}
char * basilisk_swapentry ( uint32_t requestid , uint32_t quoteid )
{
char * liststr , * retstr = 0 ; cJSON * retjson , * array , * item ; int32_t i , n ;
if ( ( liststr = basilisk_swaplist ( requestid , quoteid ) ) ! = 0 )
{
//printf("swapentry.(%s)\n",liststr);
if ( ( retjson = cJSON_Parse ( liststr ) ) ! = 0 )
{
if ( ( array = jarray ( & n , retjson , " swaps " ) ) ! = 0 )
{
for ( i = 0 ; i < n ; i + + )
{
item = jitem ( array , i ) ;
//printf("(%s) check r%u/q%u\n",jprint(item,0),juint(item,"requestid"),juint(item,"quoteid"));
if ( juint ( item , " requestid " ) = = requestid & & juint ( item , " quoteid " ) = = quoteid )
{
retstr = jprint ( item , 0 ) ;
break ;
}
}
}
free_json ( retjson ) ;
}
free ( liststr ) ;
}
return ( retstr ) ;
}
void LP_tradecommand_log ( cJSON * argjson )
{
static FILE * logfp ; char * jsonstr ;
if ( logfp = = 0 )
{
if ( ( logfp = fopen ( " stats.log " , " rb+ " ) ) ! = 0 )
fseek ( logfp , 0 , SEEK_END ) ;
else logfp = fopen ( " stats.log " , " wb " ) ;
}
if ( logfp ! = 0 )
{
jsonstr = jprint ( argjson , 0 ) ;
fprintf ( logfp , " %s \n " , jsonstr ) ;
free ( jsonstr ) ;
fflush ( logfp ) ;
}
}
char * LP_recent_swaps ( int32_t limit )
{
char fname [ 512 ] ; long fsize , offset ; FILE * fp ; int32_t i = 0 ; uint32_t requestid , quoteid ; cJSON * array , * item ;
if ( limit < = 0 )
limit = 3 ;
sprintf ( fname , " %s/SWAPS/list " , GLOBAL_DBDIR ) , OS_compatible_path ( fname ) ;
array = cJSON_CreateArray ( ) ;
if ( ( fp = fopen ( fname , " rb " ) ) ! = 0 )
{
fseek ( fp , 0 , SEEK_END ) ;
fsize = ftell ( fp ) ;
offset = ( sizeof ( requestid ) + sizeof ( quoteid ) ) ;
while ( offset < = fsize )
{
i + + ;
offset = i * ( sizeof ( requestid ) + sizeof ( quoteid ) ) ;
fseek ( fp , fsize - offset , SEEK_SET ) ;
if ( ftell ( fp ) = = fsize - offset )
{
if ( fread ( & requestid , 1 , sizeof ( requestid ) , fp ) = = sizeof ( requestid ) & & fread ( & quoteid , 1 , sizeof ( quoteid ) , fp ) = = sizeof ( quoteid ) )
{
item = cJSON_CreateArray ( ) ;
jaddinum ( item , requestid ) ;
jaddinum ( item , quoteid ) ;
jaddi ( array , item ) ;
} else break ;
} else break ;
}
fclose ( fp ) ;
}
return ( jprint ( array , 1 ) ) ;
}