Navigation Menu

Skip to content

Commit

Permalink
Roster should now handle empty roster results correct
Browse files Browse the repository at this point in the history
  • Loading branch information
dereulenspiegel committed Mar 31, 2010
1 parent 5bc91f9 commit 11ff5ff
Showing 1 changed file with 34 additions and 0 deletions.
34 changes: 34 additions & 0 deletions source/org/jivesoftware/smack/Roster.java
Expand Up @@ -68,6 +68,8 @@ public class Roster {
private PresencePacketListener presencePacketListener;

private SubscriptionMode subscriptionMode = getDefaultSubscriptionMode();

private String requestPacketId;

/**
* Returns the default subscription processing mode to use when a new Roster is created. The
Expand Down Expand Up @@ -191,6 +193,9 @@ public void reload() {
if(persistentStorage!=null){
packet.setVersion(persistentStorage.getRosterVersion());
}
requestPacketId = packet.getPacketID();
PacketFilter idFilter = new PacketIDFilter(requestPacketId);
connection.addPacketListener(new RosterResultListener(), idFilter);
connection.sendPacket(packet);
}

Expand Down Expand Up @@ -908,6 +913,35 @@ else if (presence.getType() == Presence.Type.error &&
}
}
}

/**
* Listen for empty IQ results which indicate that the client has already a current
* roster version
* @author Till Klocke
*
*/

private class RosterResultListener implements PacketListener{

@Override
public void processPacket(Packet packet) {
if(packet instanceof IQ){
IQ result = (IQ)packet;
if(result.getType().equals(IQ.Type.RESULT) && result.getExtensions().isEmpty()){
Collection<String> addedEntries = new ArrayList<String>();
Collection<String> updatedEntries = new ArrayList<String>();
Collection<String> deletedEntries = new ArrayList<String>();
if(persistentStorage!=null){
for(RosterPacket.Item item : persistentStorage.getEntries()){
insertRosterItem(item,addedEntries,updatedEntries,deletedEntries);
}
fireRosterChangedEvent(addedEntries,updatedEntries,deletedEntries);
}
}
}
connection.removePacketListener(this);
}
}

/**
* Listens for all roster packets and processes them.
Expand Down

0 comments on commit 11ff5ff

Please sign in to comment.