summaryrefslogtreecommitdiffstats
path: root/bridge/keybase/handlers.go
diff options
context:
space:
mode:
authorcori hudson <54032873+hyperobject@users.noreply.github.com>2019-08-26 15:00:31 -0400
committerWim <wim@42.be>2019-08-26 21:00:31 +0200
commit921f2dfcdf1a6263220b55eb55716e497373dfcf (patch)
tree436478bd7b61ea598d75af0d27520b512dad1683 /bridge/keybase/handlers.go
parent79a006c8de311a7bbab540e62bd3fac998d415d5 (diff)
downloadmatterbridge-msglm-921f2dfcdf1a6263220b55eb55716e497373dfcf.tar.gz
matterbridge-msglm-921f2dfcdf1a6263220b55eb55716e497373dfcf.tar.bz2
matterbridge-msglm-921f2dfcdf1a6263220b55eb55716e497373dfcf.zip
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
Diffstat (limited to 'bridge/keybase/handlers.go')
-rw-r--r--bridge/keybase/handlers.go59
1 files changed, 59 insertions, 0 deletions
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
+ }
+}