[tmp/jakarta-migration.git] /

/**
 * This document is a part of the source code and related artifacts
 * for CollectionSpace, an open source collections management system
 * for museums and related institutions:
 *
 * http://www.collectionspace.org
 * http://wiki.collectionspace.org
 *
 * Copyright (c)) 2009 Regents of the University of California
 *
 * Licensed under the Educational Community License (ECL), Version 2.0.
 * You may not use this file except in compliance with this License.
 *
 * You may obtain a copy of the ECL 2.0 License at
 * https://source.collectionspace.org/collection-space/LICENSE.txt
 *
 * 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.collectionspace.services.client.test;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.ws.rs.core.Response;

import org.collectionspace.services.WorkJAXBSchema;
import org.collectionspace.services.client.AbstractCommonListUtils;
import org.collectionspace.services.client.AuthorityClient;
import org.collectionspace.services.client.CollectionSpaceClient;
import org.collectionspace.services.client.PayloadOutputPart;
import org.collectionspace.services.client.PoxPayloadIn;
import org.collectionspace.services.client.PoxPayloadOut;
import org.collectionspace.services.client.WorkAuthorityClient;
import org.collectionspace.services.client.WorkAuthorityClientUtils;
import org.collectionspace.services.jaxb.AbstractCommonList;
import org.collectionspace.services.work.WorkTermGroup;
import org.collectionspace.services.work.WorkTermGroupList;
import org.collectionspace.services.work.WorkauthoritiesCommon;
import org.collectionspace.services.work.WorksCommon;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testng.Assert;
import org.testng.annotations.AfterClass;
import org.testng.annotations.Test;

/**
 * WorkAuthorityServiceTest, carries out tests against a
 * deployed and running WorkAuthority Service.
 *
 */
public class WorkAuthorityServiceTest extends AbstractAuthorityServiceTest<WorkauthoritiesCommon, WorksCommon> {

    /** The logger. */
    private final String CLASS_NAME = WorkAuthorityServiceTest.class.getName();
    private final Logger logger = LoggerFactory.getLogger(WorkAuthorityServiceTest.class);

    @Override
    public String getServicePathComponent() {
        return WorkAuthorityClient.SERVICE_PATH_COMPONENT;
    }

    @Override
    protected String getServiceName() {
        return WorkAuthorityClient.SERVICE_NAME;
    }
    
    public String getItemServicePathComponent() {
        return AuthorityClient.ITEMS;
    }   
    
    // Instance variables specific to this test.
    
//    /** The SERVICE path component. */
//    final String SERVICE_PATH_COMPONENT = "workauthorities";
//    
//    /** The ITEM service path component. */
//    final String ITEM_SERVICE_PATH_COMPONENT = "items";
//    

    final String TEST_WORK_TERM_DISPLAY_NAME = "Muppets Take Manhattan (1984)";
    final String TEST_WORK_TERM_NAME = "Muppets Take Manhattan";
    final String TEST_WORK_TERM_TYPE = "";
    final String TEST_WORK_TERM_STATUS = "accepted";
    final String TEST_WORK_TERM_QUALIFIER = "";
    final String TEST_WORK_TERM_LANGUAGE = "english";
    final Boolean TEST_WORK_TERM_PREFFORLANG = true;
    final String TEST_WORK_TERM_SOURCE = "featurefilms";
    final String TEST_WORK_TERM_SOURCE_DETAIL = "internal";
    final String TEST_WORK_TERM_SOURCE_ID = "12345";    
    final String TEST_WORK_TERM_SOURCE_NOTE = "source note goes here";
    final String TEST_WORK_HISTORY_NOTE = "history note goes here";
    final String TEST_WORK_TYPE = "work type goes here";
    final String TEST_WORK_CREATOR_GROUP_CREATOR = "Frank Oz";
    final String TEST_WORK_CREATOR_GROUP_CREATOR_TYPE = "director";
    final String TEST_WORK_PUBLISHER_GROUP_PUBLISHER = "TriStar Pictures";
    final String TEST_WORK_PUBLISHER_GROUP_PUBLISHER_TYPE = "Distributor";
    final String TEST_WORK_SHORT_IDENTIFIER = "muppetstakemanhattan";
    final String TEST_WORK_REFNAME = "refname";
    
