agents/contracts/summit/parser.go
package summit
import (
"fmt"
"github.com/ethereum/go-ethereum/common"
ethTypes "github.com/ethereum/go-ethereum/core/types"
"github.com/synapsecns/sanguine/agents/types"
)
// Parser parses events from the summit contract.
type Parser interface {
// EventType determines the event type.
EventType(log ethTypes.Log) (_ EventType, ok bool)
// ParseAttestationSaved parses a AttestationSaved event.
ParseAttestationSaved(log ethTypes.Log) (_ types.Attestation, ok bool)
}
type parserImpl struct {
// filterer is the parser filterer we use to parse events
filterer *SummitFilterer
}
// NewParser creates a new parser for the summit contract.
func NewParser(summitAddress common.Address) (Parser, error) {
parser, err := NewSummitFilterer(summitAddress, nil)
if err != nil {
return nil, fmt.Errorf("could not create %T: %w", SummitFilterer{}, err)
}
return &parserImpl{filterer: parser}, nil
}
func (p parserImpl) EventType(log ethTypes.Log) (_ EventType, ok bool) {
for _, logTopic := range log.Topics {
eventType := eventTypeFromTopic(logTopic)
if eventType == nil {
continue
}
return *eventType, true
}
// return an unknown event to avoid cases where user failed to check the event type
return EventType(len(topicMap()) + 2), false
}
// ParseAttestationSaved parses a AttesationSaved event.
func (p parserImpl) ParseAttestationSaved(log ethTypes.Log) (_ types.Attestation, ok bool) {
summitAttestationSaved, err := p.filterer.ParseAttestationSaved(log)
if err != nil {
return nil, false
}
attestation, err := types.DecodeAttestation(summitAttestationSaved.Attestation)
if err != nil {
return nil, false
}
return attestation, true
}
// EventType is the type of the summit event
//
//go:generate go run golang.org/x/tools/cmd/stringer -type=EventType
type EventType uint
const (
// AttestationSavedEvent is an AttestationAccepted event.
AttestationSavedEvent EventType = 0
)
// Int gets the int for an event type.
func (i EventType) Int() uint8 {
return uint8(i)
}