file-hasher as seperate binary

3 files changed, 82 insertions, 19 deletions

diff --git a/src/pool-import/dir-hasher.go b/src/file-hasher/dir-hasher.go
index aa204a0..aa204a0 100644
--- a/src/pool-import/dir-hasher.go
+++ b/src/file-hasher/dir-hasher.go
diff --git a/src/file-hasher/main.go b/src/file-hasher/main.go
new file mode 100644
index 0000000..c25f690
--- /dev/null
+++ b/src/file-hasher/main.go
@@ -0,0 +1,81 @@
+//
+//  pool-import
+//
+//  Copyright (C) 2016 Christian Pointner <equinox@helsinki.at>
+//
+//  This file is part of pool-import.
+//
+//  pool-import is free software: you can redistribute it and/or modify
+//  it under the terms of the GNU General Public License as published by
+//  the Free Software Foundation, either version 3 of the License, or
+//  any later version.
+//
+//  pool-import is distributed in the hope that it will be useful,
+//  but WITHOUT ANY WARRANTY; without even the implied warranty of
+//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+//  GNU General Public License for more details.
+//
+//  You should have received a copy of the GNU General Public License
+//  along with pool-import. If not, see <http://www.gnu.org/licenses/>.
+//
+
+package main
+
+import (
+	"log"
+	"os"
+	"os/signal"
+	"syscall"
+	"time"
+)
+
+const (
+	RD_CONF = "/etc/rd.conf"
+)
+
+func main() {
+	if len(os.Args) < 2 {
+		log.Fatal("Usage: file-hasher <directory> [ <directory [ .. ] ]")
+	}
+	directories := os.Args[1:]
+
+	stdlog := log.New(os.Stderr, "[std] ", log.LstdFlags)
+
+	C := make(chan os.Signal, 1)
+	signal.Notify(C, os.Interrupt, syscall.SIGHUP, syscall.SIGQUIT, syscall.SIGTERM)
+
+	stdlog.Println("***************************************************************")
+	stdlog.Printf("*** will hash files' from %d directories", len(directories))
+	stdlog.Println("***************************************************************")
+
+	starttime := time.Now()
+	go func() {
+		defer func() {
+			C <- syscall.SIGTERM
+		}()
+
+		stdlog.Println("********************************************")
+		allFiles := make(FileMap)
+		for _, root := range directories {
+			stdlog.Printf("*** hashing all the files in '%s'", root)
+			stdlog.Println("")
+			md := NewMusicDir(root, stdlog)
+			if err := md.ComputeHashes(); err != nil {
+				return
+			}
+			allFiles.Merge(md.Files)
+			stdlog.Println("")
+			stdlog.Println("******************************")
+		}
+		stdlog.Println("")
+		for hash, file := range allFiles {
+			stdlog.Printf("%s: %s", hash, file)
+		}
+		stdlog.Println("")
+		stdlog.Println("***************************************************************")
+		stdlog.Printf("***  hashed %d files in %v", len(allFiles), time.Since(starttime))
+		stdlog.Println("***************************************************************")
+	}()
+
+	<-C
+}
diff --git a/src/pool-import/main.go b/src/pool-import/main.go
index 10a59ec..0963ed0 100644
--- a/src/pool-import/main.go
+++ b/src/pool-import/main.go
@@ -96,25 +96,7 @@ func main() {
 			C <- syscall.SIGTERM
 		}()
 
-		stdlog.Println("********************************************")
-		allFiles := make(FileMap)
-		for _, root := range directories {
-			stdlog.Printf("*** hashing all the files in '%s'", root)
-			stdlog.Println("")
-			md := NewMusicDir(root, stdlog)
-			if err := md.ComputeHashes(); err != nil {
-				return
-			}
-			allFiles.Merge(md.Files)
-			stdlog.Println("")
-			stdlog.Println("******************************")
-		}
-		stdlog.Println("")
-		for hash, file := range allFiles {
-			stdlog.Printf("%s: %s", hash, file)
-		}
-		stdlog.Println("")
-		stdlog.Println("********************************************")
+		// TODO: use file-hasher to get file hashes
 	}()
 
 	<-C