Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Vdb 696 remove unused repo methods #126

Merged
merged 8 commits into from
Jun 18, 2019
Merged

Vdb 696 remove unused repo methods #126

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
ff09e00
Update vulcanizedb Transformer and Repository interfaces
elizabethengelman Jun 13, 2019
3415d7e
Update LogNoteTransformer.Execute to conform with updated interface
elizabethengelman Jun 13, 2019
32119ed
Update Transformer.Execute calls to conform with new interface
elizabethengelman Jun 13, 2019
62eb14b
Remove unused transformer specific repository MissingHeaders method
elizabethengelman Jun 13, 2019
cf9a13b
Remove unused transformer specific repository RecheckHeaders method
elizabethengelman Jun 13, 2019
54da45a
Remove more unused MissingHeader methods in repos and tests
elizabethengelman Jun 17, 2019
ed5e758
Remove MissingHeader and RecheckHeader methods after rebase
elizabethengelman Jun 17, 2019
9ab313b
Update VulcanizeDB to v0.0.3
elizabethengelman Jun 17, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
163 changes: 19 additions & 144 deletions Gopkg.lock
View file
Open in desktop

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion Gopkg.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@

[[constraint]]
name = "github.com/vulcanize/vulcanizedb"
version = "=0.0.2"
version = "=0.0.3"

[[constraint]]
name = "github.com/sirupsen/logrus"
Expand Down
9 changes: 0 additions & 9 deletions transformers/events/bite/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ import (
log "github.com/sirupsen/logrus"

repo "github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"

"github.com/vulcanize/mcd_transformers/transformers/shared"
Expand Down Expand Up @@ -100,11 +99,3 @@ func (repository BiteRepository) Create(headerID int64, models []interface{}) er
func (repository BiteRepository) MarkHeaderChecked(headerID int64) error {
return repo.MarkHeaderChecked(headerID, repository.db, constants.BiteChecked)
}

func (repository BiteRepository) MissingHeaders(startingBlockNumber int64, endingBlockNumber int64) ([]core.Header, error) {
return repo.MissingHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.BiteChecked)
}

func (repository BiteRepository) RecheckHeaders(startingBlockNumber int64, endingBlockNumber int64) ([]core.Header, error) {
return repo.RecheckHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.BiteChecked)
}
9 changes: 0 additions & 9 deletions transformers/events/cat_file/chop_lump/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ import (
log "github.com/sirupsen/logrus"

repo "github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"

"github.com/vulcanize/mcd_transformers/transformers/shared"
Expand Down Expand Up @@ -88,14 +87,6 @@ func (repository CatFileChopLumpRepository) MarkHeaderChecked(headerID int64) er
return repo.MarkHeaderChecked(headerID, repository.db, constants.CatFileChopLumpChecked)
}

func (repository CatFileChopLumpRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.MissingHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.CatFileChopLumpChecked)
}

func (repository CatFileChopLumpRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.RecheckHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.CatFileChopLumpChecked)
}

func (repository *CatFileChopLumpRepository) SetDB(db *postgres.DB) {
repository.db = db
}
9 changes: 0 additions & 9 deletions transformers/events/cat_file/flip/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,6 @@ import (
log "github.com/sirupsen/logrus"

repo "github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"

"github.com/vulcanize/mcd_transformers/transformers/shared/constants"
Expand Down Expand Up @@ -87,14 +86,6 @@ func (repository CatFileFlipRepository) MarkHeaderChecked(headerID int64) error
return repo.MarkHeaderChecked(headerID, repository.db, constants.CatFileFlipChecked)
}

func (repository CatFileFlipRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.MissingHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.CatFileFlipChecked)
}

func (repository CatFileFlipRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.RecheckHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.CatFileFlipChecked)
}

func (repository *CatFileFlipRepository) SetDB(db *postgres.DB) {
repository.db = db
}
9 changes: 0 additions & 9 deletions transformers/events/cat_file/vow/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ import (
log "github.com/sirupsen/logrus"

repo "github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"

"github.com/vulcanize/mcd_transformers/transformers/shared/constants"
Expand Down Expand Up @@ -77,14 +76,6 @@ func (repository CatFileVowRepository) MarkHeaderChecked(headerID int64) error {
return repo.MarkHeaderChecked(headerID, repository.db, constants.CatFileVowChecked)
}

func (repository CatFileVowRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.MissingHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.CatFileVowChecked)
}

func (repository CatFileVowRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.RecheckHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.CatFileVowChecked)
}

func (repository *CatFileVowRepository) SetDB(db *postgres.DB) {
repository.db = db
}
9 changes: 0 additions & 9 deletions transformers/events/deal/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ import (
log "github.com/sirupsen/logrus"

repo "github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"

"github.com/vulcanize/mcd_transformers/transformers/shared/constants"
Expand Down Expand Up @@ -78,14 +77,6 @@ func (repository DealRepository) MarkHeaderChecked(headerID int64) error {
return repo.MarkHeaderChecked(headerID, repository.db, constants.DealChecked)
}

func (repository DealRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.MissingHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.DealChecked)
}

