Fixes after merging staging

cmd/backfillMakerLogs.go

@@ -49,7 +49,7 @@ func backfillMakerLogs() {
 
 	repository := shared2.Repository{}
 	fetcher := shared2.NewFetcher(blockChain)
-	watcher := shared.NewWatcher(db, fetcher, repository)
+	watcher := shared.NewWatcher(db, fetcher, repository, transformers.TransformerConfigs())
 
 	watcher.AddTransformers(transformers.TransformerInitializers())
 	watcher.Execute()

libraries/shared/watcher.go

@@ -25,7 +25,7 @@ type Watcher struct {
 }
 
 func NewWatcher(db *postgres.DB, fetcher shared.LogFetcher, repository WatcherRepository,
-		transformerConfigs []shared.TransformerConfig) Watcher {
+	transformerConfigs []shared.TransformerConfig) Watcher {
 	var contractAddresses []common.Address
 	var topic0s []common.Hash
 

libraries/shared/watcher_test.go

@@ -143,10 +143,10 @@ var _ = Describe("Watcher", func() {
 
 			configA := shared2.TransformerConfig{TransformerName: "transformerA",
 				ContractAddresses: []string{"0x000000000000000000000000000000000000000A"},
-				Topic: "0xA"}
+				Topic:             "0xA"}
 			configB := shared2.TransformerConfig{TransformerName: "transformerB",
 				ContractAddresses: []string{"0x000000000000000000000000000000000000000b"},
-				Topic: "0xB"}
+				Topic:             "0xB"}
 			configs := []shared2.TransformerConfig{configA, configB}
 
 			logA := types.Log{Address: common.HexToAddress("0xA"),

pkg/transformers/integration_tests/pit_file_ilk.go

@@ -18,6 +18,8 @@ import (
 	"github.com/ethereum/go-ethereum/common"
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"
+	"github.com/vulcanize/vulcanizedb/pkg/core"
+	"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"
 
 	"github.com/vulcanize/vulcanizedb/pkg/transformers/factories"
 	"github.com/vulcanize/vulcanizedb/pkg/transformers/pit_file/ilk"
@@ -26,37 +28,46 @@ import (
 )
 
 var _ = Describe("PitFileIlk LogNoteTransformer", func() {
-	It("fetches and transforms a Pit.file ilk 'spot' event from Kovan", func() {
+	var (
-		blockNumber := int64(9103223)
+		db          *postgres.DB
-		config := ilk.IlkFileConfig
+		blockChain  core.BlockChain
-		config.StartingBlockNumber = blockNumber
+		initializer factories.LogNoteTransformer
-		config.EndingBlockNumber = blockNumber
+		addresses   []common.Address
+		topics      []common.Hash
+	)
 
+	BeforeEach(func() {
 		rpcClient, ethClient, err := getClients(ipc)
 		Expect(err).NotTo(HaveOccurred())
-		blockChain, err := getBlockChain(rpcClient, ethClient)
+		blockChain, err = getBlockChain(rpcClient, ethClient)
 		Expect(err).NotTo(HaveOccurred())
-
+		db = test_config.NewTestDB(blockChain.Node())
-		db := test_config.NewTestDB(blockChain.Node())
 		test_config.CleanTestDB(db)
+		config := ilk.IlkFileConfig
 
-		header, err := persistHeader(db, blockNumber, blockChain)
+		addresses = shared.HexStringsToAddresses(config.ContractAddresses)
-		Expect(err).NotTo(HaveOccurred())
+		topics = []common.Hash{common.HexToHash(config.Topic)}
 
-		initializer := factories.LogNoteTransformer{
+		initializer = factories.LogNoteTransformer{
 			Config:     config,
 			Converter:  &ilk.PitFileIlkConverter{},
 			Repository: &ilk.PitFileIlkRepository{},
 		}
-		transformer := initializer.NewLogNoteTransformer(db)
+	})
 
-		fetcher := shared.NewFetcher(blockChain)
+	It("fetches and transforms a Pit.file ilk 'spot' event from Kovan", func() {
-		logs, err := fetcher.FetchLogs(
+		blockNumber := int64(9103223)
-			shared.HexStringsToAddresses(config.ContractAddresses),
+		initializer.Config.StartingBlockNumber = blockNumber
-			[]common.Hash{common.HexToHash(config.Topic)},
+		initializer.Config.EndingBlockNumber = blockNumber
-			header)
+
+		header, err := persistHeader(db, blockNumber, blockChain)
 		Expect(err).NotTo(HaveOccurred())
 
+		fetcher := shared.NewFetcher(blockChain)
+		logs, err := fetcher.FetchLogs(addresses, topics, header)
+		Expect(err).NotTo(HaveOccurred())
+
+		transformer := initializer.NewLogNoteTransformer(db)
 		err = transformer.Execute(logs, header)
 		Expect(err).NotTo(HaveOccurred())
 
@@ -72,29 +83,18 @@ var _ = Describe("PitFileIlk LogNoteTransformer", func() {
 
 	It("fetches and transforms a Pit.file ilk 'line' event from Kovan", func() {
 		blockNumber := int64(8762253)
-		config := ilk.IlkFileConfig
+		initializer.Config.StartingBlockNumber = blockNumber
-		config.StartingBlockNumber = blockNumber
+		initializer.Config.EndingBlockNumber = blockNumber
-		config.EndingBlockNumber = blockNumber
 
-		rpcClient, ethClient, err := getClients(ipc)
+		header, err := persistHeader(db, blockNumber, blockChain)
-		Expect(err).NotTo(HaveOccurred())
-		blockChain, err := getBlockChain(rpcClient, ethClient)
 		Expect(err).NotTo(HaveOccurred())
 
-		db := test_config.NewTestDB(blockChain.Node())
+		fetcher := shared.NewFetcher(blockChain)
-		test_config.CleanTestDB(db)
+		logs, err := fetcher.FetchLogs(addresses, topics, header)
-
-		err = persistHeader(db, blockNumber, blockChain)
 		Expect(err).NotTo(HaveOccurred())
 
-		initializer := factories.LogNoteTransformer{
+		transformer := initializer.NewLogNoteTransformer(db)
-			Config:     config,
+		err = transformer.Execute(logs, header)
-			Fetcher:    &shared.Fetcher{},
-			Converter:  &ilk.PitFileIlkConverter{},
-			Repository: &ilk.PitFileIlkRepository{},
-		}
-		transformer := initializer.NewLogNoteTransformer(db, blockChain)
-		err = transformer.Execute()
 		Expect(err).NotTo(HaveOccurred())
 
 		var dbResult []ilk.PitFileIlkModel