From d8e8397ddc9d8ed067aa449ccb8f23c5aecf5454 Mon Sep 17 00:00:00 2001 From: "mergify[bot]" <37929162+mergify[bot]@users.noreply.github.com> Date: Wed, 4 Sep 2024 16:50:41 -0500 Subject: [PATCH] refactor: remove processed key and handling code (#216) (#218) * refactor: remove processed key and handling code * refactor: ensure the underlying apps `OnRecvPacket` callback is invoked * docs: fix broken link to Defund-Labs interquery. I cannot find a link to the code so this now links to the spec (cherry picked from commit 8cb681e31589bc90b47e0ab58173a579825fd56d) Co-authored-by: Justin Tieri <37750742+jtieri@users.noreply.github.com> --- README.md | 2 +- .../packetforward/ibc_middleware.go | 12 +++--------- .../packetforward/types/keys.go | 1 - 3 files changed, 4 insertions(+), 11 deletions(-) diff --git a/README.md b/README.md index 38906a07..dccf0f25 100644 --- a/README.md +++ b/README.md @@ -79,7 +79,7 @@ Modules and middleware developed by other awesome teams in the ecosystem: | Name | Type | Stakeholders | Description | | ---- | ---- | ------------ | ----------- | | [Interchain KV Queries](https://github.com/ingenuity-build/interchain-queries) | Module | [Ingenuity](https://github.com/ingenuity-build) | An application that enables on chain querying of another IBC enabled chains state without the need for the chain being queried to implement the application. | -| [query](https://github.com/defund-labs/defund/tree/main/x/query) | Module | [Defund Labs](https://github.com/defund-labs) | An application that enables on chain querying of another IBC enabled chains state without the need for the chain being queried to implement the application. Similar to the interchain-queries application in the row above but without callbacks. | +| [query](https://github.com/defund-labs/interquery) | Module | [Defund Labs](https://github.com/defund-labs) | An application that enables on chain querying of another IBC enabled chains state without the need for the chain being queried to implement the application. Similar to the interchain-queries application in the row above but without callbacks. | | [NFT Transfer (ICS 721)](https://github.com/bianjieai/nft-transfer) | Module | [Bianjieai](https://github.com/bianjieai) | An application that enables cross chain NFT transfer. | | [CosmWasm NFT Transfer (ICS 721)](https://github.com/public-awesome/cw-ics721) | WASM Contract | [Public Awesome (Stargaze)](https://github.com/public-awesome), [Ark Protocol](https://twitter.com/ArkProtocol) | An application that enables cross chain NFT transfer. CosmWasm implementation of the above, written in Rust. | | [recovery](https://github.com/evmos/evmos/tree/main/x/recovery) | Middleware | [Evmos](https://github.com/evmos) | Middleware enabling the recovery of tokens sent to unsupported addresses. | diff --git a/middleware/packet-forward-middleware/packetforward/ibc_middleware.go b/middleware/packet-forward-middleware/packetforward/ibc_middleware.go index b3632ddd..86ec925c 100644 --- a/middleware/packet-forward-middleware/packetforward/ibc_middleware.go +++ b/middleware/packet-forward-middleware/packetforward/ibc_middleware.go @@ -198,7 +198,6 @@ func (im IBCMiddleware) OnRecvPacket( metadata := m.Forward goCtx := ctx.Context() - processed := getBoolFromAny(goCtx.Value(types.ProcessedKey{})) nonrefundable := getBoolFromAny(goCtx.Value(types.NonrefundableKey{})) disableDenomComposition := getBoolFromAny(goCtx.Value(types.DisableDenomCompositionKey{})) @@ -214,14 +213,9 @@ func (im IBCMiddleware) OnRecvPacket( return newErrorAcknowledgement(fmt.Errorf("failed to construct override receiver: %w", err)) } - // if this packet has been handled by another middleware in the stack there may be no need to call into the - // underlying app, otherwise the transfer module's OnRecvPacket callback could be invoked more than once - // which would mint/burn vouchers more than once - if !processed { - if err := im.receiveFunds(ctx, packet, data, overrideReceiver, relayer); err != nil { - logger.Error("packetForwardMiddleware OnRecvPacket error receiving packet", "error", err) - return newErrorAcknowledgement(fmt.Errorf("error receiving packet: %w", err)) - } + if err := im.receiveFunds(ctx, packet, data, overrideReceiver, relayer); err != nil { + logger.Error("packetForwardMiddleware OnRecvPacket error receiving packet", "error", err) + return newErrorAcknowledgement(fmt.Errorf("error receiving packet: %w", err)) } // if this packet's token denom is already the base denom for some native token on this chain, diff --git a/middleware/packet-forward-middleware/packetforward/types/keys.go b/middleware/packet-forward-middleware/packetforward/types/keys.go index 700623d4..072702c6 100644 --- a/middleware/packet-forward-middleware/packetforward/types/keys.go +++ b/middleware/packet-forward-middleware/packetforward/types/keys.go @@ -16,7 +16,6 @@ const ( type ( NonrefundableKey struct{} DisableDenomCompositionKey struct{} - ProcessedKey struct{} ) func RefundPacketKey(channelID, portID string, sequence uint64) []byte {