Skip to content

Commit

Permalink
Remove db.SessionInterface param
Browse files Browse the repository at this point in the history
  • Loading branch information
aditya1702 committed Jul 29, 2024
1 parent 943b01d commit 557ab81
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions cmd/soroban-rpc/internal/db/db.go
Original file line number Diff line number Diff line change
Expand Up @@ -132,7 +132,7 @@ func getMetaValue(ctx context.Context, q db.SessionInterface, key string) (strin
return results[0], nil
}

func getLatestLedgerSequence(ctx context.Context, _ db.SessionInterface, ledgerReader LedgerReader, cache *dbCache) (uint32, error) {
func getLatestLedgerSequence(ctx context.Context, ledgerReader LedgerReader, cache *dbCache) (uint32, error) {
ledgerRange, err := ledgerReader.GetLedgerRange(ctx)
if err != nil {
return 0, err
Expand Down Expand Up @@ -210,7 +210,7 @@ func NewReadWriter(
}

func (rw *readWriter) GetLatestLedgerSequence(ctx context.Context) (uint32, error) {
return getLatestLedgerSequence(ctx, rw.db, NewLedgerReader(rw.db), rw.db.cache)
return getLatestLedgerSequence(ctx, NewLedgerReader(rw.db), rw.db.cache)
}

func (rw *readWriter) NewTx(ctx context.Context) (WriteTx, error) {
Expand Down
4 changes: 2 additions & 2 deletions cmd/soroban-rpc/internal/db/ledgerentry.go
Original file line number Diff line number Diff line change
Expand Up @@ -149,7 +149,7 @@ func (l *ledgerEntryReadTx) GetLatestLedgerSequence() (uint32, error) {
if l.latestLedgerSeqCache != 0 {
return l.latestLedgerSeqCache, nil
}
latestLedgerSeq, err := getLatestLedgerSequence(context.Background(), l.tx, l.ledgerReader, l.globalCache)
latestLedgerSeq, err := getLatestLedgerSequence(context.Background(), l.ledgerReader, l.globalCache)
if err == nil {
l.latestLedgerSeqCache = latestLedgerSeq
}
Expand Down Expand Up @@ -342,7 +342,7 @@ func NewLedgerEntryReader(db *DB) LedgerEntryReader {
}

func (r ledgerEntryReader) GetLatestLedgerSequence(ctx context.Context) (uint32, error) {
return getLatestLedgerSequence(ctx, r.db, NewLedgerReader(r.db), r.db.cache)
return getLatestLedgerSequence(ctx, NewLedgerReader(r.db), r.db.cache)
}

// NewCachedTx() caches all accessed ledger entries and select statements. If many ledger entries are accessed, it will grow without bounds.
Expand Down

0 comments on commit 557ab81

Please sign in to comment.