diff --git a/cmd/git-media-clean.go b/cmd/git-media-clean.go index d81c6a12..4da3bcde 100644 --- a/cmd/git-media-clean.go +++ b/cmd/git-media-clean.go @@ -3,12 +3,20 @@ package main import ( ".." "../filters" + "../queuedir" "fmt" "os" + "path/filepath" ) func main() { gitmedia.SetupDebugging() + qdir := queuedir.New(filepath.Join(gitmedia.LocalMediaDir, "queue")) + cleanqueue, err := qdir.Queue("clean") + if err != nil { + fmt.Println("Error setting up queue") + panic(err) + } cleaned, err := gitmediafilters.Clean(os.Stdin) if err != nil { @@ -28,6 +36,9 @@ func main() { if err := os.Rename(tmpfile, mediafile); err != nil { gitmedia.Panic(err, "Unable to move %s to %s\n", tmpfile, mediafile) } + if _, err := cleanqueue.AddString(cleaned.Sha); err != nil { + gitmedia.Panic(err, "Unable to add %s to queue", cleaned.Sha) + } gitmedia.Debug("Writing %s", mediafile) }