diff --git a/pkg/transformers/bite/repository_test.go b/pkg/transformers/bite/repository_test.go index 480fe165..c8d48f68 100644 --- a/pkg/transformers/bite/repository_test.go +++ b/pkg/transformers/bite/repository_test.go @@ -86,14 +86,4 @@ var _ = Describe("Bite repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &biteRepository, - RepositoryTwo: &bite.BiteRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/cat_file/chop_lump/repository_test.go b/pkg/transformers/cat_file/chop_lump/repository_test.go index ec10826a..41041f49 100644 --- a/pkg/transformers/cat_file/chop_lump/repository_test.go +++ b/pkg/transformers/cat_file/chop_lump/repository_test.go @@ -98,13 +98,4 @@ var _ = Describe("Cat file chop lump repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &catFileRepository, - RepositoryTwo: &chop_lump.CatFileChopLumpRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/cat_file/flip/repository_test.go b/pkg/transformers/cat_file/flip/repository_test.go index c50e3a97..8dfe6027 100644 --- a/pkg/transformers/cat_file/flip/repository_test.go +++ b/pkg/transformers/cat_file/flip/repository_test.go @@ -83,12 +83,4 @@ var _ = Describe("Cat file flip repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &catFileFlipRepository, - RepositoryTwo: &flip.CatFileFlipRepository{}, - } - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/cat_file/pit_vow/repository_test.go b/pkg/transformers/cat_file/pit_vow/repository_test.go index 5f97cfe1..c7d31167 100644 --- a/pkg/transformers/cat_file/pit_vow/repository_test.go +++ b/pkg/transformers/cat_file/pit_vow/repository_test.go @@ -81,13 +81,4 @@ var _ = Describe("Cat file pit vow repository", func() { } shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &catFilePitVowRepository, - RepositoryTwo: &pit_vow.CatFilePitVowRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/deal/repository_test.go b/pkg/transformers/deal/repository_test.go index 5a58c4ca..2e3f02b0 100644 --- a/pkg/transformers/deal/repository_test.go +++ b/pkg/transformers/deal/repository_test.go @@ -84,13 +84,4 @@ var _ = Describe("Deal Repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &dealRepository, - RepositoryTwo: &deal.DealRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/dent/repository_test.go b/pkg/transformers/dent/repository_test.go index bad19213..b667228a 100644 --- a/pkg/transformers/dent/repository_test.go +++ b/pkg/transformers/dent/repository_test.go @@ -92,13 +92,4 @@ var _ = Describe("Dent Repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &dentRepository, - RepositoryTwo: &dent.DentRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/drip_drip/repository_test.go b/pkg/transformers/drip_drip/repository_test.go index d66b9fd0..50646855 100644 --- a/pkg/transformers/drip_drip/repository_test.go +++ b/pkg/transformers/drip_drip/repository_test.go @@ -80,13 +80,4 @@ var _ = Describe("Drip drip repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &dripDripRepository, - RepositoryTwo: &drip_drip.DripDripRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/drip_file/ilk/repository_test.go b/pkg/transformers/drip_file/ilk/repository_test.go index 6853f291..8dbada31 100644 --- a/pkg/transformers/drip_file/ilk/repository_test.go +++ b/pkg/transformers/drip_file/ilk/repository_test.go @@ -82,13 +82,4 @@ var _ = Describe("Drip file ilk repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &dripFileIlkRepository, - RepositoryTwo: &ilk.DripFileIlkRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/drip_file/repo/repository_test.go b/pkg/transformers/drip_file/repo/repository_test.go index 8e297a3c..e8614b61 100644 --- a/pkg/transformers/drip_file/repo/repository_test.go +++ b/pkg/transformers/drip_file/repo/repository_test.go @@ -82,13 +82,4 @@ var _ = Describe("Drip file repo repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &dripFileRepoRepository, - RepositoryTwo: &repo.DripFileRepoRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/drip_file/vow/repository_test.go b/pkg/transformers/drip_file/vow/repository_test.go index 9ad62a49..71e8cd07 100644 --- a/pkg/transformers/drip_file/vow/repository_test.go +++ b/pkg/transformers/drip_file/vow/repository_test.go @@ -74,15 +74,6 @@ var _ = Describe("Drip file vow repository", func() { }) Describe("MarkHeaderChecked", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &dripFileVowRepository, - RepositoryTwo: &vow.DripFileVowRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) - - Describe("MissingHeaders", func() { inputs := shared_behaviors.MarkedHeaderCheckedBehaviorInputs{ CheckedHeaderColumnName: constants.DripFileVowChecked, Repository: &dripFileVowRepository, diff --git a/pkg/transformers/flap_kick/repository_test.go b/pkg/transformers/flap_kick/repository_test.go index 1012548b..2b401cfd 100644 --- a/pkg/transformers/flap_kick/repository_test.go +++ b/pkg/transformers/flap_kick/repository_test.go @@ -87,13 +87,4 @@ var _ = Describe("Flap Kick Repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &flapKickRepository, - RepositoryTwo: &flap_kick.FlapKickRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/flip_kick/repository_test.go b/pkg/transformers/flip_kick/repository_test.go index 7ecb5cb0..6befc361 100644 --- a/pkg/transformers/flip_kick/repository_test.go +++ b/pkg/transformers/flip_kick/repository_test.go @@ -87,15 +87,6 @@ var _ = Describe("FlipKick Repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("missing headers", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &flipKickRepository, - RepositoryTwo: &flip_kick.FlipKickRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) func assertDBRecordCount(db *postgres.DB, dbTable string, expectedCount int) { diff --git a/pkg/transformers/flop_kick/repository_test.go b/pkg/transformers/flop_kick/repository_test.go index c916169d..8d5a8351 100644 --- a/pkg/transformers/flop_kick/repository_test.go +++ b/pkg/transformers/flop_kick/repository_test.go @@ -85,13 +85,4 @@ var _ = Describe("FlopRepository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &repository, - RepositoryTwo: &flop_kick.FlopKickRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/frob/repository_test.go b/pkg/transformers/frob/repository_test.go index 5d399edb..36c6036a 100644 --- a/pkg/transformers/frob/repository_test.go +++ b/pkg/transformers/frob/repository_test.go @@ -86,13 +86,4 @@ var _ = Describe("Frob repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &frobRepository, - RepositoryTwo: &frob.FrobRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/pit_file/debt_ceiling/repository_test.go b/pkg/transformers/pit_file/debt_ceiling/repository_test.go index 06a7588b..026d0446 100644 --- a/pkg/transformers/pit_file/debt_ceiling/repository_test.go +++ b/pkg/transformers/pit_file/debt_ceiling/repository_test.go @@ -81,13 +81,4 @@ var _ = Describe("Pit file debt ceiling repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &pitFileDebtCeilingRepository, - RepositoryTwo: &debt_ceiling.PitFileDebtCeilingRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/pit_file/ilk/repository_test.go b/pkg/transformers/pit_file/ilk/repository_test.go index b99f6ad5..fbcebbf2 100644 --- a/pkg/transformers/pit_file/ilk/repository_test.go +++ b/pkg/transformers/pit_file/ilk/repository_test.go @@ -82,13 +82,4 @@ var _ = Describe("Pit file ilk repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &pitFileIlkRepository, - RepositoryTwo: &ilk.PitFileIlkRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/price_feeds/repository_test.go b/pkg/transformers/price_feeds/repository_test.go index 52765fd4..f58aef0d 100644 --- a/pkg/transformers/price_feeds/repository_test.go +++ b/pkg/transformers/price_feeds/repository_test.go @@ -82,13 +82,4 @@ var _ = Describe("Price feeds repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &priceFeedRepository, - RepositoryTwo: &price_feeds.PriceFeedRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/tend/repository_test.go b/pkg/transformers/tend/repository_test.go index dae2d4ba..0753524f 100644 --- a/pkg/transformers/tend/repository_test.go +++ b/pkg/transformers/tend/repository_test.go @@ -94,13 +94,4 @@ var _ = Describe("TendRepository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &tendRepository, - RepositoryTwo: &tend.TendRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/test_data/shared_behaviors/repository_behaviors.go b/pkg/transformers/test_data/shared_behaviors/repository_behaviors.go index 65ba206c..e6c24847 100644 --- a/pkg/transformers/test_data/shared_behaviors/repository_behaviors.go +++ b/pkg/transformers/test_data/shared_behaviors/repository_behaviors.go @@ -17,7 +17,6 @@ package shared_behaviors import ( . "github.com/onsi/ginkgo" . "github.com/onsi/gomega" - "github.com/vulcanize/vulcanizedb/pkg/core" "github.com/vulcanize/vulcanizedb/pkg/datastore" "github.com/vulcanize/vulcanizedb/pkg/datastore/postgres" "github.com/vulcanize/vulcanizedb/pkg/datastore/postgres/repositories" @@ -25,7 +24,6 @@ import ( "github.com/vulcanize/vulcanizedb/pkg/transformers/factories" "github.com/vulcanize/vulcanizedb/pkg/transformers/test_data" "github.com/vulcanize/vulcanizedb/test_config" - "math/rand" ) var ( @@ -132,7 +130,8 @@ func SharedRepositoryCreateBehaviors(inputs *CreateBehaviorInputs) { }) } -func SharedRepositoryMissingHeadersBehaviors(inputs *MissingHeadersBehaviorInputs) { +// Saved, will base tests of aggregate fetching on this +/*func SharedRepositoryMissingHeadersBehaviors(inputs *MissingHeadersBehaviorInputs) { Describe("MissingHeaders", func() { var ( repository = inputs.Repository @@ -211,7 +210,7 @@ func SharedRepositoryMissingHeadersBehaviors(inputs *MissingHeadersBehaviorInput Expect(nodeTwoMissingHeaders[2].BlockNumber).To(Or(Equal(startingBlockNumber), Equal(eventSpecificBlockNumber), Equal(endingBlockNumber))) }) }) -} +}*/ func SharedRepositoryMarkHeaderCheckedBehaviors(inputs *MarkedHeaderCheckedBehaviorInputs) { var repository = inputs.Repository diff --git a/pkg/transformers/vat_flux/repository_test.go b/pkg/transformers/vat_flux/repository_test.go index 14b3f403..a8b7ab85 100644 --- a/pkg/transformers/vat_flux/repository_test.go +++ b/pkg/transformers/vat_flux/repository_test.go @@ -86,15 +86,6 @@ var _ = Describe("VatFlux Repository", func() { }) }) - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &repository, - RepositoryTwo: &vat_flux.VatFluxRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) - Describe("MarkHeaderChecked", func() { inputs := shared_behaviors.MarkedHeaderCheckedBehaviorInputs{ CheckedHeaderColumnName: constants.VatFluxChecked, diff --git a/pkg/transformers/vat_fold/repository_test.go b/pkg/transformers/vat_fold/repository_test.go index a26ff75b..fc551b37 100644 --- a/pkg/transformers/vat_fold/repository_test.go +++ b/pkg/transformers/vat_fold/repository_test.go @@ -84,13 +84,4 @@ var _ = Describe("Vat.fold repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &repository, - RepositoryTwo: &vat_fold.VatFoldRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/vat_grab/repository_test.go b/pkg/transformers/vat_grab/repository_test.go index 1d6e222c..e5dded85 100644 --- a/pkg/transformers/vat_grab/repository_test.go +++ b/pkg/transformers/vat_grab/repository_test.go @@ -73,13 +73,4 @@ var _ = Describe("Vat grab repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &vatGrabRepository, - RepositoryTwo: &vat_grab.VatGrabRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/vat_heal/repository_test.go b/pkg/transformers/vat_heal/repository_test.go index 9cc668fc..d16bd9df 100644 --- a/pkg/transformers/vat_heal/repository_test.go +++ b/pkg/transformers/vat_heal/repository_test.go @@ -83,15 +83,6 @@ var _ = Describe("VatHeal Repository", func() { }) }) - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &repository, - RepositoryTwo: &vat_heal.VatHealRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) - Describe("MarkCheckedHeader", func() { inputs := shared_behaviors.MarkedHeaderCheckedBehaviorInputs{ CheckedHeaderColumnName: constants.VatHealChecked, diff --git a/pkg/transformers/vat_init/repository_test.go b/pkg/transformers/vat_init/repository_test.go index 93ca26fe..6e505171 100644 --- a/pkg/transformers/vat_init/repository_test.go +++ b/pkg/transformers/vat_init/repository_test.go @@ -72,15 +72,6 @@ var _ = Describe("Vat init repository", func() { }) }) - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &repository, - RepositoryTwo: &vat_init.VatInitRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) - Describe("MarkHeaderChecked", func() { inputs := shared_behaviors.MarkedHeaderCheckedBehaviorInputs{ CheckedHeaderColumnName: constants.VatInitChecked, diff --git a/pkg/transformers/vat_move/repository_test.go b/pkg/transformers/vat_move/repository_test.go index b4eb0bcc..179a2ee0 100644 --- a/pkg/transformers/vat_move/repository_test.go +++ b/pkg/transformers/vat_move/repository_test.go @@ -71,15 +71,6 @@ var _ = Describe("Vat Move", func() { }) }) - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &repository, - RepositoryTwo: &vat_move.VatMoveRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) - Describe("MarkHeaderChecked", func() { inputs := shared_behaviors.MarkedHeaderCheckedBehaviorInputs{ CheckedHeaderColumnName: constants.VatMoveChecked, diff --git a/pkg/transformers/vat_slip/repository_test.go b/pkg/transformers/vat_slip/repository_test.go index d3f1e64e..23a83150 100644 --- a/pkg/transformers/vat_slip/repository_test.go +++ b/pkg/transformers/vat_slip/repository_test.go @@ -68,13 +68,4 @@ var _ = Describe("Vat slip repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &repository, - RepositoryTwo: &vat_slip.VatSlipRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/vat_toll/repository_test.go b/pkg/transformers/vat_toll/repository_test.go index 6b3d21d4..3c2f9f0d 100644 --- a/pkg/transformers/vat_toll/repository_test.go +++ b/pkg/transformers/vat_toll/repository_test.go @@ -68,13 +68,4 @@ var _ = Describe("Vat toll repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &repository, - RepositoryTwo: &vat_toll.VatTollRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/vat_tune/repository_test.go b/pkg/transformers/vat_tune/repository_test.go index 5214f9e5..1700825b 100644 --- a/pkg/transformers/vat_tune/repository_test.go +++ b/pkg/transformers/vat_tune/repository_test.go @@ -71,13 +71,4 @@ var _ = Describe("Vat tune repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &repository, - RepositoryTwo: &vat_tune.VatTuneRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) }) diff --git a/pkg/transformers/vow_flog/repository_test.go b/pkg/transformers/vow_flog/repository_test.go index 153b1876..de6b3b94 100644 --- a/pkg/transformers/vow_flog/repository_test.go +++ b/pkg/transformers/vow_flog/repository_test.go @@ -80,13 +80,4 @@ var _ = Describe("Vow flog repository", func() { shared_behaviors.SharedRepositoryMarkHeaderCheckedBehaviors(&inputs) }) - - Describe("MissingHeaders", func() { - inputs := shared_behaviors.MissingHeadersBehaviorInputs{ - Repository: &repository, - RepositoryTwo: &vow_flog.VowFlogRepository{}, - } - - shared_behaviors.SharedRepositoryMissingHeadersBehaviors(&inputs) - }) })