func (repository DealRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.RecheckHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.DealChecked)
}

func (repository *DealRepository) SetDB(db *postgres.DB) {
repository.db = db
}
9 changes: 0 additions & 9 deletions transformers/events/dent/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ import (
log "github.com/sirupsen/logrus"

repo "github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"

"github.com/vulcanize/mcd_transformers/transformers/shared"
Expand Down Expand Up @@ -82,14 +81,6 @@ func (repository DentRepository) MarkHeaderChecked(headerId int64) error {
return repo.MarkHeaderChecked(headerId, repository.db, constants.DentChecked)
}

func (repository DentRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.MissingHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.DentChecked)
}

func (repository DentRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.RecheckHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.DentChecked)
}

func (repository *DentRepository) SetDB(db *postgres.DB) {
repository.db = db
}
9 changes: 0 additions & 9 deletions transformers/events/flap_kick/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ import (
log "github.com/sirupsen/logrus"

repo "github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"

"github.com/vulcanize/mcd_transformers/transformers/shared/constants"
Expand Down Expand Up @@ -77,14 +76,6 @@ func (repository *FlapKickRepository) MarkHeaderChecked(headerID int64) error {
return repo.MarkHeaderChecked(headerID, repository.db, constants.FlapKickChecked)
}

func (repository FlapKickRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.MissingHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.FlapKickChecked)
}

func (repository FlapKickRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.RecheckHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.FlapKickChecked)
}

func (repository *FlapKickRepository) SetDB(db *postgres.DB) {
repository.db = db
}
9 changes: 0 additions & 9 deletions transformers/events/flip_kick/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ import (
log "github.com/sirupsen/logrus"

repo "github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"

"github.com/vulcanize/mcd_transformers/transformers/shared/constants"
Expand Down Expand Up @@ -76,14 +75,6 @@ func (repository FlipKickRepository) MarkHeaderChecked(headerId int64) error {
return repo.MarkHeaderChecked(headerId, repository.db, constants.FlipKickChecked)
}

func (repository FlipKickRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.MissingHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.FlipKickChecked)
}

func (repository FlipKickRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.RecheckHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.FlipKickChecked)
}

func (repository *FlipKickRepository) SetDB(db *postgres.DB) {
repository.db = db
}
9 changes: 0 additions & 9 deletions transformers/events/flop_kick/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ import (
log "github.com/sirupsen/logrus"

repo "github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"

"github.com/vulcanize/mcd_transformers/transformers/shared/constants"
Expand Down Expand Up @@ -78,14 +77,6 @@ func (repository FlopKickRepository) MarkHeaderChecked(headerId int64) error {
return repo.MarkHeaderChecked(headerId, repository.db, constants.FlopKickChecked)
}

func (repository FlopKickRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.MissingHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.FlopKickChecked)
}

func (repository FlopKickRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.RecheckHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.FlopKickChecked)
}

func (repository *FlopKickRepository) SetDB(db *postgres.DB) {
repository.db = db
}
9 changes: 0 additions & 9 deletions transformers/events/jug_drip/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ import (
log "github.com/sirupsen/logrus"

repo "github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"

"github.com/vulcanize/mcd_transformers/transformers/shared"
Expand Down Expand Up @@ -87,14 +86,6 @@ func (repository JugDripRepository) MarkHeaderChecked(headerID int64) error {
return repo.MarkHeaderChecked(headerID, repository.db, constants.JugDripChecked)
}

func (repository JugDripRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.MissingHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.JugDripChecked)
}

func (repository JugDripRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.RecheckHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.JugDripChecked)
}

func (repository *JugDripRepository) SetDB(db *postgres.DB) {
repository.db = db
}
9 changes: 0 additions & 9 deletions transformers/events/jug_file/base/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ import (
log "github.com/sirupsen/logrus"

repo "github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"

"github.com/vulcanize/mcd_transformers/transformers/shared/constants"
Expand Down Expand Up @@ -80,14 +79,6 @@ func (repository JugFileBaseRepository) MarkHeaderChecked(headerID int64) error
return repo.MarkHeaderChecked(headerID, repository.db, constants.JugFileBaseChecked)
}

func (repository JugFileBaseRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.MissingHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.JugFileBaseChecked)
}

func (repository JugFileBaseRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.RecheckHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.JugFileBaseChecked)
}

func (repository *JugFileBaseRepository) SetDB(db *postgres.DB) {
repository.db = db
}
9 changes: 0 additions & 9 deletions transformers/events/jug_file/ilk/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ import (
log "github.com/sirupsen/logrus"

repo "github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"

"github.com/vulcanize/mcd_transformers/transformers/shared"
Expand Down Expand Up @@ -90,14 +89,6 @@ func (repository JugFileIlkRepository) MarkHeaderChecked(headerID int64) error {
return repo.MarkHeaderChecked(headerID, repository.db, constants.JugFileIlkChecked)
}

func (repository JugFileIlkRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.MissingHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.JugFileIlkChecked)
}

