From 42e858cc33f0048bd4528db7415ced57b959cd61 Mon Sep 17 00:00:00 2001 From: Bel LaPointe <153096461+breel-render@users.noreply.github.com> Date: Wed, 18 Sep 2024 11:13:27 -0400 Subject: [PATCH] accept args as PARENT_OF_DIRS DURATION_INTERVAL_FOR_MOVEMENT --- testdata/ffmpeg.d/cmd/prune/main.go | 11 ++++++++--- testdata/ffmpeg.d/cmd/prune/main_test.go | 2 +- 2 files changed, 9 insertions(+), 4 deletions(-) diff --git a/testdata/ffmpeg.d/cmd/prune/main.go b/testdata/ffmpeg.d/cmd/prune/main.go index bea5273..ac32481 100644 --- a/testdata/ffmpeg.d/cmd/prune/main.go +++ b/testdata/ffmpeg.d/cmd/prune/main.go @@ -32,6 +32,11 @@ func Run(ctx context.Context, args []string) error { return fmt.Errorf("failed to lsd %s: %w", args[0], err) } + movementInterval, err := time.ParseDuration(args[1]) + if err != nil { + return err + } + for _, cam := range cams { files, err := lsf(cam) if err != nil { @@ -58,7 +63,7 @@ func Run(ctx context.Context, args []string) error { seriesFiles = append(seriesFiles, file) } } - if seriesHasMovement, err := seriesHasMovement(ctx, seriesFiles); err != nil { + if seriesHasMovement, err := seriesHasMovement(ctx, seriesFiles, movementInterval); err != nil { return err } else if seriesHasMovement { for _, seriesFile := range seriesFiles { @@ -82,7 +87,7 @@ func Run(ctx context.Context, args []string) error { return nil } -func seriesHasMovement(ctx context.Context, files []string) (bool, error) { +func seriesHasMovement(ctx context.Context, files []string, movementInterval time.Duration) (bool, error) { if len(files) < 1 { return false, nil } @@ -101,7 +106,7 @@ func seriesHasMovement(ctx context.Context, files []string) (bool, error) { } gTime := gStat.ModTime() - if gTime.Sub(fTime) < time.Second { + if gTime.Sub(fTime) < movementInterval { continue } diff --git a/testdata/ffmpeg.d/cmd/prune/main_test.go b/testdata/ffmpeg.d/cmd/prune/main_test.go index 02c3afe..b07bdff 100644 --- a/testdata/ffmpeg.d/cmd/prune/main_test.go +++ b/testdata/ffmpeg.d/cmd/prune/main_test.go @@ -47,7 +47,7 @@ func TestRun(t *testing.T) { t.Fatal(err) } - if err := Run(context.Background(), []string{path.Dir(d)}); err != nil { + if err := Run(context.Background(), []string{path.Dir(d), "1s"}); err != nil { t.Fatal(err) }