msg_update_metadata.go

package keeper

import (
	"context"

	"cosmossdk.io/orm/types/ormerrors"
	sdk "github.com/cosmos/cosmos-sdk/types"
	sdkerrors "github.com/cosmos/cosmos-sdk/types/errors"

	v1 "github.com/chora-io/mods/geonode/types/v1"
)

// UpdateMetadata implements the Msg/UpdateMetadata method.
func (k Keeper) UpdateMetadata(ctx context.Context, req *v1.MsgUpdateMetadata) (*v1.MsgUpdateMetadataResponse, error) {
	sdkCtx := sdk.UnwrapSDKContext(ctx)

	// get account from curator address
	curator, err := sdk.AccAddressFromBech32(req.Curator)
	if err != nil {
		return nil, err // internal error
	}

	// get node from node table
	node, err := k.ss.NodeTable().Get(ctx, req.Id)
	if err != nil {
		if ormerrors.NotFound.Is(err) {
			return nil, sdkerrors.ErrNotFound.Wrapf("node with id %d: %s", req.Id, err)
		}
		return nil, err // internal error
	}

	// get account from account bytes
	nodeCurator := sdk.AccAddress(node.Curator)

	// verify curator is node curator
	if !nodeCurator.Equals(curator) {
		return nil, sdkerrors.ErrUnauthorized.Wrapf(
			"curator %s: node curator %s", curator, nodeCurator.String(),
		)
	}

	// set new node metadata
	node.Metadata = req.NewMetadata

	// update node in node table
	err = k.ss.NodeTable().Update(ctx, node)
	if err != nil {
		return nil, err // internal error
	}

	// emit event
	if err = sdkCtx.EventManager().EmitTypedEvent(&v1.EventUpdateMetadata{
		Id: node.Id,
	}); err != nil {
		return nil, err // internal error
	}

	// return response
	return &v1.MsgUpdateMetadataResponse{
		Id: node.Id,
	}, nil
}