1 files changed, 80 insertions, 0 deletions
diff --git a/vendor/github.com/mattermost/rsc/google/googleserver/chat.go b/vendor/github.com/mattermost/rsc/google/googleserver/chat.go
new file mode 100644
index 000000000..8b064dc92
--- /dev/null
+++ b/vendor/github.com/mattermost/rsc/google/googleserver/chat.go
@@ -0,0 +1,80 @@
+// Copyright 2011 The Go Authors.  All rights reserved.
+// Use of this source code is governed by a BSD-style
+// license that can be found in the LICENSE file.
+
+// TODO: Add ChatHangup.
+// TODO: Auto-hangup chats that are gone.
+
+package main
+
+import (
+	"fmt"
+
+	"github.com/mattermost/rsc/google"
+	"github.com/mattermost/rsc/xmpp"
+)
+
+type chatClient struct {
+	email string
+	id    string
+	xmpp  *xmpp.Client
+}
+
+var chatClients = map[string]*chatClient{}
+
+func (*Server) chatClient(cid *google.ChatID) (*chatClient, error) {
+	id := cid.ID
+	cc := chatClients[cid.ID]
+	if cc == nil {
+		a := google.Cfg.AccountByEmail(cid.Email)
+		if a == nil {
+			return nil, fmt.Errorf("unknown account %s", cid.Email)
+		}
+		// New client.
+		cli, err := xmpp.NewClient("talk.google.com:443", a.Email, a.Password)
+		if err != nil {
+			return nil, err
+		}
+		cc = &chatClient{email: a.Email, id: id, xmpp: cli}
+		cc.xmpp.Status(cid.Status, cid.StatusMsg)
+		chatClients[id] = cc
+	}
+	return cc, nil
+}
+
+func (srv *Server) ChatRecv(cid *google.ChatID, msg *xmpp.Chat) error {
+	cc, err := srv.chatClient(cid)
+	if err != nil {
+		return err
+	}
+	chat, err := cc.xmpp.Recv()
+	if err != nil {
+		return err
+	}
+	*msg = chat
+	return nil
+}
+
+func (srv *Server) ChatStatus(cid *google.ChatID, _ *Empty) error {
+	cc, err := srv.chatClient(cid)
+	if err != nil {
+		return err
+	}
+	return cc.xmpp.Status(cid.Status, cid.StatusMsg)
+}
+
+func (srv *Server) ChatSend(arg *google.ChatSend, _ *Empty) error {
+	cc, err := srv.chatClient(arg.ID)
+	if err != nil {
+		return err
+	}
+	return cc.xmpp.Send(arg.Msg)
+}
+
+func (srv *Server) ChatRoster(cid *google.ChatID, _ *Empty) error {
+	cc, err := srv.chatClient(cid)
+	if err != nil {
+		return err
+	}
+	return cc.xmpp.Roster()
+}