import uk.org.ogsadai.client.Util;
import uk.org.ogsadai.client.toolkit.GenericServiceFetcher;
import uk.org.ogsadai.client.toolkit.Response;
import uk.org.ogsadai.client.toolkit.activity.ActivityRequest;
import uk.org.ogsadai.client.toolkit.activity.delivery.DeliverFromURL;
import uk.org.ogsadai.client.toolkit.activity.delivery.DeliverToGFTP;
import uk.org.ogsadai.client.toolkit.activity.delivery.DeliverToURL;
import uk.org.ogsadai.client.toolkit.activity.sql.SQLQuery;
import uk.org.ogsadai.client.toolkit.activity.sql.WebRowSet;
import uk.org.ogsadai.client.toolkit.activity.transform.XSLTransform;
import uk.org.ogsadai.client.toolkit.security.wsrf.GSITransportEncryptionProperty;
import uk.org.ogsadai.client.toolkit.service.DataService;


public class xmltocsv 
{

    //register transport security
    static
    {
	Util.registerTransport();
    }

    
    public static void main(String[] args) throws Exception 
    {
       
	 if(!Util.isRegistered())
	{
	    System.out.println(Util.getRegistrationErrorMessage() + Util.getRegistrationException());
	    return;
	}

        String handle = "https://romeo.urz.tu-dresden.de:8443/wsrf/services/ogsadai/MyService";
	String id = "MyPQSPSIMAP169";
        DataService service = GenericServiceFetcher.getInstance().getDataService(handle,id);
        
        //Setup encryption
	service.setConnectionProperty(new GSITransportEncryptionProperty());
	System.out.println("Ready to connect to secure data service at " + service.getURL());
        
        // Create a deliverToURL object
        DeliverToGFTP deliverto = new DeliverToGFTP(  "romeo.urz.tu-dresden.de",2811,"/tmp/mytext.csv" );

        // Create a deliverFromURL object
        DeliverFromURL deliverfrom = new DeliverFromURL( "http://141.76.17.139:8080/tutorial/csvtransform.xsl" );

        // Construct a query
        SQLQuery query  = new SQLQuery("SELECT * FROM if_string limit 100") ;
        WebRowSet rowset = new WebRowSet(query.getOutput());        
        
        // Construct the transformation activity
        XSLTransform transform = new XSLTransform();
        transform.setXMLInput( rowset.getOutput() );
        transform.setXSLTInput( deliverfrom.getOutput() );
                   
        deliverto.setInput(transform.getOutput());
        
        //Construct the request
        ActivityRequest request = new ActivityRequest();
        request.add(deliverfrom);
        request.add(query);
        request.add(rowset);
        request.add(transform);
        request.add(deliverto);
        
        System.out.println("Performing request...");
        Response response = service.perform( request );

        System.out.println(response);
        
        service.terminate();
              
      }
}