@@ -13,7 +13,7 @@ import (
1313 "github.com/benleb/gloomberg/internal"
1414 "github.com/benleb/gloomberg/internal/collections"
1515 "github.com/benleb/gloomberg/internal/config"
16- "github.com/benleb/gloomberg/internal/degendata"
16+ "github.com/benleb/gloomberg/internal/degendb/ degendata"
1717 "github.com/benleb/gloomberg/internal/gbl"
1818 "github.com/benleb/gloomberg/internal/nemo/gloomberg"
1919 "github.com/benleb/gloomberg/internal/nemo/provider"
@@ -35,6 +35,7 @@ import (
3535 "github.com/benleb/gloomberg/internal/ws"
3636 "github.com/charmbracelet/log"
3737 "github.com/ethereum/go-ethereum/common"
38+ "github.com/muesli/termenv"
3839 "github.com/prometheus/client_golang/prometheus/promhttp"
3940 "github.com/redis/rueidis"
4041 "github.com/spf13/cobra"
@@ -57,6 +58,8 @@ var liveCmd = &cobra.Command{
5758}
5859
5960func runGloomberg (_ * cobra.Command , _ []string ) {
61+ termenv .DefaultOutput ().ClearScreen ()
62+
6063 // print header
6164 header := style .GetHeader (internal .GloombergVersion )
6265 fmt .Println (header )
@@ -125,6 +128,14 @@ func runGloomberg(_ *cobra.Command, _ []string) {
125128 gb .Pr (fmt .Sprintf ("connected to %s providers: %s" , style .AlmostWhiteStyle .Render (fmt .Sprint (len (providers ))), style .AlmostWhiteStyle .Render (strings .Join (nodeNames , ", " ))))
126129 }
127130
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+
128139 //
129140 // queue for everything to print to the console
130141 terminalPrinterQueue := make (chan string , 256 )
@@ -135,7 +146,6 @@ func runGloomberg(_ *cobra.Command, _ []string) {
135146 }
136147
137148 // nepa
138- // queueTokenTransactions := make(chan *totra.TokenTransaction, 256)
139149 queueWsOutTokenTransactions := make (chan * totra.TokenTransaction , 256 )
140150 queueWsInTokenTransactions := make (chan * totra.TokenTransaction , 256 )
141151 nePa := nepa .NewNePa (gb )
@@ -148,9 +158,6 @@ func runGloomberg(_ *cobra.Command, _ []string) {
148158
149159 // trapri | ttx printer to process and format the token transactions
150160 go trapri .TokenTransactionFormatter (gb , seawa )
151- // for workerID := 1; workerID <= viper.GetInt("server.workers.ttxFormatter"); workerID++ {
152- // go trapri.TokenTransactionFormatter(gb, seawa, queueWsOutTokenTransactions, queueWsInTokenTransactions)
153- // }
154161
155162 // start subscribing
156163 go nePa .Run ()
@@ -411,10 +418,6 @@ func runGloomberg(_ *cobra.Command, _ []string) {
411418 }()
412419 }
413420
414- // log.Print("")
415- // degendata.ReadOSRawDataFiles(gb, "degendata/raw/opensea/")
416- // log.Print("")
417-
418421 //
419422 // web ui
420423 if viper .GetBool ("web.enabled" ) {
@@ -423,10 +426,6 @@ func runGloomberg(_ *cobra.Command, _ []string) {
423426 gb .PrMod ("web" , "web-ui started" )
424427 }
425428
426- if err := degendata .LoadMetadatas (); err != nil {
427- log .Error (err )
428- }
429-
430429 // prometheus metrics
431430 if viper .GetBool ("metrics.enabled" ) {
432431 go func () {
@@ -512,6 +511,10 @@ func init() { //nolint:gochecknoinits
512511 liveCmd .Flags ().Bool ("show-unknown" , false , "Show unknown" )
513512 _ = viper .BindPFlag ("show.unknown" , liveCmd .Flags ().Lookup ("show-unknown" ))
514513
514+ // degendb
515+ // liveCmd.Flags().StringVar(&ddbPath, "dd-path", "degendata", "path to degendata dir")
516+ viper .SetDefault ("degendata.path" , "degendata" )
517+
515518 // worker settings
516519 viper .SetDefault ("trapri.numOpenSeaEventhandlers" , 3 )
517520 viper .SetDefault ("gloomberg.numEventHubHandlers" , 3 )
0 commit comments