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

   1 package com.indexdata.mkjsf.pazpar2;\r
   2 \r
   3 import java.io.IOException;\r
   4 import java.io.UnsupportedEncodingException;\r
   5 \r
   6 import javax.annotation.PostConstruct;\r
   7 import javax.enterprise.context.SessionScoped;\r
   8 import javax.enterprise.inject.Alternative;\r
   9 import javax.inject.Inject;\r
  10 import javax.inject.Named;\r
  11 \r
  12 import org.apache.log4j.Logger;\r
  13 \r
  14 import com.indexdata.mkjsf.config.ConfigurationReader;\r
  15 import com.indexdata.mkjsf.pazpar2.sp.ServiceProxyClient;\r
  16 import com.indexdata.mkjsf.pazpar2.sp.ServiceProxyInterface;\r
  17 import com.indexdata.mkjsf.pazpar2.sp.auth.ServiceProxyUser;\r
  18 import com.indexdata.mkjsf.utils.Utils;\r
  19 \r
  20 @Named("pz2") @SessionScoped @Alternative\r
  21 public class Pz2ProxyBean extends Pz2Bean implements ServiceProxyInterface {\r
  22     \r
  23   private static final long serialVersionUID = 4221824985678758225L;\r
  24   private static Logger logger = Logger.getLogger(Pz2ProxyBean.class);  \r
  25   private String initDocFileName = "";\r
  26   private String initDocResponse = "";\r
  27   private String serviceProxyUrl = "";  \r
  28     \r
  29   @Inject ConfigurationReader configurator;\r
  30   @Inject ServiceProxyUser user;    \r
  31   \r
  32   public Pz2ProxyBean() {\r
  33   }\r
  34   \r
  35   @PostConstruct\r
  36   public void postConstruct() {\r
  37     if (searchClient == null) {\r
  38       logger.debug(Utils.objectId(this) + " will instantiate a ServiceProxyClient next.");    \r
  39       searchClient = new ServiceProxyClient();\r
  40       logger.info("Using [" + Utils.objectId(searchClient) + "] configured by [" \r
  41                             + Utils.objectId(configurator) + "]" );    \r
  42       configureClient(searchClient,configurator);\r
  43       stateMgr.addStateListener(this);\r
  44     } else {\r
  45       logger.debug("Pz2ProxyBean:postConstruct: searchClient already instantiated " +\r
  46                         "during construction of parent object Pz2Bean.");\r
  47     }\r
  48   }\r
  49   \r
  50   public void login(String un, String pw) {\r
  51     if (user.isAuthenticated() && user.getName().equals(un) && ((ServiceProxyClient) searchClient).checkAuthentication()) {\r
  52       logger.info("Repeat request from UI to authenticate user. Auth verified for given user name so skipping log-in.");\r
  53     } else {\r
  54       logger.info("doing un/pw login");\r
  55       user.setName(un);\r
  56       user.setPassword(pw);\r
  57       login("dummy");\r
  58     }\r
  59   }\r
  60 \r
  61   @Override\r
  62   public String login(String navigateTo) {\r
  63     logger.info("doing login");\r
  64     ((ServiceProxyClient)searchClient).authenticate(user);    \r
  65     pzreq.getRecord().removeParametersInState();\r
  66     pzreq.getSearch().removeParametersInState();\r
  67     pzresp.reset();\r
  68     return navigateTo;\r
  69   }\r
  70 \r
  71   @Override\r
  72   public void setServiceProxyUrl(String url) {\r
  73     logger.info("Setting Service Proxy url: " + url);\r
  74     serviceProxyUrl = url;\r
  75     pzreq.getRecord().removeParametersInState();\r
  76     pzreq.getSearch().removeParametersInState();\r
  77     pzresp.reset();\r
  78   }\r
  79   \r
  80   public String getServiceProxyUrl() {\r
  81     return serviceProxyUrl;\r
  82   }\r
  83     \r
  84   public String getInitDocPath () {\r
  85     return searchClient.getConfiguration().get("INIT_DOC_PATH");\r
  86   }\r
  87   \r
  88   @Override\r
  89   public void setInitFileName(String fileName) {\r
  90     this.initDocFileName = fileName;\r
  91     \r
  92   }\r
  93 \r
  94   @Override\r
  95   public String getInitFileName() {\r
  96     return initDocFileName;\r
  97   }\r
  98 \r
  99   @Override\r
 100   public String postInit() throws UnsupportedEncodingException, IOException {    \r
 101     String initDocPath = ((ServiceProxyClient)searchClient).getInitDocPaths()[0];\r
 102     logger.info("Paths: " + ((ServiceProxyClient)searchClient).getInitDocPaths());\r
 103     logger.info("Path: " + initDocPath);\r
 104     pzresp.reset();\r
 105     byte[] response = ((ServiceProxyClient)searchClient).postInitDoc(initDocPath + getInitFileName());\r
 106     initDocResponse = new String(response,"UTF-8");\r
 107     return initDocResponse;\r
 108   }\r
 109   \r
 110   @Override\r
 111   public String postInit(byte[] initDoc) throws UnsupportedEncodingException, IOException {    \r
 112     pzresp.reset();\r
 113     byte[] response = ((ServiceProxyClient)searchClient).postInitDoc(initDoc);\r
 114     initDocResponse = new String(response,"UTF-8");\r
 115     return initDocResponse;\r
 116   }\r
 117 \r
 118 \r
 119   @Override\r
 120   public String getInitResponse() {\r
 121     return initDocResponse;\r
 122   }\r
 123   \r
 124   public void setAceFilter(String filterExpression) {\r
 125     //setCommandParameter("record",new CommandParameter("acefilter","=",filterExpression));\r
 126   }\r
 127   \r
 128   public String getAceFilter () {\r
 129     return null;\r
 130     // return getCommandParameterValue("record","acefilter","");\r
 131   }\r
 132 \r
 133 \r
 134 }\r