DiscoveryHandler.java

Go to the documentation of this file.

package ros.zeroconf.android.jmdns.master_browser;

import java.util.ArrayList;

import android.os.AsyncTask;
import android.widget.TextView;
import ros.zeroconf.jmdns.ZeroconfDiscoveryHandler;
import org.ros.message.zeroconf_comms.DiscoveredService;

public class DiscoveryHandler implements ZeroconfDiscoveryHandler {

        /*********************
         * Tasks
         ********************/
        private class ServiceAddedTask extends AsyncTask<DiscoveredService, String, Void> {
                
            protected Void doInBackground(DiscoveredService... services) {
                if ( services.length == 1 ) {
                    DiscoveredService service = services[0];
                                String result = "[+] Service added: " + service.name + "." + service.type + "." + service.domain + ".";
                                publishProgress(result);
                } else {
                    publishProgress("Error - ServiceAddedTask::doInBackground received #services != 1");
                }
                return null;
            }

            protected void onProgressUpdate(String... progress) {
                uiLog(progress);
                }
        }

        private class ServiceResolvedTask extends AsyncTask<DiscoveredService, String, DiscoveredService> {
                
            protected DiscoveredService doInBackground(DiscoveredService... services) {
                if ( services.length == 1 ) {
                    DiscoveredService discovered_service = services[0];
                        String result = "[=] Service resolved: " + discovered_service.name + "." + discovered_service.type + "." + discovered_service.domain + ".\n";
                        result += "    Port: " + discovered_service.port;
                        for ( String address : discovered_service.ipv4_addresses ) {
                                result += "\n    Address: " + address;
                        }
                        for ( String address : discovered_service.ipv6_addresses ) {
                                result += "\n    Address: " + address;
                        }
                        publishProgress(result);
                        return discovered_service;
                } else {
                    publishProgress("Error - ServiceAddedTask::doInBackground received #services != 1");
                }
                return null;
            }

            protected void onProgressUpdate(String... progress) {
                uiLog(progress);
                }
            
            protected void onPostExecute(DiscoveredService discovered_service) {
                // add to the content and notify the list view if its a new service
                if ( discovered_service != null ) {
                                int index = 0;
                                for ( DiscoveredService s : discovered_services ) {
                                        if ( s.name.equals(discovered_service.name) ) {
                                                break;
                                        } else {
                                                ++index;
                                        }
                                }
                                if ( index == discovered_services.size() ) {
                                        discovered_services.add(discovered_service);
                                        discovery_adapter.notifyDataSetChanged();
                                } else {
                                        android.util.Log.i("zeroconf", "Tried to add an existing service (fix this)");
                                }
                }
            }
        }
        
        private class ServiceRemovedTask extends AsyncTask<DiscoveredService, String, DiscoveredService> {
                
            protected DiscoveredService doInBackground(DiscoveredService... services) {
                if ( services.length == 1 ) {
                    DiscoveredService discovered_service = services[0];
                    String result = "[-] Service removed: " + discovered_service.name + "." + discovered_service.type + "." + discovered_service.domain + ".\n";
                    result += "    Port: " + discovered_service.port;
                        for ( String address : discovered_service.ipv4_addresses ) {
                                result += "\n    Address: " + address;
                        }
                        for ( String address : discovered_service.ipv6_addresses ) {
                                result += "\n    Address: " + address;
                        }
                        publishProgress(result);
                        return discovered_service;
                } else {
                    publishProgress("Error - ServiceAddedTask::doInBackground received #services != 1");
                }
                return null;
            }

            protected void onProgressUpdate(String... progress) {
                uiLog(progress);
                }
            
            protected void onPostExecute(DiscoveredService discovered_service) {
                // remove service from storage and notify list view
                if ( discovered_service != null ) {
                                int index = 0;
                                for ( DiscoveredService s : discovered_services ) {
                                        if ( s.name.equals(discovered_service.name) ) {
                                                break;
                                        } else {
                                                ++index;
                                        }
                                }
                                if ( index != discovered_services.size() ) {
                                        discovered_services.remove(index);
                                        discovery_adapter.notifyDataSetChanged();
                                } else {
                                        android.util.Log.i("zeroconf", "Tried to remove a non-existant service");
                                }
                }
            }
        }

        /*********************
         * Variables
         ********************/
        private ArrayList<DiscoveredService> discovered_services;
    private DiscoveryAdapter discovery_adapter;
        private TextView text_view;

        /*********************
         * Constructors
         ********************/
        public DiscoveryHandler(TextView tv, DiscoveryAdapter discovery_adapter, ArrayList<DiscoveredService> discovered_services) {
                this.text_view = tv;
                this.discovery_adapter = discovery_adapter;
                this.discovered_services = discovered_services;
        }

        /*********************
         * Callbacks
         ********************/
        public void serviceAdded(DiscoveredService service) {
                new ServiceAddedTask().execute(service);
        }
        
        public void serviceRemoved(DiscoveredService service) {
                new ServiceRemovedTask().execute(service);
        }
        
        public void serviceResolved(DiscoveredService service) {
                new ServiceResolvedTask().execute(service);
        }

        /*********************
         * Utility
         ********************/
        private void uiLog(String... messages) {
        for (String msg : messages ) {
            android.util.Log.i("zeroconf", msg);
            text_view.append(msg + "\n");
        }
        int line_count = text_view.getLineCount(); 
        int view_height = text_view.getHeight();
        int pixels_per_line = text_view.getLineHeight();
        int pixels_difference = line_count*pixels_per_line - view_height;
        if ( pixels_difference > 0 ) {
                text_view.scrollTo(0, pixels_difference);
        }
        }
}