src/main/java/com/indexdata/mkjsf/pazpar2/ServiceProxyExtensions.java

   1 package com.indexdata.mkjsf.pazpar2;\r
   2 \r
   3 import java.io.IOException;\r
   4 import java.io.Serializable;\r
   5 import java.io.UnsupportedEncodingException;\r
   6 \r
   7 import javax.enterprise.context.SessionScoped;\r
   8 import javax.inject.Inject;\r
   9 import javax.inject.Named;\r
  10 \r
  11 import org.apache.log4j.Logger;\r
  12 import org.apache.myfaces.custom.fileupload.UploadedFile;\r
  13 \r
  14 import com.indexdata.mkjsf.config.ConfigurationReader;\r
  15 import com.indexdata.mkjsf.pazpar2.commands.CommandParameter;\r
  16 import com.indexdata.mkjsf.pazpar2.commands.Pazpar2Commands;\r
  17 import com.indexdata.mkjsf.pazpar2.commands.sp.AuthCommand;\r
  18 import com.indexdata.mkjsf.pazpar2.commands.sp.InitDocUpload;\r
  19 import com.indexdata.mkjsf.pazpar2.data.ResponseDataObject;\r
  20 import com.indexdata.mkjsf.pazpar2.data.ResponseParser;\r
  21 import com.indexdata.mkjsf.pazpar2.data.Responses;\r
  22 import com.indexdata.mkjsf.pazpar2.data.sp.AuthResponse;\r
  23 import com.indexdata.mkjsf.pazpar2.data.sp.CategoriesResponse;\r
  24 import com.indexdata.mkjsf.utils.Utils;\r
  25 \r
  26 @Named("pz2x") @SessionScoped\r
  27 public class ServiceProxyExtensions implements ServiceProxyInterface, Serializable {\r
  28     \r
  29   private static final long serialVersionUID = 4221824985678758225L;\r
  30   private static Logger logger = Logger.getLogger(ServiceProxyExtensions.class);  \r
  31   private String initDocFileName = "";\r
  32   private String initDocResponse = "";  \r
  33   private InitDocUpload initDocUpload; \r
  34     \r
  35   @Inject ConfigurationReader configurator;  \r
  36   @Inject Pz2Bean pz2;\r
  37   @Inject Pazpar2Commands pzreq;\r
  38   @Inject Responses pzresp;\r
  39 \r
  40   \r
  41   public ServiceProxyExtensions() {\r
  42     this.initDocUpload = new InitDocUpload(this);\r
  43     // TODO: \r
  44     //stateMgr.addStateListener(this);\r
  45   }\r
  46    \r
  47 \r
  48   \r
  49   public void login(String un, String pw) {\r
  50       logger.info("doing un/pw login");\r
  51       pzreq.getSp().getAuth().setUsername(un);\r
  52       pzreq.getSp().getAuth().setPassword(pw);\r
  53       login("");\r
  54   }\r
  55 \r
  56 \r
  57   \r
  58   @Override  \r
  59   public String login(String navigateTo) {\r
  60     logger.info("doing login using " + pz2 + " and client " + pz2.getSpClient());\r
  61     pz2.resetSearchAndRecordCommands();\r
  62     pzresp.getSp().resetAuthAndBeyond(true);\r
  63     AuthCommand auth = pzreq.getSp().getAuth(); \r
  64     auth.setParameterInState(new CommandParameter("action","=","login"));\r
  65     ClientCommandResponse commandResponse = pz2.getSpClient().send(auth);\r
  66     String renamedResponse = renameResponseElement(commandResponse.getResponseString(), "auth");\r
  67     commandResponse.setResponseToParse(renamedResponse);\r
  68     AuthResponse responseObject = (AuthResponse) ResponseParser.getParser().getDataObject(commandResponse);\r
  69     if (ResponseParser.docTypes.contains(responseObject.getType())) {\r
  70       pzresp.put(auth.getCommandName(), responseObject);\r
  71     }\r
  72     String responseStr = commandResponse.getResponseString();\r
  73     logger.info(responseStr);      \r
  74     return navigateTo;\r
  75   }\r
  76   \r
  77   \r
  78   public void ipAuthenticate () {  \r
  79     pz2.resetSearchAndRecordCommands();\r
  80     pzresp.getSp().resetAuthAndBeyond(true);\r
  81     AuthCommand auth = pzreq.getSp().getAuth(); \r
  82     auth.setParameterInState(new CommandParameter("action","=","ipAuth"));\r
  83     ClientCommandResponse commandResponse = pz2.getSpClient().send(auth);      \r
  84     String renamedResponse = renameResponseElement(commandResponse.getResponseString(), "auth");\r
  85     commandResponse.setResponseToParse(renamedResponse);\r
  86     ResponseDataObject responseObject = ResponseParser.getParser().getDataObject(commandResponse);\r
  87     if (ResponseParser.docTypes.contains(responseObject.getType())) {\r
  88       pzresp.put(auth.getCommandName(), responseObject);\r
  89     }\r
  90     String responseStr = commandResponse.getResponseString();\r
  91     logger.info(responseStr);      \r
  92   }\r
  93   \r
  94   private String renameResponseElement(String responseString, String newName) {\r
  95     responseString = responseString.replace("<response>", "<" + newName + ">");\r
  96     responseString = responseString.replace("</response>", "</" + newName + ">");\r
  97     return responseString;\r
  98   }\r
  99     \r
 100   public String getInitDocPath () {\r
 101     return pz2.getSpClient().getConfiguration().get("INIT_DOC_PATH");\r
 102   }\r
 103   \r
 104   @Override\r
 105   public void setInitFileName(String fileName) {\r
 106     this.initDocFileName = fileName;\r
 107     \r
 108   }\r
 109 \r
 110   @Override\r
 111   public String getInitFileName() {\r
 112     return initDocFileName;\r
 113   }\r
 114 \r
 115   @Override\r
 116   public ClientCommandResponse postInit() throws UnsupportedEncodingException, IOException {    \r
 117     String initDocPath = pz2.getSpClient().getInitDocPaths().get(0);\r
 118     logger.info("Paths: " + pz2.getSpClient().getInitDocPaths());\r
 119     logger.info("Path: " + initDocPath);   \r
 120     pz2.resetSearchAndRecordCommands();\r
 121     pzresp.getSp().resetAuthAndBeyond(true);\r
 122     ClientCommandResponse response = pz2.getSpClient().postInitDoc(initDocPath + getInitFileName());    \r
 123     return response;\r
 124   }\r
 125   \r
 126   @Override\r
 127   public HttpResponseWrapper postInit(byte[] initDoc, boolean includeDebug) throws UnsupportedEncodingException, IOException {    \r
 128     pz2.resetSearchAndRecordCommands();\r
 129     pzresp.getSp().resetAuthAndBeyond(true);\r
 130     HttpResponseWrapper response = pz2.getSpClient().postInitDoc(initDoc,includeDebug);    \r
 131     return response;\r
 132   }\r
 133 \r
 134   @Override\r
 135   public String getInitResponse() {\r
 136     return initDocResponse;\r
 137   }\r
 138   \r
 139   public void setUploadedInitDoc (UploadedFile uploadedFile) {\r
 140     initDocUpload.setUploadedFile(uploadedFile);\r
 141   }\r
 142   \r
 143   public UploadedFile getUploadedInitDoc () {\r
 144     return initDocUpload.getUploadedFile();\r
 145   }\r
 146   \r
 147   public void submitInitDoc () throws IOException {\r
 148     ClientCommandResponse response =  (ClientCommandResponse) initDocUpload.submit();\r
 149     ResponseDataObject responseObject = ResponseParser.getParser().getDataObject(response);\r
 150     logger.info("Putting init response to : " + Utils.objectId(pzresp));\r
 151     pzresp.put("init", responseObject);\r
 152   }\r
 153   \r
 154   public void setIncludeInitDocDebug(boolean bool) {\r
 155     logger.info(Utils.objectId(this) + " setting debug to " + bool);\r
 156     initDocUpload.setIncludeDebug(bool);\r
 157   }\r
 158 \r
 159   public boolean getIncludeInitDocDebug() {\r
 160     return initDocUpload.getIncludeDebug();\r
 161   }\r
 162   \r
 163   // TODO: Remove when obsolete\r
 164   public InitDocUpload getInitDocUpload () {\r
 165     return initDocUpload;\r
 166   }\r
 167   \r
 168   public CategoriesResponse getCategories () {\r
 169     if (pz2.isServiceProxyService()) {\r
 170       ResponseDataObject response = pz2.doCommand("categories");\r
 171       if (response.hasApplicationError()) {\r
 172         logger.debug(response.getXml());\r
 173         return new CategoriesResponse();\r
 174       } else {\r
 175         try {\r
 176           return (CategoriesResponse) response;\r
 177         } catch (Exception e) {\r
 178           e.printStackTrace();\r
 179           logger.debug(response.getXml());\r
 180           return new CategoriesResponse();\r
 181         }\r
 182       }\r
 183     } else {\r
 184       return new CategoriesResponse();\r
 185     }\r
 186   }\r
 187   \r
 188   \r
 189 }\r