    /** The known resource id. */
    private String knownResourceShortIdentifer = null;
    private String knownResourceRefName = null;
    private String knownWorkTypeRefName = null;
    
    /* (non-Javadoc)
     * @see org.collectionspace.services.client.test.BaseServiceTest#getClientInstance()
     */
    @Override
    protected CollectionSpaceClient getClientInstance() {
        return new WorkAuthorityClient();
    }

        @Override
        protected CollectionSpaceClient getClientInstance(String clientPropertiesFilename) {
        return new WorkAuthorityClient(clientPropertiesFilename);
        }

    /**
     * Creates the item in authority.
     *
     * @param vcsid the vcsid
     * @param authRefName the auth ref name
     * @return the string
     */
    private String createItemInAuthority(AuthorityClient client, String vcsid, String authRefName) {
        final String testName = "createItemInAuthority("+vcsid+","+authRefName+")"; 
    
        // Submit the request to the service and store the response.
        Map<String, String> workMap = new HashMap<String,String>();
        // TODO Make work type and status be controlled vocabs.
        workMap.put(WorkJAXBSchema.SHORT_IDENTIFIER, TEST_WORK_SHORT_IDENTIFIER);
        workMap.put(WorkJAXBSchema.WORK_TYPE, TEST_WORK_TYPE);
        workMap.put(WorkJAXBSchema.WORK_HISTORY_NOTE, TEST_WORK_HISTORY_NOTE);
        
        List<WorkTermGroup> terms = new ArrayList<WorkTermGroup>();
        WorkTermGroup term = new WorkTermGroup();
        term.setTermDisplayName(TEST_WORK_TERM_DISPLAY_NAME);
        term.setTermName(TEST_WORK_TERM_NAME);
        term.setTermSource(TEST_WORK_TERM_SOURCE);
        term.setTermSourceDetail(TEST_WORK_TERM_SOURCE_DETAIL);
        term.setTermStatus(TEST_WORK_TERM_STATUS);
        terms.add(term);
        
        String newID = WorkAuthorityClientUtils.createItemInAuthority(vcsid,
                authRefName, workMap, terms, (WorkAuthorityClient)client);    

        // Store the ID returned from the first item resource created
        // for additional tests below.
        if (knownItemResourceId == null){
            setKnownItemResource(newID, TEST_WORK_SHORT_IDENTIFIER);
            if (logger.isDebugEnabled()) {
                logger.debug(testName + ": knownItemResourceId=" + newID);
            }
        }
        
        // Store the IDs from any item resources created
        // by tests, along with the IDs of their parents, so these items
        // can be deleted after all tests have been run.
        allResourceItemIdsCreated.put(newID, vcsid);

        return newID;
    }

    /**
     * Verify illegal item display name.
     *
     * @param testName the test name
     * @throws Exception the exception
     */
    @Test(dataProvider="testName")
        public void verifyIllegalItemDisplayName(String testName) throws Exception {
                // Perform setup for read.
                setupRead();

                // Submit the request to the service and store the response.
                WorkAuthorityClient client = new WorkAuthorityClient();
                Response res = client.readItem(knownResourceId, knownItemResourceId);
                WorksCommon work = null;
                try {
                        assertStatusCode(res, testName);
                        PoxPayloadIn input = new PoxPayloadIn(res.readEntity(String.class));
                        work = (WorksCommon) extractPart(input,
                                        client.getItemCommonPartName(), WorksCommon.class);
                        Assert.assertNotNull(work);
                } finally {
                        if (res != null) {
                                res.close();
                        }
                }

                //
                // Make an invalid UPDATE request, without a display name
                //
                WorkTermGroupList termList = work.getWorkTermGroupList();
                Assert.assertNotNull(termList);
                List<WorkTermGroup> terms = termList.getWorkTermGroup();
                Assert.assertNotNull(terms);
                Assert.assertTrue(terms.size() > 0);
                terms.get(0).setTermDisplayName(null);
                terms.get(0).setTermName(null);

                setupUpdateWithInvalidBody(); // we expect a failure

                // Submit the updated resource to the service and store the response.
                PoxPayloadOut output = new PoxPayloadOut(
                                WorkAuthorityClient.SERVICE_ITEM_PAYLOAD_NAME);
                PayloadOutputPart commonPart = output.addPart(
                                client.getItemCommonPartName(), work);
                setupUpdateWithInvalidBody(); // we expected a failure here.
                res = client.updateItem(knownResourceId, knownItemResourceId, output);
                try {
                        assertStatusCode(res, testName);
                } finally {
                        if (res != null) {
                                res.close();
                        }
                }
        }

