sync providers concurrently instead of in series
All checks were successful
continuous-integration/drone/push Build is passing
All checks were successful
continuous-integration/drone/push Build is passing
This commit is contained in:
parent
39f3b27a8b
commit
a7d0005423
11
main.go
11
main.go
@ -86,16 +86,21 @@ func refreshData() {
|
|||||||
}
|
}
|
||||||
lastRefresh = time.Now()
|
lastRefresh = time.Now()
|
||||||
|
|
||||||
|
var wg *sync.WaitGroup
|
||||||
|
|
||||||
// Loop through each configured account provider and attempt to get the account balances, and update YNAB
|
// Loop through each configured account provider and attempt to get the account balances, and update YNAB
|
||||||
for _, p := range configuredProviders {
|
for _, p := range configuredProviders {
|
||||||
|
wg.Add(1)
|
||||||
|
go func() {
|
||||||
|
defer wg.Done()
|
||||||
balances, accountIDs, err := p.GetBalances()
|
balances, accountIDs, err := p.GetBalances()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Printf("failed to get balances with provider '%s': %v", p.Name(), err)
|
log.Printf("failed to get balances with provider '%s': %v", p.Name(), err)
|
||||||
continue
|
return
|
||||||
}
|
}
|
||||||
if len(balances) != len(accountIDs) {
|
if len(balances) != len(accountIDs) {
|
||||||
log.Printf("'%s' provider data validation error: mismatched balance and accountID slice lengths - expected the same: balances length = %d, accountIDs length = %d", p.Name(), len(balances), len(accountIDs))
|
log.Printf("'%s' provider data validation error: mismatched balance and accountID slice lengths - expected the same: balances length = %d, accountIDs length = %d", p.Name(), len(balances), len(accountIDs))
|
||||||
continue
|
return
|
||||||
}
|
}
|
||||||
for i := range balances {
|
for i := range balances {
|
||||||
err = ynabClient.SetAccountBalance(accountIDs[i], balances[i])
|
err = ynabClient.SetAccountBalance(accountIDs[i], balances[i])
|
||||||
@ -103,5 +108,7 @@ func refreshData() {
|
|||||||
log.Printf("failed to update ynab account '%s' balance: %v", accountIDs[i], err)
|
log.Printf("failed to update ynab account '%s' balance: %v", accountIDs[i], err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}()
|
||||||
}
|
}
|
||||||
|
wg.Wait()
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user