fix: address serialization in PayForBlobs event (backport #2793) (#2794)

Backports #2793 to the v1.x branch

x/blob/keeper/keeper.go

@@ -54,7 +54,7 @@ func (k Keeper) PayForBlobs(goCtx context.Context, msg *types.MsgPayForBlobs) (*
 	ctx.GasMeter().ConsumeGas(gasToConsume, payForBlobGasDescriptor)
 
 	err := ctx.EventManager().EmitTypedEvent(
-		types.NewPayForBlobsEvent(sdk.AccAddress(msg.Signer).String(), msg.BlobSizes, msg.Namespaces),
+		types.NewPayForBlobsEvent(msg.Signer, msg.BlobSizes, msg.Namespaces),
 	)
 	if err != nil {
 		return &types.MsgPayForBlobsResponse{}, err

x/blob/keeper/keeper_test.go

@@ -0,0 +1,64 @@
+package keeper
+
+import (
+	"bytes"
+	"fmt"
+	"testing"
+
+	"github.com/celestiaorg/celestia-app/pkg/appconsts"
+	appns "github.com/celestiaorg/celestia-app/pkg/namespace"
+	"github.com/celestiaorg/celestia-app/x/blob/types"
+	sdk "github.com/cosmos/cosmos-sdk/types"
+	proto "github.com/gogo/protobuf/proto"
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+	tmproto "github.com/tendermint/tendermint/proto/tendermint/types"
+)
+
+// TestPayForBlobs verifies the attributes on the emitted event.
+func TestPayForBlobs(t *testing.T) {
+	k, stateStore := keeper(t)
+	ctx := sdk.NewContext(stateStore, tmproto.Header{}, false, nil)
+	signer := "celestia15drmhzw5kwgenvemy30rqqqgq52axf5wwrruf7"
+	namespace := appns.MustNewV0(bytes.Repeat([]byte{1}, appns.NamespaceVersionZeroIDSize))
+	namespaces := [][]byte{namespace.Bytes()}
+	blobData := []byte("blob")
+	blobSizes := []uint32{uint32(len(blobData))}
+
+	// verify no events exist yet
+	events := ctx.EventManager().Events().ToABCIEvents()
+	assert.Len(t, events, 0)
+
+	// emit an event by submitting a PayForBlob
+	msg := createMsgPayForBlob(t, signer, namespace, blobData)
+	_, err := k.PayForBlobs(ctx, msg)
+	require.NoError(t, err)
+
+	// verify that an event was emitted
+	events = ctx.EventManager().Events().ToABCIEvents()
+	assert.Len(t, events, 1)
+	protoEvent, err := sdk.ParseTypedEvent(events[0])
+	require.NoError(t, err)
+	event, err := convertToEventPayForBlobs(protoEvent)
+	require.NoError(t, err)
+
+	// verify the attributes of the event
+	assert.Equal(t, signer, event.Signer)
+	assert.Equal(t, namespaces, event.Namespaces)
+	assert.Equal(t, blobSizes, event.BlobSizes)
+}
+
+func convertToEventPayForBlobs(message proto.Message) (*types.EventPayForBlobs, error) {
+	if event, ok := message.(*types.EventPayForBlobs); ok {
+		return event, nil
+	}
+	return nil, fmt.Errorf("message is not of type EventPayForBlobs")
+}
+
+func createMsgPayForBlob(t *testing.T, signer string, namespace appns.Namespace, blobData []byte) *types.MsgPayForBlobs {
+	blob, err := types.NewBlob(namespace, blobData, appconsts.ShareVersionZero)
+	require.NoError(t, err)
+	msg, err := types.NewMsgPayForBlobs(signer, blob)
+	require.NoError(t, err)
+	return msg
+}