1 files changed, 204 insertions, 0 deletions
diff --git a/same-android/src/main/java/com/orbekk/SameService.java b/same-android/src/main/java/com/orbekk/SameService.java
new file mode 100644
index 0000000..0738a00
--- /dev/null
+++ b/same-android/src/main/java/com/orbekk/SameService.java
@@ -0,0 +1,204 @@
+package com.orbekk;
+
+import java.util.List;
+import java.net.DatagramPacket;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.util.ArrayList;
+import java.util.Properties;
+
+import android.app.Service;
+import android.content.Intent;
+import android.os.Handler;
+import android.os.IBinder;
+import android.os.Message;
+import android.os.Messenger;
+import android.widget.Toast;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.orbekk.same.DiscoveryListener;
+import com.orbekk.same.NetworkNotificationListener;
+import com.orbekk.same.SameController;
+import com.orbekk.same.android.net.Broadcaster;
+import com.orbekk.same.config.Configuration;
+
+public class SameService extends Service {
+    public final static int DISPLAY_MESSAGE = 1;
+
+    public final static String AVAILABLE_NETWORKS_UPDATE =
+            "com.orbekk.same.SameService.action.AVAILABLE_NETWORKS_UPDATE";
+    public final static String AVAILABLE_NETWORKS =
+            "com.orbekk.same.SameService.action.AVAILABLE_NETWORKS";
+
+    final static int PORT = 15066;
+    final static int SERVICE_PORT = 15068;
+    
+    private Logger logger = LoggerFactory.getLogger(getClass());
+    private Thread discoveryThread = null;
+    private SameController sameController = null;
+    private Configuration configuration = null;
+    
+    /** This class should go away >:-/ */
+    public final class DiscoveryThread extends Thread {
+        Broadcaster broadcast;
+        DiscoveryListener listener;
+        
+        public DiscoveryThread(DiscoveryListener listener) {
+            broadcast = new Broadcaster(SameService.this);
+            this.listener = listener;
+        }
+        
+        @Override public void run() {
+            while (!Thread.interrupted()) {
+                DatagramPacket packet = broadcast.receiveBroadcast(PORT);
+                String content = new String(packet.getData(), 0, packet.getLength());
+                String[] words = content.split(" ");
+                
+                if (!content.startsWith("Discover") || content.length() < 2) {
+                    logger.warn("Invalid discovery message: {}", content);
+                    continue;
+                }
+                
+                String port = words[1];
+                String url = "http://" + packet.getAddress().getHostAddress() +
+                        ":" + port + "/ClientService.json";
+                listener.discover(url);
+                
+                Message message = Message.obtain();
+                message.obj = "New client: " + url;
+                toastHandler.sendMessage(message);
+            }
+        }
+        
+        @Override public void interrupt() {
+            super.interrupt();
+            broadcast.interrupt();
+        }
+    }
+    
+    private Handler toastHandler = new Handler() {
+        @Override public void handleMessage(Message message) {
+            Toast.makeText(SameService.this,
+                    (String)message.obj, Toast.LENGTH_SHORT)
+                            .show();
+            logger.info("Display toast: {}", (String)message.obj);
+        }
+    };
+    
+    
+    class InterfaceHandler extends Handler {
+        @Override public void handleMessage(Message message) {
+            switch (message.what) {
+                case DISPLAY_MESSAGE:
+                    Toast.makeText(SameService.this,
+                        (String)message.obj, Toast.LENGTH_SHORT)
+                            .show();
+                            
+                    Intent intent = new Intent(AVAILABLE_NETWORKS_UPDATE);
+                    ArrayList<String> networkList = new ArrayList<String>();
+                    networkList.add("FirstNetwork");
+                    intent.putStringArrayListExtra(AVAILABLE_NETWORKS,
+                        networkList);
+                    sendBroadcast(intent);
+                        
+                    break;
+                default:
+                    super.handleMessage(message);
+            }
+        }
+    }
+    
+    private final Messenger messenger = new Messenger(new InterfaceHandler());
+    
+    private void createNetwork() {
+        if (discoveryThread == null) {
+            synchronized (this) {
+                discoveryThread = new DiscoveryThread(sameController.getClient());
+                discoveryThread.start();
+            }
+            
+        }
+    }
+    
+    private void initializeConfiguration() {
+        Properties properties = new Properties();
+        properties.setProperty("port", ""+SERVICE_PORT);
+        properties.setProperty("localIp",
+                new Broadcaster(this).getWlanAddress().getHostAddress());
+        properties.setProperty("masterUrl", "http://10.0.0.6:10010/MasterService.json");
+        configuration = new Configuration(properties);
+    }
+    
+    private void sendBroadcastDiscovery(InetAddress ip) {
+        Broadcaster broadcaster = new Broadcaster(this);
+        String message = "Discover " + (PORT + 2);
+        byte[] data = message.getBytes();
+        if (ip.equals(broadcaster.getBroadcastAddress())) {
+            broadcaster.sendUdpData(data, ip, PORT);
+        } else {
+            String remoteAddress =
+                    String.format("http://%s:%s/ClientService.json",
+                    		ip.getHostAddress(), PORT + 2);
+            sameController.getClient().sendDiscoveryRequest(
+                    remoteAddress);
+        }
+    }
+    
+    private void searchNetworks(InetAddress ip) {
+        sameController.getClient().setNetworkListener(
+                new NetworkNotificationListener() {
+                    @Override
+                    public void notifyNetwork(String networkName, String masterUrl) {
+                        Message message = Message.obtain();
+                        message.obj = "notifyNetwork(" + networkName + ", " +
+                                    masterUrl;
+                        toastHandler.sendMessage(message);
+                    }
+                });
+        sendBroadcastDiscovery(ip);
+    }
+    
+    @Override
+    public IBinder onBind(Intent intent) {
+        return messenger.getBinder();
+    }
+    
+    @Override
+    public int onStartCommand(Intent intent, int flags, int startId) {
+        System.setProperty("http.keepAlive", "false");
+        Toast.makeText(this, "service start: " + intent.getAction(),
+                Toast.LENGTH_SHORT).show();
+        if (sameController == null) {
+            initializeConfiguration();
+            sameController = SameController.create(configuration);
+            try {
+                sameController.start();
+            } catch (Exception e) {
+                logger.error("Failed to start server", e);
+                return START_STICKY;
+            }
+        }
+        
+        if (intent.getAction().equals("create")) {
+            createNetwork();
+        } else if (intent.getAction().equals("join")) {
+            String masterUrl = intent.getExtras().getString("masterUrl"); 
+            sameController.joinNetwork(masterUrl);
+        }
+        return START_STICKY;
+    }
+    
+    @Override
+    public void onDestroy() {
+        Toast.makeText(this, "service stopped", Toast.LENGTH_SHORT).show();
+        if (discoveryThread != null) {
+            discoveryThread.interrupt();
+        }
+        if (sameController != null) {
+            sameController.stop();
+        }
+    }
+
+}