cerc-io/go-ethereum
13
0
Fork 0
Code Issues 9 Pull Requests Packages Projects Releases 66 Wiki Activity

Create file for watched addresses only when required

Browse Source
This commit is contained in:
Prathamesh Musale 2022-03-21 18:03:48 +05:30 committed by Abdul Rabbani
parent a47a90e9d3
commit 536cd32b46
2 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
statediff/indexer/database/file/config.go
View File

@ -44,5 +44,4 @@ var TestConfig = Config{
ID: "mockNodeID", ID: "mockNodeID",
ClientName: "go-ethereum", ClientName: "go-ethereum",
}, },
WatchedAddressesFilePath: "./statediffing_watched_addresses_test_file.sql",
} }

16
statediff/indexer/database/file/indexer_test.go
View File

@ -1147,7 +1147,7 @@ func TestFileWatchAddressMethods(t *testing.T) {
err = ind.InsertWatchedAddresses(args, big.NewInt(int64(watchedAt1))) err = ind.InsertWatchedAddresses(args, big.NewInt(int64(watchedAt1)))
require.NoError(t, err) require.NoError(t, err)
dumpWatchedAddressesFileData(t) resetAndDumpWatchedAddressesFileData(t)
rows := []res{} rows := []res{}
err = sqlxdb.Select(&rows, pgStr) err = sqlxdb.Select(&rows, pgStr)
@ -1195,7 +1195,7 @@ func TestFileWatchAddressMethods(t *testing.T) {
err = ind.InsertWatchedAddresses(args, big.NewInt(int64(watchedAt2))) err = ind.InsertWatchedAddresses(args, big.NewInt(int64(watchedAt2)))
require.NoError(t, err) require.NoError(t, err)
dumpWatchedAddressesFileData(t) resetAndDumpWatchedAddressesFileData(t)
rows := []res{} rows := []res{}
err = sqlxdb.Select(&rows, pgStr) err = sqlxdb.Select(&rows, pgStr)
@ -1231,7 +1231,7 @@ func TestFileWatchAddressMethods(t *testing.T) {
err = ind.RemoveWatchedAddresses(args) err = ind.RemoveWatchedAddresses(args)
require.NoError(t, err) require.NoError(t, err)
dumpWatchedAddressesFileData(t) resetAndDumpWatchedAddressesFileData(t)
rows := []res{} rows := []res{}
err = sqlxdb.Select(&rows, pgStr) err = sqlxdb.Select(&rows, pgStr)
@ -1260,7 +1260,7 @@ func TestFileWatchAddressMethods(t *testing.T) {
err = ind.RemoveWatchedAddresses(args) err = ind.RemoveWatchedAddresses(args)
require.NoError(t, err) require.NoError(t, err)
dumpWatchedAddressesFileData(t) resetAndDumpWatchedAddressesFileData(t)
rows := []res{} rows := []res{}
err = sqlxdb.Select(&rows, pgStr) err = sqlxdb.Select(&rows, pgStr)
@ -1312,7 +1312,7 @@ func TestFileWatchAddressMethods(t *testing.T) {
err = ind.SetWatchedAddresses(args, big.NewInt(int64(watchedAt2))) err = ind.SetWatchedAddresses(args, big.NewInt(int64(watchedAt2)))
require.NoError(t, err) require.NoError(t, err)
dumpWatchedAddressesFileData(t) resetAndDumpWatchedAddressesFileData(t)
rows := []res{} rows := []res{}
err = sqlxdb.Select(&rows, pgStr) err = sqlxdb.Select(&rows, pgStr)
@ -1364,7 +1364,7 @@ func TestFileWatchAddressMethods(t *testing.T) {
err = ind.SetWatchedAddresses(args, big.NewInt(int64(watchedAt3))) err = ind.SetWatchedAddresses(args, big.NewInt(int64(watchedAt3)))
require.NoError(t, err) require.NoError(t, err)
dumpWatchedAddressesFileData(t) resetAndDumpWatchedAddressesFileData(t)
rows := []res{} rows := []res{}
err = sqlxdb.Select(&rows, pgStr) err = sqlxdb.Select(&rows, pgStr)
@ -1399,7 +1399,7 @@ func TestFileWatchAddressMethods(t *testing.T) {
err = ind.ClearWatchedAddresses() err = ind.ClearWatchedAddresses()
require.NoError(t, err) require.NoError(t, err)
dumpWatchedAddressesFileData(t) resetAndDumpWatchedAddressesFileData(t)
rows := []res{} rows := []res{}
err = sqlxdb.Select(&rows, pgStr) err = sqlxdb.Select(&rows, pgStr)
@ -1418,7 +1418,7 @@ func TestFileWatchAddressMethods(t *testing.T) {
err = ind.ClearWatchedAddresses() err = ind.ClearWatchedAddresses()
require.NoError(t, err) require.NoError(t, err)
dumpWatchedAddressesFileData(t) resetAndDumpWatchedAddressesFileData(t)
rows := []res{} rows := []res{}
err = sqlxdb.Select(&rows, pgStr) err = sqlxdb.Select(&rows, pgStr)