synapsecns/sanguine

package fastbridge

import (
    "bytes"
    "fmt"
    "strings"

    "github.com/ethereum/go-ethereum/accounts/abi"
    "github.com/ethereum/go-ethereum/common"
    "github.com/synapsecns/sanguine/services/explorer/types/fastbridge"
)

func init() {
    var err error
    parsedRFQEvent, err := abi.JSON(strings.NewReader(FastBridgeMetaData.ABI))
    if err != nil {
        panic(err)
    }

    BridgeRequestedTopic = parsedRFQEvent.Events["BridgeRequested"].ID

    BridgeRelayedTopic = parsedRFQEvent.Events["BridgeRelayed"].ID
}

// BridgeRequestedTopic is when a FastBridge request is sent out and has additional data.
var BridgeRequestedTopic common.Hash

// BridgeRelayedTopic is when a FastBridge request is relayed and has additional data.
var BridgeRelayedTopic common.Hash

// TopicMap maps events to topics.
// this is returned as a function to assert immutability.
func TopicMap() map[fastbridge.EventType]common.Hash {
    return map[fastbridge.EventType]common.Hash{
        fastbridge.BridgeRelayedEvent:   BridgeRelayedTopic,
        fastbridge.BridgeRequestedEvent: BridgeRequestedTopic,
    }
}

// EventTypeFromTopic gets the event type from the topic
// returns nil if the topic is not found.
func EventTypeFromTopic(ogTopic common.Hash) *fastbridge.EventType {
    for eventType, topic := range TopicMap() {
        if bytes.Equal(ogTopic.Bytes(), topic.Bytes()) {
            return &eventType
        }
    }
    return nil
}

// Topic gets the topic from the event type.
func Topic(eventType fastbridge.EventType) (common.Hash, error) {
    topicHash, ok := TopicMap()[fastbridge.EventType(eventType.Int())]
    if !ok {
        return common.Hash{}, fmt.Errorf("unknown event type: %v", eventType)
    }
    return topicHash, nil
}