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.common.vocabulary.nuxeo;
  25
  26 import java.util.ArrayList;
  27 import java.util.List;
  28 import java.util.Map;
  29
  30 import javax.ws.rs.core.Response;
  31
  32 import org.collectionspace.services.client.AbstractCommonListUtils;
  33 import org.collectionspace.services.client.AuthorityClient;
  34 import org.collectionspace.services.client.CollectionSpaceClient;
  35 import org.collectionspace.services.client.PayloadInputPart;
  36 import org.collectionspace.services.client.VocabularyClient;
  37 import org.collectionspace.services.client.PoxPayloadIn;
  38 import org.collectionspace.services.client.PoxPayloadOut;
  39 import org.collectionspace.services.client.workflow.WorkflowClient;
  40 import org.collectionspace.services.common.ResourceMap;
  41 import org.collectionspace.services.common.XmlTools;
  42 import org.collectionspace.services.common.api.RefName;
  43 import org.collectionspace.services.common.api.RefName.Authority;
  44 import org.collectionspace.services.common.api.RefNameUtils;
  45 import org.collectionspace.services.common.api.RefNameUtils.AuthorityInfo;
  46 import org.collectionspace.services.common.api.RefNameUtils.AuthorityTermInfo;
  47 import org.collectionspace.services.common.api.Tools;
  48 import org.collectionspace.services.common.context.ServiceContext;
  49 import org.collectionspace.services.common.document.DocumentException;
  50 import org.collectionspace.services.common.document.DocumentHandler;
  51 import org.collectionspace.services.common.document.DocumentNotFoundException;
  52 import org.collectionspace.services.common.document.DocumentReferenceException;
  53 import org.collectionspace.services.common.document.DocumentWrapper;
  54 import org.collectionspace.services.common.vocabulary.AuthorityItemJAXBSchema;
  55 import org.collectionspace.services.common.vocabulary.AuthorityJAXBSchema;
  56 import org.collectionspace.services.common.vocabulary.AuthorityResource;
  57 import org.collectionspace.services.common.vocabulary.AuthorityServiceUtils;
  58 import org.collectionspace.services.common.vocabulary.RefNameServiceUtils.AuthorityItemSpecifier;
  59 import org.collectionspace.services.common.vocabulary.RefNameServiceUtils.Specifier;
  60 import org.collectionspace.services.common.vocabulary.RefNameServiceUtils.SpecifierForm;
  61 import org.collectionspace.services.config.service.ObjectPartType;
  62 import org.collectionspace.services.jaxb.AbstractCommonList;
  63 import org.collectionspace.services.jaxb.AbstractCommonList.ListItem;
  64 import org.collectionspace.services.lifecycle.TransitionDef;
  65 import org.collectionspace.services.nuxeo.client.java.NuxeoDocumentModelHandler;
  66 import org.collectionspace.services.nuxeo.client.java.CoreSessionInterface;
  67 import org.collectionspace.services.nuxeo.client.java.RepositoryClientImpl;
  68 import org.collectionspace.services.nuxeo.util.NuxeoUtils;
  69 import org.dom4j.Document;
  70 import org.dom4j.Element;
  71 import org.nuxeo.ecm.core.api.ClientException;
  72 import org.nuxeo.ecm.core.api.DocumentModel;
  73 import org.slf4j.Logger;
  74 import org.slf4j.LoggerFactory;
  75
  76 /**
  77  * AuthorityDocumentModelHandler
  78  *
  79  * $LastChangedRevision: $
  80  * $LastChangedDate: $
  81  */
  82 public abstract class AuthorityDocumentModelHandler<AuthCommon>
  83         extends NuxeoDocumentModelHandler<AuthCommon> {
  84
  85         private final Logger logger = LoggerFactory.getLogger(AuthorityDocumentModelHandler.class);
  86
  87         protected String authorityCommonSchemaName;
  88     protected String authorityItemCommonSchemaName;
  89     protected boolean shouldUpdateRevNumber = true; // default to updating the revision number
  90
  91     public AuthorityDocumentModelHandler(String authorityCommonSchemaName, String authorityItemCommonSchemaName) {
  92         this.authorityCommonSchemaName = authorityCommonSchemaName;
  93         this.authorityItemCommonSchemaName = authorityItemCommonSchemaName;
  94     }
  95
  96     public void setShouldUpdateRevNumber(boolean flag) {
  97         this.shouldUpdateRevNumber = flag;
  98     }
  99
 100     public boolean getShouldUpdateRevNumber() {
 101         return this.shouldUpdateRevNumber;
 102     }
 103
 104     /**
 105      * The entity type expected from the JAX-RS Response object
 106      */
 107     public Class<String> getEntityResponseType() {
 108         return String.class;
 109     }
 110
 111     @Override
 112     public void prepareSync() throws Exception {
 113         this.setShouldUpdateRevNumber(AuthorityServiceUtils.DONT_UPDATE_REV);  // Never update rev nums on sync operations
 114     }
 115
 116     protected PayloadInputPart extractPart(Response res, String partLabel)
 117             throws Exception {
 118             PoxPayloadIn input = new PoxPayloadIn((String)res.readEntity(getEntityResponseType()));
 119             PayloadInputPart payloadInputPart = input.getPart(partLabel);
 120             if (payloadInputPart == null) {
 121                 logger.error("Part " + partLabel + " was unexpectedly null.");
 122             }
 123             return payloadInputPart;
 124     }
 125
 126     @Override
 127     public boolean handleSync(DocumentWrapper<Object> wrapDoc) throws Exception {
 128         boolean result = false;
 129         ServiceContext<PoxPayloadIn, PoxPayloadOut> ctx = getServiceContext();
 130         Specifier specifier = (Specifier) wrapDoc.getWrappedObject();
 131         //
 132         // Get the rev number of the authority so we can compare with rev number of shared authority
 133         //
 134         DocumentModel docModel = NuxeoUtils.getDocFromSpecifier(ctx, getRepositorySession(), authorityCommonSchemaName, specifier);
 135         Long localRev = (Long) NuxeoUtils.getProperyValue(docModel, AuthorityJAXBSchema.REV);
 136         String shortId = (String) NuxeoUtils.getProperyValue(docModel, AuthorityJAXBSchema.SHORT_IDENTIFIER);
 137         //
 138         // Using the short ID of the local authority, create a URN specifier to retrieve the SAS authority
 139         //
 140         Specifier sasSpecifier = new Specifier(SpecifierForm.URN_NAME, shortId);
 141         PoxPayloadIn sasPayloadIn = AuthorityServiceUtils.requestPayloadIn(ctx, sasSpecifier, getEntityResponseType());
 142         //
 143         // If the authority on the SAS is newer, synch all the items and then the authority record as well
 144         //
 145         //
 146         Long sasRev = getRevision(sasPayloadIn);
 147         if (sasRev > localRev) {
 148                 //
 149                 // First, sync all the authority items
 150                 //
 151                 syncAllItems(ctx, sasSpecifier);
 152                 //
 153                 // Next, sync the authority resource/record itself
 154                 //
 155                 AuthorityResource authorityResource = (AuthorityResource) ctx.getResource();
 156                 ctx.setProperty(AuthorityServiceUtils.SHOULD_UPDATE_REV_PROPERTY, AuthorityServiceUtils.DONT_UPDATE_REV); // Don't update the rev number, use the rev number for the SAS instance instead
 157                 PoxPayloadOut payloadOut = authorityResource.update(ctx, ctx.getResourceMap(), ctx.getUriInfo(), docModel.getName(),
 158                                 sasPayloadIn);
 159                 if (payloadOut != null) {
 160                         ctx.setOutput(payloadOut);
 161                         result = true;
 162                 }
 163         }
 164
 165         return result;
 166     }
 167
 168     /*
 169      * Get the list of authority items from the remote shared authority server (SAS) and try
 170      * to synchronize them with the local items.  If items exist on the remote but not the local, we'll create them.
 171      */
 172     protected int syncAllItems(ServiceContext ctx, Specifier sasAuthoritySpecifier) throws Exception {
 173         int result = -1;
 174         int created = 0;
 175         int synched = 0;
 176         int alreadySynched = 0;
 177         int deprecated = 0;
 178         int totalItemsProcessed = 0;
 179         ArrayList<String> itemsInRemoteAuthority = new ArrayList<String>();
 180         //
 181         // Iterate over the list of items/terms in the remote authority
 182         //
 183         PoxPayloadIn sasPayloadInItemList = requestPayloadInItemList(ctx, sasAuthoritySpecifier);
 184         List<Element> itemList = getItemList(sasPayloadInItemList);
 185         if (itemList != null) {
 186                 for (Element e:itemList) {
 187                         String remoteRefName = XmlTools.getElementValue(e, "refName");
 188                         itemsInRemoteAuthority.add(remoteRefName);
 189                         long status = syncRemoteItemWithLocalItem(ctx, remoteRefName);
 190                         if (status == 1) {
 191                                 created++;
 192                         } else if (status == 0) {
 193                                 synched++;
 194                         } else {
 195                                 alreadySynched++;
 196                         }
 197                         totalItemsProcessed++;
 198                 }
 199         }
 200         //
 201         // Now see if we need to deprecate or delete items that have been hard-deleted from the SAS but still exist
 202         // locally.  Subtract (remove) the list of remote items from the list of local items to determine which
 203         // of the remote items have been hard deleted.
 204         //
 205         ArrayList<String> itemsInLocalAuthority = getItemsInLocalAuthority(ctx, sasAuthoritySpecifier);
 206         if (itemsInLocalAuthority.removeAll(itemsInRemoteAuthority) == true) {
 207                 ArrayList<String> remainingItems = itemsInLocalAuthority; // now a subset of local items
 208                 //
 209                 // We now need to either hard-deleted or deprecate the remaining authorities
 210                 //
 211                 long processed = deleteOrDeprecateItems(ctx, remainingItems);
 212                 if (processed != remainingItems.size()) {
 213                         throw new Exception("Encountered unexpected exception trying to delete or deprecated authority items during synchronization.");
 214                 }
 215         }
 216
 217
 218         logger.info(String.format("Total number of items processed during sync: %d", totalItemsProcessed));
 219         logger.info(String.format("Number of items synchronized: %d", synched));
 220         logger.info(String.format("Number of items created during sync: %d", created));
 221         logger.info(String.format("Number not needing synchronization: %d", alreadySynched));
 222
 223         return result;
 224     }
 225
 226     /**
 227      *
 228      * @param ctx
 229      * @param refNameList
 230      * @return
 231      * @throws Exception
 232      */
 233     private long deleteOrDeprecateItems(ServiceContext ctx, ArrayList<String> refNameList) throws Exception {
 234         long result = 0;
 235
 236         ArrayList<String> failureList = new ArrayList<String>();
 237         for (String refName:refNameList) {
 238                 AuthorityTermInfo itemInfo = RefNameUtils.parseAuthorityTermInfo(refName);
 239                 AuthorityResource authorityResource = (AuthorityResource) ctx.getResource();
 240                 try {
 241                         authorityResource.deleteAuthorityItem(ctx, itemInfo.inAuthority.csid, itemInfo.csid);
 242                         result++;
 243                 } catch (DocumentReferenceException de) {
 244                         logger.info(String.format("Authority item '%s' has existing references and cannot be removed during sync.",
 245                                         refName), de);
 246                         boolean marked = AuthorityServiceUtils.markAuthorityItemAsDeprecated(ctx, authorityItemCommonSchemaName,
 247                                         itemInfo.csid);
 248                         if (marked == true) {
 249                                 result++;
 250                         }
 251                 } catch (Exception e) {
 252                         logger.warn(String.format("Unable to delete authority item '%s'", refName), e);
 253                         throw e;
 254                 }
 255         }
 256
 257         if (logger.isWarnEnabled() == true) {
 258                 if (result != refNameList.size()) {
 259                         logger.warn(String.format("Unable to delete or deprecate some authority items during synchronization with SAS.  Deleted or deprecated %d of %d.  See the services log file for details.",
 260                                         result, refNameList.size()));
 261                 }
 262         }
 263
 264         return result;
 265     }
 266
 267     /**
 268      * Gets the list of SAS related items in the local authority.  We exlude items with the "proposed" flags because
 269      * we want a list with only SAS created items.
 270      *
 271      * We need to add pagination support to this call!!!
 272      *
 273      * @param ctx
 274      * @param specifier
 275      * @return
 276      * @throws Exception
 277      */
 278     private ArrayList<String> getItemsInLocalAuthority(ServiceContext ctx, Specifier specifier) throws Exception {
 279         ArrayList<String> result = new ArrayList<String>();
 280
 281         ResourceMap resourceMap = ctx.getResourceMap();
 282         String resourceName = ctx.getClient().getServiceName();
 283         AuthorityResource authorityResource = (AuthorityResource) resourceMap.get(resourceName);
 284         AbstractCommonList acl = authorityResource.getAuthorityItemList(ctx, specifier.value, ctx.getUriInfo());
 285         List<ListItem> listItemList = acl.getListItem();
 286         for (ListItem listItem:listItemList) {
 287                 Boolean proposed = getBooleanValue(listItem, AuthorityItemJAXBSchema.PROPOSED);
 288                 if (proposed == false) { // exclude "proposed" (i.e., local-only items)
 289                         result.add(AbstractCommonListUtils.ListItemGetElementValue(listItem, AuthorityItemJAXBSchema.REF_NAME));
 290                 }
 291         }
 292
 293         return result;
 294     }
 295
 296     private Boolean getBooleanValue(ListItem listItem, String name) {
 297         Boolean result = null;
 298
 299                 String value = AbstractCommonListUtils.ListItemGetElementValue(listItem, name);
 300                 if (value != null) {
 301                         result = Boolean.valueOf(value);
 302                 }
 303
 304                 return result;
 305     }
 306
 307     private String getStringValue(ListItem listItem, String name) {
 308         return AbstractCommonListUtils.ListItemGetElementValue(listItem, AuthorityItemJAXBSchema.REF_NAME);
 309     }
 310
 311     /**
 312      * This is a sync method.
 313      * @param ctx
 314      * @param parentIdentifier - Must be in short-id-refname form -i.e., urn:cspace:name(shortid)
 315      * @param itemIdentifier   - Must be in short-id-refname form -i.e., urn:cspace:name(shortid)
 316      * @throws Exception
 317      */
 318     protected void createLocalItem(ServiceContext ctx, String parentIdentifier, String itemIdentifier) throws Exception {
 319         //
 320         // Create a URN short ID specifier for the getting a copy of the remote authority item
 321         //
 322         Specifier authoritySpecifier = Specifier.getSpecifier(parentIdentifier);
 323         Specifier itemSpecifier = Specifier.getSpecifier(itemIdentifier);
 324         AuthorityItemSpecifier sasAuthorityItemSpecifier = new AuthorityItemSpecifier(authoritySpecifier, itemSpecifier);
 325         //
 326         // Get the remote payload
 327         //
 328         PoxPayloadIn sasPayloadIn = AuthorityServiceUtils.requestPayloadIn(sasAuthorityItemSpecifier,
 329                         ctx.getServiceName(), getEntityResponseType());
 330         sasPayloadIn = AuthorityServiceUtils.filterRefnameDomains(ctx, sasPayloadIn); // We need to filter domain name part of any and all refnames in the payload
 331         //
 332         // Using the payload from the remote server, create a local copy of the item
 333         //
 334         AuthorityResource authorityResource = (AuthorityResource) ctx.getResource();
 335         Response response = authorityResource.createAuthorityItemWithParentContext(ctx, authoritySpecifier.getURNValue(),
 336                         sasPayloadIn, AuthorityServiceUtils.DONT_UPDATE_REV, AuthorityServiceUtils.NOT_PROPOSED);
 337         //
 338         // Check the response for successful POST result
 339         //
 340         if (response.getStatus() != Response.Status.CREATED.getStatusCode()) {
 341                 throw new DocumentException(String.format("Could not create new authority item '%s' during synchronization of the '%s' authority.",
 342                                 itemIdentifier, parentIdentifier));
 343         }
 344         //
 345         // Since we're creating an item that was sourced from the SAS, we need to lock it.
 346         //
 347         authorityResource.updateItemWorkflowWithTransition(ctx, parentIdentifier, itemIdentifier,
 348                         WorkflowClient.WORKFLOWTRANSITION_LOCK, AuthorityServiceUtils.DONT_UPDATE_REV);
 349         }
 350
 351     /**
 352      * Try to synchronize a remote item (using its refName) with a local item.  If the local doesn't yet
 353      * exist, we'll create it.
 354      * Result values:
 355      *  -1 = sync not needed; i.e., already in sync
 356      *   0 = sync succeeded
 357      *   1 = local item was missing so we created it
 358      * @param ctx
 359      * @param refName
 360      * @return
 361      * @throws Exception
 362      */
 363     protected long syncRemoteItemWithLocalItem(ServiceContext ctx, String itemRefName) throws Exception {
 364         long result = -1;
 365         //
 366         // Using the item refname (with no local CSID), create specifiers that we'll use to find the local versions
 367         //
 368         AuthorityTermInfo authorityTermInfo = RefNameUtils.parseAuthorityTermInfo(itemRefName);
 369         String parentIdentifier = Specifier.createShortIdURNValue(authorityTermInfo.inAuthority.name);
 370         String itemIdentifier = Specifier.createShortIdURNValue(authorityTermInfo.name);
 371         //
 372         // We'll use the Authority JAX-RS resource to peform sync operations (creates and updates)
 373         //
 374         AuthorityResource authorityResource = (AuthorityResource) ctx.getResource();
 375         PoxPayloadOut localItemPayloadOut;
 376         try {
 377                 localItemPayloadOut = authorityResource.getAuthorityItemWithExistingContext(ctx, parentIdentifier, itemIdentifier);
 378         } catch (DocumentNotFoundException dnf) {
 379                 //
 380                 // Document not found, means we need to create an item/term that exists only on the SAS
 381                 //
 382                 logger.info(String.format("Remote item with refname='%s' doesn't exist locally, so we'll create it.", itemRefName));
 383                 createLocalItem(ctx, parentIdentifier, itemIdentifier);
 384                 return 1; // exit with status of 1 means we created a new authority item
 385         }
 386         //
 387         // If we get here, we know the item exists both locally and remotely, so we need to synchronize them.
 388         //
 389         //
 390         try {
 391                 PoxPayloadOut theUpdate = authorityResource.synchronizeItemWithExistingContext(ctx, parentIdentifier, itemIdentifier);
 392                 if (theUpdate != null) {
 393                         result = 0; // means we needed to sync this item with SAS
 394                         logger.debug(String.format("Sync'd authority item parent='%s' id='%s with SAS.  Updated payload is: \n%s",
 395                                         parentIdentifier, itemIdentifier, theUpdate.getXmlPayload()));
 396                 }
 397         } catch (DocumentReferenceException de) { // Exception for items that still have records/resource referencing them.
 398                 result = -1;
 399                 logger.error(String.format("Could not sync authority item = '%s' because it has existing records referencing it.",
 400                                 itemIdentifier));
 401         }
 402
 403         return result; // -1 = no sync needed/possible, 0 = sync'd, 1 = created new item
 404     }
 405
 406     private PoxPayloadIn requestPayloadInItemList(ServiceContext ctx, Specifier specifier) throws Exception {
 407         PoxPayloadIn result = null;
 408
 409         AuthorityClient client = (AuthorityClient) ctx.getClient();
 410         Response res = client.readItemList(specifier.getURNValue(),
 411                         null,   // partial term string
 412                         null    // keyword string
 413                         );
 414         try {
 415                 int statusCode = res.getStatus();
 416
 417                 // Check the status code of the response: does it match
 418                 // the expected response(s)?
 419                 if (logger.isDebugEnabled()) {
 420                     logger.debug(client.getClass().getCanonicalName() + ": status = " + statusCode);
 421                 }
 422
 423             result = new PoxPayloadIn((String)res.readEntity(getEntityResponseType())); // Get the entire response!
 424         } finally {
 425                 res.close();
 426         }
 427
 428         return result;
 429     }
 430
 431
 432     /*
 433      * Non standard injection of CSID into common part, since caller may access through
 434      * shortId, and not know the CSID.
 435      * @see org.collectionspace.services.nuxeo.client.java.RemoteDocumentModelHandlerImpl#extractPart(org.nuxeo.ecm.core.api.DocumentModel, java.lang.String, org.collectionspace.services.common.service.ObjectPartType)
 436      */
 437     @Override
 438     protected Map<String, Object> extractPart(DocumentModel docModel, String schema, ObjectPartType partMeta)
 439             throws Exception {
 440         Map<String, Object> unQObjectProperties = super.extractPart(docModel, schema, partMeta);
 441
 442         // Add the CSID to the common part
 443         if (partMeta.getLabel().equalsIgnoreCase(authorityCommonSchemaName)) {
 444             String csid = getCsid(docModel);//NuxeoUtils.extractId(docModel.getPathAsString());
 445             unQObjectProperties.put("csid", csid);
 446         }
 447
 448         return unQObjectProperties;
 449     }
 450
 451     public void fillAllParts(DocumentWrapper<DocumentModel> wrapDoc, Action action) throws Exception {
 452         super.fillAllParts(wrapDoc, action);
 453         //
 454         // Update the record's revision number on both CREATE and UPDATE actions, but not on SYNC
 455         //
 456         if (this.getShouldUpdateRevNumber() == true) { // We won't update rev numbers on synchronization with SAS
 457                 updateRevNumbers(wrapDoc);
 458         }
 459     }
 460
 461     protected void updateRevNumbers(DocumentWrapper<DocumentModel> wrapDoc) {
 462         DocumentModel documentModel = wrapDoc.getWrappedObject();
 463         Long rev = (Long)documentModel.getProperty(authorityCommonSchemaName, AuthorityJAXBSchema.REV);
 464         if (rev == null) {
 465                 rev = (long)0;
 466         } else {
 467                 rev++;
 468         }
 469         documentModel.setProperty(authorityCommonSchemaName, AuthorityJAXBSchema.REV, rev);
 470     }
 471
 472     /*
 473      * We consider workflow state changes as changes that should bump the revision number
 474      * (non-Javadoc)
 475      * @see org.collectionspace.services.nuxeo.client.java.RemoteDocumentModelHandlerImpl#handleWorkflowTransition(org.collectionspace.services.common.document.DocumentWrapper, org.collectionspace.services.lifecycle.TransitionDef)
 476      */
 477     @Override
 478     public void handleWorkflowTransition(ServiceContext ctx, DocumentWrapper<DocumentModel> wrapDoc, TransitionDef transitionDef) throws Exception {
 479         // Update the revision number
 480         updateRevNumbers(wrapDoc);
 481     }
 482
 483     @Override
 484     public void handleCreate(DocumentWrapper<DocumentModel> wrapDoc) throws Exception {
 485         super.handleCreate(wrapDoc);
 486         // CSPACE-3178:
 487         // Uncomment once debugged and App layer is read to integrate
 488         // Experimenting with this uncommented now ...
 489         handleDisplayNameAsShortIdentifier(wrapDoc.getWrappedObject(), authorityCommonSchemaName);
 490         updateRefnameForAuthority(wrapDoc, authorityCommonSchemaName);//CSPACE-3178
 491     }
 492
 493     protected String buildWhereForShortId(String name) {
 494         return authorityCommonSchemaName
 495                 + ":" + AuthorityJAXBSchema.SHORT_IDENTIFIER
 496                 + "='" + name + "'";
 497     }
 498
 499     private boolean isUnique(DocumentModel docModel, String schemaName) throws DocumentException {
 500         return true;
 501     }
 502
 503     private boolean temp_isUnique(DocumentModel docModel, String schemaName) throws DocumentException {
 504         boolean result = true;
 505
 506         ServiceContext ctx = this.getServiceContext();
 507         String shortIdentifier = (String) docModel.getProperty(schemaName, AuthorityJAXBSchema.SHORT_IDENTIFIER);
 508         String nxqlWhereClause = buildWhereForShortId(shortIdentifier);
 509         try {
 510                         DocumentWrapper<DocumentModel> searchResultWrapper = getRepositoryClient(ctx).findDoc(ctx, nxqlWhereClause);
 511                         if (searchResultWrapper != null) {
 512                                 result = false;
 513                                 if (logger.isInfoEnabled() == true) {
 514                                         DocumentModel searchResult = searchResultWrapper.getWrappedObject();
 515                                         String debugMsg = String.format("Could not create a new authority with a short identifier of '%s', because one already exists with the same short identifer: CSID = '%s'",
 516                                                         shortIdentifier, searchResult.getName());
 517                                         logger.trace(debugMsg);
 518                                 }
 519                         }
 520                 } catch (DocumentNotFoundException e) {
 521                         // Not a problem, just means we couldn't find another authority with that short ID
 522                 }
 523
 524         return result;
 525     }
 526
 527     /**
 528      * If no short identifier was provided in the input payload,
 529      * generate a short identifier from the display name. Either way though,
 530      * the short identifier needs to be unique.
 531      */
 532     private void handleDisplayNameAsShortIdentifier(DocumentModel docModel, String schemaName) throws Exception {
 533         String shortIdentifier = (String) docModel.getProperty(schemaName, AuthorityJAXBSchema.SHORT_IDENTIFIER);
 534         String displayName = (String) docModel.getProperty(schemaName, AuthorityJAXBSchema.DISPLAY_NAME);
 535         String shortDisplayName = "";
 536         String generateShortIdentifier = null;
 537         if (Tools.isEmpty(shortIdentifier)) {
 538                 generateShortIdentifier = AuthorityIdentifierUtils.generateShortIdentifierFromDisplayName(displayName, shortDisplayName);
 539             docModel.setProperty(schemaName, AuthorityJAXBSchema.SHORT_IDENTIFIER, shortIdentifier);
 540         }
 541
 542         if (isUnique(docModel, schemaName) == false) {
 543                 String shortId = generateShortIdentifier == null ? shortIdentifier : generateShortIdentifier;
 544                 String errMsgVerb = generateShortIdentifier == null ? "supplied" : "generated";
 545                 String errMsg = String.format("The %s short identifier '%s' was not unique, so the new authority could not be created.",
 546                                 errMsgVerb, shortId);
 547                 throw new DocumentException(errMsg);
 548         }
 549     }
 550
 551     /**
 552      * Generate a refName for the authority from the short identifier
 553      * and display name.
 554      *
 555      * All refNames for authorities are generated.  If a client supplies
 556      * a refName, it will be overwritten during create (per this method)
 557      * or discarded during update (per filterReadOnlyPropertiesForPart).
 558      *
 559      * @see #filterReadOnlyPropertiesForPart(Map<String, Object>, org.collectionspace.services.common.service.ObjectPartType)
 560      *
 561      */
 562     protected void updateRefnameForAuthority(DocumentWrapper<DocumentModel> wrapDoc, String schemaName) throws Exception {
 563         DocumentModel docModel = wrapDoc.getWrappedObject();
 564         RefName.Authority authority = (Authority) getRefName(getServiceContext(), docModel);
 565         String refName = authority.toString();
 566         docModel.setProperty(schemaName, AuthorityJAXBSchema.REF_NAME, refName);
 567     }
 568
 569     @Override
 570     public RefName.RefNameInterface getRefName(ServiceContext ctx,
 571                 DocumentModel docModel) {
 572         RefName.RefNameInterface refname = null;
 573
 574         try {
 575                 String shortIdentifier = (String) docModel.getProperty(authorityCommonSchemaName, AuthorityJAXBSchema.SHORT_IDENTIFIER);
 576                 String displayName = (String) docModel.getProperty(authorityCommonSchemaName, AuthorityJAXBSchema.DISPLAY_NAME);
 577                 RefName.Authority authority = RefName.Authority.buildAuthority(ctx.getTenantName(),
 578                         ctx.getServiceName(),
 579                         null,   // Only use shortId form!!!
 580                         shortIdentifier,
 581                         displayName);
 582                 refname = authority;
 583         } catch (Exception e) {
 584                 logger.error(e.getMessage(), e);
 585         }
 586
 587         return refname;
 588     }
 589
 590     @Override
 591     protected String getRefnameDisplayName(DocumentWrapper<DocumentModel> docWrapper) {
 592         String result = null;
 593
 594         DocumentModel docModel = docWrapper.getWrappedObject();
 595         ServiceContext<PoxPayloadIn, PoxPayloadOut> ctx = this.getServiceContext();
 596         RefName.Authority refname = (RefName.Authority)getRefName(ctx, docModel);
 597         result = refname.getDisplayName();
 598
 599         return result;
 600     }
 601
 602     public String getShortIdentifier(ServiceContext ctx, String authCSID, String schemaName) throws Exception {
 603         String shortIdentifier = null;
 604         CoreSessionInterface repoSession = null;
 605         boolean releaseSession = false;
 606
 607         RepositoryClientImpl nuxeoRepoClient = (RepositoryClientImpl)this.getRepositoryClient(ctx);
 608         try {
 609                 repoSession = nuxeoRepoClient.getRepositorySession(ctx);
 610             DocumentWrapper<DocumentModel> wrapDoc = nuxeoRepoClient.getDocFromCsid(ctx, repoSession, authCSID);
 611             DocumentModel docModel = wrapDoc.getWrappedObject();
 612             if (docModel == null) {
 613                 throw new DocumentNotFoundException(String.format("Could not find authority resource with CSID='%s'.", authCSID));
 614             }
 615             shortIdentifier = (String) docModel.getProperty(schemaName, AuthorityJAXBSchema.SHORT_IDENTIFIER);
 616         } catch (ClientException ce) {
 617             throw new RuntimeException("AuthorityDocHandler Internal Error: cannot get shortId!", ce);
 618         } finally {
 619                 if (repoSession != null) {
 620                         nuxeoRepoClient.releaseRepositorySession(ctx, repoSession);
 621                 }
 622         }
 623
 624         return shortIdentifier;
 625     }
 626
 627     /**
 628      * Filters out selected values supplied in an update request.
 629      *
 630      * @param objectProps the properties filtered out from the update payload
 631      * @param partMeta metadata for the object to fill
 632      */
 633     @Override
 634     public void filterReadOnlyPropertiesForPart(
 635             Map<String, Object> objectProps, ObjectPartType partMeta) {
 636         super.filterReadOnlyPropertiesForPart(objectProps, partMeta);
 637         String commonPartLabel = getServiceContext().getCommonPartLabel();
 638         if (partMeta.getLabel().equalsIgnoreCase(commonPartLabel)) {
 639             objectProps.remove(AuthorityJAXBSchema.CSID);
 640             objectProps.remove(AuthorityJAXBSchema.SHORT_IDENTIFIER);
 641             objectProps.remove(AuthorityJAXBSchema.REF_NAME);
 642         }
 643     }
 644 }