Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
FelixFan1992 committed May 28, 2024
1 parent a0915fa commit 4264953
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 18 deletions.
5 changes: 0 additions & 5 deletions core/services/ocrcommon/transmitter.go
Original file line number Diff line number Diff line change
Expand Up @@ -124,12 +124,7 @@ func (t *transmitter) CreateEthTransaction(ctx context.Context, toAddress common
return errors.Wrap(err, "skipped OCR transmission, error getting round-robin address")
}

var key *string
if txMeta.UpkeepID != nil {
key = txMeta.UpkeepID
}
_, err = t.txm.CreateTransaction(ctx, txmgr.TxRequest{
IdempotencyKey: key,
FromAddress: roundRobinFromAddress,
ToAddress: toAddress,
EncodedPayload: payload,
Expand Down
13 changes: 0 additions & 13 deletions core/services/relay/evm/ocr2keeper.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@ import (
"fmt"

"github.com/ethereum/go-ethereum/common"
"github.com/google/uuid"
"github.com/pkg/errors"

"github.com/smartcontractkit/libocr/offchainreporting2plus/chains/evmutil"
Expand Down Expand Up @@ -179,18 +178,6 @@ func (t *ocr3keeperProviderContractTransmitter) Transmit(
reportWithInfo ocr3types.ReportWithInfo[plugin.AutomationReportInfo],
aoss []ocrtypes.AttributedOnchainSignature,
) error {

// for zk chains, the batch size should be set to 1 in order to figure out which upkeep is responsible for a possible
// overflown tx
if len(reportWithInfo.Info.UpkeepIDs) == 1 {
id := uuid.New()
uid := reportWithInfo.Info.UpkeepIDs[0]
err := t.txStatusStore.SaveTxInfo(id, uid)
if err != nil {
t.lggr.Errorf("failed to save tx info into tx status key %s for upkeep ID %s due to %s", id.String(), uid, err.Error())
}
}

return t.contractTransmitter.Transmit(
ctx,
ocrtypes.ReportContext{
Expand Down

0 comments on commit 4264953

Please sign in to comment.