add response types, pin protocol-apis version

remove comments

examples/eventSubscriber/main.go

@@ -29,30 +29,53 @@ func NewSidecarClient(url string, insecureConn bool) (v1.EventsClient, error) {
 	return v1.NewEventsClient(grpcClient), nil
 }
 
-func main() {
-	client, err := NewSidecarClient("localhost:7100", true)
+func streamIndexedBlocks(client v1.EventsClient) {
+	stream, err := client.StreamIndexedBlocks(context.Background(), &v1.StreamIndexedBlocksRequest{})
 	if err != nil {
 		panic(err)
 	}
 
-	stream, err := client.StreamIndexedBlocks(context.Background(), &v1.StreamIndexedBlocksRequest{})
+	for {
+		resp := &v1.StreamIndexedBlocksResponse{}
+		err := stream.RecvMsg(resp)
+		if err == io.EOF {
+			fmt.Printf("Server has finished sending\n")
+			return
+		}
+		if err != nil {
+			log.Fatalf("failed to receive: %v", err)
+		}
+
+		fmt.Printf("Received: %v\n", resp)
+	}
+}
+
+func streamStateChanges(client v1.EventsClient) {
+	stream, err := client.StreamEigenStateChanges(context.Background(), &v1.StreamEigenStateChangesRequest{})
 	if err != nil {
 		panic(err)
 	}
 
 	for {
-		resp := &v1.StreamIndexedBlocksResponse{}
+		resp := &v1.StreamEigenStateChangesResponse{}
 		err := stream.RecvMsg(resp)
 		if err == io.EOF {
-			// Server has finished sending
 			fmt.Printf("Server has finished sending\n")
 			return
 		}
 		if err != nil {
 			log.Fatalf("failed to receive: %v", err)
 		}
 
-		// Process your response
 		fmt.Printf("Received: %v\n", resp)
 	}
 }
+
+func main() {
+	client, err := NewSidecarClient("localhost:7100", true)
+	if err != nil {
+		panic(err)
+	}
+
+	streamStateChanges(client)
+}

go.mod

@@ -6,7 +6,7 @@ require (
 	github.com/DataDog/datadog-go/v5 v5.5.0
 	github.com/Layr-Labs/eigenlayer-contracts v0.4.1-holesky-pepe.0.20240813143901-00fc4b95e9c1
 	github.com/Layr-Labs/eigenlayer-rewards-proofs v0.2.13
-	github.com/Layr-Labs/protocol-apis v1.0.0-rc.1.0.20250109222723-376a40434d4e
+	github.com/Layr-Labs/protocol-apis v1.1.0
 	github.com/ethereum/go-ethereum v1.14.9
 	github.com/gocarina/gocsv v0.0.0-20240520201108-78e41c74b4b1
 	github.com/google/uuid v1.6.0

go.sum

@@ -43,6 +43,10 @@ github.com/Layr-Labs/eigenlayer-rewards-proofs v0.2.13 h1:Blb4AE+jC/vddV71w4/MQA
 github.com/Layr-Labs/eigenlayer-rewards-proofs v0.2.13/go.mod h1:PD/HoyzZjxDw1tAcZw3yD0yGddo+yhmwQAi+lk298r4=
 github.com/Layr-Labs/protocol-apis v1.0.0-rc.1.0.20250109222723-376a40434d4e h1:IArMOWI0V+2KFexZbJwZvIxVFTJdaDZG8PMcih/GV4A=
 github.com/Layr-Labs/protocol-apis v1.0.0-rc.1.0.20250109222723-376a40434d4e/go.mod h1:prNA2/mLO5vpMZ2q78Nsn0m97wm28uiRnwO+/yOxigk=
+github.com/Layr-Labs/protocol-apis v1.0.0-rc.1.0.20250109230911-e6fec5ffbd4c h1:uKOEYFWJ6OcCGTMZK8M4rZJHIxdWMuTI7j+LvNe8D84=
+github.com/Layr-Labs/protocol-apis v1.0.0-rc.1.0.20250109230911-e6fec5ffbd4c/go.mod h1:prNA2/mLO5vpMZ2q78Nsn0m97wm28uiRnwO+/yOxigk=
+github.com/Layr-Labs/protocol-apis v1.1.0 h1:PO6x+Y9ORiac2dkaWJayRFqhyzcvMbvRQkDIpLTNtVc=
+github.com/Layr-Labs/protocol-apis v1.1.0/go.mod h1:prNA2/mLO5vpMZ2q78Nsn0m97wm28uiRnwO+/yOxigk=
 github.com/Microsoft/go-winio v0.5.0/go.mod h1:JPGBdM1cNvN/6ISo+n8V5iA4v8pBzdOpzfwIujj1a84=
 github.com/Microsoft/go-winio v0.6.2 h1:F2VQgta7ecxGYO8k3ZZz3RS8fVIXVxONVUPlNERoyfY=
 github.com/Microsoft/go-winio v0.6.2/go.mod h1:yd8OoFMLzJbo9gZq8j5qaps8bJ9aShtEA8Ipt1oGCvU=

pkg/eigenState/avsOperators/avsOperators.go

@@ -60,8 +60,10 @@ func NewAvsOperatorsModel(
 	return s, nil
 }
 
+const AvsOperatorsModelName = "AvsOperatorsModel"
+
 func (a *AvsOperatorsModel) GetModelName() string {
-	return "AvsOperatorsModel"
+	return AvsOperatorsModelName
 }
 
 // Get the state transitions for the AvsOperatorsModel state model

pkg/eigenState/disabledDistributionRoots/disabledDistributionRoots.go

@@ -48,10 +48,10 @@ func NewDisabledDistributionRootsModel(
 	return model, nil
 }
 
-const MODEL_NAME = "DisabledDistributionRootsModel"
+const DisabledDistributionRootsModelName = "DisabledDistributionRootsModel"
 
 func (ddr *DisabledDistributionRootsModel) GetModelName() string {
-	return MODEL_NAME
+	return DisabledDistributionRootsModelName
 }
 
 func (ddr *DisabledDistributionRootsModel) GetStateTransitions() (types.StateTransitions[*types.DisabledDistributionRoot], []uint64) {

pkg/eigenState/operatorShares/operatorShares.go

@@ -95,8 +95,10 @@ func NewOperatorSharesModel(
 	return model, nil
 }
 
+const OperatorSharesModelName = "OperatorSharesModel"
+
 func (osm *OperatorSharesModel) GetModelName() string {
-	return "OperatorSharesModel"
+	return OperatorSharesModelName
 }
 
 type operatorSharesOutput struct {

pkg/eigenState/rewardSubmissions/rewardSubmissions.go

@@ -75,8 +75,10 @@ func NewRewardSubmissionsModel(
 	return model, nil
 }
 
+const RewardSubmissionsModelName = "RewardSubmissionsModel"
+
 func (rs *RewardSubmissionsModel) GetModelName() string {
-	return "RewardSubmissionsModel"
+	return RewardSubmissionsModelName
 }
 
 type genericRewardPaymentData struct {

pkg/eigenState/stakerDelegations/stakerDelegations.go

@@ -65,8 +65,10 @@ func NewStakerDelegationsModel(
 	return model, nil
 }
 
+const StakerDelegationsModelName = "StakerDelegationsModel"
+
 func (s *StakerDelegationsModel) GetModelName() string {
-	return "StakerDelegationsModel"
+	return StakerDelegationsModelName
 }
 
 func (s *StakerDelegationsModel) GetStateTransitions() (types.StateTransitions[*StakerDelegationChange], []uint64) {

pkg/eigenState/stakerShares/stakerShares.go

@@ -79,8 +79,10 @@ func NewStakerSharesModel(
 	return model, nil
 }
 
+const StakerSharesModelName = "StakerSharesModel"
+
 func (ss *StakerSharesModel) GetModelName() string {
-	return "StakerShares"
+	return StakerSharesModelName
 }
 
 type depositOutputData struct {

pkg/eigenState/stateManager/stateManager.go

@@ -179,6 +179,14 @@ func (e *EigenStateManager) encodeModelLeaf(model types.IEigenStateModel, blockN
 	return append(types.MerkleLeafPrefix_EigenStateRoot, append([]byte(model.GetModelName()), root...)...), nil
 }
 
+func (e *EigenStateManager) GetModelsMappedByName() map[string]types.IEigenStateModel {
+	models := make(map[string]types.IEigenStateModel)
+	for _, index := range e.GetSortedModelIndexes() {
+		models[e.StateModels[index].GetModelName()] = e.StateModels[index]
+	}
+	return models
+}
+
 func (e *EigenStateManager) GetSortedModelIndexes() []int {
 	indexes := make([]int, 0, len(e.StateModels))
 	for i := range e.StateModels {

pkg/eigenState/submittedDistributionRoots/submittedDistributionRoots.go

@@ -53,10 +53,10 @@ func NewSubmittedDistributionRootsModel(
 	return model, nil
 }
 
-const MODEL_NAME = "SubmittedDistributionRootsModel"
+const SubmittedDistributionRootsModelName = "SubmittedDistributionRootsModel"
 
 func (sdr *SubmittedDistributionRootsModel) GetModelName() string {
-	return MODEL_NAME
+	return SubmittedDistributionRootsModelName
 }
 
 type distributionRootSubmittedOutput struct {