Merge pull request #97 from compose/96-transformer-errors

throw transformer initialization errors early

pkg/adaptor/transformer.go

@@ -49,17 +49,17 @@ func NewTransformer(pipe *pipe.Pipe, path string, extra Config) (StopStartListen
 
 	t.fn = string(ba)
 
+	if err = t.initEnvironment(); err != nil {
+		return t, err
+	}
+
 	return t, nil
 }
 
 // Listen starts the transformer's listener, reads each message from the incoming channel
 // transformers it into mejson, and then uses the supplied javascript module.exports function
 // to transform the document.  The document is then emited to this adaptor's children
 func (t *Transformer) Listen() (err error) {
-	if err = t.initEnvironment(); err != nil {
-		return err
-	}
-
 	return t.pipe.Listen(t.transformOne)
 }