X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;f=src%2Fjalview%2Fws%2Fslivkaws%2FSlivkaWSDiscoverer.java;h=d290024937c859f62319382be3a0ad8060c4e6a7;hb=95f4ae66fbaecbbdc1c3ab3c6c9c611a3a9a3e46;hp=fc90a69cc49e8b50bc9999be118dd016f937fc14;hpb=d3f8117988649e07fcd27a5e5623a1af6391b508;p=jalview.git diff --git a/src/jalview/ws/slivkaws/SlivkaWSDiscoverer.java b/src/jalview/ws/slivkaws/SlivkaWSDiscoverer.java index fc90a69..d290024 100644 --- a/src/jalview/ws/slivkaws/SlivkaWSDiscoverer.java +++ b/src/jalview/ws/slivkaws/SlivkaWSDiscoverer.java @@ -1,107 +1,231 @@ package jalview.ws.slivkaws; -import jalview.datamodel.AlignmentView; -import jalview.gui.AlignFrame; -import jalview.ws.WSMenuEntryProviderI; -import jalview.ws.jws2.MsaWSClient; - -import java.awt.event.ActionEvent; -import java.io.IOError; +import jalview.bin.Cache; +import jalview.ws.ServiceChangeListener; +import jalview.ws.WSDiscovererI; +import jalview.ws.api.ServiceWithParameters; import java.io.IOException; -import java.net.URISyntaxException; - -import javax.swing.JMenu; -import javax.swing.JMenuItem; - +import java.net.MalformedURLException; +import java.net.URL; +import java.util.ArrayList; +import java.util.Collections; +import java.util.List; +import java.util.Set; +import java.util.Vector; +import java.util.concurrent.CompletableFuture; +import java.util.concurrent.CopyOnWriteArraySet; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import java.util.concurrent.Future; + +import compbio.data.msa.Category; import uk.ac.dundee.compbio.slivkaclient.SlivkaClient; +import uk.ac.dundee.compbio.slivkaclient.SlivkaService; -public class SlivkaWSDiscoverer - implements Runnable, WSMenuEntryProviderI +public class SlivkaWSDiscoverer implements WSDiscovererI { + private static final String SLIVKA_HOST_URLS = "SLIVKAHOSTURLS"; + + private static final String COMPBIO_SLIVKA = "https://www.compbio.dundee.ac.uk/slivka/"; + private static SlivkaWSDiscoverer instance = null; - private SlivkaClient client; - private SlivkaWSDiscoverer() { - try - { - client = new SlivkaClient("gjb-www-1.cluster.lifesci.dundee.ac.uk", 3203); - } catch (URISyntaxException e) - { - throw new RuntimeException(e); - } + private List services = List.of(); + + private SlivkaWSDiscoverer() + { } public static SlivkaWSDiscoverer getInstance() { - if (instance == null) { - instance = new SlivkaWSDiscoverer(); - } + if (instance == null) + { + instance = new SlivkaWSDiscoverer(); + } return instance; } + private Set serviceListeners = new CopyOnWriteArraySet<>(); + @Override - public void attachWSMenuEntry(JMenu wsmenu, final AlignFrame alignFrame) + public void addServiceChangeListener(ServiceChangeListener l) { - JMenu submenu = new JMenu("Slivka"); + serviceListeners.add(l); + } - String[] services = { "clustalo", "clustalw", "probcons", "muscle", "mafft", "tcoffee" }; - String[] names = { "ClustalO", "ClustalW2", "Probcons", "Muscle", "Mafft", "TCoffe" }; + @Override + public void removeServiceChangeListener(ServiceChangeListener l) + { + serviceListeners.remove(l); + } - for (int i = 0; i < services.length; i++) + public void notifyServiceListeners(List services) + { + for (var listener : serviceListeners) { + listener.servicesChanged(this, services); + } + } + + private final ExecutorService executor = Executors + .newSingleThreadExecutor(); + + private Vector> discoveryTasks = new Vector<>(); + + public CompletableFuture startDiscoverer() + { + CompletableFuture task = CompletableFuture + .supplyAsync(() -> { + reloadServices(); + return SlivkaWSDiscoverer.this; + }, executor); + discoveryTasks.add(task); + return task; + } + + private List reloadServices() + { + Cache.log.info("Reloading Slivka services"); + notifyServiceListeners(Collections.emptyList()); + ArrayList instances = new ArrayList<>(); + + for (String url : getServiceUrls()) + { + SlivkaClient client = new SlivkaClient(url); + + List services; try { - SlivkaWSInstance instance = new SlivkaWSInstance(client, - client.getService(services[i])); - - JMenuItem defaultMenuItem = new JMenuItem( - String.format("%s with defaults", names[i])); - defaultMenuItem.addActionListener((ActionEvent e) -> { - AlignmentView msa = alignFrame.gatherSequencesForAlignment(); - if (msa != null) - { - new MsaWSClient(instance, alignFrame.getTitle(), msa, false, true, - alignFrame.getViewport().getAlignment().getDataset(), - alignFrame); - } - }); - submenu.add(defaultMenuItem); - - JMenuItem customMenuItem = new JMenuItem( - String.format("%s with custom parameters", names[i])); - customMenuItem.addActionListener((ActionEvent e) -> { - AlignmentView msa = alignFrame.gatherSequencesForAlignment(); - if (msa != null) + services = client.getServices(); + } catch (IOException e) + { + e.printStackTrace(); + continue; + } + for (SlivkaService service : services) + { + SlivkaWSInstance newInstance = null; + for (String classifier : service.classifiers) + { + String[] path = classifier.split("\\s*::\\s*"); + if (path.length >= 3 && path[0].toLowerCase().equals("operation") + && path[1].toLowerCase().equals("analysis")) { - try - { - SlivkaParamSet paramSet = new SlivkaParamSet( - instance.getService()); - new MsaWSClient(instance, paramSet, null, true, - alignFrame.getTitle(), msa, false, true, - alignFrame.getViewport().getAlignment().getDataset(), - alignFrame); - } catch (IOException e1) + switch (path[path.length - 1].toLowerCase()) { - throw new IOError(e1); + case "sequence alignment analysis (conservation)": + newInstance = new SlivkaAnnotationServiceInstance(client, + service, Category.CATEGORY_CONSERVATION); + break; + case "protein sequence analysis": + newInstance = new SlivkaAnnotationServiceInstance(client, + service, Category.CATEGORY_DISORDER); + break; + case "protein secondary structure prediction": + newInstance = new SlivkaJPredServiceInstance(client, + service, "Secondary Structure Prediction"); + break; + case "multiple sequence alignment": + newInstance = new SlivkaMsaServiceInstance(client, service, + Category.CATEGORY_ALIGNMENT); + break; } - } - }); - submenu.add(customMenuItem); - } catch (IOException e) + if (newInstance != null) + break; + } + if (newInstance != null) + instances.add(newInstance); + } + } + + services = instances; + Cache.log.info("Slivka services reloading finished"); + notifyServiceListeners(instances); + return instances; + } + + @Override + public List getServices() + { + return services; + } + + @Override + public boolean hasServices() + { + return !isRunning() && services.size() > 0; + } + + @Override + public boolean isRunning() + { + return !discoveryTasks.stream().allMatch(Future::isDone); + } + + @Override + public void setServiceUrls(List wsUrls) + { + if (wsUrls != null && !wsUrls.isEmpty()) + { + Cache.setProperty(SLIVKA_HOST_URLS, String.join(",", wsUrls)); + } + else + { + Cache.removeProperty(SLIVKA_HOST_URLS); + } + } + + @Override + public List getServiceUrls() + { + String surls = Cache.getDefault(SLIVKA_HOST_URLS, COMPBIO_SLIVKA); + String[] urls = surls.split(","); + ArrayList valid = new ArrayList<>(urls.length); + for (String url : urls) + { + try { - // TODO Auto-generated catch block - e.printStackTrace(); + new URL(url); + valid.add(url); + } catch (MalformedURLException e) + { + Cache.log.warn("Problem whilst trying to make a URL from '" + + ((url != null) ? url : "") + "'"); + Cache.log.warn( + "This was probably due to a malformed comma separated list" + + " in the " + SLIVKA_HOST_URLS + + " entry of $(HOME)/.jalview_properties)"); + Cache.log.debug("Exception was ", e); } } + return valid; + } - wsmenu.add(submenu); + @Override + public boolean testServiceUrl(URL url) + { + return getServerStatusFor(url.toString()) == STATUS_OK; } @Override - public void run() + public int getServerStatusFor(String url) { + try + { + List services = new SlivkaClient(url).getServices(); + return services.isEmpty() ? STATUS_NO_SERVICES : STATUS_OK; + } catch (IOException e) + { + Cache.log.error("Slivka could not retrieve services list", e); + return STATUS_INVALID; + } + } + @Override + public String getErrorMessages() + { + // TODO Auto-generated method stub + return ""; } }