return error if block status is unknown

onflow · Oct 9, 2024 · 4232276 · 4232276
1 parent b1f90ad
commit 4232276
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/access/grpc/grpc.go b/access/grpc/grpc.go
@@ -1303,9 +1303,14 @@ func (c *BaseClient) SubscribeBlockDigestsFromStartBlockID(
 	blockStatus flow.BlockStatus,
 	opts ...grpc.CallOption,
 ) (<-chan flow.BlockDigest, <-chan error, error) {
+	status := convert.BlockStatusToEntity(blockStatus)
+	if status == entities.BlockStatus_BLOCK_UNKNOWN {
+		return nil, nil, newRPCError(errors.New("unknown block status"))
+	}
+
 	request := &access.SubscribeBlockDigestsFromStartBlockIDRequest{
 		StartBlockId: startBlockID.Bytes(),
-		BlockStatus:  convert.BlockStatusToEntity(blockStatus),
+		BlockStatus:  status,
 	}
 
 	subscribeClient, err := c.rpcClient.SubscribeBlockDigestsFromStartBlockID(ctx, request, opts...)