From 5d14f1cc96a7ac749cdcba72a14d5f2825df37a9 Mon Sep 17 00:00:00 2001
From: Nathan Lasseter <nathan@4574.co.uk>
Date: Wed, 22 May 2013 17:23:10 +0100
Subject: Moved MqttCallback to new class. Added text boxes &
 connect/disconnect button.

---
 src/user4574/texttransport/Start.java | 81 +++++++++++++++++++++++++++--------
 1 file changed, 62 insertions(+), 19 deletions(-)

(limited to 'src/user4574/texttransport/Start.java')

diff --git a/src/user4574/texttransport/Start.java b/src/user4574/texttransport/Start.java
index 03ea032..127a4e8 100644
--- a/src/user4574/texttransport/Start.java
+++ b/src/user4574/texttransport/Start.java
@@ -1,41 +1,84 @@
 package user4574.texttransport;
 
-import org.eclipse.paho.client.mqttv3.MqttCallback;
 import org.eclipse.paho.client.mqttv3.MqttClient;
-import org.eclipse.paho.client.mqttv3.MqttDeliveryToken;
 import org.eclipse.paho.client.mqttv3.MqttException;
-import org.eclipse.paho.client.mqttv3.MqttMessage;
-import org.eclipse.paho.client.mqttv3.MqttTopic;
 
 import android.app.Activity;
 import android.os.Bundle;
 import android.telephony.SmsManager;
+import android.text.Editable;
+import android.text.TextWatcher;
+import android.view.View;
+import android.view.View.OnClickListener;
+import android.widget.Button;
+import android.widget.EditText;
+import android.widget.RadioGroup;
 
-public class Start extends Activity implements MqttCallback {
+public class Start extends Activity {
 	
 	public static MqttClient client;
 	private SmsManager sms = SmsManager.getDefault();
 	
+	private Button conn;
+	private EditText ent;
+	private EditText port;
+	private RadioGroup rg;
+	private String uri = "";
+	
 	protected void onCreate(Bundle savedInstanceState) {
 		super.onCreate(savedInstanceState);
+		setContentView(R.layout.start);
 		
-		try {
-			client = new MqttClient("tcp://192.168.0.222:1883", MqttClient.generateClientId(), new AndroidPersistence());
-			client.setCallback(this);
-			client.connect();
-			client.subscribe("/texttransport/+/send");
-		} catch (MqttException e) {
-			e.printStackTrace();
-		}
+		conn = (Button) findViewById(R.id.connectbutton);
+		conn.setEnabled(false);
+		conn.setOnClickListener(new ConnectListener());
 		
-		setContentView(R.layout.start);
+		ent = (EditText) findViewById(R.id.uri);
+		ent.addTextChangedListener(new URIWatcher());
+		
+		port = (EditText) findViewById(R.id.port);
+		
+		rg = (RadioGroup) findViewById(R.id.protocol);
 	}
 	
-	public void connectionLost(Throwable exception) {}
-	public void deliveryComplete(MqttDeliveryToken token) {}
-	public void messageArrived(MqttTopic topic, MqttMessage message) throws Exception {
-		String[] topicarr = topic.getName().split("/");
-		sms.sendTextMessage(topicarr[2], null, message.toString(), null, null);
+	class ConnectListener implements OnClickListener {
+		public void onClick(View arg0) {
+			if (client != null && client.isConnected()) {
+				try {
+					client.disconnect();
+					ent.setEnabled(true);
+					conn.setText(R.string.connect);
+				} catch (MqttException e) {
+					e.printStackTrace();
+				}
+			} else if (!uri.equals("")) {
+				String server = (rg.getCheckedRadioButtonId() == R.id.ssl) ? "ssl" : "tcp";
+				server += "://" + uri;
+				if(!port.getText().toString().equals(""))
+					server += ":" + port.getText().toString();
+				try {
+					client = new MqttClient(server, MqttClient.generateClientId(), new AndroidPersistence());
+					client.setCallback(new MqttMsgCallback(sms));
+					client.connect();
+					client.subscribe("/texttransport/+/send");
+					ent.setEnabled(false);
+					conn.setText(R.string.disconnect);
+				} catch (MqttException e) {
+					e.printStackTrace();
+				}
+			}
+		}
 	}
 	
+	class URIWatcher implements TextWatcher {
+		public void beforeTextChanged(CharSequence s, int start, int count, int after) {}
+		public void onTextChanged(CharSequence s, int start, int before, int count) {}
+		public void afterTextChanged(Editable s) {
+			uri = s.toString();
+			if (uri.equals(""))
+				conn.setEnabled(false);
+			else
+				conn.setEnabled(true);
+		}
+	}
 }
\ No newline at end of file
-- 
cgit v1.2.1