DragonX/dragonx
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

test

Browse Source
This commit is contained in:
jl777
2016-10-30 09:09:33 -03:00
parent bd6bd0b185
commit 63b289ade0
1 changed files with 48 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

75
src/komodo_gateway.h
View File

@@ -24,11 +24,51 @@ struct pax_transaction
char symbol[4]; uint8_t rmd160[20],shortflag; char symbol[4]; uint8_t rmd160[20],shortflag;
}; };
int32_t komodo_issued_opreturn(int32_t *shortflagp,char *base,uint256 *txids,uint16_t *vouts,uint8_t *opretbuf,int32_t opretlen)
{
int32_t i,n,j,len;
if ( opretbuf[opretlen-5] == '-' )
*shortflagp = 1;
else *shortflagp = 0;
for (i=0; i<4; i++)
base[i] = opretbuf[opretlen-4+i];
printf("BASE.(%s) vs (%s)\n",base,ASSETCHAINS_SYMBOL);
if ( strncmp(ASSETCHAINS_SYMBOL,base,strlen(base)) == 0 ) // shortflag
{
opretbuf++, opretlen--;
for (n=len=0; n<opretlen/34; n++)
{
for (j=0; j<32; j++)
{
((uint8_t *)&txids[n])[j] = opretbuf[len++];
printf("%02x",((uint8_t *)&txids[n])[j]);
}
vouts[n] = opretbuf[len++];
vouts[n] = (opretbuf[len++] << 8) | vouts[n];
printf(" issuedtxid v%d i.%d opretlen.%d\n",vouts[n],n,opretlen);
if ( komodo_gateway_depositremove(txids[n],vouts[n]) == 0 )
printf("error removing deposit\n");
}
}
return(n);
}
int32_t komodo_check_deposit(const CBlock& block) // verify above block is valid pax pricing
{
int32_t i,n;
n = block.vout.size();
for (i=1; i<n; i++)
{
}
return(0);
}
void komodo_gateway_deposits(CMutableTransaction *txNew) void komodo_gateway_deposits(CMutableTransaction *txNew)
{ {
struct pax_transaction *ptr; uint8_t *script,opret[10000],data[10000]; int32_t i,len=0,opretlen=0,numvouts=1; struct pax_transaction *ptr; uint8_t *script,opret[10000],data[10000]; int32_t i,len=0,opretlen=0,numvouts=1;
PENDING_KOMODO_TX = 0; PENDING_KOMODO_TX = 0;
while ( (ptr= (struct pax_transaction *)queue_dequeue(&DepositsQ)) != 0 ) while ( numvouts < 64 && (ptr= (struct pax_transaction *)queue_dequeue(&DepositsQ)) != 0 )
{ {
txNew->vout.resize(numvouts+1); txNew->vout.resize(numvouts+1);
txNew->vout[numvouts].nValue = ptr->fiatoshis; txNew->vout[numvouts].nValue = ptr->fiatoshis;
@@ -71,12 +111,6 @@ void komodo_gateway_deposits(CMutableTransaction *txNew)
} else KOMODO_DEPOSIT = 0; } else KOMODO_DEPOSIT = 0;
} }
int32_t komodo_check_deposit(const CBlock& block) // verify above block is valid pax pricing
{
// reenable rpc auth
return(0);
}
void komodo_gateway_deposit(char *coinaddr,uint64_t value,int32_t shortflag,char *symbol,uint64_t fiatoshis,uint8_t *rmd160,uint256 txid,uint16_t vout) // assetchain context void komodo_gateway_deposit(char *coinaddr,uint64_t value,int32_t shortflag,char *symbol,uint64_t fiatoshis,uint8_t *rmd160,uint256 txid,uint16_t vout) // assetchain context
{ {
struct pax_transaction *ptr; struct pax_transaction *ptr;
@@ -128,7 +162,7 @@ int32_t komodo_gateway_depositremove(uint256 txid,uint16_t vout) // assetchain c
const char *komodo_opreturn(int32_t height,uint64_t value,uint8_t *opretbuf,int32_t opretlen,uint256 txid,uint16_t vout) const char *komodo_opreturn(int32_t height,uint64_t value,uint8_t *opretbuf,int32_t opretlen,uint256 txid,uint16_t vout)
{ {
uint8_t rmd160[20],addrtype,shortflag,pubkey33[33]; int32_t i,j,len,tokomodo=0; char base[4],coinaddr[64],destaddr[64]; int64_t fiatoshis,checktoshis; const char *typestr = "unknown"; uint8_t rmd160[20],addrtype,shortflag,pubkey33[33]; int32_t i,j,len,tokomodo=0; char base[4],coinaddr[64],destaddr[64]; uint256 txids[64]; uint16_t vouts[64]; int64_t fiatoshis,checktoshis; const char *typestr = "unknown";
tokomodo = (komodo_is_issuer() == 0); tokomodo = (komodo_is_issuer() == 0);
if ( opretbuf[0] == ((tokomodo == 0) ? 'D' : 'W') ) if ( opretbuf[0] == ((tokomodo == 0) ? 'D' : 'W') )
{ {
@@ -171,29 +205,16 @@ const char *komodo_opreturn(int32_t height,uint64_t value,uint8_t *opretbuf,int3
for (i=0; i<opretlen; i++) for (i=0; i<opretlen; i++)
printf("%02x",opretbuf[i]); printf("%02x",opretbuf[i]);
printf(" komodo_opreturn[%c]: ht.%d %.8f opretlen.%d\n",opretbuf[0],height,dstr(value),opretlen); printf(" komodo_opreturn[%c]: ht.%d %.8f opretlen.%d\n",opretbuf[0],height,dstr(value),opretlen);
if ( tokomodo == 0 ) // shortflag if ( tokomodo == 0 && opretbuf[0] == 'I' )
{ {
if ( opretbuf[opretlen-5] == '-' ) if ( (n= komodo_issued_opreturn(&shortflag,base,txids,vouts,opretbuf,opretlen)) > 0 )
shortflag = 1;
else shortflag = 0;
for (i=0; i<4; i++)
base[i] = opretbuf[opretlen-4+i];
printf("BASE.(%s) vs (%s)\n",base,ASSETCHAINS_SYMBOL);
if ( strncmp(ASSETCHAINS_SYMBOL,base,strlen(base)) == 0 && opretbuf[0] == 'I' )
{ {
uint256 issuedtxid; uint16_t issuedvout; for (i=0; i<n; i++)
opretbuf++, opretlen--;
for (i=len=0; i<opretlen/34; i++)
{ {
for (j=0; j<32; j++) for (j=0; j<32; j++)
{ printf("%02x",((uint8_t *)&txids)[j]);
((uint8_t *)&issuedtxid)[j] = opretbuf[len++]; printf(" issuedtxid v%d i.%d opretlen.%d\n",vouts[i],i,opretlen);
printf("%02x",((uint8_t *)&issuedtxid)[j]); if ( komodo_gateway_depositremove(txids[i],vouts[i]) == 0 )
}
issuedvout = opretbuf[len++];
issuedvout = (opretbuf[len++] << 8) | issuedvout;
printf(" issuedtxid v%d i.%d opretlen.%d\n",issuedvout,i,opretlen);
if ( komodo_gateway_depositremove(issuedtxid,issuedvout) == 0 )
printf("error removing deposit\n"); printf("error removing deposit\n");
} }
} }