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 = markAuthorityItemAsDeprecated(ctx, itemInfo);
 247                         if (marked == true) {
 248                                 result++;
 249                         }
 250                 } catch (Exception e) {
 251                         logger.warn(String.format("Unable to delete authority item '%s'", refName), e);
 252                         throw e;
 253                 }
 254         }
 255
 256         if (logger.isWarnEnabled() == true) {
 257                 if (result != refNameList.size()) {
 258                         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.",
 259                                         result, refNameList.size()));
 260                 }
 261         }
 262
 263         return result;
 264     }
 265
 266     /**
 267      * Mark the authority item as deprecated.
 268      *
 269      * @param ctx
 270      * @param itemInfo
 271      * @throws Exception
 272      */
 273     private boolean markAuthorityItemAsDeprecated(ServiceContext ctx, AuthorityTermInfo itemInfo) throws Exception {
 274         boolean result = false;
 275
 276         try {
 277                 String itemCsid = itemInfo.csid;
 278                 DocumentModel docModel = NuxeoUtils.getDocFromCsid(ctx, (CoreSessionInterface)ctx.getCurrentRepositorySession(), itemCsid);
 279                 docModel.setProperty(authorityItemCommonSchemaName, AuthorityItemJAXBSchema.DEPRECATED,
 280                                 new Boolean(AuthorityServiceUtils.DEPRECATED));
 281                 CoreSessionInterface session = (CoreSessionInterface) ctx.getCurrentRepositorySession();
 282                 session.saveDocument(docModel);
 283                 result = true;
 284         } catch (Exception e) {
 285                 logger.warn(String.format("Could not mark item '%s' as deprecated.", itemInfo.name), e);
 286                 throw e;
 287         }
 288
 289         return result;
 290     }
 291
 292     /**
 293      * Gets the list of SAS related items in the local authority.  We exlude items with the "proposed" flags because
 294      * we want a list with only SAS created items.
 295      *
 296      * We need to add pagination support to this call!!!
 297      *
 298      * @param ctx
 299      * @param specifier
 300      * @return
 301      * @throws Exception
 302      */
 303     private ArrayList<String> getItemsInLocalAuthority(ServiceContext ctx, Specifier specifier) throws Exception {
 304         ArrayList<String> result = new ArrayList<String>();
 305
 306         ResourceMap resourceMap = ctx.getResourceMap();
 307         String resourceName = ctx.getClient().getServiceName();
 308         AuthorityResource authorityResource = (AuthorityResource) resourceMap.get(resourceName);
 309         AbstractCommonList acl = authorityResource.getAuthorityItemList(ctx, specifier.value, ctx.getUriInfo());
 310         List<ListItem> listItemList = acl.getListItem();
 311         for (ListItem listItem:listItemList) {
 312                 Boolean proposed = getBooleanValue(listItem, AuthorityItemJAXBSchema.PROPOSED);
 313                 if (proposed == false) { // exclude "proposed" (i.e., local-only items)
 314                         result.add(AbstractCommonListUtils.ListItemGetElementValue(listItem, AuthorityItemJAXBSchema.REF_NAME));
 315                 }
 316         }
 317
 318         return result;
 319     }
 320
 321     private Boolean getBooleanValue(ListItem listItem, String name) {
 322         Boolean result = null;
 323
 324                 String value = AbstractCommonListUtils.ListItemGetElementValue(listItem, name);
 325                 if (value != null) {
 326                         result = Boolean.valueOf(value);
 327                 }
 328
 329                 return result;
 330     }
 331
 332     private String getStringValue(ListItem listItem, String name) {
 333         return AbstractCommonListUtils.ListItemGetElementValue(listItem, AuthorityItemJAXBSchema.REF_NAME);
 334     }
 335
 336     /**
 337      * This is a sync method.
 338      * @param ctx
 339      * @param parentIdentifier - Must be in short-id-refname form -i.e., urn:cspace:name(shortid)
 340      * @param itemIdentifier   - Must be in short-id-refname form -i.e., urn:cspace:name(shortid)
 341      * @throws Exception
 342      */
 343     protected void createLocalItem(ServiceContext ctx, String parentIdentifier, String itemIdentifier) throws Exception {
 344         //
 345         // Create a URN short ID specifier for the getting a copy of the remote authority item
 346         //
 347         Specifier authoritySpecifier = Specifier.getSpecifier(parentIdentifier);
 348         Specifier itemSpecifier = Specifier.getSpecifier(itemIdentifier);
 349         AuthorityItemSpecifier sasAuthorityItemSpecifier = new AuthorityItemSpecifier(authoritySpecifier, itemSpecifier);
 350         //
 351         // Get the remote payload
 352         //
 353         PoxPayloadIn sasPayloadIn = AuthorityServiceUtils.requestPayloadIn(sasAuthorityItemSpecifier,
 354                         ctx.getServiceName(), getEntityResponseType());
 355         //
 356         // Using the payload from the remote server, create a local copy of the item
 357         //
 358         AuthorityResource authorityResource = (AuthorityResource) ctx.getResource();
 359         Response response = authorityResource.createAuthorityItemWithParentContext(ctx, authoritySpecifier.getURNValue(),
 360                         sasPayloadIn, AuthorityServiceUtils.DONT_UPDATE_REV, AuthorityServiceUtils.NOT_PROPOSED);
 361         //
 362         // Check the response for successful POST result
 363         //
 364         if (response.getStatus() != Response.Status.CREATED.getStatusCode()) {
 365                 throw new DocumentException(String.format("Could not create new authority item '%s' during synchronization of the '%s' authority.",
 366                                 itemIdentifier, parentIdentifier));
 367         }
 368         //
 369         // Handle the workflow state
 370         //
 371         authorityResource.updateItemWorkflowWithTransition(ctx, parentIdentifier, itemIdentifier,
 372                         WorkflowClient.WORKFLOWTRANSITION_LOCK, AuthorityServiceUtils.DONT_UPDATE_REV);
 373         }
 374
 375     /**
 376      * Try to synchronize a remote item (using its refName) with a local item.  If the local doesn't yet
 377      * exist, we'll create it.
 378      * Result values:
 379      *  -1 = sync not needed; i.e., already in sync
 380      *   0 = sync succeeded
 381      *   1 = local item was missing so we created it
 382      * @param ctx
 383      * @param refName
 384      * @return
 385      * @throws Exception
 386      */
 387     protected long syncRemoteItemWithLocalItem(ServiceContext ctx, String itemRefName) throws Exception {
 388         long result = -1;
 389         //
 390         // Using the item refname (with no local CSID), create specifiers that we'll use to find the local versions
 391         //
 392         AuthorityTermInfo authorityTermInfo = RefNameUtils.parseAuthorityTermInfo(itemRefName);
 393         String parentIdentifier = Specifier.createShortIdURNValue(authorityTermInfo.inAuthority.name);
 394         String itemIdentifier = Specifier.createShortIdURNValue(authorityTermInfo.name);
 395         //
 396         // We'll use the Authority JAX-RS resource to peform sync operations (creates and updates)
 397         //
 398         AuthorityResource authorityResource = (AuthorityResource) ctx.getResource();
 399         PoxPayloadOut localItemPayloadOut;
 400         try {
 401                 localItemPayloadOut = authorityResource.getAuthorityItemWithExistingContext(ctx, parentIdentifier, itemIdentifier);
 402         } catch (DocumentNotFoundException dnf) {
 403                 //
 404                 // Document not found, means we need to create an item/term that exists only on the SAS
 405                 //
 406                 logger.info(String.format("Remote item with refname='%s' doesn't exist locally, so we'll create it.", itemRefName));
 407                 createLocalItem(ctx, parentIdentifier, itemIdentifier);
 408                 return 1; // exit with status of 1 means we created a new authority item
 409         }
 410         //
 411         // If we get here, we know the item exists both locally and remotely, so we need to synchronize them.
 412         //
 413         //
 414         try {
 415                 PoxPayloadOut theUpdate = authorityResource.synchronizeItemWithExistingContext(ctx, parentIdentifier, itemIdentifier);
 416                 if (theUpdate != null) {
 417                         result = 0; // means we needed to sync this item with SAS
 418                         logger.debug(String.format("Sync'd authority item parent='%s' id='%s with SAS.  Updated payload is: \n%s",
 419                                         parentIdentifier, itemIdentifier, theUpdate.getXmlPayload()));
 420                 }
 421         } catch (DocumentReferenceException de) { // Exception for items that still have records/resource referencing them.
 422                 result = -1;
 423                 logger.error(String.format("Could not sync authority item = '%s' because it has existing records referencing it.",
 424                                 itemIdentifier));
 425         }
 426
 427         return result; // -1 = no sync needed/possible, 0 = sync'd, 1 = created new item
 428     }
 429
 430     private PoxPayloadIn requestPayloadInItemList(ServiceContext ctx, Specifier specifier) throws Exception {
 431         PoxPayloadIn result = null;
 432
 433         AuthorityClient client = (AuthorityClient) ctx.getClient();
 434         Response res = client.readItemList(specifier.getURNValue(),
 435                         null,   // partial term string
 436                         null    // keyword string
 437                         );
 438         try {
 439                 int statusCode = res.getStatus();
 440
 441                 // Check the status code of the response: does it match
 442                 // the expected response(s)?
 443                 if (logger.isDebugEnabled()) {
 444                     logger.debug(client.getClass().getCanonicalName() + ": status = " + statusCode);
 445                 }
 446
 447             result = new PoxPayloadIn((String)res.readEntity(getEntityResponseType())); // Get the entire response!
 448         } finally {
 449                 res.close();
 450         }
 451
 452         return result;
 453     }
 454
 455
 456     /*
 457      * Non standard injection of CSID into common part, since caller may access through
 458      * shortId, and not know the CSID.
 459      * @see org.collectionspace.services.nuxeo.client.java.RemoteDocumentModelHandlerImpl#extractPart(org.nuxeo.ecm.core.api.DocumentModel, java.lang.String, org.collectionspace.services.common.service.ObjectPartType)
 460      */
 461     @Override
 462     protected Map<String, Object> extractPart(DocumentModel docModel, String schema, ObjectPartType partMeta)
 463             throws Exception {
 464         Map<String, Object> unQObjectProperties = super.extractPart(docModel, schema, partMeta);
 465
 466         // Add the CSID to the common part
 467         if (partMeta.getLabel().equalsIgnoreCase(authorityCommonSchemaName)) {
 468             String csid = getCsid(docModel);//NuxeoUtils.extractId(docModel.getPathAsString());
 469             unQObjectProperties.put("csid", csid);
 470         }
 471
 472         return unQObjectProperties;
 473     }
 474
 475     public void fillAllParts(DocumentWrapper<DocumentModel> wrapDoc, Action action) throws Exception {
 476         super.fillAllParts(wrapDoc, action);
 477         //
 478         // Update the record's revision number on both CREATE and UPDATE actions, but not on SYNC
 479         //
 480         if (this.getShouldUpdateRevNumber() == true) { // We won't update rev numbers on synchronization with SAS
 481                 updateRevNumbers(wrapDoc);
 482         }
 483     }
 484
 485     protected void updateRevNumbers(DocumentWrapper<DocumentModel> wrapDoc) {
 486         DocumentModel documentModel = wrapDoc.getWrappedObject();
 487         Long rev = (Long)documentModel.getProperty(authorityCommonSchemaName, AuthorityJAXBSchema.REV);
 488         if (rev == null) {
 489                 rev = (long)0;
 490         } else {
 491                 rev++;
 492         }
 493         documentModel.setProperty(authorityCommonSchemaName, AuthorityJAXBSchema.REV, rev);
 494     }
 495
 496     /*
 497      * We consider workflow state changes as changes that should bump the revision number
 498      * (non-Javadoc)
 499      * @see org.collectionspace.services.nuxeo.client.java.RemoteDocumentModelHandlerImpl#handleWorkflowTransition(org.collectionspace.services.common.document.DocumentWrapper, org.collectionspace.services.lifecycle.TransitionDef)
 500      */
 501     @Override
 502     public void handleWorkflowTransition(DocumentWrapper<DocumentModel> wrapDoc, TransitionDef transitionDef) throws Exception {
 503         // Update the revision number
 504         updateRevNumbers(wrapDoc);
 505     }
 506
 507     @Override
 508     public void handleCreate(DocumentWrapper<DocumentModel> wrapDoc) throws Exception {
 509         super.handleCreate(wrapDoc);
 510         // CSPACE-3178:
 511         // Uncomment once debugged and App layer is read to integrate
 512         // Experimenting with this uncommented now ...
 513         handleDisplayNameAsShortIdentifier(wrapDoc.getWrappedObject(), authorityCommonSchemaName);
 514         updateRefnameForAuthority(wrapDoc, authorityCommonSchemaName);//CSPACE-3178
 515     }
 516
 517     protected String buildWhereForShortId(String name) {
 518         return authorityCommonSchemaName
 519                 + ":" + AuthorityJAXBSchema.SHORT_IDENTIFIER
 520                 + "='" + name + "'";
 521     }
 522
 523     private boolean isUnique(DocumentModel docModel, String schemaName) throws DocumentException {
 524         return true;
 525     }
 526
 527     private boolean temp_isUnique(DocumentModel docModel, String schemaName) throws DocumentException {
 528         boolean result = true;
 529
 530         ServiceContext ctx = this.getServiceContext();
 531         String shortIdentifier = (String) docModel.getProperty(schemaName, AuthorityJAXBSchema.SHORT_IDENTIFIER);
 532         String nxqlWhereClause = buildWhereForShortId(shortIdentifier);
 533         try {
 534                         DocumentWrapper<DocumentModel> searchResultWrapper = getRepositoryClient(ctx).findDoc(ctx, nxqlWhereClause);
 535                         if (searchResultWrapper != null) {
 536                                 result = false;
 537                                 if (logger.isInfoEnabled() == true) {
 538                                         DocumentModel searchResult = searchResultWrapper.getWrappedObject();
 539                                         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'",
 540                                                         shortIdentifier, searchResult.getName());
 541                                         logger.trace(debugMsg);
 542                                 }
 543                         }
 544                 } catch (DocumentNotFoundException e) {
 545                         // Not a problem, just means we couldn't find another authority with that short ID
 546                 }
 547
 548         return result;
 549     }
 550
 551     /**
 552      * If no short identifier was provided in the input payload,
 553      * generate a short identifier from the display name. Either way though,
 554      * the short identifier needs to be unique.
 555      */
 556     private void handleDisplayNameAsShortIdentifier(DocumentModel docModel, String schemaName) throws Exception {
 557         String shortIdentifier = (String) docModel.getProperty(schemaName, AuthorityJAXBSchema.SHORT_IDENTIFIER);
 558         String displayName = (String) docModel.getProperty(schemaName, AuthorityJAXBSchema.DISPLAY_NAME);
 559         String shortDisplayName = "";
 560         String generateShortIdentifier = null;
 561         if (Tools.isEmpty(shortIdentifier)) {
 562                 generateShortIdentifier = AuthorityIdentifierUtils.generateShortIdentifierFromDisplayName(displayName, shortDisplayName);
 563             docModel.setProperty(schemaName, AuthorityJAXBSchema.SHORT_IDENTIFIER, shortIdentifier);
 564         }
 565
 566         if (isUnique(docModel, schemaName) == false) {
 567                 String shortId = generateShortIdentifier == null ? shortIdentifier : generateShortIdentifier;
 568                 String errMsgVerb = generateShortIdentifier == null ? "supplied" : "generated";
 569                 String errMsg = String.format("The %s short identifier '%s' was not unique, so the new authority could not be created.",
 570                                 errMsgVerb, shortId);
 571                 throw new DocumentException(errMsg);
 572         }
 573     }
 574
 575     /**
 576      * Generate a refName for the authority from the short identifier
 577      * and display name.
 578      *
 579      * All refNames for authorities are generated.  If a client supplies
 580      * a refName, it will be overwritten during create (per this method)
 581      * or discarded during update (per filterReadOnlyPropertiesForPart).
 582      *
 583      * @see #filterReadOnlyPropertiesForPart(Map<String, Object>, org.collectionspace.services.common.service.ObjectPartType)
 584      *
 585      */
 586     protected void updateRefnameForAuthority(DocumentWrapper<DocumentModel> wrapDoc, String schemaName) throws Exception {
 587         DocumentModel docModel = wrapDoc.getWrappedObject();
 588         RefName.Authority authority = (Authority) getRefName(getServiceContext(), docModel);
 589         String refName = authority.toString();
 590         docModel.setProperty(schemaName, AuthorityJAXBSchema.REF_NAME, refName);
 591     }
 592
 593     @Override
 594     public RefName.RefNameInterface getRefName(ServiceContext ctx,
 595                 DocumentModel docModel) {
 596         RefName.RefNameInterface refname = null;
 597
 598         try {
 599                 String shortIdentifier = (String) docModel.getProperty(authorityCommonSchemaName, AuthorityJAXBSchema.SHORT_IDENTIFIER);
 600                 String displayName = (String) docModel.getProperty(authorityCommonSchemaName, AuthorityJAXBSchema.DISPLAY_NAME);
 601                 RefName.Authority authority = RefName.Authority.buildAuthority(ctx.getTenantName(),
 602                         ctx.getServiceName(),
 603                         null,   // Only use shortId form!!!
 604                         shortIdentifier,
 605                         displayName);
 606                 refname = authority;
 607         } catch (Exception e) {
 608                 logger.error(e.getMessage(), e);
 609         }
 610
 611         return refname;
 612     }
 613
 614     @Override
 615     protected String getRefnameDisplayName(DocumentWrapper<DocumentModel> docWrapper) {
 616         String result = null;
 617
 618         DocumentModel docModel = docWrapper.getWrappedObject();
 619         ServiceContext<PoxPayloadIn, PoxPayloadOut> ctx = this.getServiceContext();
 620         RefName.Authority refname = (RefName.Authority)getRefName(ctx, docModel);
 621         result = refname.getDisplayName();
 622
 623         return result;
 624     }
 625
 626     public String getShortIdentifier(ServiceContext ctx, String authCSID, String schemaName) throws Exception {
 627         String shortIdentifier = null;
 628         CoreSessionInterface repoSession = null;
 629         boolean releaseSession = false;
 630
 631         RepositoryClientImpl nuxeoRepoClient = (RepositoryClientImpl)this.getRepositoryClient(ctx);
 632         try {
 633                 repoSession = nuxeoRepoClient.getRepositorySession(ctx);
 634             DocumentWrapper<DocumentModel> wrapDoc = nuxeoRepoClient.getDocFromCsid(ctx, repoSession, authCSID);
 635             DocumentModel docModel = wrapDoc.getWrappedObject();
 636             if (docModel == null) {
 637                 throw new DocumentNotFoundException(String.format("Could not find authority resource with CSID='%s'.", authCSID));
 638             }
 639             shortIdentifier = (String) docModel.getProperty(schemaName, AuthorityJAXBSchema.SHORT_IDENTIFIER);
 640         } catch (ClientException ce) {
 641             throw new RuntimeException("AuthorityDocHandler Internal Error: cannot get shortId!", ce);
 642         } finally {
 643                 if (repoSession != null) {
 644                         nuxeoRepoClient.releaseRepositorySession(ctx, repoSession);
 645                 }
 646         }
 647
 648         return shortIdentifier;
 649     }
 650
 651     /**
 652      * Filters out selected values supplied in an update request.
 653      *
 654      * @param objectProps the properties filtered out from the update payload
 655      * @param partMeta metadata for the object to fill
 656      */
 657     @Override
 658     public void filterReadOnlyPropertiesForPart(
 659             Map<String, Object> objectProps, ObjectPartType partMeta) {
 660         super.filterReadOnlyPropertiesForPart(objectProps, partMeta);
 661         String commonPartLabel = getServiceContext().getCommonPartLabel();
 662         if (partMeta.getLabel().equalsIgnoreCase(commonPartLabel)) {
 663             objectProps.remove(AuthorityJAXBSchema.CSID);
 664             objectProps.remove(AuthorityJAXBSchema.SHORT_IDENTIFIER);
 665             objectProps.remove(AuthorityJAXBSchema.REF_NAME);
 666         }
 667     }
 668 }