1 files changed, 46 insertions, 0 deletions
diff --git a/manager/manager.go b/manager/manager.go
new file mode 100644
index 0000000..5bbd49f
--- /dev/null
+++ b/manager/manager.go
@@ -0,0 +1,46 @@
+package manager
+
+import (
+	"fmt"
+	"sync"
+
+	"github.com/Shugyousha/stasher/filter"
+	"github.com/Shugyousha/stasher/input"
+	"github.com/Shugyousha/stasher/output"
+	"github.com/Shugyousha/stasher/work"
+)
+
+type Manager struct {
+	Input  input.Input
+	Filter filter.Filter
+	Output output.Output
+}
+
+func (m *Manager) Run() {
+	var wg sync.WaitGroup
+
+	ic := m.Input.Start()
+	for w := range ic {
+		if w.Err != nil {
+			fmt.Printf("Got an error when getting Work input: %q\n", w.Err)
+			continue
+		}
+		wg.Add(1)
+
+		go func(w *work.Work) {
+			nw := m.Filter.Filter(w)
+			err := nw.Error()
+			if err != nil {
+				fmt.Printf("Got an error when filtering Work: %q\n", err)
+			}
+			err = m.Output.Output(nw)
+			if err != nil {
+				fmt.Printf("Got an error when outputting Work: %q\n", err)
+			}
+
+			wg.Done()
+		}(w)
+	}
+
+	wg.Wait()
+}