source: MDService2/trunk/MDService2/src/eu/clarin/cmdi/mdservice/action/MDRepoProxyAction.java @ 466

package eu.clarin.cmdi.mdservice.action;

import java.io.ByteArrayInputStream;
import java.io.InputStream;
import java.net.URL;
import java.util.HashMap;

import com.opensymphony.xwork2.ActionSupport;

import eu.clarin.cmdi.mdservice.model.Query;
import eu.clarin.cmdi.mdservice.model.Result;

/**
 * Main Struts 2 controller 
 * responds to requests (collections, model, recordset) 
 * by dispatching the requests to appropriate internal methods and filling the inputStream with the result
 *  
 * @author vronk
 *
 */
public class MDRepoProxyAction extends GenericProxyAction {

        private static final long serialVersionUID = 1L;

        private String proxy_key = "mdrepository";
        
        @Override
        public String getProxyKey() {
                return proxy_key;
        }
        
        private final static HashMap<String,String> urls = new HashMap<String,String>();
         static
         {       urls.put("collection", "?operation=getCollections&collection=");
                 urls.put("model", "?q=");
                 urls.put("recordset", "?operation=searchRetrieve&query=");
         } 
                
        /**
         * uses base_url + url_pattern (parametrized by actionkey) to form a url
         * @return the URL to the component-file
         * @throws Exception 
         */
        public URL getTargetRequest() throws Exception {
        // URL targetURL =new URL( base_url, compname + ".xml");
                
                Admin.notifyUser("MDRPA.getQ:" + getQ());
                Admin.notifyUser("MDRPA.getActionkey:" + getActionkey());
                Admin.notifyUser("MDRPA.getMaxdepth:" + getMaxdepth());
                
                Query query = new Query(getQ(),getActionkey());
                if (query.isStatus(Query.PARSEERROR)) {
                        Admin.notifyUser("MDRPA.query.PARSEERROR:" + query.getMsg());
                        // pass this bad news to the client
                        setUserMsg(query.getMsg());
                        return null;
                } else {
                        query.setMaxdepth(getMaxdepth());               
                        URL targetURL = null;           
                        
                        targetURL =new URL( getBaseURL(), urls.get(getActionkey()) + query.toURLParam() );
                        Admin.notifyUser("MDRPA.targetURL:" + targetURL);
                return targetURL;
                }
        }

        
/* 
 * FOLLOWING ARE OBSOLETE METHODS 
 * for processing the requests and serving the results
 * they stay here for reference (as bad examples) temporarily
 * and can/shall be removed in the near future. 
 */
        
/**
 * serves the collections, passes the Request to MDRepositoryProxy
 * @return
 * @throws Exception
 */
        /*
        public String collections() throws Exception {
        
                Query query = new Query(getQ(),Query.COLLECTIONS);
                
//               inputStream = getMDRepo().getCollections(query);
                 
                return SUCCESS;
        }
*/
        /**
         * serves the model/terms, via Query.execute() and .getResult()
         * @return
         * @throws Exception
         */
/*
        public String model() throws Exception {
                
                Query query = new Query(getQ(), Query.MODEL, getCollection());
                        Admin.notifyUser(query.getTargetRequest().toString());
                        query.setMaxdepth(getMaxdepth());
                query.execute();                                
                        
                //inputStream = query.getResult().getResultStream(format);
                return SUCCESS;
        }
*/
        /**
         * the method for actual querying of MDRepository 
         * and getting back the MD-recordset
         * using Query-object (not asking MDRepository yet)
         *    
         * @return
         * @throws Exception
         */     
        /*
        public String recordset() throws Exception {
                
                Query query = new Query(getQ(), Query.RECORDSET, getCollection());
                        
                        Admin.notifyUser("recordset_target_uri:" + query.getTargetRequest().toString());                
                        query.execute();                                

//              String str =query.getResult().getHeader();              
                 
//              inputStream = new ByteArrayInputStream(str.getBytes());

//              inputStream = query.getResult().getResultStream(format);
                return SUCCESS;
                 
        }
        */
}