mirror of
https://github.com/0glabs/0g-chain.git
synced 2024-10-04 00:15:17 +00:00
741f1e42ee
* feat(evmutil): implement MsgConvertCosmosCoinToERC20 * docs(evmutil): update module spec * update changelog * rename conversion -> conversion_evm_native * refactor ConvertCosmosCoinToERC20 to keeper method * add CLI cmd for MsgConvertCosmosCoinToERC20 * updates from pr
146 lines
3.6 KiB
Go
146 lines
3.6 KiB
Go
package keeper
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
sdk "github.com/cosmos/cosmos-sdk/types"
|
|
|
|
"github.com/kava-labs/kava/x/evmutil/types"
|
|
)
|
|
|
|
type msgServer struct {
|
|
keeper Keeper
|
|
}
|
|
|
|
// NewMsgServerImpl returns an implementation of the evmutil MsgServer interface
|
|
// for the provided Keeper.
|
|
func NewMsgServerImpl(keeper Keeper) types.MsgServer {
|
|
return &msgServer{keeper: keeper}
|
|
}
|
|
|
|
var _ types.MsgServer = msgServer{}
|
|
|
|
////////////////////////////
|
|
// EVM-native assets -> Cosmos SDK
|
|
////////////////////////////
|
|
|
|
// ConvertCoinToERC20 handles a MsgConvertCoinToERC20 message to convert
|
|
// sdk.Coin to Kava EVM tokens.
|
|
func (s msgServer) ConvertCoinToERC20(
|
|
goCtx context.Context,
|
|
msg *types.MsgConvertCoinToERC20,
|
|
) (*types.MsgConvertCoinToERC20Response, error) {
|
|
ctx := sdk.UnwrapSDKContext(goCtx)
|
|
|
|
initiator, err := sdk.AccAddressFromBech32(msg.Initiator)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("invalid Initiator address: %w", err)
|
|
}
|
|
|
|
receiver, err := types.NewInternalEVMAddressFromString(msg.Receiver)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("invalid Receiver address: %w", err)
|
|
}
|
|
|
|
if err := s.keeper.ConvertCoinToERC20(
|
|
ctx,
|
|
initiator,
|
|
receiver,
|
|
*msg.Amount,
|
|
); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
ctx.EventManager().EmitEvent(
|
|
sdk.NewEvent(
|
|
sdk.EventTypeMessage,
|
|
sdk.NewAttribute(sdk.AttributeKeyModule, types.AttributeValueCategory),
|
|
sdk.NewAttribute(sdk.AttributeKeySender, msg.Initiator),
|
|
),
|
|
)
|
|
|
|
return &types.MsgConvertCoinToERC20Response{}, nil
|
|
}
|
|
|
|
// ConvertERC20ToCoin handles a MsgConvertERC20ToCoin message to convert
|
|
// sdk.Coin to Kava EVM tokens.
|
|
func (s msgServer) ConvertERC20ToCoin(
|
|
goCtx context.Context,
|
|
msg *types.MsgConvertERC20ToCoin,
|
|
) (*types.MsgConvertERC20ToCoinResponse, error) {
|
|
ctx := sdk.UnwrapSDKContext(goCtx)
|
|
|
|
initiator, err := types.NewInternalEVMAddressFromString(msg.Initiator)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("invalid initiator address: %w", err)
|
|
}
|
|
|
|
receiver, err := sdk.AccAddressFromBech32(msg.Receiver)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("invalid receiver address: %w", err)
|
|
}
|
|
|
|
contractAddr, err := types.NewInternalEVMAddressFromString(msg.KavaERC20Address)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("invalid contract address: %w", err)
|
|
}
|
|
|
|
if err := s.keeper.ConvertERC20ToCoin(
|
|
ctx,
|
|
initiator,
|
|
receiver,
|
|
contractAddr,
|
|
msg.Amount,
|
|
); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
ctx.EventManager().EmitEvent(
|
|
sdk.NewEvent(
|
|
sdk.EventTypeMessage,
|
|
sdk.NewAttribute(sdk.AttributeKeyModule, types.AttributeValueCategory),
|
|
sdk.NewAttribute(sdk.AttributeKeySender, msg.Initiator),
|
|
),
|
|
)
|
|
|
|
return &types.MsgConvertERC20ToCoinResponse{}, nil
|
|
}
|
|
|
|
////////////////////////////
|
|
// Cosmos SDK-native assets -> EVM
|
|
////////////////////////////
|
|
|
|
// ConvertCosmosCoinToERC20 converts a native sdk.Coin to an ERC20.
|
|
// If no ERC20 contract has been deployed for the given denom, a new
|
|
// contract will be deployed and registered to the module.
|
|
func (s msgServer) ConvertCosmosCoinToERC20(
|
|
goCtx context.Context,
|
|
msg *types.MsgConvertCosmosCoinToERC20,
|
|
) (*types.MsgConvertCosmosCoinToERC20Response, error) {
|
|
ctx := sdk.UnwrapSDKContext(goCtx)
|
|
|
|
initiator, err := sdk.AccAddressFromBech32(msg.Initiator)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("invalid initiator address: %w", err)
|
|
}
|
|
|
|
receiver, err := types.NewInternalEVMAddressFromString(msg.Receiver)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("invalid receiver address: %w", err)
|
|
}
|
|
|
|
if err := s.keeper.ConvertCosmosCoinToERC20(
|
|
ctx,
|
|
initiator,
|
|
receiver,
|
|
*msg.Amount,
|
|
); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// TODO: emit message event
|
|
|
|
return &types.MsgConvertCosmosCoinToERC20Response{}, nil
|
|
}
|