Implemented TracingSyncActivity

Fixed TracingSyncService

AndroidManifest.xml

@@ -47,7 +47,6 @@
             android:screenOrientation="portrait" >
            	<intent-filter>
                 <action android:name="android.intent.action.MAIN" />
-
                 <category android:name="android.intent.category.LAUNCHER" />
             </intent-filter>
         </activity>
@@ -82,7 +81,7 @@
             android:label="@string/gui_playground" >
         </activity>
         <activity
-            android:name="de.tudarmstadt.informatik.hostage.sync.tracing.TracingSync"
+            android:name="de.tudarmstadt.informatik.hostage.sync.tracing.TracingSyncActivity"
             android:label="@string/gui_tracing"
             android:theme="@android:style/Theme.Dialog" >
         </activity>
@@ -112,6 +111,10 @@
             android:name="de.tudarmstadt.informatik.hostage.logging.Logger"
             android:exported="false" >
         </service>
+        <service
+            android:name="de.tudarmstadt.informatik.hostage.sync.tracing.TracingSyncService"
+            android:exported="false" >
+        </service>
 
         <provider
             android:name="de.tudarmstadt.informatik.hostage.provider.HostageContentProvider"

res/layout/activity_sync_central.xml

@@ -0,0 +1,17 @@
+<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
+    xmlns:tools="http://schemas.android.com/tools"
+    android:layout_width="match_parent"
+    android:layout_height="wrap_content"
+    android:orientation="vertical"
+    android:paddingBottom="@dimen/activity_vertical_margin"
+    android:paddingLeft="@dimen/activity_horizontal_margin"
+    android:paddingRight="@dimen/activity_horizontal_margin"
+    android:paddingTop="@dimen/activity_vertical_margin" >
+
+    <TextView
+        android:id="@+id/sync_central_text_view"
+        android:layout_width="wrap_content"
+        android:layout_height="wrap_content"
+        android:text="Uploading Records to" />
+
+</LinearLayout>

src/de/tudarmstadt/informatik/hostage/logging/AttackRecord.java

@@ -159,5 +159,13 @@ public class AttackRecord implements Parcelable, Serializable{
 	public void setExternalIP(String externalIP) {
 		this.externalIP = externalIP;
 	}
+	
+	//TEMP ZU TEST
+	@Override
+	public String toString(){
+		return String
+				.format("{ \"sensor\":{\"type\": \"Honeypot\", \"name\": \"HosTaGe\"}, \"type\": \"%s server access\", \"src\":{\"ip\": \"%s\", \"port\": %d}, \"dst\":{\"ip\": \"%s\", \"port\": %d} }",
+						getProtocol(), getRemoteIP(), getRemotePort(), getExternalIP(), getLocalPort());
+	}
 
 }

src/de/tudarmstadt/informatik/hostage/persistence/HostageDBOpenHelper.java

@@ -790,7 +790,7 @@ public class HostageDBOpenHelper extends SQLiteOpenHelper {
 		record.setLocalPort(Integer.parseInt(cursor.getString(4)));
 		record.setRemoteIP(cursor.getString(5));
 		record.setRemotePort(Integer.parseInt(cursor.getString(6)));
-		record.setBssid(cursor.getString(11));
+		record.setBssid(cursor.getString(7));
 
 		return record;
 	}

src/de/tudarmstadt/informatik/hostage/sync/nfc/NFCSync.java

@@ -49,9 +49,6 @@ public class NFCSync extends Activity implements CreateNdefMessageCallback, OnNd
 	TextView mInfoText;
 	private static final int MESSAGE_SENT = 1;
 
-
-
-	/** This handler receives a message from onNdefPushComplete */
 	private final Handler mHandler = new Handler() {
 		@Override
 		public void handleMessage(Message msg) {
@@ -63,6 +60,25 @@ public class NFCSync extends Activity implements CreateNdefMessageCallback, OnNd
 			}
 		}
 	};
+	
+	@Override
+	public void onCreate(Bundle savedInstanceState) {
+		super.onCreate(savedInstanceState);
+		setContentView(R.layout.activity_nfc);
+
+		mInfoText = (TextView) findViewById(R.id.nfc_text_view);
+		// Check for available NFC Adapter
+		mNfcAdapter = NfcAdapter.getDefaultAdapter(this);
+		if (mNfcAdapter == null) {
+			mInfoText.setText("NFC is not available on this device.");
+		} else {
+			mInfoText.setText("Hold phones together to synchronize.");
+			// Register callback to set NDEF message
+			mNfcAdapter.setNdefPushMessageCallback(this, this);
+			// Register callback to listen for message-sent success
+			mNfcAdapter.setOnNdefPushCompleteCallback(this, this);
+		}
+	}
 
 	/**
 	 * Implementation for the CreateNdefMessageCallback interface
@@ -84,25 +100,6 @@ public class NFCSync extends Activity implements CreateNdefMessageCallback, OnNd
 		return msg;
 	}
 
-	@Override
-	public void onCreate(Bundle savedInstanceState) {
-		super.onCreate(savedInstanceState);
-		setContentView(R.layout.activity_nfc);
-
-		mInfoText = (TextView) findViewById(R.id.nfc_text_view);
-		// Check for available NFC Adapter
-		mNfcAdapter = NfcAdapter.getDefaultAdapter(this);
-		if (mNfcAdapter == null) {
-			mInfoText.setText("NFC is not available on this device.");
-		} else {
-			mInfoText.setText("Hold phones together to synchronize.");
-			// Register callback to set NDEF message
-			mNfcAdapter.setNdefPushMessageCallback(this, this);
-			// Register callback to listen for message-sent success
-			mNfcAdapter.setOnNdefPushCompleteCallback(this, this);
-		}
-	}
-
 	/**
 	 * Implementation for the OnNdefPushCompleteCallback interface
 	 */

