ESDTWipe fixies

client/elasticClient.go

@@ -156,7 +156,7 @@ func (ec *elasticClient) DoMultiGet(ids []string, index string, withSource bool,
 // DoQueryRemove will do a query remove to elasticsearch server
 func (ec *elasticClient) DoQueryRemove(index string, body *bytes.Buffer) error {
 	if err := ec.doRefresh(index); err != nil {
-		log.Warn("elasticClient.doRefresh", "cannot to refresh", err.Error())
+		log.Warn("elasticClient.doRefresh", "cannot do refresh", err.Error())
 	}
 
 	res, err := ec.client.DeleteByQuery(

process/elasticProcessor.go

@@ -4,6 +4,7 @@ import (
 	"bytes"
 	"encoding/hex"
 	"fmt"
+
 	elasticIndexer "github.com/ElrondNetwork/elastic-indexer-go"
 	"github.com/ElrondNetwork/elastic-indexer-go/converters"
 	"github.com/ElrondNetwork/elastic-indexer-go/data"

process/logsevents/fungibleESDTProcessor_test.go

@@ -124,3 +124,41 @@ func TestProcessLogsAndEventsESDT_CrossShardOnDestination(t *testing.T) {
 	_, ok = altered.Get("61646472")
 	require.False(t, ok)
 }
+
+func TestNftsProcessor_processLogAndEventsFungibleESDT_Wipe(t *testing.T) {
+	t.Parallel()
+
+	nftsProc := newFungibleESDTProcessor(&mock.PubkeyConverterMock{}, &mock.ShardCoordinatorMock{})
+
+	events := &transaction.Event{
+		Address:    []byte("addr"),
+		Identifier: []byte(core.BuiltInFunctionESDTWipe),
+		Topics:     [][]byte{[]byte("esdt-0123"), big.NewInt(0).SetUint64(0).Bytes(), big.NewInt(0).Bytes(), []byte("receiver")},
+	}
+
+	altered := data.NewAlteredAccounts()
+
+	res := nftsProc.processEvent(&argsProcessEvent{
+		event:        events,
+		accounts:     altered,
+		timestamp:    10000,
+		tokensSupply: data.NewTokensInfo(),
+	})
+	require.Equal(t, "esdt-0123", res.identifier)
+	require.Equal(t, "0", res.value)
+	require.Equal(t, true, res.processed)
+
+	alteredAddrSender, ok := altered.Get("61646472")
+	require.True(t, ok)
+	require.Equal(t, &data.AlteredAccount{
+		TokenIdentifier: "esdt-0123",
+		IsESDTOperation: true,
+	}, alteredAddrSender[0])
+
+	alteredAddrReceiver, ok := altered.Get("7265636569766572")
+	require.True(t, ok)
+	require.Equal(t, &data.AlteredAccount{
+		TokenIdentifier: "esdt-0123",
+		IsESDTOperation: true,
+	}, alteredAddrReceiver[0])
+}

process/logsevents/nftsProcessor.go

@@ -112,7 +112,7 @@ func (np *nftsProcessor) processEvent(args *argsProcessEvent) argOutputProcessEv
 func (np *nftsProcessor) shouldAddReceiverData(args *argsProcessEvent) bool {
 	eventIdentifier := string(args.event.GetIdentifier())
 	isWrongIdentifier := eventIdentifier != core.BuiltInFunctionESDTNFTTransfer &&
-		eventIdentifier != core.BuiltInFunctionMultiESDTNFTTransfer
+		eventIdentifier != core.BuiltInFunctionMultiESDTNFTTransfer && eventIdentifier != core.BuiltInFunctionESDTWipe
 
 	if isWrongIdentifier || len(args.event.GetTopics()) < numTopicsWithReceiverAddress {
 		return false

process/logsevents/nftsProcessor_test.go

@@ -139,4 +139,12 @@ func TestNftsProcessor_processLogAndEventsNFTs_Wipe(t *testing.T) {
 		TokenIdentifier: "nft-0123",
 		NFTNonce:        20,
 	}, alteredAddrSender[0])
+
+	alteredAddrReceiver, ok := altered.Get("7265636569766572")
+	require.True(t, ok)
+	require.Equal(t, &data.AlteredAccount{
+		IsNFTOperation:  true,
+		TokenIdentifier: "nft-0123",
+		NFTNonce:        20,
+	}, alteredAddrReceiver[0])
 }