func (repository JugFileIlkRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.RecheckHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.JugFileIlkChecked)
}

func (repository *JugFileIlkRepository) SetDB(db *postgres.DB) {
repository.db = db
}
9 changes: 0 additions & 9 deletions transformers/events/jug_file/vow/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ import (
log "github.com/sirupsen/logrus"

repo "github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"

"github.com/vulcanize/mcd_transformers/transformers/shared/constants"
Expand Down Expand Up @@ -79,14 +78,6 @@ func (repository JugFileVowRepository) MarkHeaderChecked(headerID int64) error {
return repo.MarkHeaderChecked(headerID, repository.db, constants.JugFileVowChecked)
}

func (repository JugFileVowRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.MissingHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.JugFileVowChecked)
}

func (repository JugFileVowRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.RecheckHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.JugFileVowChecked)
}

func (repository *JugFileVowRepository) SetDB(db *postgres.DB) {
repository.db = db
}
9 changes: 0 additions & 9 deletions transformers/events/jug_init/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@ import (

log "github.com/sirupsen/logrus"
repo "github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"

"github.com/vulcanize/mcd_transformers/transformers/shared"
Expand Down Expand Up @@ -86,14 +85,6 @@ func (repository JugInitRepository) MarkHeaderChecked(headerID int64) error {
return repo.MarkHeaderChecked(headerID, repository.db, constants.JugInitChecked)
}

func (repository JugInitRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.MissingHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.JugInitChecked)
}

func (repository JugInitRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.RecheckHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.JugInitChecked)
}

func (repository *JugInitRepository) SetDB(db *postgres.DB) {
repository.db = db
}
9 changes: 0 additions & 9 deletions transformers/events/pip_log_value/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ import (
log "github.com/sirupsen/logrus"

repo "github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"

"github.com/vulcanize/mcd_transformers/transformers/shared/constants"
Expand Down Expand Up @@ -78,14 +77,6 @@ func (repository PipLogValueRepository) MarkHeaderChecked(headerID int64) error
return repo.MarkHeaderChecked(headerID, repository.db, constants.PipLogValueChecked)
}

func (repository PipLogValueRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.MissingHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.PipLogValueChecked)
}

func (repository PipLogValueRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repo.RecheckHeaders(startingBlockNumber, endingBlockNumber, repository.db, constants.PipLogValueChecked)
}

func (repository *PipLogValueRepository) SetDB(db *postgres.DB) {
repository.db = db
}
9 changes: 0 additions & 9 deletions transformers/events/spot_file/mat/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ import (
"github.com/vulcanize/mcd_transformers/transformers/shared"
"github.com/vulcanize/mcd_transformers/transformers/shared/constants"
"github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"
)

Expand Down Expand Up @@ -83,14 +82,6 @@ func (repo SpotFileMatRepository) MarkHeaderChecked(headerID int64) error {
return repository.MarkHeaderChecked(headerID, repo.db, constants.SpotFileMatChecked)
}

func (repo SpotFileMatRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repository.MissingHeaders(startingBlockNumber, endingBlockNumber, repo.db, constants.SpotFileMatChecked)
}

func (repo SpotFileMatRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repository.RecheckHeaders(startingBlockNumber, endingBlockNumber, repo.db, constants.SpotFileMatChecked)
}

func (repo *SpotFileMatRepository) SetDB(db *postgres.DB) {
repo.db = db
}
9 changes: 0 additions & 9 deletions transformers/events/spot_file/pip/repository.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@ import (

"github.com/sirupsen/logrus"
"github.com/vulcanize/vulcanizedb/libraries/shared/repository"
"github.com/vulcanize/vulcanizedb/pkg/core"
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"

"github.com/vulcanize/mcd_transformers/transformers/shared"
Expand Down Expand Up @@ -85,14 +84,6 @@ func (repo SpotFilePipRepository) MarkHeaderChecked(headerID int64) error {
return repository.MarkHeaderChecked(headerID, repo.db, constants.SpotFilePipChecked)
}

func (repo SpotFilePipRepository) MissingHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repository.MissingHeaders(startingBlockNumber, endingBlockNumber, repo.db, constants.SpotFilePipChecked)
}

func (repo SpotFilePipRepository) RecheckHeaders(startingBlockNumber, endingBlockNumber int64) ([]core.Header, error) {
return repository.RecheckHeaders(startingBlockNumber, endingBlockNumber, repo.db, constants.SpotFilePipChecked)
}

func (repo *SpotFilePipRepository) SetDB(db *postgres.DB) {
repo.db = db
}
Loading