1 files changed, 96 insertions, 0 deletions
diff --git a/src/main/java/de/thedevstack/conversationsplus/services/muc/listener/ConferenceConfigurationFetched.java b/src/main/java/de/thedevstack/conversationsplus/services/muc/listener/ConferenceConfigurationFetched.java
new file mode 100644
index 00000000..a386db88
--- /dev/null
+++ b/src/main/java/de/thedevstack/conversationsplus/services/muc/listener/ConferenceConfigurationFetched.java
@@ -0,0 +1,96 @@
+package de.thedevstack.conversationsplus.services.muc.listener;
+
+import android.util.Log;
+
+import de.thedevstack.conversationsplus.Config;
+import de.thedevstack.conversationsplus.entities.Account;
+import de.thedevstack.conversationsplus.entities.Conversation;
+import de.thedevstack.conversationsplus.entities.MucOptions;
+import de.thedevstack.conversationsplus.generator.PresenceGenerator;
+import de.thedevstack.conversationsplus.persistance.DatabaseBackend;
+import de.thedevstack.conversationsplus.services.muc.OnConferenceConfigurationFetched;
+import de.thedevstack.conversationsplus.services.muc.OnConferenceJoined;
+import de.thedevstack.conversationsplus.utils.XmppConnectionServiceAccessor;
+import de.thedevstack.conversationsplus.utils.XmppSendUtil;
+import de.thedevstack.conversationsplus.xml.Element;
+import de.thedevstack.conversationsplus.xmpp.OnIqPacketReceived;
+import de.thedevstack.conversationsplus.xmpp.jid.Jid;
+import de.thedevstack.conversationsplus.xmpp.stanzas.IqPacket;
+import de.thedevstack.conversationsplus.xmpp.stanzas.PresencePacket;
+
+/**
+ */
+public class ConferenceConfigurationFetched implements OnConferenceConfigurationFetched {
+    private OnConferenceJoined onConferenceJoined;
+
+    public ConferenceConfigurationFetched(OnConferenceJoined onConferenceJoined) {
+        this.onConferenceJoined = onConferenceJoined;
+    }
+
+    private void join(Conversation conversation) {
+        Account account = conversation.getAccount();
+        final MucOptions mucOptions = conversation.getMucOptions();
+        final Jid joinJid = mucOptions.getSelf().getFullJid();
+        Log.d(Config.LOGTAG, account.getJid().toBareJid().toString() + ": joining conversation " + joinJid.toString());
+        long lastMessageTransmitted = conversation.getLastMessageTransmitted();
+        PresencePacket packet = PresenceGenerator.generateMucJoin(account, joinJid, mucOptions, lastMessageTransmitted);
+        XmppSendUtil.sendPresencePacket(account, packet);
+        if (onConferenceJoined != null) {
+            onConferenceJoined.onConferenceJoined(conversation);
+        }
+        if (!joinJid.equals(conversation.getJid())) {
+            conversation.setContactJid(joinJid);
+            DatabaseBackend.getInstance().updateConversation(conversation);
+        }
+
+        if (mucOptions.mamSupport()) {
+            XmppConnectionServiceAccessor.xmppConnectionService.getMessageArchiveService().catchupMUC(conversation);
+        }
+        if (mucOptions.membersOnly() && mucOptions.nonanonymous()) {
+            fetchConferenceMembers(conversation);
+        }
+        XmppConnectionServiceAccessor.xmppConnectionService.sendUnsentMessages(conversation);
+    }
+
+    @Override
+    public void onConferenceConfigurationFetched(Conversation conversation) {
+        join(conversation);
+    }
+
+    @Override
+    public void onFetchFailed(final Conversation conversation, Element error) {
+        join(conversation);
+        XmppConnectionServiceAccessor.xmppConnectionService.fetchConferenceConfiguration(conversation);
+    }
+
+    private void fetchConferenceMembers(final Conversation conversation) {
+        final Account account = conversation.getAccount();
+        final String[] affiliations = {"member","admin","owner"};
+        OnIqPacketReceived callback = new OnIqPacketReceived() {
+
+            private int i = 0;
+
+            @Override
+            public void onIqPacketReceived(Account account, IqPacket packet) {
+                Element query = packet.query("http://jabber.org/protocol/muc#admin");
+                if (packet.getType() == IqPacket.TYPE.RESULT && query != null) {
+                    for(Element child : query.getChildren()) {
+                        if ("item".equals(child.getName())) {
+                            conversation.getMucOptions().putMember(child.getAttributeAsJid("jid"));
+                        }
+                    }
+                } else {
+                    Log.d(Config.LOGTAG,account.getJid().toBareJid()+": could not request affiliation "+affiliations[i]+" in "+conversation.getJid().toBareJid());
+                }
+                ++i;
+                if (i >= affiliations.length) {
+                    Log.d(Config.LOGTAG,account.getJid().toBareJid()+": retrieved members for "+conversation.getJid().toBareJid()+": "+conversation.getMucOptions().getMembers());
+                }
+            }
+        };
+        for(String affiliation : affiliations) {
+            XmppSendUtil.sendIqPacket(account, XmppConnectionServiceAccessor.xmppConnectionService.getIqGenerator().queryAffiliation(conversation, affiliation), callback);
+        }
+        Log.d(Config.LOGTAG,account.getJid().toBareJid()+": fetching members for "+conversation.getName());
+    }
+}