From ce7b749fd54be871ce62934fca7978b165809e87 Mon Sep 17 00:00:00 2001 From: Wim Date: Thu, 13 Jun 2019 22:37:31 +0200 Subject: Update github.com/Rhymen/go-whatsapp vendor. Fixes #843 --- vendor/github.com/Rhymen/go-whatsapp/handler.go | 77 +++++++++++++++++++++++++ 1 file changed, 77 insertions(+) (limited to 'vendor/github.com/Rhymen/go-whatsapp/handler.go') diff --git a/vendor/github.com/Rhymen/go-whatsapp/handler.go b/vendor/github.com/Rhymen/go-whatsapp/handler.go index 7abd55f3..f909bed5 100644 --- a/vendor/github.com/Rhymen/go-whatsapp/handler.go +++ b/vendor/github.com/Rhymen/go-whatsapp/handler.go @@ -3,6 +3,7 @@ package whatsapp import ( "fmt" "os" + "strings" "github.com/Rhymen/go-whatsapp/binary" "github.com/Rhymen/go-whatsapp/binary/proto" @@ -79,6 +80,22 @@ type RawMessageHandler interface { HandleRawMessage(message *proto.WebMessageInfo) } +/** +The ContactListHandler interface needs to be implemented to applky custom actions to contact lists dispatched by the dispatcher. +*/ +type ContactListHandler interface { + Handler + HandleContactList(contacts []Contact) +} + +/** +The ChatListHandler interface needs to be implemented to apply custom actions to chat lists dispatched by the dispatcher. +*/ +type ChatListHandler interface { + Handler + HandleChatList(contacts []Chat) +} + /* AddHandler adds an handler to the list of handler that receive dispatched messages. The provided handler must at least implement the Handler interface. Additionally implemented @@ -162,6 +179,62 @@ func (wac *Conn) handle(message interface{}) { } +func (wac *Conn) handleContacts(contacts interface{}) { + var contactList []Contact + c, ok := contacts.([]interface{}) + if !ok { + return + } + for _, contact := range c { + contactNode, ok := contact.(binary.Node) + if !ok { + continue + } + + jid := strings.Replace(contactNode.Attributes["jid"], "@c.us", "@s.whatsapp.net", 1) + contactList = append(contactList, Contact{ + jid, + contactNode.Attributes["notify"], + contactNode.Attributes["name"], + contactNode.Attributes["short"], + }) + } + for _, h := range wac.handler { + if x, ok := h.(ContactListHandler); ok { + go x.HandleContactList(contactList) + } + } +} + +func (wac *Conn) handleChats(chats interface{}) { + var chatList []Chat + c, ok := chats.([]interface{}) + if !ok { + return + } + for _, chat := range c { + chatNode, ok := chat.(binary.Node) + if !ok { + continue + } + + jid := strings.Replace(chatNode.Attributes["jid"], "@c.us", "@s.whatsapp.net", 1) + chatList = append(chatList, Chat{ + jid, + chatNode.Attributes["name"], + chatNode.Attributes["count"], + chatNode.Attributes["t"], + chatNode.Attributes["mute"], + chatNode.Attributes["spam"], + }) + } + for _, h := range wac.handler { + if x, ok := h.(ChatListHandler); ok { + go x.HandleChatList(chatList) + } + } +} + func (wac *Conn) dispatch(msg interface{}) { if msg == nil { return @@ -180,6 +253,10 @@ func (wac *Conn) dispatch(msg interface{}) { } } else if message.Description == "response" && message.Attributes["type"] == "contacts" { wac.updateContacts(message.Content) + wac.handleContacts(message.Content) + } else if message.Description == "response" && message.Attributes["type"] == "chat" { + wac.updateChats(message.Content) + wac.handleChats(message.Content) } case error: wac.handle(message) -- cgit v1.2.3