package eu.siacs.conversations.xmpp.jingle; import java.math.BigInteger; import java.security.SecureRandom; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ConcurrentHashMap; import android.util.Log; import eu.siacs.conversations.entities.Account; import eu.siacs.conversations.entities.Message; import eu.siacs.conversations.services.XmppConnectionService; import eu.siacs.conversations.xml.Element; import eu.siacs.conversations.xmpp.OnIqPacketReceived; import eu.siacs.conversations.xmpp.jingle.stanzas.JinglePacket; import eu.siacs.conversations.xmpp.stanzas.IqPacket; public class JingleConnectionManager { private XmppConnectionService xmppConnectionService; private List connections = new ArrayList(); // make // concurrent private ConcurrentHashMap primaryCandidates = new ConcurrentHashMap(); private SecureRandom random = new SecureRandom(); public JingleConnectionManager(XmppConnectionService service) { this.xmppConnectionService = service; } public void deliverPacket(Account account, JinglePacket packet) { for (JingleConnection connection : connections) { if (connection.getAccountJid().equals(account.getJid()) && connection .getSessionId().equals(packet.getSessionId()) && connection .getCounterPart().equals(packet.getFrom())) { connection.deliverPacket(packet); return; } } Log.d("xmppService","delivering packet failed "+packet.toString()); } public JingleConnection createNewConnection(Message message) { JingleConnection connection = new JingleConnection(this); connection.init(message); connections.add(connection); return connection; } public JingleConnection createNewConnection(JinglePacket packet) { JingleConnection connection = new JingleConnection(this); connections.add(connection); return connection; } public XmppConnectionService getXmppConnectionService() { return this.xmppConnectionService; } public void getPrimaryCandidate(Account account, final OnPrimaryCandidateFound listener) { if (!this.primaryCandidates.containsKey(account.getJid())) { String xmlns = "http://jabber.org/protocol/bytestreams"; final String proxy = account.getXmppConnection() .findDiscoItemByFeature(xmlns); if (proxy != null) { IqPacket iq = new IqPacket(IqPacket.TYPE_GET); iq.setTo(proxy); iq.query(xmlns); account.getXmppConnection().sendIqPacket(iq, new OnIqPacketReceived() { @Override public void onIqPacketReceived(Account account, IqPacket packet) { Element streamhost = packet .query() .findChild("streamhost", "http://jabber.org/protocol/bytestreams"); if (streamhost != null) { Log.d("xmppService", "streamhost found " + streamhost.toString()); Element candidate = new Element("candidate"); candidate.setAttribute("cid", nextRandomId()); candidate.setAttribute("host", streamhost.getAttribute("host")); candidate.setAttribute("port", streamhost.getAttribute("port")); candidate.setAttribute("type", "proxy"); candidate.setAttribute("jid", proxy); candidate .setAttribute("priority", "655360"); primaryCandidates.put(account.getJid(), candidate); listener.onPrimaryCandidateFound(true, candidate); } else { listener.onPrimaryCandidateFound(false, null); } } }); } else { listener.onPrimaryCandidateFound(false, null); } } else { listener.onPrimaryCandidateFound(true, this.primaryCandidates.get(account.getJid())); } } public String nextRandomId() { return new BigInteger(50, random).toString(32); } }