X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;ds=sidebyside;f=src%2Fmain%2Fjava%2Fcom%2Findexdata%2Fmkjsf%2Fpazpar2%2Fcommands%2FRecordCommand.java;h=53068198b47de460d3e0ac59692e512bd8361067;hb=0c500bea459cf05157e0f753755466ce1b46604c;hp=028b0d5160078b07f9c014af1e97da88f3da95b5;hpb=78cce328039810027616b0dfe4fb3362f5b573af;p=mkjsf-moved-to-github.git diff --git a/src/main/java/com/indexdata/mkjsf/pazpar2/commands/RecordCommand.java b/src/main/java/com/indexdata/mkjsf/pazpar2/commands/RecordCommand.java index 028b0d5..5306819 100644 --- a/src/main/java/com/indexdata/mkjsf/pazpar2/commands/RecordCommand.java +++ b/src/main/java/com/indexdata/mkjsf/pazpar2/commands/RecordCommand.java @@ -1,75 +1,183 @@ package com.indexdata.mkjsf.pazpar2.commands; +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.commands.sp.RecordCommandSp; import com.indexdata.mkjsf.pazpar2.commands.sp.ServiceProxyCommand; -import com.indexdata.mkjsf.pazpar2.state.StateManager; +import com.indexdata.mkjsf.pazpar2.data.RecordResponse; +import com.indexdata.mkjsf.pazpar2.data.ResponseDataObject; +import com.indexdata.mkjsf.pazpar2.data.ResponseParser; +/** + * record Pazpar2 command, referenced as: pzreq.record + * + * @author Niels Erik + * + */ public class RecordCommand extends Pazpar2Command implements ServiceProxyCommand { private static final long serialVersionUID = 2817539422114569506L; + private static Logger logger = Logger.getLogger(RecordCommand.class); + private RecordCommandSp spCommand = null; - public RecordCommand(StateManager stateMgr) { - super("record",stateMgr); + public RecordCommand() { + super("record"); } + /** + * Special handling of record responses since they come in three distinctly different ways + *
    + *
  1. As a regular <record> document
  2. + *
  3. In arbitrary XML format, in case of an offset request to get the native format
  4. + *
  5. In binary (non XML) format
  6. + *
+ */ + @Override + public ResponseDataObject run() { + ResponseDataObject responseObject = null; + if (hasParameterValue("id")) { + HttpResponseWrapper commandResponse = Pz2Service.get().getSearchClient().executeCommand(this); + + if (commandResponse.getContentType().contains("xml")) { + responseObject = ResponseParser.getParser().getDataObject((ClientCommandResponse)commandResponse); + if (ResponseParser.docTypes.contains(responseObject.getType())) { + logger.debug("Storing " + responseObject.getType() + " in pzresp. "); + } else { + logger.debug("Command was 'record' but response not '' - assuming raw record response."); + ResponseDataObject recordResponse = new RecordResponse(); + recordResponse.setType("record"); + recordResponse.setXml(responseObject.getXml()); + recordResponse.setAttribute("activeclients", "0"); + responseObject = recordResponse; + } + } else if (commandResponse.isBinary()) { + responseObject = new RecordResponse(); + responseObject.setType(getCommandName()); + logger.info("Binary response"); + responseObject.setAttribute("activeclients", "0"); + responseObject.setXml("binary response"); + responseObject.setBinary(commandResponse.getBytes()); + } else { + logger.error("Response was not found to be XML or binary. The response was not handled."); + } + Pz2Service.get().getPzresp().put(getCommandName(), responseObject); + } else { + logger.debug("No record id parameter on this command. Ignoring request but clearing any previous record result."); + Pz2Service.get().getPzresp().put(getCommandName(), new RecordResponse()); + } + return responseObject; + } + + /** + * Sets the id parameter. See Pazpar2 documentation for details. + * + * @param recId record ID + */ public void setId(String recId) { setParameter(new CommandParameter("id","=",recId)); } - + + /** + * Returns the id parameter value. + */ public String getId () { return getParameterValue("id"); } - + + /** + * Sets the offset parameter. See Pazpar2 documentation for details. + */ public void setOffset (String offset) { setParameter(new CommandParameter("offset","=",offset)); } - + + /** + * Returns the offset parameter value. + */ public String getOffset () { return getParameterValue("offset"); } + /** + * Sets the checksum parameter. See Pazpar2 documentation for details. + */ public void setChecksum (String checksum) { setParameter(new CommandParameter("checksum","=",checksum)); } + /** + * Returns the checksum parameter value. + */ public String getChecksum () { return getParameterValue("checksum"); } + /** + * Sets the nativesyntax parameter. See Pazpar2 documentation for details. + */ public void setNativesyntax (String nativesyntax) { setParameterInState(new CommandParameter("nativesyntax","=",nativesyntax)); } + /** + * Returns the nativesyntax parameter value. + */ public String getNativesyntax () { return getParameterValue("nativesyntax"); } + /** + * Sets the syntax parameter. See Pazpar2 documentation for details. + */ public void setSyntax (String syntax) { setParameterInState(new CommandParameter("syntax","=",syntax)); } + /** + * Returns the syntax parameter value. + */ public String getSyntax () { return getParameterValue("syntax"); } + /** + * Sets the esn parameter. See Pazpar2 documentation for details. + */ public void setEsn (String esn) { setParameter(new CommandParameter("esn","=",esn)); } + /** + * Returns the esn parameter value. + */ public String getEsn () { return getParameterValue("esn"); } + /** + * Sets the binary parameter. See Pazpar2 documentation for details. + */ public void setBinary (String binary) { setParameter(new CommandParameter("binary","=",binary)); } + + /** + * Returns the binary parameter value. + */ + public String getBinary () { + return getParameterValue("binary"); + } @Override public RecordCommand copy () { - RecordCommand newCommand = new RecordCommand(stateMgr); + RecordCommand newCommand = new RecordCommand(); for (String parameterName : parameters.keySet()) { newCommand.setParameterInState(parameters.get(parameterName).copy()); } + newCommand.spCommand = new RecordCommandSp(newCommand); return newCommand; } @@ -79,6 +187,14 @@ public class RecordCommand extends Pazpar2Command implements ServiceProxyCommand * */ public RecordCommandSp getSp () { - return new RecordCommandSp(this); + if (spCommand==null) { + spCommand = new RecordCommandSp(this); + } + return spCommand; + } + + @Override + public boolean spOnly() { + return false; } }