/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.chemistry.opencmis.inmemory;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
import java.math.BigInteger;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import org.apache.chemistry.opencmis.commons.PropertyIds;
import org.apache.chemistry.opencmis.commons.data.ContentStream;
import org.apache.chemistry.opencmis.commons.data.ObjectData;
import org.apache.chemistry.opencmis.commons.data.ObjectList;
import org.apache.chemistry.opencmis.commons.data.Properties;
import org.apache.chemistry.opencmis.commons.data.PropertyBoolean;
import org.apache.chemistry.opencmis.commons.data.PropertyData;
import org.apache.chemistry.opencmis.commons.data.PropertyId;
import org.apache.chemistry.opencmis.commons.data.PropertyString;
import org.apache.chemistry.opencmis.commons.definitions.DocumentTypeDefinition;
import org.apache.chemistry.opencmis.commons.definitions.PropertyDefinition;
import org.apache.chemistry.opencmis.commons.definitions.TypeDefinition;
import org.apache.chemistry.opencmis.commons.enums.BaseTypeId;
import org.apache.chemistry.opencmis.commons.enums.IncludeRelationships;
import org.apache.chemistry.opencmis.commons.enums.VersioningState;
import org.apache.chemistry.opencmis.commons.exceptions.CmisConstraintException;
import org.apache.chemistry.opencmis.commons.exceptions.CmisObjectNotFoundException;
import org.apache.chemistry.opencmis.commons.exceptions.CmisUpdateConflictException;
import org.apache.chemistry.opencmis.commons.impl.dataobjects.PropertyStringDefinitionImpl;
import org.apache.chemistry.opencmis.commons.server.CallContext;
import org.apache.chemistry.opencmis.commons.spi.Holder;
import org.apache.chemistry.opencmis.inmemory.types.InMemoryDocumentTypeDefinition;
import org.apache.chemistry.opencmis.inmemory.types.PropertyCreationHelper;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
public class VersioningTest extends AbstractServiceTest {
private static final Log log = LogFactory.getLog(ObjectServiceTest.class);
private static final String PROP_VALUE = "Mickey Mouse";
private static final String PROP_VALUE_NEW = "Donald Duck";
private static final String PROP_NAME = "My Versioned Document";
private static final String TEST_USER = "TestUser";
private static final String TEST_USER_2 = "OtherUser";
ObjectCreator fCreator;
@Override
@Before
public void setUp() {
super.setTypeCreatorClass(VersionTestTypeSystemCreator.class.getName());
super.setUp();
fCreator = new ObjectCreator(fFactory, fObjSvc, fRepositoryId);
setRuntimeContext(TEST_USER);
}
@Override
@After
public void tearDown() {
super.tearDown();
}
private void setRuntimeContext(String user) {
/*
* DummyCallContext ctx = new DummyCallContext();
* ctx.put(CallContext.USERNAME, user); // Attach the CallContext to a
* thread local context that can be accessed from everywhere
* RuntimeContext.attachCfg(ctx);
*/
((DummyCallContext) fTestCallContext).put(CallContext.USERNAME, user);
}
@Test
public void testCreateVersionedDocumentMinor() {
createVersionedDocument(VersioningState.MINOR);
}
@Test
public void testCreateVersionedDocumentCheckedOut() {
createVersionedDocument(VersioningState.CHECKEDOUT);
}
@Test
public void testCreateVersionedDocumentNone() {
try {
createVersionedDocument(VersioningState.NONE);
fail("creating a document of a versionable type with state VersioningState.NONE should fail.");
} catch (Exception e) {
assertEquals(CmisConstraintException.class, e.getClass());
}
}
@Test
public void testCheckOutBasic() {
String verId = createDocument(PROP_NAME, fRootFolderId, VersioningState.MAJOR);
ObjectData version = fObjSvc.getObject(fRepositoryId, verId, "*", false, IncludeRelationships.NONE, null,
false, false, null);
String docId = getVersionSeriesId(verId, version.getProperties().getProperties());
assertTrue(null != docId && docId.length() > 0);
assertFalse(isCheckedOut(version.getProperties().getProperties()));
Holder<Boolean> contentCopied = new Holder<Boolean>();
Holder<String> idHolder = new Holder<String>(verId); // or should this
// be version
// series?
fVerSvc.checkOut(fRepositoryId, idHolder, null, contentCopied);
String pwcId = idHolder.getValue();
// test that object is checked out and that all properties are set
// correctly
Properties props = fObjSvc.getProperties(fRepositoryId, pwcId, "*", null);
String changeToken = (String) props.getProperties().get(PropertyIds.CHANGE_TOKEN).getFirstValue();
checkVersionProperties(pwcId, VersioningState.CHECKEDOUT, props.getProperties(), null);
// Test that a second checkout is not possible
try {
fVerSvc.checkOut(fRepositoryId, idHolder, null, contentCopied);
fail("Checking out a document that is already checked-out should fail.");
} catch (Exception e) {
assertTrue(e instanceof CmisUpdateConflictException);
}
// version and version series should be checked out now
// assertTrue(isCheckedOut(docId));
assertTrue(isCheckedOut(pwcId));
// Set a new content and modify property
ContentStream altContent = fCreator.createAlternateContent();
idHolder = new Holder<String>(pwcId);
Holder<String> tokenHolder = new Holder<String>(changeToken);
fObjSvc.setContentStream(fRepositoryId, idHolder, true, tokenHolder, altContent, null);
fCreator.updateProperty(idHolder.getValue(), VersionTestTypeSystemCreator.PROPERTY_ID, PROP_VALUE_NEW);
// Test that a check-in as same user is possible
String checkinComment = "Checkin without content and properties.";
fVerSvc.checkIn(fRepositoryId, idHolder, true, null, null, checkinComment, null, null, null, null);
// Neither the version nor the version series should be checked out any
// longer:
assertFalse(isCheckedOut(idHolder.getValue()));
// assertFalse(isCheckedOut(docId));
ContentStream retrievedContent = fObjSvc.getContentStream(fRepositoryId, idHolder.getValue(), null, BigInteger
.valueOf(-1) /* offset */, BigInteger.valueOf(-1) /* length */, null);
assertTrue(fCreator.verifyContent(fCreator.createAlternateContent(), retrievedContent));
assertTrue(fCreator.verifyProperty(idHolder.getValue(), VersionTestTypeSystemCreator.PROPERTY_ID,
PROP_VALUE_NEW));
List<ObjectData> allVersions = fVerSvc.getAllVersions(fRepositoryId, docId, docId, "*", false, null);
assertEquals(2, allVersions.size());
}
@Test
public void testCheckInWithContent() {
String verId = createDocument(PROP_NAME, fRootFolderId, VersioningState.MAJOR);
ObjectData version = fObjSvc.getObject(fRepositoryId, verId, "*", false, IncludeRelationships.NONE, null,
false, false, null);
String docId = getVersionSeriesId(verId, version.getProperties().getProperties());
assertTrue(null != docId && docId.length() > 0);
assertFalse(isCheckedOut(version.getProperties().getProperties()));
Holder<Boolean> contentCopied = new Holder<Boolean>();
Holder<String> idHolder = new Holder<String>(verId); // or should this
// be version
// series?
fVerSvc.checkOut(fRepositoryId, idHolder, null, contentCopied);
String pwcId = idHolder.getValue();
ContentStream altContent = fCreator.createAlternateContent();
Properties newProps = fCreator.getUpdatePropertyList(VersionTestTypeSystemCreator.PROPERTY_ID, PROP_VALUE_NEW);
idHolder = new Holder<String>(pwcId);
// assertTrue(isCheckedOut(docId));
assertTrue(isCheckedOut(pwcId));
// Test check-in and pass content and properties
String checkinComment = "Checkin with content and properties.";
fVerSvc.checkIn(fRepositoryId, idHolder, true, newProps, altContent, checkinComment, null, null, null, null);
// Neither the version nor the version series should be checked out any
// longer:
assertFalse(isCheckedOut(idHolder.getValue()));
// assertFalse(isCheckedOut(docId));
ContentStream retrievedContent = fObjSvc.getContentStream(fRepositoryId, idHolder.getValue(), null, BigInteger
.valueOf(-1) /* offset */, BigInteger.valueOf(-1) /* length */, null);
// New content and property should be set
assertTrue(fCreator.verifyContent(fCreator.createAlternateContent(), retrievedContent));
assertTrue(fCreator.verifyProperty(idHolder.getValue(), VersionTestTypeSystemCreator.PROPERTY_ID,
PROP_VALUE_NEW));
}
@Test
public void testCheckOutAndOtherUser() {
String verId = createDocument(PROP_NAME, fRootFolderId, VersioningState.MAJOR);
ObjectData version = fObjSvc.getObject(fRepositoryId, verId, "*", false, IncludeRelationships.NONE, null,
false, false, null);
String docId = getVersionSeriesId(verId, version.getProperties().getProperties());
assertTrue(null != docId && docId.length() > 0);
assertFalse(isCheckedOut(version.getProperties().getProperties()));
Holder<Boolean> contentCopied = new Holder<Boolean>();
Holder<String> idHolder = new Holder<String>(verId); // or should this
// be version
// series?
fVerSvc.checkOut(fRepositoryId, idHolder, null, contentCopied);
String pwcId = idHolder.getValue();
// Test that a checkin as another user is not possible
setRuntimeContext(TEST_USER_2);
try {
fVerSvc.checkIn(fRepositoryId, idHolder, true, null, null, "My Comment", null, null, null, null);
fail("Checking in a document as another user should fail.");
} catch (Exception e) {
assertTrue(e instanceof CmisUpdateConflictException);
}
// Test that a cancel checkout as another user is not possible
try {
fVerSvc.cancelCheckOut(fRepositoryId, pwcId, null);
fail("Checking in a document as another user should fail.");
} catch (Exception e) {
assertTrue(e instanceof CmisUpdateConflictException);
}
// Test that an updateProperties as another user is not possible
try {
fCreator.updateProperty(pwcId, VersionTestTypeSystemCreator.PROPERTY_ID, PROP_VALUE_NEW);
fail("updateProperty in a document as another user should fail.");
} catch (Exception e) {
assertTrue(e instanceof CmisUpdateConflictException);
}
ContentStream altContent = fCreator.createAlternateContent();
Holder<String> pwcHolder = new Holder<String>(pwcId);
try {
fObjSvc.setContentStream(fRepositoryId, pwcHolder, true, null, altContent, null);
fail("setContentStream in a document as another user should fail.");
} catch (Exception e) {
assertTrue(e instanceof CmisUpdateConflictException);
}
setRuntimeContext(TEST_USER);
// Test that a check-in as same user is possible
fVerSvc.checkIn(fRepositoryId, pwcHolder, true, null, null, "testCheckOutAndOtherUser", null, null, null, null);
// Because nothing was changed we should have a new version with
// identical content
ContentStream retrievedContent = fObjSvc.getContentStream(fRepositoryId, pwcHolder.getValue(), null, BigInteger
.valueOf(-1) /* offset */, BigInteger.valueOf(-1) /* length */, null);
assertTrue(fCreator.verifyContent(retrievedContent, fCreator.createContent()));
assertTrue(fCreator.verifyProperty(idHolder.getValue(), VersionTestTypeSystemCreator.PROPERTY_ID, PROP_VALUE));
}
@Test
public void testCancelCheckout() {
String verId = createDocument(PROP_NAME, fRootFolderId, VersioningState.MAJOR);
ObjectData version = fObjSvc.getObject(fRepositoryId, verId, "*", false, IncludeRelationships.NONE, null,
false, false, null);
String idOfLastVersion = version.getId();
String docId = getVersionSeriesId(verId, version.getProperties().getProperties());
assertTrue(null != docId && docId.length() > 0);
assertFalse(isCheckedOut(version.getProperties().getProperties()));
Holder<Boolean> contentCopied = new Holder<Boolean>();
Holder<String> idHolder = new Holder<String>(verId); // or should this
// be version
// series?
fVerSvc.checkOut(fRepositoryId, idHolder, null, contentCopied);
String pwcId = idHolder.getValue();
// Set a new content and modify property
Properties props = fObjSvc.getProperties(fRepositoryId, pwcId, "*", null);
String changeToken = (String) props.getProperties().get(PropertyIds.CHANGE_TOKEN).getFirstValue();
ContentStream altContent = fCreator.createAlternateContent();
idHolder = new Holder<String>(pwcId);
Holder<String> tokenHolder = new Holder<String>(changeToken);
fObjSvc.setContentStream(fRepositoryId, idHolder, true, tokenHolder, altContent, null);
fCreator.updateProperty(idHolder.getValue(), VersionTestTypeSystemCreator.PROPERTY_ID, PROP_VALUE_NEW);
// cancel checkout
fVerSvc.cancelCheckOut(fRepositoryId, pwcId, null);
try {
// Verify that pwc no longer exists
fObjSvc.getObject(fRepositoryId, pwcId, "*", false, IncludeRelationships.NONE, null, false, false, null);
fail("Getting pwc after cancel checkout should fail.");
} catch (CmisObjectNotFoundException e1) {
} catch (Exception e2) {
fail("Expected a CmisObjectNotFoundException after cancel checkin, but got a " + e2.getClass().getName());
}
// verify that the old content and properties are still valid
assertTrue(fCreator.verifyProperty(idOfLastVersion, VersionTestTypeSystemCreator.PROPERTY_ID, PROP_VALUE));
ContentStream retrievedContent = fObjSvc.getContentStream(fRepositoryId, idOfLastVersion, null, BigInteger
.valueOf(-1) /* offset */, BigInteger.valueOf(-1) /* length */, null);
assertTrue(fCreator.verifyContent(retrievedContent, fCreator.createContent()));
}
@Test
public void testGetPropertiesOfLatestVersion() {
VersioningState versioningState = VersioningState.MAJOR;
String verId = createDocument(PROP_NAME, fRootFolderId, versioningState);
getDocument(verId);
ObjectData version = fObjSvc.getObject(fRepositoryId, verId, "*", false, IncludeRelationships.NONE, null,
false, false, null);
String docId = getVersionSeriesId(verId, version.getProperties().getProperties());
assertTrue(null != docId && docId.length() > 0);
Holder<Boolean> contentCopied = new Holder<Boolean>();
Holder<String> idHolder = new Holder<String>(verId); // or should this
// be version
// series?
fVerSvc.checkOut(fRepositoryId, idHolder, null, contentCopied);
String pwcId = idHolder.getValue();
ContentStream altContent = fCreator.createAlternateContent();
Properties newProps = fCreator.getUpdatePropertyList(VersionTestTypeSystemCreator.PROPERTY_ID, PROP_VALUE_NEW);
idHolder = new Holder<String>(pwcId);
// assertTrue(isCheckedOut(docId));
assertTrue(isCheckedOut(pwcId));
// Test check-in and pass content and properties
String checkinComment = "Checkin with content and properties.";
fVerSvc.checkIn(fRepositoryId, idHolder, true, newProps, altContent, checkinComment, null, null, null, null);
Properties latest = fVerSvc.getPropertiesOfLatestVersion(fRepositoryId, docId, docId, true, "*", null);
assertNotNull(latest);
checkVersionProperties(verId, versioningState, latest.getProperties(), checkinComment);
}
@Test
public void testGetLatestVersion() {
VersioningState versioningState = VersioningState.MINOR;
String verId = createDocument(PROP_NAME, fRootFolderId, versioningState);
getDocument(verId);
ObjectData version = fObjSvc.getObject(fRepositoryId, verId, "*", false, IncludeRelationships.NONE, null,
false, false, null);
String docId = getVersionSeriesId(verId, version.getProperties().getProperties());
assertTrue(null != docId && docId.length() > 0);
Holder<Boolean> contentCopied = new Holder<Boolean>();
Holder<String> idHolder = new Holder<String>(verId); // or should this
// be version
// series?
fVerSvc.checkOut(fRepositoryId, idHolder, null, contentCopied);
String pwcId = idHolder.getValue();
ContentStream altContent = fCreator.createAlternateContent();
Properties newProps = fCreator.getUpdatePropertyList(VersionTestTypeSystemCreator.PROPERTY_ID, PROP_VALUE_NEW);
idHolder = new Holder<String>(pwcId);
// assertTrue(isCheckedOut(docId));
assertTrue(isCheckedOut(pwcId));
// Test check-in and pass content and properties
String checkinComment = "Checkin with content and properties.";
fVerSvc.checkIn(fRepositoryId, idHolder, true, newProps, altContent, checkinComment, null, null, null, null);
// get latest major version
versioningState = VersioningState.MAJOR;
boolean isMajor = true;
ObjectData objData = fVerSvc.getObjectOfLatestVersion(fRepositoryId, docId, docId, isMajor, "*", false,
IncludeRelationships.NONE, null, false, false, null);
checkVersionProperties(verId, versioningState, objData.getProperties().getProperties(), checkinComment);
ContentStream retrievedContent = fObjSvc.getContentStream(fRepositoryId, objData.getId(), null, BigInteger
.valueOf(-1) /* offset */, BigInteger.valueOf(-1) /* length */, null);
assertTrue(fCreator.verifyContent(retrievedContent, fCreator.createAlternateContent()));
// get latest non-major version, must be the same as before
versioningState = VersioningState.MAJOR;
isMajor = false;
objData = fVerSvc.getObjectOfLatestVersion(fRepositoryId, docId, docId, isMajor, "*", false,
IncludeRelationships.NONE, null, false, false, null);
checkVersionProperties(verId, versioningState, objData.getProperties().getProperties(), checkinComment);
retrievedContent = fObjSvc.getContentStream(fRepositoryId, objData.getId(), null,
BigInteger.valueOf(-1) /* offset */, BigInteger.valueOf(-1) /* length */, null);
assertTrue(fCreator.verifyContent(retrievedContent, fCreator.createAlternateContent()));
}
@Test
public void testGetCheckedOutDocuments() {
// create two folders with each having two documents, one of them being
// checked out
final int count = 2;
String[] folderIds = createLevel1Folders();
String[] verSeriesIds = new String[folderIds.length * count];
for (int i = 0; i < folderIds.length; i++) {
for (int j = 0; j < count; j++) {
String verId = createDocument("MyDoc" + j, folderIds[i], VersioningState.MAJOR);
ObjectData od = fObjSvc.getObject(fRepositoryId, verId, "*", false, IncludeRelationships.NONE, null,
false, false, null);
verSeriesIds[i * folderIds.length + j] = verId;
}
}
// checkout first in each folder
Holder<Boolean> contentCopied = new Holder<Boolean>();
Holder<String> idHolder = new Holder<String>(verSeriesIds[0]);
fVerSvc.checkOut(fRepositoryId, idHolder, null, contentCopied);
idHolder = new Holder<String>(verSeriesIds[2]);
fVerSvc.checkOut(fRepositoryId, idHolder, null, contentCopied);
// must be one in first folder
ObjectList checkedOutDocuments = fNavSvc.getCheckedOutDocs(fRepositoryId, folderIds[0], "*", null, false,
IncludeRelationships.NONE, null, BigInteger.valueOf(-1), BigInteger.valueOf(-1), null);
assertEquals(1, checkedOutDocuments.getNumItems().longValue());
assertEquals(1, checkedOutDocuments.getObjects().size());
// must be one in second folder
checkedOutDocuments = fNavSvc.getCheckedOutDocs(fRepositoryId, folderIds[1], "*", null, false,
IncludeRelationships.NONE, null, BigInteger.valueOf(-1), BigInteger.valueOf(-1), null);
assertEquals(1, checkedOutDocuments.getNumItems().longValue());
assertEquals(1, checkedOutDocuments.getObjects().size());
// must be two in repository
checkedOutDocuments = fNavSvc.getCheckedOutDocs(fRepositoryId, null, "*", null, false,
IncludeRelationships.NONE, null, BigInteger.valueOf(-1), BigInteger.valueOf(-1), null);
assertEquals(2, checkedOutDocuments.getNumItems().longValue());
assertEquals(2, checkedOutDocuments.getObjects().size());
}
@Test
public void testModifyOldVersions() {
String versionSeriesId = createVersionSeriesWithThreeVersions();
List<ObjectData> allVersions = fVerSvc.getAllVersions(fRepositoryId, null, versionSeriesId, "*", false, null);
assertEquals(3, allVersions.size());
}
private String[] createLevel1Folders() {
final int num = 2;
String[] res = new String[num];
for (int i = 0; i < num; i++) {
List<PropertyData<?>> properties = new ArrayList<PropertyData<?>>();
properties.add(fFactory.createPropertyIdData(PropertyIds.NAME, "Folder " + i));
properties.add(fFactory.createPropertyIdData(PropertyIds.OBJECT_TYPE_ID, BaseTypeId.CMIS_FOLDER.value()));
Properties props = fFactory.createPropertiesData(properties);
String id = fObjSvc.createFolder(fRepositoryId, props, fRootFolderId, null, null, null, null);
res[i] = id;
}
return res;
}
private void createVersionedDocument(VersioningState versioningState) {
// type id is:
// VersionTestTypeSystemCreator.VERSION_TEST_DOCUMENT_TYPE_ID
String verId = createDocument(PROP_NAME, fRootFolderId, versioningState);
getDocument(verId);
ObjectData version = fObjSvc.getObject(fRepositoryId, verId, "*", false, IncludeRelationships.NONE, null,
false, false, null);
String docId = getVersionSeriesId(verId, version.getProperties().getProperties());
assertTrue(null != docId && docId.length() > 0);
List<ObjectData> allVersions = fVerSvc.getAllVersions(fRepositoryId, docId, docId, "*", false, null);
assertEquals(1, allVersions.size());
checkVersionProperties(verId, versioningState, allVersions.get(0).getProperties().getProperties(), null);
}
private static String getVersionSeriesId(String docId, Map<String, PropertyData<?>> props) {
PropertyId pdid = (PropertyId) props.get(PropertyIds.VERSION_SERIES_ID);
assertNotNull(pdid);
String sVal = pdid.getFirstValue();
assertNotNull(sVal);
return sVal;
}
private boolean isCheckedOut(String objectId) {
Properties props = fObjSvc.getProperties(fRepositoryId, objectId, "*", null);
return isCheckedOut(props.getProperties());
}
private static boolean isCheckedOut(Map<String, PropertyData<?>> props) {
PropertyBoolean pdb = (PropertyBoolean) props.get(PropertyIds.IS_VERSION_SERIES_CHECKED_OUT);
assertNotNull(pdb);
boolean bVal = pdb.getFirstValue();
return bVal;
}
private void checkVersionProperties(String docId, VersioningState versioningState,
Map<String, PropertyData<?>> props, String checkinComment) {
for (PropertyData<?> pd : props.values()) {
log.info("return property id: " + pd.getId() + ", value: " + pd.getValues());
}
DocumentTypeDefinition typeDef = (DocumentTypeDefinition) fRepSvc.getTypeDefinition(fRepositoryId,
VersionTestTypeSystemCreator.VERSION_TEST_DOCUMENT_TYPE_ID, null);
PropertyBoolean pdb = (PropertyBoolean) props.get(PropertyIds.IS_LATEST_VERSION);
assertNotNull(pdb);
boolean bVal = pdb.getFirstValue();
assertEquals(versioningState != VersioningState.CHECKEDOUT, bVal); // if
// checked
// out
// it
// isn
// 't
// the
// latest
// version
pdb = (PropertyBoolean) props.get(PropertyIds.IS_MAJOR_VERSION);
assertNotNull(pdb);
bVal = pdb.getFirstValue();
assertEquals(versioningState == VersioningState.MAJOR, bVal);
pdb = (PropertyBoolean) props.get(PropertyIds.IS_LATEST_MAJOR_VERSION);
assertNotNull(pdb);
bVal = pdb.getFirstValue();
assertEquals(versioningState == VersioningState.MAJOR, bVal);
PropertyId pdid = (PropertyId) props.get(PropertyIds.VERSION_SERIES_ID);
assertNotNull(pdid);
String sVal = pdid.getFirstValue();
// if (typeDef.isVersionable()) // need not be
// assertFalse(docId.equals(sVal));
// else
// assertEquals(docId, sVal);
pdb = (PropertyBoolean) props.get(PropertyIds.IS_VERSION_SERIES_CHECKED_OUT);
assertNotNull(pdb);
bVal = pdb.getFirstValue();
assertEquals(versioningState == VersioningState.CHECKEDOUT, bVal);
PropertyString pds = (PropertyString) props.get(PropertyIds.VERSION_SERIES_CHECKED_OUT_BY);
assertNotNull(pds);
sVal = pds.getFirstValue();
if (versioningState == VersioningState.CHECKEDOUT) {
assertTrue(sVal != null && sVal.length() > 0);
} else {
assertTrue(null == sVal || sVal.equals(""));
}
pdid = (PropertyId) props.get(PropertyIds.VERSION_SERIES_CHECKED_OUT_ID);
assertNotNull(pdid);
sVal = pdid.getFirstValue();
if (versioningState == VersioningState.CHECKEDOUT) {
assertTrue(sVal != null && sVal.length() > 0);
} else {
assertTrue(null == sVal || sVal.equals(""));
}
pds = (PropertyString) props.get(PropertyIds.CHECKIN_COMMENT);
assertNotNull(pdb);
sVal = pds.getFirstValue();
if (checkinComment == null) {
assertTrue(null == sVal);
} else {
assertEquals(checkinComment, sVal);
}
}
@Override
public String getDocument(String id) {
String returnedId = null;
try {
ObjectData res = fObjSvc.getObject(fRepositoryId, id, "*", false, IncludeRelationships.NONE, null, false,
false, null);
assertNotNull(res);
testReturnedProperties(res.getProperties().getProperties());
returnedId = res.getId();
assertEquals(id, returnedId);
} catch (Exception e) {
fail("getObject() failed with exception: " + e);
}
return returnedId;
}
private static void testReturnedProperties(Map<String, PropertyData<?>> props) {
for (PropertyData<?> pd : props.values()) {
log.info("return property id: " + pd.getId() + ", value: " + pd.getValues());
}
PropertyData<?> pd = props.get(PropertyIds.NAME);
assertNotNull(pd);
assertEquals(PROP_NAME, pd.getFirstValue());
pd = props.get(PropertyIds.OBJECT_TYPE_ID);
assertEquals(VersionTestTypeSystemCreator.VERSION_TEST_DOCUMENT_TYPE_ID, pd.getFirstValue());
pd = props.get(VersionTestTypeSystemCreator.PROPERTY_ID);
assertEquals(PROP_VALUE, pd.getFirstValue());
}
private String createDocument(String name, String folderId, VersioningState versioningState) {
String id = null;
Map<String, String> properties = new HashMap<String, String>();
properties.put(VersionTestTypeSystemCreator.PROPERTY_ID, PROP_VALUE);
id = fCreator.createDocument(name, VersionTestTypeSystemCreator.VERSION_TEST_DOCUMENT_TYPE_ID, folderId,
versioningState, properties);
return id;
}
private String createVersionSeriesWithThreeVersions() {
String verIdV1 = createDocument(PROP_NAME, fRootFolderId, VersioningState.MAJOR);
getDocument(verIdV1);
ObjectData version = fObjSvc.getObject(fRepositoryId, verIdV1, "*", false, IncludeRelationships.NONE, null,
false, false, null);
String verSeriesId = getVersionSeriesId(verIdV1, version.getProperties().getProperties());
// create second version with different content
Holder<String> idHolder = new Holder<String>(verIdV1);
Holder<Boolean> contentCopied = new Holder<Boolean>(false);
fVerSvc.checkOut(fRepositoryId, idHolder, null, contentCopied);
ContentStream content2 = createContent('a');
Properties newProps = fCreator.getUpdatePropertyList(VersionTestTypeSystemCreator.PROPERTY_ID,
"PropertyFromVersion2");
idHolder = new Holder<String>(verIdV1);
// Test check-in and pass content and properties
String checkinComment = "Checkin from Unit Test-2.";
fVerSvc.checkIn(fRepositoryId, idHolder, true, newProps, content2, checkinComment, null, null, null, null);
String verIdV2 = idHolder.getValue();
// create third version with different content
contentCopied = new Holder<Boolean>(false);
fVerSvc.checkOut(fRepositoryId, idHolder, null, contentCopied);
ContentStream content3 = super.createContent('a');
newProps = fCreator.getUpdatePropertyList(VersionTestTypeSystemCreator.PROPERTY_ID, "PropertyFromVersion3");
// Test check-in and pass content and properties
checkinComment = "Checkin from Unit Test-3.";
fVerSvc.checkIn(fRepositoryId, idHolder, true, newProps, content3, checkinComment, null, null, null, null);
/* String verIdV3 = */idHolder.getValue();
// Try to update version2 which should fail (on a versioned document
// only a document that
// is checked out can be modified.
try {
fCreator.updateProperty(verIdV2, VersionTestTypeSystemCreator.PROPERTY_ID, "ChangeWithoutCheckout");
fail("updateProperty for an older version should fail.");
} catch (Exception e) {
assertTrue(e instanceof CmisUpdateConflictException);
}
// try to set content on an older version
ContentStream content4 = super.createContent('x');
idHolder = new Holder<String>(verIdV2);
try {
fObjSvc.setContentStream(fRepositoryId, idHolder, true, null, content4, null);
fail("setContentStream for an older version should fail.");
} catch (Exception e) {
assertTrue(e instanceof CmisUpdateConflictException);
}
return verSeriesId;
}
public static class VersionTestTypeSystemCreator implements TypeCreator {
public static final String VERSION_TEST_DOCUMENT_TYPE_ID = "MyVersionedType";
public static final String PROPERTY_ID = "StringProp";
public List<TypeDefinition> createTypesList() {
// always add CMIS default types
List<TypeDefinition> typesList = new LinkedList<TypeDefinition>();
// create a complex type with properties
InMemoryDocumentTypeDefinition cmisComplexType = new InMemoryDocumentTypeDefinition(
VERSION_TEST_DOCUMENT_TYPE_ID, "VersionedType", InMemoryDocumentTypeDefinition
.getRootDocumentType());
// create a single String property definition
Map<String, PropertyDefinition<?>> propertyDefinitions = new HashMap<String, PropertyDefinition<?>>();
PropertyStringDefinitionImpl prop1 = PropertyCreationHelper.createStringDefinition(PROPERTY_ID,
"Sample String Property");
propertyDefinitions.put(prop1.getId(), prop1);
cmisComplexType.addCustomPropertyDefinitions(propertyDefinitions);
cmisComplexType.setIsVersionable(true); // make it a versionable
// type;
// add type to types collection
typesList.add(cmisComplexType);
return typesList;
}
} // ObjectTestTypeSystemCreator
}