From 56ccc618a686ee5cb0128bdf32538a1f29e06b3d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= Date: Mon, 13 Feb 2012 18:06:16 +0100 Subject: Move SameService. com.orbekk{.discovery =>}.SameService --- .../src/main/java/com/orbekk/SameService.java | 204 +++++++++++++++++++++ 1 file changed, 204 insertions(+) create mode 100644 same-android/src/main/java/com/orbekk/SameService.java (limited to 'same-android/src/main/java/com/orbekk/SameService.java') 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 networkList = new ArrayList(); + 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(); + } + } + +} -- cgit v1.2.3