diff --git a/process/elasticproc/logsevents/delegatorsProcessor.go b/process/elasticproc/logsevents/delegatorsProcessor.go index 26fd3a82..0cec5816 100644 --- a/process/elasticproc/logsevents/delegatorsProcessor.go +++ b/process/elasticproc/logsevents/delegatorsProcessor.go @@ -44,10 +44,6 @@ func newDelegatorsProcessor( } func (dp *delegatorsProc) processEvent(args *argsProcessEvent) argOutputProcessEvent { - if args.selfShardID != core.MetachainShardId { - return argOutputProcessEvent{} - } - eventIdentifierStr := string(args.event.GetIdentifier()) _, ok := dp.delegatorsOperations[eventIdentifierStr] if !ok { diff --git a/process/elasticproc/logsevents/esdtIssueProcessor.go b/process/elasticproc/logsevents/esdtIssueProcessor.go index 2af66180..7b649cc1 100644 --- a/process/elasticproc/logsevents/esdtIssueProcessor.go +++ b/process/elasticproc/logsevents/esdtIssueProcessor.go @@ -41,10 +41,6 @@ func newESDTIssueProcessor(pubkeyConverter core.PubkeyConverter) *esdtIssueProce } func (eip *esdtIssueProcessor) processEvent(args *argsProcessEvent) argOutputProcessEvent { - if args.selfShardID != core.MetachainShardId { - return argOutputProcessEvent{} - } - identifierStr := string(args.event.GetIdentifier()) _, ok := eip.issueOperationsIdentifiers[identifierStr] if !ok { diff --git a/process/elasticproc/logsevents/esdtIssueProcessor_test.go b/process/elasticproc/logsevents/esdtIssueProcessor_test.go index f62d2ab3..026561d3 100644 --- a/process/elasticproc/logsevents/esdtIssueProcessor_test.go +++ b/process/elasticproc/logsevents/esdtIssueProcessor_test.go @@ -83,23 +83,3 @@ func TestIssueESDTProcessor_TransferOwnership(t *testing.T) { Properties: &data.TokenProperties{}, }, res.tokenInfo) } - -func TestIssueESDTProcessor_EventWithShardID0ShouldBeIgnored(t *testing.T) { - t.Parallel() - - esdtIssueProc := newESDTIssueProcessor(&mock.PubkeyConverterMock{}) - - event := &transaction.Event{ - Address: []byte("addr"), - Identifier: []byte(transferOwnershipFunc), - Topics: [][]byte{[]byte("MYTOKEN-abcd"), []byte("my-token"), []byte("MYTOKEN"), []byte(core.NonFungibleESDT), []byte("newOwner")}, - } - args := &argsProcessEvent{ - timestamp: 1234, - event: event, - selfShardID: 0, - } - - res := esdtIssueProc.processEvent(args) - require.False(t, res.processed) -}