staticaddr: lock mutex for active deposits access

Author: hieblmi

looprpc/go.mod

@@ -1,6 +1,7 @@
 module github.com/lightninglabs/loop/looprpc
 
-go 1.22.3
+go 1.23.0
+
 toolchain go1.23.7
 
 require (

staticaddr/deposit/manager.go

@@ -136,6 +136,7 @@ func (m *Manager) Run(ctx context.Context, currentHeight uint32) error {
 		select {
 		case height := <-newBlockChan:
 			// Inform all active deposits about a new block arrival.
+			m.mu.Lock()
 			for _, fsm := range m.activeDeposits {
 				select {
 				case fsm.blockNtfnChan <- uint32(height):
@@ -144,11 +145,14 @@ func (m *Manager) Run(ctx context.Context, currentHeight uint32) error {
 					return ctx.Err()
 				}
 			}
+			m.mu.Unlock()
 		case outpoint := <-m.finalizedDepositChan:
 			// If deposits notify us about their finalization, we
 			// update the manager's internal state and flush the
 			// finalized deposit from memory.
+			m.mu.Lock()
 			delete(m.activeDeposits, outpoint)
+			m.mu.Unlock()
 
 		case err = <-newBlockErrChan:
 			return err
@@ -197,7 +201,9 @@ func (m *Manager) recoverDeposits(ctx context.Context) error {
 			}
 		}()
 
+		m.mu.Lock()
 		m.activeDeposits[d.OutPoint] = fsm
+		m.mu.Unlock()
 	}
 
 	return nil