X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fcom%2Findexdata%2Fmkjsf%2Fpazpar2%2Fcommands%2FPazpar2Command.java;h=c7bff40d40132cc3c1e12e34bf5257f20988f2d3;hb=45780ca51a3f1a967acda7c4d7d71aebe7081a67;hp=8176512bcccdf1d1548103b70a26e724ee6fa54e;hpb=2816078831605dbc1c18147760e1212dd30909a8;p=mkjsf-moved-to-github.git

diff --git a/src/main/java/com/indexdata/mkjsf/pazpar2/commands/Pazpar2Command.java b/src/main/java/com/indexdata/mkjsf/pazpar2/commands/Pazpar2Command.java
index 8176512..c7bff40 100644
--- a/src/main/java/com/indexdata/mkjsf/pazpar2/commands/Pazpar2Command.java
+++ b/src/main/java/com/indexdata/mkjsf/pazpar2/commands/Pazpar2Command.java
@@ -3,35 +3,82 @@ package com.indexdata.mkjsf.pazpar2.commands;
 import java.io.Serializable;
 import java.util.HashMap;
 import java.util.Map;
+import java.util.StringTokenizer;
 
 import org.apache.log4j.Logger;
 
+import com.indexdata.mkjsf.pazpar2.ClientCommandResponse;
+import com.indexdata.mkjsf.pazpar2.HttpResponseWrapper;
+import com.indexdata.mkjsf.pazpar2.Pz2Service;
+import com.indexdata.mkjsf.pazpar2.SearchClient;
 import com.indexdata.mkjsf.pazpar2.commands.sp.ServiceProxyCommand;
-import com.indexdata.mkjsf.pazpar2.state.StateManager;
+import com.indexdata.mkjsf.pazpar2.data.ResponseDataObject;
+import com.indexdata.mkjsf.pazpar2.data.ResponseParser;
+import com.indexdata.mkjsf.pazpar2.data.Responses;
 
 public abstract class Pazpar2Command implements Serializable  {
   
   private static Logger logger = Logger.getLogger(Pazpar2Command.class);
   private static final long serialVersionUID = -6825491856480675917L;   
   protected String name = "";
-  protected Map<String,CommandParameter> parameters = new HashMap<String,CommandParameter>();
+  protected Map<String,CommandParameter> parameters = new HashMap<String,CommandParameter>();  
   
-  protected StateManager stateMgr;
-    
-  public Pazpar2Command (String name, StateManager stateMgr) {
+  public Pazpar2Command () {    
+  }
+  
+  public void setCommandName(String name) {
     this.name = name;
-    this.stateMgr = stateMgr;
+  }
+          
+  public Pazpar2Command (String name) {
+    this.name = name;    
   }
       
   public abstract Pazpar2Command copy ();
-  
-  public String getName() {
+          
+  public String getCommandName() {
     return name;
   }
+  
+  public ResponseDataObject run() {    
+    return run(Pz2Service.get().getSearchClient(),
+               Pz2Service.get().getPzresp());
+  }
+  
+  public ResponseDataObject runWith(String... parameters) {
+    for (String parameter : parameters) {
+      StringTokenizer tokenizer = new StringTokenizer(parameter,"=");
+      String name = (String) tokenizer.nextElement();
+      String value = (String) tokenizer.nextElement();
+      CommandParameter commandParameter = new CommandParameter(name,"=",value);
+      setParameterInState(commandParameter);
+    }
+    return run();
+  }
+  
+  /**
+   * For running the command in a thread. Client and Responses must be 
+   * provided because at this point the CDI bean cannot be retrieved 
+   * from within a thread.
+   * 
+   * @param client
+   * @param pzresp
+   * @return
+   */
+  public ResponseDataObject run(SearchClient client,Responses pzresp) {
+    logger.debug("Running " + getCommandName() + " using " + client);    
+    HttpResponseWrapper httpResponse = client.executeCommand(this);
+    logger.debug("Parsing response for " + getCommandName());
+    ResponseDataObject responseObject = ResponseParser.getParser().getDataObject((ClientCommandResponse) httpResponse);
+    logger.trace("Storing response for " + getCommandName());
+    pzresp.put(getCommandName(), responseObject);
+    return responseObject;    
+  }
+  
     
   public void setParameter (CommandParameter parameter) {
     Pazpar2Command copy = this.copy();
-    logger.debug(name + " command: setting parameter [" + parameter.getName() + "=" + parameter.getValueWithExpressions() + "]");
+    logger.trace(name + " command: setting parameter [" + parameter.getName() + "=" + parameter.getValueWithExpressions() + "]");
     copy.parameters.put(parameter.getName(),parameter);
     checkInState(copy);
   }
@@ -39,7 +86,7 @@ public abstract class Pazpar2Command implements Serializable  {
   public void setParameters (CommandParameter... params) {
     Pazpar2Command copy = this.copy();
     for (CommandParameter param : params) {
-      logger.debug(name + " command: setting parameter [" + param.getName() + "=" + param.getValueWithExpressions() + "]");
+      logger.trace(name + " command: setting parameter [" + param.getName() + "=" + param.getValueWithExpressions() + "]");
       copy.parameters.put(param.getName(),param);
     }
     checkInState(copy);
@@ -47,13 +94,13 @@ public abstract class Pazpar2Command implements Serializable  {
   
   public void setParametersInState (CommandParameter... params) {    
     for (CommandParameter param : params) {
-      logger.debug(name + " command: setting parameter [" + param.getName() + "=" + param.getValueWithExpressions() + "] silently");
+      logger.trace(name + " command: setting parameter [" + param.getName() + "=" + param.getValueWithExpressions() + "] silently");
       parameters.put(param.getName(),param);
     }    
   }
     
   public void setParameterInState (CommandParameter parameter) {
-    logger.debug(name + " command: setting parameter [" + parameter.getName() + "=" + parameter.getValueWithExpressions() + "] silently");
+    logger.trace(name + " command: setting parameter [" + parameter.getName() + "=" + parameter.getValueWithExpressions() + "] silently");
     parameters.put(parameter.getName(),parameter);    
   }
   
@@ -124,8 +171,7 @@ public abstract class Pazpar2Command implements Serializable  {
   }
 
   public String getParameterValue(String parameterName) {
-    return getParameter(parameterName)==null ? "" : getParameter(parameterName).getValueWithExpressions();
-    
+    return getParameter(parameterName)==null ? "" : getParameter(parameterName).getValueWithExpressions();    
   }
 
   public String getUrlEncodedParameterValue(String parameterName) {
@@ -141,13 +187,14 @@ public abstract class Pazpar2Command implements Serializable  {
   } 
   
   private void checkInState(Pazpar2Command command) {
-    if (stateMgr != null) {
-      stateMgr.checkIn(command);
-    } else {
-      logger.info("Command '" + command.getName() + "' not affecting state (history) as no state manager was defined for this command.");
-    }
+    Pz2Service.get().getStateMgr().checkIn(command);
   }
   
-  public abstract ServiceProxyCommand getSp();
+  public String navigateTo (String target) {
+    return target;
+  }
   
+  public abstract ServiceProxyCommand getSp();
+   
+  public abstract boolean spOnly();  
 }