aboutsummaryrefslogtreecommitdiffstats
path: root/src/de/gultsch/chat/xmpp/XmppConnection.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/de/gultsch/chat/xmpp/XmppConnection.java')
-rw-r--r--src/de/gultsch/chat/xmpp/XmppConnection.java446
1 files changed, 0 insertions, 446 deletions
diff --git a/src/de/gultsch/chat/xmpp/XmppConnection.java b/src/de/gultsch/chat/xmpp/XmppConnection.java
deleted file mode 100644
index 1b9aa0c3..00000000
--- a/src/de/gultsch/chat/xmpp/XmppConnection.java
+++ /dev/null
@@ -1,446 +0,0 @@
-package de.gultsch.chat.xmpp;
-
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
-import java.math.BigInteger;
-import java.net.Socket;
-import java.net.UnknownHostException;
-import java.security.SecureRandom;
-import java.util.HashSet;
-import java.util.Hashtable;
-import java.util.List;
-
-import javax.net.ssl.SSLSocket;
-import javax.net.ssl.SSLSocketFactory;
-
-import org.xmlpull.v1.XmlPullParserException;
-
-import android.os.Bundle;
-import android.os.PowerManager;
-import android.util.Log;
-import de.gultsch.chat.entities.Account;
-import de.gultsch.chat.utils.DNSHelper;
-import de.gultsch.chat.utils.SASL;
-import de.gultsch.chat.xml.Element;
-import de.gultsch.chat.xml.Tag;
-import de.gultsch.chat.xml.XmlReader;
-import de.gultsch.chat.xml.TagWriter;
-
-public class XmppConnection implements Runnable {
-
- protected Account account;
- private static final String LOGTAG = "xmppService";
-
- private PowerManager.WakeLock wakeLock;
-
- private SecureRandom random = new SecureRandom();
-
- private Socket socket;
- private XmlReader tagReader;
- private TagWriter tagWriter;
-
- private boolean isTlsEncrypted = false;
- private boolean isAuthenticated = false;
- // private boolean shouldUseTLS = false;
- private boolean shouldConnect = true;
- private boolean shouldBind = true;
- private boolean shouldAuthenticate = true;
- private Element streamFeatures;
- private HashSet<String> discoFeatures = new HashSet<String>();
-
- private static final int PACKET_IQ = 0;
- private static final int PACKET_MESSAGE = 1;
- private static final int PACKET_PRESENCE = 2;
-
- private Hashtable<String, OnIqPacketReceived> iqPacketCallbacks = new Hashtable<String, OnIqPacketReceived>();
- private OnPresencePacketReceived presenceListener = null;
- private OnIqPacketReceived unregisteredIqListener = null;
- private OnMessagePacketReceived messageListener = null;
- private OnStatusChanged statusListener = null;
-
- public XmppConnection(Account account, PowerManager pm) {
- this.account = account;
- wakeLock = pm.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK,
- "XmppConnection");
- tagReader = new XmlReader(wakeLock);
- tagWriter = new TagWriter();
- }
-
- protected void connect() {
- try {
- Bundle namePort = DNSHelper.getSRVRecord(account.getServer());
- String srvRecordServer = namePort.getString("name");
- int srvRecordPort = namePort.getInt("port");
- if (srvRecordServer != null) {
- Log.d(LOGTAG, account.getJid() + ": using values from dns "
- + srvRecordServer + ":" + srvRecordPort);
- socket = new Socket(srvRecordServer, srvRecordPort);
- } else {
- socket = new Socket(account.getServer(), 5222);
- }
- OutputStream out = socket.getOutputStream();
- tagWriter.setOutputStream(out);
- InputStream in = socket.getInputStream();
- tagReader.setInputStream(in);
- tagWriter.beginDocument();
- sendStartStream();
- Tag nextTag;
- while ((nextTag = tagReader.readTag()) != null) {
- if (nextTag.isStart("stream")) {
- processStream(nextTag);
- break;
- } else {
- Log.d(LOGTAG, "found unexpected tag: " + nextTag.getName());
- return;
- }
- }
- if (socket.isConnected()) {
- socket.close();
- }
- } catch (UnknownHostException e) {
- account.setStatus(Account.STATUS_SERVER_NOT_FOUND);
- if (statusListener != null) {
- statusListener.onStatusChanged(account);
- }
- return;
- } catch (IOException e) {
- Log.d(LOGTAG, "bla " + e.getMessage());
- if (shouldConnect) {
- Log.d(LOGTAG, account.getJid() + ": connection lost");
- account.setStatus(Account.STATUS_OFFLINE);
- if (statusListener != null) {
- statusListener.onStatusChanged(account);
- }
- }
- } catch (XmlPullParserException e) {
- Log.d(LOGTAG, "xml exception " + e.getMessage());
- return;
- }
-
- }
-
- @Override
- public void run() {
- shouldConnect = true;
- while (shouldConnect) {
- connect();
- try {
- if (shouldConnect) {
- Thread.sleep(30000);
- }
- } catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- }
- Log.d(LOGTAG, "end run");
- }
-
- private void processStream(Tag currentTag) throws XmlPullParserException,
- IOException {
- Tag nextTag = tagReader.readTag();
- while ((nextTag != null) && (!nextTag.isEnd("stream"))) {
- if (nextTag.isStart("error")) {
- processStreamError(nextTag);
- } else if (nextTag.isStart("features")) {
- processStreamFeatures(nextTag);
- } else if (nextTag.isStart("proceed")) {
- switchOverToTls(nextTag);
- } else if (nextTag.isStart("success")) {
- isAuthenticated = true;
- Log.d(LOGTAG, account.getJid()
- + ": read success tag in stream. reset again");
- tagReader.readTag();
- tagReader.reset();
- sendStartStream();
- processStream(tagReader.readTag());
- break;
- } else if (nextTag.isStart("failure")) {
- Element failure = tagReader.readElement(nextTag);
- Log.d(LOGTAG, "read failure element" + failure.toString());
- account.setStatus(Account.STATUS_UNAUTHORIZED);
- if (statusListener != null) {
- statusListener.onStatusChanged(account);
- }
- tagWriter.writeTag(Tag.end("stream"));
- } else if (nextTag.isStart("iq")) {
- processIq(nextTag);
- } else if (nextTag.isStart("message")) {
- processMessage(nextTag);
- } else if (nextTag.isStart("presence")) {
- processPresence(nextTag);
- } else {
- Log.d(LOGTAG, "found unexpected tag: " + nextTag.getName()
- + " as child of " + currentTag.getName());
- }
- nextTag = tagReader.readTag();
- }
- if (account.getStatus() == Account.STATUS_ONLINE) {
- account.setStatus(Account.STATUS_OFFLINE);
- if (statusListener != null) {
- statusListener.onStatusChanged(account);
- }
- }
- }
-
- private Element processPacket(Tag currentTag, int packetType)
- throws XmlPullParserException, IOException {
- Element element;
- switch (packetType) {
- case PACKET_IQ:
- element = new IqPacket();
- break;
- case PACKET_MESSAGE:
- element = new MessagePacket();
- break;
- case PACKET_PRESENCE:
- element = new PresencePacket();
- break;
- default:
- return null;
- }
- element.setAttributes(currentTag.getAttributes());
- Tag nextTag = tagReader.readTag();
- while (!nextTag.isEnd(element.getName())) {
- if (!nextTag.isNo()) {
- Element child = tagReader.readElement(nextTag);
- element.addChild(child);
- }
- nextTag = tagReader.readTag();
- }
- return element;
- }
-
- private IqPacket processIq(Tag currentTag) throws XmlPullParserException,
- IOException {
- IqPacket packet = (IqPacket) processPacket(currentTag, PACKET_IQ);
- if (iqPacketCallbacks.containsKey(packet.getId())) {
- iqPacketCallbacks.get(packet.getId()).onIqPacketReceived(account,
- packet);
- iqPacketCallbacks.remove(packet.getId());
- } else if (this.unregisteredIqListener != null) {
- this.unregisteredIqListener.onIqPacketReceived(account, packet);
- }
- return packet;
- }
-
- private void processMessage(Tag currentTag) throws XmlPullParserException,
- IOException {
- MessagePacket packet = (MessagePacket) processPacket(currentTag,
- PACKET_MESSAGE);
- if (this.messageListener != null) {
- this.messageListener.onMessagePacketReceived(account, packet);
- }
- }
-
- private void processPresence(Tag currentTag) throws XmlPullParserException,
- IOException {
- PresencePacket packet = (PresencePacket) processPacket(currentTag,
- PACKET_PRESENCE);
- if (this.presenceListener != null) {
- this.presenceListener.onPresencePacketReceived(account, packet);
- }
- }
-
- private void sendStartTLS() {
- Tag startTLS = Tag.empty("starttls");
- startTLS.setAttribute("xmlns", "urn:ietf:params:xml:ns:xmpp-tls");
- Log.d(LOGTAG, account.getJid() + ": sending starttls");
- tagWriter.writeTag(startTLS);
- }
-
- private void switchOverToTls(Tag currentTag) throws XmlPullParserException,
- IOException {
- Tag nextTag = tagReader.readTag(); // should be proceed end tag
- Log.d(LOGTAG, account.getJid() + ": now switch to ssl");
- SSLSocket sslSocket;
- try {
- sslSocket = (SSLSocket) ((SSLSocketFactory) SSLSocketFactory
- .getDefault()).createSocket(socket, socket.getInetAddress()
- .getHostAddress(), socket.getPort(), true);
- tagReader.setInputStream(sslSocket.getInputStream());
- Log.d(LOGTAG, "reset inputstream");
- tagWriter.setOutputStream(sslSocket.getOutputStream());
- Log.d(LOGTAG, "switch over seemed to work");
- isTlsEncrypted = true;
- sendStartStream();
- processStream(tagReader.readTag());
- sslSocket.close();
- } catch (IOException e) {
- Log.d(LOGTAG,
- account.getJid() + ": error on ssl '" + e.getMessage()
- + "'");
- }
- }
-
- private void sendSaslAuth() throws IOException, XmlPullParserException {
- String saslString = SASL.plain(account.getUsername(),
- account.getPassword());
- Element auth = new Element("auth");
- auth.setAttribute("xmlns", "urn:ietf:params:xml:ns:xmpp-sasl");
- auth.setAttribute("mechanism", "PLAIN");
- auth.setContent(saslString);
- Log.d(LOGTAG, account.getJid() + ": sending sasl " + auth.toString());
- tagWriter.writeElement(auth);
- }
-
- private void processStreamFeatures(Tag currentTag)
- throws XmlPullParserException, IOException {
- this.streamFeatures = tagReader.readElement(currentTag);
- Log.d(LOGTAG, account.getJid() + ": process stream features "
- + streamFeatures);
- if (this.streamFeatures.hasChild("starttls")
- && account.isOptionSet(Account.OPTION_USETLS)) {
- sendStartTLS();
- } else if (this.streamFeatures.hasChild("mechanisms")
- && shouldAuthenticate) {
- sendSaslAuth();
- }
- if (this.streamFeatures.hasChild("bind") && shouldBind) {
- sendBindRequest();
- if (this.streamFeatures.hasChild("session")) {
- IqPacket startSession = new IqPacket(IqPacket.TYPE_SET);
- Element session = new Element("session");
- session.setAttribute("xmlns",
- "urn:ietf:params:xml:ns:xmpp-session");
- session.setContent("");
- startSession.addChild(session);
- sendIqPacket(startSession, null);
- tagWriter.writeElement(startSession);
- }
- Element presence = new Element("presence");
-
- tagWriter.writeElement(presence);
- }
- }
-
- private void sendBindRequest() throws IOException {
- IqPacket iq = new IqPacket(IqPacket.TYPE_SET);
- Element bind = new Element("bind");
- bind.setAttribute("xmlns", "urn:ietf:params:xml:ns:xmpp-bind");
- iq.addChild(bind);
- this.sendIqPacket(iq, new OnIqPacketReceived() {
- @Override
- public void onIqPacketReceived(Account account, IqPacket packet) {
- String resource = packet.findChild("bind").findChild("jid")
- .getContent().split("/")[1];
- account.setResource(resource);
- account.setStatus(Account.STATUS_ONLINE);
- if (statusListener != null) {
- statusListener.onStatusChanged(account);
- }
- sendServiceDiscovery();
- }
- });
- }
-
- private void sendServiceDiscovery() {
- IqPacket iq = new IqPacket(IqPacket.TYPE_GET);
- iq.setAttribute("to", account.getServer());
- Element query = new Element("query");
- query.setAttribute("xmlns", "http://jabber.org/protocol/disco#info");
- iq.addChild(query);
- this.sendIqPacket(iq, new OnIqPacketReceived() {
-
- @Override
- public void onIqPacketReceived(Account account, IqPacket packet) {
- if (packet.hasChild("query")) {
- List<Element> elements = packet.findChild("query")
- .getChildren();
- for (int i = 0; i < elements.size(); ++i) {
- if (elements.get(i).getName().equals("feature")) {
- discoFeatures.add(elements.get(i).getAttribute(
- "var"));
- }
- }
- }
- if (discoFeatures.contains("urn:xmpp:carbons:2")) {
- sendEnableCarbons();
- }
- }
- });
- }
-
- private void sendEnableCarbons() {
- Log.d(LOGTAG,account.getJid()+": enable carbons");
- IqPacket iq = new IqPacket(IqPacket.TYPE_SET);
- Element enable = new Element("enable");
- enable.setAttribute("xmlns", "urn:xmpp:carbons:2");
- iq.addChild(enable);
- this.sendIqPacket(iq, new OnIqPacketReceived() {
-
- @Override
- public void onIqPacketReceived(Account account, IqPacket packet) {
- if (!packet.hasChild("error")) {
- Log.d(LOGTAG,account.getJid()+": successfully enabled carbons");
- } else {
- Log.d(LOGTAG,account.getJid()+": error enableing carbons "+packet.toString());
- }
- }
- });
- }
-
- private void processStreamError(Tag currentTag) {
- Log.d(LOGTAG, "processStreamError");
- }
-
- private void sendStartStream() {
- Tag stream = Tag.start("stream:stream");
- stream.setAttribute("from", account.getJid());
- stream.setAttribute("to", account.getServer());
- stream.setAttribute("version", "1.0");
- stream.setAttribute("xml:lang", "en");
- stream.setAttribute("xmlns", "jabber:client");
- stream.setAttribute("xmlns:stream", "http://etherx.jabber.org/streams");
- tagWriter.writeTag(stream);
- }
-
- private String nextRandomId() {
- return new BigInteger(50, random).toString(32);
- }
-
- public void sendIqPacket(IqPacket packet, OnIqPacketReceived callback) {
- String id = nextRandomId();
- packet.setAttribute("id", id);
- tagWriter.writeElement(packet);
- if (callback != null) {
- iqPacketCallbacks.put(id, callback);
- }
- //Log.d(LOGTAG, account.getJid() + ": sending: " + packet.toString());
- }
-
- public void sendMessagePacket(MessagePacket packet) {
- Log.d(LOGTAG,"sending message packet "+packet.toString());
- tagWriter.writeElement(packet);
- }
-
- public void sendPresencePacket(PresencePacket packet) {
- tagWriter.writeElement(packet);
- Log.d(LOGTAG, account.getJid() + ": sending: " + packet.toString());
- }
-
- public void setOnMessagePacketReceivedListener(
- OnMessagePacketReceived listener) {
- this.messageListener = listener;
- }
-
- public void setOnUnregisteredIqPacketReceivedListener(
- OnIqPacketReceived listener) {
- this.unregisteredIqListener = listener;
- }
-
- public void setOnPresencePacketReceivedListener(
- OnPresencePacketReceived listener) {
- this.presenceListener = listener;
- }
-
- public void setOnStatusChangedListener(OnStatusChanged listener) {
- this.statusListener = listener;
- }
-
- public void disconnect() {
- shouldConnect = false;
- tagWriter.writeTag(Tag.end("stream:stream"));
- }
-}
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-01 22:57:06 +0000