Merge feat/record_transaction branch and fix comments.

This commit is contained in:
maskpp
2023-04-24 14:37:30 +08:00
44 changed files with 930 additions and 181 deletions

View File

@@ -117,7 +117,7 @@ type ScrollTxOrm interface {
SaveScrollTx(id, sender string, txType types.ScrollTxType, tx *etypes.Transaction, extraData string) error
SetScrollTxConfirmedByID(hash string, txHash string) error
GetScrollTxs(fields map[string]interface{}, args ...string) ([]*types.ScrollTx, error)
GetTxByID(id string) (*types.ScrollTx, error)
GetScrollTxByID(id string) (*types.ScrollTx, error)
GetL1TxMessages(fields map[string]interface{}, args ...string) (uint64, []*types.ScrollTx, error)
GetL2TxMessages(fields map[string]interface{}, args ...string) (uint64, []*types.ScrollTx, error)
GetBlockBatchTxMessages(fields map[string]interface{}, args ...string) (uint64, []*types.ScrollTx, error)

View File

@@ -78,8 +78,8 @@ func (t *scrollTxOrm) GetScrollTxs(fields map[string]interface{}, args ...string
return txMsgs, nil
}
// GetTxByID returns tx message by message id.
func (t *scrollTxOrm) GetTxByID(id string) (*stypes.ScrollTx, error) {
// GetScrollTxByID returns tx message by message id.
func (t *scrollTxOrm) GetScrollTxByID(id string) (*stypes.ScrollTx, error) {
db := t.db
row := db.QueryRowx(db.Rebind("SELECT id, tx_hash, sender, nonce, target, value, data FROM scroll_transaction WHERE id = ?"), id)
txMsg := &stypes.ScrollTx{}

View File

@@ -479,7 +479,7 @@ func testTxOrmSaveTxAndGetTxByHash(t *testing.T) {
err = ormTx.SetScrollTxConfirmedByID("1", signedTx.Hash().String())
assert.NoError(t, err)
savedTx, err := ormTx.GetTxByID("1")
savedTx, err := ormTx.GetScrollTxByID("1")
assert.NoError(t, err)
assert.Equal(t, signedTx.Hash().String(), savedTx.TxHash.String)