Add Platform Agnostic Commands

bridge/config/config.go

@@ -15,6 +15,7 @@ import (
 )
 
 const (
+	EventWelcomeMsg        = "welcome"
 	EventJoinLeave         = "join_leave"
 	EventTopicChange       = "topic_change"
 	EventFailure           = "failure"
@@ -179,9 +180,10 @@ type Protocol struct {
 }
 
 type ChannelOptions struct {
-	Key        string // irc, xmpp
-	WebhookURL string // discord
-	Topic      string // zulip
+	Key            string // irc, xmpp
+	WebhookURL     string // discord
+	Topic          string // zulip
+	WelcomeMessage string // all
 }
 
 type Bridge struct {

bridge/telegram/handlers.go

@@ -199,6 +199,8 @@ func (b *Btelegram) handleRecv(updates <-chan tgbotapi.Update) {
 			spew.Dump(update.Message)
 		}
 
+		b.handleGroupUpdate(update)
+
 		var message *tgbotapi.Message
 
 		rmsg := config.Message{Account: b.Account, Extra: make(map[string][]interface{})}
@@ -261,6 +263,53 @@ func (b *Btelegram) handleRecv(updates <-chan tgbotapi.Update) {
 	}
 }
 
+func (b *Btelegram) handleGroupUpdate(update tgbotapi.Update) {
+	msg := update.Message
+
+	switch {
+	case msg.NewChatMembers != nil:
+		b.handleUserJoin(update)
+	case msg.LeftChatMember != nil:
+		b.handleUserLeave(update)
+	}
+}
+func (b *Btelegram) handleUserJoin(update tgbotapi.Update) {
+	msg := update.Message
+
+	for _, user := range msg.NewChatMembers {
+
+		rmsg := config.Message{
+			UserID:   strconv.FormatInt(user.ID, 10),
+			Username: user.FirstName, // for some reason all the other name felids are empty on this event (at least for me)
+			Channel:  strconv.FormatInt(msg.Chat.ID, 10),
+			Account:  b.Account,
+			Protocol: b.Protocol,
+			Event:    config.EventJoinLeave,
+			Text:     "joined chat",
+		}
+		b.Remote <- rmsg
+
+		rmsg.Event = config.EventWelcomeMsg
+		b.Remote <- rmsg
+	}
+}
+func (b *Btelegram) handleUserLeave(update tgbotapi.Update) {
+	msg := update.Message
+	user := msg.LeftChatMember
+
+	rmsg := config.Message{
+		UserID:   strconv.FormatInt(user.ID, 10),
+		Username: user.FirstName, // for some reason all the other name felids are empty on this event (at least for me)
+		Channel:  strconv.FormatInt(msg.Chat.ID, 10),
+		Account:  b.Account,
+		Protocol: b.Protocol,
+		Event:    config.EventJoinLeave,
+		Text:     "left chat",
+	}
+
+	b.Remote <- rmsg
+}
+
 // handleDownloadAvatar downloads the avatar of userid from channel
 // sends a EVENT_AVATAR_DOWNLOAD message to the gateway if successful.
 // logs an error message if it fails

bridge/whatsappmulti/handlers.go

@@ -53,7 +53,9 @@ func (b *Bwhatsapp) handleUserJoin(event *events.GroupInfo) {
 			Event:    config.EventJoinLeave,
 			Text:     "joined chat",
 		}
+		b.Remote <- rmsg
 
+		rmsg.Event = config.EventWelcomeMsg
 		b.Remote <- rmsg
 	}
 }

gateway/channelstore.go

@@ -0,0 +1,68 @@
+package gateway
+
+import (
+	"encoding/gob"
+
+	"github.com/42wim/matterbridge/bridge/config"
+	"github.com/philippgille/gokv"
+	"github.com/philippgille/gokv/bbolt"
+	"github.com/philippgille/gokv/encoding"
+)
+
+type ChannelData struct {
+	HasWelcomeMessage bool
+	WelcomeMessage    config.Message
+}
+
+func (r *Router) getChannelStore(path string) gokv.Store {
+	gob.Register(map[string]interface{}{})
+	gob.Register(config.FileInfo{})
+
+	options := bbolt.Options{
+		BucketName: "ChannelData",
+		Path:       path,
+		Codec:      encoding.Gob,
+	}
+
+	gob.Register(map[string]interface{}{})
+
+	store, err := bbolt.NewStore(options)
+	if err != nil {
+		r.logger.Errorf("Could not connect to db: %s", path)
+	}
+
+	return store
+}
+
+func (r *Router) getWelcomeMessage(Channel string) *config.Message {
+	channelData := new(ChannelData)
+	found, err := r.ChannelStore.Get(Channel, channelData)
+	if err != nil {
+		r.logger.Error(err)
+	}
+
+	if found && channelData.HasWelcomeMessage {
+		return &channelData.WelcomeMessage
+	}
+
+	return nil
+}
+
+func (r *Router) setWelcomeMessage(Channel string, newWelcomeMessage *config.Message) error {
+	channelData := new(ChannelData)
+	r.ChannelStore.Get(Channel, channelData)
+
+	if newWelcomeMessage == nil {
+		channelData.HasWelcomeMessage = false
+		channelData.WelcomeMessage = config.Message{}
+	} else {
+		channelData.HasWelcomeMessage = true
+		channelData.WelcomeMessage = *newWelcomeMessage
+	}
+
+	err := r.ChannelStore.Set(Channel, channelData)
+	if err != nil {
+		r.logger.Errorf(err.Error())
+	}
+	return err
+}