synapsecns/sanguine

Function rfqEventToBridgeEvent has 55 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func rfqEventToBridgeEvent(rfqEvent model.RFQEvent) model.BridgeEvent {
    // Only convert BridgeRequestedEvent and BridgeRelayedEvent to bridge events
    // Exclude BridgeDepositRefunded, BridgeProofProvided, and BridgeDepositClaimed
    eventType := rfqEvent.EventType
    if eventType != rfqTypes.BridgeRequestedEvent.Int() &&

Method RFQParser.ParseLog has 9 return statements (exceeds 4 allowed).

Open

func (p *RFQParser) ParseLog(log ethTypes.Log, chainID uint32) (*model.RFQEvent, rfqTypes.EventLog, error) {
    logTopic := log.Topics[0]
    iFace, err := func(log ethTypes.Log) (rfqTypes.EventLog, error) {
        // Get the topic hash safely
        bridgeRequestedTopic, err := fastbridge.Topic(rfqTypes.BridgeRequestedEvent)

Function NewRFQParser has 7 arguments (exceeds 4 allowed). Consider refactoring.

Open

func NewRFQParser(consumerDB db.ConsumerDB, rfqAddress common.Address, consumerFetcher fetcher.ScribeFetcher, rfqService fetcher.RFQService, tokenDataService tokendata.Service, tokenPriceService tokenprice.Service, fromAPI bool) (*RFQParser, error) {

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (p *RFQParser) storeBridgeEvent(ctx context.Context, bridgeEvent model.BridgeEvent) error {
    b := &backoff.Backoff{
        Factor: 2,
        Jitter: true,
        Min:    1 * time.Second,

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func NewRFQParser(consumerDB db.ConsumerDB, rfqAddress common.Address, consumerFetcher fetcher.ScribeFetcher, rfqService fetcher.RFQService, tokenDataService tokendata.Service, tokenPriceService tokenprice.Service, fromAPI bool) (*RFQParser, error) {
    filterer, err := fastbridge.NewFastBridgeFilterer(rfqAddress, nil)
    if err != nil {
        return nil, fmt.Errorf("could not create %T: %w", fastbridge.FastBridgeFilterer{}, err)
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (p *RFQParser) Parse(ctx context.Context, log ethTypes.Log, chainID uint32) (interface{}, error) {
    rfqEvent, iFace, err := p.ParseLog(log, chainID)
    if err != nil {
        return nil, fmt.Errorf("could not parse rfq event: %w", err)
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

type RFQParser struct {
    // consumerDB is the database to store parsed data in
    consumerDB db.ConsumerDB
    // Filterer is the message Filterer we use to parse events
    Filterer *fastbridge.FastBridgeFilterer

• Read up
  Read up