add cleaned files to the clean queue
This commit is contained in:
parent
7bf0709685
commit
dfa80b4dd9
@ -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)
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user