Skip to content

Commit 722ba14

Browse files
committed
make path to degendata repo configurable, read jsons after initializing other stuff
1 parent bcbc72d commit 722ba14

File tree

3 files changed

+14
-11
lines changed

3 files changed

+14
-11
lines changed

cmd/live.go

+12-10
Original file line numberDiff line numberDiff line change
@@ -128,14 +128,6 @@ func runGloomberg(_ *cobra.Command, _ []string) {
128128
gb.Pr(fmt.Sprintf("connected to %s providers: %s", style.AlmostWhiteStyle.Render(fmt.Sprint(len(providers))), style.AlmostWhiteStyle.Render(strings.Join(nodeNames, ", "))))
129129
}
130130

131-
//
132-
// degendata - ranks
133-
go func() {
134-
if err := degendata.LoadOpenseaRanks(gb); err != nil {
135-
gbl.Log.Errorf("error loading opensea ranks: %v", err)
136-
}
137-
}()
138-
139131
//
140132
// queue for everything to print to the console
141133
terminalPrinterQueue := make(chan string, 256)
@@ -418,6 +410,14 @@ func runGloomberg(_ *cobra.Command, _ []string) {
418410
}()
419411
}
420412

413+
//
414+
// degendata - ranks
415+
go func() {
416+
if err := degendata.LoadOpenseaRanks(gb); err != nil {
417+
gbl.Log.Errorf("error loading opensea ranks: %v", err)
418+
}
419+
}()
420+
421421
//
422422
// web ui
423423
if viper.GetBool("web.enabled") {
@@ -447,6 +447,8 @@ func runGloomberg(_ *cobra.Command, _ []string) {
447447
select {}
448448
}
449449

450+
var degendataPath string
451+
450452
func init() { //nolint:gochecknoinits
451453
rootCmd.AddCommand(liveCmd)
452454

@@ -512,8 +514,8 @@ func init() { //nolint:gochecknoinits
512514
_ = viper.BindPFlag("show.unknown", liveCmd.Flags().Lookup("show-unknown"))
513515

514516
// degendb
515-
// liveCmd.Flags().StringVar(&ddbPath, "dd-path", "degendata", "path to degendata dir")
516-
viper.SetDefault("degendata.path", "degendata")
517+
liveCmd.Flags().StringVar(&degendataPath, "degendata", "degendata", "path to degendata repo")
518+
_ = viper.BindPFlag("degendata.path", liveCmd.Flags().Lookup("degendata"))
517519

518520
// worker settings
519521
viper.SetDefault("trapri.numOpenSeaEventhandlers", 3)

degendata

internal/degendb/degendata/degendata.go

+1
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ import (
2020

2121
func LoadOpenseaRanks(gb *gloomberg.Gloomberg) error {
2222
ddPathRanks := path.Join(viper.GetString("degendata.path"), "ranks")
23+
log.Debugf("loading opensea ranks from %s", ddPathRanks)
2324

2425
ranksFiles, err := os.ReadDir(ddPathRanks)
2526
if err != nil {

0 commit comments

Comments
 (0)