Skip to content

Commit

Permalink
remove eventService
Browse files Browse the repository at this point in the history
  • Loading branch information
likhita-809 committed Feb 15, 2024
1 parent 0915644 commit 7455663
Show file tree
Hide file tree
Showing 4 changed files with 2 additions and 22 deletions.
1 change: 0 additions & 1 deletion simapp/app.go
Original file line number Diff line number Diff line change
Expand Up @@ -289,7 +289,6 @@ func NewSimApp(
accountsKeeper, err := accounts.NewKeeper(
appCodec,
runtime.NewEnvironment(runtime.NewKVStoreService(keys[accounts.StoreKey]), logger),
runtime.EventService{},
addressCodec,
appCodec,
app.MsgServiceRouter(),
Expand Down
4 changes: 0 additions & 4 deletions x/accounts/keeper.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@ import (
"cosmossdk.io/collections"
"cosmossdk.io/core/address"
"cosmossdk.io/core/appmodule"
"cosmossdk.io/core/event"
"cosmossdk.io/log"
"cosmossdk.io/x/accounts/accountstd"
"cosmossdk.io/x/accounts/internal/implementation"
Expand Down Expand Up @@ -65,7 +64,6 @@ type InterfaceRegistry interface {
func NewKeeper(
cdc codec.BinaryCodec,
env appmodule.Environment,
es event.Service,
addressCodec address.Codec,
signerProvider SignerProvider,
execRouter MsgRouter,
Expand All @@ -76,7 +74,6 @@ func NewKeeper(
sb := collections.NewSchemaBuilder(env.KVStoreService)
keeper := Keeper{
environment: env,
eventService: es,
logger: env.Logger,
addressCodec: addressCodec,
msgRouter: execRouter,
Expand Down Expand Up @@ -106,7 +103,6 @@ func NewKeeper(
type Keeper struct {
// deps coming from the runtime
environment appmodule.Environment
eventService event.Service
addressCodec address.Codec
msgRouter MsgRouter
signerProvider SignerProvider
Expand Down
2 changes: 1 addition & 1 deletion x/accounts/msg_server.go
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ func (m msgServer) Init(ctx context.Context, request *v1.MsgInit) (*v1.MsgInitRe
return nil, err
}

eventManager := m.k.eventService.EventManager(ctx)
eventManager := m.k.environment.EventService.EventManager(ctx)
err = eventManager.EmitKV(
"account_creation",
event.NewAttribute("address", accAddrString),
Expand Down
17 changes: 1 addition & 16 deletions x/accounts/utils_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@ import (

"cosmossdk.io/collections/colltest"
"cosmossdk.io/core/address"
"cosmossdk.io/core/event"
"cosmossdk.io/log"
"cosmossdk.io/x/accounts/internal/implementation"

Expand All @@ -25,20 +24,6 @@ type addressCodec struct{}
func (a addressCodec) StringToBytes(text string) ([]byte, error) { return []byte(text), nil }
func (a addressCodec) BytesToString(bz []byte) (string, error) { return string(bz), nil }

type eventService struct{}

func (e eventService) Emit(event protoiface.MessageV1) error { return nil }

func (e eventService) EmitKV(eventType string, attrs ...event.Attribute) error {
return nil
}

func (e eventService) EmitNonConsensus(event protoiface.MessageV1) error {
return nil
}

func (e eventService) EventManager(ctx context.Context) event.Manager { return e }

var _ InterfaceRegistry = (*interfaceRegistry)(nil)

type interfaceRegistry struct{}
Expand All @@ -51,7 +36,7 @@ func newKeeper(t *testing.T, accounts ...implementation.AccountCreatorFunc) (Kee
t.Helper()
ss, ctx := colltest.MockStore()
env := runtime.NewEnvironment(ss, log.NewNopLogger())
m, err := NewKeeper(nil, env, eventService{}, addressCodec{}, nil, nil, nil, interfaceRegistry{}, accounts...)
m, err := NewKeeper(nil, env, addressCodec{}, nil, nil, nil, interfaceRegistry{}, accounts...)
require.NoError(t, err)
return m, ctx
}
Expand Down

0 comments on commit 7455663

Please sign in to comment.