diff --git a/app/app.go b/app/app.go index 4945e4c7..d8379022 100644 --- a/app/app.go +++ b/app/app.go @@ -39,6 +39,7 @@ import ( evmListener "github.com/sprintertech/sprinter-signing/chains/evm/listener" evmMessage "github.com/sprintertech/sprinter-signing/chains/evm/message" "github.com/sprintertech/sprinter-signing/metrics" + "github.com/sprintertech/sprinter-signing/price" lifiConfig "github.com/sprintertech/solver-sdk/pkg/config" "github.com/sprintertech/sprinter-signing/chains/lighter" @@ -49,7 +50,6 @@ import ( "github.com/sprintertech/sprinter-signing/config" "github.com/sprintertech/sprinter-signing/jobs" "github.com/sprintertech/sprinter-signing/keyshare" - "github.com/sprintertech/sprinter-signing/price" "github.com/sprintertech/sprinter-signing/protocol/across" "github.com/sprintertech/sprinter-signing/protocol/lifi" lighterAPI "github.com/sprintertech/sprinter-signing/protocol/lighter" @@ -141,9 +141,6 @@ func Run() error { msgChan := make(chan []*message.Message) sigChn := make(chan interface{}) - priceAPI, err := price.NewPythPricer(ctx) - panicOnError(err) - signatureCache := cache.NewSignatureCache(communication, sygmaMetrics) go signatureCache.Watch(ctx, sigChn) @@ -176,7 +173,8 @@ func Run() error { usdPricer := pyth.NewClient(ctx) err = usdPricer.Start(ctx) - panicOnError(err) + + priceAPI := price.NewPythPricer(usdPricer) multiPricer := aggregator.New(usdPricer) resolver := token.NewTokenResolver(solverConfig, multiPricer) diff --git a/price/pyth.go b/price/pyth.go index 28c9608d..10c0ef79 100644 --- a/price/pyth.go +++ b/price/pyth.go @@ -1,7 +1,6 @@ package price import ( - "context" "fmt" "strings" @@ -12,16 +11,10 @@ type PythPricer struct { client *pyth.PythClient } -func NewPythPricer(ctx context.Context, opts ...pyth.PythClientOption) (*PythPricer, error) { - client := pyth.NewClient(ctx, opts...) - err := client.Start(ctx) - if err != nil { - return nil, err - } - +func NewPythPricer(client *pyth.PythClient) *PythPricer { return &PythPricer{ - client: pyth.NewClient(ctx, opts...), - }, nil + client: client, + } } func (p *PythPricer) TokenPrice(symbol string) (float64, error) {