package eu.siacs.conversations.entities; import android.util.Pair; import java.util.ArrayList; import java.util.HashMap; import java.util.Hashtable; import java.util.List; import java.util.Map; public class Presences { private final Hashtable presences = new Hashtable<>(); private static String nameWithoutVersion(String name) { String[] parts = name.split(" "); if (parts.length > 1 && Character.isDigit(parts[parts.length - 1].charAt(0))) { StringBuilder output = new StringBuilder(); for (int i = 0; i < parts.length - 1; ++i) { if (output.length() != 0) { output.append(' '); } output.append(parts[i]); } return output.toString(); } else { return name; } } public List getPresences() { synchronized (this.presences) { return new ArrayList<>(this.presences.values()); } } public Map getPresencesMap() { synchronized (this.presences) { return new HashMap<>(this.presences); } } public Presence get(String resource) { synchronized (this.presences) { return this.presences.get(resource); } } public void updatePresence(String resource, Presence presence) { synchronized (this.presences) { this.presences.put(resource, presence); } } public void removePresence(String resource) { synchronized (this.presences) { this.presences.remove(resource); } } public void clearPresences() { synchronized (this.presences) { this.presences.clear(); } } public Presence.Status getShownStatus() { Presence.Status status = Presence.Status.OFFLINE; synchronized (this.presences) { for (Presence p : presences.values()) { if (p.getStatus() == Presence.Status.DND) { return p.getStatus(); } else if (p.getStatus().compareTo(status) < 0) { status = p.getStatus(); } } } return status; } public int size() { synchronized (this.presences) { return presences.size(); } } public String[] toResourceArray() { synchronized (this.presences) { final String[] presencesArray = new String[presences.size()]; presences.keySet().toArray(presencesArray); return presencesArray; } } public List asTemplates() { synchronized (this.presences) { ArrayList templates = new ArrayList<>(presences.size()); for (Presence p : presences.values()) { if (p.getMessage() != null && !p.getMessage().trim().isEmpty()) { templates.add(new PresenceTemplate(p.getStatus(), p.getMessage())); } } return templates; } } public boolean has(String presence) { synchronized (this.presences) { return presences.containsKey(presence); } } public List getStatusMessages() { ArrayList messages = new ArrayList<>(); synchronized (this.presences) { for (Presence presence : this.presences.values()) { String message = presence.getMessage() == null ? null : presence.getMessage().trim(); if (message != null && !message.isEmpty() && !messages.contains(message)) { messages.add(message); } } } return messages; } public boolean allOrNonSupport(String namespace) { synchronized (this.presences) { for (Presence presence : this.presences.values()) { ServiceDiscoveryResult disco = presence.getServiceDiscoveryResult(); if (disco == null || !disco.getFeatures().contains(namespace)) { return false; } } } return true; } public Pair, Map> toTypeAndNameMap() { Map typeMap = new HashMap<>(); Map nameMap = new HashMap<>(); synchronized (this.presences) { for (Map.Entry presenceEntry : this.presences.entrySet()) { String resource = presenceEntry.getKey(); Presence presence = presenceEntry.getValue(); ServiceDiscoveryResult serviceDiscoveryResult = presence == null ? null : presence.getServiceDiscoveryResult(); if (serviceDiscoveryResult != null && serviceDiscoveryResult.getIdentities().size() > 0) { ServiceDiscoveryResult.Identity identity = serviceDiscoveryResult.getIdentities().get(0); String type = identity.getType(); String name = identity.getName(); if (type != null) { typeMap.put(resource, type); } if (name != null) { nameMap.put(resource, nameWithoutVersion(name)); } } } } return new Pair<>(typeMap, nameMap); } }