From fce0caae29edb89e8784b945559862c6b58eef94 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= <kjetil.orbekk@gmail.com>
Date: Tue, 24 Apr 2012 14:46:08 +0200
Subject: Use same-android with protobuf services.

---
 .../same/android/SameControllerActivity.java       | 11 ++--------
 .../java/com/orbekk/same/android/SameService.java  | 24 ++++++++--------------
 2 files changed, 11 insertions(+), 24 deletions(-)

diff --git a/same-android/src/main/java/com/orbekk/same/android/SameControllerActivity.java b/same-android/src/main/java/com/orbekk/same/android/SameControllerActivity.java
index 2fd0d92..6e8d613 100644
--- a/same-android/src/main/java/com/orbekk/same/android/SameControllerActivity.java
+++ b/same-android/src/main/java/com/orbekk/same/android/SameControllerActivity.java
@@ -88,24 +88,17 @@ public class SameControllerActivity extends Activity {
     }
     
     public void joinNetworkUrl(View unused) {
-        String masterUrl = "";
         Intent intent = new Intent(this, SameService.class);
         intent.setAction("join");
         EditText t = (EditText)findViewById(R.id.master_service_url);
-        masterUrl = t.getText().toString();
-        if (!masterUrl.startsWith("http://")) {
-            masterUrl = "http://" + masterUrl;
-        }
-        if (!masterUrl.endsWith("/MasterService.json")) {
-            masterUrl += "/MasterService.json";
-        }
+        String masterUrl = t.getText().toString();
         joinNetwork(masterUrl);
     }
     
     private void joinNetwork(String masterUrl) {
         logger.info("joinNetwork({})", masterUrl);
         Message message = Message.obtain(null, SameService.JOIN_NETWORK);
-        message.getData().putString("masterUrl", masterUrl);
+        message.getData().putString("masterLocation", masterUrl);
         try {
             sameService.send(message);
         } catch (RemoteException e) {
diff --git a/same-android/src/main/java/com/orbekk/same/android/SameService.java b/same-android/src/main/java/com/orbekk/same/android/SameService.java
index 8c7bbba..1ec7961 100644
--- a/same-android/src/main/java/com/orbekk/same/android/SameService.java
+++ b/same-android/src/main/java/com/orbekk/same/android/SameService.java
@@ -22,6 +22,7 @@ import com.orbekk.protobuf.Rpc;
 import com.orbekk.same.NetworkNotificationListener;
 import com.orbekk.same.SameController;
 import com.orbekk.same.Services;
+import com.orbekk.same.Services.MasterState;
 import com.orbekk.same.Services.NetworkDirectory;
 import com.orbekk.same.State;
 import com.orbekk.same.State.Component;
@@ -66,6 +67,7 @@ public class SameService extends Service {
     public final static String NETWORK_URLS =
             "com.orbekk.same.SameService.action.NETWORK_URLS";
 
+    final static int PPORT = 15070;
     final static int SERVICE_PORT = 15068;
     final static int DISCOVERY_PORT = 15066;
     final static String DIRECTORY_URL = "flode.pvv.ntnu.no:15072";
@@ -103,8 +105,10 @@ public class SameService extends Service {
                     break;
                 case JOIN_NETWORK:
                     logger.info("JOIN_NETWORK");
-                    String masterUrl = message.getData().getString("masterUrl");
-                    sameController.getClient().joinNetwork("fixme");
+                    String masterUrl = message.getData().getString("masterLocation");
+                    MasterState master = MasterState.newBuilder()
+                            .setMasterLocation(masterUrl).build();
+                    sameController.getClient().joinNetwork(master);
                     break;
                 case ADD_STATE_RECEIVER:
                     logger.info("ADD_STATE_RECEIVER: {}", message);
@@ -213,7 +217,7 @@ public class SameService extends Service {
                 }
                 for (Services.MasterState network : networks.getNetworkList()) {
                     networkListener.notifyNetwork(network.getNetworkName(),
-                            network.getMasterUrl());
+                            network.getMasterLocation());
                 }
             }
         };
@@ -226,6 +230,7 @@ public class SameService extends Service {
                 .getWlanAddress().getHostAddress();
         String baseUrl = "http://" + localIp + ":" + SERVICE_PORT + "/";
         properties.setProperty("port", ""+SERVICE_PORT);
+        properties.setProperty("pport", ""+PPORT);
         properties.setProperty("localIp", localIp);
         properties.setProperty("baseUrl", baseUrl);
         properties.setProperty("enableDiscovery", "true");
@@ -238,17 +243,7 @@ public class SameService extends Service {
     /** Create a public network. */
     private void create() {
         sameController.createNetwork(configuration.get("networkName"));
-//        try {
-//            // SameController should take care of this.
-//            sameController.getDirectory().registerNetwork(
-//                    configuration.get("networkName"),
-//                    sameController.getMaster().getUrl());
-//        } catch (Exception e) {
-//            Toast.makeText(this, "Unable to register network. " +
-//            		"Use manual address to join.",
-//                    Toast.LENGTH_LONG).show();
-//            logger.warn("Unable to advertise network.", e);
-//        }
+        sameController.registerCurrentNetwork();
     }
     
     @Override
@@ -277,7 +272,6 @@ public class SameService extends Service {
             sameController = SameController.create(configuration);
             try {
                 sameController.start();
-                sameController.getClient().setNetworkListener(networkListener);
                 sameController.getClient().getInterface()
                     .addStateListener(stateListener);
                 findNetworks();
-- 
cgit v1.2.3