diff --git a/pkg/node/bufpool.go b/pkg/node/bufpool.go
index 0c91dfe..7815449 100644
--- a/pkg/node/bufpool.go
+++ b/pkg/node/bufpool.go
@@ -29,6 +29,12 @@ func putBuffer(buffer *bytes.Buffer) {
 	}
 }
 
+// var msg Message
+// if err := UnmarshalJSON(data, &msg); err != nil { return nil, err }
+func UnmarshalJSON(data []byte, v interface{}) error {
+	return json.Unmarshal(data, v)
+}
+
 // data, err := MarshalJSON(msg)
 // if err != nil { return nil, err }
 func MarshalJSON(v interface{}) ([]byte, error) {
diff --git a/pkg/node/worker.go b/pkg/node/worker.go
index bb542da..b371cbe 100644
--- a/pkg/node/worker.go
+++ b/pkg/node/worker.go
@@ -2,7 +2,6 @@ package node
 
 import (
 	"encoding/base64"
-	"encoding/json"
 	"fmt"
 	"path"
 	"time"
@@ -341,7 +340,7 @@ func (worker *Worker) handleDeploy(conn *PeerConnection, msg *Message) (*Message
 
 		// Unmarshal into interface{} to pass to ProfileManager
 		var profile interface{}
-		if err := json.Unmarshal(profileData, &profile); err != nil {
+		if err := UnmarshalJSON(profileData, &profile); err != nil {
 			return nil, fmt.Errorf("invalid profile data JSON: %w", err)
 		}
 
@@ -381,7 +380,7 @@ func (worker *Worker) handleDeploy(conn *PeerConnection, msg *Message) (*Message
 		// If the bundle contained a profile config, save it
 		if len(profileData) > 0 && worker.profileManager != nil {
 			var profile interface{}
-			if err := json.Unmarshal(profileData, &profile); err != nil {
+			if err := UnmarshalJSON(profileData, &profile); err != nil {
 				logging.Warn("failed to parse profile from miner bundle", logging.Fields{"error": err})
 			} else {
 				if err := worker.profileManager.SaveProfile(profile); err != nil {