75 lines
1.9 KiB
Go
75 lines
1.9 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"log"
|
|
)
|
|
|
|
func (s *Server) reconcile(ctx context.Context, runID int64, rep *User, dept string) error {
|
|
reps, err := s.store.RepsFor(rep.ChapterID, dept)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if len(reps) == 0 {
|
|
// Shouldn't happen: the webhook fired for a rep in this department.
|
|
log.Printf("run %d: no reps found for chapter %d dept %q", runID, rep.ChapterID, dept)
|
|
return nil
|
|
}
|
|
if len(reps) > 1 {
|
|
log.Printf("WARNING: run %d: %d reps for chapter %d dept %q; assigning all to %d (fill-only mode)",
|
|
runID, len(reps), rep.ChapterID, dept, reps[0])
|
|
}
|
|
agent := reps[0]
|
|
|
|
members, err := s.store.EligibleMembers(rep.ChapterID, dept)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
// loop
|
|
assigned, skipped, failed := 0, 0, 0
|
|
|
|
for _, m := range members {
|
|
|
|
select {
|
|
case <-ctx.Done():
|
|
log.Printf("run %d: cancelled after %d assigned, %d skipped", runID, assigned, skipped)
|
|
return ctx.Err()
|
|
default:
|
|
}
|
|
|
|
existing, err := s.st.ActiveAgent(ctx, m)
|
|
if err != nil {
|
|
log.Printf("run %d: checking agent for %d failed: %v", runID, m, err)
|
|
failed++
|
|
continue
|
|
}
|
|
|
|
if existing != 0 {
|
|
// Fill-only: never displace an existing agent.
|
|
skipped++
|
|
if err := s.store.LogSkip(runID, m, existing, agent); err != nil {
|
|
log.Printf("run %d: logging skip for %d failed: %v", runID, m, err)
|
|
}
|
|
continue
|
|
}
|
|
|
|
if err := s.st.AssignAgent(ctx, m, agent); err != nil {
|
|
log.Printf("run %d: assigning %d to %d failed: %v", runID, m, agent, err)
|
|
failed++
|
|
continue
|
|
}
|
|
assigned++
|
|
|
|
if err := s.store.SetProgress(runID, m); err != nil {
|
|
log.Printf("run %d: recording progress failed: %v", runID, err)
|
|
}
|
|
}
|
|
if assigned == 0 && skipped > 0 {
|
|
log.Printf("WARNING: run %d: assigned nobody; all %d members already have agents",
|
|
runID, skipped)
|
|
}
|
|
log.Printf("run %d: %d assigned, %d skipped, dept %q chapter %d",
|
|
runID, assigned, skipped, dept, rep.ChapterID)
|
|
return nil
|
|
}
|