From cf3cddafab42770d9dc3fedce57b1d326703040a Mon Sep 17 00:00:00 2001
From: Wim <wim@42.be>
Date: Sun, 30 Jun 2019 18:34:38 +0200
Subject: Keep connection state. Fixes #856

Actually check if we're connected when trying to Send() a message.
Messages now will get dropped when not connected.

TODO: Ideally this should be in a ring buffer to retransmit when the
connection comes back up.
---
 bridge/xmpp/xmpp.go | 23 +++++++++++++++++++++++
 1 file changed, 23 insertions(+)

(limited to 'bridge/xmpp')

diff --git a/bridge/xmpp/xmpp.go b/bridge/xmpp/xmpp.go
index 2376d60c..e950bcda 100644
--- a/bridge/xmpp/xmpp.go
+++ b/bridge/xmpp/xmpp.go
@@ -2,7 +2,9 @@ package bxmpp
 
 import (
 	"crypto/tls"
+	"fmt"
 	"strings"
+	"sync"
 	"time"
 
 	"github.com/42wim/matterbridge/bridge"
@@ -19,6 +21,8 @@ type Bxmpp struct {
 	startTime time.Time
 	xc        *xmpp.Client
 	xmppMap   map[string]string
+	connected bool
+	sync.RWMutex
 }
 
 func New(cfg *bridge.Config) bridge.Bridger {
@@ -55,6 +59,10 @@ func (b *Bxmpp) JoinChannel(channel config.ChannelInfo) error {
 }
 
 func (b *Bxmpp) Send(msg config.Message) (string, error) {
+	// should be fixed by using a cache instead of dropping
+	if !b.Connected() {
+		return "", fmt.Errorf("bridge %s not connected, dropping message %#v to bridge", b.Account, msg)
+	}
 	// ignore delete messages
 	if msg.Event == config.EventMsgDelete {
 		return "", nil
@@ -124,6 +132,7 @@ func (b *Bxmpp) createXMPP() error {
 }
 
 func (b *Bxmpp) manageConnection() {
+	b.setConnected(true)
 	initial := true
 	bf := &backoff.Backoff{
 		Min:    time.Second,
@@ -148,6 +157,7 @@ func (b *Bxmpp) manageConnection() {
 
 		if err := b.handleXMPP(); err != nil {
 			b.Log.WithError(err).Error("Disconnected.")
+			b.setConnected(false)
 		}
 
 		// Reconnection loop using an exponential back-off strategy. We
@@ -159,6 +169,7 @@ func (b *Bxmpp) manageConnection() {
 
 			b.Log.Infof("Reconnecting now.")
 			if err := b.createXMPP(); err == nil {
+				b.setConnected(true)
 				bf.Reset()
 				break
 			}
@@ -334,3 +345,15 @@ func (b *Bxmpp) skipMessage(message xmpp.Chat) bool {
 	// skip delayed messages
 	return !message.Stamp.IsZero() && time.Since(message.Stamp).Minutes() > 5
 }
+
+func (b *Bxmpp) setConnected(state bool) {
+	b.Lock()
+	b.connected = state
+	defer b.Unlock()
+}
+
+func (b *Bxmpp) Connected() bool {
+	b.RLock()
+	defer b.RUnlock()
+	return b.connected
+}
-- 
cgit v1.2.3