Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Reduce logger noise #1011

Merged
merged 3 commits into from
Feb 29, 2024
Merged

Reduce logger noise #1011

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
5e4aaab
autopilot: reduce logger noise
peterjan Feb 29, 2024
54cd3f9
autoilot: implement MR remarks
peterjan Feb 29, 2024
96bb6ef
autopilot: fix error check
peterjan Feb 29, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 11 additions & 7 deletions autopilot/autopilot.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -195,13 +195,15 @@ func (ap *Autopilot) Run() error {

// schedule a trigger when the wallet receives its first deposit
if err := ap.tryScheduleTriggerWhenFunded(); err != nil {
ap.logger.Error(err)
if !errors.Is(err, context.Canceled) {
ap.logger.Error(err)
}
return nil
}

var forceScan bool
var launchAccountRefillsOnce sync.Once
for {
for !ap.isStopped() {
ap.logger.Info("autopilot iteration starting")
tickerFired := make(chan struct{})
ap.workers.withWorker(func(w Worker) {
Expand All @@ -220,7 +222,7 @@ func (ap *Autopilot) Run() error {
close(tickerFired)
return
}
ap.logger.Error("autopilot stopped before consensus was synced")
ap.logger.Info("autopilot stopped before consensus was synced")
return
} else if blocked {
if scanning, _ := ap.s.Status(); !scanning {
Expand All @@ -234,7 +236,7 @@ func (ap *Autopilot) Run() error {
close(tickerFired)
return
}
ap.logger.Error("autopilot stopped before it was able to confirm it was configured in the bus")
ap.logger.Info("autopilot stopped before it was able to confirm it was configured in the bus")
return
}

Expand Down Expand Up @@ -308,6 +310,7 @@ func (ap *Autopilot) Run() error {
case <-tickerFired:
}
}
return nil
}

// Shutdown shuts down the autopilot.
Expand Down Expand Up @@ -463,11 +466,12 @@ func (ap *Autopilot) blockUntilSynced(interrupt <-chan time.Time) (synced, block
}

func (ap *Autopilot) tryScheduleTriggerWhenFunded() error {
ctx, cancel := context.WithTimeout(ap.shutdownCtx, 30*time.Second)
wallet, err := ap.bus.Wallet(ctx)
cancel()
// apply sane timeout
ctx, cancel := context.WithTimeout(ap.shutdownCtx, time.Minute)
defer cancel()

// no need to schedule a trigger if the wallet is already funded
wallet, err := ap.bus.Wallet(ctx)
if err != nil {
return err
} else if !wallet.Confirmed.Add(wallet.Unconfirmed).IsZero() {
Expand Down
Loading