staticaddr: poll deposits on block arrival

In this commit we remove the ticker-based polling
of new deposits as this is wasteful, and we replace
it by polling on the arrival of new blocks.

Author: hieblmi

staticaddr/deposit/manager.go

@@ -119,17 +119,18 @@ func (m *Manager) Run(ctx context.Context, initChan chan struct{}) error {
 		return err
 	}
 
-	// Start the deposit notifier.
-	m.pollDeposits(ctx)
-
 	// Communicate to the caller that the address manager has completed its
 	// initialization.
 	close(initChan)
 
 	for {
 		select {
 		case height := <-newBlockChan:
-			// Inform all active deposits about a new block arrival.
+			// Poll for new deposits and spin up fsms for them.
+			go m.pollDeposits(ctx)
+
+			// Now inform all active deposits about a new block
+			// arrival.
 			m.mu.Lock()
 			activeDeposits := make([]*FSM, 0, len(m.activeDeposits))
 			for _, fsm := range m.activeDeposits {
@@ -213,28 +214,21 @@ func (m *Manager) recoverDeposits(ctx context.Context) error {
 	return nil
 }
 
-// pollDeposits polls new deposits to our static address and notifies the
-// manager's event loop about them.
+// pollDeposits polls new deposits to our static addresses.
 func (m *Manager) pollDeposits(ctx context.Context) {
-	log.Debugf("Waiting for new static address deposits...")
+	log.Debugf("Polling new static address deposits...")
 
-	go func() {
-		ticker := time.NewTicker(PollInterval)
-		defer ticker.Stop()
-		for {
-			select {
-			case <-ticker.C:
-				err := m.reconcileDeposits(ctx)
-				if err != nil {
-					log.Errorf("unable to reconcile "+
-						"deposits: %v", err)
-				}
+	select {
+	case <-ctx.Done():
+		return
 
-			case <-ctx.Done():
-				return
-			}
+	default:
+		err := m.reconcileDeposits(ctx)
+		if err != nil {
+			log.Errorf("unable to reconcile deposits: %v",
+				err)
 		}
-	}()
+	}
 }
 
 // reconcileDeposits fetches all spends to our static address from our lnd