    /**
     * Read item list.
     */
    @Test(dataProvider = "testName", groups = {"readList"},
               dependsOnMethods = {"readList"})
    public void readItemList(String testName) {
        readItemList(knownAuthorityWithItems, null);
    }

    /**
     * Read item list by authority name.
     */
    @Test(dataProvider = "testName", groups = {"readList"},
            dependsOnMethods = {"readItemList"})
    public void readItemListByAuthorityName(String testName) {
        readItemList(null, READITEMS_SHORT_IDENTIFIER);
    }
    
    /**
     * Read item list.
     * 
     * @param vcsid
     *            the vcsid
     * @param name
     *            the name
     */
    private void readItemList(String vcsid, String shortId) {
        String testName = "readItemList";

        // Perform setup.
        setupReadList();

        // Submit the request to the service and store the response.
        WorkAuthorityClient client = new WorkAuthorityClient();
        Response res = null;
        if (vcsid != null) {
            res = client.readItemList(vcsid, null, null);
        } else if (shortId != null) {
            res = client.readItemListForNamedAuthority(shortId, null, null);
        } else {
            Assert.fail("readItemList passed null csid and name!");
        }
        
        AbstractCommonList list = null;
        try {
            assertStatusCode(res, testName);
            list = res.readEntity(AbstractCommonList.class);
        } finally {
            if (res != null) {
                res.close();
            }
        }
        
        List<AbstractCommonList.ListItem> items = list.getListItem();
        int nItemsReturned = items.size();
        // There will be 'nItemsToCreateInList'
        // items created by the createItemList test,
        // all associated with the same parent resource.
        int nExpectedItems = nItemsToCreateInList;
        if (logger.isDebugEnabled()) {
            logger.debug(testName + ": Expected " + nExpectedItems
                    + " items; got: " + nItemsReturned);
        }
        Assert.assertEquals(nItemsReturned, nExpectedItems);

        for (AbstractCommonList.ListItem item : items) {
            String value = AbstractCommonListUtils.ListItemGetElementValue(
                    item, WorkJAXBSchema.REF_NAME);
            Assert.assertTrue((null != value), "Item refName is null!");
            value = AbstractCommonListUtils.ListItemGetElementValue(item,
                    WorkJAXBSchema.WORK_TERM_DISPLAY_NAME);
            Assert.assertTrue((null != value), "Item termDisplayName is null!");
        }
        if (logger.isTraceEnabled()) {
            AbstractCommonListUtils.ListItemsInAbstractCommonList(list, logger,
                    testName);
        }
    }

    @Override
    public void delete(String testName) throws Exception {
        // Do nothing.  See localDelete().  This ensure proper test order.
    }
    
    @Test(dataProvider = "testName", dependsOnMethods = {"localDeleteItem"})    
    public void localDelete(String testName) throws Exception {
        super.delete(testName);
    }

    @Override
    public void deleteItem(String testName) throws Exception {
        // Do nothing.  We need to wait until after the test "localDelete" gets run.  When it does,
        // its dependencies will get run first and then we can call the base class' delete method.
    }
    
    @Test(dataProvider = "testName", groups = {"delete"},
        dependsOnMethods = {"verifyIllegalItemDisplayName"})
    public void localDeleteItem(String testName) throws Exception {
        super.deleteItem(testName);
    }
    
