GlcoinCore/lightning-terminal
1
0
Fork 0
mirror of https://github.com/lightninglabs/lightning-terminal.git synced 2026-08-13 12:33:36 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

session: add context to DeleteReservedSessions

Browse source
This commit is contained in:
Elle Mouton 2025-02-25 13:25:26 +02:00
parent 7c30c510a1
commit aa5674cabd
No known key found for this signature in database
GPG key ID: D7D916376026F177
4 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

2
session/interface.go
View file

@ -302,7 +302,7 @@ type Store interface {
// DeleteReservedSessions deletes all sessions that are in the
// StateReserved state.
DeleteReservedSessions() error
DeleteReservedSessions(ctx context.Context) error
// ShiftState updates the state of the session with the given ID to the
// "dest" state.

2
session/kvdb_store.go
View file

@ -436,7 +436,7 @@ func (db *BoltStore) listSessions(filterFn func(s *Session) bool) ([]*Session,
// state.
//
// NOTE: this is part of the Store interface.
func (db *BoltStore) DeleteReservedSessions() error {
func (db *BoltStore) DeleteReservedSessions(_ context.Context) error {
return db.Update(func(tx *bbolt.Tx) error {
sessionBucket, err := getBucket(tx, sessionBucketKey)
if err != nil {

4
session/store_test.go
View file

@ -151,7 +151,7 @@ func TestBasicSessionStore(t *testing.T) {
//
// Calling DeleteReservedSessions should have no effect yet since none
// of the sessions are reserved.
require.NoError(t, db.DeleteReservedSessions())
require.NoError(t, db.DeleteReservedSessions(ctx))
sessions, err = db.ListSessionsByState(ctx, StateReserved)
require.NoError(t, err)
@ -180,7 +180,7 @@ func TestBasicSessionStore(t *testing.T) {
// Now delete the reserved session and show that it is no longer in the
// database and no longer in the group ID/session ID index.
require.NoError(t, db.DeleteReservedSessions())
require.NoError(t, db.DeleteReservedSessions(ctx))
sessions, err = db.ListSessionsByState(ctx, StateReserved)
require.NoError(t, err)

2
session_rpcserver.go
View file

@ -96,7 +96,7 @@ func newSessionRPCServer(cfg *sessionRpcServerConfig) (*sessionRpcServer,
// requests. This includes resuming all non-revoked sessions.
func (s *sessionRpcServer) start(ctx context.Context) error {
// Delete all sessions in the Reserved state.
err := s.cfg.db.DeleteReservedSessions()
err := s.cfg.db.DeleteReservedSessions(ctx)
if err != nil {
return fmt.Errorf("error deleting reserved sessions: %v", err)
}