Basic Call of HELIO Coordinate Transformation Service

Script

/*
 * $Header: 
 * $Revision$
 * $Date$
 * ====================================================================
 *
 *  Copyright 2002-2004 The Apache Software Foundation
 *
 *  Licensed under the Apache License, Version 2.0 (the "License");
 *  you may not use this file except in compliance with the License.
 *  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 *  Unless required by applicable law or agreed to in writing, software
 *  distributed under the License is distributed on an "AS IS" BASIS,
 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *  See the License for the specific language governing permissions and
 *  limitations under the License.
 * ====================================================================
 *
 * This software consists of voluntary contributions made by many
 * individuals on behalf of the Apache Software Foundation.  For more
 * information on the Apache Software Foundation, please see
 * .
 *
 * [Additional notices, if required by prior licensing conditions]
 *
 */

import java.io.File;
import java.io.FileInputStream;
import org.apache.commons.httpclient.Header;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.HttpStatus;
import org.apache.commons.httpclient.methods.GetMethod;
import org.apache.commons.httpclient.methods.StringRequestEntity;
import org.apache.commons.httpclient.methods.PostMethod;
import java.util.ArrayList;
import java.net.URI;
    
        
    /**
     * 
     * @param strURL
     * @param append
     * @return
     * @throws Exception
    */
    private static String[] getResults(String strURL,String append) throws Exception{
    	if(append!=null && !append.trim().equals("")){
			strURL=strURL+"/"+append;
        }
    	 System.out.print(" --------> Location --------> "+strURL);
    	 //PostMethod post = new PostMethod(strURL);
    	 GetMethod get = new GetMethod(strURL);
    	 get.setFollowRedirects(false); 
    	 //post.setParameter("phase", "RUN");
    	 //NameValuePair action   = new NameValuePair("PHASE", "RUN");
         //post.setRequestBody( new NameValuePair[] {action});
         // Get HTTP client
         HttpClient httpclient = new HttpClient();
         int result = httpclient.executeMethod(get);
         int statuscode = get.getStatusCode();
         String results=get.getResponseBodyAsString();
         System.out.println(results);
         //ArrayList resArr = new ArrayList();
         ArrayList resArr = new ArrayList();
         if(results!=null && !results.equals("")){
         	while(results.indexOf("xlink:href") >= 0) {
        		resArr.add(results.substring(results.indexOf("xlink:href")+12,results.indexOf("\"",results.indexOf("xlink:href")+12)));
        		System.out.println("Placed in arr = " + (results.substring(results.indexOf("xlink:href")+12,results.indexOf("\"",results.indexOf("xlink:href")+12)))   );
        		results = results.substring(results.indexOf("xlink:href")+12);
        		System.out.println("new results = " + results);
        	 
        	}
        	 
         }
         return (String [])resArr.toArray(new String[0]);
    }
    /**
     * 
     * @param strURL
     * @param append
     * @return
     * @throws Exception
    */
    private static String getPhase(String strURL,String append) throws Exception{
    	if(append!=null && !append.trim().equals("")){
			strURL=strURL+"/"+append;
        }
    	 System.out.print(" ----------> Location ----------> "+strURL);
    	 //PostMethod post = new PostMethod(strURL);
    	 GetMethod get = new GetMethod(strURL);
    	 get.setFollowRedirects(false); 
    	 //post.setParameter("phase", "RUN");
         // Get HTTP client
         HttpClient httpclient = new HttpClient();
         int result = httpclient.executeMethod(get);
         return get.getResponseBodyAsString();
    }
    /**
     * @param strURL
     * @param append
     * @throws Exception
    */
    private static void abortJob(String strURL,String append) throws Exception{
    	 if(append!=null && !append.trim().equals("")){
			strURL=strURL+"/"+append;
         }
    	 //Post 
    	 PostMethod post = new PostMethod(strURL);
    	 post.setFollowRedirects(false); 
    	 post.setParameter("phase", "ABORT");
         // Get HTTP client
         HttpClient httpclient = new HttpClient();
         int result = httpclient.executeMethod(post);
         int statuscode = post.getStatusCode();
         System.out.println(post.getResponseBodyAsString());
    }
    /**
     * 
     * @param strURL
     * @param append
     * @throws Exception
    */
    private static void executeJob(String strURL,String append) throws Exception{
    	if(append!=null && !append.trim().equals("")){
			strURL=strURL+"/"+append;
        }
    	 PostMethod post = new PostMethod(strURL);
    	 post.setFollowRedirects(false); 
    	 post.setParameter("phase", "RUN");
    	 //
    	 HttpClient httpclient = new HttpClient();
         int result = httpclient.executeMethod(post);
         int statuscode = post.getStatusCode();
         System.out.println(post.getResponseBodyAsString());
    }
    /**
     * @param filename
     * @param strURL
     * @param append
     * @return
     * @throws Exception
     */
	private static String getDetails(String property ,String strURL,String append) throws Exception{
		// Prepare HTTP post
        PostMethod post = new PostMethod(strURL);
        // Request content will be retrieved directly
        // from the input stream
        // Per default, the request content needs to be buffered
        // in order to determine its length.
        // Request body buffering can be avoided when
        // content length is explicitly specified
        
        post.setRequestEntity(new StringRequestEntity(
                property, "text/xml", "ISO-8859-1"));
        post.setRequestHeader(
                "Content-type", "text/xml; charset=ISO-8859-1");
    
        post.setFollowRedirects(false); 
        // Get HTTP client
        HttpClient httpclient = new HttpClient();
        
        try {
            //httpclient.
            int result = httpclient.executeMethod(post);
            int statuscode = post.getStatusCode();
       
            if ((statuscode == HttpStatus.SC_MOVED_TEMPORARILY) ||
                    (statuscode == HttpStatus.SC_MOVED_PERMANENTLY) ||
                    (statuscode == HttpStatus.SC_SEE_OTHER) ||
                    (statuscode == HttpStatus.SC_TEMPORARY_REDIRECT))
                {
            	
                    Header header = post.getResponseHeader("location");
                    System.out.println("   :  Header  :  "+header);
                    if (header != null)
                    {
                        newuri = header.getValue();
                        if ((newuri == null) || (newuri.equals("")))
                            newuri = "/";
		     System.out.println("   :  newuri  :  "+newuri);
                       return newuri;
                       }
                    else{
                    	return null;
                    }
                }else{
                	System.out.println(post.getResponseBodyAsString());
                }
        } finally {
            // Release current connection to the connection pool 
            // once you are done
            post.releaseConnection();
        }
        return null;
	}


    /**
     * 	Usage:
     *       java PostXML http://mywebserver:80/ c:\foo.xml
     *
     * 	@param args command line arguments
     *         Argument 0 is a URL to a web server
     *         Argument 1 is a local filename
    **/
        
        String strURL = arg1;
        String strProperty = arg0;
        out = new String("");
        String newuri;

	long start = System.currentTimeMillis();
        System.out.println(" : URL : "+strURL);
        System.out.println("-------> getting location ------->");
        String location=getDetails(strProperty,strURL,"");
        System.out.println("------->Location ------->"+location);
        System.out.println("-------> Executing the job ------->");
        if(location == null) location = newuri;
        executeJob(location,"phase");   
        System.out.println("-------> Done ------->");  
        //Thread.sleep(1000);
        System.out.println("-------> Getting phase ------->");
        String sPhase=null;
        int count=0;
        do{
        	//getting phase
 		System.out.println(" Checking if completed ");
        	sPhase=getPhase(location,"phase");
        	count++;
        	if(count==40){
        	   System.out.println("-------> Aborting the job, Exection occurred ------->");
        	   abortJob(location,"phase");
        	}
	      if(Thread.interrupted()){
		throw new Exception("Thread intrruped occured");
	      }

               if(sPhase.contains("ERROR")) {
                  throw new Exception("service finished in state ERROR");
               }

                if(!sPhase.contains("COMPLETED")) {
        	  Thread.sleep(1000);
 		}
        }while(!sPhase.contains("COMPLETED"));
        System.out.println("");
        System.out.println("");
        System.out.println("");
        System.out.println("");
        System.out.println("-------> Phase of executing ------->"+sPhase);
        System.out.println("");
        System.out.println("");
        String []sResult=null;
        //getting result
        if(sPhase.contains("COMPLETED")){
        	 sResult=getResults(location,"results");
        }
        System.out.println("-------> Result of the executing ------->");
	System.out.println("ID: " + location.substring(location.lastIndexOf("/")));
	System.out.println("Jobs Location: " + strURL.substring(0,strURL.indexOf("uws")) +  "jobs" + location.substring(location.lastIndexOf("/")) + "/");
	out=strURL.substring(0,strURL.indexOf("uws")) +  "jobs" + location.substring(location.lastIndexOf("/")) + "/";
         System.out.println(strURL.substring(0,strURL.indexOf("uws")) +  "jobs" + location.substring(location.lastIndexOf("/")) + "/");
        //for(int k=0;k < sResult.length;k++) {
	//        System.out.println("Resulting URL "+ domain + sResult[k]);
	//    }

	 System.out.println("Time taken for Java app: " + (System.currentTimeMillis() - start));

