Unit test for telemetry

androidgcs/tests/org/openpilot/uavtalk/TelemetryMonitorTest.java

@@ -0,0 +1,64 @@
+package org.openpilot.uavtalk;
+
+import static org.junit.Assert.*;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.net.DatagramSocket;
+import java.net.InetAddress;
+import java.net.Socket;
+import java.nio.ByteBuffer;
+import java.util.Observable;
+import java.util.Observer;
+
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.openpilot.uavtalk.uavobjects.UAVObjectsInitialize;
+import org.openpilot.uavtalk.UAVTalk;
+
+
+public class TelemetryMonitorTest {
+	
+	static UAVObjectManager objMngr;
+	static UAVTalk talk;
+	static final String IP_ADDRDESS = new String("127.0.0.1");
+	static final int PORT_NUM = 7777;
+	static Socket connection = null;
+	boolean succeed = false;
+
+	@Test
+	public void testTelemetry() throws Exception {
+		objMngr = new UAVObjectManager();
+		UAVObjectsInitialize.register(objMngr);
+		talk = null;
+		try{
+			InetAddress ip = InetAddress.getByName(IP_ADDRDESS);
+			connection = new Socket(ip, PORT_NUM);
+		} catch (Exception e) {
+			e.printStackTrace();
+			fail("Couldn't connect to test platform");
+		}
+		
+		try {
+			talk = new UAVTalk(connection.getInputStream(), connection.getOutputStream(), objMngr);
+		} catch (IOException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+			fail("Couldn't construct UAVTalk object");
+		}
+		
+		Thread inputStream = talk.getInputProcessThread();
+		inputStream.start();
+		
+		Telemetry tel = new Telemetry(talk, objMngr);
+		TelemetryMonitor mon = new TelemetryMonitor(objMngr,tel);
+		
+		Thread.sleep(10000);
+		
+		System.out.println("Done");
+	}
+
+
+}