dimitar
0c9c07e8de
Add the scheduling layer and the watch command so gitflow can rescan
repositories on an interval and surface state changes.
Scheduler (internal/scheduler):
- Scheduler runs a callback immediately and then on a time.Ticker until
the context is cancelled; interval <= 0 means a single run
- Graceful shutdown: cancellation is never reported as an error (checked
on the first run and after every run), so Ctrl-C / SIGTERM exit cleanly
- A non-cancellation run error stops the loop and is propagated
Change detection (pkg/status):
- Changed(prev, next) compares snapshots per repository path — status,
branch, detached flag, ahead/behind, stash count, and file counts —
and returns the repositories whose observable state differs, including
repositories that newly appear
Watch command (cmd/gitflow):
- newWatchCmd validates that --interval is positive, prompts for the
parent directory on a TTY when --dir is absent, and drives the
scheduler with ScanOnce
- Each frame clears the screen on a terminal (or prints a RFC3339 header
when output is piped, so watch doubles as a lightweight logger) and
renders through the presenter
- Footer shows changed repositories since the previous frame ("▲ name:
status") and the next scan time; JSON format emits one document per
frame for scripting
- SIGINT/SIGTERM handled via signalContext for a clean stop
Testing:
- Scheduler: single run, periodic repetition, stop-on-error, pre-cancelled
context, and cancellation-during-run (no error reported)
- status.Changed: unchanged repos ignored; status, file-count, and
newly-appeared repos detected
Verified: go build, go vet, go test -race, gofmt clean; manual watch
smoke test over a scratch directory with 1s interval — frames render,
SIGINT and SIGTERM both exit 0 with no orphaned processes.
56 lines
1.2 KiB
Go
56 lines
1.2 KiB
Go
// Package scheduler runs a function on a fixed interval with an immediate
|
|
// first execution, until the context is cancelled.
|
|
package scheduler
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
)
|
|
|
|
// Scheduler triggers a run function periodically.
|
|
type Scheduler struct {
|
|
interval time.Duration
|
|
run func(ctx context.Context) error
|
|
}
|
|
|
|
// New creates a Scheduler that calls run immediately and then every
|
|
// interval. An interval <= 0 means run once and stop.
|
|
func New(interval time.Duration, run func(ctx context.Context) error) *Scheduler {
|
|
return &Scheduler{interval: interval, run: run}
|
|
}
|
|
|
|
// Run executes run immediately and then every interval until ctx is
|
|
// cancelled. A run error stops the loop and is returned, except when the
|
|
// context was cancelled (graceful shutdown is not an error).
|
|
func (s *Scheduler) Run(ctx context.Context) error {
|
|
if err := ctx.Err(); err != nil {
|
|
return nil
|
|
}
|
|
if err := s.run(ctx); err != nil {
|
|
if ctx.Err() != nil {
|
|
return nil
|
|
}
|
|
return err
|
|
}
|
|
if s.interval <= 0 {
|
|
return nil
|
|
}
|
|
|
|
ticker := time.NewTicker(s.interval)
|
|
defer ticker.Stop()
|
|
|
|
for {
|
|
select {
|
|
case <-ctx.Done():
|
|
return nil
|
|
case <-ticker.C:
|
|
if err := s.run(ctx); err != nil {
|
|
if ctx.Err() != nil {
|
|
return nil
|
|
}
|
|
return err
|
|
}
|
|
}
|
|
}
|
|
}
|