1 files changed, 59 insertions, 0 deletions
diff --git a/src/main/java/de/thedevstack/conversationsplus/services/muc/listener/ConferenceServiceDiscoveryReceived.java b/src/main/java/de/thedevstack/conversationsplus/services/muc/listener/ConferenceServiceDiscoveryReceived.java
new file mode 100644
index 00000000..5d1b8c8d
--- /dev/null
+++ b/src/main/java/de/thedevstack/conversationsplus/services/muc/listener/ConferenceServiceDiscoveryReceived.java
@@ -0,0 +1,59 @@
+package de.thedevstack.conversationsplus.services.muc.listener;
+
+import android.util.Log;
+
+import java.util.ArrayList;
+
+import de.thedevstack.conversationsplus.Config;
+import de.thedevstack.conversationsplus.entities.Account;
+import de.thedevstack.conversationsplus.entities.Conversation;
+import de.thedevstack.conversationsplus.services.XmppConnectionService;
+import de.thedevstack.conversationsplus.services.muc.OnConferenceConfigurationFetched;
+import de.thedevstack.conversationsplus.utils.UiUpdateHelper;
+import de.thedevstack.conversationsplus.xml.Element;
+import de.thedevstack.conversationsplus.xmpp.OnIqPacketReceived;
+import de.thedevstack.conversationsplus.xmpp.disco.ServiceDiscovery;
+import de.thedevstack.conversationsplus.xmpp.forms.Data;
+import de.thedevstack.conversationsplus.xmpp.stanzas.IqPacket;
+
+/**
+ */
+public class ConferenceServiceDiscoveryReceived implements OnIqPacketReceived {
+    private Conversation conversation;
+    private OnConferenceConfigurationFetched callback;
+
+    public ConferenceServiceDiscoveryReceived(Conversation conversation, OnConferenceConfigurationFetched callback) {
+        this.conversation = conversation;
+        this.callback = callback;
+    }
+
+    @Override
+    public void onIqPacketReceived(Account account, IqPacket packet) {
+        Element query = packet.findChild(ServiceDiscovery.ELEMENT, ServiceDiscovery.NAMESPACE);
+        if (packet.getType() == IqPacket.TYPE.RESULT && query != null) {
+            ArrayList<String> features = new ArrayList<>();
+            for (Element child : query.getChildren()) {
+                if (child != null && child.getName().equals("feature")) {
+                    String var = child.getAttribute("var");
+                    if (var != null) {
+                        features.add(var);
+                    }
+                }
+            }
+            Element form = query.findChild("x", "jabber:x:data");
+            if (form != null) {
+                conversation.getMucOptions().updateFormData(Data.parse(form));
+            }
+            conversation.getMucOptions().updateFeatures(features);
+            if (callback != null) {
+                callback.onConferenceConfigurationFetched(conversation);
+            }
+            Log.d(Config.LOGTAG, account.getJid().toBareJid() + ": fetched muc configuration for " + conversation.getJid().toBareJid() + " - " + features.toString());
+            UiUpdateHelper.updateConversationUi();
+        } else if (packet.getType() == IqPacket.TYPE.ERROR) {
+            if (callback != null) {
+                callback.onFetchFailed(conversation, packet.getError());
+            }
+        }
+    }
+}