Value

Script

output = string1 + string2;

Value

Script

if ((url == void) || (url == null)) {
	throw new RuntimeException("The url must be specified");
}

URL inputURL = null;
if (base != void) {
  inputURL = new URL(new URL(base), url);
}
else {
  inputURL = new URL(url);
}
URLConnection con = inputURL.openConnection();
InputStream in = con.getInputStream();

StringBuffer result = new StringBuffer();
BufferedReader reader;

String encoding = con.getContentEncoding();
if (encoding == null) {
  reader = new BufferedReader(new InputStreamReader(in));
} else {
  reader = new BufferedReader(new InputStreamReader(in, encoding));
}
String line = null;
String NEWLINE = System.getProperty("line.separator");
while ((line = reader.readLine()) != null) {
	result.append(line);
	result.append(NEWLINE);
}

reader.close();
contents = result.toString();

Script

import org.apache.commons.lang.StringEscapeUtils;

String inputRep="";
if(inRep.trim().compareTo("RTP")==0){
  inputRep="   \n"+
  "   	\n"+
  "   \n\n";	
}

String outputRep="";
if(outRep.trim().compareTo("RTP")==0){
  outputRep="   \n"+
  "   	\n"+
  "   \n\n";
}

String part1 ="\n"+
  "\n\n"+ 
  " \n"+
  "   \n"+
  "   	\n";

String part2 = "\n\n"+
  "   \n\n"+
  "   \n"+
  "   	"+inCoordinate+"\n"+
  "   \n\n" +
  "   \n"+
  "   	"+outCoordinate+"\n"+
  "   \n\n" + inputRep + outputRep +
  " \n"+
  "";

config=part1 +""+ part2;