Use easyjson.Unmarshaler, json.Unmarshaler or json.Unmarshal

In order to allow for faster JSON unmarshalling use `internal.UnmarshalJSON` which will pick the best possible json unmarshalling action.

Author: boekkooi-fresh

driver/sql/projection.go

@@ -87,9 +87,9 @@ func (p *ProjectionNotification) UnmarshalEasyJSON(in *jlexer.Lexer) {
 		}
 		switch key {
 		case "no":
-			p.No = int64(in.Int64())
+			p.No = in.Int64()
 		case "aggregate_id":
-			p.AggregateID = string(in.String())
+			p.AggregateID = in.String()
 		default:
 			in.SkipRecursive()
 		}

strategy/json/internal/json.go

@@ -22,3 +22,18 @@ func MarshalJSON(v interface{}) ([]byte, error) {
 
 	return json.Marshal(v)
 }
+
+// UnmarshalJSON parses the JSON-encoded data and stores the result
+// in the value pointed to by v.
+// This is done using `easyjson.Unmarshal`, `json.Unmarshaler` or `json.Unmarshal`
+func UnmarshalJSON(data []byte, v interface{}) error {
+	if vm, ok := v.(easyjson.Unmarshaler); ok {
+		return easyjson.Unmarshal(data, vm)
+	}
+
+	if vm, ok := v.(json.Unmarshaler); ok {
+		return vm.UnmarshalJSON(data)
+	}
+
+	return json.Unmarshal(data, v)
+}

strategy/json/payload_transformer.go

@@ -146,15 +146,15 @@ func (p *PayloadTransformer) CreatePayload(typeName string, data interface{}) (i
 
 	// Pointer we can handle nicely
 	if payloadType.isPtr {
-		if err := json.Unmarshal(dataBytes, payload); err != nil {
+		if err := internal.UnmarshalJSON(dataBytes, payload); err != nil {
 			return nil, err
 		}
 	}
 
 	// Not a pointer so let's cry and use reflection
 	vp := reflect.New(payloadType.reflectionType)
 	vp.Elem().Set(reflect.ValueOf(payload))
-	if err := json.Unmarshal(dataBytes, vp.Interface()); err != nil {
+	if err := internal.UnmarshalJSON(dataBytes, vp.Interface()); err != nil {
 		return nil, err
 	}