fix for #166 (#167)

* fix: missing new in valToArray, wrong package during registration

* fixed incorrect registration for math and string operations

* fixed incorrect registration for cleaning and utils operations

operations/cleaning/cleaning.go

@@ -21,9 +21,9 @@ func init() {
 	_ = operation.Register(&ifnotin.Operation{}, ifnotin.New)
 	_ = operation.Register(&ifin.Operation{}, ifin.New)
 	_ = operation.Register(&oneHotEncoding.Operation{}, oneHotEncoding.New)
-	_ = operation.Register(&set.Operation{}, binning.New)
-	_ = operation.Register(&set.Operation{}, filter.New)
-	_ = operation.Register(&set.Operation{}, sort.New)
-	_ = operation.Register(&set.Operation{}, interpolateMissing.New)
+	_ = operation.Register(&binning.Operation{}, binning.New)
+	_ = operation.Register(&filter.Operation{}, filter.New)
+	_ = operation.Register(&sort.Operation{}, sort.New)
+	_ = operation.Register(&interpolateMissing.Operation{}, interpolateMissing.New)
 
 }

operations/math/math.go

@@ -21,8 +21,8 @@ func init() {
 	_ = operation.Register(&scale.Operation{}, scale.New)
 	_ = operation.Register(&multPairWise.Operation{}, multPairWise.New)
 	_ = operation.Register(&divPairWise.Operation{}, divPairWise.New)
-	_ = operation.Register(&divPairWise.Operation{}, addPairWise.New)
-	_ = operation.Register(&divPairWise.Operation{}, multi.New)
-	_ = operation.Register(&divPairWise.Operation{}, add.New)
-	_ = operation.Register(&divPairWise.Operation{}, divide.New)
+	_ = operation.Register(&addPairWise.Operation{}, addPairWise.New)
+	_ = operation.Register(&multi.Operation{}, multi.New)
+	_ = operation.Register(&add.Operation{}, add.New)
+	_ = operation.Register(&divide.Operation{}, divide.New)
 }

operations/restructuring/restructuring.go

@@ -30,5 +30,5 @@ func init() {
 	_ = operation.Register(&reshape.Operation{}, reshape.New)
 	_ = operation.Register(&table2map.Operation{}, table2map.New)
 	_ = operation.Register(&transpose.Operation{}, transpose.New)
-	_ = operation.Register(&transpose.Operation{}, valToArray.New)
+	_ = operation.Register(&valToArray.Operation{}, valToArray.New)
 }

operations/restructuring/valToArray/operation.go

@@ -1,13 +1,17 @@
 package valToArray
 
 import (
+	"github.com/project-flogo/catalystml-flogo/action/operation"
 	"github.com/project-flogo/core/support/log"
 )
 
 type Operation struct {
 	logger log.Logger
 }
 
+func New(ctx operation.InitContext) (operation.Operation, error) {
+	return &Operation{logger: ctx.Logger()}, nil
+}
 func (a *Operation) Eval(inputs map[string]interface{}) (interface{}, error) {
 
 	in := &Input{}

operations/string_processing/string-processing.go

@@ -45,14 +45,14 @@ func init() {
 	_ = operation.Register(&index.Operation{}, index.New)
 	_ = operation.Register(&lastindex.Operation{}, lastindex.New)
 	_ = operation.Register(&matchregex.Operation{}, matchregex.New)
-	_ = operation.Register(&index.Operation{}, encodestring.New)
-	_ = operation.Register(&lastindex.Operation{}, decodestring.New)
-	_ = operation.Register(&matchregex.Operation{}, date.New)
-	_ = operation.Register(&matchregex.Operation{}, replaceall.New)
-	_ = operation.Register(&matchregex.Operation{}, replaceregex.New)
-	_ = operation.Register(&matchregex.Operation{}, trim.New)
-	_ = operation.Register(&matchregex.Operation{}, trimleft.New)
-	_ = operation.Register(&matchregex.Operation{}, trimright.New)
-	_ = operation.Register(&matchregex.Operation{}, trimprefix.New)
-	_ = operation.Register(&matchregex.Operation{}, trimsuffix.New)
+	_ = operation.Register(&encodestring.Operation{}, encodestring.New)
+	_ = operation.Register(&decodestring.Operation{}, decodestring.New)
+	_ = operation.Register(&date.Operation{}, date.New)
+	_ = operation.Register(&replaceall.Operation{}, replaceall.New)
+	_ = operation.Register(&replaceregex.Operation{}, replaceregex.New)
+	_ = operation.Register(&trim.Operation{}, trim.New)
+	_ = operation.Register(&trimleft.Operation{}, trimleft.New)
+	_ = operation.Register(&trimright.Operation{}, trimright.New)
+	_ = operation.Register(&trimprefix.Operation{}, trimprefix.New)
+	_ = operation.Register(&trimsuffix.Operation{}, trimsuffix.New)
 }

operations/utils/utils.go

@@ -8,5 +8,5 @@ import (
 
 func init() {
 	_ = operation.Register(&runcml.Operation{}, runcml.New)
-	_ = operation.Register(&runcml.Operation{}, toLog.New)
+	_ = operation.Register(&toLog.Operation{}, toLog.New)
 }