    // ---------------------------------------------------------------
    // Cleanup of resources created during testing
    // ---------------------------------------------------------------
    
    /**
     * Deletes all resources created by tests, after all tests have been run.
     *
     * This cleanup method will always be run, even if one or more tests fail.
     * For this reason, it attempts to remove all resources created
     * at any point during testing, even if some of those resources
     * may be expected to be deleted by certain tests.
     */

    @AfterClass(alwaysRun=true)
    public void cleanUp() {
        String noTest = System.getProperty("noTestCleanup");
        if(Boolean.TRUE.toString().equalsIgnoreCase(noTest)) {
            if (logger.isDebugEnabled()) {
                logger.debug("Skipping Cleanup phase ...");
            }
            return;
        }
        if (logger.isDebugEnabled()) {
            logger.debug("Cleaning up temporary resources created for testing ...");
        }
        String parentResourceId;
        String itemResourceId;
        // Clean up contact resources.
        WorkAuthorityClient client = new WorkAuthorityClient();
        parentResourceId = knownResourceId;
        // Clean up item resources.
        for (Map.Entry<String, String> entry : allResourceItemIdsCreated.entrySet()) {
            itemResourceId = entry.getKey();
            parentResourceId = entry.getValue();
            // Note: Any non-success responses from the delete operation
            // below are ignored and not reported.
            client.deleteItem(parentResourceId, itemResourceId).close();
        }
        // Clean up parent resources.
        for (String resourceId : allResourceIdsCreated) {
            // Note: Any non-success responses from the delete operation
            // below are ignored and not reported.
        client.delete(resourceId).close();
        }
    }

    // ---------------------------------------------------------------
    // Utility methods used by tests above
    // ---------------------------------------------------------------
    /* (non-Javadoc)
     * @see org.collectionspace.services.client.test.BaseServiceTest#getServicePathComponent()
     */

    /**
     * Returns the root URL for the item service.
     *
     * This URL consists of a base URL for all services, followed by
     * a path component for the owning parent, followed by the
     * path component for the items.
     *
     * @param  parentResourceIdentifier  An identifier (such as a UUID) for the
     * parent authority resource of the relevant item resource.
     *
     * @return The root URL for the item service.
     */
    protected String getItemServiceRootURL(String parentResourceIdentifier) {
        return getResourceURL(parentResourceIdentifier) + "/" + getItemServicePathComponent();
    }

    /**
     * Returns the URL of a specific item resource managed by a service, and
     * designated by an identifier (such as a universally unique ID, or UUID).
     *
     * @param  parentResourceIdentifier  An identifier (such as a UUID) for the
     * parent authority resource of the relevant item resource.
     *
     * @param  itemResourceIdentifier  An identifier (such as a UUID) for an
     * item resource.
     *
     * @return The URL of a specific item resource managed by a service.
     */
    protected String getItemResourceURL(String parentResourceIdentifier, String itemResourceIdentifier) {
        return getItemServiceRootURL(parentResourceIdentifier) + "/" + itemResourceIdentifier;
    }

        @Override
    public void authorityTests(String testName) {
        // TODO Auto-generated method stub
        
    }

    //
    // Work specific overrides
    //
    
    @Override
    protected PoxPayloadOut createInstance(String commonPartName,
            String identifier) {
        // Submit the request to the service and store the response.
        String shortId = identifier;
        String displayName = "displayName-" + shortId;
        // String baseRefName = WorkAuthorityClientUtils.createWorkAuthRefName(shortId, null);      
        PoxPayloadOut result = 
            WorkAuthorityClientUtils.createWorkAuthorityInstance(
            displayName, shortId, commonPartName);
        return result;
    }
    
    @Override
    protected PoxPayloadOut createNonExistenceInstance(String commonPartName, String identifier) {
        String displayName = "displayName-NON_EXISTENT_ID";
        PoxPayloadOut result = WorkAuthorityClientUtils.createWorkAuthorityInstance(
                    displayName, "nonEx", commonPartName);
        return result;
    }

