[Access] Add scheduled transactions extended index and endpoints

access/backends/extended/api.go

@@ -70,4 +70,45 @@ type API interface {
 		expandOptions AccountTransferExpandOptions,
 		encodingVersion entities.EventEncodingVersion,
 	) (*accessmodel.NonFungibleTokenTransfersPage, error)
+
+	// GetScheduledTransaction returns a single scheduled transaction by its scheduler-assigned ID.
+	//
+	// Expected error returns during normal operations:
+	//   - [codes.NotFound]: if no transaction with the given ID exists
+	//   - [codes.FailedPrecondition]: if the index has not been initialized
+	GetScheduledTransaction(
+		ctx context.Context,
+		id uint64,
+		expandOptions ScheduledTransactionExpandOptions,
+		encodingVersion entities.EventEncodingVersion,
+	) (*accessmodel.ScheduledTransaction, error)
+
+	// GetScheduledTransactions returns a paginated list of scheduled transactions.
+	//
+	// Expected error returns during normal operations:
+	//   - [codes.FailedPrecondition]: if the index has not been initialized
+	//   - [codes.InvalidArgument]: if the query parameters are invalid
+	GetScheduledTransactions(
+		ctx context.Context,
+		limit uint32,
+		cursor *accessmodel.ScheduledTransactionCursor,
+		filter ScheduledTransactionFilter,
+		expandOptions ScheduledTransactionExpandOptions,
+		encodingVersion entities.EventEncodingVersion,
+	) (*accessmodel.ScheduledTransactionsPage, error)
+
+	// GetScheduledTransactionsByAddress returns a paginated list of scheduled transactions for the given address.
+	//
+	// Expected error returns during normal operations:
+	//   - [codes.FailedPrecondition]: if the index has not been initialized
+	//   - [codes.InvalidArgument]: if the query parameters are invalid
+	GetScheduledTransactionsByAddress(
+		ctx context.Context,
+		address flow.Address,
+		limit uint32,
+		cursor *accessmodel.ScheduledTransactionCursor,
+		filter ScheduledTransactionFilter,
+		expandOptions ScheduledTransactionExpandOptions,
+		encodingVersion entities.EventEncodingVersion,
+	) (*accessmodel.ScheduledTransactionsPage, error)
 }

access/backends/extended/backend.go

@@ -15,6 +15,7 @@ import (
 	txstatus "github.com/onflow/flow-go/engine/access/rpc/backend/transactions/status"
 	"github.com/onflow/flow-go/model/access/systemcollection"
 	"github.com/onflow/flow-go/model/flow"
+	"github.com/onflow/flow-go/module/execution"
 	"github.com/onflow/flow-go/module/irrecoverable"
 	"github.com/onflow/flow-go/state/protocol"
 	"github.com/onflow/flow-go/storage"
@@ -38,6 +39,7 @@ func DefaultConfig() Config {
 type Backend struct {
 	*AccountTransactionsBackend
 	*AccountTransfersBackend
+	*ScheduledTransactionsBackend
 
 	log zerolog.Logger
 }
@@ -61,7 +63,9 @@ func New(
 	collections storage.CollectionsReader,
 	transactions storage.TransactionsReader,
 	scheduledTransactions storage.ScheduledTransactionsReader,
+	scheduledTxIndex storage.ScheduledTransactionsIndexReader,
 	txStatusDeriver *txstatus.TxStatusDeriver,
+	scriptExecutor execution.ScriptExecutor,
 ) (*Backend, error) {
 	log = log.With().Str("component", "extended_backend").Logger()
 
@@ -85,6 +89,7 @@ func New(
 	base := &backendBase{
 		config:                config,
 		headers:               headers,
+		blocks:                blocks,
 		collections:           collections,
 		transactions:          transactions,
 		scheduledTransactions: scheduledTransactions,
@@ -94,9 +99,10 @@ func New(
 
 	chain := chainID.Chain()
 	return &Backend{
-		log:                        log,
-		AccountTransactionsBackend: NewAccountTransactionsBackend(log, base, store, chain),
-		AccountTransfersBackend:    NewAccountTransfersBackend(log, base, ftStore, nftStore, chain),
+		log:                          log,
+		AccountTransactionsBackend:   NewAccountTransactionsBackend(log, base, store, chain),
+		AccountTransfersBackend:      NewAccountTransfersBackend(log, base, ftStore, nftStore, chain),
+		ScheduledTransactionsBackend: NewScheduledTransactionsBackend(log, base, chainID, scheduledTxIndex, scheduledTransactions, state, scriptExecutor),
 	}, nil
 }
 
@@ -112,8 +118,7 @@ func mapReadError(ctx context.Context, label string, err error) error {
 	case errors.Is(err, storage.ErrNotFound):
 		return status.Errorf(codes.NotFound, "not found: %v", err)
 	default:
-		err = fmt.Errorf("failed to get %s: %w", label, err)
-		irrecoverable.Throw(ctx, err)
+		irrecoverable.Throw(ctx, fmt.Errorf("failed to get %s: %w", label, err))
 		return err
 	}
 }

access/backends/extended/backend_base.go

@@ -20,6 +20,7 @@ type backendBase struct {
 	config Config
 
 	headers               storage.Headers
+	blocks                storage.Blocks
 	collections           storage.CollectionsReader
 	transactions          storage.TransactionsReader
 	scheduledTransactions storage.ScheduledTransactionsReader