From eec834a3380c61012d9a491d4036da6e358335a6 Mon Sep 17 00:00:00 2001 From: Henrik Hautakoski Date: Fri, 13 Jan 2023 13:32:23 +0100 Subject: [PATCH] main.go: setup redis pubsub publisher. --- main.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/main.go b/main.go index 02f71c5..c419317 100644 --- a/main.go +++ b/main.go @@ -11,6 +11,9 @@ import ( "eosio-ship-trace-reader/config" "eosio-ship-trace-reader/internal/redis" + "eosio-ship-trace-reader/transport" + "eosio-ship-trace-reader/transport/redis_pubsub" + "github.com/nikoksr/notify" "github.com/nikoksr/notify/service/telegram" @@ -39,6 +42,8 @@ var ( var abi_mgr *abi.AbiManager +var publisher transport.Publisher + var redisNs redis.Namespace // Reader states @@ -220,6 +225,9 @@ func main() { return } + // Setup publisher + publisher = redis_pubsub.New(redis.Client()) + // Connect client and get chain info. log.Printf("Get chain info from api at: %s", conf.Api) eosClient = eos.New(conf.Api)