From bbf63e447da68cdac2b47512868f69ee2882de9c Mon Sep 17 00:00:00 2001
From: Henrik Hautakoski <henrik@eossweden.org>
Date: Mon, 24 Apr 2023 16:08:47 +0200
Subject: [PATCH] cmd/main/main.go: Load message codec from config and pass to
 SpawnProccessor

---
 cmd/main/main.go | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/cmd/main/main.go b/cmd/main/main.go
index e48048e..52aeab2 100644
--- a/cmd/main/main.go
+++ b/cmd/main/main.go
@@ -8,6 +8,8 @@ import (
 	"syscall"
 	"time"
 
+	"github.com/eosswedenorg/thalos/api/message"
+	_ "github.com/eosswedenorg/thalos/api/message/json"
 	api_redis "github.com/eosswedenorg/thalos/api/redis"
 	"github.com/eosswedenorg/thalos/app"
 	"github.com/eosswedenorg/thalos/app/abi"
@@ -187,6 +189,13 @@ func main() {
 		s.IrreversibleOnly = conf.Ship.IrreversibleOnly
 	})
 
+	// Get codec
+	codec, err := message.GetCodec(conf.MessageCodec)
+	if err != nil {
+		log.WithError(err).Fatal("Failed to load codec")
+		return
+	}
+
 	processor := app.SpawnProccessor(
 		shClient,
 		api_redis.NewPublisher(rdb, api_redis.Namespace{
@@ -194,6 +203,7 @@ func main() {
 			ChainID: chainInfo.ChainID.String(),
 		}),
 		abi.NewAbiManager(rdb, eosClient, conf.Redis.CacheID),
+		codec,
 	)
 
 	// Run the application