CarrotChat v2.8.80.240429版本的 MD5 值为:fdf98761f01e715a89df24b85b0d206e
以下内容为反编译后的 EntityCapsManager.java 源代码,内容仅作参考
package org.jivesoftware.smackx.caps;
import java.io.UnsupportedEncodingException;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.Comparator;
import java.util.HashMap;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.Queue;
import java.util.TreeSet;
import java.util.WeakHashMap;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.jivesoftware.smack.AbstractConnectionListener;
import org.jivesoftware.smack.ConnectionCreationListener;
import org.jivesoftware.smack.Manager;
import org.jivesoftware.smack.SmackException;
import org.jivesoftware.smack.StanzaListener;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.XMPPConnectionRegistry;
import org.jivesoftware.smack.XMPPException;
import org.jivesoftware.smack.filter.AndFilter;
import org.jivesoftware.smack.filter.PresenceTypeFilter;
import org.jivesoftware.smack.filter.StanzaExtensionFilter;
import org.jivesoftware.smack.filter.StanzaFilter;
import org.jivesoftware.smack.filter.StanzaTypeFilter;
import org.jivesoftware.smack.packet.ExtensionElement;
import org.jivesoftware.smack.packet.IQ;
import org.jivesoftware.smack.packet.Presence;
import org.jivesoftware.smack.packet.Stanza;
import org.jivesoftware.smack.roster.AbstractPresenceEventListener;
import org.jivesoftware.smack.roster.Roster;
import org.jivesoftware.smack.util.stringencoder.Base64;
import org.jivesoftware.smackx.caps.cache.EntityCapsPersistentCache;
import org.jivesoftware.smackx.caps.packet.CapsExtension;
import org.jivesoftware.smackx.disco.AbstractNodeInformationProvider;
import org.jivesoftware.smackx.disco.ServiceDiscoveryManager;
import org.jivesoftware.smackx.disco.packet.DiscoverInfo;
import org.jivesoftware.smackx.xdata.FormField;
import org.jivesoftware.smackx.xdata.packet.DataForm;
import org.jxmpp.jid.FullJid;
import org.jxmpp.jid.Jid;
import org.jxmpp.util.cache.LruCache;
public final class EntityCapsManager extends Manager {
static final LruCache<String, DiscoverInfo> CAPS_CACHE;
private static String DEFAULT_ENTITY_NODE = null;
private static final String DEFAULT_HASH = "SHA-1";
public static final String ELEMENT = "c";
static final LruCache<Jid, NodeVerHash> JID_TO_NODEVER_CACHE;
private static final Logger LOGGER = Logger.getLogger(EntityCapsManager.class.getName());
public static final String NAMESPACE = "http://jabber.org/protocol/caps";
private static final StanzaFilter PRESENCES_WITH_CAPS;
private static final Map<String, MessageDigest> SUPPORTED_HASHES;
private static boolean autoEnableEntityCaps;
private static final Map<XMPPConnection, EntityCapsManager> instances;
protected static EntityCapsPersistentCache persistentCache;
private CapsVersionAndHash currentCapsVersion;
private boolean entityCapsEnabled;
private String entityNode;
private final Queue<CapsVersionAndHash> lastLocalCapsVersions;
private volatile Presence presenceSend;
private final ServiceDiscoveryManager sdm;
public static class NodeVerHash {
private String hash;
private String node;
private String nodeVer;
private String ver;
NodeVerHash(String str, CapsVersionAndHash capsVersionAndHash) {
this(str, capsVersionAndHash.version, capsVersionAndHash.hash);
}
public String getHash() {
return this.hash;
}
public String getNode() {
return this.node;
}
public String getNodeVer() {
return this.nodeVer;
}
public String getVer() {
return this.ver;
}
NodeVerHash(String str, String str2, String str3) {
this.node = str;
this.ver = str2;
this.hash = str3;
this.nodeVer = str + "#" + str2;
}
}
static {
HashMap hashMap = new HashMap();
SUPPORTED_HASHES = hashMap;
DEFAULT_ENTITY_NODE = "http://www.igniterealtime.org/projects/smack";
autoEnableEntityCaps = true;
instances = new WeakHashMap();
PRESENCES_WITH_CAPS = new AndFilter(new StanzaTypeFilter(Presence.class), new StanzaExtensionFilter("c", "http://jabber.org/protocol/caps"));
CAPS_CACHE = new LruCache<>(1000);
JID_TO_NODEVER_CACHE = new LruCache<>(10000);
XMPPConnectionRegistry.addConnectionCreationListener(new ConnectionCreationListener() {
@Override
public void connectionCreated(XMPPConnection xMPPConnection) {
EntityCapsManager.getInstanceFor(xMPPConnection);
}
});
try {
hashMap.put("SHA-1", MessageDigest.getInstance("SHA-1"));
} catch (NoSuchAlgorithmException unused) {
}
}
private EntityCapsManager(XMPPConnection xMPPConnection) {
super(xMPPConnection);
this.lastLocalCapsVersions = new ConcurrentLinkedQueue();
this.entityNode = DEFAULT_ENTITY_NODE;
ServiceDiscoveryManager instanceFor = ServiceDiscoveryManager.getInstanceFor(xMPPConnection);
this.sdm = instanceFor;
instances.put(xMPPConnection, this);
xMPPConnection.addConnectionListener(new AbstractConnectionListener() {
private void processCapsStreamFeatureIfAvailable(XMPPConnection xMPPConnection2) {
CapsExtension capsExtension = (CapsExtension) xMPPConnection2.getFeature("c", "http://jabber.org/protocol/caps");
if (capsExtension != null) {
EntityCapsManager.addCapsExtensionInfo(xMPPConnection2.getXMPPServiceDomain(), capsExtension);
}
}
@Override
public void authenticated(XMPPConnection xMPPConnection2, boolean z10) {
processCapsStreamFeatureIfAvailable(xMPPConnection2);
if (!z10) {
EntityCapsManager.this.presenceSend = null;
}
}
@Override
public void connected(XMPPConnection xMPPConnection2) {
processCapsStreamFeatureIfAvailable(xMPPConnection2);
}
});
updateLocalEntityCaps();
if (autoEnableEntityCaps) {
enableEntityCaps();
}
xMPPConnection.addAsyncStanzaListener(new StanzaListener() {
@Override
public void processStanza(Stanza stanza) {
if (!EntityCapsManager.this.entityCapsEnabled()) {
return;
}
EntityCapsManager.addCapsExtensionInfo(stanza.getFrom(), CapsExtension.from(stanza));
}
}, PRESENCES_WITH_CAPS);
Roster.getInstanceFor(xMPPConnection).addPresenceEventListener(new AbstractPresenceEventListener() {
@Override
public void presenceUnavailable(FullJid fullJid, Presence presence) {
EntityCapsManager.JID_TO_NODEVER_CACHE.remove(fullJid);
}
});
xMPPConnection.addPacketSendingListener(new StanzaListener() {
@Override
public void processStanza(Stanza stanza) {
EntityCapsManager.this.presenceSend = (Presence) stanza;
}
}, PresenceTypeFilter.OUTGOING_PRESENCE_BROADCAST);
xMPPConnection.addPacketInterceptor(new StanzaListener() {
@Override
public void processStanza(Stanza stanza) {
if (!EntityCapsManager.this.entityCapsEnabled) {
stanza.removeExtension("c", "http://jabber.org/protocol/caps");
} else {
CapsVersionAndHash capsVersionAndHash = EntityCapsManager.this.getCapsVersionAndHash();
stanza.overrideExtension(new CapsExtension(EntityCapsManager.this.entityNode, capsVersionAndHash.version, capsVersionAndHash.hash));
}
}
}, PresenceTypeFilter.AVAILABLE);
instanceFor.setEntityCapsManager(this);
}
public static void addCapsExtensionInfo(Jid jid, CapsExtension capsExtension) {
String hash = capsExtension.getHash();
Locale locale = Locale.US;
if (!SUPPORTED_HASHES.containsKey(hash.toUpperCase(locale))) {
return;
}
String lowerCase = hash.toLowerCase(locale);
JID_TO_NODEVER_CACHE.put(jid, new NodeVerHash(capsExtension.getNode(), capsExtension.getVer(), lowerCase));
}
public static void addDiscoverInfoByNode(String str, DiscoverInfo discoverInfo) {
CAPS_CACHE.put(str, discoverInfo);
EntityCapsPersistentCache entityCapsPersistentCache = persistentCache;
if (entityCapsPersistentCache != null) {
entityCapsPersistentCache.addDiscoverInfoByNodePersistent(str, discoverInfo);
}
}
public static void clearMemoryCache() {
JID_TO_NODEVER_CACHE.clear();
CAPS_CACHE.clear();
}
private static void formFieldValuesToCaps(List<String> list, StringBuilder sb2) {
TreeSet treeSet = new TreeSet();
treeSet.addAll(list);
Iterator it = treeSet.iterator();
while (it.hasNext()) {
sb2.append((String) it.next());
sb2.append('<');
}
}
protected static CapsVersionAndHash generateVerificationString(DiscoverInfo discoverInfo) {
return generateVerificationString(discoverInfo, null);
}
public static DiscoverInfo getDiscoverInfoByUser(Jid jid) {
NodeVerHash lookup = JID_TO_NODEVER_CACHE.lookup(jid);
if (lookup == null) {
return null;
}
return getDiscoveryInfoByNodeVer(lookup.nodeVer);
}
public static DiscoverInfo getDiscoveryInfoByNodeVer(String str) {
EntityCapsPersistentCache entityCapsPersistentCache;
LruCache<String, DiscoverInfo> lruCache = CAPS_CACHE;
DiscoverInfo lookup = lruCache.lookup(str);
if (lookup == null && (entityCapsPersistentCache = persistentCache) != null && (lookup = entityCapsPersistentCache.lookup(str)) != null) {
lruCache.put(str, lookup);
}
if (lookup != null) {
return new DiscoverInfo(lookup);
}
return lookup;
}
public static synchronized EntityCapsManager getInstanceFor(XMPPConnection xMPPConnection) {
EntityCapsManager entityCapsManager;
synchronized (EntityCapsManager.class) {
if (SUPPORTED_HASHES.size() > 0) {
entityCapsManager = instances.get(xMPPConnection);
if (entityCapsManager == null) {
entityCapsManager = new EntityCapsManager(xMPPConnection);
}
} else {
throw new IllegalStateException("No supported hashes for EntityCapsManager");
}
}
return entityCapsManager;
}
public static NodeVerHash getNodeVerHashByJid(Jid jid) {
return JID_TO_NODEVER_CACHE.lookup(jid);
}
public static String getNodeVersionByJid(Jid jid) {
NodeVerHash lookup = JID_TO_NODEVER_CACHE.lookup(jid);
if (lookup != null) {
return lookup.nodeVer;
}
return null;
}
public static void removeUserCapsNode(String str) {
JID_TO_NODEVER_CACHE.remove(str);
}
public static void setDefaultEntityNode(String str) {
DEFAULT_ENTITY_NODE = str;
}
public static void setMaxsCacheSizes(int i10, int i11) {
JID_TO_NODEVER_CACHE.setMaxCacheSize(i10);
CAPS_CACHE.setMaxCacheSize(i11);
}
public static void setPersistentCache(EntityCapsPersistentCache entityCapsPersistentCache) {
persistentCache = entityCapsPersistentCache;
}
public static boolean verifyDiscoverInfoVersion(String str, String str2, DiscoverInfo discoverInfo) {
if (discoverInfo.containsDuplicateIdentities() || discoverInfo.containsDuplicateFeatures() || verifyPacketExtensions(discoverInfo) || !str.equals(generateVerificationString(discoverInfo, str2).version)) {
return false;
}
return true;
}
protected static boolean verifyPacketExtensions(DiscoverInfo discoverInfo) {
LinkedList linkedList = new LinkedList();
for (ExtensionElement extensionElement : discoverInfo.getExtensions()) {
if (extensionElement.getNamespace().equals("jabber:x:data")) {
for (FormField formField : ((DataForm) extensionElement).getFields()) {
if (formField.getVariable().equals(FormField.FORM_TYPE)) {
Iterator it = linkedList.iterator();
while (it.hasNext()) {
if (formField.equals((FormField) it.next())) {
return true;
}
}
linkedList.add(formField);
}
}
}
}
return false;
}
public boolean areEntityCapsSupported(Jid jid) throws SmackException.NoResponseException, XMPPException.XMPPErrorException, SmackException.NotConnectedException, InterruptedException {
return this.sdm.supportsFeature(jid, "http://jabber.org/protocol/caps");
}
public boolean areEntityCapsSupportedByServer() throws SmackException.NoResponseException, XMPPException.XMPPErrorException, SmackException.NotConnectedException, InterruptedException {
return areEntityCapsSupported(connection().getXMPPServiceDomain());
}
public synchronized void disableEntityCaps() {
this.entityCapsEnabled = false;
this.sdm.removeFeature("http://jabber.org/protocol/caps");
}
public synchronized void enableEntityCaps() {
this.sdm.addFeature("http://jabber.org/protocol/caps");
updateLocalEntityCaps();
this.entityCapsEnabled = true;
}
public boolean entityCapsEnabled() {
return this.entityCapsEnabled;
}
public CapsVersionAndHash getCapsVersionAndHash() {
return this.currentCapsVersion;
}
public String getLocalNodeVer() {
CapsVersionAndHash capsVersionAndHash = getCapsVersionAndHash();
if (capsVersionAndHash == null) {
return null;
}
return this.entityNode + '#' + capsVersionAndHash.version;
}
public void setEntityNode(String str) {
this.entityNode = str;
updateLocalEntityCaps();
}
public void updateLocalEntityCaps() {
XMPPConnection connection = connection();
DiscoverInfo discoverInfo = new DiscoverInfo();
discoverInfo.setType(IQ.Type.result);
this.sdm.addDiscoverInfoTo(discoverInfo);
this.currentCapsVersion = generateVerificationString(discoverInfo);
String localNodeVer = getLocalNodeVer();
discoverInfo.setNode(localNodeVer);
addDiscoverInfoByNode(localNodeVer, discoverInfo);
if (this.lastLocalCapsVersions.size() > 10) {
CapsVersionAndHash poll = this.lastLocalCapsVersions.poll();
this.sdm.removeNodeInformationProvider(this.entityNode + '#' + poll.version);
}
this.lastLocalCapsVersions.add(this.currentCapsVersion);
if (connection != null) {
JID_TO_NODEVER_CACHE.put(connection.getUser(), new NodeVerHash(this.entityNode, this.currentCapsVersion));
}
final LinkedList linkedList = new LinkedList(ServiceDiscoveryManager.getInstanceFor(connection).getIdentities());
this.sdm.setNodeInformationProvider(localNodeVer, new AbstractNodeInformationProvider() {
List<String> features;
List<ExtensionElement> packetExtensions;
{
this.features = EntityCapsManager.this.sdm.getFeatures();
this.packetExtensions = EntityCapsManager.this.sdm.getExtendedInfoAsList();
}
@Override
public List<String> getNodeFeatures() {
return this.features;
}
@Override
public List<DiscoverInfo.Identity> getNodeIdentities() {
return linkedList;
}
@Override
public List<ExtensionElement> getNodePacketExtensions() {
return this.packetExtensions;
}
});
if (connection != null && connection.isAuthenticated() && this.presenceSend != null) {
try {
connection.sendStanza(this.presenceSend.cloneWithNewId());
} catch (InterruptedException | SmackException.NotConnectedException e10) {
LOGGER.log(Level.WARNING, "Could could not update presence with caps info", e10);
}
}
}
protected static CapsVersionAndHash generateVerificationString(DiscoverInfo discoverInfo, String str) {
byte[] digest;
if (str == null) {
str = "SHA-1";
}
Map<String, MessageDigest> map = SUPPORTED_HASHES;
Locale locale = Locale.US;
MessageDigest messageDigest = map.get(str.toUpperCase(locale));
FormField formField = null;
if (messageDigest == null) {
return null;
}
String lowerCase = str.toLowerCase(locale);
DataForm from = DataForm.from(discoverInfo);
StringBuilder sb2 = new StringBuilder();
TreeSet<DiscoverInfo.Identity> treeSet = new TreeSet();
treeSet.addAll(discoverInfo.getIdentities());
for (DiscoverInfo.Identity identity : treeSet) {
sb2.append(identity.getCategory());
sb2.append('/');
sb2.append(identity.getType());
sb2.append('/');
sb2.append(identity.getLanguage() == null ? "" : identity.getLanguage());
sb2.append('/');
sb2.append(identity.getName() == null ? "" : identity.getName());
sb2.append('<');
}
TreeSet treeSet2 = new TreeSet();
Iterator<DiscoverInfo.Feature> it = discoverInfo.getFeatures().iterator();
while (it.hasNext()) {
treeSet2.add(it.next().getVar());
}
Iterator it2 = treeSet2.iterator();
while (it2.hasNext()) {
sb2.append((String) it2.next());
sb2.append('<');
}
if (from != null && from.hasHiddenFormTypeField()) {
synchronized (from) {
TreeSet<FormField> treeSet3 = new TreeSet(new Comparator<FormField>() {
@Override
public int compare(FormField formField2, FormField formField3) {
return formField2.getVariable().compareTo(formField3.getVariable());
}
});
for (FormField formField2 : from.getFields()) {
if (formField2.getVariable().equals(FormField.FORM_TYPE)) {
formField = formField2;
} else {
treeSet3.add(formField2);
}
}
if (formField != null) {
formFieldValuesToCaps(formField.getValues(), sb2);
}
for (FormField formField3 : treeSet3) {
sb2.append(formField3.getVariable());
sb2.append('<');
formFieldValuesToCaps(formField3.getValues(), sb2);
}
}
}
try {
byte[] bytes = sb2.toString().getBytes("UTF-8");
synchronized (messageDigest) {
digest = messageDigest.digest(bytes);
}
return new CapsVersionAndHash(Base64.encodeToString(digest), lowerCase);
} catch (UnsupportedEncodingException e10) {
throw new AssertionError(e10);
}
}
}