From f8f1d0399ff59e8345c81f9a627606f86680223e Mon Sep 17 00:00:00 2001
From: Henrik Hautakoski <henrik@eossweden.org>
Date: Mon, 24 Apr 2023 16:07:31 +0200
Subject: [PATCH] app/ship_processor.go: make SpawnProccessor() take in a
 message.Codec

---
 app/ship_processor.go | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/app/ship_processor.go b/app/ship_processor.go
index 061f3f5..267d84f 100644
--- a/app/ship_processor.go
+++ b/app/ship_processor.go
@@ -2,7 +2,6 @@ package app
 
 import (
 	"encoding/hex"
-	"encoding/json"
 
 	"github.com/eosswedenorg/thalos/api"
 	"github.com/eosswedenorg/thalos/api/message"
@@ -34,12 +33,12 @@ type ShipProcessor struct {
 	encode     message.Encoder
 }
 
-func SpawnProccessor(shipStream *shipclient.Stream, writer api.Writer, abi *abi.AbiManager) *ShipProcessor {
+func SpawnProccessor(shipStream *shipclient.Stream, writer api.Writer, abi *abi.AbiManager, codec message.Codec) *ShipProcessor {
 	processor := &ShipProcessor{
 		abi:        abi,
 		writer:     writer,
 		shipStream: shipStream,
-		encode:     logDecoratedEncoder(json.Marshal),
+		encode:     logDecoratedEncoder(codec.Encoder),
 	}
 
 	// Attach handlers