From 463d66fce7ef0dfea2afd537e9ef51b5ddf322da Mon Sep 17 00:00:00 2001
From: Vitaly Takmazov
Date: Fri, 3 Feb 2017 12:54:35 +0300
Subject: juick-xmpp: handle stream errors

---
 juick-xmpp/src/main/java/com/juick/components/s2s/ConnectionIn.java | 6 ++++++
 1 file changed, 6 insertions(+)

(limited to 'juick-xmpp/src/main/java/com/juick/components')

diff --git a/juick-xmpp/src/main/java/com/juick/components/s2s/ConnectionIn.java b/juick-xmpp/src/main/java/com/juick/components/s2s/ConnectionIn.java
index 8713aa03..1cd914c9 100644
--- a/juick-xmpp/src/main/java/com/juick/components/s2s/ConnectionIn.java
+++ b/juick-xmpp/src/main/java/com/juick/components/s2s/ConnectionIn.java
@@ -4,6 +4,7 @@ import com.juick.components.XMPPServer;
 import com.juick.xmpp.Iq;
 import com.juick.xmpp.Message;
 import com.juick.xmpp.Presence;
+import com.juick.xmpp.extensions.StreamError;
 import com.juick.xmpp.utils.XmlUtils;
 import org.xmlpull.v1.XmlPullParser;
 import rocks.xmpp.addr.Jid;
@@ -139,6 +140,11 @@ public class ConnectionIn extends Connection implements Runnable {
                     }
                 } else if (isSecured() && tag.equals("stream") && parser.getNamespace().equals(NS_STREAM)) {
                     sendOpenStream(null, true);
+                } else if (tag.equals("error")) {
+                    StreamError streamError = StreamError.parse(parser);
+                    logger.warn("Stream error from {}: {}", streamID, streamError.getCondition());
+                    xmpp.removeConnectionIn(this);
+                    closeConnection();
                 } else {
                     String unhandledStanza = XmlUtils.parseToString(parser, true);
                     logger.warn("Unhandled stanza from {}: {}", streamID, unhandledStanza);
-- 
cgit v1.2.3