From 536cd32b4695c7695ffa0be0130456082a653491 Mon Sep 17 00:00:00 2001 From: prathamesh0 Date: Mon, 21 Mar 2022 18:03:48 +0530 Subject: [PATCH] Create file for watched addresses only when required --- statediff/indexer/database/file/config.go | 1 - statediff/indexer/database/file/indexer_test.go | 16 ++++++++-------- 2 files changed, 8 insertions(+), 9 deletions(-) diff --git a/statediff/indexer/database/file/config.go b/statediff/indexer/database/file/config.go index 97cb10198..a075e896b 100644 --- a/statediff/indexer/database/file/config.go +++ b/statediff/indexer/database/file/config.go @@ -44,5 +44,4 @@ var TestConfig = Config{ ID: "mockNodeID", ClientName: "go-ethereum", }, - WatchedAddressesFilePath: "./statediffing_watched_addresses_test_file.sql", } diff --git a/statediff/indexer/database/file/indexer_test.go b/statediff/indexer/database/file/indexer_test.go index 97b81852e..e5a5383f7 100644 --- a/statediff/indexer/database/file/indexer_test.go +++ b/statediff/indexer/database/file/indexer_test.go @@ -1147,7 +1147,7 @@ func TestFileWatchAddressMethods(t *testing.T) { err = ind.InsertWatchedAddresses(args, big.NewInt(int64(watchedAt1))) require.NoError(t, err) - dumpWatchedAddressesFileData(t) + resetAndDumpWatchedAddressesFileData(t) rows := []res{} err = sqlxdb.Select(&rows, pgStr) @@ -1195,7 +1195,7 @@ func TestFileWatchAddressMethods(t *testing.T) { err = ind.InsertWatchedAddresses(args, big.NewInt(int64(watchedAt2))) require.NoError(t, err) - dumpWatchedAddressesFileData(t) + resetAndDumpWatchedAddressesFileData(t) rows := []res{} err = sqlxdb.Select(&rows, pgStr) @@ -1231,7 +1231,7 @@ func TestFileWatchAddressMethods(t *testing.T) { err = ind.RemoveWatchedAddresses(args) require.NoError(t, err) - dumpWatchedAddressesFileData(t) + resetAndDumpWatchedAddressesFileData(t) rows := []res{} err = sqlxdb.Select(&rows, pgStr) @@ -1260,7 +1260,7 @@ func TestFileWatchAddressMethods(t *testing.T) { err = ind.RemoveWatchedAddresses(args) require.NoError(t, err) - dumpWatchedAddressesFileData(t) + resetAndDumpWatchedAddressesFileData(t) rows := []res{} err = sqlxdb.Select(&rows, pgStr) @@ -1312,7 +1312,7 @@ func TestFileWatchAddressMethods(t *testing.T) { err = ind.SetWatchedAddresses(args, big.NewInt(int64(watchedAt2))) require.NoError(t, err) - dumpWatchedAddressesFileData(t) + resetAndDumpWatchedAddressesFileData(t) rows := []res{} err = sqlxdb.Select(&rows, pgStr) @@ -1364,7 +1364,7 @@ func TestFileWatchAddressMethods(t *testing.T) { err = ind.SetWatchedAddresses(args, big.NewInt(int64(watchedAt3))) require.NoError(t, err) - dumpWatchedAddressesFileData(t) + resetAndDumpWatchedAddressesFileData(t) rows := []res{} err = sqlxdb.Select(&rows, pgStr) @@ -1399,7 +1399,7 @@ func TestFileWatchAddressMethods(t *testing.T) { err = ind.ClearWatchedAddresses() require.NoError(t, err) - dumpWatchedAddressesFileData(t) + resetAndDumpWatchedAddressesFileData(t) rows := []res{} err = sqlxdb.Select(&rows, pgStr) @@ -1418,7 +1418,7 @@ func TestFileWatchAddressMethods(t *testing.T) { err = ind.ClearWatchedAddresses() require.NoError(t, err) - dumpWatchedAddressesFileData(t) + resetAndDumpWatchedAddressesFileData(t) rows := []res{} err = sqlxdb.Select(&rows, pgStr)