Remove support for storing ledger entries in local db

Author: urvisavla

cmd/stellar-rpc/internal/daemon/daemon.go

@@ -301,7 +301,6 @@ func createJSONRPCHandler(cfg *config.Config, logger *supportlog.Entry, daemon *
 		FeeStatWindows:    feewindows,
 		Logger:            logger,
 		LedgerReader:      db.NewLedgerReader(daemon.db),
-		LedgerEntryReader: db.NewLedgerEntryReader(daemon.db),
 		TransactionReader: db.NewTransactionReader(logger, daemon.db, cfg.NetworkPassphrase),
 		EventReader:       db.NewEventReader(logger, daemon.db, cfg.NetworkPassphrase),
 		PreflightGetter:   daemon.preflightWorkerPool,

cmd/stellar-rpc/internal/db/db.go

@@ -39,7 +39,6 @@ type ReadWriter interface {
 type WriteTx interface {
 	TransactionWriter() TransactionWriter
 	EventWriter() EventWriter
-	LedgerEntryWriter() LedgerEntryWriter
 	LedgerWriter() LedgerWriter
 
 	Commit(ledgerCloseMeta xdr.LedgerCloseMeta) error
@@ -247,13 +246,7 @@ func (rw *readWriter) NewTx(ctx context.Context) (WriteTx, error) {
 		stmtCache:              stmtCache,
 		historyRetentionWindow: rw.historyRetentionWindow,
 		ledgerWriter:           ledgerWriter{stmtCache: stmtCache},
-		ledgerEntryWriter: ledgerEntryWriter{
-			stmtCache:               stmtCache,
-			buffer:                  xdr.NewEncodingBuffer(),
-			keyToEntryBatch:         make(map[string]*xdr.LedgerEntry, rw.maxBatchSize),
-			ledgerEntryCacheWriteTx: db.cache.ledgerEntries.newWriteTx(rw.maxBatchSize),
-			maxBatchSize:            rw.maxBatchSize,
-		},
+
 		txWriter: transactionHandler{
 			log:        rw.log,
 			db:         txSession,
@@ -279,17 +272,12 @@ type writeTx struct {
 	postCommit             func() error
 	tx                     db.SessionInterface
 	stmtCache              *sq.StmtCache
-	ledgerEntryWriter      ledgerEntryWriter
 	ledgerWriter           ledgerWriter
 	txWriter               transactionHandler
 	eventWriter            eventHandler
 	historyRetentionWindow uint32
 }
 
-func (w writeTx) LedgerEntryWriter() LedgerEntryWriter {
-	return w.ledgerEntryWriter
-}
-
 func (w writeTx) LedgerWriter() LedgerWriter {
 	return w.ledgerWriter
 }
@@ -306,10 +294,6 @@ func (w writeTx) Commit(ledgerCloseMeta xdr.LedgerCloseMeta) error {
 	ledgerSeq := ledgerCloseMeta.LedgerSequence()
 	ledgerCloseTime := ledgerCloseMeta.LedgerCloseTime()
 
-	if err := w.ledgerEntryWriter.flush(); err != nil {
-		return err
-	}
-
 	if err := w.ledgerWriter.trimLedgers(ledgerSeq, w.historyRetentionWindow); err != nil {
 		return err
 	}
@@ -332,7 +316,6 @@ func (w writeTx) Commit(ledgerCloseMeta xdr.LedgerCloseMeta) error {
 		}
 		w.globalCache.latestLedgerSeq = ledgerSeq
 		w.globalCache.latestLedgerCloseTime = ledgerCloseTime
-		w.ledgerEntryWriter.ledgerEntryCacheWriteTx.commit()
 		return nil
 	}
 	if err := commitAndUpdateCache(); err != nil {

cmd/stellar-rpc/internal/db/ledger.go

@@ -26,6 +26,7 @@ type LedgerReader interface {
 	GetLedgerRange(ctx context.Context) (ledgerbucketwindow.LedgerRange, error)
 	StreamLedgerRange(ctx context.Context, startLedger uint32, endLedger uint32, f StreamLedgerFn) error
 	NewTx(ctx context.Context) (LedgerReaderTx, error)
+	GetLatestLedgerSequence(ctx context.Context) (uint32, error)
 }
 
 type LedgerReaderTx interface {
@@ -178,6 +179,10 @@ func (r ledgerReader) GetLedgerRange(ctx context.Context) (ledgerbucketwindow.Le
 	return getLedgerRangeWithoutCache(ctx, r.db)
 }
 
+func (r ledgerReader) GetLatestLedgerSequence(ctx context.Context) (uint32, error) {
+	return getLatestLedgerSequence(ctx, r, r.db.cache)
+}
+
 // getLedgerRangeWithCache uses the latest ledger cache to optimize the query.
 // It only needs to look up the first ledger since we have the latest cached.
 func getLedgerRangeWithCache(ctx context.Context, db readDB,