src/de/tudarmstadt/informatik/hostage/sync/tracing/TracingSyncActivity.java

@@ -1,7 +1,43 @@
 package de.tudarmstadt.informatik.hostage.sync.tracing;
 
+import de.tudarmstadt.informatik.hostage.R;
 import android.app.Activity;
+import android.content.Intent;
+import android.os.Bundle;
+import android.os.Handler;
+import android.widget.TextView;
 
-public class TracingSyncActivity extends Activity{
-	//TODO
+public class TracingSyncActivity extends Activity implements TracingSyncResultReciever.Receiver{
+	
+	TextView mInfoText;
+
+	@Override
+	public void onCreate(Bundle savedInstanceState) {
+		super.onCreate(savedInstanceState);
+		setContentView(R.layout.activity_nfc);
+		mInfoText = (TextView) findViewById(R.id.nfc_text_view);
+		mInfoText.setText("Uploading Records...");
+		
+		TracingSyncResultReciever mReceiver = new TracingSyncResultReciever(new Handler());
+        mReceiver.setReceiver(this);
+        
+		Intent intent = new Intent(this, TracingSyncService.class);
+		intent.setAction(TracingSyncService.ACTION_START_SYNC);
+		intent.putExtra(TracingSyncService.EXTRA_RECEIVER, mReceiver);
+		startService(intent);
+	}
+
+	@Override
+	public void onReceiveResult(int resultCode, Bundle resultData) {
+        switch (resultCode) {
+        case TracingSyncService.SYNC_COMPLETE:
+        	mInfoText.setText("Information is up to date!");
+            break;        
+        case TracingSyncService.RECORD_UPLOADED:      
+        	mInfoText.setText("Uploading Records...(" + resultData.getInt(TracingSyncService.UPLOAD_PROGRESS) + "/"+ resultData.getInt(TracingSyncService.UPLOAD_SIZE) + ")");
+        break;
+    }
+		
+	}	
+	
 }

src/de/tudarmstadt/informatik/hostage/sync/tracing/TracingSyncResultReciever.java

@@ -0,0 +1,28 @@
+package de.tudarmstadt.informatik.hostage.sync.tracing;
+
+import android.os.Bundle;
+import android.os.Handler;
+import android.os.ResultReceiver;
+ 
+public class TracingSyncResultReciever extends ResultReceiver {
+    private Receiver mReceiver;
+ 
+    public TracingSyncResultReciever(Handler handler) {
+        super(handler);
+    }
+ 
+    public void setReceiver(Receiver receiver) {
+        mReceiver = receiver;
+    }
+ 
+    public interface Receiver {
+        public void onReceiveResult(int resultCode, Bundle resultData);
+    }
+ 
+    @Override
+    protected void onReceiveResult(int resultCode, Bundle resultData) {
+        if (mReceiver != null) {
+            mReceiver.onReceiveResult(resultCode, resultData);
+        }
+    }
+}

src/de/tudarmstadt/informatik/hostage/sync/tracing/TracingSyncService.java

@@ -3,6 +3,7 @@ package de.tudarmstadt.informatik.hostage.sync.tracing;
 import java.security.KeyStore;
 import java.util.ArrayList;
 
+import org.apache.http.HttpResponse;
 import org.apache.http.HttpVersion;
 import org.apache.http.client.HttpClient;
 import org.apache.http.client.methods.HttpPost;
@@ -23,10 +24,11 @@ import android.app.IntentService;
 import android.content.Intent;
 import android.content.SharedPreferences;
 import android.content.SharedPreferences.Editor;
-import android.os.Handler;
+import android.os.Bundle;
+import android.os.ResultReceiver;
 import android.preference.PreferenceManager;
+import android.util.Log;
 import de.tudarmstadt.informatik.hostage.logging.AttackRecord;
-import de.tudarmstadt.informatik.hostage.logging.formatter.TraCINgFormatter;
 import de.tudarmstadt.informatik.hostage.net.MySSLSocketFactory;
 import de.tudarmstadt.informatik.hostage.persistence.HostageDBOpenHelper;
 
@@ -34,23 +36,33 @@ public class TracingSyncService extends IntentService{
 	
 	public static final String REMOTE_DEVICE = "de.tudarmstadt.informatik.hostage.REMOTE_DEVICE";
 	
+	public static final String ACTION_START_SYNC = "de.tudarmstadt.informatik.hostage.ACTION_START_SYNC";
+	public static final String EXTRA_RECEIVER = "de.tudarmstadt.informatik.hostage.EXTRA_HANDLER";
+	
+	public static final String UPLOAD_SIZE = "de.tudarmstadt.informatik.hostage.UPLOAD_SIZE";
+	public static final String UPLOAD_PROGRESS = "de.tudarmstadt.informatik.hostage.UPLOAD_PROGRESS";
+	
 	public static final int RECORD_UPLOADED = 0x00;
 	public static final int SYNC_COMPLETE = 0x01;
 	
 	
-	
 	private HttpClient httpClient;
-	private Handler mHandler;
+	private ResultReceiver receiver;
 	
 	HostageDBOpenHelper dbh;
 	
 	SharedPreferences pref;
 	Editor editor;
 
-	public TracingSyncService(Handler handler) {
-		super("TracingSyncService");
-		mHandler = handler;
-		httpClient = createHttpClient();
+	public TracingSyncService() {
+		super(TracingSyncService.class.getName());
+
+	}
+	
+
+	@Override
+	public void onCreate() {
+		super.onCreate();
 		pref = PreferenceManager.getDefaultSharedPreferences(this);
 		editor = pref.edit();
 		dbh = new HostageDBOpenHelper(this);
@@ -63,10 +75,19 @@ public class TracingSyncService extends IntentService{
 	 */
 	@Override
 	protected void onHandleIntent(Intent intent) {
-		//TODO Fallunterscheidung Intents		
-		uploadNewRecords();
-		getRemoteData();
-		dbh.clearSyncInfos();
+		if (intent != null) {
+			final String action = intent.getAction();
+			if (ACTION_START_SYNC.equals(action)) {
+				receiver = intent.getParcelableExtra(EXTRA_RECEIVER);
+				uploadNewRecords();
+				getRemoteData();
+				//TODO add: dbh.clearSyncInfos();
+				if(receiver != null){
+					receiver.send(SYNC_COMPLETE, null);
+				}
+			}
+
+		}	
 	}	
 	
 	
@@ -81,9 +102,16 @@ public class TracingSyncService extends IntentService{
 		int offset = 1;
 		for(AttackRecord record: recordList){
 			editor.putInt("LAST_UPLOADED_ATTACK_ID", lastUploadedAttackId + offset);
-			uploadSingleRecord(record, serverAddress);
-			if(mHandler != null)
-				mHandler.obtainMessage(RECORD_UPLOADED, offset, size);
+			editor.commit();
+			
+			boolean success = uploadSingleRecord(record, serverAddress);
+			Log.i("Tracing upload", "Upload of record: " + offset +"/" + size + ((success) ? " successful.": " failed."));
+			if(receiver != null){
+				Bundle data = new Bundle();
+				data.putInt(UPLOAD_SIZE, size); 
+				data.putInt(UPLOAD_PROGRESS, offset);
+				receiver.send(RECORD_UPLOADED, data);
+			}
 			offset++;			
 		}
 	}	
@@ -99,15 +127,17 @@ public class TracingSyncService extends IntentService{
 		// Create a https client. Uses MySSLSocketFactory to accept all certificates
 		HttpPost httppost;
 		try {
+			httpClient = createHttpClient();
 			// Create HttpPost
-			httppost = new HttpPost();
+			httppost = new HttpPost(serverAddress);
 			// Create JSON String of Record
 			//TODO FIX ME
-			StringEntity se = new StringEntity( null/*record.toString(TraCINgFormatter
-					.getInstance()) */);
+			//StringEntity se = new StringEntity( record.toString(TraCINgFormatter.getInstance()) );
+			StringEntity se = new StringEntity(record.toString());
 			httppost.setEntity(se);
 			// Execute HttpPost
-			httpClient.execute(httppost);
+			HttpResponse response = httpClient.execute(httppost);
+			Log.i("TracingSyncService", "Status Code: " + response.getStatusLine().getStatusCode()); 
 		} catch (Exception e) {
 			e.printStackTrace();
 			return false;

src/de/tudarmstadt/informatik/hostage/ui/PlayGroundActivity.java

@@ -21,6 +21,7 @@ import de.tudarmstadt.informatik.hostage.persistence.HostageDBContract;
 import de.tudarmstadt.informatik.hostage.persistence.HostageDBOpenHelper;
 import de.tudarmstadt.informatik.hostage.sync.bluetooth.BluetoothSync;
 import de.tudarmstadt.informatik.hostage.sync.nfc.NFCSync;
+import de.tudarmstadt.informatik.hostage.sync.tracing.TracingSyncActivity;
 
 public class PlayGroundActivity extends Activity {
 
@@ -50,7 +51,7 @@ public class PlayGroundActivity extends Activity {
 	}
 
 	public void startNFC(View view) {
-		startActivity(new Intent(this, NFCSync.class));
+		startActivity(new Intent(this, TracingSyncActivity.class));
 	}
 
 	public void syncData(View view) {