synapsecns · dwasse · Oct 2, 2024 · Oct 2, 2024 · Oct 3, 2024 · Oct 3, 2024
@@ -24,7 +24,7 @@
     "lint": "forge fmt && npm run solhint",
     "lint:check": "forge fmt --check && npm run solhint:check",
     "ci:lint": "npm run lint:check",
-    "build:go": "./flatten.sh contracts/*.sol test/*.sol",
+    "build:go": "./flatten.sh contracts/*.sol test/*.sol test/mocks/*.sol",
     "solhint": "solhint '{contracts,script,test}/**/*.sol' --fix --noPrompt --max-warnings 3",
     "solhint:check": "solhint '{contracts,script,test}/**/*.sol' --max-warnings 3"
   }

@@ -25,6 +25,8 @@ func (b BridgeStatus) Int() uint8 {
 }
 
 // set all contact types.
+//
+//nolint:gosec,intrange
 func init() {
 	for i := 0; i < len(_BridgeStatus_index)-1; i++ {
 		contractType := BridgeStatus(i)

@@ -0,0 +1,82 @@
+package fastbridgev2
+
+import (
+	"bytes"
+	"strings"
+
+	"github.com/ethereum/go-ethereum/accounts/abi"
+	"github.com/ethereum/go-ethereum/common"
+)
+
+// TODO: consider not exporting to avoid accidental mutation.
+var (
+	// BridgeRequestedTopic is the event topic for a bridge request.
+	BridgeRequestedTopic common.Hash
+	// BridgeRelayedTopic is the topic emitted by a bridge relay.
+	BridgeRelayedTopic common.Hash
+	// BridgeProofProvidedTopic is the topic emitted by a bridge relay.
+	BridgeProofProvidedTopic common.Hash
+	// BridgeDepositClaimedTopic is the topic emitted by a bridge relay.
+	BridgeDepositClaimedTopic common.Hash
+	// BridgeProofDisputedTopic is the topic emitted by a bridge dispute.
+	BridgeProofDisputedTopic common.Hash
+)
+
+// static checks to make sure topics actually exist.
+func init() {
+	var err error
+
+	parsedABI, err := abi.JSON(strings.NewReader(FastBridgeV2MetaData.ABI))
+	if err != nil {
+		panic(err)
+	}
+
+	BridgeRequestedTopic = parsedABI.Events["BridgeRequested"].ID
+	BridgeRelayedTopic = parsedABI.Events["BridgeRelayed"].ID
+	BridgeProofProvidedTopic = parsedABI.Events["BridgeProofProvided"].ID
+	BridgeDepositClaimedTopic = parsedABI.Events["BridgeDepositClaimed"].ID
+	BridgeProofDisputedTopic = parsedABI.Events["BridgeProofDisputed"].ID
+
+	_, err = parsedABI.EventByID(BridgeRequestedTopic)
+	if err != nil {
+		panic(err)
+	}
+
+	_, err = parsedABI.EventByID(BridgeRelayedTopic)
+	if err != nil {
+		panic(err)
+	}
+
+	_, err = parsedABI.EventByID(BridgeProofProvidedTopic)
+	if err != nil {
+		panic(err)
+	}
+
+	_, err = parsedABI.EventByID(BridgeProofDisputedTopic)
+	if err != nil {
+		panic(err)
+	}
+}
-
-	_, err = parsedABI.EventByID(BridgeProofDisputedTopic)
-	if err != nil {
-		panic(err)
-	}
-}
+	_, err = parsedABI.EventByID(BridgeProofProvidedTopic)
+	if err != nil {
+		panic(err)
+	}
+
+	// Validate BridgeDepositClaimedTopic
+	_, err = parsedABI.EventByID(BridgeDepositClaimedTopic)
+	if err != nil {
+		panic(err)
+	}
+
+	_, err = parsedABI.EventByID(BridgeProofDisputedTopic)
+	if err != nil {
+		panic(err)
+	}
+}
-
-	_, err = parsedABI.EventByID(BridgeProofDisputedTopic)
-	if err != nil {
-		panic(err)
-	}
-}
+	_, err = parsedABI.EventByID(BridgeProofProvidedTopic)
+	if err != nil {
+		panic(err)
+	}
+
+	// Validate BridgeDepositClaimedTopic
+	_, err = parsedABI.EventByID(BridgeDepositClaimedTopic)
+	if err != nil {
+		panic(err)
+	}
+
+	_, err = parsedABI.EventByID(BridgeProofDisputedTopic)
+	if err != nil {
+		panic(err)
+	}
+}
+
+// topicMap maps events to topics.
+// this is returned as a function to assert immutability.
+func topicMap() map[EventType]common.Hash {
+	return map[EventType]common.Hash{
+		BridgeRequestedEvent:      BridgeRequestedTopic,
+		BridgeRelayedEvent:        BridgeRelayedTopic,
+		BridgeProofProvidedEvent:  BridgeProofProvidedTopic,
+		BridgeDepositClaimedEvent: BridgeDepositClaimedTopic,
+		BridgeDisputeEvent:        BridgeProofDisputedTopic,
+	}
+}
+
+// eventTypeFromTopic gets the event type from the topic
+// returns nil if the topic is not found.
+func eventTypeFromTopic(ogTopic common.Hash) *EventType {
+	for eventType, topic := range topicMap() {
+		if bytes.Equal(ogTopic.Bytes(), topic.Bytes()) {
+			return &eventType
+		}
+	}
+	return nil
+}
-func eventTypeFromTopic(ogTopic common.Hash) *EventType {
-	for eventType, topic := range topicMap() {
-		if bytes.Equal(ogTopic.Bytes(), topic.Bytes()) {
-			return &eventType
-		}
-	}
-	return nil
-}
+var cachedTopicMap = topicMap()
+
+func eventTypeFromTopic(ogTopic common.Hash) *EventType {
+	for eventType, topic := range cachedTopicMap {
+		if bytes.Equal(ogTopic.Bytes(), topic.Bytes()) {
+			return &eventType
+		}
+	}
+	return nil
+}
-func eventTypeFromTopic(ogTopic common.Hash) *EventType {
-	for eventType, topic := range topicMap() {
-		if bytes.Equal(ogTopic.Bytes(), topic.Bytes()) {
-			return &eventType
-		}
-	}
-	return nil
-}
+func eventTypeFromTopic(ogTopic common.Hash) EventType {
+	for eventType, topic := range topicMap() {
+		if bytes.Equal(ogTopic.Bytes(), topic.Bytes()) {
+			return eventType
+		}
+	}
+	return UnknownEventType
+}
-func eventTypeFromTopic(ogTopic common.Hash) *EventType {
-	for eventType, topic := range topicMap() {
-		if bytes.Equal(ogTopic.Bytes(), topic.Bytes()) {
-			return &eventType
-		}
-	}
-	return nil
-}
+var cachedTopicMap = topicMap()
+
+func eventTypeFromTopic(ogTopic common.Hash) *EventType {
+	for eventType, topic := range cachedTopicMap {
+		if bytes.Equal(ogTopic.Bytes(), topic.Bytes()) {
+			return &eventType
+		}
+	}
+	return nil
+}
-func eventTypeFromTopic(ogTopic common.Hash) *EventType {
-	for eventType, topic := range topicMap() {
-		if bytes.Equal(ogTopic.Bytes(), topic.Bytes()) {
-			return &eventType
-		}
-	}
-	return nil
-}
+func eventTypeFromTopic(ogTopic common.Hash) EventType {
+	for eventType, topic := range topicMap() {
+		if bytes.Equal(ogTopic.Bytes(), topic.Bytes()) {
+			return eventType
+		}
+	}
+	return UnknownEventType
+}
@@ -0,0 +1,6 @@
+package fastbridgev2
+
+// GetAllBridgeStatuses exports all bridge statuses for testing.
+func GetAllBridgeStatuses() []BridgeStatus {
+	return allBridgeStatuses
+}