refactor to move server-side code to server subpackage, add creation of client-only jar file

/*

************************************************************************

*******************  CANADIAN ASTRONOMY DATA CENTRE  *******************

**************  CENTRE CANADIEN DE DONNÉES ASTRONOMIQUES  **************

*

*  (c) 2009.                            (c) 2009.

*  Government of Canada                 Gouvernement du Canada

*  National Research Council            Conseil national de recherches

*  Ottawa, Canada, K1A 0R6              Ottawa, Canada, K1A 0R6

*  All rights reserved                  Tous droits réservés

*

*  NRC disclaims any warranties,        Le CNRC dénie toute garantie

*  expressed, implied, or               énoncée, implicite ou légale,

*  statutory, of any kind with          de quelque nature que ce

*  respect to the software,             soit, concernant le logiciel,

*  including without limitation         y compris sans restriction

*  any warranty of merchantability      toute garantie de valeur

*  or fitness for a particular          marchande ou de pertinence

*  purpose. NRC shall not be            pour un usage particulier.

*  liable in any event for any          Le CNRC ne pourra en aucun cas

*  damages, whether direct or           être tenu responsable de tout

*  indirect, special or general,        dommage, direct ou indirect,

*  consequential or incidental,         particulier ou général,

*  arising from the use of the          accessoire ou fortuit, résultant

*  software.  Neither the name          de l'utilisation du logiciel. Ni

*  of the National Research             le nom du Conseil National de

*  Council of Canada nor the            Recherches du Canada ni les noms

*  names of its contributors may        de ses  participants ne peuvent

*  be used to endorse or promote        être utilisés pour approuver ou

*  products derived from this           promouvoir les produits dérivés

*  software without specific prior      de ce logiciel sans autorisation

*  written permission.                  préalable et particulière

*                                       par écrit.

*

*  This file is part of the             Ce fichier fait partie du projet

*  OpenCADC project.                    OpenCADC.

*

*  OpenCADC is free software:           OpenCADC est un logiciel libre ;

*  you can redistribute it and/or       vous pouvez le redistribuer ou le

*  modify it under the terms of         modifier suivant les termes de

*  the GNU Affero General Public        la “GNU Affero General Public

*  License as published by the          License” telle que publiée

*  Free Software Foundation,            par la Free Software Foundation

*  either version 3 of the              : soit la version 3 de cette

*  License, or (at your option)         licence, soit (à votre gré)

*  any later version.                   toute version ultérieure.

*

*  OpenCADC is distributed in the       OpenCADC est distribué

*  hope that it will be useful,         dans l’espoir qu’il vous

*  but WITHOUT ANY WARRANTY;            sera utile, mais SANS AUCUNE

*  without even the implied             GARANTIE : sans même la garantie

*  warranty of MERCHANTABILITY          implicite de COMMERCIALISABILITÉ

*  or FITNESS FOR A PARTICULAR          ni d’ADÉQUATION À UN OBJECTIF

*  PURPOSE.  See the GNU Affero         PARTICULIER. Consultez la Licence

*  General Public License for           Générale Publique GNU Affero

*  more details.                        pour plus de détails.

*

*  You should have received             Vous devriez avoir reçu une

*  a copy of the GNU Affero             copie de la Licence Générale

*  General Public License along         Publique GNU Affero avec

*  with OpenCADC.  If not, see          OpenCADC ; si ce n’est

*  <http://www.gnu.org/licenses/>.      pas le cas, consultez :

*                                       <http://www.gnu.org/licenses/>.

*

*  $Revision: 4 $

*

************************************************************************

*/

package ca.nrc.cadc.vos.util;

import java.util.Collection;

import java.util.Comparator;

import java.util.TreeSet;

/**

 * Implementation of a TreeSet with a settable upper size limit.

 * 

 * @author jburke

 * @param <E>

 */

public class FixedSizeTreeSet<E> extends TreeSet<E>

{

    // The maximum size of the Set.

    private int maxSize = Integer.MAX_VALUE;

    /**

     * Set the maximum size of the TreeSet.

     *

     * @param maxSize The maximum size of the Set.

     */

    public void setMaxSize(int maxSize)

    {

        this.maxSize = maxSize;

    }

    /**

     * Add the specified element to the TreeSet.

     *

     * @param e The element to add.

     * @return true if the Set is changed as a result of the add, false otherwise.

     */

    @Override

    public boolean add(E e)

    {

        boolean changed = super.add(e);

        while (size() > maxSize)

        {

            pollLast();

        }

        return changed;

    }

    /**

     * Add the specified Collection to the TreeSet.

     * 

     * @param c The Collection to add.

     * @return true if the Set is changed as a result of the add, false otherwise.

     */

    @Override

    public boolean addAll(Collection<? extends E> c)

    {

        boolean changed = super.addAll(c);

        while (size() > maxSize)

        {

            pollLast();

        }

        return changed;

    }

}

package ca.nrc.cadc.vos;

import static org.junit.Assert.assertEquals;

import java.nio.charset.Charset;

import java.security.MessageDigest;

import org.junit.Before;

import org.junit.Test;

import ca.nrc.cadc.util.FileMetadata;

public abstract class VOSpaceFileMetadataSourceTest extends AbstractPersistenceTest

{

    private VOSpaceFileMetadataSource vospaceFileMetadataSource;

    private VOSURI testURI;

    private DataNode testNode;

    public VOSpaceFileMetadataSourceTest()

    {

        super();

    }

    @Before

    public void before() throws Exception

    {

        super.commonBefore();

        vospaceFileMetadataSource = new VOSpaceFileMetadataSource();

        vospaceFileMetadataSource.setNodePersistence(nodeDAO);

        ContainerNode rootContainer = (ContainerNode) nodeDAO.getFromParent(getRootContainerName(), null);

        testURI = new VOSURI(getVOSURIPrefix() + "/" + getRootContainerName() + "/" + getNodeName("testNode"));

        testNode = new DataNode(testURI);

        testNode.setOwner(getNodeOwner());

        nodeDAO.putInContainer(testNode, rootContainer);

    }

    @Test

    public void testMetadata() throws Exception

    {

        String contentEncoding = "gzip";

        Long contentLength = 256L;

        String contentType = "text/xml";

        String md5SumSource = "valuetohashis a longer string now.";

        MessageDigest md = MessageDigest.getInstance("MD5");

        md.reset();

        md.update(md5SumSource.getBytes("iso-8859-1"), 0, md5SumSource.length());

        byte[] md5hash = md.digest();

        String contentMD5 = new String(md5hash, Charset.forName("iso-8859-1"));

        FileMetadata metadata1 = new FileMetadata();

        metadata1.setContentEncoding(contentEncoding);

        metadata1.setContentLength(contentLength);

        metadata1.setContentType(contentType);

        metadata1.setMd5Sum(contentMD5);

        vospaceFileMetadataSource.set(testURI.getURIObject(), metadata1);

        FileMetadata metadata2 = vospaceFileMetadataSource.get(testURI.getURIObject());

        assertEquals(contentEncoding, metadata2.getContentEncoding());

        assertEquals(contentLength, metadata2.getContentLength());

        assertEquals(contentType, metadata2.getContentType());

        assertEquals(contentMD5, metadata2.getMd5Sum());

    }

}