X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fcom%2Findexdata%2Fmkjsf%2Fpazpar2%2FServiceProxyExtensions.java;h=d11a55b94b923b45b23c11d1be441b160e7de818;hb=45780ca51a3f1a967acda7c4d7d71aebe7081a67;hp=0ee282552ee8981e62318d86021e9396aea62be3;hpb=bcb39bd9bde8071ac3a6741ce5d51ed9e763ba9c;p=mkjsf-moved-to-github.git diff --git a/src/main/java/com/indexdata/mkjsf/pazpar2/ServiceProxyExtensions.java b/src/main/java/com/indexdata/mkjsf/pazpar2/ServiceProxyExtensions.java index 0ee2825..d11a55b 100644 --- a/src/main/java/com/indexdata/mkjsf/pazpar2/ServiceProxyExtensions.java +++ b/src/main/java/com/indexdata/mkjsf/pazpar2/ServiceProxyExtensions.java @@ -12,15 +12,9 @@ import org.apache.log4j.Logger; import org.apache.myfaces.custom.fileupload.UploadedFile; import com.indexdata.mkjsf.config.ConfigurationReader; -import com.indexdata.mkjsf.pazpar2.commands.CommandParameter; -import com.indexdata.mkjsf.pazpar2.commands.Pazpar2Commands; -import com.indexdata.mkjsf.pazpar2.commands.sp.AuthCommand; import com.indexdata.mkjsf.pazpar2.commands.sp.InitDocUpload; -import com.indexdata.mkjsf.pazpar2.data.AuthResponse; import com.indexdata.mkjsf.pazpar2.data.ResponseDataObject; import com.indexdata.mkjsf.pazpar2.data.ResponseParser; -import com.indexdata.mkjsf.pazpar2.data.Responses; -import com.indexdata.mkjsf.pazpar2.sp.auth.ServiceProxyUser; import com.indexdata.mkjsf.utils.Utils; @Named("pz2x") @SessionScoped @@ -32,90 +26,21 @@ public class ServiceProxyExtensions implements ServiceProxyInterface, Serializab private String initDocResponse = ""; private InitDocUpload initDocUpload; - @Inject ConfigurationReader configurator; - @Inject ServiceProxyUser user; - @Inject Pz2Bean pz2; - @Inject Pazpar2Commands pzreq; - @Inject Responses pzresp; - - + @Inject ConfigurationReader configurator; + public ServiceProxyExtensions() { this.initDocUpload = new InitDocUpload(this); // TODO: //stateMgr.addStateListener(this); } - - /* - public void login(String un, String pw) { - if (user.isAuthenticated() && user.getName().equals(un) && pz2.spClient.checkAuthentication(user)) { - logger.info("Repeat request from UI to authenticate user. Auth verified for given user name so skipping log-in."); - } else { - logger.info("doing un/pw login"); - user.setName(un); - user.setPassword(pw); - login("dummy"); - } - } - */ - - - @Override - public String login(String navigateTo) { - logger.info("doing login by " + user + " using " + pz2 + " and client " + pz2.getSpClient()); - pz2.resetSearchAndRecordCommands(); - pzresp.resetAllSessionData(); - AuthCommand auth = pzreq.getSp().getAuth(); - auth.setParametersInState(new CommandParameter("action","=","login"), - new CommandParameter("username","=",user.getName()), - new CommandParameter("password","=",user.getPassword())); - ClientCommandResponse commandResponse = pz2.getSpClient().send(auth); - AuthResponse responseObject = (AuthResponse) (ResponseParser.getParser().getDataObject(commandResponse.getResponseString())); - if (ResponseParser.docTypes.contains(responseObject.getType())) { - pzresp.put(auth.getCommandName(), responseObject); - } - String responseStr = commandResponse.getResponseString(); - logger.info(responseStr); - if (responseStr.contains("FAIL")) { - user.credentialsAuthenticationSucceeded(false); - } else { - user.credentialsAuthenticationSucceeded(true); - } - return navigateTo; - } - - - public void ipAuthenticate (ServiceProxyUser user) { - if (!user.isIpAuthenticated()) { - if (user.isAuthenticated()) { - user.clear(); - } - pz2.resetSearchAndRecordCommands(); - pzresp.resetAllSessionData(); - AuthCommand auth = pzreq.getSp().getAuth(); - auth.setParameterInState(new CommandParameter("action","=","ipAuth")); - ClientCommandResponse commandResponse = pz2.getSpClient().send(auth); - AuthResponse responseObject = (AuthResponse) (ResponseParser.getParser().getDataObject(commandResponse.getResponseString())); - if (ResponseParser.docTypes.contains(responseObject.getType())) { - pzresp.put(auth.getCommandName(), responseObject); - } - String responseStr = commandResponse.getResponseString(); - logger.info(responseStr); - if (responseStr.contains("FAIL")) { - user.credentialsAuthenticationSucceeded(false); - } else { - user.credentialsAuthenticationSucceeded(true); - } - } - } - + public String getInitDocPath () { - return pz2.getSpClient().getConfiguration().get("INIT_DOC_PATH"); + return Pz2Service.get().getSpClient().getConfiguration().get("INIT_DOC_PATH"); } @Override public void setInitFileName(String fileName) { - this.initDocFileName = fileName; - + this.initDocFileName = fileName; } @Override @@ -125,20 +50,20 @@ public class ServiceProxyExtensions implements ServiceProxyInterface, Serializab @Override public ClientCommandResponse postInit() throws UnsupportedEncodingException, IOException { - String initDocPath = pz2.getSpClient().getInitDocPaths().get(0); - logger.info("Paths: " + pz2.getSpClient().getInitDocPaths()); - logger.info("Path: " + initDocPath); - pz2.resetSearchAndRecordCommands(); - pzresp.resetAllSessionData(); - ClientCommandResponse response = pz2.getSpClient().postInitDoc(initDocPath + getInitFileName()); + String initDocPath = Pz2Service.get().getSpClient().getInitDocPaths().get(0); + logger.info("Paths: " + Pz2Service.get().getSpClient().getInitDocPaths()); + logger.info("Path: " + initDocPath); + Pz2Service.get().resetSearchAndRecordCommands(); + Pz2Service.get().getPzresp().getSp().resetAuthAndBeyond(true); + ClientCommandResponse response = Pz2Service.get().getSpClient().postInitDoc(initDocPath + getInitFileName()); return response; } @Override public HttpResponseWrapper postInit(byte[] initDoc, boolean includeDebug) throws UnsupportedEncodingException, IOException { - pz2.resetSearchAndRecordCommands(); - pzresp.resetAllSessionData(); - HttpResponseWrapper response = pz2.getSpClient().postInitDoc(initDoc,includeDebug); + Pz2Service.get().resetSearchAndRecordCommands(); + Pz2Service.get().getPzresp().getSp().resetAuthAndBeyond(true); + HttpResponseWrapper response = Pz2Service.get().getSpClient().postInitDoc(initDoc,includeDebug); return response; } @@ -156,10 +81,9 @@ public class ServiceProxyExtensions implements ServiceProxyInterface, Serializab } public void submitInitDoc () throws IOException { - HttpResponseWrapper response = initDocUpload.submit(); - ResponseDataObject responseObject = ResponseParser.getParser().getDataObject(response.getResponseString()); - logger.info("Putting init response to : " + Utils.objectId(pzresp)); - pzresp.put("init", responseObject); + ClientCommandResponse response = (ClientCommandResponse) initDocUpload.submit(); + ResponseDataObject responseObject = ResponseParser.getParser().getDataObject(response); + Pz2Service.get().getPzresp().put("init", responseObject); } public void setIncludeInitDocDebug(boolean bool) { @@ -171,12 +95,10 @@ public class ServiceProxyExtensions implements ServiceProxyInterface, Serializab return initDocUpload.getIncludeDebug(); } - // TODO: Remove when possible + // TODO: Remove when obsolete public InitDocUpload getInitDocUpload () { return initDocUpload; } - - - + }