3 import org.apache.axis.client.*;
\r
4 import javax.xml.namespace.QName;
\r
6 import jalview.datamodel.*;
\r
7 import jalview.gui.*;
\r
8 import javax.swing.*;
\r
11 import jalview.analysis.AlignSeq;
\r
12 import ext.vamsas.*;
\r
13 import vamsas.objects.*;
\r
15 public class MsaWSClient
\r
17 int jobsRunning = 0;
\r
18 ext.vamsas.MuscleWS server;
\r
19 WebserviceInfo wsInfo;
\r
23 * @param msa SequenceI[]
\r
25 public MsaWSClient(SequenceI[] msa)
\r
27 wsInfo = new jalview.gui.WebserviceInfo("Muscle Alignment job",
\r
28 "Edgar, Robert C. (2004), MUSCLE: multiple sequence alignment with high accuracy and high throughput, Nucleic Acids Research 32(5), 1792-97.");
\r
31 wsInfo.setProgressText("Job details\n");
\r
34 MuscleWSServiceLocator loc = new MuscleWSServiceLocator(); // Default
\r
36 this.server = (MuscleWS) loc.getMuscleWS(); // JBPNote will be set from properties
\r
38 catch (Exception ex) {
\r
39 wsInfo.setProgressText("Serious! MuscleWS Service location failed\nfor URL :"
\r
40 +loc.getMuscleWSAddress()+"\n"+ex.getMessage());
\r
41 ex.printStackTrace();
\r
44 MsaWSThread musclethread = new MsaWSThread(msa);
\r
45 wsInfo.setthisService(musclethread);
\r
46 musclethread.start();
\r
50 protected class MsaWSThread extends Thread implements WSClientI
\r
52 String ServiceName = "MuscleWS";
\r
53 public boolean isCancellable()
\r
58 String OutputHeader;
\r
59 vamsas.objects.simple.MsaResult result = null;
\r
60 vamsas.objects.simple.SequenceSet seqs = new vamsas.objects.simple.
\r
63 int allowedServerExceptions = 3; // thread dies if too many exceptions.
\r
64 MsaWSThread(SequenceI[] msa)
\r
66 OutputHeader = wsInfo.getProgressText();
\r
67 vamsas.objects.simple.Sequence[] seqarray = new vamsas.objects.simple.
\r
68 Sequence[msa.length];
\r
69 for (int i = 0; i < msa.length; i++)
\r
71 seqarray[i] = new vamsas.objects.simple.Sequence();
\r
72 seqarray[i].setId(msa[i].getName());
\r
73 seqarray[i].setSeq(AlignSeq.extractGaps("-. ", msa[i].getSequence()));
\r
75 this.seqs = new vamsas.objects.simple.SequenceSet();
\r
76 this.seqs.setSeqs(seqarray);
\r
79 boolean jobComplete = false;
\r
81 public void cancelJob() {
\r
83 String cancelledMessage="";
\r
85 vamsas.objects.simple.WsJobId cancelledJob = server.cancel(jobId);
\r
86 if (cancelledJob.getStatus() == 2)
\r
89 cancelledMessage = "Job cancelled.";
\r
90 wsInfo.setStatus(WebserviceInfo.STATE_CANCELLED_OK);
\r
96 if (cancelledJob.getStatus() == 3)
\r
98 // VALID UNSTOPPABLE JOB
\r
100 "Server cannot cancel this job. just close the window.\n";
\r
102 if (cancelledJob.getJobId() != null)
\r
103 cancelledMessage += "[" + cancelledJob.getJobId() + "]";
\r
104 cancelledMessage +="\n";
\r
105 } catch (Exception exc) {
\r
106 cancelledMessage +="\nProblems cancelling the job : Exception received...\n"+exc+"\n";
\r
107 exc.printStackTrace();
\r
109 wsInfo.setProgressText(OutputHeader + cancelledMessage+"\n");
\r
118 while (!jobComplete && (allowedServerExceptions > 0))
\r
122 result = server.getResult(jobId);
\r
124 if( result.isRunning() )
\r
125 wsInfo.setStatus(WebserviceInfo.STATE_RUNNING);
\r
126 else if( result.isQueued() )
\r
127 wsInfo.setStatus(WebserviceInfo.STATE_QUEUING);
\r
129 if (result.isFinished())
\r
132 jobComplete = true;
\r
137 wsInfo.setProgressText(OutputHeader + "\n" + result.getStatus());
\r
138 if (! (result.isJobFailed() || result.isServerError()))
\r
140 Thread.sleep(5000);
\r
141 // System.out.println("I'm alive "+seqid+" "+jobid);
\r
145 catch (Exception ex)
\r
147 allowedServerExceptions--;
\r
148 wsInfo.appendProgressText("\n"+ServiceName+" Server exception!\n" + ex.getMessage());
\r
149 ex.printStackTrace();
\r
153 if (! (result!=null && (result.isJobFailed() || result.isServerError())))
\r
154 wsInfo.setStatus(WebserviceInfo.STATE_STOPPED_OK);
\r
156 wsInfo.setStatus(WebserviceInfo.STATE_STOPPED_ERROR);
\r
163 vamsas.objects.simple.WsJobId jobsubmit = server.align(seqs);
\r
164 if (jobsubmit.getStatus()==1) {
\r
165 System.out.println(jobId=jobsubmit.getJobId());
\r
167 throw new Exception(jobsubmit.getJobId());
\r
170 catch (Exception e)
\r
172 System.out.println(ServiceName + " Client: Failed to submit the prediction\n" +
\r
173 e.toString() + "\n");
\r
174 e.printStackTrace();
\r
178 private void addFloatAnnotations(Alignment al, int[] gapmap, Vector values, String Symname, String Visname, float min, float max, int winLength) {
\r
180 Annotation[] annotations = new Annotation[al.getWidth()];
\r
181 for (int j = 0; j < values.size(); j++)
\r
183 float value = Float.parseFloat(values.get(j).toString());
\r
184 annotations[gapmap[j]] = new Annotation("", value+"",' ',value);
\r
186 al.addAnnotation(new AlignmentAnnotation(Symname, Visname, annotations, min, max, winLength));
\r
188 private jalview.datamodel.Sequence[] getVamsasAlignment(vamsas.objects.simple.Alignment valign) {
\r
189 vamsas.objects.simple.Sequence[] seqs = valign.getSeqs().getSeqs();
\r
190 jalview.datamodel.Sequence[] msa = new jalview.datamodel.Sequence[seqs.length];
\r
191 for (int i=0, j=seqs.length; i<j;i++)
\r
192 msa[i] = new jalview.datamodel.Sequence(seqs[i].getId(), seqs[i].getSeq());
\r
197 SequenceI[] seqs=null;
\r
199 // OutputHeader = output.getText();
\r
200 if (result.isFailed()) {
\r
201 OutputHeader +="Job failed.\n";
\r
203 if (result.getStatus()!=null) {
\r
204 OutputHeader += "\n"+result.getStatus();
\r
206 if (result.getMsa()!=null) {
\r
207 OutputHeader += "\nAlignment Object Method Notes\n";
\r
208 String lines[] = result.getMsa().getMethod();
\r
209 for (int line=0;line<lines.length; line++)
\r
210 OutputHeader+=lines[line]+"\n";
\r
212 // JBPNote The returned files from a webservice could be hidden behind icons in the monitor window that, when clicked, pop up their corresponding data
\r
213 seqs = getVamsasAlignment(result.getMsa());
\r
216 wsInfo.setProgressText(OutputHeader);
\r
219 al = new Alignment(seqs);
\r
221 // TODO: JBPNote Should also rename the query sequence sometime...
\r
222 AlignFrame af = new AlignFrame(al);
\r
223 Desktop.addInternalFrame(af,
\r
224 ServiceName + " Alignment",
\r
225 AlignFrame.NEW_WINDOW_WIDTH,
\r
226 AlignFrame.NEW_WINDOW_HEIGHT);
\r
228 }catch(Exception ex){ex.printStackTrace();}
\r