From 26da1203f3d5d0d6ed55ad9c548b225bb845c4d7 Mon Sep 17 00:00:00 2001 From: Chengcheng Zhang <943420582@qq.com> Date: Fri, 28 Jun 2019 16:25:34 +0800 Subject: [PATCH] update SetUnconfirmedTransaction --- database/wallet_store.go | 7 ++++++- wallet/store.go | 2 +- wallet/unconfirmed.go | 6 +----- 3 files changed, 8 insertions(+), 7 deletions(-) diff --git a/database/wallet_store.go b/database/wallet_store.go index f21d067d..362f96b3 100644 --- a/database/wallet_store.go +++ b/database/wallet_store.go @@ -384,12 +384,17 @@ func (store *WalletStore) GetUnconfirmedTransaction(txID string) (*query.Annotat } // SetUnconfirmedTransaction set unconfirmed tx by txID -func (store *WalletStore) SetUnconfirmedTransaction(txID string, rawTx []byte) { +func (store *WalletStore) SetUnconfirmedTransaction(txID string, tx *query.AnnotatedTx) error { + rawTx, err := json.Marshal(tx) + if err != nil { + return err + } if store.batch == nil { store.walletDB.Set(calcUnconfirmedTxKey(txID), rawTx) } else { store.batch.Set(calcUnconfirmedTxKey(txID), rawTx) } + return nil } // DeleteStardardUTXO delete stardard utxo by outputID diff --git a/wallet/store.go b/wallet/store.go index 13b29634..9478a1d4 100644 --- a/wallet/store.go +++ b/wallet/store.go @@ -26,7 +26,7 @@ type WalletStorer interface { GetTransactions() ([]*query.AnnotatedTx, error) GetUnconfirmedTransactions() ([]*query.AnnotatedTx, error) GetUnconfirmedTransaction(string) (*query.AnnotatedTx, error) - SetUnconfirmedTransaction(string, []byte) + SetUnconfirmedTransaction(string, *query.AnnotatedTx) error DeleteStardardUTXO(bc.Hash) DeleteContractUTXO(bc.Hash) SetStandardUTXO(bc.Hash, []byte) diff --git a/wallet/unconfirmed.go b/wallet/unconfirmed.go index 5942965f..2df04d7c 100644 --- a/wallet/unconfirmed.go +++ b/wallet/unconfirmed.go @@ -1,7 +1,6 @@ package wallet import ( - "encoding/json" "fmt" "sort" "time" @@ -143,12 +142,9 @@ func (w *Wallet) saveUnconfirmedTx(tx *types.Tx) error { annotatedTxs = append(annotatedTxs, annotatedTx) annotateTxsAccount(annotatedTxs, w.store) - rawTx, err := json.Marshal(annotatedTxs[0]) - if err != nil { + if err := w.store.SetUnconfirmedTransaction(tx.ID.String(), annotatedTxs[0]); err != nil { return err } - - w.store.SetUnconfirmedTransaction(tx.ID.String(), rawTx) return nil } -- 2.11.0