synapsecns/sanguine

Method Store.StoreLogsAtHead has 53 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (s Store) StoreLogsAtHead(ctx context.Context, chainID uint32, logs ...types.Log) error {
    var storeLogs []LogAtHead
    for _, log := range logs {
        var topics []sql.NullString

Method Store.RetrieveReceiptsFromHeadRangeQuery has 7 return statements (exceeds 4 allowed).

Open

func (s Store) RetrieveReceiptsFromHeadRangeQuery(ctx context.Context, receiptFilter db.ReceiptFilter, startBlock uint64, endBlock uint64, page int) ([]types.Receipt, error) {
    if receiptFilter.ContractAddress == "" || receiptFilter.ChainID == 0 {
        return nil, fmt.Errorf("contract address and chain ID must be passed")
    }
    if page < 1 {

Method Store.StoreEthTxAtHead has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (s Store) StoreEthTxAtHead(ctx context.Context, tx *types.Transaction, chainID uint32, blockHash common.Hash, blockNumber uint64, transactionIndex uint64) error {

Method Store.RetrieveUnconfirmedEthTxsFromHeadRangeQuery has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (s Store) RetrieveUnconfirmedEthTxsFromHeadRangeQuery(ctx context.Context, ethTxFilter db.EthTxFilter, startBlock uint64, endBlock uint64, lastIndexed uint64, page int) ([]db.TxWithBlockNumber, error) {

Method Store.RetrieveLogsFromHeadRangeQuery has 6 return statements (exceeds 4 allowed).

Open

func (s Store) RetrieveLogsFromHeadRangeQuery(ctx context.Context, logFilter db.LogFilter, startBlock uint64, endBlock uint64, page int) ([]*types.Log, error) {
    if logFilter.ContractAddress == "" || logFilter.ChainID == 0 {
        return nil, fmt.Errorf("contract address and chain ID must be passed")
    }
    if page < 1 {

Method Store.RetrieveUnconfirmedEthTxsFromHeadRangeQuery has 6 return statements (exceeds 4 allowed).

Open

func (s Store) RetrieveUnconfirmedEthTxsFromHeadRangeQuery(ctx context.Context, ethTxFilter db.EthTxFilter, startBlock uint64, endBlock uint64, lastIndexed uint64, page int) ([]db.TxWithBlockNumber, error) {
    if ethTxFilter.ChainID == 0 {
        return nil, fmt.Errorf("chain ID must be passed")
    }
    if page < 1 {

Method Store.RetrieveReceiptsFromHeadRangeQuery has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (s Store) RetrieveReceiptsFromHeadRangeQuery(ctx context.Context, receiptFilter db.ReceiptFilter, startBlock uint64, endBlock uint64, page int) ([]types.Receipt, error) {

Method Store.RetrieveLogsFromHeadRangeQuery has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (s Store) RetrieveLogsFromHeadRangeQuery(ctx context.Context, logFilter db.LogFilter, startBlock uint64, endBlock uint64, page int) ([]*types.Log, error) {

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

Open

    if s.db.Dialector.Name() == dbcommon.Sqlite.String() {
        dbTx = dbTx.Clauses(clause.OnConflict{
            Columns: []clause.Column{
                {Name: ContractAddressFieldName}, {Name: ChainIDFieldName}, {Name: TxHashFieldName}, {Name: BlockIndexFieldName},
            },

• Read up
  Read up

Identical blocks of code found in 4 locations. Consider refactoring.

Open

    if s.DB().Dialector.Name() == dbcommon.Sqlite.String() {
        dbTx = dbTx.Clauses(clause.OnConflict{
            Columns:   []clause.Column{{Name: TxHashFieldName}, {Name: ChainIDFieldName}},
            DoNothing: true,
        })

• Read up
  Read up

Identical blocks of code found in 4 locations. Consider refactoring.

Open

    if s.DB().Dialector.Name() == dbcommon.Sqlite.String() {
        dbTx = dbTx.Clauses(clause.OnConflict{
            Columns:   []clause.Column{{Name: TxHashFieldName}, {Name: ChainIDFieldName}},
            DoNothing: true,
        })

• Read up
  Read up

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

Open

    subQuery2 := s.DB().WithContext(ctx).ToSQL(func(tx *gorm.DB) *gorm.DB {
        return tx.Model(ReceiptAtHead{}).Select(ReceiptColumns).Where("block_number BETWEEN ? AND ?", lastIndexed+1, endBlock).Where(queryFilter).Find(&[]Receipt{})
    })

• Read up
  Read up

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

Open

    subQuery2 := s.DB().WithContext(ctx).ToSQL(func(tx *gorm.DB) *gorm.DB {
        return tx.Model(EthTxAtHead{}).Select(EthTxColumns).Where("block_number BETWEEN ? AND ?", lastIndexed+1, endBlock).Where(queryFilter).Find(&[]EthTx{})
    })

• Read up
  Read up

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

Open

    subQuery2 := s.DB().WithContext(ctx).ToSQL(func(tx *gorm.DB) *gorm.DB {
        return tx.Model(LogAtHead{}).Select(LogColumns).Where("block_number BETWEEN ? AND ?", lastIndexed+1, endBlock).Where(queryFilter).Find(&[]Log{})
    })

• Read up
  Read up

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

Open

    subQuery1 := s.DB().WithContext(ctx).ToSQL(func(tx *gorm.DB) *gorm.DB {
        return tx.Model(EthTx{}).Select("*").Where("block_number BETWEEN ? AND ?", startBlock, lastIndexed).Where(queryFilter).Find(&[]EthTx{})
    })

• Read up
  Read up

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

Open

    subQuery1 := s.DB().WithContext(ctx).ToSQL(func(tx *gorm.DB) *gorm.DB {
        return tx.Model(Receipt{}).Select("*").Where("block_number BETWEEN ? AND ?", startBlock, lastIndexed).Where(queryFilter).Find(&[]Receipt{})
    })

• Read up
  Read up

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

Open

    subQuery1 := s.DB().WithContext(ctx).ToSQL(func(tx *gorm.DB) *gorm.DB {
        return tx.Model(Log{}).Select("*").Where("block_number BETWEEN ? AND ?", startBlock, lastIndexed).Where(queryFilter).Find(&[]Log{})
    })

• Read up
  Read up

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

Open

        for index := 0; index <= indexedTopics+1; index++ {
            if index < topicsLength {
                topics = append(topics, sql.NullString{
                    String: log.Topics[index].String(),
                    Valid:  true,

• Read up
  Read up