From d2bb76867267520950083511f541f70007b16778 Mon Sep 17 00:00:00 2001 From: dimitri Date: Fri, 9 Aug 2019 02:13:16 +0200 Subject: [PATCH] [Fix] gabs library evolutions no more Consume method replaced by Wrap + Consume and Children don't return error --- realtime/messages.go | 17 ++++++----------- 1 file changed, 6 insertions(+), 11 deletions(-) diff --git a/realtime/messages.go b/realtime/messages.go index 4a51acf..354da98 100644 --- a/realtime/messages.go +++ b/realtime/messages.go @@ -1,11 +1,11 @@ package realtime import ( - "github.com/gopackage/ddp" + "fmt" + "github.com/Jeffail/gabs" "github.com/detached/gorocket/api" - "log" - "fmt" + "github.com/gopackage/ddp" ) const ( @@ -49,18 +49,13 @@ func (c *Client) SubscribeToMessageStream(channel *api.Channel) (chan api.Messag } func getMessageFromData(data interface{}) *api.Message { - document, _ := gabs.Consume(data) + document := gabs.Wrap(data) return getMessageFromDocument(document) } func getMessagesFromUpdateEvent(update ddp.Update) []api.Message { - document, _ := gabs.Consume(update["args"]) - args, err := document.Children() - - if err != nil { - log.Printf("Event arguments are in an unexpected format: %v", err) - return make([]api.Message, 0) - } + document := gabs.Wrap(update["args"]) + args := document.Children() messages := make([]api.Message, len(args))