WATCHER: Build out consumer receive & process functions using new Event

struct.

cmd/main.go

@@ -5,8 +5,8 @@ import (
 )
 
 func main() {
-	path := "/Users/cian.gallagher/test_events"
-	destination := "/tmp"
+	path := "/Users/cian.gallagher/input"
+	destination := "/Users/cian.gallagher/output"
 
 	var pw watcher.Producer = &watcher.PathWatcher{
 		Path: path,
@@ -15,6 +15,7 @@ func main() {
 	var pc watcher.Consumer = &watcher.PathConsumer{
 		Path:        path,
 		Destination: destination,
+		Ext:         ".txt",
 	}
 
 	pw.Register(&pc)

watcher/watcher.go

@@ -5,6 +5,8 @@ import (
 	"os"
 	"path/filepath"
 
+	"github.com/cian911/switchboard/event"
+	"github.com/cian911/switchboard/utils"
 	"github.com/fsnotify/fsnotify"
 )
 
@@ -17,7 +19,7 @@ type Producer interface {
 
 type Consumer interface {
 	Receive(path, event string)
-	Process(path, destination string)
+	Process(e *event.Event)
 }
 
 type PathWatcher struct {
@@ -29,14 +31,32 @@ type PathWatcher struct {
 type PathConsumer struct {
 	Path        string
 	Destination string
+	Ext         string
 }
 
-func (pc *PathConsumer) Receive(path, event string) {
-	log.Printf("CONSUMER EVENT: path: %s, event: %s", path, event)
+func (pc *PathConsumer) Receive(path, ev string) {
+	log.Printf("Event Received: %s, Path: %s\n", ev, path)
+
+	e := &event.Event{
+		File:        filepath.Base(path),
+		Path:        path,
+		Destination: pc.Destination,
+		Ext:         utils.ExtractFileExt(path),
+		Operation:   ev,
+	}
+
+	log.Printf("pc.Path: {%s}", pc.Path)
+	log.Printf("Event: %v", e)
+
+	if e.IsValidEvent(pc.Ext) {
+		log.Println("Event is valid")
+		pc.Process(e)
+	}
 }
 
-func (pc *PathConsumer) Process(path, destination string) {
-	log.Printf("CONSUMER PROCESSING EVENT: path: %s, event: %s", path, destination)
+func (pc *PathConsumer) Process(e *event.Event) {
+	log.Println("Event has been processed.")
+	e.Move()
 }
 
 func (pw *PathWatcher) Register(consumer *Consumer) {