ISInterface.java

/*
 * ISInterface.java
 *
 * Created on 06 November 2003, 17:16
 */

package GuiComponents.System;

import ipc.*;
import is.*;

public class ISInterface {
    
    public static ISInterface getInstance() {
        return instance;
    }
        
    public void refresh() {
        r = null;
    }
    
    public String[] getISServers() {
        try {
            is.ServerIterator sit = new is.ServerIterator(si.getPartition());
            String[] servers = new String[sit.entries()];
            for (int i=0; i<sit.entries(); ++i) {
                servers[i] = sit.nextServerName();
            }
            return servers;
        } catch (NullPointerException npe) { //Caused by partition not available
            return new String[0];
        }
    }
    
    public String[] getISObjects(String server) {
        try {
            InfoList l = new InfoList(si.getPartition(), server);
            String[] objects = new String[l.getSize()];
            AnyInfo info;
            for (int i=0; i<l.getSize(); i++) {
                info = l.getInfo(i);
                objects[i] = new String(info.getName()); 
            }
            return objects;
        } catch (NullPointerException npe) { //Caused by partition not available
            return new String[0];
        }
    }
    
    public int getNumberOfISObjects(String server, String pattern) {
        if (si.getPartition()==null) return 0;
        InfoList l = new InfoList(si.getPartition(), server, pattern);
        return l.getSize();
    }
    
    public String[] getISObjects(String server, String pattern) {
        if (si.getPartition()==null) return new String[0];
        InfoList l = new InfoList(si.getPartition(), server, pattern);
        String[] objects = new String[l.getSize()];
        AnyInfo info;
        for (int i=0; i<l.getSize(); i++) {
            info = l.getInfo(i);
            objects[i] = new String(info.getName()); 
        }
        return objects;
    }
    
    public Repository getRepository() {
        if (r == null) {
            try {
                Partition p = si.getPartition();
                r = new SctRepository(p);
            } catch (NullPointerException npe) {
                //Do nothing - this must have been caused by not being able to get the partition, which we've already logged
            }
        }
        return r;
    }
    

    public String subscribe(String server, String regex, InfoListener l) {
        try {
            getRepository().subscribe(server, new Criteria(regex), l);
        } catch (RepositoryNotFoundException rnfe) {
            return "Internal error while subscribing to server " +server +" for " + regex + " : " + rnfe;
        } catch (InvalidCriteriaException iee) {
            return "Internal error while subscribing to server " +server +" for " + regex + " : " + iee;
        } catch (NullPointerException npe) {
            return "Couldn't get repository - see logs";
        }

        return "Subscribe to " + server + " with regex " + regex + " successful";
    }

   public String subscribe(String infoName, InfoListener l) {
        try {
            getRepository().subscribe(infoName, l);
        } catch (RepositoryNotFoundException rnfe) {
            return "Internal error while subscribing to "+ infoName + " : " + rnfe;
        } catch (InvalidNameException iee) {
            return "InvalidName error while subscribing to " + infoName + " : " + iee;
        } catch (NullPointerException npe) {
            return "Couldn't get repository - see logs";
        }

        return "Subscribe to " + infoName + " successful";
    }

    public String subscribe(String server, String regex, boolean isRegex, InfoListener l) {        
        try {
            getRepository().subscribe(server, regex, isRegex, l);
        } catch (RepositoryNotFoundException rnfe) {
            return "Internal error while subscribing to server " +server +" for " + regex + " : " + rnfe;
        } catch (InvalidCriteriaException iee) {
            return "Internal error while subscribing to server " +server +" for " + regex + " : " + iee;
        } catch (NullPointerException npe) {
            return "Couldn't get repository - see logs";
        }

        return "Subscribe to " + server + " with regex " + regex + " successful";
    }

//    public String subscribe(String server, InfoListener l) {
//           return subscribe(server, ".*", l);
//    }
    
    public String unsubscribe(String infoName) {
        try {
            getRepository().unsubscribe(infoName);
        } catch (RepositoryNotFoundException rnfe) {
            return "Oops, internal error while unsubscribing: " + rnfe;
        } catch (SubscriptionNotFoundException snfe) {
            return "Ooops, internal error - subscription not found: " + snfe;
        } catch (InvalidNameException npe) {
            return "Ooops, InvalidName error : " + npe;
        }

        return "Unsubscribe from " + infoName + " successful";
    }

    public String unsubscribe(String server, String regex) {
        try {
            getRepository().unsubscribe(server, new Criteria(regex));
        } catch (RepositoryNotFoundException rnfe) {
            return "Oops, internal error while unsubscribing: " + rnfe;
        } catch (SubscriptionNotFoundException snfe) {
            return "Ooop, internal error - subscription not found: " + snfe;
        } catch (NullPointerException npe) {
            return "Couldn't get repository - see logs";
        }

        return "Unsubscribe from " + server + " for " + regex + " successful";
    }
    
    public String remove(String object) {
        try {
            getRepository().remove(object);
        } catch (RepositoryNotFoundException rnfe) {
            return "Oops, internal error while unsubscribing: " + rnfe;
        } catch (InfoNotFoundException infe) {
            return "Object not found in repository: " + infe;
        } catch (NullPointerException npe) {
            return "Couldn't get repository - see logs";
        }
        
        return "Object" + object + " successfully removed";
    }
    
    private ISInterface() {        
        si = SystemInterface.getInstance();
        refresh();
    }
    
    private static ISInterface instance = new ISInterface();
    private Repository r;
    private SystemInterface si;
}

---