feat: add ChainGetEvents to the gateway API (#11724)

filecoin-project · Mar 15, 2024 · 12b6d76 · 12b6d76
1 parent bfb3602
commit 12b6d76
Show file tree

Hide file tree

Showing 8 changed files with 22 additions and 0 deletions.
diff --git a/api/api_gateway.go b/api/api_gateway.go
@@ -132,4 +132,5 @@ type Gateway interface {
 
 	GetActorEvents(ctx context.Context, filter *types.ActorEventFilter) ([]*types.ActorEvent, error)
 	SubscribeActorEvents(ctx context.Context, filter *types.ActorEventFilter) (<-chan *types.ActorEvent, error)
+	ChainGetEvents(context.Context, cid.Cid) ([]types.Event, error)
 }
diff --git a/api/proxy_gen.go b/api/proxy_gen.go
diff --git a/build/openrpc/full.json.gz b/build/openrpc/full.json.gz
diff --git a/build/openrpc/gateway.json.gz b/build/openrpc/gateway.json.gz
diff --git a/build/openrpc/miner.json.gz b/build/openrpc/miner.json.gz
diff --git a/build/openrpc/worker.json.gz b/build/openrpc/worker.json.gz
diff --git a/gateway/node.go b/gateway/node.go
@@ -149,6 +149,7 @@ type TargetAPI interface {
 
 	GetActorEvents(ctx context.Context, filter *types.ActorEventFilter) ([]*types.ActorEvent, error)
 	SubscribeActorEvents(ctx context.Context, filter *types.ActorEventFilter) (<-chan *types.ActorEvent, error)
+	ChainGetEvents(ctx context.Context, eventsRoot cid.Cid) ([]types.Event, error)
 }
 
 var _ TargetAPI = *new(api.FullNode) // gateway depends on latest

diff --git a/gateway/proxy_fil.go b/gateway/proxy_fil.go
@@ -451,6 +451,13 @@ func (gw *Node) SubscribeActorEvents(ctx context.Context, filter *types.ActorEve
 	return gw.target.SubscribeActorEvents(ctx, filter)
 }
 
+func (gw *Node) ChainGetEvents(ctx context.Context, eventsRoot cid.Cid) ([]types.Event, error) {
+	if err := gw.limit(ctx, chainRateLimitTokens); err != nil {
+		return nil, err
+	}
+	return gw.target.ChainGetEvents(ctx, eventsRoot)
+}
+
 func (gw *Node) StateReadState(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*api.ActorState, error) {
 	if err := gw.limit(ctx, stateRateLimitTokens); err != nil {
 		return nil, err