feat: index operator socket registry with filter logs

Layr-Labs · Jan 2, 2025 · 1af099c · 1af099c
1 parent 59b7ff7
commit 1af099c
Show file tree

Hide file tree

Showing 6 changed files with 1,522 additions and 31 deletions.
diff --git a/api/clients/retrieval_client_test.go b/api/clients/retrieval_client_test.go
@@ -127,7 +127,7 @@ func setup(t *testing.T) {
 		},
 		Data: codec.ConvertByPaddingEmptyByte(gettysburgAddressBytes),
 	}
-	operatorState, err = indexedChainState.GetOperatorState(context.Background(), (0), []core.QuorumID{quorumID})
+	operatorState, err := chainState.GetOperatorState(context.Background(), (0), []core.QuorumID{quorumID})
 	if err != nil {
 		t.Fatalf("failed to get operator state: %s", err)
 	}

diff --git a/common/abi.go b/common/abi.go
@@ -9,4 +9,11 @@ import (
 //go:embed abis/EigenDAServiceManager.json
 var ServiceManagerAbi []byte
 
+//go:embed abis/RegistryCoordinator.json
+var RegistryCoordinatorAbi []byte
+
 var BatchConfirmedEventSigHash = crypto.Keccak256Hash([]byte("BatchConfirmed(bytes32,uint32)"))
+var OperatorSocketUpdateEventSigHash = crypto.Keccak256Hash([]byte("OperatorSocketUpdate(bytes32,string)"))
+
+// TODO: consider adding deregistration for limiting size of socket map
+// var OperatorDeregisteredEventSigHash = crypto.Keccak256Hash([]byte("OperatorDeregistered(address,bytes32)"))