fixup! loopd: add notification manager

Author: sputn1ck

loopd/daemon.go

@@ -501,27 +501,14 @@ func (d *Daemon) initialize(withMacaroonService bool) error {
 
 	// Start the notification manager.
 	notificationCfg := &notifications.Config{
-		Client: loop_swaprpc.NewSwapServerClient(swapClient.Conn),
+		Client:    loop_swaprpc.NewSwapServerClient(swapClient.Conn),
+		FetchL402: d.impl.Server.FetchL402,
 	}
 	notificationManager := notifications.NewManager(notificationCfg)
 
-	d.wg.Add(1)
-	notificationInitChan := make(chan struct{})
-	go func() {
-		defer d.wg.Done()
-		err = notificationManager.Run(d.mainCtx, notificationInitChan)
-		if err != nil {
-			d.internalErrChan <- err
-		}
-	}()
-
-	select {
-	case <-notificationInitChan:
-		break
-	case <-time.After(15 * time.Second):
-		return fmt.Errorf("notification manager not ready")
-	case <-d.mainCtx.Done():
-		return fmt.Errorf("notification manager not ready: %v", d.mainCtx.Err())
+	err = notificationManager.Run(d.mainCtx)
+	if err != nil {
+		return err
 	}
 
 	var (