@ -8,6 +8,7 @@ import (
"net/http"
"net/http"
"os"
"os"
"strings"
"strings"
"time"
)
)
const (
const (
@ -118,12 +119,13 @@ func (ic *Interconnect) UpdateUsers() {
}
}
func ( ic * Interconnect ) UpdateTimeEntries ( ) {
func ( ic * Interconnect ) UpdateTimeEntries ( ) {
users := ic . DBConnector . Fetch Engineer Users( )
users := ic . DBConnector . Fetch Users( )
entryChan := make ( chan * [ ] * TimeEntry )
entryChan := make ( chan * [ ] * TimeEntry )
coroutineCount := 0
coroutineCount := 0
for _ , userPtr := range * users {
for _ , userPtr := range * users {
go ic . Client . GetTimeAllTimeEntriesForUserThroughDate ( userPtr . Id , "2022-04-28" , entryChan )
go ic . Client . GetTimeAllTimeEntriesForUserThroughDate ( userPtr . Id , "2022-04-28" , entryChan )
coroutineCount ++
coroutineCount ++
time . Sleep ( 200 * time . Millisecond )
}
}
log . Printf ( "Currently working goroutines: %d\n" , coroutineCount )
log . Printf ( "Currently working goroutines: %d\n" , coroutineCount )