source: MDService2/branches/MDService_simple3/src/eu/clarin/cmdi/mdservice/action/RepoAction.java @ 1623

package eu.clarin.cmdi.mdservice.action;

import java.net.URL;

import org.apache.log4j.Logger;
import eu.clarin.cmdi.mdservice.model.Diagnostic;
import eu.clarin.cmdi.mdservice.model.Query;
import eu.clarin.cmdi.mdservice.model.WorkspaceProfile;
import eu.clarin.cmdi.mdservice.proxy.MDRepoProxy;
import eu.clarin.cmdi.mdservice.proxy.Pz2Proxy;
import eu.clarin.cmdi.mdservice.proxy.SRUProxy;

/**
 * A Struts2 controller, responsible for calls to repositories.
 * After 2011-09 rework Action and Proxy are decoupled.
 * So Action calls appropriate Proxy based upon the target repository type
 * 
 * responds to requests (collections, model, recordset) 
 * by dispatching the requests to appropriate Proxy and filling the inputStream with the result
 * It is possible to switch target-repository dynamically  (on every request). I.e. the client explicitly selects one of the repositories.
 *
 *  
 * @author vronk
 */
public class RepoAction extends GenericAction 
{

        private static final long serialVersionUID = 1L;
        private static Logger log = Logger.getLogger("RepoAction");
        
        protected URL base_url ;
        Query query;
        
        @Override
        public String getFullFormat() {         
                return getActionkey() + "2" + getFormat();
        }

        @Override
        @SuppressWarnings("unchecked")
        protected void loadParams() {   
                super.loadParams();
                query = new Query(getActionkey(), this.getParams());
        }
        /**
         * Based on the repository type - we create a typed Proxy, that will do the work.
         * If the type is not recognized - that is a bad user error    
         */
        public void setTargetProxy(){
                                                
                        if (getRepository()==null) {
                                getDiagnostics().Add(Diagnostic.MANDATORY_NOTSUPPLIED, "repository", "");
                                return;
                        }
                        
                        if (!WorkspaceProfile.repositoryExists(getRepository())){
                                getDiagnostics().Add(Diagnostic.UNSUPPORTED_PARAMETERVALUE, "repository", "repository=" + getRepository() );
                                return;
                        }
                        //Query query = new Query();
                        switch (WorkspaceProfile.RepositoryType.toRepositoryType(WorkspaceProfile.getRepositoryType(getRepository())))
                        {               
                            case PAZPAR: 
                                setTargetProxy(new Pz2Proxy());
                                return;
                            case SRU:
                                setTargetProxy(new SRUProxy(query));
                                return;
                            case MD:
                                setTargetProxy(new MDRepoProxy(query));
                                return;
                            default:
                                //TODO error  = bad workspaceProfile configuration
                                getDiagnostics().Add(Diagnostic.SYSTEM_ERROR, "Error in workspaceprofile configuration", "repository=" + getRepository() );
                        }
        }

}