CryptoMessage v1.3.2版本的 MD5 值为:66c611ce56a11450659dc23697562928
以下内容为反编译后的 FileTransferManager.java 源代码,内容仅作参考
package org.jivesoftware.smackx.filetransfer;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.WeakHashMap;
import java.util.concurrent.CopyOnWriteArrayList;
import org.jivesoftware.smack.Manager;
import org.jivesoftware.smack.SmackException;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.iqrequest.AbstractIqRequestHandler;
import org.jivesoftware.smack.iqrequest.IQRequestHandler;
import org.jivesoftware.smack.packet.IQ;
import org.jivesoftware.smack.packet.StanzaError;
import org.jivesoftware.smackx.si.packet.StreamInitiation;
import org.jxmpp.jid.EntityFullJid;
public final class FileTransferManager extends Manager {
private static final Map<XMPPConnection, FileTransferManager> INSTANCES = new WeakHashMap();
private final FileTransferNegotiator fileTransferNegotiator;
private final List<FileTransferListener> listeners;
private FileTransferManager(XMPPConnection xMPPConnection) {
super(xMPPConnection);
this.listeners = new CopyOnWriteArrayList();
this.fileTransferNegotiator = FileTransferNegotiator.getInstanceFor(xMPPConnection);
xMPPConnection.registerIQRequestHandler(new AbstractIqRequestHandler(StreamInitiation.ELEMENT, "http://jabber.org/protocol/si", IQ.Type.set, IQRequestHandler.Mode.async) {
@Override
public IQ handleIQRequest(IQ iq) {
FileTransferRequest fileTransferRequest = new FileTransferRequest(FileTransferManager.this, (StreamInitiation) iq);
Iterator it = FileTransferManager.this.listeners.iterator();
while (it.hasNext()) {
((FileTransferListener) it.next()).fileTransferRequest(fileTransferRequest);
}
return null;
}
});
}
public static synchronized FileTransferManager getInstanceFor(XMPPConnection xMPPConnection) {
FileTransferManager fileTransferManager;
synchronized (FileTransferManager.class) {
Map<XMPPConnection, FileTransferManager> map = INSTANCES;
fileTransferManager = map.get(xMPPConnection);
if (fileTransferManager == null) {
fileTransferManager = new FileTransferManager(xMPPConnection);
map.put(xMPPConnection, fileTransferManager);
}
}
return fileTransferManager;
}
public void addFileTransferListener(FileTransferListener fileTransferListener) {
this.listeners.add(fileTransferListener);
}
public void removeFileTransferListener(FileTransferListener fileTransferListener) {
this.listeners.remove(fileTransferListener);
}
public OutgoingFileTransfer createOutgoingFileTransfer(EntityFullJid entityFullJid) {
if (entityFullJid == null) {
throw new IllegalArgumentException("userID was null");
}
return new OutgoingFileTransfer(connection().getUser(), entityFullJid, FileTransferNegotiator.getNextStreamID(), this.fileTransferNegotiator);
}
public IncomingFileTransfer createIncomingFileTransfer(FileTransferRequest fileTransferRequest) {
Objects.requireNonNull(fileTransferRequest, "ReceiveRequest cannot be null");
IncomingFileTransfer incomingFileTransfer = new IncomingFileTransfer(fileTransferRequest, this.fileTransferNegotiator);
incomingFileTransfer.setFileInfo(fileTransferRequest.getFileName(), fileTransferRequest.getFileSize());
return incomingFileTransfer;
}
public void rejectIncomingFileTransfer(FileTransferRequest fileTransferRequest) throws SmackException.NotConnectedException, InterruptedException {
connection().sendStanza(IQ.createErrorResponse(fileTransferRequest.getStreamInitiation(), StanzaError.getBuilder(StanzaError.Condition.forbidden).build()));
}
}