From 489e57ce3c46eb9e8ca25c7e966a1ea26fe41d57 Mon Sep 17 00:00:00 2001 From: Chengcheng Zhang <943420582@qq.com> Date: Thu, 11 Jul 2019 16:51:09 +0800 Subject: [PATCH] update log (#259) * update log * update --- database/wallet_store.go | 2 +- wallet/annotated.go | 2 +- wallet/indexer.go | 10 +++++----- wallet/unconfirmed.go | 8 +++++--- wallet/utxo.go | 2 +- wallet/wallet.go | 1 + 6 files changed, 14 insertions(+), 11 deletions(-) diff --git a/database/wallet_store.go b/database/wallet_store.go index 85eb2e16..b810e46a 100644 --- a/database/wallet_store.go +++ b/database/wallet_store.go @@ -246,7 +246,7 @@ func (store *WalletStore) GetGlobalTransactionIndex(txID string) []byte { func (store *WalletStore) GetStandardUTXO(outid bc.Hash) (*acc.UTXO, error) { rawUTXO := store.db.Get(StandardUTXOKey(outid)) if rawUTXO == nil { - return nil, fmt.Errorf("failed get standard UTXO, outputID: %s ", outid.String()) + return nil, wallet.ErrGetStandardUTXO } UTXO := new(acc.UTXO) diff --git a/wallet/annotated.go b/wallet/annotated.go index fe05f7ba..ef8cfc32 100644 --- a/wallet/annotated.go +++ b/wallet/annotated.go @@ -32,7 +32,7 @@ func annotateTxsAsset(w *Wallet, txs []*query.AnnotatedTx) { func (w *Wallet) getExternalDefinition(assetID *bc.AssetID) json.RawMessage { externalAsset, err := w.Store.GetAsset(assetID) - if err != nil { + if err != nil && err != ErrGetAsset { log.WithFields(log.Fields{"module": logModule, "err": err, "assetID": assetID.String()}).Info("fail on get asset definition.") } if externalAsset == nil { diff --git a/wallet/indexer.go b/wallet/indexer.go index 317ee0ed..9f55115a 100644 --- a/wallet/indexer.go +++ b/wallet/indexer.go @@ -106,22 +106,22 @@ transactionLoop: if _, err := w.AccountMgr.GetControlProgram(bc.NewHash(hash)); err == nil { annotatedTxs = append(annotatedTxs, w.buildAnnotatedTransaction(tx, b, statusFail, pos)) continue transactionLoop - } else { - log.WithFields(log.Fields{"module": logModule, "err": err, "hash": hex.EncodeToString(hash[:])}).Info("filterAccountTxs fail.") + } else if err != account.ErrFindCtrlProgram { + log.WithFields(log.Fields{"module": logModule, "err": err, "hash": hex.EncodeToString(hash[:])}).Error("filterAccountTxs fail.") } } for _, v := range tx.Inputs { outid, err := v.SpentOutputID() if err != nil { - log.WithFields(log.Fields{"module": logModule, "err": err, "outputID": hex.EncodeToString(outid.Bytes())}).Info("filterAccountTxs fail.") + log.WithFields(log.Fields{"module": logModule, "err": err, "outputID": outid.String()}).Error("filterAccountTxs fail.") continue } if _, err = w.Store.GetStandardUTXO(outid); err == nil { annotatedTxs = append(annotatedTxs, w.buildAnnotatedTransaction(tx, b, statusFail, pos)) continue transactionLoop - } else { - log.WithFields(log.Fields{"module": logModule, "err": err, "outputID": hex.EncodeToString(outid.Bytes())}).Info("filterAccountTxs fail.") + } else if err != ErrGetStandardUTXO { + log.WithFields(log.Fields{"module": logModule, "err": err, "outputID": outid.String()}).Error("filterAccountTxs fail.") } } } diff --git a/wallet/unconfirmed.go b/wallet/unconfirmed.go index 8effda0a..229cbc58 100644 --- a/wallet/unconfirmed.go +++ b/wallet/unconfirmed.go @@ -1,6 +1,7 @@ package wallet import ( + "encoding/hex" "fmt" "sort" "time" @@ -9,6 +10,7 @@ import ( log "github.com/sirupsen/logrus" + acc "github.com/vapor/account" "github.com/vapor/blockchain/query" "github.com/vapor/crypto/sha3pool" "github.com/vapor/protocol" @@ -113,8 +115,8 @@ func (w *Wallet) checkRelatedTransaction(tx *types.Tx) bool { var hash [32]byte sha3pool.Sum256(hash[:], v.ControlProgram()) cp, err := w.AccountMgr.GetControlProgram(bc.NewHash(hash)) - if err != nil { - log.WithFields(log.Fields{"module": logModule, "err": err, "hash": string(hash[:])}).Error("checkRelatedTransaction fail.") + if err != nil && err != acc.ErrFindCtrlProgram { + log.WithFields(log.Fields{"module": logModule, "err": err, "hash": hex.EncodeToString(hash[:])}).Error("checkRelatedTransaction fail.") continue } if cp != nil { @@ -128,7 +130,7 @@ func (w *Wallet) checkRelatedTransaction(tx *types.Tx) bool { continue } utxo, err := w.Store.GetStandardUTXO(outid) - if err != nil { + if err != nil && err != ErrGetStandardUTXO { log.WithFields(log.Fields{"module": logModule, "err": err, "outputID": outid.String()}).Error("checkRelatedTransaction fail.") continue } diff --git a/wallet/utxo.go b/wallet/utxo.go index 0419dafa..bc60f56c 100644 --- a/wallet/utxo.go +++ b/wallet/utxo.go @@ -121,7 +121,7 @@ func (w *Wallet) filterAccountUtxo(utxos []*account.UTXO) []*account.UTXO { var hash [32]byte sha3pool.Sum256(hash[:], []byte(s)) cp, err := w.AccountMgr.GetControlProgram(bc.NewHash(hash)) - if err != nil { + if err != nil && err != account.ErrFindCtrlProgram { log.WithFields(log.Fields{"module": logModule, "err": err}).Error("filterAccountUtxo fail.") continue } diff --git a/wallet/wallet.go b/wallet/wallet.go index ab865bbd..0a955d21 100644 --- a/wallet/wallet.go +++ b/wallet/wallet.go @@ -29,6 +29,7 @@ var ( ErrGetWalletStatusInfo = errors.New("failed get wallet info") ErrGetAsset = errors.New("Failed to find asset definition") ErrAccntTxIDNotFound = errors.New("account TXID not found") + ErrGetStandardUTXO = errors.New("failed get standard UTXO") ) //StatusInfo is base valid block info to handle orphan block rollback -- 2.11.0