From 40d76b22960fcc57e167fb08b97f4ff3aec31090 Mon Sep 17 00:00:00 2001
From: Wim <wim@42.be>
Date: Mon, 11 Feb 2019 01:34:50 +0100
Subject: Fix error handling on bad event queue id (zulip). Closes #694

---
 bridge/zulip/zulip.go | 18 +++++++++++++++++-
 1 file changed, 17 insertions(+), 1 deletion(-)

(limited to 'bridge')

diff --git a/bridge/zulip/zulip.go b/bridge/zulip/zulip.go
index 88832d36..165bdb18 100644
--- a/bridge/zulip/zulip.go
+++ b/bridge/zulip/zulip.go
@@ -100,7 +100,23 @@ func (b *Bzulip) getChannel(id int) string {
 
 func (b *Bzulip) handleQueue() error {
 	for {
-		messages, _ := b.q.GetEvents()
+		messages, err := b.q.GetEvents()
+		switch err {
+		case gzb.BackoffError:
+			time.Sleep(time.Second * 5)
+		case gzb.BadEventQueueError:
+			b.Log.Info("got a bad event queue id error, reconnecting")
+			b.bot.Queues = nil
+			b.q, err = b.bot.RegisterAll()
+			if err != nil {
+				b.Log.Errorf("reconnecting failed: %s. Sleeping 10 seconds", err)
+				time.Sleep(time.Second * 10)
+				continue
+			}
+			continue
+		default:
+			b.Log.Debugf("receiving error: %#v", err)
+		}
 		for _, m := range messages {
 			b.Log.Debugf("== Receiving %#v", m)
 			// ignore our own messages
-- 
cgit v1.2.3