synapsecns/sanguine

package config

import (
    "fmt"

    "github.com/ethereum/go-ethereum/common"
    "github.com/richardwilkes/toolbox/collection"
)

// ContractConfig defines the config for a specific contract.
type ContractConfig struct {
    // Address is the address of the contract.
    Address string `yaml:"address"`
    // StartBlock is the block number to start indexing events from.
    StartBlock uint64 `yaml:"start_block"`
    // EndBlock is the block number to stop indexing events at. If this is set, it will enforce the start block and ignore the last indexed block.
    EndBlock uint64 `yaml:"end_block"`
    // RefreshRate is the rate at which the contract is refreshed.
    RefreshRate uint64 `yaml:"refresh_rate"`
}

// ContractConfigs contains a list of ContractConfigs.
type ContractConfigs []ContractConfig

// IsValid validates the contract configs by asserting no two contracts appear twice.
// It also calls IsValid on each individual ContractConfig.
func (c ContractConfigs) IsValid() (ok bool, err error) {
    addressSet := collection.Set[string]{}

    for _, cfg := range c {
        address := common.HexToAddress(cfg.Address).String()
        if addressSet.Contains(address) {
            return false, fmt.Errorf("duplicate contract address %s was found: %w", address, ErrDuplicateAddress)
        }

        ok, err = cfg.IsValid()
        if !ok {
            return false, err
        }

        addressSet.Add(address)
    }

    return true, nil
}

// IsValid validates the contract config.
func (c ContractConfig) IsValid() (ok bool, err error) {
    if c.Address == "" {
        return false, fmt.Errorf("field Address: %w", ErrRequiredField)
    }
    // the `+2` is for the 0x prefix
    if len(c.Address) != (common.AddressLength*2)+2 {
        return false, fmt.Errorf("address not correct length: %w", ErrAddressLength)
    }
    return true, nil
}