git.aero2k.de Git - tmp/jakarta-migration.git/blob

   1 /**
   2  *  This document is a part of the source code and related artifacts
   3  *  for CollectionSpace, an open source collections management system
   4  *  for museums and related institutions:
   5
   6  *  http://www.collectionspace.org
   7  *  http://wiki.collectionspace.org
   8
   9  *  Copyright 2009 University of California at Berkeley
  10
  11  *  Licensed under the Educational Community License (ECL), Version 2.0.
  12  *  You may not use this file except in compliance with this License.
  13
  14  *  You may obtain a copy of the ECL 2.0 License at
  15
  16  *  https://source.collectionspace.org/collection-space/LICENSE.txt
  17
  18  *  Unless required by applicable law or agreed to in writing, software
  19  *  distributed under the License is distributed on an "AS IS" BASIS,
  20  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  21  *  See the License for the specific language governing permissions and
  22  *  limitations under the License.
  23  */
  24 package org.collectionspace.services.servicegroup.nuxeo;
  25
  26 import java.util.ArrayList;
  27 import java.util.HashMap;
  28 import java.util.Iterator;
  29 import java.util.List;
  30 import java.util.Map;
  31
  32 import javax.ws.rs.core.Response;
  33
  34 import org.collectionspace.services.nuxeo.client.java.CommonList;
  35 import org.collectionspace.services.nuxeo.client.java.NuxeoDocumentModelHandler;
  36 import org.collectionspace.services.nuxeo.client.java.CoreSessionInterface;
  37 import org.collectionspace.services.nuxeo.client.java.RepositoryClientImpl;
  38 import org.collectionspace.services.nuxeo.util.NuxeoUtils;
  39 import org.collectionspace.services.jaxb.AbstractCommonList;
  40 import org.collectionspace.services.client.IQueryManager;
  41 import org.collectionspace.services.client.PoxPayloadIn;
  42 import org.collectionspace.services.client.PoxPayloadOut;
  43
  44 import org.collectionspace.services.common.CSWebApplicationException;
  45 import org.collectionspace.services.common.ServiceMain;
  46 import org.collectionspace.services.common.ServiceMessages;
  47 import org.collectionspace.services.common.StoredValuesUriTemplate;
  48 import org.collectionspace.services.common.UriTemplateFactory;
  49 import org.collectionspace.services.common.UriTemplateRegistry;
  50 import org.collectionspace.services.common.UriTemplateRegistryKey;
  51 import org.collectionspace.services.common.config.TenantBindingConfigReaderImpl;
  52 import org.collectionspace.services.common.context.ServiceBindingUtils;
  53 import org.collectionspace.services.common.context.ServiceContext;
  54 import org.collectionspace.services.common.document.DocumentException;
  55 import org.collectionspace.services.common.document.DocumentFilter;
  56 import org.collectionspace.services.common.document.DocumentWrapper;
  57 import org.collectionspace.services.common.security.SecurityUtils;
  58 import org.collectionspace.services.common.query.nuxeo.QueryManagerNuxeoImpl;
  59
  60 import org.collectionspace.services.config.service.ServiceBindingType;
  61 import org.collectionspace.services.config.service.ServiceObjectType;
  62 import org.collectionspace.services.servicegroup.ServicegroupsCommon;
  63
  64 import org.nuxeo.ecm.core.api.DocumentModel;
  65 import org.nuxeo.ecm.core.api.DocumentModelList;
  66
  67 import org.slf4j.Logger;
  68 import org.slf4j.LoggerFactory;
  69
  70 public class ServiceGroupDocumentModelHandler
  71         extends NuxeoDocumentModelHandler<ServicegroupsCommon> {
  72
  73     protected final Logger logger = LoggerFactory.getLogger(this.getClass());
  74
  75     protected static final int NUM_META_FIELDS = 3;
  76     protected static final String DOC_TYPE_FIELD = "docType";
  77     protected static final String DOC_NUMBER_FIELD = "docNumber";
  78     protected static final String DOC_NAME_FIELD = "docName";
  79
  80     public AbstractCommonList getItemsForGroup(
  81                 ServiceContext<PoxPayloadIn, PoxPayloadOut> ctx,
  82                 List<String> serviceGroupNames) throws Exception {
  83         CommonList commonList = new CommonList();
  84         AbstractCommonList list = (AbstractCommonList)commonList;
  85         CoreSessionInterface repoSession = null;
  86         boolean releaseRepoSession = false;
  87
  88         try {
  89                 RepositoryClientImpl repoClient = (RepositoryClientImpl)this.getRepositoryClient(ctx);
  90                 repoSession = this.getRepositorySession();
  91                 if (repoSession == null) {
  92                         repoSession = repoClient.getRepositorySession(ctx);
  93                         releaseRepoSession = true;
  94                 }
  95             DocumentFilter myFilter = getDocumentFilter();
  96                 // Make sure we pick up workflow state, etc.
  97                 int pageSize = myFilter.getPageSize();
  98                 int pageNum = myFilter.getStartPage();
  99                 list.setPageNum(pageNum);
 100                 list.setPageSize(pageSize);
 101
 102                 try {
 103                 Map<String, ServiceBindingType> queriedServiceBindings = new HashMap<String, ServiceBindingType>();
 104                 RepositoryClientImpl nuxeoRepoClient = (RepositoryClientImpl)repoClient;
 105                 // Get the service bindings for this tenant
 106                 TenantBindingConfigReaderImpl tReader =
 107                         ServiceMain.getInstance().getTenantBindingConfigReader();
 108                 // We need to get all the procedures, authorities, and objects.
 109                 List<ServiceBindingType> servicebindings =
 110                                 tReader.getServiceBindingsByType(ctx.getTenantId(), serviceGroupNames);
 111                 if (servicebindings == null || servicebindings.isEmpty()) {
 112                     Response response = Response.status(Response.Status.NOT_FOUND).entity(
 113                             ServiceMessages.READ_FAILED +
 114                             ServiceMessages.resourceNotFoundMsg(implode(serviceGroupNames, ","))).type("text/plain").build();
 115                     throw new CSWebApplicationException(response);
 116                 }
 117                 servicebindings = SecurityUtils.getReadableServiceBindingsForCurrentUser(servicebindings);
 118                 // Build the list of docTypes for allowed serviceBindings
 119                 ArrayList<String> docTypes = new ArrayList<String>();
 120                 for(ServiceBindingType binding:servicebindings) {
 121                         ServiceObjectType serviceObj = binding.getObject();
 122                         if(serviceObj!=null) {
 123                         String docType = serviceObj.getName();
 124                                 docTypes.add(docType);
 125                         queriedServiceBindings.put(docType, binding);
 126                         }
 127                 }
 128
 129                 // This should be "Document" but CMIS is gagging on that right now.
 130                 ctx.getQueryParams().add(IQueryManager.SELECT_DOC_TYPE_FIELD, QueryManagerNuxeoImpl.COLLECTIONSPACE_DOCUMENT_TYPE);
 131
 132                 // Now we have to issue the search
 133                 // findDocs will build a QueryContext, which wants to see a docType for our context
 134                 ctx.setDocumentType(QueryManagerNuxeoImpl.NUXEO_DOCUMENT_TYPE);
 135                 DocumentWrapper<DocumentModelList> docListWrapper =
 136                                 nuxeoRepoClient.findDocs(ctx, this, repoSession, docTypes );
 137                 // Now we gather the info for each document into the list and return
 138                 DocumentModelList docList = docListWrapper.getWrappedObject();
 139
 140                 if (docList == null) { // found no authRef fields - nothing to process
 141                     return list;
 142                 }
 143                 processDocList(ctx.getTenantId(), docList, queriedServiceBindings, commonList);
 144                 list.setItemsInPage(docList.size());
 145                 list.setTotalItems(docList.totalSize());
 146                 } catch (DocumentException de) {
 147                         throw de;
 148                 } catch (Exception e) {
 149                         if (logger.isDebugEnabled()) {
 150                                 logger.debug("Caught exception ", e);
 151                         }
 152                         throw new DocumentException(e);
 153                 } finally {
 154                         if (releaseRepoSession && repoSession != null) {
 155                                 repoClient.releaseRepositorySession(ctx, repoSession);
 156                         }
 157                 }
 158         } catch (Exception e) {
 159                 if (logger.isDebugEnabled()) {
 160                         logger.debug("Caught exception ", e);
 161                 }
 162                 throw new DocumentException(e);
 163         }
 164
 165         return list;
 166     }
 167
 168     // Move this to a Utils class!
 169     public static String implode(List<String> stringList, String sep) {
 170         StringBuilder sb = new StringBuilder();
 171         boolean fFirst = false;
 172         for(String name:stringList) {
 173                 if(fFirst) {
 174                         fFirst = false;
 175                 } else {
 176                         sb.append(sep);
 177                 }
 178                 sb.append(name);
 179         }
 180         return sb.toString();
 181     }
 182
 183     private String getUriFromServiceBinding(ServiceBindingType sb, String csid) {
 184         return "/" + sb.getName().toLowerCase() + "/" + csid;
 185     }
 186
 187     private void processDocList(
 188                 String tenantId,
 189                 DocumentModelList docList,
 190                 Map<String, ServiceBindingType> queriedServiceBindings,
 191                 CommonList list ) {
 192         int nFields = NUM_META_FIELDS+NUM_STANDARD_LIST_RESULT_FIELDS;
 193         String fields[] = new String[nFields];
 194         fields[0] = STANDARD_LIST_CSID_FIELD;
 195         fields[1] = STANDARD_LIST_URI_FIELD;
 196         fields[2] = STANDARD_LIST_UPDATED_AT_FIELD;
 197         fields[3] = STANDARD_LIST_WORKFLOW_FIELD;
 198         fields[4] = STANDARD_LIST_REFNAME_FIELD;
 199         fields[5] = DOC_NAME_FIELD;
 200         fields[6] = DOC_NUMBER_FIELD;
 201         fields[7] = DOC_TYPE_FIELD;
 202         list.setFieldsReturned(fields);
 203         Iterator<DocumentModel> iter = docList.iterator();
 204                 HashMap<String, Object> item = new HashMap<String, Object>();
 205         while (iter.hasNext()) {
 206             DocumentModel docModel = iter.next();
 207             String docType = docModel.getDocumentType().getName();
 208             docType = ServiceBindingUtils.getUnqualifiedTenantDocType(docType);
 209             ServiceBindingType sb = queriedServiceBindings.get(docType);
 210             if (sb == null) {
 211                 throw new RuntimeException(
 212                         "processDocList: No Service Binding for docType: " + docType);
 213             }
 214             String csid = NuxeoUtils.getCsid(docModel);
 215             item.put(STANDARD_LIST_CSID_FIELD, csid);
 216
 217             UriTemplateRegistry uriTemplateRegistry = ServiceMain.getInstance().getUriTemplateRegistry();
 218             StoredValuesUriTemplate storedValuesResourceTemplate = uriTemplateRegistry.get(new UriTemplateRegistryKey(tenantId, docType));
 219             Map<String, String> additionalValues = new HashMap<String, String>();
 220             if (storedValuesResourceTemplate.getUriTemplateType() == UriTemplateFactory.ITEM) {
 221                 try {
 222                     String inAuthorityCsid = (String) NuxeoUtils.getProperyValue(docModel, "inAuthority"); //docModel.getPropertyValue("inAuthority"); // AuthorityItemJAXBSchema.IN_AUTHORITY
 223                     additionalValues.put(UriTemplateFactory.IDENTIFIER_VAR, inAuthorityCsid);
 224                     additionalValues.put(UriTemplateFactory.ITEM_IDENTIFIER_VAR, csid);
 225                 } catch (Exception e) {
 226                         String msg = String.format("Could not extract inAuthority property from authority item with CSID = ", docModel.getName());
 227                     logger.warn(msg, e);
 228                 }
 229             } else {
 230                 additionalValues.put(UriTemplateFactory.IDENTIFIER_VAR, csid);
 231             }
 232             String uriStr = storedValuesResourceTemplate.buildUri(additionalValues);
 233             item.put(STANDARD_LIST_URI_FIELD, uriStr);
 234
 235             try {
 236                 item.put(STANDARD_LIST_UPDATED_AT_FIELD, getUpdatedAtAsString(docModel));
 237                 item.put(STANDARD_LIST_WORKFLOW_FIELD, docModel.getCurrentLifeCycleState());
 238                 item.put(STANDARD_LIST_REFNAME_FIELD, getRefname(docModel));
 239             } catch(Exception e) {
 240                 logger.error("Error getting core values for doc ["+csid+"]: "+e.getLocalizedMessage());
 241             }
 242
 243             String value = ServiceBindingUtils.getMappedFieldInDoc(sb,
 244                                                         ServiceBindingUtils.OBJ_NUMBER_PROP, docModel);
 245             if (value != null) {
 246                 item.put(DOC_NUMBER_FIELD, value);
 247             }
 248
 249             value = ServiceBindingUtils.getMappedFieldInDoc(sb,
 250                                                         ServiceBindingUtils.OBJ_NAME_PROP, docModel);
 251             if (value != null) {
 252                 item.put(DOC_NAME_FIELD, value);
 253             }
 254
 255             item.put(DOC_TYPE_FIELD, docType);
 256             // add the item to the list
 257             list.addItem(item);
 258             item.clear();
 259         }
 260
 261     }
 262
 263
 264 }
 265