Change Output interface to return an error

4 files changed, 12 insertions, 6 deletions

diff --git a/manager.go b/manager.go
index 3fd2234..0eeb51f 100644
--- a/manager.go
+++ b/manager.go
@@ -27,9 +27,12 @@ func (m *Manager) Run() {
 			nw := m.Filter.Filter(w)
 			err := nw.Error()
 			if err != nil {
-				fmt.Printf("Got an error when processing Work: %q\n", err)
+				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)
 			}
-			m.Output.Output(nw)
 
 			wg.Done()
 		}(w)
diff --git a/output/http/http.go b/output/http/http.go
index 3ea603c..158f091 100644
--- a/output/http/http.go
+++ b/output/http/http.go
@@ -22,9 +22,11 @@ func New(kv map[string]string) output.Output {
 	return &HttpOutput{url: url}
 }
 
-func (h *HttpOutput) Output(w *work.Work) {
+func (h *HttpOutput) Output(w *work.Work) error {
 	_, err := http.Post(h.url, "application/json", bytes.NewReader(w.Data))
 	if err != nil {
 		w.Err = err
 	}
+
+	return err
 }
diff --git a/output/outputinterface.go b/output/outputinterface.go
index 8f1137a..385fe4e 100644
--- a/output/outputinterface.go
+++ b/output/outputinterface.go
@@ -3,5 +3,5 @@ package output
 import "github.com/Shugyousha/stasher/work"
 
 type Output interface {
-	Output(*work.Work)
+	Output(*work.Work) error
 }
diff --git a/output/stdout/stdout.go b/output/stdout/stdout.go
index 9d66581..f3e4f57 100644
--- a/output/stdout/stdout.go
+++ b/output/stdout/stdout.go
@@ -19,6 +19,7 @@ func New(map[string]string) output.Output {
 	return &StdoutOutput{}
 }
 
-func (o *StdoutOutput) Output(w *work.Work) {
-	fmt.Printf("%s\n", w.Data)
+func (o *StdoutOutput) Output(w *work.Work) error {
+	_, err := fmt.Printf("%s\n", w.Data)
+	return err
 }