    @Override
    protected WorkauthoritiesCommon updateInstance(WorkauthoritiesCommon workauthoritiesCommon) {
        WorkauthoritiesCommon result = new WorkauthoritiesCommon();
        
        result.setDisplayName("updated-" + workauthoritiesCommon.getDisplayName());
        result.setVocabType("updated-" + workauthoritiesCommon.getVocabType());
        
        return result;
    }

    @Override
    protected void compareUpdatedInstances(WorkauthoritiesCommon original,
            WorkauthoritiesCommon updated) throws Exception {
        Assert.assertEquals(updated.getDisplayName(),
                original.getDisplayName(),
                "Display name in updated object did not match submitted data.");
    }

    protected void compareReadInstances(WorkauthoritiesCommon original,
            WorkauthoritiesCommon fromRead) throws Exception {
        Assert.assertNotNull(fromRead.getDisplayName());
        Assert.assertNotNull(fromRead.getShortIdentifier());
        Assert.assertNotNull(fromRead.getRefName());
    }
    
    //
    // Authority item specific overrides
    //
    
    @Override
    protected String createItemInAuthority(AuthorityClient client, String authorityId) {
        return createItemInAuthority(client, authorityId, null /*refname*/);
    }

    @Override
    protected WorksCommon updateItemInstance(WorksCommon worksCommon) {
                            
            WorkTermGroupList termList = worksCommon.getWorkTermGroupList();
            Assert.assertNotNull(termList);
            List<WorkTermGroup> terms = termList.getWorkTermGroup();
            Assert.assertNotNull(terms);
            Assert.assertTrue(terms.size() > 0);
            terms.get(0).setTermDisplayName("updated-" + terms.get(0).getTermDisplayName());
            terms.get(0).setTermName("updated-" + terms.get(0).getTermName());
            worksCommon.setWorkTermGroupList(termList);

            return worksCommon;
    }

    @Override
    protected void compareUpdatedItemInstances(WorksCommon original,
            WorksCommon updated) throws Exception {
            
            WorkTermGroupList originalTermList = original.getWorkTermGroupList();
            Assert.assertNotNull(originalTermList);
            List<WorkTermGroup> originalTerms = originalTermList.getWorkTermGroup();
            Assert.assertNotNull(originalTerms);
            Assert.assertTrue(originalTerms.size() > 0);
            
            WorkTermGroupList updatedTermList = updated.getWorkTermGroupList();
            Assert.assertNotNull(updatedTermList);
            List<WorkTermGroup> updatedTerms = updatedTermList.getWorkTermGroup();
            Assert.assertNotNull(updatedTerms);
            Assert.assertTrue(updatedTerms.size() > 0);
            
            Assert.assertEquals(updatedTerms.get(0).getTermDisplayName(),
                originalTerms.get(0).getTermDisplayName(),
                "Value in updated record did not match submitted data.");
    }

    @Override
    protected void verifyReadItemInstance(WorksCommon item)
            throws Exception {
        // TODO Auto-generated method stub
        
    }

    @Override
    protected PoxPayloadOut createNonExistenceItemInstance(
            String commonPartName, String identifier) {
        Map<String, String> nonexMap = new HashMap<String,String>();
        nonexMap.put(WorkJAXBSchema.WORK_TERM_DISPLAY_NAME, TEST_WORK_TERM_DISPLAY_NAME);
        nonexMap.put(WorkJAXBSchema.SHORT_IDENTIFIER, "nonEx");
        nonexMap.put(WorkJAXBSchema.WORK_TERM_STATUS, TEST_WORK_TERM_STATUS);
        final String EMPTY_REFNAME = "";
        PoxPayloadOut result = 
                WorkAuthorityClientUtils.createWorkInstance(EMPTY_REFNAME, nonexMap,
                WorkAuthorityClientUtils.getTermGroupInstance(TEST_WORK_TERM_DISPLAY_NAME), commonPartName);
        return result;
    }
}