Adapt LedgerTransactionReader to support seeking and on-the-fly reads

stellar · Apr 15, 2024 · 07a9d40 · 07a9d40
1 parent 49c2adc
commit 07a9d40
Show file tree

Hide file tree

Showing 4 changed files with 98 additions and 378 deletions.
diff --git a/ingest/lazy_transaction_reader.go b/ingest/lazy_transaction_reader.go
diff --git a/ingest/lazy_transaction_reader_test.go b/ingest/lazy_transaction_reader_test.go
diff --git a/ingest/ledger_change_reader.go b/ingest/ledger_change_reader.go
@@ -176,7 +176,7 @@ func (r *LedgerChangeReader) Read() (Change, error) {
 		}
 		return r.Read()
 	case evictionChangesState:
-		entries, err := r.ledgerCloseMeta.EvictedPersistentLedgerEntries()
+		entries, err := r.lcm.EvictedPersistentLedgerEntries()
 		if err != nil {
 			return Change{}, err
 		}
@@ -196,9 +196,9 @@ func (r *LedgerChangeReader) Read() (Change, error) {
 		return r.Read()
 	case upgradeChangesState:
 		// Get upgrade changes
-		if r.upgradeIndex < len(r.LedgerTransactionReader.ledgerCloseMeta.UpgradesProcessing()) {
+		if r.upgradeIndex < len(r.LedgerTransactionReader.lcm.UpgradesProcessing()) {
 			changes := GetChangesFromLedgerEntryChanges(
-				r.LedgerTransactionReader.ledgerCloseMeta.UpgradesProcessing()[r.upgradeIndex].Changes,
+				r.LedgerTransactionReader.lcm.UpgradesProcessing()[r.upgradeIndex].Changes,
 			)
 			r.pending = append(r.pending, changes...)
 			r.upgradeIndex++