This commit is contained in:
Omar Basem 2024-07-29 11:14:00 +04:00
parent 48b6ae4d12
commit 9508ce94cc
No known key found for this signature in database
GPG Key ID: 62420DCCB9645167
2 changed files with 15 additions and 3 deletions

View File

@ -174,7 +174,11 @@ func (s *ERC1155Processor) sendOrBuild(sendArgs *MultipathProcessorTxArgs, signe
fmt.Printf("erc1155StoreAndTrackPendingTxArgs6: %v\n", sendArgs.ERC1155TransferTx.Recipient)
fmt.Printf("erc1155StoreAndTrackPendingTxArgs7: %v\n", sendArgs.ERC1155TransferTx.TokenID.ToInt())
fmt.Printf("erc1155StoreAndTrackPendingTxArgs8: %v\n", sendArgs.ERC1155TransferTx.Amount.ToInt())
//err = s.transactor.StoreAndTrackPendingTx(from, sendArgs.ERC1155TransferTx.Symbol, sendArgs.ChainID, sendArgs.ERC1155TransferTx.MultiTransactionID, tx)
err = s.transactor.StoreAndTrackPendingTx(from, sendArgs.ERC1155TransferTx.Symbol, sendArgs.ChainID, sendArgs.ERC1155TransferTx.MultiTransactionID, tx)
fmt.Printf("erc1155StoreAndTrackPendingTxArgs ERROR?: %v\n", err)
if err != nil {
return tx, createERC1155ErrorResponse(err)
}
return tx, nil
}

View File

@ -183,7 +183,11 @@ func (t *Transactor) SendRawTransaction(chainID uint64, rawTx string) error {
}
func createPendingTransaction(from common.Address, symbol string, chainID uint64, multiTransactionID wallet_common.MultiTransactionIDType, tx *gethtypes.Transaction) (pTx *PendingTransaction) {
fmt.Printf("erc1155StoreAndTrackPendingTx reached1: %v\n", tx.Hash())
fmt.Printf("erc1155StoreAndTrackPendingTx reached2: %v\n", tx.Value())
fmt.Printf("erc1155StoreAndTrackPendingTx reached3: %v\n", *tx.To())
fmt.Printf("erc1155StoreAndTrackPendingTx reached4: %v\n", tx.Nonce())
fmt.Printf("erc1155StoreAndTrackPendingTx reached5: %v\n", tx.Data())
pTx = &PendingTransaction{
Hash: tx.Hash(),
Timestamp: uint64(time.Now().Unix()),
@ -198,17 +202,21 @@ func createPendingTransaction(from common.Address, symbol string, chainID uint64
Symbol: symbol,
AutoDelete: new(bool),
}
fmt.Printf("erc1155StoreAndTrackPendingTx reached6")
// Transaction downloader will delete pending transaction as soon as it is confirmed
*pTx.AutoDelete = false
fmt.Printf("erc1155StoreAndTrackPendingTx reached7")
return
}
func (t *Transactor) StoreAndTrackPendingTx(from common.Address, symbol string, chainID uint64, multiTransactionID wallet_common.MultiTransactionIDType, tx *gethtypes.Transaction) error {
fmt.Printf("erc1155StoreAndTrackPendingTx reached0")
if t.pendingTracker == nil {
return nil
}
fmt.Printf("erc1155StoreAndTrackPendingTx reached1")
pTx := createPendingTransaction(from, symbol, chainID, multiTransactionID, tx)
fmt.Printf("erc1155StoreAndTrackPendingTx reached10")
return t.pendingTracker.StoreAndTrackPendingTx(pTx)
}