From cf57648d7d414d59410efef606708bc75264b123 Mon Sep 17 00:00:00 2001 From: Giulio rebuffo Date: Fri, 8 Jul 2022 16:25:51 +0200 Subject: [PATCH] envelope (#518) --- txpool/fetch.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/txpool/fetch.go b/txpool/fetch.go index 873fa642f..bc42a0bb5 100644 --- a/txpool/fetch.go +++ b/txpool/fetch.go @@ -444,7 +444,7 @@ func (f *Fetch) handleStateChanges(ctx context.Context, client StateChangesClien for i := range change.Txs { minedTxs.Txs[i] = &types2.TxSlot{} if err = f.threadSafeParseStateChangeTxn(func(parseContext *types2.TxParseContext) error { - _, err := parseContext.ParseTransaction(change.Txs[i], 0, minedTxs.Txs[i], minedTxs.Senders.At(i), true /* hasEnvelope */, nil) + _, err := parseContext.ParseTransaction(change.Txs[i], 0, minedTxs.Txs[i], minedTxs.Senders.At(i), false /* hasEnvelope */, nil) return err }); err != nil { log.Warn("stream.Recv", "err", err) @@ -457,7 +457,7 @@ func (f *Fetch) handleStateChanges(ctx context.Context, client StateChangesClien for i := range change.Txs { unwindTxs.Txs[i] = &types2.TxSlot{} if err = f.threadSafeParseStateChangeTxn(func(parseContext *types2.TxParseContext) error { - _, err = parseContext.ParseTransaction(change.Txs[i], 0, unwindTxs.Txs[i], unwindTxs.Senders.At(i), true /* hasEnvelope */, nil) + _, err = parseContext.ParseTransaction(change.Txs[i], 0, unwindTxs.Txs[i], unwindTxs.Senders.At(i), false /* hasEnvelope */, nil) return err }); err != nil { log.Warn("stream.Recv", "err", err)