diff options
Diffstat (limited to 'same-android/src/main/java/com/orbekk/discovery')
-rw-r--r-- | same-android/src/main/java/com/orbekk/discovery/SameService.java | 203 |
1 files changed, 0 insertions, 203 deletions
diff --git a/same-android/src/main/java/com/orbekk/discovery/SameService.java b/same-android/src/main/java/com/orbekk/discovery/SameService.java deleted file mode 100644 index c43d4ff..0000000 --- a/same-android/src/main/java/com/orbekk/discovery/SameService.java +++ /dev/null @@ -1,203 +0,0 @@ -package com.orbekk.discovery; - -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.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(); - } - } - -} |