Add getTransactions endpoint

cmd/soroban-rpc/internal/config/config.go

@@ -25,6 +25,7 @@ type Config struct {
 	CheckpointFrequency                         uint32
 	CoreRequestTimeout                          time.Duration
 	DefaultEventsLimit                          uint
+	DefaultTransactionsLimit                    uint
 	EventLedgerRetentionWindow                  uint32
 	FriendbotURL                                string
 	HistoryArchiveURLs                          []string
@@ -33,6 +34,7 @@ type Config struct {
 	LogFormat                                   LogFormat
 	LogLevel                                    logrus.Level
 	MaxEventsLimit                              uint
+	MaxTransactionsLimit                        uint
 	MaxHealthyLedgerLatency                     time.Duration
 	NetworkPassphrase                           string
 	PreflightWorkerCount                        uint
@@ -48,6 +50,7 @@ type Config struct {
 	RequestBacklogGetLatestLedgerQueueLimit     uint
 	RequestBacklogGetLedgerEntriesQueueLimit    uint
 	RequestBacklogGetTransactionQueueLimit      uint
+	RequestBacklogGetTransactionsQueueLimit     uint
 	RequestBacklogSendTransactionQueueLimit     uint
 	RequestBacklogSimulateTransactionQueueLimit uint
 	RequestExecutionWarningThreshold            time.Duration
@@ -59,6 +62,7 @@ type Config struct {
 	MaxGetLatestLedgerExecutionDuration         time.Duration
 	MaxGetLedgerEntriesExecutionDuration        time.Duration
 	MaxGetTransactionExecutionDuration          time.Duration
+	MaxGetTransactionsExecutionDuration         time.Duration
 	MaxSendTransactionExecutionDuration         time.Duration
 	MaxSimulateTransactionExecutionDuration     time.Duration
 

cmd/soroban-rpc/internal/config/options.go

@@ -251,6 +251,28 @@ func (cfg *Config) options() ConfigOptions {
 				return nil
 			},
 		},
+		{
+			Name:         "max-transactions-limit",
+			Usage:        "Maximum amount of transactions allowed in a single getTransactions response",
+			ConfigKey:    &cfg.MaxTransactionsLimit,
+			DefaultValue: uint(200),
+		},
+		{
+			Name:         "default-transactions-limit",
+			Usage:        "Default cap on the amount of transactions included in a single getTransactions response",
+			ConfigKey:    &cfg.DefaultTransactionsLimit,
+			DefaultValue: uint(50),
+			Validate: func(co *ConfigOption) error {
+				if cfg.DefaultTransactionsLimit > cfg.MaxTransactionsLimit {
+					return fmt.Errorf(
+						"default-transactions-limit (%v) cannot exceed max-transactions-limit (%v)",
+						cfg.DefaultTransactionsLimit,
+						cfg.MaxTransactionsLimit,
+					)
+				}
+				return nil
+			},
+		},
 		{
 			Name: "max-healthy-ledger-latency",
 			Usage: "maximum ledger latency (i.e. time elapsed since the last known ledger closing time) considered to be healthy" +
@@ -334,6 +356,13 @@ func (cfg *Config) options() ConfigOptions {
 			DefaultValue: uint(1000),
 			Validate:     positive,
 		},
+		{
+			TomlKey:      strutils.KebabToConstantCase("request-backlog-get-transactions-queue-limit"),
+			Usage:        "Maximum number of outstanding GetTransactions requests",
+			ConfigKey:    &cfg.RequestBacklogGetTransactionsQueueLimit,
+			DefaultValue: uint(1000),
+			Validate:     positive,
+		},
 		{
 			TomlKey:      strutils.KebabToConstantCase("request-backlog-send-transaction-queue-limit"),
 			Usage:        "Maximum number of outstanding SendTransaction requests",
@@ -402,6 +431,12 @@ func (cfg *Config) options() ConfigOptions {
 			ConfigKey:    &cfg.MaxGetTransactionExecutionDuration,
 			DefaultValue: 5 * time.Second,
 		},
+		{
+			TomlKey:      strutils.KebabToConstantCase("max-get-transactions-execution-duration"),
+			Usage:        "The maximum duration of time allowed for processing a getTransactions request. When that time elapses, the rpc server would return -32001 and abort the request's execution",
+			ConfigKey:    &cfg.MaxGetTransactionsExecutionDuration,
+			DefaultValue: 5 * time.Second,
+		},
 		{
 			TomlKey:      strutils.KebabToConstantCase("max-send-transaction-execution-duration"),
 			Usage:        "The maximum duration of time allowed for processing a sendTransaction request. When that time elapses, the rpc server would return -32001 and abort the request's execution",

cmd/soroban-rpc/internal/db/mock_transaction.go → cmd/soroban-rpc/internal/db/mocks.go

@@ -15,20 +15,24 @@ import (
 type mockTransactionHandler struct {
 	passphrase string
 
-	ledgerRange ledgerbucketwindow.LedgerRange
-	txs         map[string]ingest.LedgerTransaction
-	ledgers     map[string]*xdr.LedgerCloseMeta
+	ledgerRange     ledgerbucketwindow.LedgerRange
+	txs             map[string]ingest.LedgerTransaction
+	txHashToMeta    map[string]*xdr.LedgerCloseMeta
+	ledgerSeqToMeta map[uint32]*xdr.LedgerCloseMeta
 }
 
 func NewMockTransactionStore(passphrase string) *mockTransactionHandler {
 	return &mockTransactionHandler{
-		passphrase: passphrase,
-		txs:        make(map[string]ingest.LedgerTransaction),
-		ledgers:    make(map[string]*xdr.LedgerCloseMeta),
+		passphrase:      passphrase,
+		txs:             make(map[string]ingest.LedgerTransaction),
+		txHashToMeta:    make(map[string]*xdr.LedgerCloseMeta),
+		ledgerSeqToMeta: make(map[uint32]*xdr.LedgerCloseMeta),
 	}
 }
 
 func (txn *mockTransactionHandler) InsertTransactions(lcm xdr.LedgerCloseMeta) error {
+	txn.ledgerSeqToMeta[lcm.LedgerSequence()] = &lcm
+
 	reader, err := ingest.NewLedgerTransactionReaderFromLedgerCloseMeta(txn.passphrase, lcm)
 	if err != nil {
 		return err
@@ -44,7 +48,7 @@ func (txn *mockTransactionHandler) InsertTransactions(lcm xdr.LedgerCloseMeta) e
 
 		h := tx.Result.TransactionHash.HexString()
 		txn.txs[h] = tx
-		txn.ledgers[h] = &lcm
+		txn.txHashToMeta[h] = &lcm
 	}
 
 	if lcmSeq := lcm.LedgerSequence(); lcmSeq < txn.ledgerRange.FirstLedger.Sequence ||
@@ -72,12 +76,35 @@ func (txn *mockTransactionHandler) GetTransaction(ctx context.Context, hash xdr.
 	if tx, ok := txn.txs[hash.HexString()]; !ok {
 		return Transaction{}, txn.ledgerRange, ErrNoTransaction
 	} else {
-		itx, err := ParseTransaction(*txn.ledgers[hash.HexString()], tx)
+		itx, err := ParseTransaction(*txn.txHashToMeta[hash.HexString()], tx)
 		return itx, txn.ledgerRange, err
 	}
 }
 
 func (txn *mockTransactionHandler) RegisterMetrics(_, _ prometheus.Observer) {}
 
+type mockLedgerReader struct {
+	txn mockTransactionHandler
+}
+
+func NewMockLedgerReader(txn *mockTransactionHandler) *mockLedgerReader {
+	return &mockLedgerReader{
+		txn: *txn,
+	}
+}
+
+func (m *mockLedgerReader) GetLedger(ctx context.Context, sequence uint32) (xdr.LedgerCloseMeta, bool, error) {
+	lcm, ok := m.txn.ledgerSeqToMeta[sequence]
+	if !ok {
+		return xdr.LedgerCloseMeta{}, false, nil
+	}
+	return *lcm, true, nil
+}
+
+func (m *mockLedgerReader) StreamAllLedgers(ctx context.Context, f StreamLedgerFn) error {
+	return nil
+}
+
 var _ TransactionReader = &mockTransactionHandler{}
 var _ TransactionWriter = &mockTransactionHandler{}
+var _ LedgerReader = &mockLedgerReader{}

cmd/soroban-rpc/internal/jsonrpc.go

@@ -204,6 +204,13 @@ func NewJSONRPCHandler(cfg *config.Config, params HandlerParams) Handler {
 			queueLimit:           cfg.RequestBacklogGetTransactionQueueLimit,
 			requestDurationLimit: cfg.MaxGetTransactionExecutionDuration,
 		},
+		{
+			methodName:           "getTransactions",
+			underlyingHandler:    methods.NewGetTransactionsHandler(params.Logger, params.LedgerReader, params.TransactionReader, cfg.MaxTransactionsLimit, cfg.DefaultTransactionsLimit, cfg.NetworkPassphrase),
+			longName:             "get_transactions",
+			queueLimit:           cfg.RequestBacklogGetTransactionsQueueLimit,
+			requestDurationLimit: cfg.MaxGetTransactionsExecutionDuration,
+		},
 		{
 			methodName: "sendTransaction",
 			underlyingHandler: methods.NewSendTransactionHandler(