feat (serializer) StringToMap and MapToString

serializer/jsonSerializer.go

@@ -2,8 +2,10 @@ package serializer
 
 import (
 	"bytes"
+	"encoding/json"
 	"errors"
 	"io"
+
 	"sort"
 	"strconv"
 	"time"
@@ -59,6 +61,32 @@ func (serializer JSONSerializer) ReaderToPayload(r io.Reader) moleculer.Payload
 	return payload
 }
 
+//MapToString serialize a map into a string
+//This implementation uses the standard library json pkg and it needs to be compared with others for performance.
+//Performance: it should be experimented with multiple implementations. This is just he initial one.
+func (serializer JSONSerializer) MapToString(m interface{}) string {
+	r, err := json.Marshal(m)
+	if err != nil {
+		serializer.logger.Errorln("Error trying to serialize a map. error: ", err)
+		panic(err)
+	}
+	s := string(r)
+	return s
+}
+
+//StringToMap deserialize a string (json) into map
+//Same implementation and performance notes as MapToString
+func (serializer JSONSerializer) StringToMap(j string) map[string]interface{} {
+	m := map[string]interface{}{}
+	err := json.Unmarshal([]byte(j), &m)
+	if err != nil {
+		serializer.logger.Errorln("Error trying to deserialize a map from json: " + j)
+		serializer.logger.Errorln("error: ", err)
+		panic(err)
+	}
+	return m
+}
+
 func (serializer JSONSerializer) PayloadToBytes(payload moleculer.Payload) []byte {
 	return []byte(serializer.PayloadToString(payload))
 }

serializer/serializer.go

@@ -1,15 +1,18 @@
 package serializer
 
 import (
-	"github.com/moleculer-go/moleculer"
 	"io"
+
+	"github.com/moleculer-go/moleculer"
 )
 
 type Serializer interface {
 	ReaderToPayload(io.Reader) moleculer.Payload
 	BytesToPayload(*[]byte) moleculer.Payload
 	PayloadToBytes(moleculer.Payload) []byte
 	PayloadToString(moleculer.Payload) string
+	MapToString(interface{}) string
+	StringToMap(string) map[string]interface{}
 	PayloadToContextMap(moleculer.Payload) map[string]interface{}
 	MapToPayload(*map[string]interface{}) (moleculer.Payload, error)
 }