From 921f2dfcdf1a6263220b55eb55716e497373dfcf Mon Sep 17 00:00:00 2001
From: cori hudson <54032873+hyperobject@users.noreply.github.com>
Date: Mon, 26 Aug 2019 15:00:31 -0400
Subject: Add initial Keybase Chat support (#877)
* initial work on native keybase bridging
* Hopefully make a functional keybase bridge
* add keybase to bridgemap
* send to right channel, try to figure out received msgs
* add account and userid
* i am a Dam Fool
* Fix formatting for messages, handle /me
* update vendors, ran golint and goimports
* move handlers to handlers.go, clean up unused config options
* add sample config, fix inconsistent remote nick handling
* Update readme with keybase links
* Resolve fixmie errors
* Error -> Errorf
* fix linting errors in go.mod and go.sum
* explicitly join channels, ignore messages from non-specified channels
* check that team names match before bridging message
---
bridge/keybase/handlers.go | 59 +++++++++++++++++++++++++++++++++
bridge/keybase/keybase.go | 82 ++++++++++++++++++++++++++++++++++++++++++++++
2 files changed, 141 insertions(+)
create mode 100644 bridge/keybase/handlers.go
create mode 100644 bridge/keybase/keybase.go
(limited to 'bridge/keybase')
diff --git a/bridge/keybase/handlers.go b/bridge/keybase/handlers.go
new file mode 100644
index 00000000..165aeb16
--- /dev/null
+++ b/bridge/keybase/handlers.go
@@ -0,0 +1,59 @@
+package bkeybase
+
+import (
+ "strconv"
+
+ "github.com/42wim/matterbridge/bridge/config"
+ "github.com/keybase/go-keybase-chat-bot/kbchat"
+)
+
+func (b *Bkeybase) handleKeybase() {
+ sub, err := b.kbc.ListenForNewTextMessages()
+ if err != nil {
+ b.Log.Errorf("Error listening: %s", err.Error())
+ }
+
+ go func() {
+ for {
+ msg, err := sub.Read()
+ if err != nil {
+ b.Log.Errorf("failed to read message: %s", err.Error())
+ }
+
+ if msg.Message.Content.Type != "text" {
+ continue
+ }
+
+ if msg.Message.Sender.Username == b.kbc.GetUsername() {
+ continue
+ }
+
+ b.handleMessage(msg.Message)
+
+ }
+ }()
+}
+
+func (b *Bkeybase) handleMessage(msg kbchat.Message) {
+ b.Log.Debugf("== Receiving event: %#v", msg)
+ if msg.Channel.TopicName != b.channel || msg.Channel.Name != b.team {
+ return
+ }
+
+ if msg.Sender.Username != b.kbc.GetUsername() {
+
+ // TODO download avatar
+
+ // Create our message
+ rmsg := config.Message{Username: msg.Sender.Username, Text: msg.Content.Text.Body, UserID: msg.Sender.Uid, Channel: msg.Channel.TopicName, ID: strconv.Itoa(msg.MsgID), Account: b.Account}
+
+ // Text must be a string
+ if msg.Content.Type != "text" {
+ b.Log.Errorf("message is not text")
+ return
+ }
+
+ b.Log.Debugf("<= Sending message from %s on %s to gateway", msg.Sender.Username, msg.Channel.Name)
+ b.Remote <- rmsg
+ }
+}
diff --git a/bridge/keybase/keybase.go b/bridge/keybase/keybase.go
new file mode 100644
index 00000000..a4b12742
--- /dev/null
+++ b/bridge/keybase/keybase.go
@@ -0,0 +1,82 @@
+package bkeybase
+
+import (
+ "strconv"
+
+ "github.com/42wim/matterbridge/bridge"
+ "github.com/42wim/matterbridge/bridge/config"
+ "github.com/keybase/go-keybase-chat-bot/kbchat"
+)
+
+// Bkeybase bridge structure
+type Bkeybase struct {
+ kbc *kbchat.API
+ user string
+ channel string
+ team string
+ *bridge.Config
+}
+
+// New initializes Bkeybase object and sets team
+func New(cfg *bridge.Config) bridge.Bridger {
+ b := &Bkeybase{Config: cfg}
+ b.team = b.Config.GetString("Team")
+ return b
+}
+
+// Connect starts keybase API and listener loop
+func (b *Bkeybase) Connect() error {
+ var err error
+ b.Log.Infof("Connecting %s", b.GetString("Team"))
+
+ // use default keybase location (`keybase`)
+ b.kbc, err = kbchat.Start(kbchat.RunOptions{})
+ if err != nil {
+ return err
+ }
+ b.user = b.kbc.GetUsername()
+ b.Log.Info("Connection succeeded")
+ go b.handleKeybase()
+ return nil
+}
+
+// Disconnect doesn't do anything for now
+func (b *Bkeybase) Disconnect() error {
+ return nil
+}
+
+// JoinChannel sets channel name in struct
+func (b *Bkeybase) JoinChannel(channel config.ChannelInfo) error {
+ if _, err := b.kbc.JoinChannel(b.team, channel.Name); err != nil {
+ return err
+ }
+ b.channel = channel.Name
+ return nil
+}
+
+// Send receives bridge messages and sends them to Keybase chat room
+func (b *Bkeybase) Send(msg config.Message) (string, error) {
+ b.Log.Debugf("=> Receiving %#v", msg)
+
+ // Handle /me events
+ if msg.Event == config.EventUserAction {
+ msg.Text = "_" + msg.Text + "_"
+ }
+
+ // Delete message if we have an ID
+ // Delete message not supported by keybase go library yet
+
+ // Upload a file if it exists
+ // kbchat lib does not support attachments yet
+
+ // Edit message if we have an ID
+ // kbchat lib does not support message editing yet
+
+ // Send regular message
+ resp, err := b.kbc.SendMessageByTeamName(b.team, msg.Username+msg.Text, &b.channel)
+ if err != nil {
+ return "", err
+ }
+
+ return strconv.Itoa(resp.Result.MsgID), err
+}
--
cgit v1.2.3