[Access] Add contracts extended index and endpoints

access/backends/extended/api.go

@@ -111,4 +111,64 @@ type API interface {
 		expandOptions ScheduledTransactionExpandOptions,
 		encodingVersion entities.EventEncodingVersion,
 	) (*accessmodel.ScheduledTransactionsPage, error)
+
+	// GetContract returns the most recent deployment of the given contract.
+	//
+	// Expected error returns during normal operations:
+	//   - [codes.NotFound]: if no contract with the given identifier exists
+	//   - [codes.FailedPrecondition]: if the index has not been initialized
+	GetContract(
+		ctx context.Context,
+		id string,
+		filter ContractDeploymentFilter,
+		expandOptions ContractDeploymentExpandOptions,
+		encodingVersion entities.EventEncodingVersion,
+	) (*accessmodel.ContractDeployment, error)
+
+	// GetContractDeployments returns a paginated list of all deployments of the given contract,
+	// most recent first.
+	//
+	// Expected error returns during normal operations:
+	//   - [codes.NotFound]: if no contract with the given identifier exists
+	//   - [codes.FailedPrecondition]: if the index has not been initialized
+	//   - [codes.InvalidArgument]: if query parameters are invalid
+	GetContractDeployments(
+		ctx context.Context,
+		id string,
+		limit uint32,
+		cursor *accessmodel.ContractDeploymentsCursor,
+		filter ContractDeploymentFilter,
+		expandOptions ContractDeploymentExpandOptions,
+		encodingVersion entities.EventEncodingVersion,
+	) (*accessmodel.ContractDeploymentPage, error)
+
+	// GetContracts returns a paginated list of contracts at their latest deployment.
+	//
+	// Expected error returns during normal operations:
+	//   - [codes.FailedPrecondition]: if the index has not been initialized
+	//   - [codes.InvalidArgument]: if query parameters are invalid
+	GetContracts(
+		ctx context.Context,
+		limit uint32,
+		cursor *accessmodel.ContractDeploymentsCursor,
+		filter ContractDeploymentFilter,
+		expandOptions ContractDeploymentExpandOptions,
+		encodingVersion entities.EventEncodingVersion,
+	) (*accessmodel.ContractDeploymentPage, error)
+
+	// GetContractsByAddress returns a paginated list of contracts at their latest deployment for
+	// the given address.
+	//
+	// Expected error returns during normal operations:
+	//   - [codes.FailedPrecondition]: if the index has not been initialized
+	//   - [codes.InvalidArgument]: if query parameters are invalid
+	GetContractsByAddress(
+		ctx context.Context,
+		address flow.Address,
+		limit uint32,
+		cursor *accessmodel.ContractDeploymentsCursor,
+		filter ContractDeploymentFilter,
+		expandOptions ContractDeploymentExpandOptions,
+		encodingVersion entities.EventEncodingVersion,
+	) (*accessmodel.ContractDeploymentPage, error)
 }

access/backends/extended/backend.go

@@ -40,6 +40,7 @@ type Backend struct {
 	*AccountTransactionsBackend
 	*AccountTransfersBackend
 	*ScheduledTransactionsBackend
+	*ContractsBackend
 
 	log zerolog.Logger
 }
@@ -64,6 +65,7 @@ func New(
 	transactions storage.TransactionsReader,
 	scheduledTransactions storage.ScheduledTransactionsReader,
 	scheduledTxIndex storage.ScheduledTransactionsIndexReader,
+	contractsIndex storage.ContractDeploymentsIndexReader,
 	txStatusDeriver *txstatus.TxStatusDeriver,
 	scriptExecutor execution.ScriptExecutor,
 ) (*Backend, error) {
@@ -102,7 +104,8 @@ func New(
 		log:                          log,
 		AccountTransactionsBackend:   NewAccountTransactionsBackend(log, base, store, chain),
 		AccountTransfersBackend:      NewAccountTransfersBackend(log, base, ftStore, nftStore, chain),
-		ScheduledTransactionsBackend: NewScheduledTransactionsBackend(log, base, chainID, scheduledTxIndex, scheduledTransactions, state, scriptExecutor),
+		ScheduledTransactionsBackend: NewScheduledTransactionsBackend(log, base, chainID, scheduledTxIndex, contractsIndex, scheduledTransactions, state, scriptExecutor),
+		ContractsBackend:             NewContractsBackend(log, base, contractsIndex),
 	}, nil
 }
 

access/backends/extended/backend_account_transfers_test.go

@@ -100,7 +100,6 @@ func TestBackend_GetAccountFungibleTokenTransfers(t *testing.T) {
 					RecipientAddress: unittest.RandomAddressFixture(),
 				},
 			},
-			NextCursor: nil,
 		}
 
 		blockID := unittest.IdentifierFixture()
@@ -328,7 +327,6 @@ func TestBackend_GetAccountNonFungibleTokenTransfers(t *testing.T) {
 					RecipientAddress: unittest.RandomAddressFixture(),
 				},
 			},
-			NextCursor: nil,
 		}
 
 		blockID := unittest.IdentifierFixture()