feat(x/fswap): introduce new event(MakeSwapProposal)

CHANGELOG.md

@@ -58,6 +58,7 @@ Ref: https://keepachangelog.com/en/1.0.0/
 * (server) [\#1175](https://github.com/Finschia/finschia-sdk/pull/1175) Use go embed for swagger
 * (x/collection) [\#1287](https://github.com/Finschia/finschia-sdk/pull/1287) add nft id validation to MsgSendNFT
 * (types) [\#1314](https://github.com/Finschia/finschia-sdk/pull/1314) replace IsEqual with Equal
+* (x/fswap) [\#1363](https://github.com/Finschia/finschia-sdk/pull/1363) introduce new event for MakeSwapProposal
 
 ### Bug Fixes
 * chore(deps) [\#1141](https://github.com/Finschia/finschia-sdk/pull/1141) Bump github.com/cosmos/ledger-cosmos-go from 0.12.2 to 0.13.2 to fix ledger signing issue

docs/core/proto-docs.md

@@ -950,15 +950,16 @@
 
     - [Msg](#lbm.foundation.v1.Msg)
 
-- [lbm/fswap/v1/event.proto](#lbm/fswap/v1/event.proto)
-    - [EventSwapCoins](#lbm.fswap.v1.EventSwapCoins)
-
 - [lbm/fswap/v1/fswap.proto](#lbm/fswap/v1/fswap.proto)
     - [MakeSwapProposal](#lbm.fswap.v1.MakeSwapProposal)
     - [Swap](#lbm.fswap.v1.Swap)
     - [SwapStats](#lbm.fswap.v1.SwapStats)
     - [Swapped](#lbm.fswap.v1.Swapped)
 
+- [lbm/fswap/v1/event.proto](#lbm/fswap/v1/event.proto)
+    - [EventMakeSwapProposal](#lbm.fswap.v1.EventMakeSwapProposal)
+    - [EventSwapCoins](#lbm.fswap.v1.EventSwapCoins)
+
 - [lbm/fswap/v1/genesis.proto](#lbm/fswap/v1/genesis.proto)
     - [GenesisState](#lbm.fswap.v1.GenesisState)
 
@@ -14120,39 +14121,6 @@ Msg defines the foundation Msg service.
 
 
 
-<a name="lbm/fswap/v1/event.proto"></a>
-<p align="right"><a href="#top">Top</a></p>
-
-## lbm/fswap/v1/event.proto
-
-
-
-<a name="lbm.fswap.v1.EventSwapCoins"></a>
-
-### EventSwapCoins
-
-
-
-| Field | Type | Label | Description |
-| ----- | ---- | ----- | ----------- |
-| `address` | [string](#string) |  | holder's address |
-| `from_coin_amount` | [cosmos.base.v1beta1.Coin](#cosmos.base.v1beta1.Coin) |  | from-coin amount |
-| `to_coin_amount` | [cosmos.base.v1beta1.Coin](#cosmos.base.v1beta1.Coin) |  | to-coin amount |
-
-
-
-
-
- <!-- end messages -->
-
- <!-- end enums -->
-
- <!-- end HasExtensions -->
-
- <!-- end services -->
-
-
-
 <a name="lbm/fswap/v1/fswap.proto"></a>
 <p align="right"><a href="#top">Top</a></p>
 
@@ -14226,6 +14194,55 @@ From cosmos-sdk 0.46.0 they deprecated this way, but currently finschia-sdk base
 
 
 
+ <!-- end messages -->
+
+ <!-- end enums -->
+
+ <!-- end HasExtensions -->
+
+ <!-- end services -->
+
+
+
+<a name="lbm/fswap/v1/event.proto"></a>
+<p align="right"><a href="#top">Top</a></p>
+
+## lbm/fswap/v1/event.proto
+
+
+
+<a name="lbm.fswap.v1.EventMakeSwapProposal"></a>
+
+### EventMakeSwapProposal
+
+
+
+| Field | Type | Label | Description |
+| ----- | ---- | ----- | ----------- |
+| `swap` | [Swap](#lbm.fswap.v1.Swap) |  |  |
+| `to_denom_metadata` | [cosmos.bank.v1beta1.Metadata](#cosmos.bank.v1beta1.Metadata) |  |  |
+
+
+
+
+
+
+<a name="lbm.fswap.v1.EventSwapCoins"></a>
+
+### EventSwapCoins
+
+
+
+| Field | Type | Label | Description |
+| ----- | ---- | ----- | ----------- |
+| `address` | [string](#string) |  | holder's address |
+| `from_coin_amount` | [cosmos.base.v1beta1.Coin](#cosmos.base.v1beta1.Coin) |  | from-coin amount |
+| `to_coin_amount` | [cosmos.base.v1beta1.Coin](#cosmos.base.v1beta1.Coin) |  | to-coin amount |
+
+
+
+
+
  <!-- end messages -->
 
  <!-- end enums -->

proto/lbm/fswap/v1/event.proto

@@ -5,6 +5,8 @@ option go_package = "github.com/Finschia/finschia-sdk/x/fswap/types";
 
 import "gogoproto/gogo.proto";
 import "cosmos/base/v1beta1/coin.proto";
+import "cosmos/bank/v1beta1/bank.proto";
+import "lbm/fswap/v1/fswap.proto";
 
 message EventSwapCoins {
   // holder's address
@@ -16,3 +18,9 @@ message EventSwapCoins {
   cosmos.base.v1beta1.Coin to_coin_amount = 3
       [(gogoproto.nullable) = false, (gogoproto.castrepeated) = "github.com/Finschia/finschia-sdk/types.Coin"];
 }
+
+message EventMakeSwapProposal {
+  Swap                         swap              = 1 [(gogoproto.nullable) = false];
+  cosmos.bank.v1beta1.Metadata to_denom_metadata = 2
+      [(gogoproto.moretags) = "yaml:\"denom_metadata\"", (gogoproto.nullable) = false];
+}

x/fswap/keeper/proposal.go

@@ -56,6 +56,7 @@
 	existingMetadata, ok := k.GetDenomMetaData(ctx, swap.ToDenom)
 	if !ok {
 		k.SetDenomMetaData(ctx, toDenomMetadata)
+		emitMakeSwapProposalEvent(ctx, swap, toDenomMetadata)
 		return nil
 	}
 	if !denomMetadataEqual(existingMetadata, toDenomMetadata) {
@@ -65,6 +66,15 @@
 	return nil
 }
 
+func emitMakeSwapProposalEvent(ctx sdk.Context, swap types.Swap, toDenomMetadata bank.Metadata) {
+	if err := ctx.EventManager().EmitTypedEvent(&(types.EventMakeSwapProposal{
+		Swap:            swap,
+		ToDenomMetadata: toDenomMetadata,
+	})); err != nil {
+		panic(err)
+	}
+}
+
 func denomMetadataEqual(metadata, otherMetadata bank.Metadata) bool {
 	if metadata.Description != otherMetadata.Description {
 		return false

x/fswap/keeper/proposal_test.go

@@ -1,6 +1,10 @@
 package keeper_test
 
 import (
+	"fmt"
+
+	abci "github.com/tendermint/tendermint/abci/types"
+
 	sdk "github.com/Finschia/finschia-sdk/types"
 	sdkerrors "github.com/Finschia/finschia-sdk/types/errors"
 	bank "github.com/Finschia/finschia-sdk/x/bank/types"
@@ -13,6 +17,7 @@ func (s *KeeperTestSuite) TestMakeSwapProposal() {
 		toDenomMeta      bank.Metadata
 		existingMetadata bool
 		expectedError    error
+		expectedEvent    sdk.Event
 	}{
 		"valid": {
 			types.Swap{
@@ -24,6 +29,21 @@ func (s *KeeperTestSuite) TestMakeSwapProposal() {
 			s.toDenomMetadata,
 			false,
 			nil,
+			sdk.Event{
+				Type: "lbm.fswap.v1.EventMakeSwapProposal",
+				Attributes: []abci.EventAttribute{
+					{
+						Key:   []byte("swap"),
+						Value: []uint8{0x7b, 0x22, 0x66, 0x72, 0x6f, 0x6d, 0x5f, 0x64, 0x65, 0x6e, 0x6f, 0x6d, 0x22, 0x3a, 0x22, 0x66, 0x72, 0x6f, 0x6d, 0x44, 0x22, 0x2c, 0x22, 0x74, 0x6f, 0x5f, 0x64, 0x65, 0x6e, 0x6f, 0x6d, 0x22, 0x3a, 0x22, 0x74, 0x6f, 0x44, 0x22, 0x2c, 0x22, 0x61, 0x6d, 0x6f, 0x75, 0x6e, 0x74, 0x5f, 0x63, 0x61, 0x70, 0x5f, 0x66, 0x6f, 0x72, 0x5f, 0x74, 0x6f, 0x5f, 0x64, 0x65, 0x6e, 0x6f, 0x6d, 0x22, 0x3a, 0x22, 0x31, 0x22, 0x2c, 0x22, 0x73, 0x77, 0x61, 0x70, 0x5f, 0x72, 0x61, 0x74, 0x65, 0x22, 0x3a, 0x22, 0x31, 0x2e, 0x30, 0x30, 0x30, 0x30, 0x30, 0x30, 0x30, 0x30, 0x30, 0x30, 0x30, 0x30, 0x30, 0x30, 0x30, 0x30, 0x30, 0x30, 0x22, 0x7d},
+						Index: false,
+					},
+					{
+						Key:   []byte("to_denom_metadata"),
+						Value: []uint8{0x7b, 0x22, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x3a, 0x22, 0x54, 0x68, 0x69, 0x73, 0x20, 0x69, 0x73, 0x20, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x20, 0x66, 0x6f, 0x72, 0x20, 0x74, 0x6f, 0x2d, 0x63, 0x6f, 0x69, 0x6e, 0x22, 0x2c, 0x22, 0x64, 0x65, 0x6e, 0x6f, 0x6d, 0x5f, 0x75, 0x6e, 0x69, 0x74, 0x73, 0x22, 0x3a, 0x5b, 0x7b, 0x22, 0x64, 0x65, 0x6e, 0x6f, 0x6d, 0x22, 0x3a, 0x22, 0x74, 0x6f, 0x64, 0x65, 0x6e, 0x6f, 0x6d, 0x22, 0x2c, 0x22, 0x65, 0x78, 0x70, 0x6f, 0x6e, 0x65, 0x6e, 0x74, 0x22, 0x3a, 0x30, 0x2c, 0x22, 0x61, 0x6c, 0x69, 0x61, 0x73, 0x65, 0x73, 0x22, 0x3a, 0x5b, 0x5d, 0x7d, 0x5d, 0x2c, 0x22, 0x62, 0x61, 0x73, 0x65, 0x22, 0x3a, 0x22, 0x64, 0x75, 0x6d, 0x6d, 0x79, 0x22, 0x2c, 0x22, 0x64, 0x69, 0x73, 0x70, 0x6c, 0x61, 0x79, 0x22, 0x3a, 0x22, 0x64, 0x75, 0x6d, 0x6d, 0x79, 0x63, 0x6f, 0x69, 0x6e, 0x22, 0x2c, 0x22, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x3a, 0x22, 0x44, 0x55, 0x4d, 0x4d, 0x59, 0x22, 0x2c, 0x22, 0x73, 0x79, 0x6d, 0x62, 0x6f, 0x6c, 0x22, 0x3a, 0x22, 0x44, 0x55, 0x4d, 0x22, 0x7d},
+						Index: false,
+					},
+				},
+			},
 		},
 		"to-denom metadata change not allowed": {
 			types.Swap{
@@ -42,6 +62,7 @@ func (s *KeeperTestSuite) TestMakeSwapProposal() {
 			},
 			true,
 			sdkerrors.ErrInvalidRequest,
+			sdk.Event{},
 		},
 	}
 	for name, tc := range testCases {
@@ -51,9 +72,15 @@ func (s *KeeperTestSuite) TestMakeSwapProposal() {
 			if tc.existingMetadata {
 				err := s.keeper.MakeSwap(ctx, tc.swap, s.toDenomMetadata)
 				s.Require().ErrorIs(err, tc.expectedError)
-			} else {
-				s.Require().ErrorIs(err, tc.expectedError)
+				return
 			}
+
+			s.Require().ErrorIs(err, tc.expectedError)
+			events := ctx.EventManager().Events()
+			s.Require().Len(events, 1)
+			actualEvent := events[0]
+			fmt.Printf("%#v\n", actualEvent)
+			s.Require().Equal(tc.expectedEvent, actualEvent)
 		})
 	}
 }